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

change addr cache

Browse source
This commit is contained in:
boufni95 2026-01-08 17:52:07 +00:00
parent ece291f0be
commit be9e7bc035
1 changed files with 6 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

6
src/services/lnd/lnd.ts
View file

@ -55,6 +55,7 @@ export default class {
liquidProvider: LiquidityProvider liquidProvider: LiquidityProvider
utils: Utils utils: Utils
unlockLnd: () => Promise<void> unlockLnd: () => Promise<void>
addressesCache: Record<string, { isChange: boolean }> = {}
constructor(getSettings: () => { lndSettings: LndSettings, lndNodeSettings: LndNodeSettings }, liquidProvider: LiquidityProvider, unlockLnd: () => Promise<any>, utils: Utils, addressPaidCb: AddressPaidCb, invoicePaidCb: InvoicePaidCb, newBlockCb: NewBlockCb, htlcCb: HtlcCb, channelEventCb: ChannelEventCb) { constructor(getSettings: () => { lndSettings: LndSettings, lndNodeSettings: LndNodeSettings }, liquidProvider: LiquidityProvider, unlockLnd: () => Promise<any>, utils: Utils, addressPaidCb: AddressPaidCb, invoicePaidCb: InvoicePaidCb, newBlockCb: NewBlockCb, htlcCb: HtlcCb, channelEventCb: ChannelEventCb) {
this.getSettings = getSettings this.getSettings = getSettings
this.utils = utils this.utils = utils
@ -334,6 +335,10 @@ export default class {
} }
async IsChangeAddress(address: string): Promise<boolean> { async IsChangeAddress(address: string): Promise<boolean> {
const cached = this.addressesCache[address]
if (cached) {
return cached.isChange
}
const addresses = await this.ListAddresses() const addresses = await this.ListAddresses()
const addr = addresses.find(a => a.address === address) const addr = addresses.find(a => a.address === address)
if (!addr) { if (!addr) {
@ -345,6 +350,7 @@ export default class {
async ListAddresses(): Promise<LndAddress[]> { async ListAddresses(): Promise<LndAddress[]> {
const res = await this.walletKit.listAddresses({ accountName: "", showCustomAccounts: false }, DeadLineMetadata()) const res = await this.walletKit.listAddresses({ accountName: "", showCustomAccounts: false }, DeadLineMetadata())
const addresses = res.response.accountWithAddresses.map(a => a.addresses.map(a => ({ address: a.address, change: a.isInternal }))).flat() const addresses = res.response.accountWithAddresses.map(a => a.addresses.map(a => ({ address: a.address, change: a.isInternal }))).flat()
addresses.forEach(a => this.addressesCache[a.address] = { isChange: a.change })
return addresses return addresses
} }