Reputation query pass-through

Author: area

packages/reputation-miner/bin/forked.js

@@ -1,5 +1,7 @@
 const hre = require("hardhat");
 const path = require("path");
+const express = require("express");
+const axios = require("axios")
 
 const { argv } = require("yargs")
   .option('privateKey', {string:true})
@@ -44,13 +46,62 @@ const client = new ReputationMinerClient({
   oracle,
   exitOnError,
   adapter: adapterObject,
-  oraclePort,
+  oraclePort: 3001,
   processingDelay
 });
 
 async function main() {
   await client.initialise(colonyNetworkAddress, syncFrom);
   client._miner.realWallet = await ethers.getImpersonatedSigner(minerAddress);
+
+  if (oracle) {
+    // Start a forked oracle. This will query our local node, and if that fails, query upstream.
+
+    this._app = express();
+
+    this._app.use(function(req, res, next) {
+      res.header("Access-Control-Allow-Origin", "*");
+      next();
+    });
+
+    this._app.get("/favicon.ico", (req, res) => {
+      res.status(204).end();
+    });
+
+    this._app.get("/", (req, res) => {
+      res.status(204).end();
+    });
+
+
+    this._app.get("*", async (req, res) => {
+
+      try {
+        const { data } = await axios.get(`http://localhost:${3001}/${req.originalUrl}`);
+        res.send(data);
+      } catch (e) {
+        console.log('Local reputation request failed, try upstream URL:');
+        // If the local oracle fails, query the upstream oracle.
+        console.log(`${process.env.REPUTATION_URL}/${req.originalUrl}`)
+        try {
+
+          const { data } = await axios({
+            url: `${process.env.REPUTATION_URL}/${req.originalUrl}`,
+            responseType: "stream",
+          });
+
+          res.send(data);
+        } catch (e2) {
+          console.log('Upstream reputation request failed');
+          res.status(500).send(e2);
+        }
+      }
+    });
+
+
+    this._app.listen(oraclePort || 3000, () => {
+      console.log(`Forked (pass-through) oracle listening on port ${oraclePort || 3000}`);
+    });
+  }
 }
 
 main();

packages/reputation-miner/package.json

@@ -15,6 +15,7 @@
   "license": "ISC",
   "dependencies": {
     "apicache": "^1.6.3",
+    "axios": "^1.7.3",
     "better-sqlite3": "^9.5.0",
     "bn.js": "^5.2.1",
     "ethers": "^5.6.9",

pnpm-lock.yaml

@@ -9,14 +9,14 @@ const axios = require("axios");
 
 const provider = new ethers.providers.StaticJsonRpcProvider("http://127.0.0.1:8545");
 
-const { FORKED_NETWORK_ADDRESS, LATEST_STATE_URL } = process.env;
+const { FORKED_NETWORK_ADDRESS, REPUTATION_URL } = process.env;
 
 if (!FORKED_NETWORK_ADDRESS) {
   throw new Error("FORKED_NETWORK_ADDRESS must be set");
 }
 
-if (!LATEST_STATE_URL) {
-  throw new Error("LATEST_STATE_URL must be set");
+if (!REPUTATION_URL) {
+  throw new Error("REPUTATION_URL must be set");
 }
 
 let signer;
@@ -125,7 +125,7 @@ async function main() {
 
   const response = await axios({
     method: "GET",
-    url: LATEST_STATE_URL,
+    url: `${REPUTATION_URL}/latestState`,
     responseType: "stream",
   });