Struct ThreadStorage 

pub struct ThreadStorage { /* private fields */ }

Main storage manager for threads and content-addressed objects.

Implementations

impl ThreadStorage

pub fn store_image( &self, bytes: &[u8], explicit_tone: Option<String>, ) -> Result<StoredImage, StorageError>

Store image bytes using content-addressable storage.

Returns the hash and path to the stored image. If the image already exists with the same hash, returns the existing path.

pub fn store_image_from_path( &self, path: &str, explicit_tone: Option<String>, ) -> Result<StoredImage, StorageError>

Store an image from a file path.

pub fn store_file( &self, bytes: &[u8], extension: &str, explicit_tone: Option<String>, ) -> Result<StoredImage, StorageError>

Store a generic file using content-addressable storage, preserving the extension.

pub fn object_dir(&self, hash: &str) -> Result<PathBuf, StorageError>

pub fn load_document_conversion( &self, source_hash: &str, source_extension: &str, ) -> Result<Option<DocumentConversion>, StorageError>

pub fn save_document_conversion( &self, conversion: &DocumentConversion, ) -> Result<(), StorageError>

pub fn object_manifest_path(&self, hash: &str) -> Result<PathBuf, StorageError>

pub fn find_object_blob(&self, hash: &str) -> Result<PathBuf, StorageError>

pub fn load_object_manifest( &self, hash: &str, ) -> Result<ObjectManifest, StorageError>

pub fn save_object_manifest( &self, hash: &str, manifest: &ObjectManifest, ) -> Result<(), StorageError>

pub fn lock_object_manifest( &self, hash: &str, ) -> Result<ObjectManifestLock, StorageError>

pub fn has_object_remotes(&self) -> Result<bool, StorageError>

pub fn get_image_path(&self, hash: &str) -> Result<String, StorageError>

Get the canonical blob path by hash.

pub fn get_image_tone(&self, hash: &str) -> Option<String>

Get the cached tone for a stored image by hash.

pub fn get_reverse_image_search_cache( &self, hash: &str, ) -> Result<Option<ReverseImageSearchCache>, StorageError>

pub fn save_reverse_image_search_cache( &self, hash: &str, imgbb_url: String, google_lens_url: String, ) -> Result<(), StorageError>

impl ThreadStorage

pub fn create_workspace( &self, name: &str, directories: &[String], ) -> Result<WorkspaceMetadata, StorageError>

pub fn update_workspace( &self, workspace_id: &str, name: &str, directories: &[String], ) -> Result<WorkspaceMetadata, StorageError>

pub fn delete_workspace(&self, workspace_id: &str) -> Result<(), StorageError>

pub fn get_thread_workspace_id( &self, thread_id: &str, ) -> Result<Option<String>, StorageError>

pub fn list_sidechat_threads( &self, ) -> Result<Vec<SideChatMetadata>, StorageError>

pub fn group_threads( &self, first_id: &str, second_id: &str, ) -> Result<WorkspaceMetadata, StorageError>

Group two unassigned threads in one catalog write.

pub fn list_unassigned_threads( &self, ) -> Result<Vec<ThreadMetadata>, StorageError>

impl ThreadStorage

pub fn attachment_manifest_entry( &self, attachment_hash: &str, display_name: &str, last_mention_at: DateTime<Utc>, ) -> Result<AttachmentManifestEntry, StorageError>

pub fn save_thread(&self, thread: &ThreadData) -> Result<(), StorageError>

pub fn save_thread_in_workspace( &self, thread: &ThreadData, workspace_id: &str, ) -> Result<(), StorageError>

pub fn save_sidechat(&self, sidechat: &SideChatData) -> Result<(), StorageError>

pub fn load_sidechat( &self, sidechat_id: &str, ) -> Result<SideChatData, StorageError>

pub fn update_sidechat_metadata( &self, metadata: &SideChatMetadata, ) -> Result<(), StorageError>

pub fn delete_sidechat(&self, sidechat_id: &str) -> Result<(), StorageError>

pub fn fork_sidechat_latest( &self, sidechat_id: &str, ) -> Result<SideChatMetadata, StorageError>

pub fn set_thread_workspace( &self, thread_id: &str, workspace_id: Option<&str>, ) -> Result<(), StorageError>

pub fn load_thread(&self, thread_id: &str) -> Result<ThreadData, StorageError>

pub fn load_messages( &self, thread_id: &str, ) -> Result<Vec<ThreadMessage>, StorageError>

pub fn list_threads(&self) -> Result<Vec<ThreadMetadata>, StorageError>

pub fn list_workspaces(&self) -> Result<Vec<WorkspaceMetadata>, StorageError>

pub fn delete_thread(&self, thread_id: &str) -> Result<(), StorageError>

pub fn delete_threads(&self, thread_ids: &[String]) -> Result<(), StorageError>

pub fn fork_thread_latest( &self, thread_id: &str, ) -> Result<ThreadMetadata, StorageError>

pub fn update_thread_metadata( &self, metadata: &ThreadMetadata, ) -> Result<(), StorageError>

impl ThreadStorage

pub fn save_ocr_data( &self, thread_id: &str, model_id: &str, ocr_data: &[OcrRegion], ) -> Result<(), StorageError>

Save OCR data for a specific model into the thread’s OCR annotations.

pub fn get_ocr_annotations( &self, thread_id: &str, ) -> Result<HashMap<String, OcrAnnotationEntry>, StorageError>

Get the entire OCR annotations for a thread.

impl ThreadStorage

pub fn with_config_root( config_root: PathBuf, ) -> Result<ThreadStorage, StorageError>

pub fn new() -> Result<ThreadStorage, StorageError>

Create a new storage manager using the default global thread location.

pub fn base_dir(&self) -> &PathBuf

Get the base storage directory path.

pub fn objects_dir(&self) -> &PathBuf

Get the objects directory path.