feat: add ape store spellbook

dbt_subprojects/daily_spellbook/models/ape_store/ape_store_schema.yml

@@ -0,0 +1,68 @@
+version: 2
+
+models:
+  - name: ape_store_trades
+    meta:
+      blockchain: base, ethereum
+      project: ape_store
+      contributors: whale_hunter
+    config:
+      tags: ["base", "ethereum", "ape_store", "dex", "whale_hunter"]
+    description: >
+      Trades for tokens that get deployed through ApeStore across all chains
+    tests:
+      - dbt_utils.unique_combination_of_columns:
+          combination_of_columns:
+            - block_month
+            - blockchain
+            - tx_hash
+            - tx_index
+    columns:
+      - &block_time
+        name: block_time
+        description: "UTC timestamp of the trade"
+      - &block_date
+        name: block_date
+        description: "UTC date of the trade"
+      - &block_month
+        name: block_month
+        description: "UTC month of the trade"
+      - &blockchain
+        name: blockchain
+        description: "Blockchain on which the trade occured"
+      - &platform
+        name: platform
+        description: "Platform on which the trade occured. e.g. Bonding Curve or DEX"
+      - &type
+        name: type
+        description: "Wether the trade is a buy or a sell"
+      - &amount_usd
+        name: amount_usd
+        description: "USD value of the trade"
+      - &token_bought_amount
+        name: token_bought_amount
+        description: "Value of the token bought at time of execution in the original currency"
+      - &token_bought_symbol
+        name: token_bought_symbol
+        description: "Token symbol for token bought in the trade"
+      - &token_bought_address
+        name: token_bought_address
+        description: "Contract address of the token bought"
+      - &token_sold_amount
+        name: token_sold_amount
+        description: "Value of the token sold at time of execution in the original currency"
+      - &token_sold_symbol
+        name: token_sold_symbol
+        description: "Token symbol for token sold in the trade"
+      - &token_sold_address
+        name: token_sold_address
+        description: "Contract address of the token sold"
+      - &user
+        name: user
+        description: "Address which initiated the trade"
+      - &tx_hash
+        name: tx_hash
+        description: "Unique transaction hash value tied to each transaction on the DEX"
+      - &tx_index
+        name: tx_index
+        description: "Index of the corresponding trade event"

dbt_subprojects/daily_spellbook/models/ape_store/ape_store_trades.sql

@@ -0,0 +1,40 @@
+{{
+    config(
+        schema = 'ape_store',
+        alias = 'trades',
+        materialized = 'view',
+        post_hook = '{{ expose_spells(
+                        blockchains = \'["base", "ethereum"]\',
+                        spell_type = "project",
+                        spell_name = "ape_store",
+                        contributors = \'["whale_hunter"]\') }}'
+    )
+}}
+
+{% set ape_store_models = [
+    ref('ape_store_base_trades')
+    , ref('ape_store_ethereum_trades')
+] %}
+
+{% for model in ape_store_models %}
+SELECT block_time,
+       block_date,
+       block_month,
+       blockchain,
+       platform,
+       type,
+       amount_usd,
+       token_bought_amount,
+       token_bought_symbol,
+       token_bought_address,
+       token_sold_amount,
+       token_sold_symbol,
+       token_sold_address,
+       user,
+       tx_hash,
+       tx_index
+FROM {{ model }}
+{% if not loop.last %}
+UNION ALL
+{% endif %}
+{% endfor %}

dbt_subprojects/daily_spellbook/models/ape_store/base/ape_store_base_deployments.sql

@@ -0,0 +1,31 @@
+{{
+    config(
+        alias='deployments',
+        schema='ape_store_base',
+        materialized='incremental',
+        file_format='delta',
+        incremental_strategy='merge',
+        incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
+        unique_key='token'
+    )
+}}
+
+{% set project_start_date = '2024-04-04' %}
+{% set blockchain = 'base' %}
+
+select
+    evt_block_time as block_time,
+    date_trunc('day', evt_block_time) as block_date,
+    date_trunc('month', evt_block_time) as block_month,
+    '{{blockchain}}' as blockchain,
+    token,
+    id,
+    evt_tx_from as deployer,
+    evt_tx_hash as tx_hash
+from {{ source("ape_store_base", "Router_evt_CreateToken") }}
+where 
+    {% if is_incremental() %}
+    {{ incremental_predicate('evt_block_time') }}
+    {% else %}
+    evt_block_time >= timestamp '{{project_start_date}}'
+    {% endif %}

