Method onSchedule

src/app/maintenance-worker.ts:123–192

()

  }

  private async onSchedule(): Promise<void> {
    const currentSettings = this.settings()
    const clearOldEventsPromise = this.clearOldEventsSafely()

    await this.processNip05Reverifications(currentSettings)

    if (!path(['payments', 'enabled'], currentSettings)) {
      await clearOldEventsPromise
      return
    }

    const invoices = await this.paymentsService.getPendingInvoices()
    logger('found %d pending invoices', invoices.length)
    const delay = () => delayMs(100 + Math.floor(Math.random() * 10))

    let successful = 0

    for (const invoice of invoices) {
      try {
        logger('getting invoice %s from payment processor: %o', invoice.id, invoice)
        const updatedInvoice = await this.paymentsService.getInvoiceFromPaymentsProcessor(invoice)
        await delay()
        logger('updating invoice status %s: %o', updatedInvoice.id, updatedInvoice)

        if (typeof updatedInvoice.id !== 'string' || typeof updatedInvoice.status !== 'string') {
          continue
        }
        const { id, status } = updatedInvoice

        await this.paymentsService.updateInvoiceStatus({ id, status })

        if (
          invoice.status !== updatedInvoice.status &&
          updatedInvoice.status == InvoiceStatus.COMPLETED &&
          updatedInvoice.confirmedAt
        ) {
          logger('confirming invoice %s & notifying %s', invoice.id, invoice.pubkey)

          const update = pipe(
            mergeDeepLeft(updatedInvoice),
            mergeDeepLeft({ amountPaid: invoice.amountRequested }),
          )(invoice)

          await Promise.all([
            this.paymentsService.confirmInvoice(update),
            this.paymentsService.sendInvoiceUpdateNotification(update),
          ])

          await delay()
        }
        successful++
      } catch (error) {
        if (isNotFoundError(error) && isExpiredInvoice(invoice)) {
          logger('marking expired invoice %s after payment processor returned 404', invoice.id)
          await this.paymentsService.updateInvoiceStatus({
            id: invoice.id,
            status: InvoiceStatus.EXPIRED,
          })