use activitystreams_new::{ collection::OrderedCollection, object::{ApObject, Page}, prelude::*, traits::Extends, }; use anyhow::Error; fn main() -> Result<(), Error> { let collection_json = r#"{ "type": "OrderedCollection", "id": "http://lemmy_alpha:8540/federation/c/main", "context": "https://www.w3.org/ns/activitystreams", "items": [ { "type": "Page", "id": "http://lemmy_alpha:8540/federation/post/2", "attributedTo": "http://lemmy_alpha:8540/federation/u/2", "content": "test", "context": "https://www.w3.org/ns/activitystreams", "name": "test", "published": "2020-03-13T00:14:41.188634+00:00" }, { "type": "Page", "id": "http://lemmy_alpha:8540/federation/post/1", "attributedTo": "http://lemmy_alpha:8540/federation/u/2", "context": "https://www.w3.org/ns/activitystreams", "name": "test", "published": "2020-03-13T00:13:56.311479+00:00" } ], "totalItems": 2 }"#; let page_json = r#"{ "type": "Page", "id": "http://lemmy_alpha:8540/federation/post/2", "attributedTo": "http://lemmy_alpha:8540/federation/u/2", "content": "test", "name": "test", "published": "2020-03-13T00:14:41.188634+00:00" }"#; let page: ApObject = serde_json::from_str(page_json)?; println!("{:#?}", page); let mut collection: ApObject = serde_json::from_str(collection_json)?; println!("{:#?}", collection); let v: Vec> = collection .items() .clone() .many() .into_iter() .flatten() .filter_map(|any_object| any_object.object()) .map(|object| object.solidify().and_then(|o| o.extend())) .collect::, _>>()?; println!("{:#?}", v); let v = v .into_iter() .map(|o| o.retracts().and_then(|o| o.into_generic())) .collect::, _>>()?; collection.set_many_items(v); Ok(()) }