yml for silver models

models/descriptions/block_producers.md

@@ -0,0 +1,5 @@
+{% docs block_producers %}
+
+Number of block producers in this epoch.
+
+{% enddocs %}

models/descriptions/blocks.md

@@ -0,0 +1,5 @@
+{% docs blocks %}
+
+Number of blocks included in the epoch.
+
+{% enddocs %}

models/descriptions/circulating_supply.md

@@ -0,0 +1,5 @@
+{% docs circulating_supply %}
+
+Total supply less locked supply.
+
+{% enddocs %}

models/descriptions/deposit_timestamp.md

@@ -0,0 +1,5 @@
+{% docs deposit_timestamp %}
+
+Block timestamp of the initial deposit.
+
+{% enddocs %}

models/descriptions/end_time.md

@@ -0,0 +1,5 @@
+{% docs end_time %}
+
+Block timestamp associated with max block id.
+
+{% enddocs %}

models/descriptions/epoch_num.md

@@ -0,0 +1,5 @@
+{% docs epoch_num %}
+
+Ordinal number of the epoch.
+
+{% enddocs %}

models/descriptions/liquid_supply.md

@@ -0,0 +1,5 @@
+{% docs liquid_supply %}
+
+Nonlocked and nonstaked NEAR.
+
+{% enddocs %}

models/descriptions/locked_amount.md

@@ -0,0 +1,5 @@
+{% docs locked_amount %}
+
+Amount of NEAR still locked.
+
+{% enddocs %}

models/descriptions/lockup_amount.md

@@ -0,0 +1,5 @@
+{% docs lockup_amount %}
+
+The amount, in NEAR, of the initial lockup.
+
+{% enddocs %}

models/descriptions/lockup_end_timestamp.md

@@ -0,0 +1,5 @@
+{% docs lockup_end_timestamp %}
+
+When the lockup period ends, per the lockup config on chain.
+
+{% enddocs %}

models/descriptions/lockup_index.md

@@ -0,0 +1,5 @@
+{% docs lockup_index %}
+
+An ordinal representation of the lockup account, in block_timestamp order.
+
+{% enddocs %}

models/descriptions/lockup_time_left_ns.md

@@ -0,0 +1,5 @@
+{% docs lockup_time_left_ns %}
+
+Time left in the lockup, for the date of record at 00:00 UTC.
+
+{% enddocs %}

models/descriptions/max_block_id.md

@@ -0,0 +1,5 @@
+{% docs max_block_id %}
+
+The end block for the epoch, or max block thus far if the epoch is current.
+
+{% enddocs %}

models/descriptions/min_block_id.md

@@ -0,0 +1,5 @@
+{% docs min_block_id %}
+
+The starting block for the epoch.
+
+{% enddocs %}

models/descriptions/non_staked_locked_supply.md

@@ -0,0 +1,5 @@
+{% docs non_staked_locked_supply %}
+
+NEAR supply that is locked via a lockup but not staked.
+
+{% enddocs %}

models/descriptions/nonliquid_supply.md

@@ -0,0 +1,5 @@
+{% docs nonliquid_supply %}
+
+Total supply, less liquid supply.
+
+{% enddocs %}

models/descriptions/nonstaked_circulating_supply.md

@@ -0,0 +1,5 @@
+{% docs nonstaked_circulating_supply %}
+
+NEAR supply that is neither locked nor staked.
+
+{% enddocs %}

models/descriptions/perc_circulating_supply.md

@@ -0,0 +1,6 @@
+{% docs perc_circulating_supply %}
+
+Percentage of NEAR circulating.
+circulating_supply / total_supply
+
+{% enddocs %}

models/descriptions/perc_locked_supply.md

@@ -0,0 +1,6 @@
+{% docs perc_locked_supply %}
+
+Percentage of supply locked.  
+total_locked_supply / total_supply
+
+{% enddocs %}

models/descriptions/perc_staked_circulating.md

@@ -0,0 +1,6 @@
+{% docs perc_staked_circulating %}
+
+Percentage of supply staked and not locked, of circulating supply.
+nonlocked_and_staked_supply / circulating_supply
+
+{% enddocs %}

models/descriptions/perc_staked_locked.md

@@ -0,0 +1,6 @@
+{% docs perc_staked_locked %}
+
+Percentage of supply both staked and locked, out of all locked supply.  
+locked_and_staked_supply / total_locked_supply
+
+{% enddocs %}

models/descriptions/predecessor_id.md

@@ -0,0 +1,5 @@
+{% docs predecessor_id %}
+
+Preceeeding id, from the receipt action.
+
+{% enddocs %}

models/descriptions/staked_balance.md

@@ -0,0 +1,5 @@
+{% docs staked_balance %}
+
+Gross balance of staked NEAR for the record, whether date or account.
+
+{% enddocs %}

models/descriptions/staked_circulating_supply.md

@@ -0,0 +1,5 @@
+{% docs staked_circulating_supply %}
+
+Non-locked (from a lockup.near disbursement) and staked to a node.
+
+{% enddocs %}

models/descriptions/staked_locked_supply.md

@@ -0,0 +1,5 @@
+{% docs staked_locked_supply %}
+
+NEAR supply that is locked via a lockup and staked to a node.
+
+{% enddocs %}

models/descriptions/start_time.md

@@ -0,0 +1,5 @@
+{% docs start_time %}
+
+Block timestamp associated with min block id.
+
+{% enddocs %}

models/descriptions/terminate_vesting_timestamp.md

@@ -0,0 +1,5 @@
+{% docs terminate_vesting_timestamp %}
+
+Timestamp of when the vesting is to be terminated, if applicable.
+
+{% enddocs %}

models/descriptions/termination_unvested_amount.md

@@ -0,0 +1,5 @@
+{% docs termination_unvested_amount %}
+
+Unvested amount upon termination of lockup, if applicable.
+
+{% enddocs %}

models/descriptions/termination_withdrawn_amount.md

@@ -0,0 +1,5 @@
+{% docs termination_withdrawn_amount %}
+
+Amount, in NEAR, withdrawn at termination of the vesting period, if applicable.
+
+{% enddocs %}

models/descriptions/total_locked_supply.md

@@ -0,0 +1,5 @@
+{% docs total_locked_supply %}
+
+Total NEAR locked by lockup.near disbursements.
+
+{% enddocs %}

models/descriptions/total_near_supply.md

@@ -0,0 +1,5 @@
+{% docs total_near_supply %}
+
+Total supply of NEAR, per the block header, at this epoch.
+
+{% enddocs %}

models/descriptions/total_nonstaked_supply.md

@@ -0,0 +1,5 @@
+{% docs total_nonstaked_supply %}
+
+Total supply less total staked supply of NEAR.
+
+{% enddocs %}

models/descriptions/total_staked_supply.md

@@ -0,0 +1,5 @@
+{% docs total_staked_supply %}
+
+Gross staked supply of NEAR.
+
+{% enddocs %}

models/descriptions/unlocked_amount_today.md

@@ -0,0 +1,5 @@
+{% docs unlocked_amount_today %}
+
+Amount of NEAR unlocked on the date of record.
+
+{% enddocs %}

