Struct SqliteRemoteRepository 

pub struct SqliteRemoteRepository { /* private fields */ }

Implementations

impl SqliteRemoteRepository

pub async fn new_file(path: impl AsRef<Path>) -> Result<Self, Error>

pub async fn create_project(&self, project_id: &str) -> Result<(), Error>

pub async fn create_token( &self, project_id: &str, token_id: &str, token_hash: &str, capabilities_json: &str, member_id: Option<&str>, status: &str, ) -> Result<(), Error>

pub async fn authenticate_token( &self, project_id: &str, token_hash: &str, ) -> Result<Option<(String, Vec<String>, Option<String>)>, Error>

pub async fn push_project_state( &self, request: PushProjectStateRequest<'_>, ) -> Result<i64, Error>

pub async fn pull_project_state( &self, project_id: &str, ) -> Result<Option<(i64, Vec<ProjectFile>)>, Error>

pub async fn get_manifest( &self, project_id: &str, revision: i64, ) -> Result<Option<(String, String, Option<String>)>, Error>

pub async fn list_join_requests( &self, project_id: &str, ) -> Result<Vec<(String, String, String, Option<String>, String)>, Error>

pub async fn upsert_join_request( &self, request: UpsertJoinRequest<'_>, ) -> Result<(), Error>

pub async fn revoke_tokens( &self, project_id: &str, token_ids: &[String], ) -> Result<(), Error>

pub async fn list_project_tokens( &self, project_id: &str, ) -> Result<Vec<(String, String, Option<String>, String, String, Option<String>, Option<String>)>, Error>

pub async fn get_project_meta( &self, project_id: &str, ) -> Result<Option<(Option<String>, Option<String>)>, Error>

pub async fn has_admin_token(&self) -> Result<bool, Error>

pub async fn create_admin_token( &self, token_id: &str, token_hash: &str, capabilities_json: &str, created_at: &str, ) -> Result<(), Error>

pub async fn authenticate_admin_token( &self, token_hash: &str, ) -> Result<Option<(String, Vec<String>)>, Error>

pub async fn create_project_request( &self, project_id: &str, requester_member_id: &str, requester_name: &str, requester_recipient: &str, claim_secret_hash: &str, kagi_json: Option<&str>, ) -> Result<(), Error>

pub async fn list_project_requests( &self, ) -> Result<Vec<(String, String, String, String, String, Option<String>, String)>, Error>

pub async fn get_project_request( &self, project_id: &str, ) -> Result<Option<(String, String, String, String, String, Option<String>, String)>, Error>

pub async fn delete_project_request( &self, project_id: &str, ) -> Result<(), Error>

pub async fn create_project_member( &self, req: CreateProjectMemberRequest<'_>, ) -> Result<(), Error>

pub async fn get_project_member( &self, project_id: &str, member_id: &str, ) -> Result<Option<(String, String, String, String, String)>, Error>

pub async fn save_wrapped_project_token( &self, project_id: &str, member_id: &str, wrapped: &str, ) -> Result<(), Error>

pub async fn get_wrapped_project_token( &self, project_id: &str, member_id: &str, ) -> Result<Option<String>, Error>

pub async fn get_project_member_role( &self, project_id: &str, member_id: &str, ) -> Result<Option<String>, Error>

pub async fn approve_project_request_tx( &self, req: ApproveProjectRequest<'_>, ) -> Result<(), Error>

pub async fn delete_project(&self, project_id: &str) -> Result<(), Error>

pub async fn list_projects( &self, ) -> Result<Vec<(String, i64, Option<String>, String)>, Error>

pub async fn create_audit_event( &self, event_id: &str, project_id: Option<&str>, actor_member_id: Option<&str>, actor_token_id: Option<&str>, event_type: &str, request_id: Option<&str>, remote_addr: Option<&str>, metadata_json: Option<&str>, ) -> Result<(), Error>

pub async fn list_audit_events( &self, project_id: Option<&str>, limit: i64, ) -> Result<Vec<(String, String, Option<String>, Option<String>, Option<String>, String, Option<String>, Option<String>, Option<String>)>, Error>

pub async fn request_id_seen( &self, project_id: &str, request_id: &str, event_type: &str, ) -> Result<bool, Error>

pub async fn get_metrics(&self) -> Result<(i64, i64, i64, i64), Error>