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

debug

Browse source
This commit is contained in:
shocknet-justin 2025-12-19 02:06:31 -05:00
parent 5902e6cc72
commit ddafc2db2a
1 changed files with 38 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

39
src/services/main/liquidityProvider.ts
View file

@ -57,10 +57,14 @@ export class LiquidityProvider {
}, this.clientSend, this.clientSub)
this.utils.nostrSender.OnReady(() => {
this.log("nostrSender is ready, checking if liquidity provider can be configured")
this.setSetIfConfigured()
if (this.configured) {
this.log("liquidity provider configured, clearing interval and connecting")
clearInterval(this.configuredInterval)
this.Connect()
} else {
this.log("liquidity provider not yet configured, waiting for nostr info")
}
})
this.configuredInterval = setInterval(() => {
@ -68,6 +72,7 @@ export class LiquidityProvider {
this.setSetIfConfigured()
}
if (this.configured) {
this.log("liquidity provider configured via interval, clearing interval and connecting")
clearInterval(this.configuredInterval)
this.Connect()
}
@ -132,6 +137,9 @@ export class LiquidityProvider {
}
GetUserState = async () => {
if (!this.configured || !this.utils.nostrSender.IsReady()) {
throw new Error("liquidity provider not initialized")
}
const res = await Promise.race([this.client.GetUserInfo(), new Promise<Types.ResultError>(res => setTimeout(() => res({ status: 'ERROR', reason: 'timeout' }), 10 * 1000))])
if (res.status === 'ERROR') {
if (res.reason !== 'timeout') {
@ -211,6 +219,11 @@ export class LiquidityProvider {
if (!this.IsReady()) {
throw new Error("liquidity provider is not ready yet, disabled or unreachable")
}
if (!this.configured || !this.utils.nostrSender.IsReady()) {
const reason = !this.configured ? `configured=false (nostrReady=${this.utils.nostrSender.IsReady()}, hasProviderPub=${!!this.providerPubkey}, hasLocalId=${!!this.localId}, hasLocalPubkey=${!!this.localPubkey})` : 'nostrSender not ready'
this.log(`liquidity provider not initialized: ${reason}`)
throw new Error(`liquidity provider not initialized: ${reason}`)
}
const res = await this.client.NewInvoice({ amountSats: amount, memo, expiry })
if (res.status === 'ERROR') {
this.log("error creating invoice", res.reason)
@ -230,6 +243,9 @@ export class LiquidityProvider {
if (!this.IsReady()) {
throw new Error("liquidity provider is not ready yet, disabled or unreachable")
}
if (!this.configured || !this.utils.nostrSender.IsReady()) {
throw new Error("liquidity provider not initialized")
}
const fees = this.GetFees()
const providerServiceFee = this.GetServiceFee(decodedAmount, fees)
if (feeLimit && providerServiceFee > feeLimit) {
@ -269,6 +285,9 @@ export class LiquidityProvider {
if (!this.IsReady()) {
throw new Error("liquidity provider is not ready yet, disabled or unreachable")
}
if (!this.configured || !this.utils.nostrSender.IsReady()) {
throw new Error("liquidity provider not initialized")
}
const res = await this.client.GetPaymentState({ invoice })
if (res.status === 'ERROR') {
this.log("error getting payment state", res.reason)
@ -281,6 +300,9 @@ export class LiquidityProvider {
if (!this.IsReady()) {
throw new Error("liquidity provider is not ready yet, disabled or unreachable")
}
if (!this.configured || !this.utils.nostrSender.IsReady()) {
throw new Error("liquidity provider not initialized")
}
const res = await this.client.GetUserOperations({
latestIncomingInvoice: { ts: 0, id: 0 }, latestOutgoingInvoice: { ts: 0, id: 0 },
latestIncomingTx: { ts: 0, id: 0 }, latestOutgoingTx: { ts: 0, id: 0 }, latestIncomingUserToUserPayment: { ts: 0, id: 0 },
@ -298,13 +320,26 @@ export class LiquidityProvider {
this.localId = localId
this.localPubkey = localPubkey
this.setSetIfConfigured()
// If nostrSender becomes ready after setNostrInfo, ensure we check again
if (!this.configured && this.utils.nostrSender.IsReady()) {
this.setSetIfConfigured()
}
}
setSetIfConfigured = () => {
if (this.utils.nostrSender.IsReady() && !!this.providerPubkey && !!this.localId && !!this.localPubkey) {
const nostrReady = this.utils.nostrSender.IsReady()
const hasProviderPub = !!this.providerPubkey
const hasLocalId = !!this.localId
const hasLocalPubkey = !!this.localPubkey
if (nostrReady && hasProviderPub && hasLocalId && hasLocalPubkey) {
if (!this.configured) {
this.configured = true
this.log("configured to send to ")
this.log("configured to send to provider")
}
} else if (!this.configured) {
this.log(`not configured yet: nostrReady=${nostrReady}, hasProviderPub=${hasProviderPub}, hasLocalId=${hasLocalId}, hasLocalPubkey=${hasLocalPubkey}`)
}
}
onBeaconEvent = async (beaconData: { content: string, pub: string }) => {