update skar-client, cargo update

Cargo.toml

@@ -27,8 +27,8 @@ anyhow = "1"
 
 serde_json = "1"
 
-skar-client = "0.13"
-skar-net-types = "0.1"
+skar-client = "0.16"
+skar-net-types = "0.2"
 skar-format = "0.2"
 
 [build-dependencies]

examples/parquet-out/src/app.ts

@@ -1,24 +1,21 @@
 import { HypersyncClient } from "@envio-dev/hypersync-client";
-import fs from "node:fs";
 
 async function main() {
     // Create hypersync client using the mainnet hypersync endpoint
     const client = HypersyncClient.new({
-      url: "https://eth.hypersync.xyz"
+      url: "https://eth.hypersync.xyz",
     });
 
     // The query to run
     const query = {
         "fromBlock": 18500123,
-        "toBlock": 18550123,
-        "transactions": [{}],
+        "toBlock": 18501123,
+        "logs": [{
+          "address": ["0xdAC17F958D2ee523a2206206994597C13D831ec7"],
+          "topics": [["0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef"]],
+        }],
         // Select the fields we are interested in, notice topics are selected as topic0,1,2,3
         "fieldSelection": {
-          "block": [
-            "number",
-            "timestamp",
-            "hash"
-          ],
           "log": [
             "block_number",
             "log_index",
@@ -31,15 +28,6 @@ async function main() {
             "topic2",
             "topic3"
           ],
-          "transaction": [
-            "block_number",
-            "transaction_index",
-            "hash",
-            "from",
-            "to",
-            "value",
-            "input"
-          ]
         },
       };
 
@@ -51,6 +39,12 @@ async function main() {
       retry: true,
       /// Convert binary columns to prefixed hex format like '0x1ab..'
       hexOutput: true,
+      columnMapping: {
+        decodedLog: {
+          "value": "float64",
+        },
+      },
+      eventSignature: "Transfer(address indexed from, address indexed to, uint256 value)",
     });
 
     console.log("finished writing parquet");

index.d.ts

@@ -16,11 +16,14 @@ export interface ParquetConfig {
   retry?: boolean
   /** Define type mapping for output columns */
   columnMapping?: ColumnMapping
+  /** Event signature for decoding logs */
+  eventSignature?: string
 }
 export interface ColumnMapping {
   block?: Record<string, string>
   transaction?: Record<string, string>
   log?: Record<string, string>
+  decodedLog?: Record<string, string>
 }
 export interface StreamConfig {
   /** Block range size to use when making individual requests. */

src/config.rs

@@ -23,6 +23,9 @@ pub struct ParquetConfig {
     #[serde(skip_serializing_if = "Option::is_none")]
     /// Define type mapping for output columns
     pub column_mapping: Option<ColumnMapping>,
+    #[serde(skip_serializing_if = "Option::is_none")]
+    /// Event signature for decoding logs
+    pub event_signature: Option<String>,
 }
 
 #[napi(object)]
@@ -34,6 +37,8 @@ pub struct ColumnMapping {
     pub transaction: Option<HashMap<String, String>>,
     #[serde(skip_serializing_if = "Option::is_none")]
     pub log: Option<HashMap<String, String>>,
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub decoded_log: Option<HashMap<String, String>>,
 }
 
 impl ParquetConfig {