dbt_subprojects/daily_spellbook/models/ape_store/base/ape_store_base_schema.yml

@@ -0,0 +1,96 @@
+version: 2
+
+models:
+  - name: ape_store_base_trades
+    meta:
+      blockchain: base
+      project: ape_store
+      contributors: whale_hunter
+    config:
+      tags: ["base", "ape_store", "dex", "whale_hunter"]
+    description: >
+      Trades for tokens that get deployed through ApeStore on Base
+    tests:
+      - dbt_utils.unique_combination_of_columns:
+          combination_of_columns:
+            - block_month
+            - blockchain
+            - tx_hash
+            - tx_index
+    columns:
+      - &block_time
+        name: block_time
+        description: "UTC timestamp of the trade"
+      - &block_date
+        name: block_date
+        description: "UTC date of the trade"
+      - &block_month
+        name: block_month
+        description: "UTC month of the trade"
+      - &blockchain
+        name: blockchain
+        description: "Blockchain on which the trade occured"
+      - &platform
+        name: platform
+        description: "Platform on which the trade occured. e.g. Bonding Curve or DEX"
+      - &type
+        name: type
+        description: "Wether the trade is a buy or a sell"
+      - &amount_usd
+        name: amount_usd
+        description: "USD value of the trade"
+      - &token_bought_amount
+        name: token_bought_amount
+        description: "Value of the token bought at time of execution in the original currency"
+      - &token_bought_symbol
+        name: token_bought_symbol
+        description: "Token symbol for token bought in the trade"
+      - &token_bought_address
+        name: token_bought_address
+        description: "Contract address of the token bought"
+      - &token_sold_amount
+        name: token_sold_amount
+        description: "Value of the token sold at time of execution in the original currency"
+      - &token_sold_symbol
+        name: token_sold_symbol
+        description: "Token symbol for token sold in the trade"
+      - &token_sold_address
+        name: token_sold_address
+        description: "Contract address of the token sold"
+      - &user
+        name: user
+        description: "Address which initiated the trade"
+      - &tx_hash
+        name: tx_hash
+        description: "Unique transaction hash value tied to each transaction on the DEX"
+      - &tx_index
+        name: tx_index
+        description: "Index of the corresponding trade event"
+  - name: ape_store_base_deployments
+    meta:
+      blockchain: base
+      project: ape_store
+      contributors: whale_hunter
+    config:
+      tags: ["base", "ape_store", "dex", "whale_hunter"]
+    description: >
+      Tokens that get deployed through ApeStore on Base
+    tests:
+      - dbt_utils.unique_combination_of_columns:
+          combination_of_columns:
+            - token
+    columns:
+      - *block_time
+      - *block_date
+      - *block_month
+      - *blockchain
+      - &token
+        name: token
+        description: "Contract address of the deployed token"
+      - &id
+        name: id
+        description: "ID of the deployed token"
+      - &deployer
+        name: deployer
+        description: "Address which initiated the deployment"
+      - *tx_hash

dbt_subprojects/daily_spellbook/models/ape_store/base/ape_store_base_trades.sql

