enigmatick 0.4.1

Enigmatick is a social media platform that integrates with servers that implement the ActivityPub protocol (e.g., Mastodon)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33

use enigmatick::retriever::collection_fetcher;
use futures_lite::StreamExt;
use jdt_activity_pub::ApCollection;
use jdt_activity_pub::Collectible;

#[tokio::main]
pub async fn main() {
    let client = reqwest::Client::new();
    let collection = client
        //.get("https://mastodon.social/users/Gargron/outbox")
        .get("https://mastodon.social/users/belldotbz/statuses/114754909171422185/replies")
        //.get("https://enigmatick.social/user/jdt/outbox")
        .header("Content-Type", "application/activity+json")
        .send()
        .await
        .unwrap()
        .json::<ApCollection>()
        .await
        .unwrap();

    println!("Collection: {collection:?}");
    println!("Items count: {:?}", collection.items().map(|i| i.len()));
    println!("First: {:?}", collection.first);
    println!("Next: {:?}", collection.next);

    let mut stream = collection.stream_all(collection_fetcher());
    while let Some(item_result) = stream.next().await {
        match item_result {
            Ok(item) => println!("Got item: {item:?}"),
            Err(e) => eprintln!("Error fetching: {e}"),
        }
    }
}