flip/sei-models
1
0
Fork 0
mirror of https://github.com/FlipsideCrypto/sei-models.git synced 2026-02-06 10:58:58 +00:00
Code Issues Actions 7 Packages Projects Releases Wiki Activity

evm scores (#136)

Browse Source 
* evm scores

* limit

* vars
This commit is contained in:
Austin 2025-09-04 16:32:12 -04:00 committed by GitHub
parent c63f6a8cff
commit 42d32503ef
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
21 changed files with 1383 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
.github/workflows/dbt_run_scheduled_scores.yml vendored Normal file
View File

@ -0,0 +1,56 @@
name: dbt_run_scheduled_scores
run-name: dbt_run_scheduled_scores
on:
workflow_dispatch:
branches:
- "main"
schedule:
# Runs "at 8:07am UTC" (see https://crontab.guru)
- cron: '7 8 * * *'
env:
DBT_PROFILES_DIR: ./
ACCOUNT: "${{ vars.ACCOUNT }}"
ROLE: "${{ vars.ROLE }}"
USER: "${{ vars.USER }}"
PASSWORD: "${{ secrets.PASSWORD }}"
REGION: "${{ vars.REGION }}"
DATABASE: "${{ vars.DATABASE }}"
WAREHOUSE: "${{ vars.WAREHOUSE }}"
SCHEMA: "${{ vars.SCHEMA }}"
concurrency:
group: ${{ github.workflow }}
jobs:
run_dbt_jobs:
runs-on: ubuntu-latest
environment:
name: workflow_prod
steps:
- uses: actions/checkout@v3
- uses: actions/setup-python@v4
with:
python-version: "3.10"
cache: "pip"
- name: install dependencies
run: |
pip install -r requirements.txt
dbt deps
- name: Run DBT Jobs
run: |
dbt run -m "sei_models,tag:scores"
notify-failure:
needs: [run_dbt_jobs]
if: failure()
uses: ./.github/workflows/slack_notify.yml
secrets:
EVM_SLACK_WEBHOOK_URL: ${{ secrets.EVM_SLACK_WEBHOOK_URL }}

10
macros/tests/txs_have_traces.sql
View File

@ -3,7 +3,9 @@
transactions_model
) %}
{% set vars = return_vars() %}
{% set MAIN_CORE_GOLD_TRACES_TEST_ERROR_THRESHOLD = var('MAIN_CORE_GOLD_TRACES_TEST_ERROR_THRESHOLD', 5000) %}
{% set GLOBAL_PROJECT_NAME = 'sei'%}
WITH txs_with_traces AS (
@ -28,11 +30,11 @@ WHERE
)
AND txs.from_address <> '0x0000000000000000000000000000000000000000'
AND txs.to_address <> '0x0000000000000000000000000000000000000000'
{% if vars.GLOBAL_PROJECT_NAME == 'arbitrum' %}
{% if GLOBAL_PROJECT_NAME == 'arbitrum' %}
AND txs.to_address <> '0x000000000000000000000000000000000000006e'
AND txs.block_number > 22207817
{% endif %}
{% if vars.GLOBAL_PROJECT_NAME == 'boba' %}
{% if GLOBAL_PROJECT_NAME == 'boba' %}
AND txs.block_number > 1041894
{% endif %}
)
@ -44,7 +46,7 @@ FROM
WHERE
(
SELECT
COUNT(DISTINCT block_number) >= {{ vars.MAIN_CORE_GOLD_TRACES_TEST_ERROR_THRESHOLD }}
COUNT(DISTINCT block_number) >= {{ MAIN_CORE_GOLD_TRACES_TEST_ERROR_THRESHOLD }}
FROM
txs_with_traces
)

5
models/evm/gold/core/core_evm__ez_native_transfers.sql
View File

