Merge pull request #6 from quiknode-labs/sc-63518-marketplace-starter…

…-js-missing-transformer

[sc-63518] add Marketplace starter JS missing transformer

package.json

@@ -11,6 +11,7 @@
   "author": "Luc Castera <[email protected]> (https://github.com/luccastera)",
   "license": "MIT",
   "dependencies": {
+    "axios": "^1.4.0",
     "cors": "^2.8.5",
     "dotenv": "^16.0.3",
     "express": "^4.18.2",

src/routes/rpc.js

@@ -2,7 +2,8 @@ import { Router } from "express";
 
 const router = Router();
 
-import models, { sequelize } from "../models";
+import models from "../models";
+import RPCRequestTranslator from "../translator";
 
 router.post("/", async (request, response) => {
   console.log(request.body);
@@ -53,13 +54,19 @@ router.post("/", async (request, response) => {
     } else {
       // If you need to make a request to the QuickNode endpoint here,
       // then you can use endpoint.get('http_url') to get the URL of the endpoint.
+      const newTranslator = new RPCRequestTranslator();
+      const translatedRequestResponse = await newTranslator.translateRequest(
+        rpcMethod,
+        rpcParams
+      );
 
       response.status(200).json({
         id: 1,
         result: {
           message: "Welcome to the JSON-RPC API.",
           method: rpcMethod,
           params: rpcParams,
+          result: translatedRequestResponse,
         },
         jsonrpc: "2.0",
       });

src/translator.js

@@ -0,0 +1,31 @@
+import axios from "axios"; // Import the Axios library
+
+class RPCRequestTranslator {
+  constructor() {
+    this.API_BASE_URL = "http://example.com/";
+    this.METHOD_PATHS = { qn_test: "" };
+  }
+
+  async translateRequest(rpcMethod, rpcParams) {
+    console.log("  matched method to: " + this.METHOD_PATHS[rpcMethod]);
+    const translatedRequest = {
+      method: "get",
+      url: `${this.API_BASE_URL}${this.METHOD_PATHS[rpcMethod]}`,
+      body: rpcParams,
+      headers: {
+        "Content-Type": "application/json",
+        "X-Custom-Header": "some-value",
+      },
+    };
+
+    try {
+      // Use the Axios library to perform the translated request
+      const response = await axios(translatedRequest);
+      return response.data;
+    } catch (error) {
+      throw new Error(`Error performing request: ${error.message}`);
+    }
+  }
+}
+
+export default RPCRequestTranslator;