Struct ClaudeCodeStorage 

pub struct ClaudeCodeStorage { /* private fields */ }

Storage layer for ClaudeCode sessions

Implementations

impl ClaudeCodeStorage

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

Create a new ClaudeCode storage instance with a shared Arbor storage

pub fn arbor(&self) -> &ArborStorage

Get access to the underlying arbor storage

pub async fn session_create( &self, name: String, working_dir: String, model: Model, system_prompt: Option<String>, mcp_config: Option<Value>, loopback_enabled: bool, metadata: Option<Value>, ) -> Result<ClaudeCodeConfig, ClaudeCodeError>

Create a new ClaudeCode session with a new conversation tree

pub async fn session_get( &self, session_id: &ClaudeCodeId, ) -> Result<ClaudeCodeConfig, ClaudeCodeError>

Get a session by ID

pub async fn session_get_by_name( &self, name: &str, ) -> Result<ClaudeCodeConfig, ClaudeCodeError>

Get a session by name (supports partial matching)

pub async fn session_list(&self) -> Result<Vec<ClaudeCodeInfo>, ClaudeCodeError>

List all sessions

pub async fn session_update_head( &self, session_id: &ClaudeCodeId, new_head: NodeId, claude_session_id: Option<String>, ) -> Result<(), ClaudeCodeError>

Update session’s canonical head and optionally the Claude session ID

pub async fn session_update( &self, session_id: &ClaudeCodeId, name: Option<String>, model: Option<Model>, system_prompt: Option<Option<String>>, mcp_config: Option<Value>, metadata: Option<Value>, ) -> Result<(), ClaudeCodeError>

Update session configuration

pub async fn session_delete( &self, session_id: &ClaudeCodeId, ) -> Result<(), ClaudeCodeError>

Delete a session (does not delete the arbor tree)

pub async fn message_create( &self, session_id: &ClaudeCodeId, role: MessageRole, content: String, model_id: Option<String>, input_tokens: Option<i64>, output_tokens: Option<i64>, cost_usd: Option<f64>, ) -> Result<Message, ClaudeCodeError>

Create a message and return it

pub async fn message_create_ephemeral( &self, session_id: &ClaudeCodeId, role: MessageRole, content: String, model_id: Option<String>, input_tokens: Option<i64>, output_tokens: Option<i64>, cost_usd: Option<f64>, ) -> Result<Message, ClaudeCodeError>

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

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

Get a message by ID

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

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 ClaudeCodeHandle enum for type-safe handle creation.

pub async fn unknown_event_store( &self, session_id: Option<&ClaudeCodeId>, event_type: &str, data: &Value, ) -> Result<String, ClaudeCodeError>

Store an unknown event and return its ID (handle)

pub async fn unknown_event_get( &self, id: &str, ) -> Result<(String, Value), ClaudeCodeError>

Retrieve an unknown event by ID

pub async fn unknown_events_by_type( &self, event_type: &str, ) -> Result<Vec<(String, Value)>, ClaudeCodeError>

List unknown events by type (for analysis/debugging)

pub async fn stream_create( &self, session_id: ClaudeCodeId, ) -> Result<StreamId, ClaudeCodeError>

Create a new stream buffer for async chat

pub async fn stream_set_user_position( &self, stream_id: &StreamId, position: Position, ) -> Result<(), ClaudeCodeError>

Set the user position for a stream (called after user message is created)

pub async fn stream_push_event( &self, stream_id: &StreamId, event: ChatEvent, ) -> Result<u64, ClaudeCodeError>

Push an event to a stream buffer

pub async fn stream_set_status( &self, stream_id: &StreamId, status: StreamStatus, error: Option<String>, ) -> Result<(), ClaudeCodeError>

Update stream status

pub async fn stream_get_info( &self, stream_id: &StreamId, ) -> Result<StreamInfo, ClaudeCodeError>

Get stream info

pub async fn stream_poll( &self, stream_id: &StreamId, from_seq: Option<u64>, limit: Option<usize>, ) -> Result<(StreamInfo, Vec<BufferedEvent>), ClaudeCodeError>

Poll events from a stream Returns events starting from from_seq up to limit events

pub async fn stream_list(&self) -> Vec<StreamInfo>

List all active streams

pub async fn stream_list_for_session( &self, session_id: &ClaudeCodeId, ) -> Vec<StreamInfo>

List active streams for a session

pub async fn stream_cleanup(&self, stream_id: &StreamId) -> Option<StreamInfo>

Remove a completed/failed stream from memory Returns the final stream info if found

pub async fn stream_exists(&self, stream_id: &StreamId) -> bool

Check if a stream exists

pub async fn render_messages( &self, tree_id: &TreeId, start: &NodeId, end: &NodeId, ) -> Result<Vec<ClaudeMessage>, ClaudeCodeError>

Render arbor tree path into Claude API messages format

Walks from start to end node, parsing NodeEvent JSON from each node, and groups into Claude messages array.

Algorithm

1. Get path from start to end via arbor
2. Parse each node’s content as NodeEvent
3. Group into messages based on event type
4. Return messages array