models/descriptions/unreleased_amount.md

@@ -0,0 +1,5 @@
+{% docs unreleased_amount %}
+
+Amount of NEAR yet to be unlocked, as of the date of record.
+
+{% enddocs %}

models/descriptions/unvested_amount.md

@@ -0,0 +1,5 @@
+{% docs unvested_amount %}
+
+Unvested NEAR at time of record.
+
+{% enddocs %}

models/descriptions/utc_date.md

@@ -0,0 +1,5 @@
+{% docs utc_date %}
+
+Datestamp, assuming UTC-0, of the record.
+
+{% enddocs %}

models/descriptions/vesting_cliff_timestamp.md

@@ -0,0 +1,5 @@
+{% docs vesting_cliff_timestamp %}
+
+Timestamp for a cliff-style unlock of NEAR, if applicable to this lockup.
+
+{% enddocs %}

models/descriptions/vesting_end_timestamp.md

@@ -0,0 +1,5 @@
+{% docs vesting_end_timestamp %}
+
+End of the vesting period, if applicable.
+
+{% enddocs %}

models/descriptions/vesting_start_timestamp.md

@@ -0,0 +1,5 @@
+{% docs vesting_start_timestamp %}
+
+The start of the vesting period.
+
+{% enddocs %}

models/descriptions/vesting_time_left_ns.md

@@ -0,0 +1,5 @@
+{% docs vesting_time_left_ns %}
+
+Time left, in ns, until the lockup is fully vested, if applicable.
+
+{% enddocs %}

models/descriptions/vesting_total_time_ns.md

@@ -0,0 +1,5 @@
+{% docs vesting_total_time_ns %}
+
+The total amount of time, in ns, of the vesting period, if applicable.
+
+{% enddocs %}

models/silver/atlas/supply/README.md

