feat(transaction-pool-api): boot API server from Start handler

packages/api-transaction-pool/source/index.ts

@@ -1,3 +1,2 @@
-export * from "./identifiers.js";
 export * from "./server.js";
 export * from "./service-provider.js";

packages/api-transaction-pool/source/service-provider.ts

@@ -1,16 +1,16 @@
 import { AbstractServiceProvider, Plugins, ServerConstructor } from "@mainsail/api-common";
+import { Identifiers } from "@mainsail/contracts";
 
 import Handlers from "./handlers.js";
-import { Identifiers as ApiTransactionPoolIdentifiers } from "./identifiers.js";
 import { Server } from "./server.js";
 
 export class ServiceProvider extends AbstractServiceProvider<Server> {
  protected httpIdentifier(): symbol {
- return ApiTransactionPoolIdentifiers.HTTP;
+ return Identifiers.TransactionPool.API.HTTP;
  }
 
  protected httpsIdentifier(): symbol {
- return ApiTransactionPoolIdentifiers.HTTPS;
+ return Identifiers.TransactionPool.API.HTTPS;
  }
 
  protected getServerConstructor(): ServerConstructor<Server> {
@@ -21,6 +21,8 @@ export class ServiceProvider extends AbstractServiceProvider<Server> {
  return Handlers;
  }
 
+ public async boot(): Promise<void> {}
+
  protected getPlugins(): any[] {
  const config = this.config().get<any>("plugins");
 

packages/bootstrap/source/bootstrapper.ts

@@ -70,7 +70,7 @@ export class Bootstrapper {
  this.state.setBootstrap(false);
 
  this.validatorRepository.printLoadedValidators();
- await this.txPoolWorker.start();
+ await this.txPoolWorker.start(this.stateStore.getHeight());
 
  void this.runConsensus();
 

packages/contracts/source/contracts/api/api.ts

@@ -5,6 +5,11 @@ import { Processor } from "./rpc.js";
 
 export type ApiServer = Hapi.Server<ServerState>;
 
+export interface Server {
+ boot(): Promise<void>;
+ dispose(): Promise<void>;
+}
+
 export enum ServerType {
  Http = "HTTP",
  Https = "HTTPS",

packages/contracts/source/contracts/transaction-pool/worker.ts

@@ -11,7 +11,7 @@ export interface WorkerScriptHandler {
  commit(height: number, sendersAddresses: string[]): Promise<void>;
  setPeer(ip: string): Promise<void>;
  forgetPeer(ip: string): Promise<void>;
- start(): Promise<void>;
+ start(height: number): Promise<void>;
  reloadWebhooks(): Promise<void>;
 }
 

packages/contracts/source/identifiers.ts

@@ -253,6 +253,10 @@ export const Identifiers = {
  },
  },
  TransactionPool: {
+ API: {
+ HTTP: Symbol.for("API<TransactionPool.HTTP>"),
+ HTTPS: Symbol.for("API<TransactionPool.HTTPS>"),
+ },
  Broadcaster: Symbol("TransactionPoolBroadcaster<Broadcaster>"),
  ExpirationService: Symbol("TransactionPool<ExpirationService>"),
  Mempool: Symbol("TransactionPool<Mempool>"),

packages/transaction-pool-worker/source/handlers/start.ts

@@ -1,12 +1,32 @@
-import { inject, injectable } from "@mainsail/container";
+import { inject, injectable, tagged } from "@mainsail/container";
 import { Contracts, Identifiers } from "@mainsail/contracts";
+import { Providers } from "@mainsail/kernel";
 
 @injectable()
 export class StartHandler {
+ @inject(Identifiers.Application.Instance)
+ protected readonly app!: Contracts.Kernel.Application;
+
+ @inject(Identifiers.State.Store)
+ protected readonly store!: Contracts.State.Store;
+
  @inject(Identifiers.TransactionPool.Service)
  private readonly transactionPoolService!: Contracts.TransactionPool.Service;
 
- public async handle(): Promise<void> {
+ @inject(Identifiers.ServiceProvider.Configuration)
+ @tagged("plugin", "api-transaction-pool")
+ private readonly configuration!: Providers.PluginConfiguration;
+
+ public async handle(height: number): Promise<void> {
+ this.store.setHeight(height);
  await this.transactionPoolService.reAddTransactions();
+
+ if (this.configuration.get("server.http.enabled")) {
+ await this.app.get<Contracts.Api.Server>(Identifiers.TransactionPool.API.HTTP).boot();
+ }
+
+ if (this.configuration.get("server.https.enabled")) {
+ await this.app.get<Contracts.Api.Server>(Identifiers.TransactionPool.API.HTTPS).boot();
+ }
  }
 }

packages/transaction-pool-worker/source/worker-handler.ts

@@ -27,8 +27,8 @@ export class WorkerScriptHandler implements Contracts.TransactionPool.WorkerScri
  this.#app = app;
  }
 
- public async start(): Promise<void> {
- await this.#app.resolve(StartHandler).handle();
+ public async start(height: number): Promise<void> {
+ await this.#app.resolve(StartHandler).handle(height);
  }
 
  public async commit(height: number, sendersAddresses: string[]): Promise<void> {

packages/transaction-pool-worker/source/worker.ts

@@ -60,8 +60,8 @@ export class Worker implements Contracts.TransactionPool.Worker {
  await this.ipcSubprocess.sendRequest("commit", unit.height, [...sendersAddresses.keys()]);
  }
 
- public async start(): Promise<void> {
- await this.ipcSubprocess.sendRequest("start");
+ public async start(height: number): Promise<void> {
+ await this.ipcSubprocess.sendRequest("start", height);
  }
 
  public async getTransactionBytes(): Promise<Buffer[]> {