feat: implement file-based chain cursor (txpipe#723)

trafkin · Dec 29, 2023 · b8114ae · b8114ae
1 parent cdaa596
commit b8114ae
Show file tree

Hide file tree

Showing 37 changed files with 581 additions and 626 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -30,9 +30,9 @@ pallas = "0.19.0"
 # pallas = { path = "../pallas/pallas" }
 # pallas = { git = "https://github.com/txpipe/pallas" }
 
-gasket = { version = "^0.4", features = ["derive"] }
+gasket = { version = "^0.6", features = ["derive"] }
 # gasket = { path = "../../construkts/gasket-rs/gasket", features = ["derive"] }
-# gasket = { git = "https://github.com/construkts/gasket-rs.git", features = ["derive"]  }
+# gasket = { git = "https://github.com/construkts/gasket-rs.git", features = ["derive"] }
 
 utxorpc = { version = "1.0.0-alpha.1" }
 hex = "0.4.3"

diff --git a/examples/file_cursor/.gitignore b/examples/file_cursor/.gitignore
@@ -0,0 +1 @@
+*.json
diff --git a/examples/file_cursor/daemon.toml b/examples/file_cursor/daemon.toml
@@ -0,0 +1,14 @@
+[source]
+type = "N2N"
+peers = ["relays-new.cardano-mainnet.iohk.io:3001"]
+
+[intersect]
+type = "Point"
+value = [4493860, "ce7f821d2140419fea1a7900cf71b0c0a0e94afbb1f814a6717cff071c3b6afc"]
+
+[cursor]
+type = "File"
+path = "my_cursor.json"
+
+[sink]
+type = "Stdout"
diff --git a/src/_utils/facade.rs b/src/_utils/facade.rs
diff --git a/src/_utils/retry.rs b/src/_utils/retry.rs