Fix metaplex fees + added metaplex mints

models/projects/metaplex/core/ez_metaplex_metrics.sql

@@ -58,9 +58,9 @@ with date_spine as (
 , mints as (
     select
         date
-        , sum(daily_mints) as daily_mints
+        , daily_mints
+        , cumulative_mints
     from {{ ref("fact_metaplex_assets_minted") }}
-    group by 1
 )
 , price as (
     {{get_coingecko_metrics('metaplex')}}
@@ -69,10 +69,11 @@ with date_spine as (
 SELECT
     ds.date
     , coalesce(revenue.revenue_usd, 0) as fees
-    , coalesce(revenue.revenue_usd, 0) / 2 as revenue -- Fees are paid continuously, but revenue is only recognized at the time of the buyback
+    , coalesce(revenue.revenue_usd, 0) as revenue -- Fees + Revenue are same - 50% fees go to buybacks | the other 50% goes to dao treasury.
     , coalesce(buybacks.buyback, 0) as buyback -- 50% of fees (ie all of revenue) go to buybacks but buybacks are done in batches, at the time of the buyback
     , coalesce(buybacks.buyback_native, 0) as buyback_native
     , coalesce(mints.daily_mints, 0) as daily_mints
+    , coalesce(mints.cumulative_mints, 0) as cumulative_mints
     , coalesce(active_wallets.dau, 0) as dau
     , coalesce(transactions.txns, 0) as txns
     , coalesce(unique_signers.unique_signers, 0) as unique_signers

models/staging/metaplex/fact_metaplex_assets_minted.sql

@@ -3,10 +3,10 @@
     snowflake_warehouse="METAPLEX"
 ) }}
 
-WITH daily_mints AS (
+WITH metaplex_mints AS (
     SELECT 
         date,
-        COUNT(DISTINCT mint) AS daily_mints,
+        COUNT(DISTINCT mint) AS mints,
         COUNT_IF(program_id = 'BGUMAp9Gq7iTEuizy4pqaxsTyUCBK68MDfK752saRPUY') AS daily_bubblegum_mints,
         COUNT_IF(program_id = 'metaqbxxUerdq28cj1RbAWkYQm3ybzjb6a8bt518x1s') AS daily_token_metadata_mints,
         COUNT_IF(program_id IN (
@@ -21,15 +21,15 @@ WITH daily_mints AS (
 
 SELECT 
     date,
-    daily_mints,
-    SUM(daily_mints) OVER (ORDER BY date) AS cumulative_mints,
+    mints as daily_mints,
+    SUM(mints) OVER (ORDER BY date) as cumulative_mints,
     daily_bubblegum_mints,
     daily_token_metadata_mints,
     daily_candymachine_mints,
     SUM(daily_bubblegum_mints) OVER (ORDER BY date) AS cumulative_bubblegum_mints,
     SUM(daily_token_metadata_mints) OVER (ORDER BY date) AS cumulative_token_metadata_mints,
     SUM(daily_candymachine_mints) OVER (ORDER BY date) AS cumulative_candymachine_mints
 FROM 
-    daily_mints
+    metaplex_mints
 ORDER BY 
-    date DESC
+    date DESC

models/staging/metaplex/fact_metaplex_buybacks.sql

@@ -1,14 +1,15 @@
 {{ config(
     materialized= "incremental",
+    unique_key="date",
     snowflake_warehouse="METAPLEX"
 ) }}
 
 WITH 
 buybacks AS (
     select 
        date_trunc('day', block_timestamp) as date
-       , amount 
-       , mint as token_address
+       , max(amount) as amount
+       , max(mint) as token_address
     from solana_flipside.core.fact_transfers 
     where tx_to = 'E7Hzc1cQwx5BgJa8hJGVuDF2G2f2penLrhiKU6nU53gK' and tx_from = 'BBcPaj5v95nFFbXfgTebYyJDSY5HBCpARuRCLynVWimp'
     and mint = 'METAewgxyPbgwsseH8T16a39CQ5VyVxZi9zXiDPY18m'
@@ -17,18 +18,20 @@ buybacks AS (
     {% else %}
     and block_timestamp >= '2024-06-26'
     {% endif %}
+    GROUP BY date
 )
 , prices AS (
     {{ get_coingecko_price_with_latest('metaplex') }}
 )
 SELECT
     b.date,
-    b.amount as buyback_native,
-    b.amount * p.price AS buyback
+    MAX(b.amount) as buyback_native,
+    MAX(b.amount * p.price) AS buyback
 FROM
     buybacks b
 LEFT JOIN
     prices p
     ON b.date = p.date
+GROUP BY b.date
 ORDER BY
     b.date DESC

models/staging/metaplex/fact_metaplex_mints.sql

@@ -25,4 +25,4 @@ WHERE
     )
     {% if is_incremental() %}
         AND block_timestamp > (SELECT MAX(date) FROM {{ this }})
-    {% endif %}
+    {% endif %}

models/staging/metaplex/fact_metaplex_sales.sql

@@ -13,5 +13,5 @@ FROM
 JOIN 
     {{ ref('fact_metaplex_mints') }} AS m ON s.mint = m.mint
 {% if is_incremental() %}
-    AND block_timestamp > (SELECT MAX(block_timestamp) FROM {{ this }})
-{% endif %}
+    WHERE block_timestamp > (SELECT MAX(block_timestamp) FROM {{ this }})
+{% endif %}