Fixed run-graphql to test metrics

Author: rpanic

packages/stack/package.json

@@ -11,7 +11,7 @@
     "test:file": "node --experimental-vm-modules ../../node_modules/jest/bin/jest.js",
     "test": "npm run test:file -- ./test/**",
     "test:watch": "npm run test:file -- ./test/** --watch",
-    "graphql": "npm run build && node --experimental-vm-modules --experimental-wasm-modules --experimental-wasm-threads --es-module-specifier-resolution=node ./dist/src/scripts/graphql/run-graphql.js",
+    "graphql": "npm run build && node --experimental-vm-modules --experimental-wasm-modules --es-module-specifier-resolution=node ./dist/scripts/graphql/run-graphql.js",
     "start": "node --experimental-vm-modules --es-module-specifier-resolution=node ./dist/start.js"
   },
   "main": "dist/index.js",

packages/stack/src/scripts/graphql/run-graphql.ts

@@ -1,3 +1,4 @@
+#!/usr/bin/env ts-node
 import "reflect-metadata";
 
 import { sleep } from "@proto-kit/common";
@@ -11,3 +12,5 @@ export class SequencerStartable implements Startable {
     await sleep(100000000);
   }
 }
+
+await startServer();

packages/stack/src/scripts/graphql/server.ts

@@ -22,7 +22,7 @@ import {
   VanillaRuntimeModules,
   UInt64,
 } from "@proto-kit/library";
-import { log } from "@proto-kit/common";
+import { log, mapSequential, range } from "@proto-kit/common";
 import {
   BatchProducerModule,
   InMemoryDatabase,
@@ -35,6 +35,7 @@ import {
   BlockProducerModule,
   VanillaTaskWorkerModules,
   SequencerStartupModule,
+  TimedBlockTrigger,
 } from "@proto-kit/sequencer";
 import {
   BatchStorageResolver,
@@ -45,6 +46,7 @@ import {
   NodeStatusResolver,
   QueryGraphqlModule,
   BlockResolver,
+  OpenTelemetryServer,
 } from "@proto-kit/api";
 import { container } from "tsyringe";
 
@@ -103,16 +105,19 @@ export async function startServer() {
       modules: {
         Database: InMemoryDatabase,
         // Database: PrismaRedisDatabase,
+        OpenTelemetryServer,
 
         Mempool: PrivateMempool,
         GraphqlServer,
         LocalTaskWorkerModule: LocalTaskWorkerModule.from(
           VanillaTaskWorkerModules.withoutSettlement()
         ),
+
         BaseLayer: NoopBaseLayer,
         BatchProducerModule,
         BlockProducerModule,
-        BlockTrigger: ManualBlockTrigger,
+        // BlockTrigger: ManualBlockTrigger,
+        BlockTrigger: TimedBlockTrigger,
         TaskQueue: LocalTaskQueue,
         // SettlementModule: SettlementModule,
 
@@ -135,6 +140,7 @@ export async function startServer() {
             BlockResolver: {},
           },
         }),
+
         SequencerStartupModule,
       },
     }),
@@ -189,6 +195,8 @@ export async function startServer() {
         MerkleWitnessResolver: {},
       },
 
+      OpenTelemetryServer: {},
+
       Database: {
         // redis: {
         //   host: "localhost",
@@ -218,7 +226,10 @@ export async function startServer() {
         allowEmptyBlock: true,
       },
 
-      BlockTrigger: {},
+      BlockTrigger: {
+        blockInterval: 10000,
+        settlementInterval: 20000,
+      },
     },
 
     TransactionSender: {},
@@ -246,30 +257,31 @@ export async function startServer() {
   const as = await appChain.query.protocol.AccountState.accountState.get(
     priv.toPublicKey()
   );
-  const nonce = Number(as?.nonce.toString() ?? "0");
-
-  const tx = await appChain.transaction(
-    priv.toPublicKey(),
-    async () => {
-      await balances.addBalance(tokenId, priv.toPublicKey(), UInt64.from(1000));
-    },
-    {
-      nonce,
-    }
-  );
-  appChain.resolve("Signer").config.signer = priv;
-  await tx.sign();
-  await tx.send();
-
-  const tx2 = await appChain.transaction(
-    priv.toPublicKey(),
-    async () => {
-      await balances.addBalance(tokenId, priv.toPublicKey(), UInt64.from(1000));
-    },
-    { nonce: nonce + 1 }
-  );
-  await tx2.sign();
-  await tx2.send();
+  let nonce = Number(as?.nonce.toString() ?? "0");
+
+  setInterval(async () => {
+    const random = Math.floor(Math.random() * 5);
+    await mapSequential(range(0, random), async () => {
+      const tx = await appChain.transaction(
+        priv.toPublicKey(),
+        async () => {
+          await balances.addBalance(
+            tokenId,
+            priv.toPublicKey(),
+            UInt64.from(1000)
+          );
+        },
+        {
+          nonce,
+        }
+      );
+      appChain.resolve("Signer").config.signer = priv;
+      await tx.sign();
+      await tx.send();
+
+      nonce += 1;
+    });
+  }, 10000);
 
   return appChain;
 }

packages/stack/src/start.ts

@@ -4,15 +4,21 @@
 //   Environment,
 //   startEnvironment,
 // } from "@proto-kit/deployment";
-
+//
 // import { SequencerStartable } from "./scripts/graphql/run-graphql";
 // import { WorkerEnvironment } from "./scripts/worker";
-
+//
 // const env = Environments.from({
 //   single: Environment.from({
 //     sequencer: new SequencerStartable(),
 //   }),
 //   distributed: WorkerEnvironment,
 // });
-
+//
 // await startEnvironment(env);
+
+import { startServer } from "./scripts/graphql/server";
+import { sleep } from "@proto-kit/common";
+
+await startServer();
+await sleep(1000);

packages/stack/test/start.test.ts

@@ -0,0 +1,9 @@
+import { startServer } from "../src";
+import { sleep } from "@proto-kit/common";
+
+describe("Start", () => {
+  it("a", async () => {
+    await startServer();
+    await sleep(10000000);
+  }, 10000000);
+});