use anyhow::Result;
use chrono::Utc;
use serde_json::json;
use sqlitegraph::GraphEntity;
use super::{
AtheneumGraph, EdgeType, OntologyClassInfo, OntologyPropertyInfo, ONTOLOGY_CLASS_KIND,
ONTOLOGY_PROPERTY_KIND,
};
impl AtheneumGraph {
pub fn define_class(&self, name: &str, description: Option<&str>) -> Result<i64> {
let existing = self.find_ontology_entity(ONTOLOGY_CLASS_KIND, name)?;
let data = json!({
"name": name,
"description": description,
"registered_at": Utc::now().to_rfc3339(),
});
if let Some(id) = existing {
self.update_entity_data(id, &data)?;
Ok(id)
} else {
let entity = GraphEntity {
id: 0,
kind: ONTOLOGY_CLASS_KIND.to_string(),
name: name.to_string(),
file_path: None,
data,
};
self.inner
.insert_entity(&entity)
.map_err(|e| anyhow::anyhow!("Failed to insert OntologyClass: {}", e))
}
}
pub fn define_property(
&self,
name: &str,
domain_class: &str,
range_class: &str,
description: Option<&str>,
) -> Result<i64> {
let existing = self.find_ontology_entity(ONTOLOGY_PROPERTY_KIND, name)?;
let data = json!({
"name": name,
"domain_class": domain_class,
"range_class": range_class,
"description": description,
"registered_at": Utc::now().to_rfc3339(),
});
if let Some(id) = existing {
self.update_entity_data(id, &data)?;
Ok(id)
} else {
let entity = GraphEntity {
id: 0,
kind: ONTOLOGY_PROPERTY_KIND.to_string(),
name: name.to_string(),
file_path: None,
data,
};
self.inner
.insert_entity(&entity)
.map_err(|e| anyhow::anyhow!("Failed to insert OntologyProperty: {}", e))
}
}
pub fn list_classes(&self) -> Result<Vec<OntologyClassInfo>> {
let entities = self.entities_by_kind(ONTOLOGY_CLASS_KIND)?;
Ok(entities
.into_iter()
.map(|e| OntologyClassInfo {
id: e.id,
name: e.name.clone(),
description: e
.data
.get("description")
.and_then(|v| v.as_str())
.map(str::to_string),
})
.collect())
}
pub fn list_properties(&self) -> Result<Vec<OntologyPropertyInfo>> {
let entities = self.entities_by_kind(ONTOLOGY_PROPERTY_KIND)?;
Ok(entities
.into_iter()
.map(|e| OntologyPropertyInfo {
id: e.id,
name: e.name.clone(),
domain_class: e
.data
.get("domain_class")
.and_then(|v| v.as_str())
.unwrap_or("ANY")
.to_string(),
range_class: e
.data
.get("range_class")
.and_then(|v| v.as_str())
.unwrap_or("ANY")
.to_string(),
description: e
.data
.get("description")
.and_then(|v| v.as_str())
.map(str::to_string),
})
.collect())
}
pub fn validate_edge(&self, from_kind: &str, to_kind: &str, edge_type: &str) -> Result<bool> {
let props = self.list_properties()?;
let Some(prop) = props.iter().find(|p| p.name == edge_type) else {
return Ok(true);
};
let domain_ok = prop.domain_class == "ANY" || prop.domain_class == from_kind;
let range_ok = prop.range_class == "ANY" || prop.range_class == to_kind;
Ok(domain_ok && range_ok)
}
pub fn seed_standard_ontology(&self) -> Result<()> {
const STANDARD: &[(&str, &str)] = &[
("Agent", "An autonomous participant"),
("Task", "A unit of work"),
("Event", "Something that happened, recorded for provenance"),
("ToolCall", "An action taken by an agent"),
("Knowledge", "Persistent contextual information"),
("Discovery", "A dynamic insight found by an agent"),
("Handoff", "Context transfer between agents"),
("WikiPage", "A static knowledge document"),
("JournalSection", "An entry in a Logseq journal"),
("ReasoningLog", "A stream of thought from an agent"),
("Session", "A single invocation of a development tool"),
("Commit", "A git commit recorded as evidence"),
("TestRun", "A test execution result"),
("EventLog", "An append-only evidence event"),
("Project", "A workspace or product scope"),
(
"CodeSymbol",
"A source-level symbol such as a function, type, or module",
),
("File", "A source, document, or generated file"),
("Skill", "An agent instruction pack or capability"),
(
"Failure",
"A failing test, bug, regression, or observed defect",
),
("Memory", "Stable facts, preferences, and conventions"),
("QueryTrace", "A trace record of a search/navigation query"),
];
for (name, description) in STANDARD {
self.define_class(name, Some(description))?;
}
const STANDARD_PROPERTIES: &[(EdgeType, &str, &str, &str)] = &[
(
EdgeType::PerformedBy,
"ANY",
"Agent",
"Action or event was performed by an agent",
),
(
EdgeType::ProducedBy,
"ANY",
"QueryTrace",
"Entity was produced as a result of a query trace",
),
(
EdgeType::AssignedTo,
"Task",
"Agent",
"Task is assigned to an agent",
),
(
EdgeType::Called,
"ReasoningLog",
"ToolCall",
"Reasoning log called a tool",
),
(
EdgeType::Calls,
"CodeSymbol",
"CodeSymbol",
"Code symbol calls another code symbol",
),
(
EdgeType::Accessed,
"Session",
"File",
"Session accessed a file or path while gathering context",
),
(
EdgeType::Modified,
"ToolCall",
"ANY",
"Tool call modified a target entity",
),
(
EdgeType::VerifiedBy,
"ANY",
"TestRun",
"Entity or session was verified by a test run",
),
(
EdgeType::CausedBy,
"ANY",
"ANY",
"Entity or event was caused by another entity",
),
(
EdgeType::LedTo,
"ANY",
"ANY",
"A prior decision (ReasoningLog or Discovery) led to this one; inverse of caused_by, stored for cheap outward thread walks",
),
(
EdgeType::Created,
"ANY",
"ANY",
"Entity created another entity",
),
(
EdgeType::RelatedTo,
"ANY",
"ANY",
"Loose relationship retained for compatibility",
),
(
EdgeType::Mentions,
"ANY",
"ANY",
"Entity text mentions another entity",
),
(
EdgeType::Wikilink,
"WikiPage",
"WikiPage",
"Wiki page links to another wiki page",
),
(
EdgeType::Implements,
"CodeSymbol",
"ANY",
"Code symbol implements a requirement, interface, or design",
),
(
EdgeType::DependsOn,
"ANY",
"ANY",
"Entity depends on another entity",
),
(
EdgeType::TestedBy,
"ANY",
"TestRun",
"Entity is tested by a test run or test target",
),
(
EdgeType::FixedBy,
"Failure",
"ANY",
"Failure was fixed by another entity",
),
(
EdgeType::RegressedBy,
"ANY",
"ANY",
"Entity regressed because of another entity",
),
(
EdgeType::ObservedIn,
"ANY",
"Session",
"Entity was observed in a session or run",
),
(
EdgeType::BelongsToProject,
"ANY",
"Project",
"Entity belongs to a project scope",
),
(
EdgeType::SimilarFailure,
"Failure",
"Failure",
"Failure resembles another failure",
),
(
EdgeType::RequiresSkill,
"ANY",
"Skill",
"Task or workflow requires a skill",
),
(
EdgeType::HandledByTool,
"ANY",
"ToolCall",
"Entity or task was handled by a tool",
),
(
EdgeType::Explains,
"WikiPage",
"CodeSymbol",
"Wiki page explains a code symbol or concept",
),
(
EdgeType::DerivedFrom,
"ANY",
"ANY",
"Entity was derived from another entity",
),
(
EdgeType::SupersededBy,
"Memory",
"Memory",
"Memory entry was superseded by a newer or canonical memory entry",
),
(
EdgeType::ConsolidatedFrom,
"Memory",
"Memory",
"Memory entry was consolidated into another memory entry",
),
(
EdgeType::AttachedTo,
"Memory",
"Concept",
"Memory is attached to a concept",
),
(
EdgeType::HasMemory,
"Concept",
"Memory",
"Concept has an attached memory",
),
(
EdgeType::Verifies,
"TestRun",
"ANY",
"Test run verifies an entity or session",
),
(
EdgeType::Supersedes,
"Memory",
"Memory",
"Memory entry supersedes an older memory entry",
),
];
for (edge_type, domain, range, description) in STANDARD_PROPERTIES {
self.define_property(edge_type.as_str(), domain, range, Some(description))?;
}
Ok(())
}
pub(super) fn find_ontology_entity(&self, kind: &str, name: &str) -> Result<Option<i64>> {
self.find_entity_id_by_kind_and_name(kind, name)
}
}