add refresh total ibc status

mapofzones · Aug 6, 2024 · 34ef3d6 · 34ef3d6
1 parent b79c6dc
commit 34ef3d6
Show file tree

Hide file tree

Showing 4 changed files with 29 additions and 0 deletions.
diff --git a/src/main/java/com/mapofzones/adaptor/data/repository/CustomProcedureRepository.java b/src/main/java/com/mapofzones/adaptor/data/repository/CustomProcedureRepository.java
@@ -21,6 +21,10 @@ public void updateBlockchainStatsFromIbc() {
         jdbcTemplate.execute("CALL public.update_flat_tables_ibc_txs(date_trunc('day', now())::timestamp without time zone);");
     }
 
+    public void updateAlltimeIbcStats() {
+        jdbcTemplate.execute("REFRESH MATERIALIZED VIEW mv_ibc_transfer_stats;");
+    }
+
     public void executeBlockchainCosmoshubStub() {
         jdbcTemplate.execute("" +
                 "UPDATE\n" +

diff --git a/src/main/java/com/mapofzones/adaptor/processor/Processor.java b/src/main/java/com/mapofzones/adaptor/processor/Processor.java
@@ -32,4 +32,12 @@ public void updateBlockchainStatsFromIbc() {
         System.out.println("Finished updating blockchain stats from ibc!");
         System.out.println("---------------");
     }
+
+    @Transactional
+    public void updateAlltimeIbcStats() {
+        System.out.println("Starting running update alltime ibc stats");
+        customProcedureRepository.updateAlltimeIbcStats();
+        System.out.println("Finished updating alltime blockchain stats from ibc!");
+        System.out.println("---------------");
+    }
 }
diff --git a/src/main/java/com/mapofzones/adaptor/scheduler/GetDataScheduler.java b/src/main/java/com/mapofzones/adaptor/scheduler/GetDataScheduler.java
@@ -35,6 +35,9 @@ public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
             case "update_blockchain_stats_from_ibc":
                 updateBlockchainStatsFromIbcScheduler(taskRegistrar);
                 break;
+            case "update_all_time_ibc_stats":
+                updateAlltimeIbcStatsScheduler(taskRegistrar);
+                break;
             default:
                 System.out.println("No matching command-to-run value. Make sure to set it in the configurations.");
                 System.out.println("Available commands: update-flat-tables, update_blockchain_stats_from_ibc");
@@ -60,4 +63,14 @@ public void updateBlockchainStatsFromIbcScheduler(ScheduledTaskRegistrar taskReg
             this.updateBlockchainStatsSyncTime
         );
     }
+
+    public void updateAlltimeIbcStatsScheduler(ScheduledTaskRegistrar taskRegistrar) {
+        processor.updateAlltimeIbcStats();
+        taskRegistrar.addFixedDelayTask(
+            () -> {
+                processor.updateAlltimeIbcStats();
+            },
+            Long.parseLong(updateFlatTablesSyncTime)
+        );
+    }
 }
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
@@ -8,6 +8,10 @@ commands:
   update_blockchain_stats_from_ibc:
     # 00:10 UTC every day
     sync-time: "10 0 0 * * ?"
+
+  update_all_time_ibc_stats:
+    # every one hour
+    sync-time: 3600000
 
 spring:
   main: