Merge pull request #9 from rsksmart/feat/add-offchain-store-endpoint

Added Offchain Endpoint

Author: jonathansmirnoff

graph.ts

@@ -10,8 +10,11 @@ import {
   buildSchema,
   UseMiddleware,
 } from "type-graphql";
-import { ApolloServer } from "apollo-server";
+import { ApolloServer } from "@apollo/server";
+import express from "express";
 import { prisma } from "./db.server";
+import { expressMiddleware } from '@apollo/server/express4';
+import { storeOffchainAttestation } from "./utils";
 
 const PORT = process.env.GRAPH_PORT || 4000;
 
@@ -138,13 +141,53 @@ export async function startGraph() {
     authChecker: customAuthChecker,
   });
 
+  const app = express();
+  app.use(express.json());
+
+  app.post("/offchain/store", async (req, res) => {
+    try {
+      
+      if (!req.body.textJson) {
+        return res.status(400).json({ error: "textJson is required" });
+      }
+      
+      let parsedJson;
+      try {
+        parsedJson = typeof req.body.textJson === "string"
+          ? JSON.parse(req.body.textJson)
+          : req.body.textJson;
+      } catch (parseError) {
+        return res.status(400).json({ error: "Invalid JSON in textJson" });
+      }
+      const attestation = await storeOffchainAttestation(parsedJson);
+        
+      res.json({ status: "ok", attestation });
+    }
+    catch (error) {
+      const sanitizedError = typeof error === "string" ? error.replace(/\n|\r/g, "") : JSON.stringify(error).replace(/\n|\r/g, "");
+      console.error("Error storing offchain attestation:", sanitizedError);      
+      res.status(500).json({ error: "Internal server error" });
+    }
+  });
+
   const server = new ApolloServer({
     schema: schema,
     cache: "bounded",
     introspection: true,
-    context: () => ({ prisma }),
   });
 
-  const { url } = await server.listen(PORT);
-  console.log(`Server is running, GraphQL Playground available at ${url}`);
+  await server.start();
+  app.use(
+    '/graphql',
+    express.json({limit: '100kb'}),
+    expressMiddleware(server, {
+      context: async () => ({ prisma }),
+    })
+  );
+
+  app.listen(PORT, () => {
+    console.log(`GraphQL en http://localhost:${PORT}/graphql`);
+    console.log(`REST en http://localhost:${PORT}/offchain/store`);
+  });
 }
+

package.json

@@ -5,31 +5,32 @@
   "main": "index.js",
   "scripts": {
     "test": "echo \"Error: no test specified\" && exit 1",
-    "postinstall": "typechain --target ethers-v5 ./abis/*.json",
+    "postinstall": "typechain --target ethers-v6 ./abis/*.json",
     "start": "ts-node start.ts"
   },
   "keywords": [],
   "author": "",
   "license": "ISC",
   "dependencies": {
-    "@ethereum-attestation-service/eas-sdk": "0.28.2",
+    "@apollo/server": "4.12.1",
+    "@ethereum-attestation-service/eas-sdk": "2.7.0",
     "@prisma/client": "4.13.0",
-    "apollo-server": "^3.12.0",
+    "@typechain/ethers-v6": "^0.5.1",
     "class-validator": "^0.14.0",
     "dayjs": "^1.11.5",
     "dotenv": "^16.0.3",
-    "ethers": "^5.7.2",
+    "ethers": "6.14.3",
+    "express": "^4.18.2",
     "graphql": "^15.8.0",
     "graphql-fields": "^2.0.3",
     "p-limit": "^3.0.2",
     "prisma": "^4.13.0",
     "reflect-metadata": "^0.1.13",
     "ts-node": "^10.9.1",
     "type-graphql": "^1.1.1",
-    "typegraphql-prisma": "^0.24.7",
-    "typescript": "^4.8.4",
     "typechain": "^8.1.0",
-    "@typechain/ethers-v5": "^10.1.0"
+    "typegraphql-prisma": "^0.24.7",
+    "typescript": "^4.8.4"
   },
   "devDependencies": {
     "@types/node": "^18.8.4"

start.ts

@@ -54,18 +54,18 @@ async function go() {
 const filter = {
   topics: [
     [
-      ethers.utils.id(registeredEventSignatureV1),
-      ethers.utils.id(registeredEventSignatureV2),
-      ethers.utils.id(attestedEventSignature),
-      ethers.utils.id(revokedEventSignature),
-      ethers.utils.id(timestampEventSignature),
-      ethers.utils.id(revokedOffchainEventSignature),
+      ethers.id(registeredEventSignatureV1),
+      ethers.id(registeredEventSignatureV2),
+      ethers.id(attestedEventSignature),
+      ethers.id(revokedEventSignature),
+      ethers.id(timestampEventSignature),
+      ethers.id(revokedOffchainEventSignature),
     ],
   ],
 };
 
 if (!DISABLE_LISTENER) {
-  provider.on(filter, async (log: ethers.providers.Log) => {
+  provider.on(filter, async (log: ethers.Log) => {
     go();
   });
 }