@ -1,3 +1,6 @@
{% set GLOBAL_PROJECT_NAME = 'sei'%}
{% set GLOBAL_NEW_BUILD_ENABLED = var('GLOBAL_NEW_BUILD_ENABLED', false) %}
{{ config (
materialized = "incremental",
@ -119,7 +122,7 @@ SELECT
t.origin_to_address,
t.origin_function_signature,
t.ez_native_transfers_id,
{% if is_incremental() or vars.GLOBAL_NEW_BUILD_ENABLED %}
{% if is_incremental() or GLOBAL_NEW_BUILD_ENABLED %}
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp
{% else %}

451
models/evm/scores_package/scores__actions.sql Normal file
View File

@ -0,0 +1,451 @@
-- depends_on: {{ ref('scores__target_days') }}
{# Scores Variables #}
{% set SCORES_FULL_RELOAD_ENABLED = var('SCORES_FULL_RELOAD_ENABLED', false) %}
{% set SCORES_LIMIT_DAYS = var('SCORES_LIMIT_DAYS', 30) %}
{% set include_gaming_metrics = var('INCLUDE_GAMING_METRICS', false) %}
{% set GLOBAL_PROJECT_NAME = 'sei'%}
{{ config (
materialized = "incremental",
unique_key = "block_date",
incremental_strategy = "delete+insert",
cluster_by = "block_date",
full_refresh = false,
tags = ['silver','scores','phase_4']
) }}
{% if is_incremental() %}
{% set max_block_date_query %}
WITH target_days AS (
SELECT block_date
FROM {{ ref('scores__target_days') }}
{% if not SCORES_FULL_RELOAD_ENABLED %}
WHERE block_date > dateadd('day', -120, sysdate())
{% endif %}
),
processed_days AS (
SELECT DISTINCT block_date
FROM {{ this }}
{% if not SCORES_FULL_RELOAD_ENABLED %}
WHERE block_date > dateadd('day', -120, sysdate())
{% endif %}
),
unprocessed_days AS (
SELECT block_date
FROM target_days
EXCEPT
SELECT block_date
FROM processed_days
)
SELECT block_date
FROM unprocessed_days
{% endset %}
{% set results = run_query(max_block_date_query) %}
{% if execute %}
{% set block_dates = results.columns[0].values() %}
{% if block_dates|length > 0 %}
{{ log("==========================================", info=True) }}
{{ log("Loading action data for blockchain: " ~ GLOBAL_PROJECT_NAME, info=True) }}
{{ log("For block dates: " ~ block_dates|join(', '), info=True) }}
{{ log("==========================================", info=True) }}
{% else %}
{{ log("==========================================", info=True) }}
{{ log("No new action data to process for blockchain: " ~ GLOBAL_PROJECT_NAME, info=True) }}
{{ log("==========================================", info=True) }}
{% endif %}
{% else %}
{% set block_dates = [] %}
{% endif %}
{% endif %}
{% if (is_incremental() and block_dates|length > 0) or (not is_incremental()) %}
WITH txs AS (
SELECT
block_timestamp :: DATE AS block_date,
from_address,
to_address,
input_data <> '0x'
AND LEFT(input_data, 10) <> '0xa9059cbb' AS complex_tx,
input_data <> '0x' AS to_address_is_contract,
block_timestamp,
tx_hash,
block_number
FROM
{{ ref('core_evm__fact_transactions') }} t
WHERE
tx_succeeded
{% if is_incremental() %}
AND t.block_timestamp::date IN ({% for date in block_dates %}{% if not loop.first %}, {% endif %}'{{ date }}'{% endfor %})
AND 1=1
{% else %}
AND block_timestamp :: DATE < (SELECT MAX(block_timestamp)::DATE FROM {{ ref('core_evm__fact_transactions') }})
{% endif %}
),
raw_logs AS (
SELECT
block_timestamp :: DATE AS block_date,
origin_from_address,
origin_to_address,
event_index,
contract_address,
topics[0] :: STRING AS event_sig,
topics,
data,
block_timestamp,
tx_hash,
block_number
FROM
{{ ref('core_evm__fact_event_logs') }} l
JOIN txs USING (block_number, tx_hash)
WHERE
{% if is_incremental() %}
l.block_timestamp::date IN ({% for date in block_dates %}{% if not loop.first %}, {% endif %}'{{ date }}'{% endfor %})
AND 1=1
{% else %}
l.block_timestamp :: DATE < (SELECT MAX(block_timestamp)::DATE FROM {{ ref('core_evm__fact_transactions') }})
{% endif %}
),
decoded_event_logs AS (
SELECT
event_index,
contract_address,
event_name,
block_timestamp,
tx_hash,
block_number
FROM
{{ ref('core_evm__ez_decoded_event_logs') }} dl
JOIN txs USING (block_number, tx_hash)
WHERE
{% if is_incremental() %}
dl.block_timestamp::date IN ({% for date in block_dates %}{% if not loop.first %}, {% endif %}'{{ date }}'{% endfor %})
AND 1=1
{% else %}
dl.block_timestamp :: DATE < (SELECT MAX(block_timestamp)::DATE FROM {{ ref('core_evm__fact_transactions') }})
{% endif %}
),
native_transfers AS (
SELECT
from_address,
to_address,
value,
block_timestamp,
tx_hash,
block_number,
trace_index
FROM
{{ ref('core_evm__fact_traces') }} tr
JOIN txs USING (block_number, tx_hash)
WHERE
{% if is_incremental() %}
tr.block_timestamp::date IN ({% for date in block_dates %}{% if not loop.first %}, {% endif %}'{{ date }}'{% endfor %})
AND 1=1
{% else %}
tr.block_timestamp :: DATE < (SELECT MAX(block_timestamp)::DATE FROM {{ ref('core_evm__fact_transactions') }})
{% endif %}
AND value > 0
AND trace_succeeded
),
event_names AS (
SELECT
block_date,
origin_from_address,
origin_to_address,
contract_address,
event_sig,
COALESCE(d.event_name, e.event_name) AS event_name,
event_index,
topics,
data,
block_timestamp,
tx_hash,
block_number
FROM
raw_logs
LEFT JOIN decoded_event_logs d USING (block_number, tx_hash, event_index)
LEFT JOIN {{ ref('scores__event_sigs') }} e USING (event_sig)
),
all_transfers AS (
SELECT
block_date,
origin_from_address,
origin_to_address,
contract_address,
event_index,
block_timestamp,
block_number,
tx_hash,
CASE
WHEN topics[0] :: STRING = '0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef'
AND data = '0x'
AND topics[3] IS NOT NULL THEN 'erc721_transfer'
WHEN topics[0] :: STRING = '0xc3d58168c5ae7397731d063d5bbf3d657854427343f4c083240f7aacaa2d0f62' THEN 'erc1155_transfer'
WHEN topics[0] :: STRING = '0x4a39dc06d4c0dbc64b70af90fd698a233a518aa5d07e595d983b8c0526c8f7fb' THEN 'erc1155_transfer_batch'
WHEN topics[0] :: STRING = '0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef'
AND SUBSTR(data, 3, 64) IS NOT NULL
AND SUBSTR(topics[1], 27, 40) IS NOT NULL
AND SUBSTR(topics[2], 27, 40) IS NOT NULL THEN 'erc20_transfer'
ELSE NULL
END AS transfer_type,
IFF(
transfer_type = 'erc20_transfer',
TRY_TO_NUMBER(utils.udf_hex_to_int(SUBSTR(data, 3, 64))) / POW(10, COALESCE(c.decimals, 18)),
NULL
) AS value,
CASE
WHEN transfer_type IN ('erc20_transfer', 'erc721_transfer') THEN CONCAT('0x', SUBSTR(topics[1], 27, 40)) :: STRING
WHEN transfer_type IN ('erc1155_transfer', 'erc1155_transfer_batch') THEN CONCAT('0x', SUBSTR(topics[2] :: STRING, 27, 40))
ELSE NULL
END AS token_from_address,
CASE
WHEN transfer_type IN ('erc20_transfer', 'erc721_transfer') THEN CONCAT('0x', SUBSTR(topics[2], 27, 40)) :: STRING
WHEN transfer_type IN ('erc1155_transfer', 'erc1155_transfer_batch') THEN CONCAT('0x', SUBSTR(topics[3] :: STRING, 27, 40))
ELSE NULL
END AS token_to_address,
token_from_address = '0x0000000000000000000000000000000000000000' AS is_mint
FROM
event_names e
LEFT JOIN {{ ref('core_evm__dim_contracts') }} c ON e.contract_address = c.address
WHERE
transfer_type IS NOT NULL
UNION ALL
SELECT
block_timestamp :: DATE AS block_date,
txs.from_address AS origin_from_address,
txs.to_address AS origin_to_address,
NULL AS contract_address,
trace_index AS event_index,
block_timestamp,
block_number,
tx_hash,
'native_transfer' AS transfer_type,
value,
from_address AS token_from_address,
to_address AS token_to_address,
FALSE AS is_mint
FROM
native_transfers
LEFT JOIN txs USING (block_number, tx_hash)
),
labeled_transfers AS (
SELECT
t.block_date,
t.origin_from_address,
t.origin_to_address,
t.contract_address,
t.event_index,
t.block_timestamp,
t.block_number,
t.tx_hash,
t.transfer_type,
t.value,
t.token_from_address,
t.token_to_address,
t.is_mint,
lbl_from.label_type AS from_type,
lbl_from.label_subtype AS from_subtype,
lbl_to.label_type AS to_type,
lbl_to.label_subtype AS to_subtype,
CASE
WHEN is_mint AND transfer_type = 'erc721_transfer' THEN 'n_nft_mints'
WHEN is_mint AND transfer_type = 'erc1155_transfer' THEN 'n_nft_mints'
WHEN is_mint AND transfer_type = 'erc1155_transfer_batch' THEN 'n_nft_mints'
WHEN lbl_from.label_type = 'bridge' and lbl_from.label_subtype <> 'token_contract' THEN 'n_bridge_in'
WHEN (transfer_type = 'native_transfer' or (transfer_type = 'erc20_transfer' and am.is_verified))
AND from_type = 'cex' and from_subtype in ('hot_wallet', 'deposit_wallet')
AND to_type IS NULL
THEN 'n_cex_withdrawals'
ELSE NULL
END AS label_metric_name,
metric_rank
FROM
all_transfers t
LEFT JOIN {{ ref('core_evm__dim_labels') }} lbl_from ON t.token_from_address = lbl_from.address
LEFT JOIN {{ ref('core_evm__dim_labels') }} lbl_to ON t.token_to_address = lbl_to.address
LEFT JOIN {{ ref('price__ez_asset_metadata')}} am ON t.contract_address = am.token_address
LEFT JOIN {{ ref('scores__scoring_activity_categories') }} a ON a.metric = label_metric_name
),
eligible_events AS (
SELECT
block_date,
origin_from_address,
origin_to_address,
contract_address,
e.event_sig,
e.event_name,
event_index,
block_timestamp,
tx_hash,
block_number,
l.label_type,
s.metric AS sig_metric_name,
n.metric AS name_metric_name,
CASE
WHEN l.label_type = 'bridge' and l.label_subtype <> 'token_contract' THEN 'n_bridge_in'
WHEN l.label_type = 'dex' THEN 'n_swap_tx'
WHEN l.label_type = 'defi' THEN 'n_other_defi'
{% if include_gaming_metrics %}
WHEN l.label_type IN ('nft', 'token', 'games') THEN 'n_gaming_actions'
{% endif %}
ELSE NULL
END AS label_metric_name,
{% if include_gaming_metrics %}
CASE
WHEN l.label_type IN ('nft', 'token', 'games') THEN label_metric_name
ELSE COALESCE(sig_metric_name, label_metric_name, name_metric_name)
END AS metric_name_0,
{% else %}
COALESCE(sig_metric_name, label_metric_name, name_metric_name) AS metric_name_0,
{% endif %}
CASE
WHEN wrapped_asset_address IS NOT NULL AND e.event_sig = '0xe1fffcc4923d04b559f4d29a8bfc6cda04eb5b0d3c460751c2402c5c5cc9109c' THEN 'n_swap_tx'
WHEN metric_name_0 = 'n_bridge_in' THEN 'n_other_defi' -- any events labeled as bridge would be bridges out, therefore we need to label them as other_defi
ELSE metric_name_0
END AS metric_name,
metric_rank
FROM
event_names e
LEFT JOIN {{ ref('core_evm__dim_labels') }} l ON contract_address = l.address
LEFT JOIN {{ ref('scores__known_event_sigs') }} s ON s.event_sig = e.event_sig
LEFT JOIN {{ ref('scores__known_event_names') }} n ON e.event_name ILIKE '%' || n.event_name || '%'
LEFT JOIN {{ ref('scores__wrapped_assets') }} w ON e.contract_address = w.wrapped_asset_address AND w.blockchain = '{{ GLOBAL_PROJECT_NAME }}'
LEFT JOIN {{ ref('scores__scoring_activity_categories') }} a ON a.metric = metric_name
WHERE
e.event_sig NOT IN (
'0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef', -- transfers
'0x8c5be1e5ebec7d5bd14f71427d1e84f3dd0314c0f7b2291e5b200ac8c7c3b925', -- approvals,
'0x4a39dc06d4c0dbc64b70af90fd698a233a518aa5d07e595d983b8c0526c8f7fb', -- transfer batch
'0xc3d58168c5ae7397731d063d5bbf3d657854427343f4c083240f7aacaa2d0f62' -- transfer single
)
),
prioritized_eligible_events AS (
SELECT
block_date,
origin_from_address,
origin_to_address,
contract_address,
event_sig,
event_name,
event_index,
block_timestamp,
tx_hash,
block_number,
label_type,
sig_metric_name,
name_metric_name,
label_metric_name,
metric_name_0,
metric_name,
metric_rank
FROM
eligible_events
QUALIFY ROW_NUMBER() OVER (PARTITION BY tx_hash, event_index ORDER BY metric_rank ASC) = 1
),
create_action_details AS (
SELECT
block_date,
origin_from_address,
origin_to_address,
event_index AS index,
block_timestamp,
block_number,
tx_hash,
transfer_type AS action_type,
OBJECT_CONSTRUCT(
'value', value,
'token_from_address', token_from_address,
'token_to_address', token_to_address,
'from_label_type', from_type,
'to_label_type', to_type,
'contract_address', contract_address
) AS action_details,
label_metric_name AS metric_name,
metric_rank
FROM
labeled_transfers
UNION ALL
SELECT
block_date,
origin_from_address,
origin_to_address,
event_index AS index,
block_timestamp,
block_number,
tx_hash,
'contract_interaction' AS action_type,
OBJECT_CONSTRUCT(
'event_name', event_name,
'event_sig', event_sig,
'label_type', label_type,
'contract_address', contract_address
) AS action_details,
metric_name,
metric_rank
FROM
prioritized_eligible_events
UNION ALL
SELECT
block_date,
from_address AS origin_from_address,
to_address AS origin_to_address,
-1 AS index,
block_timestamp,
block_number,
tx_hash,
'tx' AS action_type,
OBJECT_CONSTRUCT(
'complex_tx', complex_tx,
'to_address_is_contract', to_address_is_contract,
'label_type', NULL
) AS action_details,
NULL AS metric_name,
NULL AS metric_rank
FROM
txs
)
SELECT
block_date,
origin_from_address,
origin_to_address,
index,
block_timestamp,
block_number,
tx_hash,
action_type,
action_details,
metric_name,
metric_rank,
'{{ GLOBAL_PROJECT_NAME }}' AS blockchain,
{{ dbt_utils.generate_surrogate_key(['tx_hash', 'index', 'action_type', "'" ~ blockchain ~ "'"]) }} AS actions_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
create_action_details
{% else %}
-- Return an empty result set with the correct schema
SELECT
CAST(NULL AS DATE) AS block_date,
CAST(NULL AS STRING) AS origin_from_address,
CAST(NULL AS STRING) AS origin_to_address,
CAST(NULL AS INTEGER) AS index,
CAST(NULL AS TIMESTAMP) AS block_timestamp,
CAST(NULL AS INTEGER) AS block_number,
CAST(NULL AS STRING) AS tx_hash,
CAST(NULL AS STRING) AS action_type,
CAST(NULL AS OBJECT) AS action_details,
CAST(NULL AS STRING) AS metric_name,
CAST(NULL AS INTEGER) AS metric_rank,
CAST(NULL AS STRING) AS blockchain,
CAST(NULL AS STRING) AS actions_id,
CAST(NULL AS TIMESTAMP) AS inserted_timestamp,
CAST(NULL AS TIMESTAMP) AS modified_timestamp,
CAST(NULL AS STRING) AS _invocation_id
WHERE 1 = 0
{% endif %}

188
models/evm/scores_package/scores__actions_agg.sql Normal file
View File

@ -0,0 +1,188 @@
-- depends_on: {{ ref('scores__actions_daily') }}
-- depends_on: {{ ref('core_evm__dim_labels') }}
-- depends_on: {{ ref('core_evm__dim_contracts') }}
{# Scores Variables #}
{% set SCORES_FULL_RELOAD_ENABLED = var('SCORES_FULL_RELOAD_ENABLED', false) %}
{% set SCORES_LIMIT_DAYS = var('SCORES_LIMIT_DAYS', 30) %}
{% set include_gaming_metrics = var('INCLUDE_GAMING_METRICS', false) %}
{% set GLOBAL_PROJECT_NAME = 'sei'%}
{{ config (
materialized = "incremental",
unique_key = "score_date",
incremental_strategy = "delete+insert",
cluster_by = "score_date",
version = 1,
full_refresh = false,
tags = ['silver','scores','phase_4']
) }}
{% set score_dates_query %}
SELECT block_date as score_date
FROM {{ ref('scores__target_days') }}
{% if not SCORES_FULL_RELOAD_ENABLED %}
WHERE score_date > dateadd('day', -120, sysdate())
{% endif %}
{% if is_incremental() %}
EXCEPT
SELECT DISTINCT score_date
FROM {{ this }}
{% if not SCORES_FULL_RELOAD_ENABLED %}
WHERE score_date > dateadd('day', -120, sysdate())
{% endif %}
{% endif %}
ORDER BY score_date ASC
{% if SCORES_LIMIT_DAYS %}
LIMIT {{ SCORES_LIMIT_DAYS }}
{% endif %}
{% endset %}
{% set score_dates = run_query(score_dates_query) %}
{% if execute %}
{% set score_dates_list = score_dates.columns[0].values() %}
{% else %}
{% set score_dates_list = [] %}
{% endif %}
{% if execute %}
{% if score_dates_list|length > 0 %}
{{ log("==========================================", info=True) }}
{% if score_dates_list|length == 1 %}
{{ log("Calculating action totals for blockchain: " ~ GLOBAL_PROJECT_NAME, info=True) }}
{{ log("For score date: " ~ score_dates_list[0], info=True) }}
{% else %}
{{ log("Calculating action totals for blockchain: " ~ GLOBAL_PROJECT_NAME, info=True) }}
{{ log("For score dates: " ~ score_dates_list|join(', '), info=True) }}
{% endif %}
{{ log("==========================================", info=True) }}
{% else %}
{{ log("==========================================", info=True) }}
{{ log("No action totals to calculate for blockchain: " ~ GLOBAL_PROJECT_NAME, info=True) }}
{{ log("==========================================", info=True) }}
{% endif %}
{% endif %}
{% if score_dates_list|length > 0 %}
WITH combined_results AS (
{% for score_date in score_dates_list %}
SELECT
user_address,
n_complex_txn,
n_contracts,
n_days_active,
n_txn,
n_bridge_in,
n_cex_withdrawals,
net_token_accumulate,
n_other_defi,
n_lp_adds,
n_swap_tx,
n_nft_collections,
n_nft_mints,
n_nft_trades,
n_gov_votes,
n_stake_tx,
n_restakes,
n_validators,
{% if include_gaming_metrics %}
n_gaming_actions,
net_gaming_token_accumulate,
net_gaming_nft_accumulate,
{% endif %}
CURRENT_TIMESTAMP AS calculation_time,
CAST('{{ score_date }}' AS DATE) AS score_date,
'{{ GLOBAL_PROJECT_NAME }}' AS blockchain,
{{ dbt_utils.generate_surrogate_key(['user_address', "'" ~ blockchain ~ "'", "'" ~ score_date ~ "'"]) }} AS actions_agg_id,
'{{ model.config.version }}' AS score_version,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
(
SELECT
user_address,
SUM(n_bridge_in) AS n_bridge_in,
SUM(n_cex_withdrawals) AS n_cex_withdrawals,
SUM(n_other_defi) AS n_other_defi,
SUM(n_lp_adds) AS n_lp_adds,
SUM(n_swap_tx) AS n_swap_tx,
SUM(n_nft_mints) AS n_nft_mints,
SUM(n_nft_trades) AS n_nft_trades,
SUM(n_gov_votes) AS n_gov_votes,
SUM(n_stake_tx) AS n_stake_tx,
SUM(n_restakes) AS n_restakes,
SUM(net_token_accumulate) AS net_token_accumulate,
SUM(n_txn) AS n_txn,
SUM(IFF(active_day, 1, 0)) AS n_days_active,
SUM(complex_tx) AS n_complex_txn,
ARRAY_SIZE(ARRAY_COMPACT(ARRAY_DISTINCT(ARRAY_UNION_AGG(validator_addresses)))) AS n_validators,
ARRAY_SIZE(ARRAY_COMPACT(ARRAY_DISTINCT(ARRAY_UNION_AGG(contract_addresses)))) AS n_contracts,
ARRAY_SIZE(ARRAY_COMPACT(ARRAY_DISTINCT(ARRAY_UNION_AGG(nft_collection_addresses)))) AS n_nft_collections
{% if include_gaming_metrics %}
,SUM(n_gaming_actions) AS n_gaming_actions,
SUM(net_gaming_token_accumulate) AS net_gaming_token_accumulate,
SUM(net_gaming_nft_accumulate) AS net_gaming_nft_accumulate
{% endif %}
FROM
{{ ref('scores__actions_daily') }} a
LEFT JOIN {{ ref('core_evm__dim_labels') }} b
ON a.user_address = b.address
LEFT JOIN {{ ref('core_evm__dim_contracts') }} c
ON a.user_address = c.address
WHERE
b.address IS NULL
AND c.address IS NULL
AND a.block_date BETWEEN DATEADD('day', -90, '{{ score_date }}') AND '{{ score_date }}' :: DATE
GROUP BY
user_address
)
{% if not loop.last %}
UNION ALL
{% endif %}
{% endfor %}
)
SELECT * FROM combined_results
{% else %}
-- Return an empty result set with the correct schema
SELECT
CAST(NULL AS STRING) AS user_address,
CAST(NULL AS INTEGER) AS n_complex_txn,
CAST(NULL AS INTEGER) AS n_contracts,
CAST(NULL AS INTEGER) AS n_days_active,
CAST(NULL AS INTEGER) AS n_txn,
CAST(NULL AS INTEGER) AS n_bridge_in,
CAST(NULL AS INTEGER) AS n_cex_withdrawals,
CAST(NULL AS FLOAT) AS net_token_accumulate,
CAST(NULL AS INTEGER) AS n_other_defi,
CAST(NULL AS INTEGER) AS n_lp_adds,
CAST(NULL AS INTEGER) AS n_swap_tx,
CAST(NULL AS INTEGER) AS n_nft_collections,
CAST(NULL AS INTEGER) AS n_nft_mints,
CAST(NULL AS INTEGER) AS n_nft_trades,
CAST(NULL AS INTEGER) AS n_gov_votes,
CAST(NULL AS INTEGER) AS n_stake_tx,
CAST(NULL AS INTEGER) AS n_restakes,
CAST(NULL AS INTEGER) AS n_validators,
{% if include_gaming_metrics %}
CAST(NULL AS INTEGER) AS n_gaming_actions,
CAST(NULL AS FLOAT) AS net_gaming_token_accumulate,
CAST(NULL AS FLOAT) AS net_gaming_nft_accumulate,
{% endif %}
CAST(NULL AS TIMESTAMP) AS calculation_time,
CAST(NULL AS DATE) AS score_date,
CAST(NULL AS STRING) AS blockchain,
CAST(NULL AS STRING) AS actions_agg_id,
CAST(NULL AS STRING) AS score_version,
CAST(NULL AS TIMESTAMP) AS inserted_timestamp,
CAST(NULL AS TIMESTAMP) AS modified_timestamp,
CAST(NULL AS STRING) AS _invocation_id
WHERE 1 = 0
{% endif %}

516
models/evm/scores_package/scores__actions_daily.sql Normal file
View File

@ -0,0 +1,516 @@
{# Scores Variables #}
{% set SCORES_FULL_RELOAD_ENABLED = var('SCORES_FULL_RELOAD_ENABLED', false) %}
{% set SCORES_LIMIT_DAYS = var('SCORES_LIMIT_DAYS', 30) %}
{% set include_gaming_metrics = var('INCLUDE_GAMING_METRICS', false) %}
{% set GLOBAL_PROJECT_NAME = 'sei'%}
{{ config (
materialized = "incremental",
unique_key = "block_date",
incremental_strategy = "delete+insert",
cluster_by = "block_date",
version = 1,
tags = ['silver','scores','phase_4']
) }}
{% if is_incremental() %}
{% set max_modified_timestamp_query %}
SELECT MAX(modified_timestamp) as max_modified_timestamp
FROM {{ this }}
{% endset %}
{% set results = run_query(max_modified_timestamp_query) %}
{% if execute %}
{% set max_modified_timestamp = results.columns[0].values()[0] %}
{% else %}
{% set max_modified_timestamp = none %}
{% endif %}
{% endif %}
{% if execute %}
{{ log("==========================================", info=True) }}
{% if is_incremental() %}
{% set new_data_check_query %}
SELECT COUNT(1) as cnt
FROM {{ ref('scores__actions') }}
WHERE modified_timestamp > '{{ max_modified_timestamp }}'
limit 1
{% endset %}
{% set new_data_results = run_query(new_data_check_query) %}
{% set new_data_count = new_data_results.columns[0].values()[0] %}
{% if new_data_count > 0 %}
{{ log("Processing action data for blockchain: " ~ GLOBAL_PROJECT_NAME ~ " modified after: " ~ max_modified_timestamp, info=True) }}
{% else %}
{{ log("No new action data to aggregate daily for blockchain: " ~ GLOBAL_PROJECT_NAME, info=True) }}
{% endif %}
{% else %}
{{ log("Aggregating daily action data for blockchain: " ~ GLOBAL_PROJECT_NAME, info=True) }}
{% endif %}
{{ log("==========================================", info=True) }}
{% endif %}
WITH actions AS (
SELECT
block_date,
origin_from_address,
origin_to_address,
INDEX,
block_timestamp,
block_number,
tx_hash,
action_type,
action_details,
metric_name,
metric_rank
FROM
{{ ref('scores__actions') }}
WHERE
1=1
{% if is_incremental() %}
AND modified_timestamp > '{{ max_modified_timestamp }}'
{% endif %}
),
prioritized_actions AS (
SELECT
block_date,
origin_from_address,
origin_to_address,
INDEX,
block_timestamp,
block_number,
tx_hash,
action_type,
action_details,
metric_name,
metric_rank,
CASE
WHEN metric_name = 'n_bridge_in' THEN action_details :token_to_address :: STRING
WHEN metric_name = 'n_cex_withdrawals' THEN action_details :token_to_address :: STRING
WHEN metric_name = 'n_other_defi' THEN origin_from_address :: STRING
WHEN metric_name = 'n_lp_adds' THEN origin_from_address :: STRING
WHEN metric_name = 'n_swap_tx' THEN origin_from_address :: STRING
WHEN metric_name = 'n_nft_mints' THEN action_details :token_to_address :: STRING
WHEN metric_name = 'n_nft_trades' THEN origin_from_address :: STRING
WHEN metric_name = 'n_gov_votes' THEN origin_from_address :: STRING
WHEN metric_name = 'n_stake_tx' THEN origin_from_address :: STRING
WHEN metric_name = 'n_restakes' THEN origin_from_address :: STRING
{% if include_gaming_metrics %}
WHEN metric_name = 'n_gaming_actions' THEN origin_from_address :: STRING
{% endif %}
END AS user_address
FROM
actions
WHERE
action_type <> 'tx'
qualify ROW_NUMBER() over (PARTITION BY tx_hash, user_address, metric_name ORDER BY metric_rank ASC nulls last) = 1
),
simple_aggs AS (
SELECT
block_date,
user_address,
SUM(IFF(metric_name = 'n_bridge_in', 1, 0)) AS n_bridge_in,
SUM(IFF(metric_name = 'n_cex_withdrawals', 1, 0)) AS n_cex_withdrawals,
SUM(IFF(metric_name = 'n_other_defi', 1, 0)) AS n_other_defi,
SUM(IFF(metric_name = 'n_lp_adds', 1, 0)) AS n_lp_adds,
SUM(IFF(metric_name = 'n_swap_tx', 1, 0)) AS n_swap_tx,
SUM(IFF(metric_name = 'n_nft_mints', 1, 0)) AS n_nft_mints,
SUM(IFF(metric_name = 'n_nft_trades', 1, 0)) AS n_nft_trades,
SUM(IFF(metric_name = 'n_gov_votes', 1, 0)) AS n_gov_votes,
SUM(IFF(metric_name = 'n_stake_tx', 1, 0)) AS n_stake_tx,
SUM(IFF(metric_name = 'n_restakes', 1, 0)) AS n_restakes
{% if include_gaming_metrics %}
,SUM(IFF(metric_name = 'n_gaming_actions', 1, 0)) AS n_gaming_actions,
{% endif %}
FROM
prioritized_actions
GROUP BY
ALL
),
xfer_in AS (
SELECT
block_date,
action_details :token_to_address :: STRING AS user_address,
{% if include_gaming_metrics %}
COUNT(IFF(l.label_type != 'games' OR l.label_type IS NULL, 1, 0)) AS n_xfer_in,
COUNT(IFF(l.label_type = 'games', 1, 0)) AS n_gaming_xfer_in
{% else %}
COUNT(1) AS n_xfer_in
{% endif %}
FROM
actions a
{% if include_gaming_metrics %}
LEFT JOIN {{ ref('core_evm__dim_labels') }} l
ON a.action_details:contract_address::string = l.address
{% endif %}
WHERE
action_type IN (
'erc20_transfer',
'native_transfer'
)
GROUP BY
ALL
),
xfer_out AS (
SELECT
block_date,
action_details :token_from_address :: STRING AS user_address,
{% if include_gaming_metrics %}
COUNT(IFF(l.label_type != 'games' OR l.label_type IS NULL, 1, 0)) AS n_xfer_out,
COUNT(IFF(l.label_type = 'games', 1, 0)) AS n_gaming_xfer_out
{% else %}
COUNT(1) AS n_xfer_out
{% endif %}
FROM
actions a
{% if include_gaming_metrics %}
LEFT JOIN {{ ref('core_evm__dim_labels') }} l
ON a.action_details:contract_address::string = l.address
{% endif %}
WHERE
action_type IN (
'erc20_transfer',
'native_transfer'
)
GROUP BY
ALL
),
net_token_accumulate AS (
SELECT
COALESCE(
A.block_date,
b.block_date
) AS block_date,
COALESCE(
A.user_address,
b.user_address
) AS user_address,
COALESCE(n_xfer_in / (ifnull(n_xfer_in,0) + ifnull(n_xfer_out,0)),0) AS net_token_accumulate
{% if include_gaming_metrics %}
,COALESCE(n_gaming_xfer_in / NULLIF(n_gaming_xfer_in + n_gaming_xfer_out, 0), 0) AS net_gaming_token_accumulate
{% endif %}
FROM
xfer_in A full
OUTER JOIN xfer_out b
ON A.user_address = b.user_address
AND A.block_date = b.block_date
),
nft_in AS (
SELECT
block_date,
action_details :token_to_address :: STRING AS user_address,
{% if include_gaming_metrics %}
COUNT(IFF(l.label_type != 'games' OR l.label_type IS NULL, 1, 0)) AS n_nft_in,
COUNT(IFF(l.label_type = 'games', 1, 0)) AS n_gaming_nft_in
{% else %}
COUNT(1) AS n_nft_in
{% endif %}
FROM
actions a
{% if include_gaming_metrics %}
LEFT JOIN {{ ref('core_evm__dim_labels') }} l
ON a.action_details:contract_address::string = l.address
{% endif %}
WHERE
action_type IN (
'erc721_transfer',
'erc1155_transfer',
'erc1155_transfer_batch'
)
GROUP BY
ALL
),
nft_out AS (
SELECT
block_date,
action_details :token_from_address :: STRING AS user_address,
{% if include_gaming_metrics %}
COUNT(IFF(l.label_type != 'games' OR l.label_type IS NULL, 1, 0)) AS n_nft_out,
COUNT(IFF(l.label_type = 'games', 1, 0)) AS n_gaming_nft_out
{% else %}
COUNT(1) AS n_nft_out
{% endif %}
FROM
actions a
{% if include_gaming_metrics %}
LEFT JOIN {{ ref('core_evm__dim_labels') }} l
ON a.action_details:contract_address::string = l.address
{% endif %}
WHERE
action_type IN (
'erc721_transfer',
'erc1155_transfer',
'erc1155_transfer_batch'
)
GROUP BY
ALL
),
net_nft_accumulate AS (
SELECT
COALESCE(A.block_date, b.block_date) AS block_date,
COALESCE(A.user_address, b.user_address) AS user_address,
COALESCE(n_nft_in / NULLIF(n_nft_in + n_nft_out, 0), 0) AS net_nft_accumulate
{% if include_gaming_metrics %}
,COALESCE(n_gaming_nft_in / NULLIF(n_gaming_nft_in + n_gaming_nft_out, 0), 0) AS net_gaming_nft_accumulate
{% endif %}
FROM
nft_in A
FULL OUTER JOIN nft_out b
ON A.user_address = b.user_address
AND A.block_date = b.block_date
),
nft_collections AS (
SELECT
block_date,
user_address,
{% if include_gaming_metrics %}
ARRAY_AGG(IFF(l.label_type != 'games' OR l.label_type IS NULL, nft_address, NULL)) AS nft_collection_addresses,
ARRAY_AGG(IFF(l.label_type = 'games', nft_address, NULL)) AS gaming_nft_collection_addresses
{% else %}
ARRAY_AGG(nft_address) AS nft_collection_addresses
{% endif %}
FROM
(
SELECT
DISTINCT block_date,
action_details :token_from_address :: STRING AS user_address,
action_details: contract_address :: STRING AS nft_address
FROM
actions
WHERE
action_type IN (
'erc721_transfer',
'erc1155_transfer',
'erc1155_transfer_batch'
)
UNION
SELECT
DISTINCT block_date,
action_details :token_to_address :: STRING AS user_address,
action_details: contract_address :: STRING AS nft_address
FROM
actions
WHERE
action_type IN (
'erc721_transfer',
'erc1155_transfer',
'erc1155_transfer_batch'
)
qualify row_number() over (partition by user_address, block_date order by block_date asc) <= 1000
) nfts
{% if include_gaming_metrics %}
LEFT JOIN {{ ref('core_evm__dim_labels') }} l ON nfts.nft_address = l.address
{% endif %}
GROUP BY ALL
),
staking_validators AS (
SELECT
block_date,
origin_from_address AS user_address,
ARRAY_AGG(
action_details :contract_address :: STRING
) AS validator_addresses
FROM
(
select *
from actions
where action_type = 'contract_interaction'
and metric_name = 'n_stake_tx'
qualify row_number() over (partition by origin_from_address, block_date order by block_timestamp asc) <= 1000
)
GROUP BY
ALL
),
complex_txns AS (
SELECT
block_date,
user_address,
SUM(complex_tx) AS complex_tx
FROM
(
SELECT
block_date,
origin_from_address AS user_address,
IFF(
action_details :complex_tx :: BOOLEAN,
1,
0
) AS complex_tx,
tx_hash
FROM
actions
WHERE
action_type = 'tx'
UNION ALL
SELECT
block_date,
COALESCE(
action_details: token_to_address :: STRING,
origin_from_address :: STRING
) AS user_address,
1 AS complex_tx,
tx_hash
FROM
actions
WHERE
metric_name = 'n_bridge_in'
)
GROUP BY
ALL
),
contract_interactions AS (
SELECT
block_date,
origin_from_address AS user_address,
ARRAY_AGG(
origin_to_address
) AS contract_addresses
FROM
(
select *
from actions
where action_type = 'tx'
and action_details: to_address_is_contract :: BOOLEAN
qualify row_number() over (partition by origin_from_address, block_date order by block_timestamp asc) <= 1000
)
GROUP BY
ALL
),
active_day AS (
SELECT
block_date,
user_address,
MAX(active_day) = 1 AS active_day,
SUM(active_day) AS n_txn
FROM
(
SELECT
block_date,
origin_from_address AS user_address,
1 AS active_day
FROM
actions
WHERE
action_type = 'tx'
UNION ALL
SELECT
block_date,
action_details: token_to_address :: STRING AS user_address,
1 AS active_day
FROM
actions
WHERE
metric_name = 'n_bridge_in'
UNION ALL
SELECT
block_date,
action_details: token_to_address :: STRING AS user_address,
1 AS active_day
FROM
actions
WHERE
metric_name = 'n_cex_withdrawals'
)
GROUP BY
ALL
)
SELECT
ad.block_date,
ad.user_address,
IFNULL(
n_bridge_in,
0
) AS n_bridge_in,
IFNULL(
n_cex_withdrawals,
0
) AS n_cex_withdrawals,
IFNULL(
n_other_defi,
0
) AS n_other_defi,
IFNULL(
n_lp_adds,
0
) AS n_lp_adds,
IFNULL(
n_swap_tx,
0
) AS n_swap_tx,
IFNULL(
n_nft_mints,
0
) AS n_nft_mints,
IFNULL(
n_nft_trades,
0
) AS n_nft_trades,
IFNULL(
n_gov_votes,
0
) AS n_gov_votes,
IFNULL(
n_stake_tx,
0
) AS n_stake_tx,
IFNULL(
n_restakes,
0
) AS n_restakes,
{% if include_gaming_metrics %}
IFNULL(n_gaming_actions, 0) AS n_gaming_actions,
IFNULL(net_gaming_token_accumulate, 0) AS net_gaming_token_accumulate,
IFNULL(net_gaming_nft_accumulate, 0) AS net_gaming_nft_accumulate,
IFNULL(gaming_nft_collection_addresses, ARRAY_CONSTRUCT()) AS gaming_nft_collection_addresses,
{% endif %}
IFNULL(
net_token_accumulate,
0
) AS net_token_accumulate,
IFNULL(net_nft_accumulate, 0) AS net_nft_accumulate,
IFNULL(nft_collection_addresses, ARRAY_CONSTRUCT()) AS nft_collection_addresses,
IFNULL(validator_addresses, ARRAY_CONSTRUCT()) AS validator_addresses,
IFNULL(
complex_tx,
0
) AS complex_tx,
IFNULL(contract_addresses, ARRAY_CONSTRUCT()) AS contract_addresses,
IFNULL(
active_day,
FALSE
) AS active_day,
IFNULL(
n_txn,
0
) AS n_txn,
'{{ GLOBAL_PROJECT_NAME }}' AS blockchain,
{{ dbt_utils.generate_surrogate_key(
['ad.block_date','ad.user_address', "'" ~ blockchain ~ "'"]
) }} AS actions_daily_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
active_day ad
LEFT JOIN simple_aggs sa
ON ad.user_address = sa.user_address
AND ad.block_date = sa.block_date
LEFT JOIN net_token_accumulate nta
ON ad.user_address = nta.user_address
AND ad.block_date = nta.block_date
LEFT JOIN nft_collections nc
ON ad.user_address = nc.user_address
AND ad.block_date = nc.block_date
LEFT JOIN staking_validators sv
ON ad.user_address = sv.user_address
AND ad.block_date = sv.block_date
LEFT JOIN complex_txns ct
ON ad.user_address = ct.user_address
AND ad.block_date = ct.block_date
LEFT JOIN contract_interactions ci
ON ad.user_address = ci.user_address
AND ad.block_date = ci.block_date
LEFT JOIN net_nft_accumulate nna
ON ad.user_address = nna.user_address
AND ad.block_date = nna.block_date

6
models/evm/scores_package/scores__dates.sql Normal file
View File

@ -0,0 +1,6 @@
{{ config (
materialized = "view",
tags = ['silver','scores','phase_4']
) }}
select * from {{ source('data_science_silver', 'dates') }}

5
models/evm/scores_package/scores__dates.yml Normal file
View File

@ -0,0 +1,5 @@
version: 2
models:
- name: scores__dates
description: "Dates table for scores"

6
models/evm/scores_package/scores__event_sigs.sql Normal file
View File

@ -0,0 +1,6 @@
{{ config (
materialized = "view",
tags = ['silver','scores','phase_4']
) }}
select * from {{ source('data_science_silver', 'evm_event_sigs') }}

5
models/evm/scores_package/scores__event_sigs.yml Normal file
View File

@ -0,0 +1,5 @@
version: 2
models:
- name: scores__event_sigs
description: "This table contains a de-duplicated list of event signatures for EVM chains from the complete_event_abis model."

6
models/evm/scores_package/scores__known_event_names.sql Normal file
View File

@ -0,0 +1,6 @@
{{ config (
materialized = "view",
tags = ['silver','scores','phase_4']
) }}
select * from {{ source('data_science_silver', 'evm_known_event_names') }}

5
models/evm/scores_package/scores__known_event_names.yml Normal file
View File

@ -0,0 +1,5 @@
version: 2
models:
- name: scores__known_event_names
description: "This table contains a de-duplicated list of event names mapped to their scoring category. Sourced from curated models."

6
models/evm/scores_package/scores__known_event_sigs.sql Normal file
View File

@ -0,0 +1,6 @@
{{ config (
materialized = "view",
tags = ['silver','scores','phase_4']
) }}
select * from {{ source('data_science_silver', 'evm_known_event_sigs') }}

5
models/evm/scores_package/scores__known_event_sigs.yml Normal file
View File

@ -0,0 +1,5 @@
version: 2
models:
- name: scores__known_event_sigs
description: "This table contains a de-duplicated list of event signatures mapped to their scoring category. Sourced from curated models."

6
models/evm/scores_package/scores__scoring_activity_categories.sql Normal file
View File

@ -0,0 +1,6 @@
{{ config (
materialized = "view",
tags = ['silver','scores','phase_4']
) }}
select * from {{ source('data_science_silver', 'scoring_activity_categories') }}

5
models/evm/scores_package/scores__scoring_activity_categories.yml Normal file
View File

@ -0,0 +1,5 @@
version: 2
models:
- name: scores__scoring_activity_categories
description: "This table contains the scoring activity categories for the scores package."

80
models/evm/scores_package/scores__target_days.sql Normal file
View File

@ -0,0 +1,80 @@
{# Scores Variables #}
{% set SCORES_FULL_RELOAD_ENABLED = var('SCORES_FULL_RELOAD_ENABLED', false) %}
{% set SCORES_LIMIT_DAYS = var('SCORES_LIMIT_DAYS', 30) %}
{% set include_gaming_metrics = var('INCLUDE_GAMING_METRICS', false) %}
{% set GLOBAL_PROJECT_NAME = 'sei'%}
{{ config (
materialized = "view",
tags = ['silver','scores','phase_4']
) }}
{% if execute %}
{{ log("==========================================", info=True) }}
{{ log("Generating date spine for blockchain: " ~ GLOBAL_PROJECT_NAME, info=True) }}
{{ log("Backfill mode: " ~ SCORES_FULL_RELOAD_ENABLED, info=True) }}
{{ log("==========================================", info=True) }}
{% endif %}
WITH chain_dates AS (
SELECT
block_timestamp :: DATE AS block_date,
count(distinct date_trunc('hour', block_timestamp)) AS n_hours
FROM {{ ref('core_evm__fact_blocks') }}
{% if not SCORES_FULL_RELOAD_ENABLED %}
WHERE block_timestamp :: DATE > DATEADD('day', -120, SYSDATE() :: DATE)
{% endif %}
GROUP BY ALL
),
date_spine AS (
{% if SCORES_FULL_RELOAD_ENABLED %}
SELECT
date_day
FROM
{{ ref('scores__dates') }}
WHERE
day_of_week = 1
AND date_day < DATEADD('day', -90, SYSDATE() :: DATE) -- every sunday, excluding last 90 days
UNION
{% endif %}
SELECT
date_day
FROM
{{ ref('scores__dates') }}
WHERE
date_day >= DATEADD('day', -90, SYSDATE() :: DATE)
and date_day <= (SELECT MAX(block_date) FROM chain_dates where n_hours = 24)
),
day_of_chain AS (
SELECT
block_date,
ROW_NUMBER() over (ORDER BY block_date ASC) AS chain_day
FROM
chain_dates
),
exclude_first_90_days AS (
SELECT
block_date
FROM
day_of_chain
{% if SCORES_FULL_RELOAD_ENABLED %}
WHERE chain_day >= 90
{% endif %}
),
eligible_dates AS (
SELECT
block_date
FROM
exclude_first_90_days
JOIN date_spine ON date_day = block_date
)
SELECT
block_date
FROM
eligible_dates
ORDER BY block_date ASC

5
models/evm/scores_package/scores__target_days.yml Normal file
View File

@ -0,0 +1,5 @@
version: 2
models:
- name: scores__target_days
description: "This table contains the target days for the scores package. It is used to score events for the target days."

6
models/evm/scores_package/scores__wrapped_assets.sql Normal file
View File

@ -0,0 +1,6 @@
{{ config (
materialized = "view",
tags = ['silver','scores','phase_4']
) }}
select * from {{ source('data_science_silver', 'evm_wrapped_assets') }}

5
models/evm/scores_package/scores__wrapped_assets.yml Normal file
View File

@ -0,0 +1,5 @@
version: 2
models:
- name: scores__wrapped_assets
description: "This table contains a the wrapped assets for EVM chains. It is needed to correctly score deposits and withdrawals for wrapped assets."

12
models/sources.yml
View File

@ -91,4 +91,14 @@ sources:
- name: dex_swaps_seaswap
- name: lp_actions_seaswap
- name: lp_actions_fuzio
- name: lp_actions_astroport
- name: lp_actions_astroport
- name: data_science_silver
database: datascience
schema: silver
tables:
- name: evm_event_sigs
- name: evm_known_event_names
- name: evm_known_event_sigs
- name: evm_wrapped_assets
- name: dates
- name: scoring_activity_categories