aiolabs/lightning-pub
2
0
Fork 0
Code Issues 9 Pull requests 4 Projects Releases Packages Wiki Activity Actions

disable new invoice check

Browse source
This commit is contained in:
boufni95 2025-10-31 19:37:21 +00:00
parent 203dde3d38
commit 3e45e4ec90
1 changed files with 5 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

10
src/services/storage/paymentStorage.ts
View file

@ -90,7 +90,7 @@ export default class {
take take
}, txId); }, txId);
items.push(...firstBatch); items.push(...firstBatch);
} }
const needMore = take - items.length const needMore = take - items.length
// If need more, fetch higher paid_at_unix // If need more, fetch higher paid_at_unix
@ -134,7 +134,7 @@ export default class {
} }
async RemoveUserInvoices(userId: string, txId?: string) { async RemoveUserInvoices(userId: string, txId?: string) {
return this.dbs.Delete<UserReceivingInvoice>('UserReceivingInvoice', { user: { user_id: userId } }, txId) return this.dbs.Delete<UserReceivingInvoice>('UserReceivingInvoice', { user: { user_id: userId } }, txId)
} }
async GetAddressOwner(address: string, txId?: string): Promise<UserReceivingAddress | null> { async GetAddressOwner(address: string, txId?: string): Promise<UserReceivingAddress | null> {
@ -401,7 +401,7 @@ export default class {
]) ])
const receivingTransactions = await Promise.all(receivingAddresses.map(addr => const receivingTransactions = await Promise.all(receivingAddresses.map(addr =>
this.dbs.Find<AddressReceivingTransaction>('AddressReceivingTransaction', { where: { user_address: { serial_id: addr.serial_id }, ...time } }))) this.dbs.Find<AddressReceivingTransaction>('AddressReceivingTransaction', { where: { user_address: { serial_id: addr.serial_id }, ...time } })))
return { return {
receivingInvoices, receivingAddresses, receivingTransactions, receivingInvoices, receivingAddresses, receivingTransactions,
outgoingInvoices, outgoingTransactions, outgoingInvoices, outgoingTransactions,
userToUser userToUser
@ -419,8 +419,8 @@ export default class {
async VerifyDbEvent(e: LoggedEvent) { async VerifyDbEvent(e: LoggedEvent) {
switch (e.type) { switch (e.type) {
case "new_invoice": /* case "new_invoice":
return orFail(this.dbs.FindOne<UserReceivingInvoice>('UserReceivingInvoice', { where: { invoice: e.data, user: { user_id: e.userId } } })) return orFail(this.dbs.FindOne<UserReceivingInvoice>('UserReceivingInvoice', { where: { invoice: e.data, user: { user_id: e.userId } } })) */
case 'new_address': case 'new_address':
return orFail(this.dbs.FindOne<UserReceivingAddress>('UserReceivingAddress', { where: { address: e.data, user: { user_id: e.userId } } })) return orFail(this.dbs.FindOne<UserReceivingAddress>('UserReceivingAddress', { where: { address: e.data, user: { user_id: e.userId } } }))
case 'invoice_paid': case 'invoice_paid':