Class PaymentsService

src/services/payments-service.ts:17–243

const logger = createLogger('payments-service')

export class PaymentsService implements IPaymentsService {
  public constructor(
    private readonly dbClient: DatabaseClient,
    private readonly paymentsProcessor: IPaymentsProcessor,
    private readonly userRepository: IUserRepository,
    private readonly invoiceRepository: IInvoiceRepository,
    private readonly eventRepository: IEventRepository,
    private readonly settings: () => Settings,
  ) {}

  public async getPendingInvoices(): Promise<Invoice[]> {
    logger('get pending invoices')
    try {
      return await this.invoiceRepository.findPendingInvoices(0, 10)
    } catch (error) {
      logger.error('Unable to get pending invoices.', error)

      throw error
    }
  }

  public async getInvoiceFromPaymentsProcessor(invoice: Invoice | string): Promise<Partial<Invoice>> {
    try {
      return await this.paymentsProcessor.getInvoice(
        typeof invoice === 'string' || invoice?.verifyURL ? invoice : invoice.id,
      )
    } catch (error) {
      logger.error('Unable to get invoice from payments processor. Reason:', error)

      throw error
    }
  }

  public async createInvoice(pubkey: Pubkey, amount: bigint, description: string): Promise<Invoice> {
    logger('create invoice for %s for %s: %s', pubkey, amount.toString(), description)
    const transaction = new Transaction(this.dbClient)

    try {
      await transaction.begin()

      await this.userRepository.upsert({ pubkey }, transaction.transaction)

      const invoiceResponse = await this.paymentsProcessor.createInvoice({
        amount,
        description,
        requestId: pubkey,
      })

      const date = new Date()

      await this.invoiceRepository.upsert(
        {
          id: invoiceResponse.id,
          pubkey,
          bolt11: invoiceResponse.bolt11,
          amountRequested: invoiceResponse.amountRequested,
          description: invoiceResponse.description,
          unit: invoiceResponse.unit,