chore: add poolId or stakeAddress into ReportMessage

cardano-foundation · Apr 25, 2024 · 8146ad7 · 8146ad7
1 parent 67d7646
commit 8146ad7
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/src/main/java/org/cardanofoundation/explorer/api/service/impl/PoolReportServiceImpl.java b/src/main/java/org/cardanofoundation/explorer/api/service/impl/PoolReportServiceImpl.java
@@ -85,6 +85,7 @@ public Boolean create(
             .timePattern(poolReportCreateRequest.getTimePattern())
             .zoneOffset(poolReportCreateRequest.getZoneOffset())
             .dateFormat(poolReportCreateRequest.getDateFormat())
+            .poolId(poolReportCreateRequest.getPoolId())
             .build();
 
     Boolean isSuccess = kafkaService.sendReportHistory(reportMessage);

diff --git a/src/main/java/org/cardanofoundation/explorer/api/service/impl/StakeKeyReportServiceImpl.java b/src/main/java/org/cardanofoundation/explorer/api/service/impl/StakeKeyReportServiceImpl.java
@@ -76,6 +76,7 @@ public StakeKeyReportHistoryResponse generateStakeKeyReport(
             .timePattern(stakeKeyReportRequest.getTimePattern())
             .zoneOffset(stakeKeyReportRequest.getZoneOffset())
             .dateFormat(stakeKeyReportRequest.getDateFormat())
+            .stakeAddress(stakeKeyReportRequest.getStakeKey())
             .build();
 
     Boolean isSuccess = kafkaService.sendReportHistory(reportMessage);