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

use dialtone_common::ap::ap_object::ApObject;
use dialtone_common::rest::ap_objects::ap_object_model::ApObjectOwnerData;
use sqlx::types::Json;
use sqlx::{Executor, Postgres};

pub async fn update_ap_object(
    exec: impl Executor<'_, Database = Postgres>,
    ap_object: &ApObject,
    owner_data: Option<&ApObjectOwnerData>,
) -> Result<(), sqlx::Error> {
    sqlx::query(
        r#"
        update ap_object
        set
            activity_pub_json = $1,
            owner_data = $2
        where
            id = $3
        returning id
        "#,
    )
    .bind(Json(ap_object))
    .bind(Json(owner_data))
    .bind(ap_object.id.as_ref())
    .fetch_one(exec)
    .await?;

    Ok(())
}