Stablecoin V2: Optimism Pipeline (#318)

macros/address_balances/address_balances_by_token.sql

@@ -12,6 +12,17 @@
             {% if is_incremental() %}
                 where block_timestamp > (select max(block_timestamp) from {{ this }})
             {% endif %}
+            {% if chain in ('optimism') %}
+            -- Some chains had a re-genesis event, if this is the case we need to include the genesis balances
+
+                union all
+                select address, contract_address, block_timestamp, balance as flow
+                from {{ref("fact_"~chain~"_genesis_stablecoin_balances")}}
+                {% if is_incremental() %}
+                    where block_timestamp > (select max(block_timestamp) from {{ this }})
+                {% endif %}
+            {% endif %}
+
         ),
         credit_debits_and_latest_balances as (
             select address, contract_address, block_timestamp, flow

macros/stablecoins/genesis_stablecoin_balances.sql

@@ -0,0 +1,11 @@
+{% macro genesis_stablecoin_balances(source_table, genesis_timestamp) %}
+
+    select
+        '{{genesis_timestamp}}'::timestamp as block_timestamp
+        , lower(value:contract_address::string) as contract_address
+        , lower(value:address::string) as address
+        , value:balance::float as balance
+    from {{ source("PROD_LANDING", source_table)}},
+        lateral flatten(input => parse_json(source_json))
+    where extraction_date = (select max(extraction_date) from {{ source("PROD_LANDING", source_table)}})
+{% endmacro %}

models/projects/optimism/core/ez_optimism_stablecoin_metrics_by_address.sql

@@ -0,0 +1,13 @@
+{{
+    config(
+        materialized="incremental",
+        unique_key="unique_id",
+        database="optimism",
+        schema="core",
+        alias="ez_stablecoin_metrics_by_address",
+        snowflake_warehouse="STABLECOIN_V2_LG_2",
+    )
+}}
+
+
+{{stablecoin_metrics("optimism")}}

models/staging/optimism/__optimism__sources.yml

@@ -4,3 +4,10 @@ sources:
     database: PC_DBT_DB
     tables:
       - name: dim_optimism_current_balances
+  - name: PROD_LANDING
+    schema: PROD_LANDING
+    database: LANDING_DATABASE
+    tables:
+      - name: raw_optimism_genesis_dai_stablecoin_balances
+      - name: raw_optimism_genesis_usdce_stablecoin_balances
+      - name: raw_optimism_genesis_usdt_stablecoin_balances

models/staging/optimism/fact_optimism_genesis_stablecoin_balances.sql

@@ -0,0 +1,16 @@
+{{ config(materialized="table") }}
+
+{% set genesis_timestamp = "2021-11-10 00:00:00.000" %}
+
+with
+    dai as ({{genesis_stablecoin_balances("raw_optimism_genesis_dai_stablecoin_balances", genesis_timestamp)}})
+
+    , usdce as ({{genesis_stablecoin_balances("raw_optimism_genesis_usdce_stablecoin_balances", genesis_timestamp)}})
+
+    , usdt as ({{genesis_stablecoin_balances("raw_optimism_genesis_usdt_stablecoin_balances", genesis_timestamp)}})
+
+select * from dai
+union all
+select * from usdce
+union all 
+select * from usdt

models/staging/optimism/fact_optimism_stablecoin_balances.sql

@@ -0,0 +1,10 @@
+{{
+    config(
+        materialized="incremental",
+        unique_key="unique_id",
+        snowflake_warehouse="STABLECOIN_V2_LG_2",
+    )
+}}
+
+
+{{stablecoin_balances("optimism")}}

models/staging/optimism/fact_optimism_stablecoin_metrics_all.sql

@@ -0,0 +1,10 @@
+{{
+    config(
+        materialized="incremental",
+        unique_key="unique_id",
+        snowflake_warehouse="STABLECOIN_V2_LG_2",
+    )
+}}
+
+
+{{stablecoin_metrics_all("optimism")}}

models/staging/optimism/fact_optimism_stablecoin_metrics_artemis.sql

@@ -0,0 +1,10 @@
+{{
+    config(
+        materialized="incremental",
+        unique_key="unique_id",
+        snowflake_warehouse="STABLECOIN_V2_LG_2",
+    )
+}}
+
+
+{{stablecoin_metrics_p2p("optimism")}}

models/staging/optimism/fact_optimism_stablecoin_metrics_p2p.sql

@@ -0,0 +1,10 @@
+{{
+    config(
+        materialized="incremental",
+        unique_key="unique_id",
+        snowflake_warehouse="STABLECOIN_V2_LG_2",
+    )
+}}
+
+
+{{stablecoin_metrics_p2p("optimism")}}