Struct ConeStorage 

pub struct ConeStorage { /* private fields */ }

Storage layer for cone configurations

Implementations

impl ConeStorage

pub async fn new( config: ConeStorageConfig, arbor: Arc<ArborStorage>, ) -> Result<Self, ConeError>

Create a new cone storage instance with a shared Arbor storage

pub fn arbor(&self) -> &ArborStorage

Get access to the underlying arbor storage

pub async fn cone_create( &self, name: String, model_id: String, system_prompt: Option<String>, metadata: Option<Value>, ) -> Result<ConeConfig, ConeError>

Create a new cone with a new conversation tree

If a cone with the given name already exists, automatically appends #<uuid> to make it unique. For example, “assistant” becomes “assistant#550e8400…”

pub async fn resolve_cone_identifier( &self, identifier: &ConeIdentifier, ) -> Result<ConeId, ConeError>

Resolve a cone identifier to a ConeId

For name lookups, supports partial matching on the name portion before ‘#’:

• “assistant” matches “assistant” or “assistant#550e8400-…”
• “assistant#550e” matches “assistant#550e8400-…”

Fails if the pattern matches multiple cones (ambiguous).

pub async fn cone_get(&self, cone_id: &ConeId) -> Result<ConeConfig, ConeError>

Get a cone by ID

pub async fn cone_get_by_identifier( &self, identifier: &ConeIdentifier, ) -> Result<ConeConfig, ConeError>

Get a cone by identifier (name or UUID)

pub async fn cone_list(&self) -> Result<Vec<ConeInfo>, ConeError>

List all cones

pub async fn cone_update_head( &self, cone_id: &ConeId, new_head: NodeId, ) -> Result<(), ConeError>

Update cone’s canonical head

pub async fn cone_update( &self, cone_id: &ConeId, name: Option<String>, model_id: Option<String>, system_prompt: Option<Option<String>>, metadata: Option<Value>, ) -> Result<(), ConeError>

Update cone configuration

pub async fn cone_delete(&self, cone_id: &ConeId) -> Result<(), ConeError>

Delete an cone (does not delete the tree)

pub async fn message_create( &self, cone_id: &ConeId, role: MessageRole, content: String, model_id: Option<String>, input_tokens: Option<i64>, output_tokens: Option<i64>, ) -> Result<Message, ConeError>

Create a message and return its ID

pub async fn message_create_ephemeral( &self, cone_id: &ConeId, role: MessageRole, content: String, model_id: Option<String>, input_tokens: Option<i64>, output_tokens: Option<i64>, ) -> Result<Message, ConeError>

Create an ephemeral message (marked for deletion) and return it

pub async fn message_get( &self, message_id: &MessageId, ) -> Result<Message, ConeError>

Get a message by ID

pub async fn resolve_message_handle( &self, identifier: &str, ) -> Result<Message, ConeError>

Resolve a message handle identifier to a Message Handle format: “msg-{message_id}:{role}:{name}”

pub fn message_to_handle(message: &Message, name: &str) -> Handle

Create a handle for a message

Format: {plugin_id}@1.0.0::chat:msg-{id}:{role}:{name} Uses ConeHandle enum for type-safe handle creation.