missing logs (#361)

macros/tests/missing_decoding.sql

@@ -0,0 +1,17 @@
+{% test missing_decoded_logs(model) %}
+SELECT
+    l.block_number,
+    l._log_id
+FROM
+    {{ ref('silver__logs') }}
+    l
+    LEFT JOIN {{ model }}
+    d
+    ON l.block_number = d.block_number
+    AND l._log_id = d._log_id
+WHERE
+    l.contract_address = LOWER('0x0d500B1d8E8eF31E21C99d1Db9A6444d3ADf1270') -- WMATIC
+    AND l.topics [0] :: STRING = '0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef' -- Transfer
+    AND l.block_timestamp BETWEEN DATEADD('hour', -48, SYSDATE())
+    AND DATEADD('hour', -6, SYSDATE())
+    AND d._log_id IS NULL {% endtest %}

models/silver/core/silver__decoded_logs.sql

@@ -36,7 +36,7 @@ WITH base_data AS (
 WHERE
     TO_TIMESTAMP_NTZ(_inserted_timestamp) >= (
         SELECT
-            MAX(_inserted_timestamp)
+            MAX(_inserted_timestamp) - INTERVAL '4 hours'
         FROM
             {{ this }}
     )

models/silver/core/tests/decoded_logs/test_silver__decoded_logs_recent.yml

@@ -13,6 +13,7 @@ models:
           config:
             severity: error
             error_if: ">0"
+      - missing_decoded_logs
 
     columns:
       - name: BLOCK_NUMBER