filter out null responses; add buffer to realtime (#34)

models/silver/core/silver__blocks.sql

@@ -43,6 +43,7 @@ WITH pre_final AS (
     WHERE
         block_id IS NOT NULL
         AND error IS NULL
+        AND data IS NOT NULL
         {% if is_incremental() %}
         AND _inserted_timestamp >= '{{ max_inserted_timestamp }}'
         {% endif %}

models/streamline/core/complete/streamline__blocks_complete.sql

@@ -26,6 +26,7 @@ WHERE
         FROM
             {{ this }}
     )
+    AND data IS NOT NULL
 {% else %}
     {{ ref('bronze__FR_blocks') }}
 {% endif %}

models/streamline/core/streamline__chainhead.sql

@@ -24,4 +24,4 @@ SELECT
             []
         ),
         'Vault/prod/eclipse/mainnet'
-    ) :data :result :: INT AS block_id
+    ) :data :result :: INT - 50 AS block_id