Implement caching for user admission check

package.json

@@ -96,7 +96,7 @@
     "@types/express": "4.17.21",
     "@types/js-yaml": "4.0.5",
     "@types/mocha": "^9.1.1",
-    "@types/node": "^24.0.0",
+    "@types/node": "^24.12.2",
     "@types/pg": "^8.6.5",
     "@types/ramda": "^0.28.13",
     "@types/sinon": "^10.0.11",

src/@types/adapters.ts

@@ -11,7 +11,6 @@ export interface IWebServerAdapter extends EventEmitter {
   close(callback?: () => void): void
 }
 
-
 export type IWebSocketAdapter = EventEmitter & {
   getClientId(): string
   getClientAddress(): string
@@ -21,7 +20,7 @@ export type IWebSocketAdapter = EventEmitter & {
 export interface ICacheAdapter {
   getKey(key: string): Promise<string>
   hasKey(key: string): Promise<boolean>
-  setKey(key: string, value: string): Promise<boolean>
+  setKey(key: string, value: string, expirySeconds?: number): Promise<boolean>
   addToSortedSet(key: string, set: Record<string, string> | Record<string, string>[]): Promise<number>
   removeRangeByScoreFromSortedSet(key: string, min: number, max: number): Promise<number>
   getRangeFromSortedSet(key: string, start: number, stop: number): Promise<string[]>

src/@types/base.ts

@@ -16,21 +16,15 @@ type ExtraTagValues = {
 }
 
 export interface TagBase extends ExtraTagValues {
-  0: TagName;
+  0: TagName
   1: string
 }
 
-type Enumerate<
-  N extends number,
-  Acc extends number[] = [],
-> = Acc['length'] extends N
+type Enumerate<N extends number, Acc extends number[] = []> = Acc['length'] extends N
   ? Acc[number]
   : Enumerate<N, [...Acc, Acc['length']]>
 
-export type Range<F extends number, T extends number> = Exclude<
-  Enumerate<T>,
-  Enumerate<F>
->
+export type Range<F extends number, T extends number> = Exclude<Enumerate<T>, Enumerate<F>>
 
 export type Factory<TOutput = any, TInput = void> = (input: TInput) => TOutput
 
@@ -45,4 +39,4 @@ export interface ContextMetadata {
 export interface IRunnable {
   run(): void
   close(callback?: (...args: any[]) => void): void
-}
+}

src/@types/cache.ts

@@ -1,8 +1,3 @@
-import {
-  RedisClientType,
-  RedisFunctions,
-  RedisModules,
-  RedisScripts,
-} from 'redis'
+import { RedisClientType, RedisFunctions, RedisModules, RedisScripts } from 'redis'
 
 export type CacheClient = RedisClientType<RedisModules, RedisFunctions, RedisScripts>

src/@types/database.ts

@@ -2,7 +2,7 @@ import { DatabaseTransaction } from './base'
 
 export interface ITransaction {
   begin(): Promise<void>
-  get transaction (): DatabaseTransaction
+  get transaction(): DatabaseTransaction
   commit(): Promise<any[]>
   rollback(): Promise<any[]>
 }

src/@types/event.ts

@@ -1,5 +1,10 @@
 import { ContextMetadata, EventId, Pubkey, Tag } from './base'
-import { ContextMetadataKey, EventDeduplicationMetadataKey, EventExpirationTimeMetadataKey, EventKinds } from '../constants/base'
+import {
+  ContextMetadataKey,
+  EventDeduplicationMetadataKey,
+  EventExpirationTimeMetadataKey,
+  EventKinds,
+} from '../constants/base'
 
 export interface BaseEvent {
   id: EventId

src/@types/invoice.ts

@@ -3,7 +3,7 @@ import { Pubkey } from './base'
 export enum InvoiceUnit {
   MSATS = 'msats',
   SATS = 'sats',
-  BTC = 'btc'
+  BTC = 'btc',
 }
 
 export enum InvoiceStatus {
@@ -39,7 +39,7 @@ export interface DBInvoice {
   amount_requested: bigint
   amount_paid: bigint
   unit: InvoiceUnit
-  status: InvoiceStatus,
+  status: InvoiceStatus
   description: string
   confirmed_at: Date
   expires_at: Date

src/@types/messages.ts

@@ -9,23 +9,14 @@ export enum MessageType {
   CLOSE = 'CLOSE',
   NOTICE = 'NOTICE',
   EOSE = 'EOSE',
-  OK = 'OK'
+  OK = 'OK',
 }
 
-export type IncomingMessage = (
-  | SubscribeMessage
-  | IncomingEventMessage
-  | UnsubscribeMessage
-  ) & {
-    [ContextMetadataKey]?: ContextMetadata
-  }
-
+export type IncomingMessage = (SubscribeMessage | IncomingEventMessage | UnsubscribeMessage) & {
+  [ContextMetadataKey]?: ContextMetadata
+}
 
-export type OutgoingMessage =
-  | OutgoingEventMessage
-  | EndOfStoredEventsNotice
-  | NoticeMessage
-  | CommandResult
+export type OutgoingMessage = OutgoingEventMessage | EndOfStoredEventsNotice | NoticeMessage | CommandResult
 
 export type SubscribeMessage = {
   [index in Range<2, 100>]: SubscriptionFilter

src/@types/repositories.ts

@@ -42,21 +42,9 @@ export interface IEventRepository {
 export interface IInvoiceRepository {
   findById(id: string, client?: DatabaseClient): Promise<Invoice | undefined>
   upsert(invoice: Partial<Invoice>, client?: DatabaseClient): Promise<number>
-  updateStatus(
-    invoice: Pick<Invoice, 'id' | 'status'>,
-    client?: DatabaseClient,
-  ): Promise<Invoice | undefined>
-  confirmInvoice(
-    invoiceId: string,
-    amountReceived: bigint,
-    confirmedAt: Date,
-    client?: DatabaseClient,
-  ): Promise<void>
-  findPendingInvoices(
-    offset?: number,
-    limit?: number,
-    client?: DatabaseClient,
-  ): Promise<Invoice[]>
+  updateStatus(invoice: Pick<Invoice, 'id' | 'status'>, client?: DatabaseClient): Promise<Invoice | undefined>
+  confirmInvoice(invoiceId: string, amountReceived: bigint, confirmedAt: Date, client?: DatabaseClient): Promise<void>
+  findPendingInvoices(offset?: number, limit?: number, client?: DatabaseClient): Promise<Invoice[]>
 }
 
 export interface IUserRepository {
@@ -71,10 +59,6 @@ export interface IUserRepository {
 export interface INip05VerificationRepository {
   findByPubkey(pubkey: Pubkey): Promise<Nip05Verification | undefined>
   upsert(verification: Nip05Verification): Promise<number>
-  findPendingVerifications(
-    updateFrequencyMs: number,
-    maxFailures: number,
-    limit: number,
-  ): Promise<Nip05Verification[]>
+  findPendingVerifications(updateFrequencyMs: number, maxFailures: number, limit: number): Promise<Nip05Verification[]>
   deleteByPubkey(pubkey: Pubkey): Promise<number>
 }

src/@types/services.ts

@@ -7,16 +7,10 @@ export interface IMaintenanceService {
 
 export interface IPaymentsService {
   getInvoiceFromPaymentsProcessor(invoice: string | Invoice): Promise<Partial<Invoice>>
-  createInvoice(
-    pubkey: Pubkey,
-    amount: bigint,
-    description: string,
-  ): Promise<Invoice>
+  createInvoice(pubkey: Pubkey, amount: bigint, description: string): Promise<Invoice>
   updateInvoice(invoice: Partial<Invoice>): Promise<void>
   updateInvoiceStatus(invoice: Pick<Invoice, 'id' | 'status'>): Promise<Invoice>
-  confirmInvoice(
-    invoice: Pick<Invoice, 'id' | 'amountPaid' | 'confirmedAt' | 'status' | 'pubkey'>,
-  ): Promise<void>
+  confirmInvoice(invoice: Pick<Invoice, 'id' | 'amountPaid' | 'confirmedAt' | 'status' | 'pubkey'>): Promise<void>
   sendInvoiceUpdateNotification(invoice: Invoice): Promise<void>
   getPendingInvoices(): Promise<Invoice[]>
 }

src/@types/settings.ts

@@ -199,7 +199,7 @@ export interface NodelessPaymentsProcessor {
 }
 
 export interface PaymentsProcessors {
-  lnurl?: LnurlPaymentsProcessor,
+  lnurl?: LnurlPaymentsProcessor
   zebedee?: ZebedeePaymentsProcessor
   lnbits?: LNbitsPaymentsProcessor
   nodeless?: NodelessPaymentsProcessor

src/@types/utils.ts

@@ -1,6 +1,6 @@
 export interface IRateLimiterOptions {
-  period: number;
-  rate: number;
+  period: number
+  rate: number
 }
 
 export interface IRateLimiter {