forked from duneanalytics/spellbook
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #1 from duneanalytics/main
.
- Loading branch information
Showing
174 changed files
with
33,309 additions
and
26,757 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
175 changes: 175 additions & 0 deletions
175
models/_sector/nft/trades/old/platforms/element_polygon_events.sql
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,175 @@ | ||
| {{ config( | ||
| schema = 'element_polygon', | ||
| alias = 'events', | ||
| partition_by = ['block_date'], | ||
| materialized = 'incremental', | ||
| file_format = 'delta', | ||
| incremental_strategy = 'merge', | ||
| unique_key = ['block_time', 'unique_trade_id'] | ||
| ) | ||
| }} | ||
|
|
||
| WITH element_txs AS ( | ||
| -- polygon ERC721 Sells | ||
| SELECT 'polygon' AS blockchain | ||
| , 'element' AS project | ||
| , 'v1' AS version | ||
| , ee.evt_block_time AS block_time | ||
| , ee.erc721TokenId AS token_id | ||
| , 'erc721' AS token_standard | ||
| , 'Single Item Trade' AS trade_type | ||
| , 1 AS number_of_items | ||
| , 'Offer Accepted' AS trade_category | ||
| , ee.maker AS seller | ||
| , ee.taker AS buyer | ||
| , ee.erc20TokenAmount AS amount_raw | ||
| , CASE WHEN ee.erc20Token='0xeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee' THEN '0x0d500B1d8E8eF31E21C99d1Db9A6444d3ADf1270' | ||
| ELSE ee.erc20Token END AS currency_contract | ||
| , CASE WHEN ee.erc20Token='0xeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee' THEN 'WMATIC' END AS currency_symbol | ||
| , ee.erc721Token AS nft_contract_address | ||
| , ee.contract_address AS project_contract_address | ||
| , ee.evt_tx_hash AS tx_hash | ||
| , ee.evt_block_number AS block_number | ||
| , ee.evt_index | ||
| FROM {{ source('element_ex_polygon','OrdersFeature_evt_ERC721SellOrderFilled') }} ee | ||
| {% if is_incremental() %} | ||
| WHERE ee.evt_block_time >= date_trunc("day", now() - interval '1 week') | ||
| {% endif %} | ||
|
|
||
| UNION ALL | ||
|
|
||
| -- polygon ERC721 Buys | ||
| SELECT 'polygon' AS blockchain | ||
| , 'element' AS project | ||
| , 'v1' AS version | ||
| , ee.evt_block_time AS block_time | ||
| , ee.erc721TokenId AS token_id | ||
| , 'erc721' AS token_standard | ||
| , 'Single Item Trade' AS trade_type | ||
| , 1 AS number_of_items | ||
| , 'Buy' AS trade_category | ||
| , ee.taker AS seller | ||
| , ee.maker AS buyer | ||
| , ee.erc20TokenAmount AS amount_raw | ||
| , CASE WHEN ee.erc20Token='0xeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee' THEN '0x0d500B1d8E8eF31E21C99d1Db9A6444d3ADf1270' | ||
| ELSE ee.erc20Token END AS currency_contract | ||
| , CASE WHEN ee.erc20Token='0xeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee' THEN 'WMATIC' END AS currency_symbol | ||
| , ee.erc721Token AS nft_contract_address | ||
| , ee.contract_address AS project_contract_address | ||
| , ee.evt_tx_hash AS tx_hash | ||
| , ee.evt_block_number AS block_number | ||
| , ee.evt_index | ||
| FROM {{ source('element_ex_polygon','OrdersFeature_evt_ERC721BuyOrderFilled') }} ee | ||
| {% if is_incremental() %} | ||
| WHERE ee.evt_block_time >= date_trunc("day", now() - interval '1 week') | ||
| {% endif %} | ||
|
|
||
| UNION ALL | ||
|
|
||
| -- polygon ERC1155 Sells | ||
| SELECT 'polygon' AS blockchain | ||
| , 'element' AS project | ||
| , 'v1' AS version | ||
| , ee.evt_block_time AS block_time | ||
| , ee.erc1155TokenId AS token_id | ||
| , 'erc1155' AS token_standard | ||
| , 'Single Item Trade' AS trade_type | ||
| , 1 AS number_of_items | ||
| , 'Offer Accepted' AS trade_category | ||
| , ee.maker AS seller | ||
| , ee.taker AS buyer | ||
| , ee.erc20FillAmount AS amount_raw | ||
| , CASE WHEN ee.erc20Token='0xeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee' THEN '0x0d500B1d8E8eF31E21C99d1Db9A6444d3ADf1270' | ||
| ELSE ee.erc20Token END AS currency_contract | ||
| , CASE WHEN ee.erc20Token='0xeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee' THEN 'WMATIC' END AS currency_symbol | ||
| , ee.erc1155Token AS nft_contract_address | ||
| , ee.contract_address AS project_contract_address | ||
| , ee.evt_tx_hash AS tx_hash | ||
| , ee.evt_block_number AS block_number | ||
| , ee.evt_index | ||
| FROM {{ source('element_ex_polygon','OrdersFeature_evt_ERC1155SellOrderFilled') }} ee | ||
| {% if is_incremental() %} | ||
| WHERE ee.evt_block_time >= date_trunc("day", now() - interval '1 week') | ||
| {% endif %} | ||
|
|
||
| UNION ALL | ||
|
|
||
| -- polygon ERC1155 Buys | ||
| SELECT 'polygon' AS blockchain | ||
| , 'element' AS project | ||
| , 'v1' AS version | ||
| , ee.evt_block_time AS block_time | ||
| , ee.erc1155TokenId AS token_id | ||
| , 'erc1155' AS token_standard | ||
| , 'Single Item Trade' AS trade_type | ||
| , 1 AS number_of_items | ||
| , 'Buy' AS trade_category | ||
| , ee.taker AS seller | ||
| , ee.maker AS buyer | ||
| , ee.erc20FillAmount AS amount_raw | ||
| , CASE WHEN ee.erc20Token='0xeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee' THEN '0x0d500B1d8E8eF31E21C99d1Db9A6444d3ADf1270' | ||
| ELSE ee.erc20Token END AS currency_contract | ||
| , CASE WHEN ee.erc20Token='0xeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee' THEN 'WMATIC' END AS currency_symbol | ||
| , ee.erc1155Token AS nft_contract_address | ||
| , ee.contract_address AS project_contract_address | ||
| , ee.evt_tx_hash AS tx_hash | ||
| , ee.evt_block_number AS block_number | ||
| , ee.evt_index | ||
| FROM {{ source('element_ex_polygon','OrdersFeature_evt_ERC1155BuyOrderFilled') }} ee | ||
| {% if is_incremental() %} | ||
| WHERE ee.evt_block_time >= date_trunc("day", now() - interval '1 week') | ||
| {% endif %} | ||
| ) | ||
|
|
||
| SELECT alet.blockchain | ||
| , alet.project | ||
| , alet.version | ||
| , alet.block_time | ||
| , date_trunc('day', alet.block_time) AS block_date | ||
| , alet.token_id | ||
| , polygon_nft_tokens.name AS collection | ||
| , alet.amount_raw/POWER(10, polygon_bep20_tokens.decimals)*prices.price AS amount_usd | ||
| , alet.token_standard | ||
| , CASE WHEN agg.name IS NOT NULL THEN 'Bundle Trade' ELSE 'Single Item Trade' END AS trade_type | ||
| , CAST(alet.number_of_items AS DECIMAL(38,0)) AS number_of_items | ||
| , alet.trade_category | ||
| , 'Trade' AS evt_type | ||
| , alet.seller | ||
| , alet.buyer | ||
| , alet.amount_raw/POWER(10, polygon_bep20_tokens.decimals) AS amount_original | ||
| , CAST(alet.amount_raw AS DECIMAL(38,0)) AS amount_raw | ||
| , COALESCE(alet.currency_symbol, polygon_bep20_tokens.symbol) AS currency_symbol | ||
| , alet.currency_contract | ||
| , alet.nft_contract_address | ||
| , alet.project_contract_address | ||
| , agg.name AS aggregator_name | ||
| , CASE WHEN agg.name IS NOT NULL THEN agg.contract_address END AS aggregator_address | ||
| , alet.tx_hash | ||
| , alet.block_number | ||
| , bt.from AS tx_from | ||
| , bt.to AS tx_to | ||
| , CAST(0 AS DOUBLE) AS platform_fee_amount_raw | ||
| , CAST(0 AS DOUBLE) AS platform_fee_amount | ||
| , CAST(0 AS DOUBLE) AS platform_fee_amount_usd | ||
| , CAST(0 AS DOUBLE) AS platform_fee_percentage | ||
| , CAST(0 AS DOUBLE) AS royalty_fee_amount_raw | ||
| , CAST(0 AS DOUBLE) AS royalty_fee_amount | ||
| , CAST(0 AS DOUBLE) AS royalty_fee_amount_usd | ||
| , CAST(0 AS DOUBLE) AS royalty_fee_percentage | ||
| , CAST('0' AS VARCHAR(5)) AS royalty_fee_receive_address | ||
| , CAST('0' AS VARCHAR(5)) AS royalty_fee_currency_symbol | ||
| , alet.blockchain || alet.project || alet.version || alet.tx_hash || alet.seller || alet.buyer || alet.nft_contract_address || alet.token_id || alet.evt_index AS unique_trade_id | ||
| FROM element_txs alet | ||
| LEFT JOIN {{ ref('nft_aggregators') }} agg ON alet.buyer=agg.contract_address AND agg.blockchain='polygon' | ||
| LEFT JOIN {{ ref('tokens_erc20') }} polygon_bep20_tokens ON polygon_bep20_tokens.contract_address=alet.currency_contract AND polygon_bep20_tokens.blockchain='polygon' | ||
| LEFT JOIN {{ ref('tokens_nft') }} polygon_nft_tokens ON polygon_nft_tokens.contract_address=alet.currency_contract AND polygon_nft_tokens.blockchain='polygon' | ||
| LEFT JOIN {{ source('prices', 'usd') }} prices ON prices.minute=date_trunc('minute', alet.block_time) | ||
| AND (prices.contract_address=alet.currency_contract AND prices.blockchain=alet.blockchain) | ||
| {% if is_incremental() %} | ||
| AND prices.minute >= date_trunc("day", now() - interval '1 week') | ||
| {% endif %} | ||
| LEFT JOIN {{ source('polygon','transactions') }} bt ON bt.hash=alet.tx_hash | ||
| AND bt.block_time=alet.block_time | ||
| {% if is_incremental() %} | ||
| AND bt.block_time >= date_trunc("day", now() - interval '1 week') | ||
| {% endif %} |
Oops, something went wrong.