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

Merge remote-tracking branch 'refs/remotes/origin/fix/bootstrap' into fix/bootstrap

Browse source
This commit is contained in:
Justin (shocknet) 2024-07-16 17:11:34 -04:00
commit 3c078a857e
2 changed files with 5 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -79,11 +79,11 @@ export class LiquidityProvider {
Connect = async () => {
await new Promise(res => setTimeout(res, 2000))
this.log("ready")
const res = await this.GetUserState()
if (res.status === 'ERROR') {
if (res.status === 'ERROR' && res.reason !== 'timeout') {
return
}
this.log("provider ready with balance:", res.status === 'OK' ? res.balance : 0)
this.ready = true
this.queue.forEach(q => q('ready'))
this.log("subbing to user operations")
@ -101,9 +101,9 @@ export class LiquidityProvider {
}
GetUserState = async () => {
const res = await this.client.GetUserInfo()
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') {
this.log("error getting user info", res)
this.log("error getting user info", res.reason)
return res
}
this.utils.stateBundler.AddBalancePoint('providerBalance', res.balance)

2
src/services/main/rugPullTracker.ts
View file

@ -43,7 +43,7 @@ export class RugPullTracker {
}
checkForDisruption = async (pubDst: string, trackedBalance: number, providerTracker: TrackedProvider) => {
const diff = providerTracker.latest_balance - trackedBalance
const diff = trackedBalance - providerTracker.latest_balance
this.log({ latestBalance: providerTracker.latest_balance, diff })
if (diff < 0) {
this.rugPulled = true