Struct MappingStore 

pub struct MappingStore { /* private fields */ }

Implementations

impl MappingStore

pub async fn new<P: AsRef<Path>>(db_path: P) -> Result<Self>

pub async fn store_mapping(&self, mapping: TaskMapping) -> Result<()>

pub async fn get_mapping_by_linear_id( &self, sync_source: &str, linear_issue_id: &str, ) -> Result<Option<TaskMapping>>

pub async fn get_mapping_by_motion_id( &self, motion_task_id: &str, ) -> Result<Option<TaskMapping>>

pub async fn remove_mapping( &self, sync_source: &str, linear_issue_id: &str, ) -> Result<Option<TaskMapping>>

pub async fn list_mappings_by_source( &self, sync_source: &str, ) -> Result<Vec<TaskMapping>>

pub async fn list_all_mappings(&self) -> Result<Vec<TaskMapping>>

pub async fn update_mapping(&self, mapping: TaskMapping) -> Result<()>

pub async fn create_pending_mapping( &self, sync_source: &str, issue: &LinearIssue, ) -> Result<TaskMapping>

Create a pending mapping from a Linear issue

pub async fn mark_synced( &self, sync_source: &str, linear_issue_id: &str, motion_task_id: String, ) -> Result<()>

Update mapping with Motion task ID when sync succeeds

pub async fn mark_failed( &self, sync_source: &str, linear_issue_id: &str, error: String, ) -> Result<()>

Update mapping when sync fails

pub async fn update_issue_data( &self, sync_source: &str, linear_issue_id: &str, issue: &LinearIssue, ) -> Result<()>

Update the stored Linear issue data in a mapping (used for re-sync)

pub async fn list_mappings_by_status( &self, status: MappingStatus, ) -> Result<Vec<TaskMapping>>

Get mappings by status

pub async fn flush(&self) -> Result<()>