projects.rs 100.0%

32 of 32 lines run, 7 of 14 functions · run #36 on main · run missed

//! Projects (spec §23.1): any kind of work a group of agents shares. A
//! project has a name, a description, and optionally a folder and a link;
//! Spectra records where the folder is and reads nothing inside it. The
//! owner links projects (`project.linked`: one depends on another), which
//! is what `to: "downstream"` follows.

use crate::event::Event;
use anyhow::{Context, Result};
use serde_json::Value as Json;
use sqlx::SqliteConnection;
use std::path::Path;

/// Kinds of event the owner signs about projects.
pub const KINDS: &[&str] = &["project.added", "project.linked", "project.unlinked"];

/// A project's name from a folder: its name, lower-cased, made valid.
pub fn default_name(path: &Path) -> Result<String> {
    let base = path.canonicalize()?.file_name().and_then(|n| n.to_str()).map(str::to_lowercase).context("the path has no name")?;
    Ok(base.chars().map(|c| if c.is_ascii_alphanumeric() || c == '-' { c } else { '-' }).collect())
}

/// Apply a project event to the tables.
pub async fn project(conn: &mut SqliteConnection, e: &Event) -> sqlx::Result<()> {
    let p = e.json();
    let s = |k: &str| p.get(k).and_then(Json::as_str).map(String::from);
    match e.kind.as_str() {
        "project.added" => {
            let Some(name) = s("name") else { return Ok(()) };
            sqlx::query("INSERT OR REPLACE INTO projects (name, path, description, url, seq) VALUES (?, ?, ?, ?, ?)")
                .bind(&name)
                .bind(s("path").filter(|p| !p.is_empty()))
                .bind(s("description").unwrap_or_default())
                .bind(s("url"))
                .bind(e.seq as i64)
                .execute(&mut *conn)
                .await?;
        }
        "project.linked" | "project.unlinked" => {
            let (Some(project), Some(on)) = (s("project"), s("depends_on")) else { return Ok(()) };
            let sql = if e.kind == "project.linked" {
                "INSERT OR IGNORE INTO project_relations (project, depends_on) VALUES (?, ?)"
            } else {
                "DELETE FROM project_relations WHERE project = ? AND depends_on = ?"
            };
            sqlx::query(sql).bind(project).bind(on).execute(&mut *conn).await?;
        }
        _ => {}
    }
    Ok(())
}

1		//! Projects (spec §23.1): any kind of work a group of agents shares. A
2		//! project has a name, a description, and optionally a folder and a link;
3		//! Spectra records where the folder is and reads nothing inside it. The
4		//! owner links projects (`project.linked`: one depends on another), which
5		//! is what `to: "downstream"` follows.
6
7		use crate::event::Event;
8		use anyhow::{Context, Result};
9		use serde_json::Value as Json;
10		use sqlx::SqliteConnection;
11		use std::path::Path;
12
13		/// Kinds of event the owner signs about projects.
14		pub const KINDS: &[&str] = &["project.added", "project.linked", "project.unlinked"];
15
16		/// A project's name from a folder: its name, lower-cased, made valid.
17	25×	pub fn default_name(path: &Path) -> Result<String> {
18	25×	let base = path.canonicalize()?.file_name().and_then(\|n\| n.to_str()).map(str::to_lowercase).context("the path has no name")?;
19	146×	Ok(base.chars().map(\|c\| if c.is_ascii_alphanumeric() \|\| c == '-' { c } else { '-' }).collect())
20	25×	}
21
22		/// Apply a project event to the tables.
23	42882×	pub async fn project(conn: &mut SqliteConnection, e: &Event) -> sqlx::Result<()> {
24	42882×	let p = e.json();
25	42882×	let s = \|k: &str\| p.get(k).and_then(Json::as_str).map(String::from);
26	42882×	match e.kind.as_str() {
27	42882×	"project.added" => {
28	3566×	let Some(name) = s("name") else { return Ok(()) };
29	54×	sqlx::query("INSERT OR REPLACE INTO projects (name, path, description, url, seq) VALUES (?, ?, ?, ?, ?)")
30	54×	.bind(&name)
31	54×	.bind(s("path").filter(\|p\| !p.is_empty()))
32	54×	.bind(s("description").unwrap_or_default())
33	54×	.bind(s("url"))
34	54×	.bind(e.seq as i64)
35	54×	.execute(&mut *conn)
36	54×	.await?;
37		}
38	39316×	"project.linked" \| "project.unlinked" => {
39	4×	let (Some(project), Some(on)) = (s("project"), s("depends_on")) else { return Ok(()) };
40	4×	let sql = if e.kind == "project.linked" {
41	2×	"INSERT OR IGNORE INTO project_relations (project, depends_on) VALUES (?, ?)"
42		} else {
43	2×	"DELETE FROM project_relations WHERE project = ? AND depends_on = ?"
44		};
45	4×	sqlx::query(sql).bind(project).bind(on).execute(&mut *conn).await?;
46		}
47	39312×	_ => {}
48		}
49	39370×	Ok(())
50	42882×	}

`/`	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/projects.rs 100.0%

Keyboard