Class PostInvoiceController

src/controllers/invoices/post-invoice-controller.ts:22–177

const logger = createLogger('post-invoice-controller')

export class PostInvoiceController implements IController {
  public constructor(
    private readonly userRepository: IUserRepository,
    private readonly paymentsService: IPaymentsService,
    private readonly settings: () => Settings,
    private readonly rateLimiter: () => IRateLimiter,
  ) {}

  public async handleRequest(request: Request, response: Response): Promise<void> {
    logger('params: %o', request.params)
    logger('body: %o', request.body)

    const currentSettings = this.settings()

    const {
      info: { name: relayName, relay_url: relayUrl },
    } = currentSettings

    const limited = await this.isRateLimited(request, currentSettings)
    if (limited) {
      response.status(429).setHeader('content-type', 'text/plain; charset=utf8').send('Too many requests')
      return
    }

    if (!request.body || typeof request.body !== 'object') {
      response.status(400).setHeader('content-type', 'text/plain; charset=utf8').send('Invalid request')

      return
    }

    const tosAccepted = request.body?.tosAccepted === 'yes'

    if (!tosAccepted) {
      response.status(400).setHeader('content-type', 'text/plain; charset=utf8').send('ToS agreement: not accepted')

      return
    }

    const isAdmissionInvoice = request.body?.feeSchedule === 'admission'
    if (!isAdmissionInvoice) {
      response.status(400).setHeader('content-type', 'text/plain; charset=utf8').send('Invalid fee')

      return
    }

    const pubkeyRaw = path(['body', 'pubkey'], request)

    let pubkey: string
    if (typeof pubkeyRaw !== 'string') {
      response.status(400).setHeader('content-type', 'text/plain; charset=utf8').send('Invalid pubkey: missing')

      return
    } else if (/^[0-9a-f]{64}$/.test(pubkeyRaw)) {
      pubkey = pubkeyRaw
    } else if (/^npub1/.test(pubkeyRaw)) {
      try {
        pubkey = fromBech32(pubkeyRaw)
      } catch (_error) {