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

queue lnd metics saves

Browse source
This commit is contained in:
boufni95 2024-02-09 18:30:27 +01:00
parent bf102b2a73
commit 821cbdf2f9
1 changed files with 9 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

17
src/services/storage/metricsStorage.ts
View file

@ -10,16 +10,17 @@ export default class {
this.DB = DB this.DB = DB
this.txQueue = txQueue this.txQueue = txQueue
} }
async SaveRoutingEvent(event: Partial<RoutingEvent>, entityManager = this.DB) { async SaveRoutingEvent(event: Partial<RoutingEvent>) {
const entry = entityManager.getRepository(RoutingEvent).create(event) const entry = this.DB.getRepository(RoutingEvent).create(event)
return entityManager.getRepository(RoutingEvent).save(entry) return this.txQueue.PushToQueue<RoutingEvent>({ exec: async db => db.getRepository(RoutingEvent).save(entry), dbTx: false })
} }
async SaveBalanceEvents(balanceEvent: Partial<BalanceEvent>, channelBalanceEvents: Partial<ChannelBalanceEvent>[], entityManager = this.DB) { async SaveBalanceEvents(balanceEvent: Partial<BalanceEvent>, channelBalanceEvents: Partial<ChannelBalanceEvent>[]) {
const blanceEventEntry = entityManager.getRepository(BalanceEvent).create(balanceEvent) const blanceEventEntry = this.DB.getRepository(BalanceEvent).create(balanceEvent)
const balanceEntry = await entityManager.getRepository(BalanceEvent).save(blanceEventEntry) const balanceEntry = await this.txQueue.PushToQueue<BalanceEvent>({ exec: async db => db.getRepository(BalanceEvent).save(blanceEventEntry), dbTx: false })
const channelsEntry = entityManager.getRepository(ChannelBalanceEvent).create(channelBalanceEvents.map(e => ({ ...e, balance_event: balanceEntry })))
const channelsEntries = await entityManager.getRepository(ChannelBalanceEvent).save(channelsEntry) const channelsEntry = this.DB.getRepository(ChannelBalanceEvent).create(channelBalanceEvents.map(e => ({ ...e, balance_event: balanceEntry })))
const channelsEntries = await this.txQueue.PushToQueue<ChannelBalanceEvent[]>({ exec: async db => db.getRepository(ChannelBalanceEvent).save(channelsEntry), dbTx: false })
return { balanceEntry, channelsEntries } return { balanceEntry, channelsEntries }
} }