Init flare dex

dbt_subprojects/dex/models/trades/flare/_schema.yml

@@ -0,0 +1,78 @@
+version: 2
+
+models:
+  - name: dex_flare_base_trades
+    meta:
+      blockchain: flare
+      sector: dex
+      project: dex
+      contributors: hosuke
+    config:
+      tags: ['flare', 'dex', 'trades']
+    description: >
+      Flare DEX trades
+    columns:
+      - name: blockchain
+        description: "Blockchain"
+      - name: project
+        description: "Project name of the DEX"
+      - name: version
+        description: "Version of the DEX protocol"
+      - name: block_month
+        description: "UTC event block month"
+      - name: block_date
+        description: "UTC event block date"
+      - name: block_time
+        description: "UTC event block time"
+      - name: block_number
+        description: "Block number"
+      - name: token_bought_amount_raw
+        description: "Raw amount of token bought (not normalized)"
+      - name: token_sold_amount_raw
+        description: "Raw amount of token sold (not normalized)"
+      - name: token_bought_address
+        description: "Contract address of the token bought"
+      - name: token_sold_address
+        description: "Contract address of the token sold"
+      - name: taker
+        description: "Address of trader who initiated the trade"
+      - name: maker
+        description: "Address of trader who provided liquidity"
+      - name: project_contract_address
+        description: "Project's contract address that executed the trade"
+      - name: tx_hash
+        description: "Transaction hash"
+      - name: evt_index
+        description: "Event index"
+    data_tests:
+      - check_dex_info_relationship
+
+  - name: enosys_v2_flare_base_trades
+    meta:
+      blockchain: flare
+      sector: dex
+      project: enosys
+      contributors: hosuke
+    config:
+      tags: [ 'flare', 'dex', 'trades', 'enosys', 'v2' ]
+    description: "Enosys V2 Flare base trades"
+    data_tests:
+      - dbt_utils.unique_combination_of_columns:
+          combination_of_columns:
+            - tx_hash
+            - evt_index
+
+  - name: enosys_v3_flare_base_trades
+    meta:
+      blockchain: flare
+      sector: dex
+      project: enosys
+      contributors: hosuke
+    config:
+      tags: [ 'flare', 'dex', 'trades', 'enosys', 'v3' ]
+    description: "Enosys V3 Flare base trades"
+    data_tests:
+      - dbt_utils.unique_combination_of_columns:
+          combination_of_columns:
+            - tx_hash
+            - evt_index

dbt_subprojects/dex/models/trades/flare/dex_flare_base_trades.sql

@@ -0,0 +1,49 @@
+{{ config(
+    schema = 'dex_flare'
+    , alias = 'base_trades'
+    , materialized = 'view'
+    )
+}}
+
+{% set base_models = [
+    ref('enosys_v2_flare_base_trades')
+    , ref('enosys_v3_flare_base_trades')
+] %}
+
+WITH base_union AS (
+    SELECT *
+    FROM (
+        {% for base_model in base_models %}
+        SELECT
+            blockchain
+            , project
+            , version
+            , block_month
+            , block_date
+            , block_time
+            , block_number
+            , token_bought_amount_raw
+            , token_sold_amount_raw
+            , token_bought_address
+            , token_sold_address
+            , taker
+            , maker
+            , project_contract_address
+            , tx_hash
+            , evt_index
+        FROM
+            {{ base_model }}
+        {% if not loop.last %}
+        UNION ALL
+        {% endif %}
+        {% endfor %}
+    )
+)
+
+{{
+    add_tx_columns(
+        model_cte = 'base_union'
+        , blockchain = 'flare'
+        , columns = ['from', 'to', 'index']
+    )
+}}

dbt_subprojects/dex/models/trades/flare/platforms/enosys_v2_flare_base_trades.sql

@@ -0,0 +1,28 @@
+{{ config(
+    schema = 'enosys_v2_flare'
+    , alias = 'base_trades'
+    , materialized = 'incremental'
+    , file_format = 'delta'
+    , incremental_strategy = 'merge'
+    , unique_key = ['tx_hash', 'evt_index']
+    , incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+    )
+}}
+
+WITH dexs AS
+(
+    {{
+    uniswap_compatible_v2_trades(
+        blockchain = 'flare'
+        , project = 'enosys'
+        , version = '2'
+        , Pair_evt_Swap = source('enosys_flare', 'EnosysDexPair_evt_Swap')
+        , Factory_evt_PairCreated = source('enosys_flare', 'EnosysDexFactory_evt_PairCreated')
+    )
+    }}
+)
+
+SELECT 
+    *
+FROM 
+    dexs

dbt_subprojects/dex/models/trades/flare/platforms/enosys_v3_flare_base_trades.sql

@@ -0,0 +1,28 @@
+{{ config(
+    schema = 'enosys_v3_flare'
+    , alias = 'base_trades'
+    , materialized = 'incremental'
+    , file_format = 'delta'
+    , incremental_strategy = 'merge'
+    , unique_key = ['tx_hash', 'evt_index']
+    , incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')]
+    )
+}}
+
+WITH dexs AS
+(
+    {{
+    uniswap_compatible_v3_trades(
+        blockchain = 'flare'
+        , project = 'enosys'
+        , version = '3'
+        , Pair_evt_Swap = source('enosys_flare', 'EnosysDexV3Pool_evt_Swap')
+        , Factory_evt_PoolCreated = source('enosys_flare', 'EnosysDexV3Factory_evt_PoolCreated')
+    )
+    }}
+)
+
+SELECT 
+    *
+FROM 
+    dexs

sources/_sector/dex/trades/flare/_sources.yml

@@ -0,0 +1,19 @@
+version: 2
+
+sources:
+  - name: blazeswap_flare
+    tables:
+      - name: BlazeSwapFactory_evt_PairCreated
+      # - name: BlazeSwapPair_evt_Swap not existed yet
+
+  - name: sparkdex_flare
+    tables:
+      - name: UniswapV3Factory_evt_PoolCreated
+      - name: UniswapV2Factory_evt_PairCreated
+
+  - name: enosys_flare
+    tables:
+      - name: EnosysDexPair_evt_Swap
+      - name: EnosysDexFactory_evt_PairCreated
+      - name: EnosysDexV3Pool_evt_Swap
+      - name: EnosysDexV3Factory_evt_PoolCreated