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

use dialtone_common::rest::actors::actor_model::OwnedActor;
use dialtone_sqlx::db::actor::fetch_owned::{
    fetch_default_owned_actor, fetch_owned_actor_by_acct, fetch_owned_actor_by_id,
};

use dialtone_test_util::create_actor::create_actor_tst_utl;
use dialtone_test_util::test_pg::test_pg;

#[tokio::test]
async fn fetch_owned_actor_by_id_test() {
    test_pg(move |pool| async move {
        let created_actor = create_actor_tst_utl(&pool, "testymctestfase", "example.com").await;

        let action = fetch_owned_actor_by_id(&pool, &created_actor.owned_actor.ap.id).await;
        assert_action_ok(action);
    })
    .await;
}

#[tokio::test]
async fn fetch_owned_actor_by_acct_test() {
    test_pg(move |pool| async move {
        let created_actor = create_actor_tst_utl(&pool, "testymctestfase", "example.com").await;

        let webfinger_acct = created_actor.owned_actor.jrd.unwrap().subject;
        let action = fetch_owned_actor_by_acct(&pool, &webfinger_acct).await;
        assert_action_ok(action);
    })
    .await;
}

#[tokio::test]
async fn fetch_default_owned_actor_test() {
    test_pg(move |pool| async move {
        let created_actor = create_actor_tst_utl(&pool, "testymctestfase", "example.com").await;

        let user_acct = created_actor.creating_user_acct;
        let action = fetch_default_owned_actor(&pool, &user_acct).await;
        assert_action_ok(action);
    })
    .await;
}

fn assert_action_ok(action: Result<Option<OwnedActor>, sqlx::Error>) -> OwnedActor {
    if action.is_err() {
        println!("{:?}", action.as_ref().err())
    }
    assert!(action.is_ok());
    action.unwrap().unwrap()
}