projections.rs 100.0%

11 of 11 lines run, 2 of 4 functions · run #6 on main · run missed

//! Projections (spec §9.3): tables kept from the ledger in the same
//! transaction as each append, and rebuilt from it by `spectra admin
//! rebuild`. Every table here must be a function of the events alone; the
//! test harness and `spectra admin check` hold them to it.

use crate::event::Event;
use sqlx::SqliteConnection;

/// The projection tables, in the order they are cleared and compared.
pub const TABLES: &[&str] = &["event_counts", "identities", "agents", "projects", "project_relations", "presence", "sessions"];

/// Apply one event to every projection.
pub async fn apply(conn: &mut SqliteConnection, e: &Event) -> sqlx::Result<()> {
    sqlx::query("INSERT INTO event_counts (kind, n) VALUES (?, 1) ON CONFLICT(kind) DO UPDATE SET n = n + 1")
        .bind(&e.kind)
        .execute(&mut *conn)
        .await?;
    crate::principals::project(conn, e).await?;
    crate::projects::project(conn, e).await?;
    crate::presence::project(conn, e).await?;
    Ok(())
}

1		//! Projections (spec §9.3): tables kept from the ledger in the same
2		//! transaction as each append, and rebuilt from it by `spectra admin
3		//! rebuild`. Every table here must be a function of the events alone; the
4		//! test harness and `spectra admin check` hold them to it.
5
6		use crate::event::Event;
7		use sqlx::SqliteConnection;
8
9		/// The projection tables, in the order they are cleared and compared.
10		pub const TABLES: &[&str] = &["event_counts", "identities", "agents", "projects", "project_relations", "presence", "sessions"];
11
12		/// Apply one event to every projection.
13	41790×	pub async fn apply(conn: &mut SqliteConnection, e: &Event) -> sqlx::Result<()> {
14	41790×	sqlx::query("INSERT INTO event_counts (kind, n) VALUES (?, 1) ON CONFLICT(kind) DO UPDATE SET n = n + 1")
15	41790×	.bind(&e.kind)
16	41790×	.execute(&mut *conn)
17	41790×	.await?;
18	41790×	crate::principals::project(conn, e).await?;
19	41790×	crate::projects::project(conn, e).await?;
20	41790×	crate::presence::project(conn, e).await?;
21	41790×	Ok(())
22	41790×	}

`/`	Search
`g` `c`	Code
`g` `h`	History
`g` `b`	Bookmarks
`g` `t`	Trust
`y`	Permalink to this state (files and trees)
`?`	This sheet

Coverage / crates/spectra-core/src/projections.rs 100.0%

Keyboard