update: add event history api for mantle

crypitor · May 20, 2024 · 6118c7a · 6118c7a
1 parent 96daca4
commit 6118c7a
Showing 1 changed file with 48 additions and 0 deletions.
diff --git a/app/apps/onebox/src/modules/event_history/event_history.service.ts b/app/apps/onebox/src/modules/event_history/event_history.service.ts
@@ -69,6 +69,16 @@ export class EventHistoryService {
         });
     }
 
+    if (monitor.network === MonitorNetwork.Mantle) {
+      return this.avaxEventHistoryRepository
+        .getEventHistory(monitor.monitorId, request.limit, request.offset)
+        .then((response) => {
+          return response.map((event) =>
+            MonitorEventHistoryResponseDto.from(event),
+          );
+        });
+    }
+
     this.logger.error(`network ${monitor.network} not supported`);
     throw ErrorCode.INTERNAL_SERVER_ERROR.asException();
   }
@@ -129,6 +139,21 @@ export class EventHistoryService {
         });
     }
 
+    if (monitor.network === MonitorNetwork.Mantle) {
+      return this.avaxEventHistoryRepository
+        .findEventHistoryByMonitorAndHash(
+          monitor.monitorId,
+          request.hash,
+          request.limit,
+          request.offset,
+        )
+        .then((response) => {
+          return response.map((event) =>
+            MonitorEventHistoryResponseDto.from(event),
+          );
+        });
+    }
+
     this.logger.error(`network ${monitor.network} not supported`);
     throw ErrorCode.INTERNAL_SERVER_ERROR.asException();
   }
@@ -189,6 +214,21 @@ export class EventHistoryService {
         });
     }
 
+    if (monitor.network === MonitorNetwork.Mantle) {
+      return this.avaxEventHistoryRepository
+        .findEventHistoryByMonitorAndHash(
+          monitor.monitorId,
+          request.associatedAddress,
+          request.limit,
+          request.offset,
+        )
+        .then((response) => {
+          return response.map((event) =>
+            MonitorEventHistoryResponseDto.from(event),
+          );
+        });
+    }
+
     this.logger.error(`network ${monitor.network} not supported`);
     throw ErrorCode.INTERNAL_SERVER_ERROR.asException();
   }
@@ -228,6 +268,14 @@ export class EventHistoryService {
         });
     }
 
+    if (monitor.network === MonitorNetwork.Mantle) {
+      return this.avaxEventHistoryRepository
+        .findByEventId(request.eventId)
+        .then((response) => {
+          return MonitorEventHistoryResponseDto.from(response);
+        });
+    }
+
     this.logger.error(`network ${monitor.network} not supported`);
     throw ErrorCode.INTERNAL_SERVER_ERROR.asException();
   }