deprecate PostStream, implmement generic handler for unsupported types

skystreamer/examples/stream_raw.rs

@@ -25,8 +25,8 @@ pub async fn main() -> Result<(), Box<dyn std::error::Error>> {
 
         // println!("{:?}", record);
 
-        if let skystreamer::types::commit::Record::Other(_) = record {
-            println!("{:?}", record);
+        if let skystreamer::types::commit::Record::Other(val) = record {
+            println!("{:?}", val);
         }
     }
 

skystreamer/src/stream.rs

@@ -6,14 +6,14 @@
 use crate::types::{commit, Post};
 use crate::Result;
 use futures::StreamExt;
-// a commit turns into a block of Posts
-// is there a way to turn a block of posts into a stream of individual posts?
 
+#[deprecated(note = "Please use [`EventStream`] instead")]
 pub struct PostStream {
     // inner: Box<dyn futures::Stream<Item = Post> + Unpin + Send>,
     subscription: crate::RepoSubscription,
 }
 
+#[allow(deprecated)]
 impl PostStream {
     pub async fn new(inner: crate::RepoSubscription) -> Self {
         PostStream {
@@ -50,6 +50,8 @@ impl PostStream {
 
 /// A stream of every event from the firehose.
 /// Replaces the old [`PostStream`] type.
+/// 
+/// This stream will yield every single event from the firehose, 
 pub struct EventStream {
     subscription: crate::RepoSubscription,
 }

skystreamer/src/types/commit.rs

@@ -14,7 +14,8 @@ pub enum Record {
     Repost(Box<RepostEvent>),
     ListItem(Box<ListItemEvent>),
     Profile(Box<Profile>),
-    Other(String),
+    // Other(Box<serde::de::value::>),
+    Other((Operation, Box<serde_json::Value>)),
 }
 
 impl Record {
@@ -105,7 +106,11 @@ impl Record {
 
             other => {
                 tracing::trace!("Unhandled operation: {:?}", other);
-                records.push(Record::Other(format!("{:?}", other)));
+                // todo: some kind of generic Serde value?
+                records.push(Record::Other(*Box::new((
+                    other.clone(),
+                    serde_ipld_dagcbor::from_reader(&mut item.as_slice())?,
+                ))));
             }
         }