chore: check name only contract is to be decoded (#652)

getdozer · Jan 18, 2023 · 139a7da · 139a7da
1 parent 554c43f
commit 139a7da
Show file tree

Hide file tree

Showing 3 changed files with 39 additions and 39 deletions.
diff --git a/dozer-ingestion/src/connectors/ethereum/helper.rs b/dozer-ingestion/src/connectors/ethereum/helper.rs
@@ -78,17 +78,16 @@ pub fn decode_event(
     tables: Option<Vec<TableInfo>>,
     schema_map: HashMap<H256, usize>,
 ) -> Option<OperationEvent> {
-    // Topics 0, 1, 2 should be name, buyer, seller in most cases
-    let name = log
-        .topics
-        .get(0)
-        .expect("name is expected")
-        .to_owned()
-        .to_string();
-
     let address = format!("{:?}", log.address);
 
     if let Some(contract_tuple) = contracts.get(&address) {
+        // Topics 0, 1, 2 should be name, buyer, seller in most cases
+        let name = log
+            .topics
+            .get(0)
+            .expect("name is expected")
+            .to_owned()
+            .to_string();
         let opt_event = contract_tuple
             .0
             .events

diff --git a/dozer-tests/src/e2e_tests/cases/eth/dozer-config.yaml b/dozer-tests/src/e2e_tests/cases/eth/dozer-config.yaml
@@ -1,34 +1,35 @@
 app_name: working_app
 connections:
-- authentication: !Ethereum
-    filter:
-      from_block: 0
-      addresses: []
-      topics: []
-    wss_url: "{{ETH_WSS_URL}}"
+  - authentication: !Ethereum
+      filter:
+        from_block: 0
+        to_block: 1
+        addresses: []
+        topics: []
+      wss_url: "{{ETH_WSS_URL}}"
+      name: eth_logs
+    db_type: Ethereum
     name: eth_logs
-  db_type: Ethereum
-  name: eth_logs
 sources:
-- name: eth_logs
-  table_name: eth_logs
-  columns:
-  - block_number
-  - id
-  connection: !Ref eth_logs
+  - name: eth_logs
+    table_name: eth_logs
+    columns:
+      - block_number
+      - id
+    connection: !Ref eth_logs
 endpoints:
-- id: 1b44cca2-7631-4f0c-8b6e-254c08d28dae
-  app_id: 5116e5e4-6963-47fe-b63c-e80ced1fbf29
-  name: eth_stats
-  path: /eth/stats
-  sql: select block_number, sum(id) from eth_logs where 1=1 group by block_number;
-  index:
-    primary_key:
-    - block_number
-- name: eth_logs
-  path: /eth/logs
-  sql: select block_number, id  from eth_logs where 1=1 group by block_number, id;
-  index:
-    primary_key:
-    - block_number
-    - id
+  - id: 1b44cca2-7631-4f0c-8b6e-254c08d28dae
+    app_id: 5116e5e4-6963-47fe-b63c-e80ced1fbf29
+    name: eth_stats
+    path: /eth/stats
+    sql: select block_number, sum(id) from eth_logs where 1=1 group by block_number;
+    index:
+      primary_key:
+        - block_number
+  - name: eth_logs
+    path: /eth/logs
+    sql: select block_number, id  from eth_logs where 1=1 group by block_number, id;
+    index:
+      primary_key:
+        - block_number
+        - id
diff --git a/dozer-tests/src/e2e_tests/cases/eth/expectations.json b/dozer-tests/src/e2e_tests/cases/eth/expectations.json
@@ -9,7 +9,7 @@
                         "fields": [
                             {
                                 "name": "block_number",
-                                "typ": "Int",
+                                "typ": "UInt",
                                 "nullable": true
                             },
                             {
@@ -32,7 +32,7 @@
                         "fields": [
                             {
                                 "name": "block_number",
-                                "typ": "Int",
+                                "typ": "UInt",
                                 "nullable": true
                             },
                             {