waiting for relayer info update

helix-bridge · Jan 26, 2024 · e6b3e10 · e6b3e10
1 parent 01c38c9
commit e6b3e10
Showing 1 changed file with 20 additions and 11 deletions.
diff --git a/apollo/src/lnv3/lnv3.service.ts b/apollo/src/lnv3/lnv3.service.ts
@@ -196,6 +196,23 @@ export class Lnv3Service implements OnModuleInit {
             let requestWithdrawTimestamp = Number(relayRecord.requestWithdrawTimestamp);
             let endTxHash = record.endTxHash;
             if (record.result !== RecordStatus.success) {
+              const providerId = this.genRelayInfoID(
+                transfer.chainId,
+                toChain.chainId,
+                record.relayer,
+                record.sendTokenAddress
+              );
+              const relayerInfo = await this.aggregationService.queryLnBridgeRelayInfoById({
+                id: providerId,
+              });
+              // waiting for relayer info update
+              if (!relayerInfo) {
+                this.logger.log(
+                  `lnv3 [${transfer.chain}->${toChain.chain}] waiting for relayer info update, id: ${providerId}`
+                );
+                continue;
+              }
+
               if (relayRecord.slashed) {
                 needWithdrawLiquidity = false;
               }
@@ -217,17 +234,9 @@ export class Lnv3Service implements OnModuleInit {
                 data: updateData,
               });
 
-              const cost = relayRecord.slashed ? relayRecord.fee : 0;
-              const profit = relayRecord.slashed ? record.fee : 0;
-              const providerId = this.genRelayInfoID(
-                transfer.chainId,
-                toChain.chainId,
-                record.relayer,
-                record.sendTokenAddress
-              );
-              const relayerInfo = await this.aggregationService.queryLnBridgeRelayInfoById({
-                id: providerId,
-              });
+              const cost = relayRecord.slashed ? 0 : relayRecord.fee;
+              const profit = relayRecord.slashed ? 0 : record.fee;
+
               await this.aggregationService.updateLnBridgeRelayInfo({
                 where: { id: providerId },
                 data: {