import {
  PrivateMempool,
  PendingTransaction,
  AppChainModule,
} from "@proto-kit/sequencer";
import { inject, injectable } from "tsyringe";
import { ModuleContainerLike } from "@proto-kit/common";

export interface TransactionSender extends AppChainModule<unknown> {
  send: (transaction: PendingTransaction) => Promise<void>;
}

@injectable()
export class InMemoryTransactionSender
  extends AppChainModule
  implements TransactionSender
{
  public mempool: PrivateMempool;

  public constructor(
    @inject("Sequencer") public sequencer: ModuleContainerLike
  ) {
    super();

    this.mempool = this.sequencer.resolveOrFail("Mempool", PrivateMempool);
  }

  public async send(transaction: PendingTransaction) {
    await this.mempool.add(transaction);
  }
}