fix: enrich event metadata before persistence in import service

Author: Anshumancanrock

src/@types/repositories.ts

@@ -1,46 +1,48 @@
-import { PassThrough } from 'stream'
-
-import { DatabaseClient, EventId, Pubkey } from './base'
-import { DBEvent, Event } from './event'
-import { Invoice } from './invoice'
-import { SubscriptionFilter } from './subscription'
-import { User } from './user'
-
-export type ExposedPromiseKeys = 'then' | 'catch' | 'finally'
-
-export interface IQueryResult<T> extends Pick<Promise<T>, keyof Promise<T> & ExposedPromiseKeys> {
-  stream(options?: Record<string, any>): PassThrough & AsyncIterable<T>
-}
-
-export interface IEventRepository {
-  create(event: Event): Promise<number>
-  upsert(event: Event): Promise<number>
-  findByFilters(filters: SubscriptionFilter[]): IQueryResult<DBEvent[]>
-  deleteByPubkeyAndIds(pubkey: Pubkey, ids: EventId[]): Promise<number>
-}
-
-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[]>
-}
-
-export interface IUserRepository {
-  findByPubkey(pubkey: Pubkey, client?: DatabaseClient): Promise<User | undefined>
-  upsert(user: Partial<User>, client?: DatabaseClient): Promise<number>
-  getBalanceByPubkey(pubkey: Pubkey, client?: DatabaseClient): Promise<bigint>
-}
+import { PassThrough } from 'stream'
+
+import { DatabaseClient, EventId, Pubkey } from './base'
+import { DBEvent, Event } from './event'
+import { Invoice } from './invoice'
+import { SubscriptionFilter } from './subscription'
+import { User } from './user'
+
+export type ExposedPromiseKeys = 'then' | 'catch' | 'finally'
+
+export interface IQueryResult<T> extends Pick<Promise<T>, keyof Promise<T> & ExposedPromiseKeys> {
+  stream(options?: Record<string, any>): PassThrough & AsyncIterable<T>
+}
+
+export interface IEventRepository {
+  create(event: Event): Promise<number>
+  createMany(events: Event[]): Promise<number>
+  upsert(event: Event): Promise<number>
+  upsertMany(events: Event[]): Promise<number>
+  findByFilters(filters: SubscriptionFilter[]): IQueryResult<DBEvent[]>
+  deleteByPubkeyAndIds(pubkey: Pubkey, ids: EventId[]): Promise<number>
+}
+
+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[]>
+}
+
+export interface IUserRepository {
+  findByPubkey(pubkey: Pubkey, client?: DatabaseClient): Promise<User | undefined>
+  upsert(user: Partial<User>, client?: DatabaseClient): Promise<number>
+  getBalanceByPubkey(pubkey: Pubkey, client?: DatabaseClient): Promise<bigint>
+}

src/import-events.ts

@@ -12,8 +12,8 @@ import {
   EventImportService,
   EventImportStats,
 } from './services/event-import-service'
-import { getMasterDbClient } from './database/client'
 import { EventRepository } from './repositories/event-repository'
+import { getMasterDbClient } from './database/client'
 
 interface CliOptions {
   batchSize: number