using SequencerIdProvider,

removed .vscode/launch.json

Author: Raunaque97

.vscode/launch.json

@@ -5,6 +5,7 @@ import {
   SequencerModule,
   TaskPayload,
   TaskQueue,
+  SequencerIdProvider,
 } from "@proto-kit/sequencer";
 import { log } from "@proto-kit/common";
 import { inject } from "tsyringe";
@@ -22,7 +23,8 @@ export class IndexerNotifier extends SequencerModule<Record<never, never>> {
     public sequencer: Sequencer<NotifierMandatorySequencerModules>,
     @inject("TaskQueue")
     public taskQueue: TaskQueue,
-    public indexBlockTask: IndexBlockTask
+    public indexBlockTask: IndexBlockTask,
+    private readonly sequencerIdProvider: SequencerIdProvider
   ) {
     super();
   }
@@ -37,7 +39,7 @@ export class IndexerNotifier extends SequencerModule<Record<never, never>> {
         block.block.height.toBigInt()
       );
       const payload = await inputSerializer.toJSON(block);
-      const sequencerId = this.sequencer.id;
+      const sequencerId = this.sequencerIdProvider.getSequencerId();
 
       const task: TaskPayload = {
         name: this.indexBlockTask.name,

packages/indexer/src/IndexerNotifier.ts

@@ -5,6 +5,7 @@ export * from "./mempool/CompressedSignature";
 export * from "./mempool/private/PrivateMempool";
 export * from "./sequencer/executor/Sequencer";
 export * from "./sequencer/executor/Sequenceable";
+export * from "./sequencer/SequencerIdProvider";
 export * from "./sequencer/builder/SequencerModule";
 export * from "./sequencer/builder/Closeable";
 export * from "./worker/flow/Flow";

packages/sequencer/src/index.ts

@@ -0,0 +1,17 @@
+import { injectable, scoped, Lifecycle, singleton } from "tsyringe";
+import { Field } from "o1js";
+
+@injectable()
+@singleton()
+export class SequencerIdProvider {
+  private readonly sequencerId: string;
+
+  public constructor() {
+    this.sequencerId = Field.random().toString();
+  }
+
+  public getSequencerId(): string {
+    return this.sequencerId;
+  }
+}
+

packages/sequencer/src/sequencer/SequencerIdProvider.ts

@@ -17,7 +17,6 @@ import {
   ProtocolModulesRecord,
 } from "@proto-kit/protocol";
 import { injectable } from "tsyringe";
-import { Field } from "o1js";
 
 import { SequencerModule } from "../builder/SequencerModule";
 import { Closeable } from "../builder/Closeable";
@@ -36,11 +35,8 @@ export class Sequencer<Modules extends SequencerModulesRecord>
   extends ModuleContainer<Modules>
   implements Sequenceable
 {
-  public readonly id: string;
-
   public constructor(definition: Modules) {
     super(definition);
-    this.id = Field.random().toString();
   }
 
   /**

packages/sequencer/src/sequencer/executor/Sequencer.ts

@@ -3,7 +3,7 @@ import { log, mapSequential } from "@proto-kit/common";
 
 import { InstantiatedQueue, TaskQueue } from "../queue/TaskQueue";
 import { Closeable } from "../../sequencer/builder/Closeable";
-import type { Sequencer } from "../../sequencer/executor/Sequencer";
+import { SequencerIdProvider } from "../../sequencer/SequencerIdProvider";
 
 import { Task, TaskPayload } from "./Task";
 
@@ -186,10 +186,15 @@ export class Flow<State> implements Closeable {
 export class FlowCreator {
   public constructor(
     @inject("TaskQueue") private readonly queueImpl: TaskQueue,
-    @inject("Sequencer") private readonly sequencer: Sequencer<any>
+    private readonly sequencerIdProvider: SequencerIdProvider
   ) {}
 
   public createFlow<State>(flowId: string, state: State): Flow<State> {
-    return new Flow(this.queueImpl, flowId, state, this.sequencer.id);
+    return new Flow(
+      this.queueImpl,
+      flowId,
+      state,
+      this.sequencerIdProvider.getSequencerId()
+    );
   }
 }

packages/sequencer/src/worker/flow/Flow.ts

@@ -90,7 +90,6 @@ describe("ReductionTaskFlow", () => {
     di.register("TaskQueue", {
       useValue: queue,
     });
-    di.register("Sequencer", { useValue: { id: "1" } });
 
     const worker = new FlowTaskWorker(di.resolve("TaskQueue"), [
       di.resolve(NumberIdentityTask),

packages/sequencer/test/protocol/production/flow/ReductionTaskFlow.test.ts

@@ -226,7 +226,6 @@ describe("flow", () => {
       await worker.start();
 
       container.register("TaskQueue", { useValue: queue });
-      container.register("Sequencer", { useValue: { id: "1" } });
       const flowCreator = container.resolve(FlowCreator);
 
       const flow = flowCreator.createFlow("1", {