Working first version

packages/apps/graph/package.json

@@ -9,14 +9,14 @@
   "main": "index.js",
   "scripts": {
     "build": "pnpm prisma:generate && heft build --clean",
+    "devnet": "docker run -it -p 8080:8080 -p 5432:5432 -p 9999:9999 -v $HOME/.kda-devnet/data:/data -v ./cwd-extra-migrations:/cwd-extra-migrations enof/devnet:l2-latest-arm64",
+    "devnet:update": "docker pull enof/devnet:l2-latest",
     "format": "pnpm run /^format:.*/",
     "format:src": "prettier config src --write",
     "lint": "eslint package.json src --ext .js,.ts --fix",
     "prisma:generate": "prisma generate",
     "prisma:pull": "prisma db pull",
     "prisma:studio": "prisma studio",
-    "devnet": "docker run -it -p 8080:8080 -p 5432:5432 -p 9999:9999 -v $HOME/.kda-devnet/data:/data -v ./cwd-extra-migrations:/cwd-extra-migrations enof/devnet:l2-latest-arm64",
-    "devnet:update": "docker pull enof/devnet:l2-latest",
     "start": "pnpm run prisma:generate && npx ts-node-dev --respawn --no-notify --exit-child src/index.ts",
     "test": "echo \"no test specified\""
   },

packages/apps/graph/src/graph/Subscription/transaction.ts

@@ -1,5 +1,5 @@
 import { prismaClient } from '../../db/prismaClient';
-import { builder } from '../builder';
+import { builder, Context } from '../builder';
 
 import { Transaction } from '@prisma/client';
 import _debug, { Debugger } from 'debug';
@@ -13,32 +13,30 @@ builder.subscriptionField('transaction', (t) => {
     },
     type: 'Transaction',
     nullable: true,
-    subscribe: (parent, args, context, info) => iteratorFn(args.requestKey),
+    subscribe: (parent, args, context, info) =>
+      iteratorFn(args.requestKey, context),
     resolve: (__, transaction) => transaction,
   });
 });
 
 async function* iteratorFn(
   requestKey: string,
-): AsyncGenerator<Transaction, void, unknown> {
-  console.log('iteratorFn', requestKey);
-  log('iteratorFn', requestKey);
-  while (true) {
+  context: Context,
+): AsyncGenerator<Transaction | null, void, unknown> {
+  while (!context.req.socket.destroyed) {
     const transaction = await prismaClient.transaction.findFirst({
       where: {
         requestkey: requestKey,
       },
     });
 
     if (transaction) {
-      console.log('transaction found', transaction);
       log('transaction found', transaction);
       yield transaction;
       return;
     }
 
-    console.log('waiting for transaction ' + requestKey);
-    log('waiting for transaction ' + requestKey);
+    log(`waiting for transaction ${requestKey}`);
     await new Promise((resolve) => setTimeout(resolve, 1000));
   }
-}
+}

packages/apps/graph/src/graph/builder.ts

@@ -10,6 +10,7 @@ import {
   DateTimeResolver,
   PositiveFloatResolver,
 } from 'graphql-scalars';
+import { IncomingMessage } from 'http';
 
 interface IDefaultTypesExtension {
   Scalars: {
@@ -28,10 +29,15 @@ interface IDefaultTypesExtension {
   };
 }
 
+export interface Context {
+  req: IncomingMessage;
+}
+
 // eslint-disable-next-line @rushstack/typedef-var
 export const builder = new SchemaBuilder<
   IDefaultTypesExtension & {
     PrismaTypes: PrismaTypes;
+    Context: Context;
   }
 >({
   plugins: [RelayPlugin, PrismaPlugin],

packages/apps/graph/src/utils/dev-database/startEmbeddedPostgres.ts

@@ -73,8 +73,8 @@ export async function startDevelopmentWorker(): Promise<void> {
               )
               .catch(console.error);
 
-            if (i > 38 && statements.length > 0) {
-              await new Promise((resolve) => setTimeout(resolve, 5000));
+            if (i > 5 && statements.length > 0) {
+              await new Promise((resolve) => setTimeout(resolve, 2000));
             }
             i++;
           }