@@ -0,0 +1,110 @@
+{{ config(
+    alias = 'trades',
+    schema = 'ape_store_base',
+    partition_by = ['block_month'],
+    materialized = 'incremental',
+    file_format = 'delta',
+    incremental_strategy = 'merge',
+    incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
+    unique_key = ['block_month', 'blockchain', 'tx_hash', 'tx_index']
+   )
+}}
+
+{% set project_start_date = '2024-04-04' %}
+{% set blockchain = 'base' %}
+{% set weth_contract_address = '0x4200000000000000000000000000000000000006' %}
+
+with
+    deployments as (
+        select * from {{ref('ape_store_base_deployments')}}
+    ),
+    bondingcurvetrades as (
+        select
+            evt_block_time as block_time,
+            date_trunc('day', evt_block_time) as block_date,
+            date_trunc('month', evt_block_time) as block_month,
+            '{{blockchain}}' as blockchain,
+            'Bonding Curve' as platform,
+            if(amount0out > 0, 'Buy', 'Sell') as type,
+            (amount1in + amount1out) / 1e18 * price as amount_usd,
+            (amount0out + amount1out) / 1e18 as token_bought_amount,
+            if(amount0out > 0, token.symbol, 'WETH') token_bought_symbol,
+            if(
+                amount0out > 0, token, {{ weth_contract_address }}
+            ) as token_bought_address,
+            (amount0in + amount1in) / 1e18 as token_sold_amount,
+            if(amount0out > 0, 'WETH', token.symbol) as token_sold_symbol,
+            if(
+                amount0out > 0, {{ weth_contract_address }}, token
+            ) as token_sold_address,
+            sender as user,
+            evt_tx_hash as tx_hash,
+            evt_index as tx_index
+        from {{ source('ape_store_base', 'Router_evt_swap') }} as swaps
+        left join
+            {{ source('tokens', 'erc20') }} as token
+            on (
+                token.blockchain = '{{blockchain}}'
+                and token.contract_address = swaps.token
+            )
+        left join
+            {{ source('prices', 'usd') }} as ethPrice
+            on (
+                ethPrice.blockchain = '{{blockchain}}'
+                and ethPrice.contract_address = {{ weth_contract_address }}
+                and ethPrice.minute = date_trunc('minute', evt_block_time)
+                and (
+                    {% if is_incremental() %}
+                    {{ incremental_predicate('ethPrice.minute') }}
+                    {% else %}
+                    ethPrice.minute >= timestamp '{{project_start_date}}'
+                    {% endif %}
+                )
+            )
+        where
+            {% if is_incremental() %}
+            {{ incremental_predicate('evt_block_time') }}
+            {% else %}
+            evt_block_time >= timestamp '{{project_start_date}}'
+            {% endif %}
+    ),
+    dextrades as (
+        select distinct
+            trades.block_time,
+            date_trunc('day', trades.block_time) as block_date,
+            date_trunc('month', trades.block_time) as block_month,
+            trades.blockchain,
+            'DEX' as platform,
+            if(token_sold_address = {{ weth_contract_address }}, 'Buy', 'Sell') as type,
+            amount_usd,
+            token_bought_amount,
+            token_bought_symbol,
+            token_bought_address,
+            token_sold_amount,
+            token_sold_symbol,
+            token_sold_address,
+            tx_from as user,
+            trades.tx_hash,
+            evt_index as tx_index
+        from {{ source('dex', 'trades') }} as trades
+        join
+            deployments
+            on (
+                trades.blockchain = deployments.blockchain
+                and trades.block_month >= deployments.block_month
+                and (token_bought_address = token or token_sold_address = token)
+            )
+        where
+            trades.blockchain = '{{blockchain}}'
+            and
+            {% if is_incremental() %}
+            {{ incremental_predicate('trades.block_time') }}
+            {% else %}
+            trades.block_time >= timestamp '{{project_start_date}}'
+            {% endif %}
+    )
+select *
+from bondingcurvetrades
+union all
+select *
+from dextrades

dbt_subprojects/daily_spellbook/models/ape_store/ethereum/ape_store_ethereum_deployments.sql

@@ -0,0 +1,42 @@
+{{
+    config(
+        alias='deployments',
+        schema='ape_store_ethereum',
+        materialized='incremental',
+        file_format='delta',
+        incremental_strategy='merge',
+        incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_time')],
+        unique_key='token'
+    )
+}}
+
+{% set project_start_date = '2024-09-06' %}
+{% set blockchain = 'ethereum' %}
+
+select
+    evt_block_time as block_time,
+    date_trunc('day', evt_block_time) as block_date,
+    date_trunc('month', evt_block_time) as block_month,
+    '{{blockchain}}' as blockchain,
+    token,
+    id,
+    evt_tx_from as deployer,
+    evt_tx_hash as tx_hash
+from {{ source("ape_store_base", "Router_evt_CreateToken") }}
+join {{source(blockchain, 'transactions')}} on (
+    evt_block_time = block_time
+    and evt_tx_hash = hash
+    and (
+        {% if is_incremental() %}
+        {{ incremental_predicate('block_time') }}
+        {% else %}
+        block_time >= timestamp '{{project_start_date}}'
+        {% endif %}
+    )
+)
+where 
+    {% if is_incremental() %}
+    {{ incremental_predicate('evt_block_time') }}
+    {% else %}
+    evt_block_time >= timestamp '{{project_start_date}}'
+    {% endif %}