feat(sqlmesh): create fee revenue models for oracles (#5321)

Author: ccerv1

warehouse/oso_sqlmesh/models/intermediate/domain-specific/superchain/oracles/int_optimism_oracles_direct_fees_daily.sql

@@ -0,0 +1,44 @@
+MODEL (
+  name oso.int_optimism_oracles_direct_fees_daily,
+  description "Optimism oracles direct fees daily",
+  dialect trino,
+  kind incremental_by_time_range(
+   time_column bucket_day,
+   batch_size 60,
+   batch_concurrency 1,
+   lookback 14,
+   forward_only true,
+   on_destructive_change warn,
+  ),
+  start @blockchain_incremental_start,
+  cron '@daily',
+  partitioned_by MONTH("bucket_day"),
+  audits (
+    has_at_least_n_rows(threshold := 0),
+  ),
+  ignored_rules (
+    "incrementalmustdefinenogapsaudit",
+    "incrementalmusthaveforwardonly",
+  ),
+);
+
+WITH events AS (
+  SELECT
+    DATE_TRUNC('DAY', block_timestamp) AS bucket_day,
+    project_name AS oracle_name,
+    to_address_trace AS oracle_address,
+    gas_used_trace::DOUBLE / 1e18 * gas_price_tx::DOUBLE AS read_fees,
+    transaction_hash
+  FROM oso.int_optimism_static_calls_to_oracles
+  WHERE block_timestamp BETWEEN @start_dt AND @end_dt
+)
+
+SELECT
+  bucket_day,
+  oracle_name,
+  oracle_address,
+  SUM(read_fees) AS read_fees,
+  COUNT(DISTINCT transaction_hash) AS transaction_count
+FROM events
+GROUP BY 1, 2, 3
+ORDER BY 1, 2

warehouse/oso_sqlmesh/models/intermediate/domain-specific/superchain/oracles/int_optimism_oracles_indirect_fees_daily.sql

@@ -0,0 +1,77 @@
+MODEL (
+  name oso.int_optimism_oracles_indirect_fees_daily,
+  description "Optimism oracles indirect fees daily",
+  dialect trino,
+  kind incremental_by_time_range(
+   time_column bucket_day,
+   batch_size 60,
+   batch_concurrency 1,
+   lookback 14,
+   forward_only true,
+   on_destructive_change warn,
+  ),
+  start @blockchain_incremental_start,
+  cron '@daily',
+  partitioned_by MONTH("bucket_day"),
+  audits (
+    has_at_least_n_rows(threshold := 0),
+  ),
+  ignored_rules (
+    "incrementalmustdefinenogapsaudit",
+    "incrementalmusthaveforwardonly",
+  ),
+);
+
+WITH events AS (
+  SELECT
+    DATE_TRUNC('DAY', block_timestamp) AS bucket_day,
+    project_name AS oracle_name,
+    to_address_tx AS to_address,
+    gas_used_tx::DOUBLE / 1e18 * gas_price_tx::DOUBLE AS l2_tx_fees,
+    transaction_hash
+  FROM oso.int_optimism_static_calls_to_oracles
+  WHERE
+    block_timestamp BETWEEN @start_dt AND @end_dt
+    AND project_name IS NOT NULL
+),
+oracles_per_txn AS (
+  SELECT
+    transaction_hash,
+    COUNT(DISTINCT oracle_name) AS num_oracles
+  FROM events
+  GROUP BY 1
+),
+amortized_events AS (
+  SELECT
+    bucket_day,
+    oracle_name,
+    to_address,
+    SUM(l2_tx_fees / num_oracles) AS l2_tx_fees,
+    SUM(1.0 / num_oracles) AS tx_count
+  FROM events
+  JOIN oracles_per_txn
+    ON events.transaction_hash = oracles_per_txn.transaction_hash
+  GROUP BY 1, 2, 3
+),
+apps AS (
+  SELECT DISTINCT
+    artifact_name,
+    project_name AS to_project_name
+  FROM oso.artifacts_by_project_v1
+  WHERE
+    project_source = 'OSS_DIRECTORY'
+    AND project_namespace = 'oso'
+    AND artifact_source = 'OPTIMISM'
+)
+
+SELECT
+  ae.bucket_day,
+  ae.oracle_name,
+  ae.to_address,
+  apps.to_project_name,
+  ae.l2_tx_fees,
+  ae.tx_count
+FROM amortized_events AS ae
+LEFT JOIN apps
+  ON ae.to_address = apps.artifact_name
+ORDER BY 1