Implemented automatic block trigger

packages/sequencer/src/index.ts

@@ -28,6 +28,7 @@ export * from "./protocol/production/tasks/StateTransitionTaskParameters";
 export * from "./protocol/production/trigger/BlockTrigger";
 export * from "./protocol/production/trigger/ManualBlockTrigger";
 export * from "./protocol/production/trigger/TimedBlockTrigger";
+export * from "./protocol/production/trigger/AutomaticBlockTrigger";
 export * from "./protocol/production/BlockProducerModule";
 export * from "./protocol/production/BlockTaskFlowService";
 export * from "./protocol/production/TransactionTraceService";

packages/sequencer/src/protocol/production/trigger/AutomaticBlockTrigger.ts

@@ -0,0 +1,34 @@
+import { inject } from "tsyringe";
+import { log } from "@proto-kit/common";
+
+import { SequencerModule } from "../../../sequencer/builder/SequencerModule";
+import { UnprovenProducerModule } from "../unproven/UnprovenProducerModule";
+import { Mempool } from "../../../mempool/Mempool";
+
+import { BlockTrigger } from "./BlockTrigger";
+
+/**
+ * Only unproven invocation at the moment, because
+ * this is primarily for development and testing purposes
+ */
+export class AutomaticBlockTrigger
+  extends SequencerModule<Record<string, never>>
+  implements BlockTrigger
+{
+  public constructor(
+    @inject("UnprovenProducerModule")
+    private readonly unprovenProducerModule: UnprovenProducerModule,
+    @inject("Mempool")
+    private readonly mempool: Mempool
+  ) {
+    super();
+  }
+
+  public async start(): Promise<void> {
+    // eslint-disable-next-line @typescript-eslint/no-misused-promises
+    this.mempool.events.on("transactionAdded", async () => {
+      log.info("Transaction received, creating block...");
+      await this.unprovenProducerModule.tryProduceUnprovenBlock();
+    });
+  }
+}