From 32b4ce2eefb2f701d7d51278a310e98b36554c72 Mon Sep 17 00:00:00 2001 From: asonix Date: Sun, 17 May 2020 20:15:35 -0500 Subject: [PATCH] Add example of handling incoming JSON --- examples/handle_incoming.rs | 40 +++++++++++++++++++++++++++++++++++++ 1 file changed, 40 insertions(+) create mode 100644 examples/handle_incoming.rs diff --git a/examples/handle_incoming.rs b/examples/handle_incoming.rs new file mode 100644 index 0000000..cb2d784 --- /dev/null +++ b/examples/handle_incoming.rs @@ -0,0 +1,40 @@ +use activitystreams_new::{activity::ActorAndObject, prelude::*}; + +#[derive(Clone, Debug, serde::Deserialize, serde::Serialize)] +pub enum AcceptedTypes { + Accept, + Announce, + Create, + Delete, + Follow, + Reject, + Update, + Undo, +} + +pub type AcceptedActivity = ActorAndObject; + +pub fn handle_activity(activity: AcceptedActivity) -> Result<(), anyhow::Error> { + println!("Actor: {:?}", activity.actor()); + println!("Object: {:?}", activity.object()); + + match activity.kind() { + Some(AcceptedTypes::Accept) => println!("Accept"), + Some(AcceptedTypes::Announce) => println!("Announce"), + Some(AcceptedTypes::Create) => println!("Create"), + Some(AcceptedTypes::Delete) => println!("Delete"), + Some(AcceptedTypes::Follow) => println!("Follow"), + Some(AcceptedTypes::Reject) => println!("Reject"), + Some(AcceptedTypes::Update) => println!("Update"), + Some(AcceptedTypes::Undo) => println!("Undo"), + None => return Err(anyhow::Error::msg("No activity type provided")), + } + + Ok(()) +} + +static EXAMPLE_JSON: &str = r#"{"actor":"https://asonix.dog/users/asonix","object":"https://asonix.dog/users/asonix/posts/1","type":"Announce"}"#; + +fn main() -> Result<(), anyhow::Error> { + handle_activity(serde_json::from_str(EXAMPLE_JSON)?) +}