An 2321/migrating defi models from flipsideproddb (#63)

* new models moved plus docs

* catalog

* changing reference to harmony sushi

models/defi/defi__ez_borrowing.sql

@@ -0,0 +1,174 @@
+{{ config(
+    materialized = 'view',
+    tags = ['snowflake', 'crosschain','borrowing'],
+    persist_docs ={ "relation": true,
+    "columns": true }
+) }}
+
+-- Ethereum/sushi
+select
+    block_timestamp,
+    block_number,
+    tx_hash,
+    action,
+    'ethereum' as blockchain,
+    'sushi' as platform,
+    origin_from_address,
+    origin_to_address,
+    origin_function_signature,
+    asset,
+    borrower,
+    borrower_is_a_contract,
+    lending_pool_address,
+    amount,
+    amount_usd,
+    lending_pool,
+    symbol,
+    _log_id
+
+from
+    {{ source(
+        'ethereum_db_sushi',
+        'ez_borrowing'
+    ) }} 
+
+union all
+
+-- polygon/sushi
+select
+    block_timestamp,
+    block_number,
+    tx_hash,
+    action,
+    'polygon' as blockchain,
+    'sushi' as platform,
+    origin_from_address,
+    origin_to_address,
+    origin_function_signature,
+    asset,
+    borrower,
+    borrower_is_a_contract,
+    lending_pool_address,
+    amount,
+    amount_usd, 
+    lending_pool,
+    symbol,
+    _log_id
+from
+    {{ source(
+        'polygon',
+        'EZ_BORROWING'
+    ) }} 
+
+union all
+
+-- arbitrum/sushi
+select
+    block_timestamp,
+    block_number,
+    tx_hash,
+    action,
+    'arbitrum' as blockchain,
+    'sushi' as platform,
+    origin_from_address,
+    origin_to_address,
+    origin_function_signature,
+    asset,
+    borrower,
+    borrower_is_a_contract,
+    lending_pool_address,
+    amount,
+    amount_usd,
+    lending_pool,
+    symbol,
+    _log_id
+from
+    {{ source(
+        'Arbitrum',
+        'EZ_BORROWING'
+    ) }} 
+
+
+union all
+
+-- avalanche/sushi
+select
+    block_timestamp,
+    block_number,
+    tx_hash,
+    action,
+    'avalanche' as blockchain,
+    'sushi' as platform,
+    origin_from_address,
+    origin_to_address,
+    origin_function_signature,
+    asset,
+    borrower,
+    borrower_is_a_contract,
+    lending_pool_address,
+    amount,
+    amount_usd,
+    lending_pool,
+    symbol,
+    _log_id
+from
+    {{ source(
+        'Avalanche',
+        'EZ_BORROWING'
+    ) }} 
+
+union all
+
+-- Gnosis/sushi
+select
+    block_timestamp,
+    block_number,
+    tx_hash,
+    action,
+    'gnosis' as blockchain,
+    'sushi' as platform,
+    origin_from_address,
+    origin_to_address,
+    origin_function_signature,
+    asset,
+    borrower,
+    borrower_is_a_contract,
+    lending_pool_address,
+    amount,
+    amount_usd,
+    lending_pool,
+    symbol,
+    _log_id
+from
+    {{ source(
+        'Gnosis',
+        'EZ_BORROWING'
+    ) }} 
+
+union all
+
+-- bsc/sushi
+select
+    block_timestamp,
+    block_number,
+    tx_hash,
+    action,
+    'BSC' as blockchain,
+    'sushi' as platform,
+    origin_from_address,
+    origin_to_address,
+    origin_function_signature,
+    asset,
+    borrower,
+    borrower_is_a_contract,
+    lending_pool_address,
+    amount,
+    amount_usd,
+    lending_pool,
+    symbol,
+    _log_id
+from
+    {{ source(
+        'BSC',
+        'EZ_BORROWING'
+    ) }} 

models/defi/defi__ez_borrowing.yml

@@ -0,0 +1,108 @@
+version: 2
+models:
+  - name: defi__ez_borrowing
+    description: 'This is a table that shows all the events across various blockchains and various platforms that are related to Borrowing or repaying the loan'
+
+    tests:
+      - dbt_utils.unique_combination_of_columns:
+          combination_of_columns:
+            - _LOG_ID
+    columns:
+      - name: BLOCK_NUMBER
+        description: '{{ doc("cross_chain_block_number") }}'
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_be_in_type_list:
+              column_type_list:
+                - NUMBER
+                - FLOAT
+      - name: BLOCK_TIMESTAMP
+        description: '{{ doc("cross_chain_block_timestamp") }}'
+        tests:
+          - not_null
+          - dbt_expectations.expect_row_values_to_have_recent_data:
+              datepart: day
+              interval: 3
+          - dbt_expectations.expect_column_values_to_be_in_type_list:
+              column_type_list:
+                - TIMESTAMP_NTZ
+      - name: TX_HASH
+        description: '{{ doc("cross_chain_tx_hash") }}'
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_match_regex:
+              regex: 0[xX][0-9a-fA-F]+
+      - name: LENDING_POOL_ADDRESS
+        description: '{{ doc("cross_chain_lending_pool_address") }}'
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_match_regex:
+              regex: 0[xX][0-9a-fA-F]+
+
+      - name: LENDING_POOL
+        description: '{{ doc("cross_chain_lending_lending_pool") }}'
+        tests:
+          - not_null
+
+      - name: BORROWER_IS_A_CONTRACT
+        description: '{{ doc("crosschain_lending_borrower_is_a_contract") }}'
+        tests:
+          - not_null
+
+      - name: AMOUNT
+        description: '{{ doc("crosschain_borrow_amount") }}'
+        tests:
+          - dbt_expectations.expect_column_values_to_be_in_type_list:
+              column_type_list:
+                - NUMBER
+                - FLOAT
+      - name: AMOUNT_USD
+        description: '{{ doc("crosschain_borrow_amount_usd") }}'
+        tests:
+          - dbt_expectations.expect_column_values_to_be_in_type_list:
+              column_type_list:
+                - NUMBER
+                - FLOAT
+
+      - name: SYMBOL
+        description: '{{ doc("crosschain_borrow_symbol") }}'
+        tests:
+          - dbt_expectations.expect_column_values_to_be_in_type_list:
+              column_type_list:
+                - STRING
+                - VARCHAR
+    
+      - name: ACTION
+        description: '{{ doc("crosschain_borrow_action") }}'
+
+
+      - name: BORROWER
+        description: '{{ doc("crosschain_borrower") }}'
+        tests:
+          - not_null:
+              where: BLOCK_TIMESTAMP > '2021-08-01'
+          - dbt_expectations.expect_column_values_to_match_regex:
+              regex: 0[xX][0-9a-fA-F]+
+     
+      - name: PLATFORM
+        description: '{{ doc("cross_chain_swap_platform") }}'
+        tests:
+          - dbt_expectations.expect_column_values_to_be_in_type_list:
+              column_type_list:
+                - STRING
+                - VARCHAR
+      - name: _LOG_ID
+        description: '{{ doc("cross_chain_event_log_id") }}'
+        tests:
+          - not_null
+      - name: ORIGIN_FROM_ADDRESS
+        description: '{{ doc("crosschain_lending_origin_from_address") }}'
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_match_regex:
+              regex: 0[xX][0-9a-fA-F]+
+      - name: ORIGIN_TO_ADDRESS
+        description: '{{ doc("crosschain_lending_origin_to_address") }}'
+        tests:
+          - dbt_expectations.expect_column_values_to_match_regex:
+              regex: 0[xX][0-9a-fA-F]+

models/defi/defi__ez_lending.sql

@@ -0,0 +1,178 @@
+{{ config(
+    materialized = 'view',
+    tags = ['snowflake', 'crosschain','lending'],
+    persist_docs ={ "relation": true,
+    "columns": true }
+) }}
+
+-- Ethereum/sushi
+select
+    block_timestamp,
+    block_number,
+    tx_hash,
+    action,
+    'ethereum' as blockchain,
+    'sushi' as platform,
+    origin_from_address,
+    origin_to_address,
+    origin_function_signature,
+    asset,
+    depositor,
+    lender_is_a_contract,
+    lending_pool_address,
+    amount as asset_amount,
+    amount_usd as asset_amount_usd,
+    lending_pool,
+    symbol,
+    _log_id
+
+from
+    {{ source(
+        'ethereum_db_sushi',
+        'ez_lending'
+    ) }} 
+
+union all
+
+-- polygon/sushi
+select
+    block_timestamp,
+    block_number,
+    tx_hash,
+    action,
+    'polygon' as blockchain,
+    'sushi' as platform,
+    origin_from_address,
+    origin_to_address,
+    origin_function_signature,
+    asset,
+    depositor,
+    lender_is_a_contract,
+    lending_pool_address,
+    amount as asset_amount,
+    amount_usd as asset_amount_usd,
+    lending_pool,
+    symbol,
+    _log_id
+
+from
+    {{ source(
+        'polygon',
+        'EZ_LENDING'
+    ) }} 
+
+union all
+
+-- Arbitrum/sushi
+select
+    block_timestamp,
+    block_number,
+    tx_hash,
+    action,
+    'arbitrum' as blockchain,
+    'sushi' as platform,
+    origin_from_address,
+    origin_to_address,
+    origin_function_signature,
+    asset,
+    depositor,
+    lender_is_a_contract,
+    lending_pool_address,
+    asset_amount,
+    asset_amount_usd,
+    lending_pool,
+    symbol,
+    _log_id
+
+from
+    {{ source(
+        'Arbitrum',
+        'EZ_LENDING'
+    ) }} 
+
+union all
+
+-- Avalanche/sushi
+select
+    block_timestamp,
+    block_number,
+    tx_hash,
+    action,
+    'avalanche' as blockchain,
+    'sushi' as platform,
+    origin_from_address,
+    origin_to_address,
+    origin_function_signature,
+    asset,
+    depositor,
+    lender_is_a_contract,
+    lending_pool_address,
+    asset_amount,
+    asset_amount_usd,
+    lending_pool,
+    symbol,
+    _log_id
+
+from
+    {{ source(
+        'Avalanche',
+        'EZ_LENDING'
+    ) }} 
+
+union all
+
+-- BSC/sushi
+select
+    block_timestamp,
+    block_number,
+    tx_hash,
+    action,
+    'BSC' as blockchain,
+    'sushi' as platform,
+    origin_from_address,
+    origin_to_address,
+    origin_function_signature,
+    asset,
+    depositor,
+    lender_is_a_contract,
+    lending_pool_address,
+    asset_amount,
+    asset_amount_usd,
+    lending_pool,
+    symbol,
+    _log_id
+
+from
+    {{ source(
+        'BSC',
+        'EZ_LENDING'
+    ) }} 
+
+union all
+
+-- Gnosis/sushi
+select
+    block_timestamp,
+    block_number,
+    tx_hash,
+    action,
+    'gnosis' as blockchain,
+    'sushi' as platform,
+    origin_from_address,
+    origin_to_address,
+    origin_function_signature,
+    asset,
+    depositor,
+    lender_is_a_contract,
+    lending_pool_address,
+    asset_amount,
+    asset_amount_usd,
+    lending_pool,
+    symbol,
+    _log_id
+
+from
+    {{ source(
+        'Gnosis',
+        'EZ_LENDING'
+    ) }} 

models/defi/defi__ez_lending.yml

@@ -0,0 +1,115 @@
+version: 2
+models:
+  - name: defi__ez_lending
+    description: This is a table that shows all the events across various blockchains and various platforms that are related to providing capital for lending and withdrawing capital
+
+
+    tests:
+      - dbt_utils.unique_combination_of_columns:
+          combination_of_columns:
+            - _LOG_ID
+    columns:
+      - name: BLOCK_NUMBER
+        description: '{{ doc("cross_chain_block_number") }}'
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_be_in_type_list:
+              column_type_list:
+                - NUMBER
+                - FLOAT
+      - name: BLOCK_TIMESTAMP
+        description: '{{ doc("cross_chain_block_timestamp") }}'
+        tests:
+          - not_null
+          - dbt_expectations.expect_row_values_to_have_recent_data:
+              datepart: day
+              interval: 3
+          - dbt_expectations.expect_column_values_to_be_in_type_list:
+              column_type_list:
+                - TIMESTAMP_NTZ
+      - name: TX_HASH
+        description: '{{ doc("cross_chain_tx_hash") }}'
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_match_regex:
+              regex: 0[xX][0-9a-fA-F]+
+      - name: LENDING_POOL_ADDRESS
+        description: '{{ doc("cross_chain_lending_pool_address") }}'
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_match_regex:
+              regex: 0[xX][0-9a-fA-F]+
+
+      - name: LENDING_POOL
+        description: '{{ doc("cross_chain_lending_lending_pool") }}'
+        tests:
+          - not_null
+
+      - name: LENDER_IS_A_CONTRACT
+        description: '{{ doc("cross_chain_lending_lender_is_a_contract") }}'
+        tests:
+          - not_null
+
+      - name: AMOUNT
+        description: '{{ doc("cross_chain_lending_amount") }}'
+        tests:
+          - dbt_expectations.expect_column_values_to_be_in_type_list:
+              column_type_list:
+                - NUMBER
+                - FLOAT
+      - name: AMOUNT_USD
+        description: '{{ doc("cross_chain_lending_amount_usd") }}'
+        tests:
+          - dbt_expectations.expect_column_values_to_be_in_type_list:
+              column_type_list:
+                - NUMBER
+                - FLOAT
+
+      - name: SYMBOL
+        description: '{{ doc("cross_chain_lending_symbol") }}'
+        tests:
+          - dbt_expectations.expect_column_values_to_be_in_type_list:
+              column_type_list:
+                - STRING
+                - VARCHAR
+      - name: ACTION
+        description: '{{ doc("crosschain_action") }}'
+
+      - name: DEPOSITOR
+        description: '{{ doc("cross_chain_lending_depositor") }}'
+        tests:
+          - not_null:
+              where: BLOCK_TIMESTAMP > '2021-08-01'
+          - dbt_expectations.expect_column_values_to_match_regex:
+              regex: 0[xX][0-9a-fA-F]+
+     
+      - name: PLATFORM
+        description: '{{ doc("cross_chain_swap_platform") }}'
+        tests:
+          - dbt_expectations.expect_column_values_to_be_in_type_list:
+              column_type_list:
+                - STRING
+                - VARCHAR
+
+      - name: EVENT_INDEX
+        description: '{{ doc("cross_chain_event_index") }}'
+        tests:
+          - dbt_expectations.expect_column_values_to_be_in_type_list:
+              column_type_list:
+                - NUMBER
+                - FLOAT
+      - name: _LOG_ID
+        description: '{{ doc("cross_chain_event_log_id") }}'
+        tests:
+          - not_null
+      - name: ORIGIN_FROM_ADDRESS
+        description: '{{ doc("crosschain_lending_origin_from_address") }}'
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_match_regex:
+              regex: 0[xX][0-9a-fA-F]+
+      - name: ORIGIN_TO_ADDRESS
+        description: '{{ doc("crosschain_lending_origin_to_address") }}'
+        tests:
+          - dbt_expectations.expect_column_values_to_match_regex:
+              regex: 0[xX][0-9a-fA-F]+

models/defi/defi__ez_swaps.sql

@@ -0,0 +1,256 @@
+{{ config(
+    materialized = 'view',
+    tags = ['snowflake', 'crosschain','swaps'],
+    persist_docs ={ "relation": true,
+    "columns": true }
+) }}
+
+-- Harmony/sushi
+SELECT
+    'Harmony' as Blockchain,
+    Block_timestamp,
+    Block_number,
+    Tx_hash,
+    evm_origin_from_address as origin_from_address,
+    evm_origin_to_address as origin_to_address,
+    Pool_address,
+    Platform,
+    Event_index,
+    Amount_in,
+    Amount_out,
+    Sender,
+    Log_id,
+    Token_in,
+    Token_out,
+    Symbol_in,
+    Symbol_out,
+    Tx_to,
+    Amount_in_USD,
+    Amount_out_USD,
+    (Symbol_in || '-' || Symbol_out || ' SLP') as Pool_name
+
+FROM
+    {{ source(
+        'Harmony_db',
+        'EZ_SUSHI_SWAPS'
+    ) }} 
+
+Union all
+
+
+--  Ethereum/All dex
+SELECT
+    'Ethereum' as Blockchain,
+    Block_timestamp,
+    Block_number,
+    Tx_hash,
+    origin_from_address,
+    origin_to_address,
+    contract_address as Pool_address,
+    Platform,
+    Event_index,
+    Amount_in,
+    Amount_out,
+    Sender,
+    _Log_id as Log_id,
+    Token_in,
+    Token_out,
+    Symbol_in,
+    Symbol_out,
+    Tx_to,
+    Amount_in_USD,
+    Amount_out_USD,
+    Pool_name
+FROM
+    {{ source(
+        'ethereum_core',
+        'ez_dex_swaps'
+    ) }}
+
+Union all
+
+
+--  polygon/sushi
+SELECT
+    'Polygon' as Blockchain,
+    Block_timestamp,
+    Block_number,
+    Tx_hash,
+    origin_from_address,
+    origin_to_address,
+    contract_address as Pool_address,
+    Platform,
+    Event_index,
+    Amount_in,
+    Amount_out,
+    Sender,
+    _Log_id as Log_id,
+    Token_in,
+    Token_out,
+    Symbol_in,
+    Symbol_out,
+    Tx_to,
+    Amount_in_USD,
+    Amount_out_USD,
+    Pool_name
+FROM
+    {{ source(
+        'polygon',
+        'EZ_SWAPS'
+    ) }}
+
+Union all
+
+--  Arbitrum/sushi
+SELECT
+    'Arbitrum' as Blockchain,
+    Block_timestamp,
+    Block_number,
+    Tx_hash,
+    origin_from_address,
+    origin_to_address,
+    contract_address as Pool_address,
+    Platform,
+    Event_index,
+    Amount_in,
+    Amount_out,
+    Sender,
+    _Log_id as Log_id,
+    Token_in,
+    Token_out,
+    Symbol_in,
+    Symbol_out,
+    Tx_to,
+    Amount_in_USD,
+    Amount_out_USD,
+    Pool_name
+FROM
+    {{ source(
+        'Arbitrum',
+        'EZ_SWAPS'
+    ) }}
+
+
+    Union all
+
+--  Avalanche/sushi
+SELECT
+    'Avalanche' as Blockchain,
+    Block_timestamp,
+    Block_number,
+    Tx_hash,
+    origin_from_address,
+    origin_to_address,
+    contract_address as Pool_address,
+    Platform,
+    Event_index,
+    Amount_in,
+    Amount_out,
+    Sender,
+    _Log_id as Log_id,
+    Token_in,
+    Token_out,
+    Symbol_in,
+    Symbol_out,
+    Tx_to,
+    Amount_in_USD,
+    Amount_out_USD,
+    Pool_name
+FROM
+    {{ source(
+        'Avalanche',
+        'EZ_SWAPS'
+    ) }}
+
+    Union all
+
+--  Optimism/sushi
+SELECT
+    'Optimism' as Blockchain,
+    Block_timestamp,
+    Block_number,
+    Tx_hash,
+    origin_from_address,
+    origin_to_address,
+    contract_address as Pool_address,
+    Platform,
+    Event_index,
+    Amount_in,
+    Amount_out,
+    'Nan' as Sender,
+    _Log_id as Log_id,
+    Token_in,
+    Token_out,
+    Symbol_in,
+    Symbol_out,
+    Tx_to,
+    Amount_in_USD,
+    Amount_out_USD,
+    Pool_name
+FROM
+    {{ source(
+        'Optimism',
+        'EZ_SWAPS'
+    ) }}
+
+    Union all
+
+--  BSC/sushi 
+SELECT
+    'BSC' as Blockchain,
+    Block_timestamp,
+    Block_number,
+    Tx_hash,
+    origin_from_address,
+    origin_to_address,
+    contract_address as Pool_address,
+    Platform,
+    Event_index,
+    Amount_in,
+    Amount_out,
+    Sender,
+    _Log_id as Log_id,
+    Token_in,
+    Token_out,
+    Symbol_in,
+    Symbol_out,
+    Tx_to,
+    Amount_in_USD,
+    Amount_out_USD,
+    Pool_name
+FROM
+    {{ source(
+        'BSC',
+        'EZ_SWAPS'
+    ) }}
+
+    Union all
+
+--  Gnosis/sushi 
+SELECT
+    'Gnosis' as Blockchain,
+    Block_timestamp,
+    Block_number,
+    Tx_hash,
+    origin_from_address,
+    origin_to_address,
+    contract_address as Pool_address,
+    Platform,
+    Event_index,
+    Amount_in,
+    Amount_out,
+    Sender,
+    _Log_id as Log_id,
+    Token_in,
+    Token_out,
+    Symbol_in,
+    Symbol_out,
+    Tx_to,
+    Amount_in_USD,
+    Amount_out_USD,
+    Pool_name
+FROM
+    {{ source(
+        'Gnosis',
+        'EZ_SWAPS'
+    ) }}

models/defi/defi__ez_swaps.yml

@@ -0,0 +1,134 @@
+version: 2
+models:
+  - name: defi__ez_swaps
+    description: This table aggregates all swap transactions that happen within a chain from various decentralized exchange protocols such as Uniswap, sushiswap, etc.
+    tests:
+      - dbt_utils.unique_combination_of_columns:
+          combination_of_columns:
+            - LOG_ID
+    columns:
+      - name: BLOCK_NUMBER
+        description: '{{ doc("cross_chain_block_number") }}'
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_be_in_type_list:
+              column_type_list:
+                - NUMBER
+                - FLOAT
+      - name: BLOCK_TIMESTAMP
+        description: '{{ doc("cross_chain_block_timestamp") }}'
+        tests:
+          - not_null
+          - dbt_expectations.expect_row_values_to_have_recent_data:
+              datepart: day
+              interval: 1
+          - dbt_expectations.expect_column_values_to_be_in_type_list:
+              column_type_list:
+                - TIMESTAMP_NTZ
+      - name: TX_HASH
+        description: '{{ doc("cross_chain_tx_hash") }}'
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_match_regex:
+              regex: 0[xX][0-9a-fA-F]+
+      - name: POOL_ADDRESS
+        description: '{{ doc("cross_chain_swap_pool_address") }}'
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_match_regex:
+              regex: 0[xX][0-9a-fA-F]+
+      - name: AMOUNT_IN
+        description: '{{ doc("cross_chain_swap_amount_in") }}'
+        tests:
+          - dbt_expectations.expect_column_values_to_be_in_type_list:
+              column_type_list:
+                - NUMBER
+                - FLOAT
+      - name: AMOUNT_OUT
+        description: '{{ doc("cross_chain_swap_amount_out") }}'
+        tests:
+          - dbt_expectations.expect_column_values_to_be_in_type_list:
+              column_type_list:
+                - NUMBER
+                - FLOAT
+      - name: AMOUNT_IN_USD
+        description: '{{ doc("cross_chain_swap_amount_in_usd") }}'
+        tests:
+          - dbt_expectations.expect_column_values_to_be_in_type_list:
+              column_type_list:
+                - NUMBER
+                - FLOAT
+      - name: AMOUNT_OUT_USD
+        description: '{{ doc("cross_chain_swap_amount_out_usd") }}'
+        tests:
+          - dbt_expectations.expect_column_values_to_be_in_type_list:
+              column_type_list:
+                - NUMBER
+                - FLOAT
+      - name: TOKEN_IN
+        description: '{{ doc("cross_chain_swap_token_in") }}'
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_match_regex:
+              regex: 0[xX][0-9a-fA-F]+
+      - name: TOKEN_OUT
+        description: '{{ doc("cross_chain_swap_token_out") }}'
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_match_regex:
+              regex: 0[xX][0-9a-fA-F]+
+      - name: SYMBOL_IN
+        description: '{{ doc("cross_chain_swap_symbol_in") }}'
+        tests:
+          - dbt_expectations.expect_column_values_to_be_in_type_list:
+              column_type_list:
+                - STRING
+                - VARCHAR
+      - name: SYMBOL_OUT
+        description: '{{ doc("cross_chain_swap_symbol_out") }}'
+        tests:
+          - dbt_expectations.expect_column_values_to_be_in_type_list:
+              column_type_list:
+                - STRING
+                - VARCHAR
+      - name: SENDER
+        description: '{{ doc("cross_chain_swap_sender") }}'
+        tests:
+          - not_null:
+              where: BLOCK_TIMESTAMP > '2021-08-01'
+
+      - name: TX_TO
+        description: '{{ doc("cross_chain_swap_tx_to") }}'
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_match_regex:
+              regex: 0[xX][0-9a-fA-F]+
+      - name: PLATFORM
+        description: '{{ doc("cross_chain_swap_platform") }}'
+        tests:
+          - dbt_expectations.expect_column_values_to_be_in_type_list:
+              column_type_list:
+                - STRING
+                - VARCHAR
+      - name: EVENT_INDEX
+        description: '{{ doc("cross_chain_event_index") }}'
+        tests:
+          - dbt_expectations.expect_column_values_to_be_in_type_list:
+              column_type_list:
+                - NUMBER
+                - FLOAT
+      - name: LOG_ID
+        description: '{{ doc("cross_chain_event_log_id") }}'
+        tests:
+          - not_null
+      - name: ORIGIN_FROM_ADDRESS
+        description: '{{ doc("origin_from_address") }}'
+        tests:
+          - not_null
+          - dbt_expectations.expect_column_values_to_match_regex:
+              regex: 0[xX][0-9a-fA-F]+
+      - name: ORIGIN_TO_ADDRESS
+        description: '{{ doc("origin_to_address") }}'
+        tests:
+          - dbt_expectations.expect_column_values_to_match_regex:
+              regex: 0[xX][0-9a-fA-F]+

models/docs/Block_number.md

@@ -0,0 +1,5 @@
+{% docs cross_chain_block_number %}
+
+The block number at which the transaction is finalized.
+
+{% enddocs %}

models/docs/Block_timestamp_UTC.md

@@ -0,0 +1,5 @@
+{% docs cross_chain_block_timestamp %}
+
+The block timestamp of this transaction in UTC
+
+{% enddocs %}

models/docs/Event_Log_id.md

@@ -0,0 +1,5 @@
+{% docs cross_chain_event_log_id %}
+
+This is the primary key for this table. This is a concatenation of the transaction hash and the event index at which the event occurred. This field can be used within other event based tables such as ```fact_transfers``` & ```ez_token_transfers```.
+
+{% enddocs %}

models/docs/Event_index.md

@@ -0,0 +1,5 @@
+{% docs cross_chain_event_index %}
+
+Event number within a transaction.
+
+{% enddocs %}

models/docs/TX_Hash.md

@@ -0,0 +1,5 @@
+{% docs cross_chain_tx_hash %}
+
+Transaction hash is a unique 66-character identifier that is generated when a transaction is executed. 
+
+{% enddocs %}

models/docs/defi/Borrowing/Borrow_symbol.md

@@ -0,0 +1,5 @@
+{% docs crosschain_borrow_symbol %}
+
+The symbol of the asset/collateral that is payed or received, depending on the action
+
+{% enddocs %}

models/docs/defi/Borrowing/Borrower.md

@@ -0,0 +1,5 @@
+{% docs crosschain_borrower %}
+
+Its the address of the user who is Borrowing or repaying the loan, depending on the action.
+
+{% enddocs %}

models/docs/defi/Borrowing/action.md

@@ -0,0 +1,9 @@
+{% docs crosschain_borrow_action %}
+
+The action that the user is taking.
+ Borrow: user is borrowing an asset
+ Repay: user is repaying the asset that they have borrowed in a previous loan
+ Add collateral: user is depositing collateral for their loan. This happens some times in the same transaction as the borrowing transaction and some times in a separate transaction. 
+ Remove collateral: user is withdrawing collateral. This happens some times in the same transaction as the borrowing transaction and some times in a separate transaction.
+
+{% enddocs %}

models/docs/defi/Borrowing/amount.md

@@ -0,0 +1,9 @@
+{% docs crosschain_borrow_amount %}
+
+The meaning depends on the action:
+Borrow: The amount of the asset that the user is borrowing or
+Repay: The amount of the asset that the user is repaying
+Add collateral: The amount of collateral that the user is depositing
+Remove collateral: The amount of collateral that the user is withdrawing
+
+{% enddocs %}

models/docs/defi/Borrowing/amount_usd.md

@@ -0,0 +1,8 @@
+{% docs crosschain_borrow_amount_usd %}
+
+The meaning depends on the action:
+Borrow: The amount of the asset in USD that the user is borrowing or
+Repay: The amount of the asset in USD that the user is repaying
+Add collateral: The amount of collateral in USD that the user is depositing
+Remove collateral: The amount of collateral in USD that the user is withdrawing
+{% enddocs %}

models/docs/defi/Borrowing/asset.md

@@ -0,0 +1,5 @@
+{% docs crosschain_borrow_asset %}
+
+The address of the asset/collateral token that is being borrowed/repayed/deposited etc. depending on the action
+
+{% enddocs %}

models/docs/defi/Borrowing/borrower_is_a_contract.md

@@ -0,0 +1,5 @@
+{% docs crosschain_lending_borrower_is_a_contract %}
+
+If the depositor of collateral is a contract then its a Yes, if the depositor of collateral is a normal address it is a No.
+
+{% enddocs %}

models/docs/defi/Pool_address.md

@@ -0,0 +1,5 @@
+{% docs cross_chain_swap_pool_address %}
+
+The contract address for the liquidity pool. 
+
+{% enddocs %}

models/docs/defi/Swap_Amount_in.md

@@ -0,0 +1,5 @@
+{% docs cross_chain_swap_amount_in %}
+
+The amount of tokens put into the swap.
+
+{% enddocs %}

models/docs/defi/Swap_Amount_out.md

@@ -0,0 +1,5 @@
+{% docs cross_chain_swap_amount_out %}
+
+The amount of tokens taken out of or received from the swap.
+
+{% enddocs %}

models/docs/defi/Swap_amount_in_USD.md

@@ -0,0 +1,5 @@
+{% docs cross_chain_swap_amount_in_usd %}
+
+The amount of tokens put into the swap converted to USD using the price of the token.
+
+{% enddocs %}

models/docs/defi/Swap_amount_out_USD.md

@@ -0,0 +1,5 @@
+{% docs cross_chain_swap_amount_out_usd %}
+
+The amount of tokens taken out of or received from the swap converted to USD using the price of the token.
+
+{% enddocs %}

models/docs/defi/Swap_platform.md

@@ -0,0 +1,5 @@
+{% docs cross_chain_swap_platform %}
+
+This field denotes which application the liquidity pool belongs to. 
+
+{% enddocs %}

models/docs/defi/Swap_sender.md

@@ -0,0 +1,5 @@
+{% docs cross_chain_swap_sender %}
+
+The address of the wallet or contract that creates the swap. The Router is usually the Sender in the swap function. 
+
+{% enddocs %}

models/docs/defi/Swap_symbol_in.md

@@ -0,0 +1,5 @@
+{% docs cross_chain_swap_symbol_in %}
+
+The symbol of the token sent for swap.
+
+{% enddocs %}

models/docs/defi/Swap_symbol_out.md

@@ -0,0 +1,5 @@
+{% docs cross_chain_swap_symbol_out %}
+
+The symbol of the token being swapped to.
+
+{% enddocs %}

models/docs/defi/Swap_token_in.md

@@ -0,0 +1,5 @@
+{% docs cross_chain_swap_token_in %}
+
+The address of the token sent for swap.
+
+{% enddocs %}

models/docs/defi/Swap_token_out.md

@@ -0,0 +1,5 @@
+{% docs cross_chain_swap_token_out %}
+
+The address of the token being swapped to.
+
+{% enddocs %}

models/docs/defi/Swap_tx_to.md

@@ -0,0 +1,5 @@
+{% docs cross_chain_swap_tx_to %}
+
+The tx_to is the address who receives the swapped token. This corresponds to the "to" field in the swap function.
+
+{% enddocs %}

models/docs/defi/lending/action.md

@@ -0,0 +1,7 @@
+{% docs crosschain_action %}
+
+The action that the user is taking.
+ Deposit: user is depositing funds to be used for lending
+ Withdraw: user has changed their mind and are no longer willing to lend, so they withdraw their asset
+
+{% enddocs %}

models/docs/defi/lending/amount.md

@@ -0,0 +1,5 @@
+{% docs cross_chain_lending_amount %}
+
+The amount of the asset that is being deposited for lending
+
+{% enddocs %}

models/docs/defi/lending/amount_usd.md

@@ -0,0 +1,5 @@
+{% docs cross_chain_lending_amount_usd %}
+
+The amount of the asset that is being deposited for lending in USD.
+
+{% enddocs %}

models/docs/defi/lending/depositor.md

@@ -0,0 +1,5 @@
+{% docs cross_chain_lending_depositor %}
+
+The address of the user or contract that is depositing funds for lending
+
+{% enddocs %}

models/docs/defi/lending/lender_is_a_contract.md

@@ -0,0 +1,5 @@
+{% docs cross_chain_lending_lender_is_a_contract %}
+
+If the depositor is a contract then its a Yes, if the depositor is a normal address it is a No.
+
+{% enddocs %}

models/docs/defi/lending/lending_pool.md

@@ -0,0 +1,5 @@
+{% docs cross_chain_lending_lending_pool %}
+
+The name of the lending pool. 
+
+{% enddocs %}

models/docs/defi/lending/origin_from_address.md

@@ -0,0 +1,5 @@
+{% docs crosschain_lending_origin_from_address %}
+
+The address of the user who initiates the transaction.
+
+{% enddocs %}

models/docs/defi/lending/origin_to_address.md

@@ -0,0 +1,5 @@
+{% docs crosschain_lending_origin_to_address %}
+
+The person who initiates the depositing transaction has to interact with this address. This address belongs to the lending platform or directs the transactio there.  
+
+{% enddocs %}

models/docs/defi/lending/pool_address.md

@@ -0,0 +1,5 @@
+{% docs cross_chain_lending_pool_address %}
+
+The contract address for the lending pool. 
+
+{% enddocs %}

models/docs/defi/lending/symbol.md

@@ -0,0 +1,5 @@
+{% docs cross_chain_lending_symbol %}
+
+The symbol of the asset that is being deposited for lending. 
+
+{% enddocs %}

models/docs/origin_from_address.md

@@ -0,0 +1,5 @@
+{% docs origin_from_address %}
+
+The address of the user who initiates the swap. If a swap action generates multiple swaps, all of them will have the same address as origin_from_address.
+
+{% enddocs %}

models/docs/origin_to_address.md

@@ -0,0 +1,5 @@
+{% docs origin_to_address %}
+
+The person who initiates the swap has to interact with this address. This address belongs to the decentralized exchange and/or is a router.  
+
+{% enddocs %}

models/sources.yml

@@ -40,6 +40,7 @@ sources:
       - name: fact_traces
       - name: ez_nft_sales
       - name: ez_current_balances
+      - name: ez_dex_swaps
   - name: ethereum_silver
     database: ethereum
     schema: silver
@@ -185,4 +186,60 @@ sources:
     database: flipside_prod_db
     schema: bronze
     tables: 
-      - name: prod_address_label_sink_291098491
+      - name: prod_address_label_sink_291098491
+  - name: Harmony_db
+    database: HARMONY
+    schema: SUSHI
+    tables:
+      - name: EZ_SUSHI_SWAPS
+  - name: polygon
+    database: POLYGON
+    schema: SUSHI
+    tables:
+      - name: EZ_SWAPS
+      - name: EZ_LENDING
+      - name: EZ_BORROWING  
+  - name: Arbitrum
+    database: ARBITRUM
+    schema: SUSHI
+    tables:
+      - name: EZ_SWAPS
+      - name: EZ_LENDING
+      - name: EZ_BORROWING 
+
+  - name: Avalanche
+    database: AVALANCHE
+    schema: SUSHI
+    tables:
+      - name: EZ_SWAPS
+      - name: EZ_LENDING
+      - name: EZ_BORROWING  
+  
+  - name: BSC
+    database: BSC
+    schema: SUSHI
+    tables:
+      - name: EZ_SWAPS
+      - name: EZ_LENDING
+      - name: EZ_BORROWING  
+
+  - name: Optimism
+    database: OPTIMISM
+    schema: SUSHI
+    tables:
+      - name: EZ_SWAPS
+
+  - name: Gnosis  
+    database: GNOSIS
+    schema: SUSHI
+    tables:
+      - name: EZ_SWAPS
+      - name: EZ_LENDING
+      - name: EZ_BORROWING  
+  - name: ethereum_db_sushi
+    database: ethereum
+    schema: sushi
+    tables:
+      - name: dim_distributor_reward_schedule
+      - name: ez_lending
+      - name: ez_borrowing