Adding aave interests abstraction in Dune v2

dbt_project.yml

@@ -25,6 +25,12 @@ clean-targets:         # directories to be removed by `dbt clean`
 # Full documentation: https://docs.getdbt.com/docs/configuring-models
 models:
   spellbook:
+    aave:
+      +schema: aave
+      +materialized: view
+      ethereum:
+        +schema: aave_ethereum
+        +materialized: view
     ens:
       +schema: ens
       +materialized: view
@@ -229,3 +235,4 @@ seeds:
           amount_original: double
           platform_fee_amount: double
           pool_fee_amount: double
+

models/aave/ethereum/aave_ethereum_schema.yml

@@ -0,0 +1,27 @@
+version: 2
+
+models:
+ - name: aave_v2_ethereum_interest_rates
+   meta:
+     blockchain: ethereum
+     sector: dex
+     project: aave_v2
+     contibutors: batwayne, chuxinh
+
+   config:
+     tags: ['ethereum', 'aave_v2', 'interest', 'aave', 'dex']
+   description: "Hourly aave interest rates on ethereum"
+   columns:
+     - name: reserve
+       description: "Aave reserve contract address"
+     - name: symbol
+       description: "Symbol of the reserve"
+     - name: hour
+       description: "Block timestamp truncated to hours"
+     - name: deposit_apy
+       description: "Hourly deposit interest rate value of the reserve"
+     - name: stable_borrow_apy
+       description: "Hourly stable borrow interest rate value of the reserve" 
+     - name: variable_borrow_apy
+       description: "Hourly variable borrow interest rate value of the reserve" 
+

models/aave/ethereum/aave_ethereum_sources.yml

@@ -0,0 +1,41 @@
+version: 2
+
+sources:
+  - name: aave_v2_ethereum
+    description: "Decoded contracts for aave v2 on Ethereum"
+
+    tables:
+      - name: LendingPool_evt_ReserveDataUpdated
+        loaded_at_field: evt_block_time
+        description: "Provides the liqudity index, stable and variable borrow rates for aave v2 reserves."
+        freshness:
+          warn_after: { count: 12, period: hour }
+          error_after: { count: 24, period: hour }
+        columns:
+        - name: contract_address
+          description: "Aave token contract address"       
+        - &evt_block_number
+          name: evt_block_number
+          description: "Event block number"  
+        - &evt_block_time
+          name: evt_block_time
+          description: "Timestamp for block event time in UTC"
+        - &evt_index
+          name: evt_index
+          description: "Event index"  
+        - &evt_tx_hash
+          name: evt_tx_hash
+          description: "Transaction hash of the event" 
+        - name: liqudityIndex
+          description: "Liqudity index value of the reserve"
+        - name: liqudityRate
+          description: "Liqudity rate value of the reserve"
+        - name: reserve
+          description: "Aave reserve contract address"
+        - name: stableBorrowRate
+          description: "Stable borrow rate value of the reserve"  
+        - name: variableBorrowIndex
+          description: "Variable borrow index value of the reserve"
+        - name: variableBorrowRate
+          description: "Variable borrow rate value of the reserve"     
+

models/aave/ethereum/aave_v2_ethereum_interest_rates.sql

@@ -0,0 +1,13 @@
+{{ config(materialized='view', alias='aave_interest') }}
+
+select 
+  a.reserve, 
+  t.symbol,
+  date_trunc('hour',a.evt_block_time) as hour, 
+  avg(a.liquidityRate) / 1e27 as deposit_apy, 
+  avg(a.stableBorrowRate) / 1e27 as stable_borrow_apy, 
+  avg(a.variableBorrowRate) / 1e27 as variable_borrow_apy
+from {{ source('aave_v2_ethereum', 'LendingPool_evt_ReserveDataUpdated') }} a
+left join {{ ref('tokens_ethereum_erc20') }} t
+on a.reserve=t.contract_address
+group by 1,2,3

tests/aave/ethereum/aave_interests_test.sql

@@ -0,0 +1,22 @@
+with unit_test1
+    as (select case
+                 when variable_borrow_apy = 0.024106036652769853 then true
+                 else false
+               end as test
+        from   {{ ref('aave_v2_ethereum_interest_rates' )}}
+        where  reserve = '0xdac17f958d2ee523a2206206994597c13d831ec7'
+               and hour = '2022-08-22 12:00'),
+    unit_test2
+    as (select case when deposit_apy = 0.004223674732695223 then true
+                 else false
+               end as test
+        from   {{ ref('aave_v2_ethereum_interest_rates' )}}
+        where  symbol = 'USDC'
+               and hour = '2022-08-25 09:00')
+select *
+from   (select *
+       from   unit_test1
+       union
+       select *
+       from   unit_test2)
+where  test = false