@@ -0,0 +1,672 @@
+# NEAR Daily Supply
+The set of models in this folder calculate the total supply of NEAR, derived from a model originally built by the Foundation. The composite parts of the below query (locked staked, locked unstaked, staked) have been segmented into separate sql models and are combined in `silver__atlas_supply.sql`. The model `silver__atlas_supply_daily_staked_supply.sql` has been replaced with an existing model in the Flipside project `silver__pool_balance_daily`, which follows a similar mechanic of extracting staked balance per pool, per day, from the logs emitted by staking actions on-chain.  
+
+
+### Original SQL
+[Link to Data Studio Query by dweinstein13](https://flipsidecrypto.xyz/dweinstein33/q/u29te7T8c36t/ad---total-supply-atlas)  
+
+```sql
+ WITH
+
+lockup_receipts AS (
+    SELECT fr.tx_hash
+         , fr.block_timestamp
+         , fr.actions:predecessor_id::string AS predecessor_id
+         , fr.receiver_id
+         , fr.actions
+         , OBJECT_KEYS(fr.status_value)[0]::string AS status
+         , fr.logs
+    
+    FROM near.core.fact_receipts AS fr
+    WHERE fr.receiver_id LIKE '%.lockup.near'
+      AND status != 'Failure'
+),
+
+
+daily_lockup_locked_balances AS (
+    WITH
+
+    -- new lockup contract created
+    new_lockup_txs AS (
+        SELECT lr.tx_hash
+             , lr.block_timestamp
+             , lr.receiver_id AS lockup_account_id
+        FROM lockup_receipts AS lr,
+            LATERAL FLATTEN( input => lr.actions:receipt:Action:actions )
+        WHERE value:FunctionCall:method_name::string = 'new'
+    ),
+    
+    
+    -- vesting is stopped by the Foundation
+    terminate_vesting_txs AS (
+        SELECT lr.tx_hash
+             , lr.block_timestamp
+             , lr.receiver_id AS lockup_account_id
+             , split(lr.logs[0], 'unvested balance is ')[1]::bigint / 1e24 AS unvested_balance
+        FROM lockup_receipts AS lr,
+            LATERAL FLATTEN( input => lr.actions:receipt:Action:actions )
+        WHERE value:FunctionCall:method_name::string = 'terminate_vesting'
+    ),
+    
+    
+    terminate_vesting_txs_with_vesting_schedule AS (
+        SELECT tv.*
+             , fc.args:vesting_schedule_with_salt:vesting_schedule AS vesting_schedule
+    
+        FROM terminate_vesting_txs AS tv
+            LEFT JOIN near.core.fact_actions_events_function_call AS fc
+                ON fc.tx_hash = tv.tx_hash
+                AND fc.method_name = 'terminate_vesting'
+    
+        QUALIFY row_number() OVER (partition by tv.tx_hash order by tv.block_timestamp) = 1  -- dedupe
+    ),
+    
+    
+    -- unvested tokens are withdrawn (effectively unlocked into circulating supply)
+    termination_withdraw_txs AS (
+        SELECT lr.tx_hash
+             , lr.block_timestamp
+             , lr.receiver_id AS lockup_account_id
+             , split(split(lr.logs[0], ' of terminated unvested balance')[0], 'Withdrawing ')[1]::bigint / 1e24 AS withdrawn_amount
+        FROM lockup_receipts AS lr,
+            LATERAL FLATTEN( input => lr.actions:receipt:Action:actions )
+        WHERE value:FunctionCall:method_name::string = 'termination_withdraw'
+     -- Simplify logic -> get only first termination withdrawal
+        -- QUALIFY row_number() OVER (partition by lockup_account_id order by block_timestamp) = 1
+    ),
+    
+    
+    daily_termination_withdrawn_amount AS (
+        SELECT lockup_account_id
+             , block_timestamp::date AS utc_date
+             , sum(withdrawn_amount) AS withdrawn_amount
+        FROM termination_withdraw_txs
+        GROUP BY 1,2
+    ),
+    
+    
+    -- lockup amounts
+    deposits AS (
+        SELECT lr.tx_hash
+             , lr.block_timestamp
+             , value:Transfer:deposit::bigint / 1e24 AS deposit_amount
+        FROM lockup_receipts AS lr,
+            LATERAL FLATTEN( input => lr.actions:receipt:Action:actions )
+        WHERE OBJECT_KEYS(value:Transfer)[0]::string = 'deposit'
+    ),
+    
+    
+    lockup_contracts AS (
+        SELECT lcr.tx_hash
+             , lcr.block_timestamp
+             , lcr.lockup_account_id
+             , fc1.args:lockup_duration::bigint AS input_lockup_duration_ns
+             , fc1.args:lockup_timestamp::bigint AS input_lockup_timestamp_epoch
+             , fc1.args:owner_account_id::string AS owner_account_id
+             , fc1.args:release_duration::bigint AS input_release_duration_ns
+             , coalesce(tv.vesting_schedule, fc1.args:vesting_schedule:VestingSchedule) AS vesting_schedule_
+             , vesting_schedule_:cliff_timestamp::bigint AS vesting_cliff_timestamp_epoch
+             , vesting_schedule_:start_timestamp::bigint AS vesting_start_timestamp_epoch
+             , vesting_schedule_:end_timestamp::bigint AS vesting_end_timestamp_epoch
+             , coalesce( fc1.args:transfers_information:TransfersEnabled:transfers_timestamp::bigint, 
+                         1602614338293769340 ) AS transfers_enabled_timestamp_epoch
+             , d.deposit_amount
+    
+             , tv.block_timestamp AS terminate_vesting_timestamp
+             , tv.unvested_balance AS termination_unvested_amount
+    
+             , tw.block_timestamp AS termination_withdraw_timestamp
+             , tw.withdrawn_amount AS termination_withdrawn_amount
+    
+             , (CASE WHEN OBJECT_KEYS(fc1.args:vesting_schedule)[0]::string = 'VestingHash'
+                     THEN True ELSE False END) AS is_private_vesting
+    
+        FROM new_lockup_txs AS lcr
+            LEFT JOIN near.core.fact_actions_events_function_call AS fc1
+                ON fc1.tx_hash = lcr.tx_hash
+                AND fc1.method_name = 'new'
+    
+            LEFT JOIN deposits AS d
+                ON d.tx_hash = lcr.tx_hash
+    
+            LEFT JOIN terminate_vesting_txs_with_vesting_schedule AS tv
+                ON tv.lockup_account_id = lcr.lockup_account_id
+    
+            LEFT JOIN termination_withdraw_txs AS tw
+                ON tw.lockup_account_id = lcr.lockup_account_id
+    
+        WHERE lcr.tx_hash IN (SELECT tx_hash FROM new_lockup_txs)
+          AND d.deposit_amount > 0
+    ),
+    
+    
+    lockup_contracts__parsed AS (
+        SELECT lockup_account_id
+            -- the number of times the same lockup account ID has been used (used as part of lockup unique identifier)
+             , row_number() OVER (partition by lockup_account_id order by block_timestamp) AS lockup_index
+             , owner_account_id
+             , deposit_amount AS lockup_amount
+    
+            -- timestamp when tokens were locked (lock start)
+             , block_timestamp AS deposit_timestamp
+    
+            -- timestamp when transfers were enabled in the blockchain (default reference when lockup_timestamp is null)
+             , to_timestamp(transfers_enabled_timestamp_epoch, 9) AS transfers_enabled_timestamp
+    
+            -- timestamp when tokens start unlocking (explicit parameter)
+             , to_timestamp(input_lockup_timestamp_epoch, 9) AS input_lockup_timestamp
+    
+            -- if lockup_timestamp is null, calculate unlock start from lockup duration
+             , timestampadd(nanoseconds, input_lockup_duration_ns, transfers_enabled_timestamp) AS calculated_lockup_timestamp
+    
+            -- lockup mechanism
+             , input_lockup_duration_ns
+             , input_release_duration_ns
+    
+            -- Max between input and calculated lockup timestamp
+             , (CASE WHEN input_lockup_timestamp IS NOT NULL
+                     THEN greatest(input_lockup_timestamp, calculated_lockup_timestamp)
+                     ELSE calculated_lockup_timestamp END) AS lockup_timestamp
+    
+            -- If release_duration is not provided, tokens are immediately unlocked
+             , (CASE WHEN input_release_duration_ns IS NOT NULL
+                     THEN timestampadd(nanosecond, input_release_duration_ns, lockup_timestamp)  -- linear release if release_duration is provided, else full unlock
+                     ELSE lockup_timestamp END) AS lockup_end_timestamp
+    
+            -- vesting mechanism
+             , is_private_vesting
+             , to_timestamp(vesting_start_timestamp_epoch, 9) AS vesting_start_timestamp
+             , to_timestamp(vesting_end_timestamp_epoch, 9) AS vesting_end_timestamp
+             , to_timestamp(vesting_cliff_timestamp_epoch, 9) AS vesting_cliff_timestamp
+    
+            -- vesting termination
+             , terminate_vesting_timestamp
+             , termination_unvested_amount
+             , termination_withdraw_timestamp
+             , termination_withdrawn_amount
+    
+             , tx_hash AS _tx_hash
+    
+             , (CASE WHEN lockup_timestamp IS NOT NULL AND vesting_start_timestamp IS NULL
+                     THEN least(deposit_timestamp, lockup_timestamp)
+                     WHEN lockup_timestamp IS NULL AND vesting_start_timestamp IS NOT NULL
+                     THEN least(deposit_timestamp, vesting_start_timestamp)
+                     ELSE least(deposit_timestamp, lockup_timestamp, vesting_start_timestamp) END)::date AS _lockup_start_date
+    
+             , (CASE WHEN lockup_end_timestamp IS NOT NULL AND vesting_end_timestamp IS NULL
+                     THEN lockup_end_timestamp
+                     WHEN lockup_end_timestamp IS NULL AND vesting_end_timestamp IS NOT NULL
+                     THEN vesting_end_timestamp
+                     ELSE greatest(lockup_end_timestamp, vesting_end_timestamp) END)::date AS _lockup_end_date
+    
+        FROM lockup_contracts
+    ),
+    
+    
+    lockup_contracts_daily_balance__prep_1 AS (
+        WITH dates AS ( SELECT DISTINCT dateadd(day, -seq4(), CURRENT_DATE) AS utc_date
+                        FROM TABLE(GENERATOR(rowcount => 10000))
+                        WHERE utc_date BETWEEN '2020-01-01' AND CURRENT_DATE )
+    
+        SELECT lc.lockup_account_id
+             , lc.lockup_index
+             , lc.owner_account_id
+    
+             , d.utc_date
+             , d.utc_date + interval '1 day' - interval '1 nanosecond' AS block_timestamp  -- End of day block timestamp
+    
+             , lc.lockup_amount
+             , lc.deposit_timestamp
+    
+            -- Lockup logic
+             , lc.lockup_timestamp
+             , lc.lockup_end_timestamp
+             , greatest(0, timestampdiff(nanosecond, block_timestamp, lockup_end_timestamp)) AS lockup_time_left_ns
+             , (CASE WHEN block_timestamp >= lockup_timestamp
+                     THEN (CASE WHEN input_release_duration_ns > 0
+                                THEN (CASE WHEN block_timestamp >= lockup_end_timestamp
+                                           THEN 0  -- everything is released
+                                           ELSE lockup_amount * lockup_time_left_ns / input_release_duration_ns
+                                           END)
+                                ELSE 0 END)
+                     ELSE lockup_amount  -- The entire balance is still locked before the lockup timestamp
+                     END) AS unreleased_amount
+    
+            -- Vesting logic
+             , lc.vesting_start_timestamp
+             , lc.vesting_cliff_timestamp
+             , lc.vesting_end_timestamp
+             , lc.terminate_vesting_timestamp
+             , lc.termination_unvested_amount
+             , greatest(0, timestampdiff(nanosecond, block_timestamp, vesting_end_timestamp)) AS vesting_time_left_ns
+             , timestampdiff(nanosecond, vesting_start_timestamp, vesting_end_timestamp) AS vesting_total_time_ns
+    
+        FROM lockup_contracts__parsed AS lc, dates AS d
+        WHERE d.utc_date BETWEEN lc._lockup_start_date
+                             AND lc._lockup_end_date
+    ),
+    
+    
+    lockup_contracts_daily_balance__prep_2 AS (
+        SELECT lc.*
+             , sum(coalesce(dtw.withdrawn_amount, 0))
+                    OVER (partition by lc.lockup_account_id, lc.lockup_index
+                              order by lc.utc_date
+                              rows between unbounded preceding
+                                       and current row) AS termination_withdrawn_amount
+        
+        FROM lockup_contracts_daily_balance__prep_1 AS lc
+            LEFT JOIN daily_termination_withdrawn_amount AS dtw
+                ON dtw.lockup_account_id = lc.lockup_account_id
+                AND dtw.utc_date = lc.utc_date
+    
+    ),
+    
+    
+    lockup_contracts_daily_balance AS (
+        SELECT lc.*
+    
+            -- Vesting logic
+    
+            -- Not 100% accurate due to private vesting lockups (unknown/hidden vesting parameters)
+             , (CASE WHEN block_timestamp >= terminate_vesting_timestamp
+                     THEN termination_unvested_amount - termination_withdrawn_amount
+                     ELSE (CASE WHEN block_timestamp < vesting_cliff_timestamp
+                                THEN lockup_amount  -- Before the cliff, nothing is vested
+                                WHEN block_timestamp >= vesting_end_timestamp
+                                THEN 0  -- After the end, everything is vested
+                                ELSE lockup_amount * vesting_time_left_ns / vesting_total_time_ns
+                                END)
+                     END) AS unvested_amount
+    
+            -- Combined logic
+             , greatest(unreleased_amount - termination_withdrawn_amount, coalesce(unvested_amount, 0)) AS locked_amount
+    
+             , locked_amount - coalesce(lag(locked_amount) OVER (partition by lc.lockup_account_id, lc.lockup_index order by lc.utc_date), 0) AS unlocked_amount_today
+    
+        FROM lockup_contracts_daily_balance__prep_2 AS lc
+    )
+
+    SELECT * FROM lockup_contracts_daily_balance
+),
+
+
+daily_lockup_staking_balances AS (
+    WITH
+
+    lockup_staking_logs AS (
+        SELECT lr.tx_hash
+             , lr.block_timestamp
+             , value:FunctionCall:method_name::string AS method_name
+             , lr.receiver_id AS lockup_account_id
+             , (CASE method_name
+                    WHEN 'stake'
+                    THEN split(split(lr.logs[0], ' at the staking pool')[0], 'Staking ')[1]::bigint / 1e24
+                    
+                    WHEN 'deposit_and_stake'
+                    THEN split(split(lr.logs[0], ' to the staking pool')[0], 'Depositing and staking ')[1]::bigint / 1e24
+    
+                    WHEN 'unstake'
+                    THEN split(split(lr.logs[0], ' from the staking pool')[0], 'Unstaking ')[1]::bigint / 1e24
+    
+                    END) AS amount
+    
+             , lr.logs
+    
+        FROM lockup_receipts AS lr,
+            LATERAL FLATTEN( input => lr.actions:receipt:Action:actions )
+        WHERE method_name IN ('stake','deposit_and_stake',
+                              'unstake','unstake_all')
+    ),
+    
+    
+    daily_staking_stats AS (
+        SELECT lockup_account_id
+             , block_timestamp::date AS utc_date
+             , sum(CASE WHEN method_name IN ('stake','deposit_and_stake') THEN amount ELSE 0 END) AS staked_amount_
+             , sum(CASE WHEN method_name IN ('unstake') THEN amount ELSE 0 END) AS unstaked_amount_
+             , (CASE WHEN count(CASE WHEN method_name = 'unstake_all' THEN tx_hash ELSE NULL END) > 0
+                     THEN True ELSE False END) AS unstaked_all
+        FROM lockup_staking_logs
+        GROUP BY 1,2
+    ),
+    
+    
+    lockup_stakers AS (
+        SELECT lockup_account_id
+             , min(block_timestamp)::date AS start_date
+        FROM lockup_staking_logs
+        GROUP BY 1
+    ),
+    
+    
+    lockup_stakers_daily_balances__prep_1 AS (
+        WITH dates AS ( SELECT DISTINCT dateadd(day, -seq4(), CURRENT_DATE) AS utc_date
+                        FROM TABLE(GENERATOR(rowcount => 10000))
+                        WHERE utc_date BETWEEN '2020-09-01' AND CURRENT_DATE )
+    
+        SELECT ls.lockup_account_id
+             , d.utc_date
+    
+        FROM lockup_stakers AS ls, dates AS d
+        WHERE d.utc_date >= ls.start_date
+    ),
+    
+    
+    lockup_stakers_daily_balances__prep_2 AS (
+        SELECT d.lockup_account_id
+             , d.utc_date
+             , coalesce(dss.staked_amount_, 0) AS staked_amount
+             , coalesce(dss.unstaked_amount_, 0) AS unstaked_amount
+             , dss.unstaked_all
+             , sum(CASE WHEN dss.unstaked_all = True THEN 1 ELSE 0 END)
+                  OVER (partition by d.lockup_account_id
+                        order by d.utc_date
+                        rows between unbounded preceding
+                                 and current row) AS _unstake_counter
+    
+        FROM lockup_stakers_daily_balances__prep_1 AS d
+            LEFT JOIN daily_staking_stats AS dss
+                ON dss.lockup_account_id = d.lockup_account_id
+                AND dss.utc_date = d.utc_date
+    ),
+    
+    
+    lockup_stakers_daily_balances__prep_3 AS (
+        SELECT *
+             , coalesce(lag(_unstake_counter) 
+                  OVER (partition by lockup_account_id
+                            order by utc_date)
+               , 0) AS staking_period_index
+        FROM lockup_stakers_daily_balances__prep_2
+    ),
+    
+    
+    lockup_stakers_daily_balances__prep_4 AS (
+        SELECT *
+             , sum(staked_amount - unstaked_amount) 
+                  OVER (partition by lockup_account_id, staking_period_index
+                            order by utc_date
+                            rows between unbounded preceding
+                                     and current row) AS _cumulative_staked_amount
+    
+             , (CASE WHEN unstaked_all = True THEN 0 ELSE _cumulative_staked_amount END) AS staked_balance
+        FROM lockup_stakers_daily_balances__prep_3
+    ),
+    
+    
+    lockup_stakers_daily_balances AS (
+        SELECT lockup_account_id
+             , utc_date
+             , staked_balance
+        FROM lockup_stakers_daily_balances__prep_4
+    )
+    
+    
+    SELECT * FROM lockup_stakers_daily_balances
+),
+
+
+daily_lockup_locked_and_staking_balances AS (
+    SELECT l.lockup_account_id
+         , l.utc_date
+         , l.locked_amount
+         , coalesce(s.staked_balance, 0) AS staked_amount
+         , least(staked_amount, locked_amount) AS locked_and_staked_amount
+
+    FROM daily_lockup_locked_balances AS l
+        LEFT JOIN daily_lockup_staking_balances AS s
+            ON s.lockup_account_id = l.lockup_account_id
+            AND s.utc_date = l.utc_date
+),
+
+
+daily_locked_and_staked_supply AS (
+    SELECT utc_date
+         , sum(locked_amount) AS total_locked_supply
+         , sum(locked_and_staked_amount) AS locked_and_staked_supply
+
+    FROM daily_lockup_locked_and_staking_balances
+    GROUP BY 1
+),
+
+
+daily_staked_supply AS (
+    WITH
+    
+    dim_epochs AS (
+     	SELECT epoch_id
+      		 , min(block_id) AS min_block_id
+      		 , max(block_id) AS max_block_id
+      		 , count(*) AS blocks
+      		 , count(distinct block_author) AS block_producers
+      		 , min(block_timestamp) AS start_time
+      		 , max(block_timestamp) AS end_time
+      		 , max(total_supply) / 1e24 AS total_near_supply
+      		 , row_number() OVER (order by min_block_id asc) - 1 + 900 AS epoch_num
+      
+      	FROM near.core.fact_blocks AS b
+      	GROUP BY 1
+    ),
+    
+    
+    staking_actions AS (
+      	SELECT r.tx_hash
+          	 , r.block_timestamp
+          	 , r.receiver_id AS validator_address
+          	 , replace(split(l.value::string, ': Contract received total')[0], 'Epoch ', '')::integer AS epoch_num
+          	 , split(split(l.value::string, 'New total staked balance is ')[1], '. Total number of shares')[0]::bigint / 1e24 AS staked_balance
+          
+        FROM near.core.fact_receipts AS r
+      	   , lateral flatten( input => r.logs ) AS l
+      
+        WHERE ( right(receiver_id, 12) = '.poolv1.near' OR right(receiver_id, 10) = '.pool.near' )
+          AND r.tx_hash IN ( SELECT tx_hash 
+          				     FROM near.core.fact_actions_events_function_call
+          				     WHERE method_name IN ('ping','stake','unstake','stake_all','unstake_all','deposit_and_stake') )
+          AND left(l.value::string, 6) = 'Epoch '
+    
+      	QUALIFY row_number() OVER (partition by epoch_num, validator_address order by block_timestamp desc) = 1
+    ),
+    
+    
+    proposals AS (
+      	SELECT b.block_id
+          	 , b.block_timestamp
+          	 , b.epoch_id
+          	 , vp.value['account_id'] AS validator_address
+          	 , vp.value['stake']::bigint / 1e24 AS staked_balance
+        FROM near.core.fact_blocks AS b
+           , lateral flatten( input => b.chunks ) AS c
+           , lateral flatten( input => c.value['validator_proposals']) AS vp
+      	-- WHERE b.block_timestamp >= '2021-09-01'
+        QUALIFY row_number() OVER (partition by validator_address, epoch_id order by block_timestamp desc) = 1
+    ),
+    
+    
+    proposals_per_epoch AS (
+      	SELECT p.block_timestamp
+      		 , p.epoch_id
+      		 , p.validator_address
+      		 , p.staked_balance
+      		 , e.epoch_num
+      
+      	FROM proposals AS p
+      		INNER JOIN dim_epochs AS e
+      			ON e.epoch_id = p.epoch_id
+    
+      	QUALIFY row_number() OVER (partition by epoch_num, validator_address order by block_timestamp desc) = 1
+    ),
+    
+    
+    block_producers_per_epoch AS (
+      	SELECT b.epoch_id
+      		 , e.epoch_num
+      		 , b.block_author AS validator_address
+      		 , sa.staked_balance
+      		 , count(distinct b.block_id) OVER (partition by b.epoch_id, b.block_author) AS blocks_produced
+      
+      	FROM near.core.fact_blocks AS b
+      		INNER JOIN dim_epochs AS e
+      			ON e.epoch_id = b.epoch_id
+    
+      		LEFT JOIN staking_actions AS sa
+      			ON sa.epoch_num = e.epoch_num
+      			AND sa.validator_address = b.block_author
+    
+      	QUALIFY row_number() OVER (partition by b.epoch_id, b.block_author order by b.block_timestamp desc) = 1
+    ),
+    
+    
+    dim_validators AS (
+      	SELECT validator_address
+      		 , min(start_epoch) AS start_epoch
+      		 , min(start_time) AS start_time
+      
+      	FROM (
+    		SELECT validator_address
+        		 , min(epoch_num) AS start_epoch
+        		 , min(block_timestamp) AS start_time
+        	FROM staking_actions AS sa
+        	GROUP BY 1
+      
+        	UNION ALL
+      
+        	SELECT block_author AS validator_address
+        		 , min(e.epoch_num) AS start_epoch
+        		 , min(b.block_timestamp) AS start_time
+        	FROM near.core.fact_blocks AS b
+        		LEFT JOIN dim_epochs AS e
+        			ON b.block_id BETWEEN e.min_block_id AND e.max_block_id
+        	GROUP BY 1
+        ) AS x
+      
+      	GROUP BY 1
+    ),
+    
+    
+    dim_table AS (
+      	SELECT v.validator_address
+      		 , e.epoch_num
+      		 , e.start_time
+      		 , e.total_near_supply
+      
+      	FROM dim_validators AS v, dim_epochs AS e
+      	WHERE v.start_epoch <= e.epoch_num
+    ),
+    
+    
+    validator_status_per_epoch AS (
+      	SELECT dt.epoch_num
+      		 , dt.start_time
+      		 , dt.validator_address
+      		 , coalesce(
+      				last_value(coalesce(bp.staked_balance, p.staked_balance)) IGNORE NULLS
+      					OVER (partition by dt.validator_address 
+      					  	  order by dt.epoch_num
+      					  	  rows between unbounded preceding
+      								   and current row),
+      				0) AS staked_balance
+      		 , bp.blocks_produced
+      		 , (CASE WHEN p.validator_address IS NOT NULL THEN True ELSE False END) AS is_proposer
+      
+      	FROM dim_table AS dt
+      		LEFT JOIN block_producers_per_epoch AS bp
+      			ON bp.epoch_num = dt.epoch_num
+      			AND bp.validator_address= dt.validator_address
+    
+      		LEFT JOIN proposals_per_epoch AS p
+      			ON p.epoch_num = dt.epoch_num
+      			AND p.validator_address= dt.validator_address
+    
+    ),
+    
+    
+    epoch_stats AS (
+      	SELECT epoch_num
+          	 , start_time
+      		 , sum(staked_balance) AS total_near_staked
+          
+        FROM validator_status_per_epoch
+        WHERE staked_balance > 0
+        GROUP BY 1,2
+    ),
+    
+    
+    epoch_stats_2 AS (
+      	SELECT es.*
+      		 , de.total_near_supply
+      		 , de.total_near_supply - es.total_near_staked AS other_near_supply
+      	 	 , 100.00 * total_near_staked / total_near_supply AS perc_staked_supply
+      	FROM epoch_stats AS es
+      		LEFT JOIN dim_epochs AS de
+      			ON de.epoch_num = es.epoch_num
+    )
+    
+    
+    SELECT start_time::date AS utc_date
+         , total_near_staked AS total_staked_supply
+         , total_near_supply AS total_supply
+    FROM epoch_stats_2
+    QUALIFY row_number() OVER (partition by utc_date order by start_time desc) = 1
+),
+
+
+daily_supply_stats AS (
+    SELECT s.utc_date
+         , s.total_supply
+         , s.total_staked_supply
+         , s.total_supply - s.total_staked_supply AS total_nonstaked_supply
+         , ls.total_locked_supply
+         , ls.locked_and_staked_supply
+         , greatest(0, total_staked_supply - locked_and_staked_supply) AS nonlocked_and_staked_supply
+         , greatest(0, total_locked_supply - locked_and_staked_supply) AS locked_and_nonstaked_supply
+         , total_supply
+            - locked_and_staked_supply
+            - locked_and_nonstaked_supply
+            - nonlocked_and_staked_supply AS nonlocked_and_nonstaked_supply
+
+         , total_supply - total_locked_supply AS circulating_supply
+         , total_locked_supply AS locked_supply
+
+    FROM daily_staked_supply AS s
+        LEFT JOIN daily_locked_and_staked_supply AS ls
+            ON ls.utc_date = s.utc_date
+),
+
+
+output AS (
+    SELECT utc_date
+         , utc_date AS "Date"
+         , total_supply AS "Total Supply - Actual"
+         , total_staked_supply AS "Staked Supply"
+         , total_nonstaked_supply AS "Non-staked Supply"
+         , circulating_supply AS "Circulating Supply"
+         , total_supply - circulating_supply as "Total Supply"
+         , total_locked_supply AS "Locked Supply"
+         , nonlocked_and_nonstaked_supply AS "Liquid Supply"
+         , total_supply - nonlocked_and_nonstaked_supply  AS "Non-liquid Supply"
+
+         , locked_and_staked_supply AS "Staked (Locked Supply)"
+         , locked_and_nonstaked_supply AS "Non-staked (Locked Supply)"
+
+         , nonlocked_and_staked_supply AS "Staked (Circulating Supply)"
+         , nonlocked_and_nonstaked_supply AS "Non-staked (Circulating Supply)"
+
+         , total_locked_supply / total_supply AS perc_locked_supply
+         , circulating_supply / total_supply AS perc_circulating_supply
+
+         , locked_and_staked_supply / total_locked_supply AS perc_staked__locked
+         , nonlocked_and_staked_supply / circulating_supply AS perc_staked__circulating
+
+         , 1 AS dummy
+
+    FROM daily_supply_stats
+)
+
+
+SELECT *
+FROM output
+WHERE utc_date >= '2023-01-01'
+ORDER BY utc_date DESC 
+```

models/silver/atlas/supply/silver__atlas_block_proposers.sql

@@ -1,115 +0,0 @@
-{{ config(
-    materialized = "incremental",
-    cluster_by = ["epoch_num"],
-    unique_key = "atlas_block_proposers_id",
-    merge_exclude_columns = ["inserted_timestamp"],
-    incremental_strategy = "merge",
-    tags = ['atlas', 'atlas_supply'],
-    enabled = False
-) }}
-{# Potential future table for staking / governance. DISABLED MODEL, keeping as archive for down the line. #}
-WITH epochs AS (
-
-    SELECT
-        *
-    FROM
-        {{ ref('silver__atlas_supply_epochs') }}
-),
-blocks AS (
-    SELECT
-        *
-    FROM
-        {{ ref('silver__streamline_blocks') }}
-    WHERE
-        {% if var("MANUAL_FIX") %}
-            {{ partition_load_manual('no_buffer') }}
-        {% else %}
-            {% if is_incremental() %}
-                block_id >= (
-                    SELECT
-                        MAX(min_block_id)
-                    FROM
-                        epochs
-                )
-            {% endif %}
-        {% endif %}
-),
-proposals AS (
-    SELECT
-        b.block_id,
-        b.block_timestamp,
-        b.epoch_id,
-        vp.value ['account_id'] :: STRING AS validator_address,
-        vp.value ['stake'] :: bigint / 1e24 AS staked_balance
-    FROM
-        blocks AS b,
-        LATERAL FLATTEN(
-            input => b.chunks
-        ) AS C,
-        LATERAL FLATTEN(
-            input => C.value ['validator_proposals']
-        ) AS vp -- WHERE b.block_timestamp >= '2021-09-01'
-        qualify ROW_NUMBER() over (
-            PARTITION BY validator_address,
-            epoch_id
-            ORDER BY
-                block_timestamp DESC
-        ) = 1
-),
-proposals_per_epoch AS (
-    SELECT
-        p.block_timestamp,
-        p.epoch_id,
-        p.validator_address,
-        p.staked_balance,
-        e.epoch_num
-    FROM
-        proposals AS p
-        INNER JOIN epochs AS e
-        ON e.epoch_id = p.epoch_id qualify ROW_NUMBER() over (
-            PARTITION BY epoch_num,
-            validator_address
-            ORDER BY
-                block_timestamp DESC
-        ) = 1
-),
-block_producers_per_epoch AS (
-    SELECT
-        b.epoch_id,
-        e.epoch_num,
-        b.block_author AS validator_address,
-        COUNT(
-            DISTINCT b.block_id
-        ) over (
-            PARTITION BY b.epoch_id,
-            b.block_author
-        ) AS blocks_produced,
-        COALESCE(
-            b._inserted_timestamp,
-            b._load_timestamp
-        ) AS _inserted_timestamp,
-        b._partition_by_block_number
-    FROM
-        blocks AS b
-        INNER JOIN epochs AS e
-        ON e.epoch_id = b.epoch_id
-        qualify ROW_NUMBER() over (
-            PARTITION BY b.epoch_id,
-            b.block_author
-            ORDER BY
-                b.block_timestamp DESC
-        ) = 1
-)
-SELECT
-    epoch_id,
-    epoch_num,
-    validator_address,
-    blocks_produced,
-    _inserted_timestamp,
-    _partition_by_block_number,
-    {{ dbt_utils.generate_surrogate_key(['epoch_id', 'validator_address']) }} AS atlas_block_proposers_id,
-    SYSDATE() AS inserted_timestamp,
-    SYSDATE() AS modified_timestamp,
-    '{{ invocation_id }}' AS invocation_id
-FROM
-    block_producers_per_epoch

models/silver/atlas/supply/silver__atlas_supply.sql

@@ -50,9 +50,11 @@ daily_locked_and_staked_supply AS (
 daily_staked_supply AS (
     SELECT
         date_day AS utc_date,
-        balance AS total_staked_supply
+        SUM(balance) AS total_staked_supply
     FROM
         {{ ref('silver__pool_balance_daily') }}
+    GROUP BY
+        1
 ),
 daily_total_supply AS (
     SELECT
@@ -95,29 +97,41 @@ daily_supply_stats AS (
 output AS (
     SELECT
         utc_date,
-        utc_date AS "Date",
-        total_supply AS "Total Supply - Actual",
-        total_staked_supply AS "Staked Supply",
-        total_nonstaked_supply AS "Non-staked Supply",
-        circulating_supply AS "Circulating Supply",
-        total_supply - circulating_supply AS "Total Supply",
-        total_locked_supply AS "Locked Supply",
-        nonlocked_and_nonstaked_supply AS "Liquid Supply",
-        total_supply - nonlocked_and_nonstaked_supply AS "Non-liquid Supply",
-        locked_and_staked_supply AS "Staked (Locked Supply)",
-        locked_and_nonstaked_supply AS "Non-staked (Locked Supply)",
-        nonlocked_and_staked_supply AS "Staked (Circulating Supply)",
-        nonlocked_and_nonstaked_supply AS "Non-staked (Circulating Supply)",
+        total_supply,
+        total_staked_supply,
+        total_nonstaked_supply,
+        circulating_supply,
+        total_locked_supply,
+        nonlocked_and_nonstaked_supply AS liquid_supply,
+        total_supply - nonlocked_and_nonstaked_supply AS nonliquid_supply,
+        locked_and_staked_supply AS staked_locked_supply,
+        locked_and_nonstaked_supply AS non_staked_locked_supply,
+        nonlocked_and_staked_supply AS staked_circulating_supply,
+        nonlocked_and_nonstaked_supply AS nonstaked_circulating_supply,
         total_locked_supply / total_supply AS perc_locked_supply,
         circulating_supply / total_supply AS perc_circulating_supply,
-        locked_and_staked_supply / total_locked_supply AS perc_staked__locked,
-        nonlocked_and_staked_supply / circulating_supply AS perc_staked__circulating,
-        1 AS dummy
+        locked_and_staked_supply / total_locked_supply AS perc_staked_locked,
+        nonlocked_and_staked_supply / circulating_supply AS perc_staked_circulating
     FROM
         daily_supply_stats
 )
 SELECT
-    *,
+    utc_date,
+    total_supply,
+    total_staked_supply,
+    total_nonstaked_supply,
+    circulating_supply,
+    total_locked_supply,
+    liquid_supply,
+    nonliquid_supply,
+    staked_locked_supply,
+    non_staked_locked_supply,
+    staked_circulating_supply,
+    nonstaked_circulating_supply,
+    perc_locked_supply,
+    perc_circulating_supply,
+    perc_staked_locked,
+    perc_staked_circulating,
     {{ dbt_utils.generate_surrogate_key(['utc_date']) }} AS atlas_supply_id,
     SYSDATE() AS inserted_timestamp,
     SYSDATE() AS modified_timestamp,

models/silver/atlas/supply/silver__atlas_supply.yml

@@ -0,0 +1,84 @@
+version: 2
+
+models:
+  - name: silver__atlas_supply
+    description: |-
+      A table represeting calculations for the supply of NEAR across various categories, such as staked and locked.
+    columns:
+      - name: utc_date
+        description: "{{ doc('utc_date') }}"
+        tests:
+          - not_null
+      - name: total_supply
+        description: "{{ doc('total_supply') }}"
+        tests:
+          - not_null
+      - name: total_staked_supply
+        description: "{{ doc('total_staked_supply') }}"
+        tests:
+          - not_null
+      - name: total_nonstaked_supply
+        description: "{{ doc('total_nonstaked_supply') }}"
+        tests:
+          - not_null
+      - name: circulating_supply
+        description: "{{ doc('circulating_supply') }}"
+        tests:
+          - not_null
+      - name: total_locked_supply
+        description: "{{ doc('total_locked_supply') }}"
+        tests:
+          - not_null
+      - name: liquid_supply
+        description: "{{ doc('liquid_supply') }}"
+        tests:
+          - not_null
+      - name: nonliquid_supply
+        description: "{{ doc('nonliquid_supply') }}"
+        tests:
+          - not_null
+      - name: staked_locked_supply
+        description: "{{ doc('staked_locked_supply') }}"
+        tests:
+          - not_null
+      - name: non_staked_locked_supply
+        description: "{{ doc('non_staked_locked_supply') }}"
+        tests:
+          - not_null
+      - name: staked_circulating_supply
+        description: "{{ doc('staked_circulating_supply') }}"
+        tests:
+          - not_null
+      - name: nonstaked_circulating_supply
+        description: "{{ doc('nonstaked_circulating_supply') }}"
+        tests:
+          - not_null
+      - name: perc_locked_supply
+        description: "{{ doc('perc_locked_supply') }}"
+        tests:
+          - not_null
+      - name: perc_circulating_supply
+        description: "{{ doc('perc_circulating_supply') }}"
+        tests:
+          - not_null
+      - name: perc_staked_locked
+        description: "{{ doc('perc_staked_locked') }}"
+        tests:
+          - not_null
+      - name: perc_staked_circulating
+        description: "{{ doc('perc_staked_circulating') }}"
+        tests:
+          - not_null
+      - name: atlas_supply_id
+        description: "{{ doc('id') }}"
+        tests:
+          - not_null
+          - unique
+      - name: inserted_timestamp
+        description: "{{ doc('inserted_timestamp') }}"
+
+      - name: modified_timestamp
+        description: "{{ doc('modified_timestamp') }}"
+
+      - name: invocation_id
+        description: "{{ doc('invocation_id') }}"

models/silver/atlas/supply/silver__atlas_supply_daily_lockup_locked_balances.sql

@@ -435,7 +435,7 @@ SELECT
     unlocked_amount_today,
     _inserted_timestamp,
     _partition_by_block_number,
-    {{ dbt_utils.generate_surrogate_key(['lockup_account_id', 'utc_date']) }} AS atlas_daily_lockup_locked_balances_id,
+    {{ dbt_utils.generate_surrogate_key(['utc_date', 'lockup_account_id', 'lockup_index', 'owner_account_id']) }} AS atlas_daily_lockup_locked_balances_id,
     SYSDATE() AS inserted_timestamp,
     SYSDATE() AS modified_timestamp,
     '{{ invocation_id }}' AS invocation_id

models/silver/atlas/supply/silver__atlas_supply_daily_lockup_locked_balances.yml

@@ -0,0 +1,103 @@
+version: 2
+
+models:
+  - name: silver__atlas_supply_daily_lockup_locked_balances
+    description: |-
+      Calculates daily balance of locked balance on a per lockup account-basis.
+
+    columns:
+      - name: lockup_account_id
+        description: "{{ doc('lockup_account_id') }}"
+        tests:
+          - not_null
+      - name: lockup_index
+        description: "{{ doc('lockup_index') }}"
+        tests:
+          - not_null
+      - name: owner_account_id
+        description: "{{ doc('owner_account_id') }}"
+        tests:
+          - not_null
+      - name: utc_date
+        description: "{{ doc('utc_date') }}"
+        tests:
+          - not_null
+      - name: block_timestamp
+        description: "{{ doc('block_timestamp') }}"
+        tests:
+          - not_null
+      - name: lockup_amount
+        description: "{{ doc('lockup_amount') }}"
+        tests:
+          - not_null
+      - name: deposit_timestamp
+        description: "{{ doc('deposit_timestamp') }}"
+        tests:
+          - not_null
+      - name: lockup_timestamp
+        description: "{{ doc('lockup_timestamp') }}"
+
+      - name: lockup_end_timestamp
+        description: "{{ doc('lockup_end_timestamp') }}"
+
+      - name: lockup_time_left_ns
+        description: "{{ doc('lockup_time_left_ns') }}"
+
+      - name: unreleased_amount
+        description: "{{ doc('unreleased_amount') }}"
+
+      - name: vesting_start_timestamp
+        description: "{{ doc('vesting_start_timestamp') }}"
+
+      - name: vesting_cliff_timestamp
+        description: "{{ doc('vesting_cliff_timestamp') }}"
+
+      - name: vesting_end_timestamp
+        description: "{{ doc('vesting_end_timestamp') }}"
+
+      - name: terminate_vesting_timestamp
+        description: "{{ doc('terminate_vesting_timestamp') }}"
+
+      - name: termination_unvested_amount
+        description: "{{ doc('termination_unvested_amount') }}"
+
+      - name: vesting_time_left_ns
+        description: "{{ doc('vesting_time_left_ns') }}"
+
+      - name: vesting_total_time_ns
+        description: "{{ doc('vesting_total_time_ns') }}"
+
+      - name: termination_withdrawn_amount
+        description: "{{ doc('termination_withdrawn_amount') }}"
+
+      - name: unvested_amount
+        description: "{{ doc('unvested_amount') }}"
+
+      - name: locked_amount
+        description: "{{ doc('locked_amount') }}"
+        tests:
+          - not_null
+      - name: unlocked_amount_today
+        description: "{{ doc('unlocked_amount_today') }}"
+        tests:
+          - not_null
+      - name: _inserted_timestamp
+        description: "{{ doc('_inserted_timestamp') }}"
+
+      - name: _partition_by_block_number
+        description: "{{ doc('_partition_by_block_number') }}"
+
+      - name: atlas_daily_lockup_locked_balances_id
+        description: "{{ doc('id') }}"
+        tests:
+          - not_null
+          - unique
+
+      - name: inserted_timestamp
+        description: "{{ doc('inserted_timestamp') }}"
+
+      - name: modified_timestamp
+        description: "{{ doc('modified_timestamp') }}"
+
+      - name: invocation_id
+        description: "{{ doc('invocation_id') }}"

models/silver/atlas/supply/silver__atlas_supply_daily_lockup_staking_balances.yml

@@ -0,0 +1,37 @@
+version: 2
+
+models:
+  - name: silver__atlas_supply_daily_lockup_staking_balances
+    description: |-
+      Calculates daily balance of staked balance on a per lockup account-basis.
+
+    columns:
+      - name: lockup_account_id
+        description: "{{ doc('lockup_account_id') }}"
+        tests:
+          - not_null
+      - name: utc_date
+        description: "{{ doc('utc_date') }}"
+        tests:
+          - not_null
+      - name: staked_balance
+        description: "{{ doc('staked_balance') }}"
+        tests:
+          - not_null
+      - name: _inserted_timestamp
+        description: "{{ doc('_inserted_timestamp') }}"
+
+      - name: atlas_daily_lockup_staking_balances_id
+        description: "{{ doc('id') }}"
+        tests:
+          - not_null
+          - unique
+
+      - name: inserted_timestamp
+        description: "{{ doc('inserted_timestamp') }}"
+
+      - name: modified_timestamp
+        description: "{{ doc('modified_timestamp') }}"
+
+      - name: invocation_id
+        description: "{{ doc('invocation_id') }}"

models/silver/atlas/supply/silver__atlas_supply_daily_staked_supply.yml

@@ -0,0 +1,7 @@
+version: 2
+
+models:
+  - name: silver__atlas_supply_daily_staked_supply
+    description: |-
+      A currently disabled model. The CTE in the original SQL has been converted to dbt-jinja, before being deprecated in favor of another model that captures daily staked balance in a more efficient manner.
+      This is being retained for archive purposes.

models/silver/atlas/supply/silver__atlas_supply_epochs.yml

@@ -0,0 +1,55 @@
+version: 2
+
+models:
+  - name: silver__atlas_supply_epochs
+    description: |-
+      Daily snapshot of each epoch on Near.
+
+    columns:
+      - name: epoch_id
+        description: "{{ doc('epoch_id') }}"
+        tests:
+          - not_null
+      - name: min_block_id
+        description: "{{ doc('min_block_id') }}"
+        tests:
+          - not_null
+      - name: max_block_id
+        description: "{{ doc('max_block_id') }}"
+        tests:
+          - not_null
+      - name: blocks
+        description: "{{ doc('blocks') }}"
+        tests:
+          - not_null
+      - name: block_producers
+        description: "{{ doc('block_producers') }}"
+        tests:
+          - not_null
+      - name: start_time
+        description: "{{ doc('start_time') }}"
+        tests:
+          - not_null
+      - name: end_time
+        description: "{{ doc('end_time') }}"
+        tests:
+          - not_null
+      - name: total_near_supply
+        description: "{{ doc('total_near_supply') }}"
+        tests:
+          - not_null
+      - name: epoch_num
+        description: "{{ doc('epoch_num') }}"
+        tests:
+          - not_null
+      - name: atlas_epochs_id
+        description: "{{ doc('id') }}"
+        tests:
+          - not_null
+          - unique
+      - name: inserted_timestamp  
+        description: "{{ doc('inserted_timestamp') }}"
+      - name: modified_timestamp
+        description: "{{ doc('modified_timestamp') }}"
+      - name: invocation_id
+        description: "{{ doc('invocation_id') }}"

models/silver/atlas/supply/silver__atlas_supply_lockup_receipts.yml

@@ -0,0 +1,53 @@
+version: 2
+
+models:
+  - name: silver__atlas_supply_lockup_receipts
+    description: |-
+      Receipts for lockup transactions.
+
+    columns:
+      - name: receipt_object_id
+        description: "{{ doc('receipt_object_id') }}"
+        tests:
+          - not_null
+      - name: tx_hash
+        description: "{{ doc('tx_hash') }}"
+        tests:
+          - not_null
+      - name: block_timestamp
+        description: "{{ doc('block_timestamp') }}"
+        tests:
+          - not_null
+      - name: predecessor_id
+        description: "{{ doc('predecessor_id') }}"
+        tests:
+          - not_null
+      - name: receiver_id
+        description: "{{ doc('receiver_id') }}"
+        tests:
+          - not_null
+      - name: actions
+        description: "{{ doc('actions') }}"
+        tests:
+          - not_null
+      - name: status
+        description: "{{ doc('status_value') }}"
+        tests:
+          - not_null
+      - name: logs
+        description: "{{ doc('logs') }}"
+      - name: _inserted_timestamp
+        description: "{{ doc('_inserted_timestamp') }}"
+      - name: _partition_by_block_number
+        description: "{{ doc('_partition_by_block_number') }}"
+      - name: atlas_supply_lockup_receipts_id
+        description: "{{ doc('id') }}"
+        tests:
+          - not_null
+          - unique
+      - name: inserted_timestamp
+        description: "{{ doc('inserted_timestamp') }}"
+      - name: modified_timestamp
+        description: "{{ doc('modified_timestamp') }}"
+      - name: invocation_id
+        description: "{{ doc('invocation_id') }}"