dialtone_sqlx 0.1.0

Dialtone SQLx Back-End
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

use dialtone_common::ap::ap_object::{ApObject, ApObjectType};
use dialtone_sqlx::db::ap_object::fetch::fetch_ap_object;

use dialtone_sqlx::db::ap_object::insert::insert_ap_object;
use dialtone_sqlx::db::ap_object::{ApObjectDbType, ApObjectVisibilityDbType};
use dialtone_test_util::create_site::create_site_tst_utl;
use dialtone_test_util::{test_action, test_pg};

#[tokio::test]
#[allow(non_snake_case)]
async fn GIVEN_ap_object_id_WHEN_fetch_ap_object_by_id_THEN_success() {
    test_pg::test_pg(move |pool| async move {
        // GIVEN
        let host_name = "example.net";
        create_site_tst_utl(&pool, host_name).await;
        let ap_object = ApObject {
            name: None,
            id: Some("https://example.net/pub/bar/this_is_a_post".to_string()),
            url: None,
            media_type: None,
            ap_type: Option::from(ApObjectType::Article),
            content: Some("<p>this is a post</p>".to_string()),
            summary: None,
            actor: None,
            attributed_to: None,
            to: None,
            cc: None,
            bto: None,
            bcc: None,
        };
        let action = insert_ap_object(
            &pool,
            host_name,
            &ap_object,
            None,
            ApObjectDbType::Article,
            None,
            ApObjectVisibilityDbType::Visible,
        )
        .await;
        test_action!(action);

        // WHEN
        let action = fetch_ap_object(&pool, ap_object.id.as_ref().unwrap().as_str()).await;
        test_action!(action);

        // THEN
        let fetched_result = action.unwrap();
        assert!(fetched_result.is_some());
        let fetched_ap_object = fetched_result.unwrap();
        assert_eq!(&ap_object.id, &fetched_ap_object.id);
        assert_eq!(ap_object.ap_type, fetched_ap_object.ap_type);
        assert_eq!(ap_object.content, fetched_ap_object.content);
    })
    .await;
}