use most recent process_lib

kinode-dao · Dec 20, 2024 · fee5de2 · fee5de2
1 parent d069e7e
commit fee5de2
Show file tree

Hide file tree

Showing 40 changed files with 49 additions and 49 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/kinode/packages/app-store/Cargo.lock b/kinode/packages/app-store/Cargo.lock
diff --git a/kinode/packages/app-store/app-store/Cargo.toml b/kinode/packages/app-store/app-store/Cargo.toml
@@ -11,7 +11,7 @@ alloy-primitives = "0.8.15"
 alloy-sol-types = "0.8.15"
 anyhow = "1.0"
 bincode = "1.3.3"
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 process_macros = "0.1"
 rand = "0.8"
 serde = { version = "1.0", features = ["derive"] }

diff --git a/kinode/packages/app-store/chain/Cargo.toml b/kinode/packages/app-store/chain/Cargo.toml
@@ -11,7 +11,7 @@ alloy-primitives = "0.8.15"
 alloy-sol-types = "0.8.15"
 anyhow = "1.0"
 bincode = "1.3.3"
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 process_macros = "0.1"
 rand = "0.8"
 serde = { version = "1.0", features = ["derive"] }

diff --git a/kinode/packages/app-store/chain/src/lib.rs b/kinode/packages/app-store/chain/src/lib.rs
@@ -127,7 +127,7 @@ impl DB {
     }
 
     pub fn set_last_saved_block(&self, block: u64) -> anyhow::Result<()> {
-        let query = "INSERT INTO meta (key, value) VALUES ('last_saved_block', ?) 
+        let query = "INSERT INTO meta (key, value) VALUES ('last_saved_block', ?)
             ON CONFLICT(key) DO UPDATE SET value=excluded.value";
         let params = vec![block.to_string().into()];
         self.inner.write(query.into(), params, None)?;
@@ -147,12 +147,12 @@ impl DB {
 
         let query = "INSERT INTO listings (package_name, publisher_node, tba, metadata_uri, metadata_hash, metadata_json, auto_update, block)
             VALUES (?, ?, ?, ?, ?, ?, ?, ?)
-            ON CONFLICT(package_name, publisher_node) 
-            DO UPDATE SET 
-              tba=excluded.tba, 
-              metadata_uri=excluded.metadata_uri, 
-              metadata_hash=excluded.metadata_hash, 
-              metadata_json=excluded.metadata_json, 
+            ON CONFLICT(package_name, publisher_node)
+            DO UPDATE SET
+              tba=excluded.tba,
+              metadata_uri=excluded.metadata_uri,
+              metadata_hash=excluded.metadata_hash,
+              metadata_json=excluded.metadata_json,
               auto_update=excluded.auto_update,
               block=excluded.block";
         let params = vec![
@@ -240,7 +240,7 @@ impl DB {
         block_number: u64,
     ) -> anyhow::Result<Vec<(PackageId, PackageListing)>> {
         let query = "SELECT package_name, publisher_node, tba, metadata_uri, metadata_hash, metadata_json, auto_update, block
-                     FROM listings 
+                     FROM listings
                      WHERE block > ?";
         let params = vec![block_number.into()];
         let rows = self.inner.read(query.into(), params)?;
@@ -421,7 +421,7 @@ fn handle_message(our: &Address, state: &mut State, message: &Message) -> anyhow
                     state
                         .kimap
                         .provider
-                        .subscribe_loop(1, app_store_filter(state));
+                        .subscribe_loop(1, app_store_filter(state), 1, 0);
                 }
             }
             Req::Request(chains) => {
@@ -761,7 +761,7 @@ pub fn fetch_and_subscribe_logs(our: &Address, state: &mut State, last_saved_blo
     let filter = app_store_filter(state);
     // get past logs, subscribe to new ones.
     // subscribe first so we don't miss any logs
-    state.kimap.provider.subscribe_loop(1, filter.clone());
+    state.kimap.provider.subscribe_loop(1, filter.clone(), 1, 0);
     // println!("fetching old logs from block {last_saved_block}");
     for log in fetch_logs(&state.kimap.provider, &filter.from_block(last_saved_block)) {
         if let Err(e) = handle_eth_log(our, state, log, true) {

diff --git a/kinode/packages/app-store/download/Cargo.toml b/kinode/packages/app-store/download/Cargo.toml
@@ -8,7 +8,7 @@ simulation-mode = []
 
 [dependencies]
 anyhow = "1.0"
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 process_macros = "0.1"
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"

diff --git a/kinode/packages/app-store/downloads/Cargo.toml b/kinode/packages/app-store/downloads/Cargo.toml
@@ -8,7 +8,7 @@ simulation-mode = []
 
 [dependencies]
 anyhow = "1.0"
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 process_macros = "0.1"
 rand = "0.8"
 serde = { version = "1.0", features = ["derive"] }

diff --git a/kinode/packages/app-store/ft-worker/Cargo.toml b/kinode/packages/app-store/ft-worker/Cargo.toml
@@ -9,7 +9,7 @@ simulation-mode = []
 [dependencies]
 anyhow = "1.0"
 bincode = "1.3.3"
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 process_macros = "0.1"
 rand = "0.8"
 serde = { version = "1.0", features = ["derive"] }

diff --git a/kinode/packages/app-store/install/Cargo.toml b/kinode/packages/app-store/install/Cargo.toml
@@ -8,7 +8,7 @@ simulation-mode = []
 
 [dependencies]
 anyhow = "1.0"
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 process_macros = "0.1"
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"

diff --git a/kinode/packages/app-store/uninstall/Cargo.toml b/kinode/packages/app-store/uninstall/Cargo.toml
@@ -8,7 +8,7 @@ simulation-mode = []
 
 [dependencies]
 anyhow = "1.0"
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 process_macros = "0.1"
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"

diff --git a/kinode/packages/chess/Cargo.lock b/kinode/packages/chess/Cargo.lock
diff --git a/kinode/packages/chess/chess/Cargo.toml b/kinode/packages/chess/chess/Cargo.toml
@@ -9,7 +9,7 @@ simulation-mode = []
 [dependencies]
 anyhow = "1.0"
 bincode = "1.3.3"
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 pleco = "0.5"
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"

diff --git a/kinode/packages/contacts/Cargo.lock b/kinode/packages/contacts/Cargo.lock
diff --git a/kinode/packages/contacts/contacts/Cargo.toml b/kinode/packages/contacts/contacts/Cargo.toml
@@ -7,7 +7,7 @@ edition = "2021"
 simulation-mode = []
 
 [dependencies]
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 process_macros = "0.1"
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"

diff --git a/kinode/packages/contacts/get-names/Cargo.toml b/kinode/packages/contacts/get-names/Cargo.toml
@@ -6,7 +6,7 @@ publish = false
 
 [dependencies]
 anyhow = "1.0"
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 process_macros = "0.1"
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"

diff --git a/kinode/packages/homepage/Cargo.lock b/kinode/packages/homepage/Cargo.lock
diff --git a/kinode/packages/homepage/homepage/Cargo.toml b/kinode/packages/homepage/homepage/Cargo.toml
@@ -9,7 +9,7 @@ simulation-mode = []
 [dependencies]
 anyhow = "1.0"
 bincode = "1.3.3"
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 wit-bindgen = "0.36.0"

diff --git a/kinode/packages/kns-indexer/Cargo.lock b/kinode/packages/kns-indexer/Cargo.lock
diff --git a/kinode/packages/kns-indexer/get-block/Cargo.toml b/kinode/packages/kns-indexer/get-block/Cargo.toml
@@ -7,7 +7,7 @@ edition = "2021"
 simulation-mode = []
 
 [dependencies]
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 wit-bindgen = "0.36.0"

diff --git a/kinode/packages/kns-indexer/kns-indexer/Cargo.toml b/kinode/packages/kns-indexer/kns-indexer/Cargo.toml
@@ -11,7 +11,7 @@ anyhow = "1.0"
 alloy-primitives = "0.8.15"
 alloy-sol-types = "0.8.15"
 hex = "0.4.3"
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 process_macros = "0.1"
 rmp-serde = "1.1.2"
 serde = { version = "1.0", features = ["derive"] }

diff --git a/kinode/packages/kns-indexer/node-info/Cargo.toml b/kinode/packages/kns-indexer/node-info/Cargo.toml
@@ -7,7 +7,7 @@ edition = "2021"
 simulation-mode = []
 
 [dependencies]
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 process_macros = "0.1"

diff --git a/kinode/packages/kns-indexer/reset/Cargo.toml b/kinode/packages/kns-indexer/reset/Cargo.toml
@@ -7,7 +7,7 @@ edition = "2021"
 simulation-mode = []
 
 [dependencies]
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 process_macros = "0.1"

diff --git a/kinode/packages/settings/Cargo.lock b/kinode/packages/settings/Cargo.lock
diff --git a/kinode/packages/settings/settings/Cargo.toml b/kinode/packages/settings/settings/Cargo.toml
@@ -10,7 +10,7 @@ simulation-mode = []
 anyhow = "1.0"
 base64 = "0.22.0"
 bincode = "1.3.3"
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 rmp-serde = "1.2.0"
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"

diff --git a/kinode/packages/terminal/Cargo.lock b/kinode/packages/terminal/Cargo.lock
diff --git a/kinode/packages/terminal/alias/Cargo.toml b/kinode/packages/terminal/alias/Cargo.toml
@@ -8,7 +8,7 @@ simulation-mode = []
 
 [dependencies]
 anyhow = "1.0"
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 wit-bindgen = "0.36.0"

diff --git a/kinode/packages/terminal/cat/Cargo.toml b/kinode/packages/terminal/cat/Cargo.toml
@@ -8,7 +8,7 @@ simulation-mode = []
 
 [dependencies]
 anyhow = "1.0"
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 wit-bindgen = "0.36.0"

diff --git a/kinode/packages/terminal/echo/Cargo.toml b/kinode/packages/terminal/echo/Cargo.toml
@@ -7,7 +7,7 @@ edition = "2021"
 simulation-mode = []
 
 [dependencies]
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 wit-bindgen = "0.36.0"
 
 [lib]

diff --git a/kinode/packages/terminal/help/Cargo.toml b/kinode/packages/terminal/help/Cargo.toml
@@ -7,7 +7,7 @@ edition = "2021"
 simulation-mode = []
 
 [dependencies]
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 wit-bindgen = "0.36.0"
 
 [lib]

diff --git a/kinode/packages/terminal/hi/Cargo.toml b/kinode/packages/terminal/hi/Cargo.toml
@@ -7,7 +7,7 @@ edition = "2021"
 simulation-mode = []
 
 [dependencies]
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 wit-bindgen = "0.36.0"

diff --git a/kinode/packages/terminal/kfetch/Cargo.toml b/kinode/packages/terminal/kfetch/Cargo.toml
@@ -8,7 +8,7 @@ simulation-mode = []
 
 [dependencies]
 anyhow = "1.0"
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 rmp-serde = "1.1.2"
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"

diff --git a/kinode/packages/terminal/kill/Cargo.toml b/kinode/packages/terminal/kill/Cargo.toml
@@ -8,7 +8,7 @@ simulation-mode = []
 
 [dependencies]
 anyhow = "1.0"
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 wit-bindgen = "0.36.0"

diff --git a/kinode/packages/terminal/m/Cargo.toml b/kinode/packages/terminal/m/Cargo.toml
@@ -9,7 +9,7 @@ simulation-mode = []
 [dependencies]
 anyhow = "1.0"
 clap = "4.4"
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 regex = "1.10.3"
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"

diff --git a/kinode/packages/terminal/net-diagnostics/Cargo.toml b/kinode/packages/terminal/net-diagnostics/Cargo.toml
@@ -7,7 +7,7 @@ edition = "2021"
 simulation-mode = []
 
 [dependencies]
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 rmp-serde = "1.1.2"
 serde = { version = "1.0", features = ["derive"] }
 wit-bindgen = "0.36.0"

diff --git a/kinode/packages/terminal/peer/Cargo.toml b/kinode/packages/terminal/peer/Cargo.toml
@@ -7,7 +7,7 @@ edition = "2021"
 simulation-mode = []
 
 [dependencies]
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 rmp-serde = "1.1.2"
 serde = { version = "1.0", features = ["derive"] }
 wit-bindgen = "0.36.0"

diff --git a/kinode/packages/terminal/peers/Cargo.toml b/kinode/packages/terminal/peers/Cargo.toml
@@ -7,7 +7,7 @@ edition = "2021"
 simulation-mode = []
 
 [dependencies]
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 rmp-serde = "1.1.2"
 serde = { version = "1.0", features = ["derive"] }
 wit-bindgen = "0.36.0"

diff --git a/kinode/packages/terminal/terminal/Cargo.toml b/kinode/packages/terminal/terminal/Cargo.toml
@@ -9,7 +9,7 @@ simulation-mode = []
 [dependencies]
 anyhow = "1.0"
 bincode = "1.3.3"
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 rand = "0.8"
 regex = "1.10.3"
 serde = { version = "1.0", features = ["derive"] }

diff --git a/kinode/packages/terminal/top/Cargo.toml b/kinode/packages/terminal/top/Cargo.toml
@@ -9,7 +9,7 @@ simulation-mode = []
 [dependencies]
 anyhow = "1.0"
 clap = "4.4"
-kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "d97e012" }
+kinode_process_lib = { git = "https://github.com/kinode-dao/process_lib", rev = "ea8490a" }
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 wit-bindgen = "0.36.0"

diff --git a/kinode/packages/tester/Cargo.lock b/kinode/packages/tester/Cargo.lock