chore: clean code

docker-compose.yml

@@ -27,7 +27,7 @@ services:
     networks:
       default:
   denostr-maintenance:
-    image: ghcr.io/denostr-protocol/denostr:v0.1.1-maintenance
+    image: ghcr.io/denostr-protocol/denostr:v0.2.0-maintenance
     container_name: denostr-maintenance
     environment:
       RELAY_PORT: 8008

src/@types/repositories.ts

@@ -2,7 +2,7 @@ import { PassThrough, Stream } from 'stream'
 
 import mongoose from 'mongoose'
 
-import { DatabaseClient, DatabaseTransaction, EventId, Pubkey } from './base.ts'
+import { DatabaseTransaction, EventId, Pubkey } from './base.ts'
 import { DBEvent, Event } from './event.ts'
 import { Invoice } from './invoice.ts'
 import { SubscriptionFilter } from './subscription.ts'
@@ -23,8 +23,8 @@ export interface IEventRepository {
 }
 
 export interface IInvoiceRepository {
-    findById(id: string, client?: DatabaseClient): Promise<Invoice | undefined>
-    upsert(invoice: Partial<Invoice>, session?: DatabaseTransaction): Promise<number>
+    findById(id: string): Promise<Invoice | undefined>
+    upsert(invoice: Partial<Invoice>): Promise<number>
     updateStatus(
         invoice: Pick<Invoice, 'id' | 'status'>,
         session?: DatabaseTransaction,
@@ -38,7 +38,6 @@ export interface IInvoiceRepository {
     findPendingInvoices(
         offset?: number,
         limit?: number,
-        client?: DatabaseClient,
     ): Promise<Invoice[]>
 }
 

src/factories/controllers/get-invoice-status-controller-factory.ts

@@ -1,11 +1,8 @@
 import { GetInvoiceStatusController } from '@/controllers/invoices/get-invoice-status-controller.ts'
-import { getReadReplicaDbClient } from '@/database/client.ts'
 import { InvoiceRepository } from '@/repositories/invoice-repository.ts'
 
 export const createGetInvoiceStatusController = () => {
-    const rrDbClient = getReadReplicaDbClient()
-
-    const invoiceRepository = new InvoiceRepository(rrDbClient)
+    const invoiceRepository = new InvoiceRepository()
 
     return new GetInvoiceStatusController(invoiceRepository)
 }

src/factories/controllers/lnbits-callback-controller-factory.ts

@@ -1,12 +1,11 @@
 import { createPaymentsService } from '@/factories/payments-service-factory.ts'
-import { getMasterDbClient } from '@/database/client.ts'
 import { IController } from '@/@types/controllers.ts'
 import { InvoiceRepository } from '@/repositories/invoice-repository.ts'
 import { LNbitsCallbackController } from '@/controllers/callbacks/lnbits-callback-controller.ts'
 
 export const createLNbitsCallbackController = (): IController => {
     return new LNbitsCallbackController(
         createPaymentsService(),
-        new InvoiceRepository(getMasterDbClient()),
+        new InvoiceRepository(),
     )
 }

src/factories/payments-service-factory.ts

@@ -8,7 +8,7 @@ import { createSettings } from './settings-factory.ts'
 
 export const createPaymentsService = () => {
     const dbClient = getMasterDbClient()
-    const invoiceRepository = new InvoiceRepository(dbClient)
+    const invoiceRepository = new InvoiceRepository()
     const userRepository = new UserRepository(createSettings)
     const paymentsProcessor = createPaymentsProcessor()
     const eventRepository = new EventRepository(createSettings)

src/repositories/invoice-repository.ts

@@ -1,6 +1,5 @@
 import { always, applySpec, ifElse, is, pipe, prop, propSatisfies, toString } from 'ramda'
 
-import { DatabaseClient } from '@/@types/base.ts'
 import { DBInvoice, Invoice, InvoiceStatus } from '@/@types/invoice.ts'
 import { IInvoiceRepository } from '@/@types/repositories.ts'
 import { createLogger } from '@/factories/logger-factory.ts'
@@ -12,8 +11,6 @@ import { DatabaseTransaction } from '@/@types/base.ts'
 const debug = createLogger('invoice-repository')
 
 export class InvoiceRepository implements IInvoiceRepository {
-    public constructor(private readonly dbClient: DatabaseClient) {}
-
     public async confirmInvoice(
         invoiceId: string,
         amountPaid: bigint,