evaa_ton_supply.sql

models/dbt_subprojects/daily_spellbook/models/evaa/ton/evaa_ton_supply.sql

@@ -0,0 +1,56 @@
+{{ config(
+       schema = 'evaa_ton'
+       , alias = 'supply'
+       , materialized = 'incremental'
+       , file_format = 'delta'
+       , incremental_strategy = 'merge'
+       , incremental_predicates = [incremental_predicate('DBT_INTERNAL_DEST.block_date')]
+       , unique_key = ['tx_hash', 'block_date']
+       , post_hook='{{ expose_spells(\'["ton"]\',
+                                   "project",
+                                   "evaa",
+                                   \'["pshuvalov"]\') }}'
+   )
+ }}
+
+
+-- log::supply_success is sent by the router and contains all the data regarding the supply
+-- https://github.com/evaafi/contracts/blob/d5a6bf889f8bbfa8bcc82671c17e65a3b2b360cd/contracts/core/master-supply.fc#L239-L254
+
+WITH evaa_ton_pools AS (
+    {{ evaa_ton_pools() }}
+),
+parsed_boc AS (
+    SELECT M.block_date, M.tx_hash, M.trace_id, M.tx_now, M.tx_lt, pool_address, pool_name, body_boc
+    FROM {{ source('ton', 'messages') }} M
+    JOIN evaa_ton_pools ON M.source = pool_address
+    WHERE M.direction = 'out' AND M.destination IS NULL -- ext out message
+    AND M.block_date >= TIMESTAMP '2023-10-09' -- protocol launch
+    {% if is_incremental() %}
+        AND {{ incremental_predicate('M.block_date') }}
+    {% endif %}
+    AND bitwise_right_shift(opcode, 24) = 1 -- log::supply_success, 0x1
+), parse_output as (
+select {{ ton_from_boc('body_boc', [
+    ton_begin_parse(),
+    ton_load_uint(8, 'opcode'),
+    ton_load_address('owner_address'),
+    ton_load_address('sender_address'),
+    ton_load_uint(32, '_current_time'),
+    ton_load_ref(),
+    ton_begin_parse(),
+    ton_load_uint(256, 'asset_id'),
+    ton_load_uint(64, 'amount_supplied'),
+    ton_load_int(64, 'user_new_principal'),
+    ton_load_int(64, 'new_total_supply'),
+    ton_load_int(64, 'new_total_borrow'),
+    ton_load_uint(64, 's_rate'),
+    ton_load_uint(64, 'b_rate')
+    ]) }} as result, * from parsed_boc
+)
+select block_date, tx_hash, trace_id, tx_now, tx_lt, pool_address, pool_name,
+result.owner_address, result.sender_address, result.asset_id,
+result.amount_supplied, result.user_new_principal, result.new_total_supply,
+result.new_total_borrow,
+CAST(result.s_rate AS bigint) AS s_rate, CAST(result.b_rate AS bigint) AS b_rate -- should be less than 2^64
+from parse_output