BQ: add daily coin price (#2224)

Signed-off-by: Itai Segall <itai.segall@digitalasset.com>

Author: isegall-da

apps/app/src/test/scala/org/lfdecentralizedtrust/splice/integration/tests/ScanTotalSupplyBigQueryIntegrationTest.scala

@@ -43,7 +43,8 @@ class ScanTotalSupplyBigQueryIntegrationTest
       .withScanDisabledMiningRoundsCache()
       .withAmuletPrice(walletAmuletPrice)
 
-  override def walletAmuletPrice = SpliceUtil.damlDecimal(0.00001)
+  def coinPrice = BigDecimal(0.00001)
+  override def walletAmuletPrice = SpliceUtil.damlDecimal(coinPrice)
 
   override protected def runTokenStandardCliSanityCheck = false
 
@@ -553,6 +554,9 @@ class ScanTotalSupplyBigQueryIntegrationTest
       numActiveValidators: Long,
       avgTps: Double,
       peakTps: Double,
+      minCoinPrice: BigDecimal,
+      maxCoinPrice: BigDecimal,
+      avgCoinPrice: BigDecimal,
   )
 
   private def parseQueryResults(result: bq.TableResult) = {
@@ -593,6 +597,9 @@ class ScanTotalSupplyBigQueryIntegrationTest
       numActiveValidators = int("num_active_validators"),
       avgTps = float("average_tps"),
       peakTps = float("peak_tps"),
+      minCoinPrice = bd("daily_min_coin_price"),
+      maxCoinPrice = bd("daily_max_coin_price"),
+      avgCoinPrice = bd("daily_avg_coin_price"),
     )
   }
 
@@ -612,6 +619,9 @@ class ScanTotalSupplyBigQueryIntegrationTest
         ("current_supply_total", results.currentSupplyTotal, lockedAmount + unlockedAmount),
         ("num_amulet_holders", results.numAmuletHolders, amuletHolders),
         ("num_active_validators", results.numActiveValidators, validators),
+        ("daily_min_coin_price", results.minCoinPrice, coinPrice),
+        ("daily_max_coin_price", results.maxCoinPrice, coinPrice),
+        ("daily_avg_coin_price", results.avgCoinPrice, coinPrice),
       )
     ) { case (clue, actual, expected) =>
       actual shouldBe expected withClue clue

cluster/pulumi/canton-network/src/bigQuery.ts

@@ -225,6 +225,9 @@ function installDashboardsDataset(): gcp.bigquery.Dataset {
         { name: 'num_active_validators', type: 'INT64' },
         { name: 'average_tps', type: 'FLOAT64' },
         { name: 'peak_tps', type: 'FLOAT64' },
+        { name: 'daily_min_coin_price', type: 'BIGNUMERIC' },
+        { name: 'daily_max_coin_price', type: 'BIGNUMERIC' },
+        { name: 'daily_avg_coin_price', type: 'BIGNUMERIC' },
       ]),
     },
     { dependsOn: [dataset] }

cluster/pulumi/canton-network/src/bigQuery_functions.ts

