spools 0.6.1

Content scraping library for Instagram's Threads
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
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93

use crate::{Author, Threads};

#[tokio::test]
async fn new_client() {
    let client = Threads::new();
    assert!(client.is_ok());
}

#[tokio::test]
async fn fetch_existing_user() {
    let client = Threads::new().unwrap();
    let resp = client.fetch_user("zuck").await;
    println!("{:#?}", resp);
    assert!(resp.is_ok());

    let user = resp.unwrap();
    assert_eq!(user.id, 314216);
    assert_eq!(user.verified, true);
}

#[tokio::test]
async fn fetch_nonexistent_user() {
    let client = Threads::new().unwrap();
    let resp = client.fetch_user("cant-have-dashes").await;
    assert!(resp.is_err());
}

#[tokio::test]
async fn fetch_existing_post() {
    let client = Threads::new().unwrap();
    let resp = client.fetch_post("C2QBoRaRmR1").await;
    println!("{:#?}", resp);
    assert!(resp.is_ok());

    let post = resp.unwrap();
    println!("{:#?}", post);
    assert_eq!(post.id, "3283131293873103989");
    assert_eq!(post.author.username, "zuck");

    let mut reply_scan: Vec<Author> = vec![];
    for reply in post.replies {
        if reply.author.username == "zuck" {
            reply_scan.push(reply.author);
        }
    }

    assert!(reply_scan.len() > 0);
}

#[tokio::test]
async fn fetch_nonexistent_post() {
    let client = Threads::new().unwrap();
    let resp = client.fetch_post("foo").await;
    assert!(resp.is_err());
}

#[tokio::test]
async fn convert_to_post() {
    let client = Threads::new().unwrap();
    let child_resp = client.fetch_post("C6brVPxR1fZ").await;
    println!("{:#?}", child_resp);
    assert!(child_resp.is_ok());

    let child_post = child_resp.unwrap();
    println!("{:#?}", child_post);

    let resp = child_post.parents[0].to_post().await;
    println!("{:#?}", resp);
    assert!(resp.is_ok());

    let post = resp.unwrap();
    assert_eq!(post.id, "3358445536292748283");
    assert_eq!(post.author.username, "metaquest");
}

#[tokio::test]
async fn convert_to_user() {
    let client = Threads::new().unwrap();
    let post_resp = client.fetch_post("C6brVPxR1fZ").await;
    println!("{:#?}", post_resp);
    assert!(post_resp.is_ok());

    let post = post_resp.unwrap();
    println!("{:#?}", post);

    let resp = post.author.to_user().await;
    println!("{:#?}", resp);
    assert!(resp.is_ok());

    let user = resp.unwrap();
    assert_eq!(user.id, 314216);
    assert_eq!(user.verified, true);
}