uf-valence-backend-sql 0.1.1

//! Table layout: `(id TEXT PRIMARY KEY, body JSON)`.

use serde_json::{Map, Value};

/// Primary key column name in SQL document tables.
pub const ID_COLUMN: &str = "id";
pub const BODY_COLUMN: &str = "body";

/// Edge junction table shared by SQL backends.
pub const EDGES_TABLE: &str = "valence_edges";

/// DDL for a Valence schemaless table.
pub fn ensure_table_ddl(table: &str) -> String {
    format!(
        "CREATE TABLE IF NOT EXISTS {table} (\
         {ID_COLUMN} TEXT PRIMARY KEY NOT NULL, \
         {BODY_COLUMN} TEXT NOT NULL DEFAULT '{{}}')"
    )
}

/// DDL for the shared edge junction table.
pub fn ensure_edges_table_ddl() -> String {
    format!(
        "CREATE TABLE IF NOT EXISTS {EDGES_TABLE} (\
         from_table TEXT NOT NULL, \
         from_id TEXT NOT NULL, \
         edge_type TEXT NOT NULL, \
         to_table TEXT NOT NULL, \
         to_id TEXT NOT NULL, \
         PRIMARY KEY (from_table, from_id, edge_type, to_table, to_id))"
    )
}

/// Ensure a table exists (caller runs DDL via sqlx).
pub fn ensure_table(table: &str) -> String {
    ensure_table_ddl(table)
}

/// Build a JSON row object from stored body + id.
pub fn row_from_body(table: &str, id: &str, body: Value) -> Value {
    let mut obj = body.as_object().cloned().unwrap_or_default();
    obj.insert(
        "id".into(),
        Value::Object(Map::from_iter([
            ("table".into(), Value::String(table.to_string())),
            ("id".into(), Value::String(id.to_string())),
        ])),
    );
    Value::Object(obj)
}

/// Merge content fields into body map for insert/update.
pub fn upsert_body_fields(content: Value) -> Map<String, Value> {
    content.as_object().cloned().unwrap_or_default()
}