sofie-http 0.2.0

The HTTP server, areas, routes and the handler model.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use serde_json::{Value, json};
use sofie_core::Result;
use sofie_db::{Aggregate, Read, history_of};

/// Empty for an aggregate that does not record its changes.
pub(super) async fn changes<R: Aggregate>(read: &Read, record: &R) -> Result<Value> {
    let changes = history_of::<R>(read, record.id()).await?;
    Ok(changes
        .into_iter()
        .map(|change| {
            json!({
                "change": format!("{:?}", change.kind),
                "fields": change.fields.join(", "),
                "actor": change.actor.map(|actor| actor.to_string()),
                "action": change.action,
                "at": change.at,
            })
        })
        .collect())
}