works now

Author: saihaj

management-api/.dev.vars

@@ -1 +1,2 @@
-SVIX_TOKEN="eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpYXQiOjE3MTI3NjcxODYsImV4cCI6MjAyODEyNzE4NiwibmJmIjoxNzEyNzY3MTg2LCJpc3MiOiJzdml4LXNlcnZlciIsInN1YiI6Im9yZ18yM3JiOFlkR3FNVDBxSXpwZ0d3ZFhmSGlyTXUifQ.Gnj4vMl0qls2Q6ks690ZEUAW7h6VsgUHc6iwFWNPa1I"
+SVIX_TOKEN="eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpYXQiOjE3MTc1OTg4NzIsImV4cCI6MjAzMjk1ODg3MiwibmJmIjoxNzE3NTk4ODcyLCJpc3MiOiJzdml4LXNlcnZlciIsInN1YiI6Im9yZ18yM3JiOFlkR3FNVDBxSXpwZ0d3ZFhmSGlyTXUifQ.INXKFPcmciCj25DzB-FTDA1lvbvl1mrRrPM-WuFf6ZI"
+SF_TOKEN="eyJhbGciOiJLTVNFUzI1NiIsInR5cCI6IkpXVCJ9.eyJleHAiOjIwMzI5NTcyNjIsImp0aSI6Ijg4MGRlNTVkLTVjZDktNDY5MS04MDJjLTY1ZTBkMGI1NTgxOCIsImlhdCI6MTcxNzU5NzI2MiwiaXNzIjoiZGZ1c2UuaW8iLCJzdWIiOiIwem9qbzBmZjgxNDE5ZjA1ZTJjNjciLCJ2IjoxLCJha2kiOiJlMmZmMWFjMTZkMTczYmViYWJhNzkwZWU2OGY1YTJiOGZjZWYxMDFjODJhYTk5YmFmNzlmZjk4YzVmMGE0NGZiIiwidWlkIjoiMHpvam8wZmY4MTQxOWYwNWUyYzY3In0.Houp42QFgFbHPYzNw8ezbQ6k8YG8L82a3_SpeqWUt7agm1SHe4BqYkAp9Y23dCopoouFUQ1mXS_lpsPLrVTqIQ"

management-api/src/context.ts

@@ -5,6 +5,7 @@ export interface Env {
   DB: D1Database;
   SVIX_TOKEN: string;
   SVIX_HOST: string;
+  SF_TOKEN: string;
 }
 
 export interface Context extends Env {

management-api/src/schema/project.ts

@@ -123,7 +123,7 @@ builder.relayMutationField(
     }),
   },
   {
-    resolve: async (_parent, { input }, { db, svix, SVIX_TOKEN }) => {
+    resolve: async (_parent, { input }, { db, svix, SVIX_TOKEN, SF_TOKEN }) => {
       const configuration = await ProjectConfigurationSchema.safeParseAsync({
         ...input,
         webhookUrl: input.webhookUrl?.toString(),
@@ -132,10 +132,10 @@ builder.relayMutationField(
       if (!configuration.success) {
         throw new Error("Invalid configuration");
       }
+
       const id = uuidv4();
 
       const projectName = `${id}-${input.chain}`;
-
       const svixApp = await svix["/api/v1/app/"].post({
         headers: {
           Authorization: `Bearer ${SVIX_TOKEN}`,
@@ -191,6 +191,7 @@ builder.relayMutationField(
             appId: id,
             startBlock: input.startBlock,
             contractAddress: input.contractAddress,
+            substreamsToken: SF_TOKEN,
           }),
         },
       );

substream-listener/src/index.mts

@@ -66,7 +66,7 @@ const router = createRouter({
         return Response.json({ message: "appId is required" }, { status: 400 });
       }
 
-      if (!startBlock) {
+      if (startBlock == null) {
         return Response.json(
           { message: "startBlock is required" },
           { status: 400 },

substream-listener/src/send-webhook.mts

@@ -23,6 +23,7 @@ const OUTPUT_MODULE = "map_transfers";
 const spkgPath = path.join(
   __dirname,
   "..",
+  "..",
   "erc721-substream",
   "erc-721-v0.1.0.spkg",
 );
@@ -38,6 +39,12 @@ export async function sendWebhook({
   contractAddress: Address;
   token: string;
 }) {
+  console.log({
+    startBlock,
+    appId,
+    contractAddress,
+    token,
+  });
   const substreamPackage = await readPackage(spkgPath);
 
   if (!substreamPackage.modules) {
@@ -78,6 +85,7 @@ export async function sendWebhook({
         },
       });
     });
+    console.log(a.length);
     try {
       await Promise.all(a);
     } catch (e) {
@@ -104,8 +112,8 @@ export async function sendWebhook({
   console.time("🆗 close");
   emitter.start();
 
-  // Cancel after 3 seconds
-  setTimeout(() => {
-    emitter.cancelFn?.();
-  }, 3000);
+  // // Cancel after 3 seconds
+  // setTimeout(() => {
+  //   emitter.cancelFn?.();
+  // }, 3000);
 }