filter offline relayers

helix-bridge · Jan 18, 2024 · c467a26 · c467a26
1 parent e20e5d5
commit c467a26
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/apollo/src/aggregation/aggregation.resolver.ts b/apollo/src/aggregation/aggregation.resolver.ts
@@ -5,6 +5,7 @@ import { Prisma } from '@prisma/client';
 
 @Resolver()
 export class AggregationResolver {
+  private readonly heartbeatTimeout = 300;
   constructor(private aggregationService: AggregationService) {}
 
   @Query()
@@ -302,6 +303,7 @@ export class AggregationResolver {
     // query all pending txs
     var sortedRelayers = [];
     var transferLimit = BigInt(0);
+    const now = Math.floor(Date.now() / 1000);
     for (const record of records.records) {
       const limit = record.version == 'lnv2' ? BigInt(record.margin) : BigInt(record.transferLimit);
       if (limit > transferLimit) {
@@ -311,6 +313,10 @@ export class AggregationResolver {
       if (limit < BigInt(amount) + providerFee + BigInt(record.protocolFee) || record.paused) {
         continue;
       }
+      // offline
+      if (record.heartbeatTimestamp + this.heartbeatTimeout < now) {
+        continue;
+      }
       const point = await this.aggregationService.calculateLnBridgeRelayerPoint(
         token,
         BigInt(amount),