Skip to content

Commit

Permalink
info
Browse files Browse the repository at this point in the history
  • Loading branch information
wsdt committed Mar 2, 2024
1 parent e6a3824 commit ec3d983
Showing 1 changed file with 14 additions and 5 deletions.
19 changes: 14 additions & 5 deletions src/service.ts
Original file line number Diff line number Diff line change
Expand Up @@ -396,7 +396,7 @@ export class LightBridgeService extends BaseService<TeleportationOptions> {
)
approvePending.push(approveTx.wait())
} else {
this.logger.debug(
this.logger.info(
`Not triggering new approve function, since already approved: ${approvedAmount} for token ${token[0]}`
)
}
Expand All @@ -419,7 +419,7 @@ export class LightBridgeService extends BaseService<TeleportationOptions> {

sliceStart = sliceEnd
sliceEnd = Math.min(sliceEnd + 10, numberOfDisbursement)
this.logger.debug(`Disbursement Slice disbursed: `, {
this.logger.info(`Disbursement Slice disbursed: `, {
disburseTx: disburseTx?.hash,
chainId: disburseTx?.chainId,
})
Expand Down Expand Up @@ -459,9 +459,15 @@ export class LightBridgeService extends BaseService<TeleportationOptions> {
): Promise<Disbursement[]> => {
// totalDisbursements[sourceChainId]
const nextDepositIds: { [sourceChainId: number]: number } = {}
this.logger.debug(`Unfiltered disbursements for db recovery: `, {disbursements})
this.logger.info(`Unfiltered disbursements for db recovery: `, {
disbursements,
})
disbursements = disbursements.filter(async (d) => {
this.logger.debug(`Filter iteration for new disbursements (db recover)`, {disbursement: d, sourceChain: d.sourceChainId, nextDepositIds})
this.logger.info(`Filter iteration for new disbursements (db recover)`, {
disbursement: d,
sourceChain: d.sourceChainId,
nextDepositIds,
})
if (!nextDepositIds[d.sourceChainId]) {
// load into mapping if not yet done
nextDepositIds[d.sourceChainId] =
Expand All @@ -470,7 +476,10 @@ export class LightBridgeService extends BaseService<TeleportationOptions> {
// only try to disburse those who haven't been disbursed from a previous service already before DB state got lost
return d.depositId >= nextDepositIds[d.sourceChainId]
})
this.logger.debug(`Filtered disbursements for db recovery: `, {disbursements, nextDepositIdsKeys: Object.keys(nextDepositIds)})
this.logger.info(`Filtered disbursements for db recovery: `, {
disbursements,
nextDepositIdsKeys: Object.keys(nextDepositIds),
})

for (const sourceChainId of Object.keys(nextDepositIds)) {
const nextDisbursement = disbursements.find(
Expand Down

0 comments on commit ec3d983

Please sign in to comment.