AN-5202/aave-fork-lending-bug (#167)

update lending pool column
FlipsideCrypto · Sep 11, 2024 · 4285cae · 4285cae
1 parent 8b49682
commit 4285cae
Show file tree

Hide file tree

Showing 7 changed files with 28 additions and 7 deletions.
diff --git a/models/silver/defi/lending/aave/silver__aave_withdraws.sql b/models/silver/defi/lending/aave/silver__aave_withdraws.sql
@@ -44,7 +44,10 @@ withdraw AS(
         ) :: INTEGER AS withdraw_amount,
         tx_hash,
         'Aave V3' AS aave_version,
-        origin_to_address AS lending_pool_contract,
+        COALESCE(
+            origin_to_address,
+            contract_address
+        ) AS lending_pool_contract,
         _inserted_timestamp,
         _log_id
     FROM

diff --git a/models/silver/defi/lending/agave/silver__agave_repayments.sql b/models/silver/defi/lending/agave/silver__agave_repayments.sql
@@ -44,7 +44,10 @@ atoken_meta AS (
             segmented_data [0] :: STRING
         ) :: INTEGER AS repayed_amount,
         'Agave' AS agave_version,
-        origin_to_address AS lending_pool_contract,
+        COALESCE(
+            origin_to_address,
+            contract_address
+        ) AS lending_pool_contract,
         origin_from_address AS repayer_address,
         _log_id,
         _inserted_timestamp

diff --git a/models/silver/defi/lending/agave/silver__agave_withdraws.sql b/models/silver/defi/lending/agave/silver__agave_withdraws.sql
@@ -44,7 +44,10 @@ withdraw AS(
         ) :: INTEGER AS withdraw_amount,
         tx_hash,
         'Agave' AS agave_version,
-        origin_to_address AS lending_pool_contract,
+        COALESCE(
+            origin_to_address,
+            contract_address
+        ) AS lending_pool_contract,
         _inserted_timestamp,
         _log_id
     FROM

diff --git a/models/silver/defi/lending/realt/silver__realt_repayments.sql b/models/silver/defi/lending/realt/silver__realt_repayments.sql
@@ -43,7 +43,10 @@ repay AS(
             segmented_data [0] :: STRING
         ) :: INTEGER AS repayed_amount,
         'realT' AS realt_version,
-        origin_to_address AS lending_pool_contract,
+        COALESCE(
+            origin_to_address,
+            contract_address
+        ) AS lending_pool_contract,
         origin_from_address AS repayer_address,
         _log_id,
         _inserted_timestamp

diff --git a/models/silver/defi/lending/realt/silver__realt_withdraws.sql b/models/silver/defi/lending/realt/silver__realt_withdraws.sql
@@ -43,7 +43,10 @@ withdraw AS(
         ) :: INTEGER AS withdraw_amount,
         tx_hash,
         'realT' AS realt_version,
-        origin_to_address AS lending_pool_contract,
+        COALESCE(
+            origin_to_address,
+            contract_address
+        ) AS lending_pool_contract,
         _inserted_timestamp,
         _log_id
     FROM

diff --git a/models/silver/defi/lending/spark/silver__spark_repayments.sql b/models/silver/defi/lending/spark/silver__spark_repayments.sql
@@ -45,7 +45,10 @@ repay AS(
         _log_id,
         _inserted_timestamp,
         'Spark' AS spark_version,
-        origin_to_address AS lending_pool_contract,
+        COALESCE(
+            origin_to_address,
+            contract_address
+        ) AS lending_pool_contract,
         origin_from_address AS repayer_address,
         CASE
             WHEN reserve_1 = '0xeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee' THEN '0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2'

diff --git a/models/silver/defi/lending/spark/silver__spark_withdraws.sql b/models/silver/defi/lending/spark/silver__spark_withdraws.sql
@@ -45,7 +45,10 @@ withdraw AS(
         _log_id,
         tx_hash,
         'Spark' AS spark_version,
-        origin_to_address AS lending_pool_contract,
+        COALESCE(
+            origin_to_address,
+            contract_address
+        ) AS lending_pool_contract,
         CASE
             WHEN reserve_1 = '0xeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee' THEN '0xc02aaa39b223fe8d0a0e5c4f27ead9083c756cc2'
             ELSE reserve_1