fix: issues with invoices (#271)

* fix: issues with invoices

* chore: add invoice event tag

* chore: add sub limits

* chore: cleanup invoices page

* chore: use mergeDeepLeft when updating invoice

* chore: ignore whitelisted pubkey for adminssion fee

* chore: use secp256k1 bytesToHex

* fix: insecure derivation from secret

* fix: tests

* chore: consistent returns

* test: fix intg tests

* fix: intg tests

* chore: set SECRET for intg tests

Author: cameri

resources/default-settings.yaml

@@ -82,14 +82,14 @@ limits:
         - 10
       - - 40
         - 49
-      maxLength: 65536
+      maxLength: 102400
     - description: 96 KB for event kind ranges 11-39 and 50-max
       kinds:
       - - 11
         - 39
       - - 50
         - 9007199254740991
-      maxLength: 98304
+      maxLength: 102400
     rateLimits:
     - description: 6 events/min for event kinds 0, 3, 40 and 41
       kinds:
@@ -143,6 +143,10 @@ limits:
     subscription:
       maxSubscriptions: 10
       maxFilters: 10
+      maxFilterValues: 2500
+      maxSubscriptionIdLength: 256
+      maxLimit: 5000
+      minPrefixLength: 4
   message:
     rateLimits:
     - description: 240 raw messages/min

resources/invoices.html

@@ -107,8 +107,11 @@ <h2 class="text-danger">Invoice expired!</h2>
       var timeout
       var paid = false
       var fallbackTimeout
+      var now = Math.floor(Date.now()/1000)
 
       console.log('invoice id', reference)
+      console.log('pubkey', pubkey)
+      console.log('bolt11', invoice)
 
       function getBackoffTime() {
         return 5000 + Math.floor(Math.random() * 5000)
@@ -149,7 +152,8 @@ <h2 class="text-danger">Invoice expired!</h2>
         var socket = new WebSocket(relayUrl)
         socket.onopen = () => {
           console.log('connected')
-          socket.send(JSON.stringify(['REQ', 'payment', { kinds: [4], authors: [relayPubkey], '#c': [reference], limit: 1 }]))
+          var subscription = ['REQ', 'payment', { kinds: [402], '#p': [pubkey], since: now - 60 }]
+          socket.send(JSON.stringify(subscription))
         }
 
         socket.onmessage = (raw) => {
@@ -162,16 +166,22 @@ <h2 class="text-danger">Invoice expired!</h2>
 
           switch (message[0]) {
             case 'EVENT': {
-              // TODO: validate event
               const event = message[2]
-              // TODO: validate signature
-              if (event.pubkey === relayPubkey) {
-                paid = true
+              if (
+                event.pubkey === relayPubkey
+                && event.kind === 402
+              ) {
+                const pubkeyTag = event.tags.find((t) => t[0] === 'p' && t[1] === pubkey)
+                const invoiceTag = event.tags.find((t) => t[0] === 'bolt11' && t[1] === invoice)
 
-                if (expiresAt) clearTimeout(timeout)
+                if (pubkeyTag && invoiceTag) {
+                  paid = true
 
-                hide('pending')
-                show('paid')
+                  if (expiresAt) clearTimeout(timeout)
+
+                  hide('pending')
+                  show('paid')
+                }
               }
             }
             break;

src/@types/base.ts

@@ -1,17 +1,23 @@
 import { Knex } from 'knex'
 import { SocketAddress } from 'net'
 
+import { EventTags } from '../constants/base'
+
 export type EventId = string
 export type Pubkey = string
-export type TagName = string
+export type TagName = EventTags | string
 export type Signature = string
 export type Tag = TagBase & string[]
 
 export type Secret = string
 
-export interface TagBase {
-  0: TagName
-  [index: number]: string
+type ExtraTagValues = {
+  [index in Range<2, 100>]?: string
+}
+
+export interface TagBase extends ExtraTagValues {
+  0: TagName;
+  1: string
 }
 
 type Enumerate<

src/@types/services.ts

@@ -13,7 +13,6 @@ export interface IPaymentsService {
   confirmInvoice(
     invoice: Pick<Invoice, 'id' | 'amountPaid' | 'confirmedAt'>,
   ): Promise<void>
-  sendNewInvoiceNotification(invoice: Invoice): Promise<void>
   sendInvoiceUpdateNotification(invoice: Invoice): Promise<void>
   getPendingInvoices(): Promise<Invoice[]>
 }

src/@types/settings.ts

@@ -82,6 +82,10 @@ export interface EventLimits {
 export interface ClientSubscriptionLimits {
   maxSubscriptions?: number
   maxFilters?: number
+  maxFilterValues?: number
+  maxLimit?: number
+  minPrefixLength?: number
+  maxSubscriptionIdLength?: number
 }
 
 export interface ClientLimits {

src/app/maintenance-worker.ts

@@ -1,5 +1,5 @@
+import { mergeDeepLeft, path, pipe } from 'ramda'
 import { IRunnable } from '../@types/base'
-import { path } from 'ramda'
 
 import { createLogger } from '../factories/logger-factory'
 import { delayMs } from '../utils/misc'
@@ -47,21 +47,27 @@ export class MaintenanceWorker implements IRunnable {
     for (const invoice of invoices) {
       debug('invoice %s: %o', invoice.id, invoice)
       try {
-        debug('getting invoice %s from payment processor', invoice.id)
+        debug('getting invoice %s from payment processor: %o', invoice.id, invoice)
         const updatedInvoice = await this.paymentsService.getInvoiceFromPaymentsProcessor(invoice)
         await delay()
-        debug('updating invoice status %s: %o', invoice.id, invoice)
+        debug('updating invoice status %s: %o', updatedInvoice.id, updatedInvoice)
         await this.paymentsService.updateInvoiceStatus(updatedInvoice)
 
         if (
           invoice.status !== updatedInvoice.status
           && updatedInvoice.status == InvoiceStatus.COMPLETED
-          && invoice.confirmedAt
+          && updatedInvoice.confirmedAt
         ) {
           debug('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(invoice),
-            this.paymentsService.sendInvoiceUpdateNotification(invoice),
+            this.paymentsService.confirmInvoice(update),
+            this.paymentsService.sendInvoiceUpdateNotification(update),
           ])
 
           await delay()

src/constants/base.ts

@@ -27,7 +27,6 @@ export enum EventKinds {
   PARAMETERIZED_REPLACEABLE_FIRST = 30000,
   PARAMETERIZED_REPLACEABLE_LAST = 39999,
   USER_APPLICATION_FIRST = 40000,
-  USER_APPLICATION_LAST = Number.MAX_SAFE_INTEGER,
 }
 
 export enum EventTags {
@@ -37,6 +36,7 @@ export enum EventTags {
   Delegation = 'delegation',
   Deduplication = 'd',
   Expiration = 'expiration',
+  Invoice = 'bolt11',
 }
 
 export enum PaymentsProcessors {

src/controllers/invoices/post-invoice-controller.ts

@@ -136,7 +136,12 @@ export class PostInvoiceController implements IController {
     }
 
     let invoice: Invoice
-    const amount = admissionFee.reduce((sum, fee) => sum + BigInt(fee.amount), 0n)
+    const amount = admissionFee.reduce((sum, fee) => {
+      return fee.enabled && !fee.whitelists?.pubkeys?.includes(pubkey)
+        ? BigInt(fee.amount) + sum
+        : sum
+    }, 0n)
+
     try {
       const description = `${relayName} Admission Fee for ${toBech32('npub')(pubkey)}`
 
@@ -145,8 +150,6 @@ export class PostInvoiceController implements IController {
         amount,
         description,
       )
-
-      await this.paymentsService.sendNewInvoiceNotification(invoice)
     } catch (error) {
       console.error('Unable to create invoice. Reason:', error)
       response

src/handlers/event-message-handler.ts

@@ -1,6 +1,6 @@
 import { Event, ExpiringEvent  } from '../@types/event'
 import { EventRateLimit, FeeSchedule, Settings } from '../@types/settings'
-import { getEventExpiration, getEventProofOfWork, getPubkeyProofOfWork, isEventIdValid, isEventKindOrRangeMatch, isEventSignatureValid, isExpiredEvent } from '../utils/event'
+import { getEventExpiration, getEventProofOfWork, getPubkeyProofOfWork, getPublicKey, getRelayPrivateKey, isEventIdValid, isEventKindOrRangeMatch, isEventSignatureValid, isExpiredEvent } from '../utils/event'
 import { IEventStrategy, IMessageHandler } from '../@types/message-handlers'
 import { ContextMetadataKey } from '../constants/base'
 import { createCommandResult } from '../utils/messages'
@@ -79,7 +79,15 @@ export class EventMessageHandler implements IMessageHandler {
     }
   }
 
+  protected getRelayPublicKey(): string {
+    const relayPrivkey = getRelayPrivateKey(this.settings().info.relay_url)
+    return getPublicKey(relayPrivkey)
+  }
+
   protected canAcceptEvent(event: Event): string | undefined {
+    if (this.getRelayPublicKey() === event.pubkey) {
+      return
+    }
     const now = Math.floor(Date.now()/1000)
 
     const limits = this.settings().limits?.event ?? {}
@@ -185,6 +193,10 @@ export class EventMessageHandler implements IMessageHandler {
   }
 
   protected async isRateLimited(event: Event): Promise<boolean> {
+    if (this.getRelayPublicKey() === event.pubkey) {
+      return false
+    }
+
     const { whitelists, rateLimits } = this.settings().limits?.event ?? {}
     if (!rateLimits || !rateLimits.length) {
       return false
@@ -249,6 +261,10 @@ export class EventMessageHandler implements IMessageHandler {
       return
     }
 
+    if (this.getRelayPublicKey() === event.pubkey) {
+      return
+    }
+
     const isApplicableFee = (feeSchedule: FeeSchedule) =>
       feeSchedule.enabled
       && !feeSchedule.whitelists?.pubkeys?.some((prefix) => event.pubkey.startsWith(prefix))

src/handlers/request-handlers/root-request-handler.ts

@@ -17,6 +17,8 @@ export const rootRequestHandler = (request: Request, response: Response, next: N
     paymentsUrl.protocol = paymentsUrl.protocol === 'wss:' ? 'https:' : 'http:'
     paymentsUrl.pathname = '/invoices'
 
+    const content = settings.limits?.event?.content
+
     const relayInformationDocument = {
       name,
       description,
@@ -29,12 +31,14 @@ export const rootRequestHandler = (request: Request, response: Response, next: N
       limitation: {
             max_message_length: settings.network.maxPayloadSize,
             max_subscriptions: settings.limits?.client?.subscription?.maxSubscriptions,
-            max_filters: settings.limits?.client?.subscription?.maxFilters,
-            max_limit: 5000,
-            max_subid_length: 256,
-            min_prefix: 4,
+            max_filters: settings.limits?.client?.subscription?.maxFilterValues,
+            max_limit: settings.limits?.client?.subscription?.maxLimit,
+            max_subid_length: settings.limits?.client?.subscription?.maxSubscriptionIdLength,
+            min_prefix: settings.limits?.client?.subscription?.minPrefixLength,
             max_event_tags: 2500,
-            max_content_length: 102400,
+            max_content_length: Array.isArray(content)
+              ? content[0].maxLength // best guess since we have per-kind limits
+              : content?.maxLength,
             min_pow_difficulty: settings.limits?.event?.eventId?.minLeadingZeroBits,
             auth_required: false,
             payment_required: settings.payments?.enabled,