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

update lending pool column
2026-02-06 13:57:16 +00:00 · 2024-09-11 14:53:39 -07:00 · 2024-09-11 14:53:39 -07:00 · 4285cae353
commit 4285cae353
parent 8b49682266
7 changed files with 28 additions and 7 deletions
--- 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
--- 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
--- 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
--- 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
--- 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
--- 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'
--- 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