Merge pull request #94 from timfpark/main

Update firehose example to latest atrium-api library
sugyan · Jan 20, 2024 · 0978304 · 0978304
2 parents ce1f4cd + b6ddc9e
commit 0978304
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 4 deletions.
diff --git a/atrium-xrpc-server/Cargo.toml b/atrium-xrpc-server/Cargo.toml
@@ -6,7 +6,7 @@ edition = "2021"
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
-atrium-api = "0.13"
+atrium-api = "0.15"
 anyhow = "1.0.71"
 libipld-core = { version = "0.16.0", features = ["serde-codec"] }
 serde_ipld_dagcbor = "0.3.0"
diff --git a/examples/firehose/Cargo.toml b/examples/firehose/Cargo.toml
@@ -7,9 +7,9 @@ edition = "2021"
 
 [dependencies]
 atrium-xrpc-server = { path = "../../atrium-xrpc-server" }
-atrium-api = "0.13"
+atrium-api = "0.15"
 ciborium = "0.2.1"
 futures = "0.3.28"
 rs-car = "0.4.1"
 tokio = { version = "1.28.1", features = ["full"] }
-tokio-tungstenite = { version = "0.18.0", features = ["native-tls"] }
+tokio-tungstenite = { version = "0.21.0", features = ["native-tls"] }
diff --git a/examples/firehose/src/main.rs b/examples/firehose/src/main.rs
@@ -34,8 +34,15 @@ async fn process_message(message: &[u8]) -> Result<(), Box<dyn std::error::Error
                             {
                                 println!("{}: {}", value.created_at, value.text);
                             } else {
-                                // TODO
+                                println!("FAILED: could not deserialize post from item of length: {}", item.len());
+
                             }
+                        } else {
+                            println!(
+                                "FAILED: could not find item with operation cid {:?} out of {} items",
+                                op.cid,
+                                items.len()
+                            );
                         }
                     }
                 }