From f8d7199b9f6cd7da2011e1cd928b3b7f6b8ba2ab Mon Sep 17 00:00:00 2001 From: drethereum Date: Mon, 14 Aug 2023 13:49:33 -0600 Subject: [PATCH] temp files --- macros/python/logs_config_bridges.json | 2 +- .../hop/silver_bridge__hop_transfers_sent.sql | 77 ++++++++++--------- .../silver_bridge__multichain_v6_anycall.sql | 77 ++++++++++--------- .../silver_bridge__multichain_v7_anycall.sql | 77 ++++++++++--------- .../silver_bridge__multichain_v7_swapin.sql | 75 +++++++++--------- .../silver_bridge__multichain_v7_swapout.sql | 75 +++++++++--------- .../stargate/silver_bridge__stargate_swap.sql | 76 +++++++++--------- 7 files changed, 248 insertions(+), 211 deletions(-) diff --git a/macros/python/logs_config_bridges.json b/macros/python/logs_config_bridges.json index 6481ac07..3016faeb 100644 --- a/macros/python/logs_config_bridges.json +++ b/macros/python/logs_config_bridges.json @@ -53,7 +53,7 @@ "name": "multichain_v7_swapout", "contract_address": "0x1633D66Ca91cE4D81F63Ea047B7B19Beb92dF7f3", "topic_0": "0x0d969ae475ff6fcaf0dcfa760d4d8607244e8d95e9bf426f8d5d69f9a3e525af", - "drop": true + "drop": false }, { "blockchain": "optimism", diff --git a/models/silver/bridge/hop/silver_bridge__hop_transfers_sent.sql b/models/silver/bridge/hop/silver_bridge__hop_transfers_sent.sql index 0f8d95b9..8dbe28f9 100644 --- a/models/silver/bridge/hop/silver_bridge__hop_transfers_sent.sql +++ b/models/silver/bridge/hop/silver_bridge__hop_transfers_sent.sql @@ -1,39 +1,46 @@ - - {{ config( +{{ config( materialized = 'incremental', unique_key = '_log_id', tags = ['non_realtime'] - ) }} - - SELECT - block_number, - block_timestamp, - tx_hash, - origin_function_signature, - origin_from_address, - origin_to_address, - contract_address, - 'hop_transfers_sent' AS name, - event_index, - topics[0] :: STRING AS topic_0, - event_name, - decoded_flat:"amount"::INTEGER AS amount, decoded_flat:"amountOutMin"::INTEGER AS amountOutMin, decoded_flat:"bonderFee"::INTEGER AS bonderFee, decoded_flat:"chainId"::INTEGER AS chainId, decoded_flat:"deadline"::INTEGER AS deadline, decoded_flat:"index"::INTEGER AS index, decoded_flat:"recipient"::STRING AS recipient, decoded_flat:"transferId"::STRING AS transferId, decoded_flat:"transferNonce"::STRING AS transferNonce, - decoded_flat, - data, - event_removed, - tx_status, - _log_id, - _inserted_timestamp - FROM - {{ ref('silver__decoded_logs') }} - WHERE - topics[0] :: STRING = '0xe35dddd4ea75d7e9b3fe93af4f4e40e778c3da4074c9d93e7c6536f1e803c1eb' - +) }} - {% if is_incremental() %} - AND _inserted_timestamp >= ( - SELECT MAX(_inserted_timestamp) :: DATE - FROM {{ this }} - ) - {% endif %} - \ No newline at end of file +SELECT + block_number, + block_timestamp, + tx_hash, + origin_function_signature, + origin_from_address, + origin_to_address, + contract_address, + 'hop_transfers_sent' AS NAME, + event_index, + topics [0] :: STRING AS topic_0, + event_name, + decoded_flat :"amount" :: INTEGER AS amount, + decoded_flat :"amountOutMin" :: INTEGER AS amountOutMin, + decoded_flat :"bonderFee" :: INTEGER AS bonderFee, + decoded_flat :"chainId" :: INTEGER AS chainId, + decoded_flat :"deadline" :: INTEGER AS deadline, + decoded_flat :"index" :: INTEGER AS INDEX, + decoded_flat :"recipient" :: STRING AS recipient, + decoded_flat :"transferId" :: STRING AS transferId, + decoded_flat :"transferNonce" :: STRING AS transferNonce, + decoded_flat, + DATA, + event_removed, + tx_status, + _log_id, + _inserted_timestamp +FROM + {{ ref('silver__decoded_logs') }} +WHERE + topics [0] :: STRING = '0xe35dddd4ea75d7e9b3fe93af4f4e40e778c3da4074c9d93e7c6536f1e803c1eb' + +{% if is_incremental() %} +AND _inserted_timestamp >= ( + SELECT + MAX(_inserted_timestamp) :: DATE + FROM + {{ this }} +) +{% endif %} diff --git a/models/silver/bridge/multichain/silver_bridge__multichain_v6_anycall.sql b/models/silver/bridge/multichain/silver_bridge__multichain_v6_anycall.sql index 0e053687..14f22ffd 100644 --- a/models/silver/bridge/multichain/silver_bridge__multichain_v6_anycall.sql +++ b/models/silver/bridge/multichain/silver_bridge__multichain_v6_anycall.sql @@ -1,39 +1,46 @@ - - {{ config( +{{ config( materialized = 'incremental', unique_key = '_log_id', tags = ['non_realtime'] - ) }} - - SELECT - block_number, - block_timestamp, - tx_hash, - origin_function_signature, - origin_from_address, - origin_to_address, - contract_address, - 'multichain_v6_anycall' AS name, - event_index, - topics[0] :: STRING AS topic_0, - event_name, - decoded_flat:"_fallback"::STRING AS _fallback, decoded_flat:"appID"::STRING AS appID, decoded_flat:"data"::STRING AS data, decoded_flat:"flags"::INTEGER AS flags, decoded_flat:"from"::STRING AS from_address, decoded_flat:"nonce"::INTEGER AS nonce, decoded_flat:"to"::STRING AS to_address, decoded_flat:"toChainID"::INTEGER AS toChainID, - decoded_flat, - data, - event_removed, - tx_status, - _log_id, - _inserted_timestamp - FROM - {{ ref('silver__decoded_logs') }} - WHERE - topics[0] :: STRING = '0xa17aef042e1a5dd2b8e68f0d0d92f9a6a0b35dc25be1d12c0cb3135bfd8951c9' - AND contract_address IN ('0xc10ef9f491c9b59f936957026020c321651ac078') +) }} - {% if is_incremental() %} - AND _inserted_timestamp >= ( - SELECT MAX(_inserted_timestamp) :: DATE - FROM {{ this }} - ) - {% endif %} - \ No newline at end of file +SELECT + block_number, + block_timestamp, + tx_hash, + origin_function_signature, + origin_from_address, + origin_to_address, + contract_address, + 'multichain_v6_anycall' AS NAME, + event_index, + topics [0] :: STRING AS topic_0, + event_name, + decoded_flat :"_fallback" :: STRING AS _fallback, + decoded_flat :"appID" :: STRING AS appID, + decoded_flat :"data" :: STRING AS DATA, + decoded_flat :"flags" :: INTEGER AS flags, + decoded_flat :"from" :: STRING AS from_address, + decoded_flat :"nonce" :: INTEGER AS nonce, + decoded_flat :"to" :: STRING AS to_address, + decoded_flat :"toChainID" :: INTEGER AS toChainID, + decoded_flat, + DATA, + event_removed, + tx_status, + _log_id, + _inserted_timestamp +FROM + {{ ref('silver__decoded_logs') }} +WHERE + topics [0] :: STRING = '0xa17aef042e1a5dd2b8e68f0d0d92f9a6a0b35dc25be1d12c0cb3135bfd8951c9' + AND contract_address IN ('0xc10ef9f491c9b59f936957026020c321651ac078') + +{% if is_incremental() %} +AND _inserted_timestamp >= ( + SELECT + MAX(_inserted_timestamp) :: DATE + FROM + {{ this }} +) +{% endif %} diff --git a/models/silver/bridge/multichain/silver_bridge__multichain_v7_anycall.sql b/models/silver/bridge/multichain/silver_bridge__multichain_v7_anycall.sql index 23fb7e86..43c875ca 100644 --- a/models/silver/bridge/multichain/silver_bridge__multichain_v7_anycall.sql +++ b/models/silver/bridge/multichain/silver_bridge__multichain_v7_anycall.sql @@ -1,39 +1,46 @@ - - {{ config( +{{ config( materialized = 'incremental', unique_key = '_log_id', tags = ['non_realtime'] - ) }} - - SELECT - block_number, - block_timestamp, - tx_hash, - origin_function_signature, - origin_from_address, - origin_to_address, - contract_address, - 'multichain_v7_anycall' AS name, - event_index, - topics[0] :: STRING AS topic_0, - event_name, - decoded_flat:"appID"::STRING AS appID, decoded_flat:"data"::STRING AS data, decoded_flat:"extdata"::STRING AS extdata, decoded_flat:"flags"::INTEGER AS flags, decoded_flat:"from"::STRING AS from_address, decoded_flat:"nonce"::INTEGER AS nonce, decoded_flat:"to"::STRING AS to_address, decoded_flat:"toChainID"::INTEGER AS toChainID, - decoded_flat, - data, - event_removed, - tx_status, - _log_id, - _inserted_timestamp - FROM - {{ ref('silver__decoded_logs') }} - WHERE - topics[0] :: STRING = '0x17dac14bf31c4070ebb2dc182fc25ae5df58f14162a7f24a65b103e22385af0d' - AND contract_address IN ('0x8efd012977dd5c97e959b9e48c04ee5fcd604374') +) }} - {% if is_incremental() %} - AND _inserted_timestamp >= ( - SELECT MAX(_inserted_timestamp) :: DATE - FROM {{ this }} - ) - {% endif %} - \ No newline at end of file +SELECT + block_number, + block_timestamp, + tx_hash, + origin_function_signature, + origin_from_address, + origin_to_address, + contract_address, + 'multichain_v7_anycall' AS NAME, + event_index, + topics [0] :: STRING AS topic_0, + event_name, + decoded_flat :"appID" :: STRING AS appID, + decoded_flat :"data" :: STRING AS DATA, + decoded_flat :"extdata" :: STRING AS extdata, + decoded_flat :"flags" :: INTEGER AS flags, + decoded_flat :"from" :: STRING AS from_address, + decoded_flat :"nonce" :: INTEGER AS nonce, + decoded_flat :"to" :: STRING AS to_address, + decoded_flat :"toChainID" :: INTEGER AS toChainID, + decoded_flat, + DATA, + event_removed, + tx_status, + _log_id, + _inserted_timestamp +FROM + {{ ref('silver__decoded_logs') }} +WHERE + topics [0] :: STRING = '0x17dac14bf31c4070ebb2dc182fc25ae5df58f14162a7f24a65b103e22385af0d' + AND contract_address IN ('0x8efd012977dd5c97e959b9e48c04ee5fcd604374') + +{% if is_incremental() %} +AND _inserted_timestamp >= ( + SELECT + MAX(_inserted_timestamp) :: DATE + FROM + {{ this }} +) +{% endif %} diff --git a/models/silver/bridge/multichain/silver_bridge__multichain_v7_swapin.sql b/models/silver/bridge/multichain/silver_bridge__multichain_v7_swapin.sql index 6dbed810..23ad32fe 100644 --- a/models/silver/bridge/multichain/silver_bridge__multichain_v7_swapin.sql +++ b/models/silver/bridge/multichain/silver_bridge__multichain_v7_swapin.sql @@ -1,39 +1,44 @@ - - {{ config( +{{ config( materialized = 'incremental', unique_key = '_log_id', tags = ['non_realtime'] - ) }} - - SELECT - block_number, - block_timestamp, - tx_hash, - origin_function_signature, - origin_from_address, - origin_to_address, - contract_address, - 'multichain_v7_swapin' AS name, - event_index, - topics[0] :: STRING AS topic_0, - event_name, - decoded_flat:"amount"::INTEGER AS amount, decoded_flat:"fromChainID"::INTEGER AS fromChainID, decoded_flat:"receiver"::STRING AS receiver, decoded_flat:"swapID"::STRING AS swapID, decoded_flat:"swapoutID"::STRING AS swapoutID, decoded_flat:"token"::STRING AS token, - decoded_flat, - data, - event_removed, - tx_status, - _log_id, - _inserted_timestamp - FROM - {{ ref('silver__decoded_logs') }} - WHERE - topics[0] :: STRING = '0x164f647883b52834be7a5219336e455a23a358be27519d0442fc0ee5e1b1ce2e' - AND contract_address IN ('0x1633d66ca91ce4d81f63ea047b7b19beb92df7f3') +) }} - {% if is_incremental() %} - AND _inserted_timestamp >= ( - SELECT MAX(_inserted_timestamp) :: DATE - FROM {{ this }} - ) - {% endif %} - \ No newline at end of file +SELECT + block_number, + block_timestamp, + tx_hash, + origin_function_signature, + origin_from_address, + origin_to_address, + contract_address, + 'multichain_v7_swapin' AS NAME, + event_index, + topics [0] :: STRING AS topic_0, + event_name, + decoded_flat :"amount" :: INTEGER AS amount, + decoded_flat :"fromChainID" :: INTEGER AS fromChainID, + decoded_flat :"receiver" :: STRING AS receiver, + decoded_flat :"swapID" :: STRING AS swapID, + decoded_flat :"swapoutID" :: STRING AS swapoutID, + decoded_flat :"token" :: STRING AS token, + decoded_flat, + DATA, + event_removed, + tx_status, + _log_id, + _inserted_timestamp +FROM + {{ ref('silver__decoded_logs') }} +WHERE + topics [0] :: STRING = '0x164f647883b52834be7a5219336e455a23a358be27519d0442fc0ee5e1b1ce2e' + AND contract_address IN ('0x1633d66ca91ce4d81f63ea047b7b19beb92df7f3') + +{% if is_incremental() %} +AND _inserted_timestamp >= ( + SELECT + MAX(_inserted_timestamp) :: DATE + FROM + {{ this }} +) +{% endif %} diff --git a/models/silver/bridge/multichain/silver_bridge__multichain_v7_swapout.sql b/models/silver/bridge/multichain/silver_bridge__multichain_v7_swapout.sql index 5cfa3f40..9cecfeea 100644 --- a/models/silver/bridge/multichain/silver_bridge__multichain_v7_swapout.sql +++ b/models/silver/bridge/multichain/silver_bridge__multichain_v7_swapout.sql @@ -1,39 +1,44 @@ - - {{ config( +{{ config( materialized = 'incremental', unique_key = '_log_id', tags = ['non_realtime'] - ) }} - - SELECT - block_number, - block_timestamp, - tx_hash, - origin_function_signature, - origin_from_address, - origin_to_address, - contract_address, - 'multichain_v7_swapout' AS name, - event_index, - topics[0] :: STRING AS topic_0, - event_name, - decoded_flat:"amount"::INTEGER AS amount, decoded_flat:"from"::STRING AS from_address, decoded_flat:"receiver"::STRING AS receiver, decoded_flat:"swapoutID"::STRING AS swapoutID, decoded_flat:"toChainID"::INTEGER AS toChainID, decoded_flat:"token"::STRING AS token, - decoded_flat, - data, - event_removed, - tx_status, - _log_id, - _inserted_timestamp - FROM - {{ ref('silver__decoded_logs') }} - WHERE - topics[0] :: STRING = '0x0d969ae475ff6fcaf0dcfa760d4d8607244e8d95e9bf426f8d5d69f9a3e525af' - AND contract_address IN ('0x1633d66ca91ce4d81f63ea047b7b19beb92df7f3') +) }} - {% if is_incremental() %} - AND _inserted_timestamp >= ( - SELECT MAX(_inserted_timestamp) :: DATE - FROM {{ this }} - ) - {% endif %} - \ No newline at end of file +SELECT + block_number, + block_timestamp, + tx_hash, + origin_function_signature, + origin_from_address, + origin_to_address, + contract_address, + 'multichain_v7_swapout' AS NAME, + event_index, + topics [0] :: STRING AS topic_0, + event_name, + decoded_flat :"amount" :: INTEGER AS amount, + decoded_flat :"from" :: STRING AS from_address, + decoded_flat :"receiver" :: STRING AS receiver, + decoded_flat :"swapoutID" :: STRING AS swapoutID, + decoded_flat :"toChainID" :: INTEGER AS toChainID, + decoded_flat :"token" :: STRING AS token, + decoded_flat, + DATA, + event_removed, + tx_status, + _log_id, + _inserted_timestamp +FROM + {{ ref('silver__decoded_logs') }} +WHERE + topics [0] :: STRING = '0x0d969ae475ff6fcaf0dcfa760d4d8607244e8d95e9bf426f8d5d69f9a3e525af' + AND contract_address IN ('0x1633d66ca91ce4d81f63ea047b7b19beb92df7f3') + +{% if is_incremental() %} +AND _inserted_timestamp >= ( + SELECT + MAX(_inserted_timestamp) :: DATE + FROM + {{ this }} +) +{% endif %} diff --git a/models/silver/bridge/stargate/silver_bridge__stargate_swap.sql b/models/silver/bridge/stargate/silver_bridge__stargate_swap.sql index e96b36e7..781db4b4 100644 --- a/models/silver/bridge/stargate/silver_bridge__stargate_swap.sql +++ b/models/silver/bridge/stargate/silver_bridge__stargate_swap.sql @@ -1,39 +1,45 @@ - - {{ config( +{{ config( materialized = 'incremental', unique_key = '_log_id', tags = ['non_realtime'] - ) }} - - SELECT - block_number, - block_timestamp, - tx_hash, - origin_function_signature, - origin_from_address, - origin_to_address, - contract_address, - 'stargate_swap' AS name, - event_index, - topics[0] :: STRING AS topic_0, - event_name, - decoded_flat:"amountSD"::INTEGER AS amountSD, decoded_flat:"chainId"::INTEGER AS chainId, decoded_flat:"dstPoolId"::INTEGER AS dstPoolId, decoded_flat:"eqFee"::INTEGER AS eqFee, decoded_flat:"eqReward"::INTEGER AS eqReward, decoded_flat:"from"::STRING AS from_address, decoded_flat:"lpFee"::INTEGER AS lpFee, decoded_flat:"protocolFee"::INTEGER AS protocolFee, - decoded_flat, - data, - event_removed, - tx_status, - _log_id, - _inserted_timestamp - FROM - {{ ref('silver__decoded_logs') }} - WHERE - topics[0] :: STRING = '0x34660fc8af304464529f48a778e03d03e4d34bcd5f9b6f0cfbf3cd238c642f7f' - +) }} - {% if is_incremental() %} - AND _inserted_timestamp >= ( - SELECT MAX(_inserted_timestamp) :: DATE - FROM {{ this }} - ) - {% endif %} - \ No newline at end of file +SELECT + block_number, + block_timestamp, + tx_hash, + origin_function_signature, + origin_from_address, + origin_to_address, + contract_address, + 'stargate_swap' AS NAME, + event_index, + topics [0] :: STRING AS topic_0, + event_name, + decoded_flat :"amountSD" :: INTEGER AS amountSD, + decoded_flat :"chainId" :: INTEGER AS chainId, + decoded_flat :"dstPoolId" :: INTEGER AS dstPoolId, + decoded_flat :"eqFee" :: INTEGER AS eqFee, + decoded_flat :"eqReward" :: INTEGER AS eqReward, + decoded_flat :"from" :: STRING AS from_address, + decoded_flat :"lpFee" :: INTEGER AS lpFee, + decoded_flat :"protocolFee" :: INTEGER AS protocolFee, + decoded_flat, + DATA, + event_removed, + tx_status, + _log_id, + _inserted_timestamp +FROM + {{ ref('silver__decoded_logs') }} +WHERE + topics [0] :: STRING = '0x34660fc8af304464529f48a778e03d03e4d34bcd5f9b6f0cfbf3cd238c642f7f' + +{% if is_incremental() %} +AND _inserted_timestamp >= ( + SELECT + MAX(_inserted_timestamp) :: DATE + FROM + {{ this }} +) +{% endif %}