@@ -558,6 +558,32 @@ const peak_tps = new BQScalarFunction(
   `
 );
 
+const coin_price = new BQScalarFunction(
+  'coin_price',
+  time_window_args,
+  new BQStruct([
+    { name: 'minPrice', type: BIGNUMERIC },
+    { name: 'maxPrice', type: BIGNUMERIC },
+    { name: 'avgPrice', type: BIGNUMERIC },
+  ]),
+  `
+    (SELECT AS
+      STRUCT
+        MIN(\`$$FUNCTIONS_DATASET$$.daml_record_numeric\`(c.create_arguments, [2])),
+        MAX(\`$$FUNCTIONS_DATASET$$.daml_record_numeric\`(c.create_arguments, [2])),
+        AVG(\`$$FUNCTIONS_DATASET$$.daml_record_numeric\`(c.create_arguments, [2]))
+    FROM \`$$SCAN_DATASET$$.scan_sv_1_update_history_creates\` c
+      WHERE template_id_entity_name = 'SummarizingMiningRound'
+      AND c.template_id_module_name = 'Splice.Round'
+      AND package_name = 'splice-amulet'
+      AND \`$$FUNCTIONS_DATASET$$.in_time_window\`(
+        start_record_time, start_migration_id,
+        up_to_record_time, up_to_migration_id,
+        c.record_time, c.migration_id
+    ))
+  `
+);
+
 const all_stats = new BQTableFunction(
   'all_stats',
   as_of_args,
@@ -577,6 +603,9 @@ const all_stats = new BQTableFunction(
     new BQColumn('num_active_validators', INT64),
     new BQColumn('average_tps', FLOAT64),
     new BQColumn('peak_tps', FLOAT64),
+    new BQColumn('daily_min_coin_price', BIGNUMERIC),
+    new BQColumn('daily_max_coin_price', BIGNUMERIC),
+    new BQColumn('daily_avg_coin_price', BIGNUMERIC),
   ],
   `
     SELECT
@@ -619,7 +648,25 @@ const all_stats = new BQTableFunction(
       \`$$FUNCTIONS_DATASET$$.num_amulet_holders\`(as_of_record_time, migration_id) as num_amulet_holders,
       \`$$FUNCTIONS_DATASET$$.num_active_validators\`(as_of_record_time, migration_id) as num_active_validators,
       IFNULL(\`$$FUNCTIONS_DATASET$$.average_tps\`(as_of_record_time, migration_id), 0.0) as average_tps,
-      IFNULL(\`$$FUNCTIONS_DATASET$$.peak_tps\`(as_of_record_time, migration_id), 0.0) as peak_tps
+      IFNULL(\`$$FUNCTIONS_DATASET$$.peak_tps\`(as_of_record_time, migration_id), 0.0) as peak_tps,
+      \`$$FUNCTIONS_DATASET$$.coin_price\`(
+            TIMESTAMP_SUB(as_of_record_time, INTERVAL 24 HOUR),
+            \`$$FUNCTIONS_DATASET$$.migration_id_at_time\`(TIMESTAMP_SUB(as_of_record_time, INTERVAL 24 HOUR)),
+            as_of_record_time,
+            migration_id).minPrice
+          AS daily_min_coin_price,
+      \`$$FUNCTIONS_DATASET$$.coin_price\`(
+            TIMESTAMP_SUB(as_of_record_time, INTERVAL 24 HOUR),
+            \`$$FUNCTIONS_DATASET$$.migration_id_at_time\`(TIMESTAMP_SUB(as_of_record_time, INTERVAL 24 HOUR)),
+            as_of_record_time,
+            migration_id).maxPrice
+          AS daily_max_coin_price,
+      \`$$FUNCTIONS_DATASET$$.coin_price\`(
+            TIMESTAMP_SUB(as_of_record_time, INTERVAL 24 HOUR),
+            \`$$FUNCTIONS_DATASET$$.migration_id_at_time\`(TIMESTAMP_SUB(as_of_record_time, INTERVAL 24 HOUR)),
+            as_of_record_time,
+            migration_id).avgPrice
+          AS daily_avg_coin_price
   `
 );
 
@@ -672,6 +719,9 @@ const days_with_missing_stats = new BQTableFunction(
             AND num_active_validators IS NOT NULL
             AND average_tps IS NOT NULL
             AND peak_tps IS NOT NULL
+            AND daily_min_coin_price IS NOT NULL
+            AND daily_max_coin_price IS NOT NULL
+            AND daily_avg_coin_price IS NOT NULL
     `
 );
 
@@ -716,6 +766,7 @@ export const allScanFunctions = [
   one_day_updates,
   average_tps,
   peak_tps,
+  coin_price,
   all_stats,
 ];