Struct Store 

pub struct Store { /* private fields */ }

The embedded store: a thin typed repository over an embedded SurrealDB instance.

Implementations

impl Store

pub async fn open(path: &Path) -> Res<Self>

Opens (or creates) a persistent store rooted at path using the SurrealKV backend.

Errors

Returns an error if the backend cannot be opened or the schema cannot be applied.

pub async fn open_in_memory() -> Res<Self>

Opens an ephemeral in-memory store (for tests).

Errors

Returns an error if the in-memory backend cannot be initialized.

pub async fn create_user(&self, username: &str) -> Res<UserRecord>

Creates a user, enforcing the unique-username constraint.

Errors

Returns an error if the username is already taken or the write fails.

pub async fn get_user(&self, username: &str) -> Res<Option<UserRecord>>

Fetches a user by username.

Errors

Returns an error if the query fails.

pub async fn create_machine( &self, user: &str, name: &str, pubkey_base64: &str, ) -> Res<MachineRecord>

Enrolls a machine, enforcing the globally-unique pubkey and per-user-unique name constraints.

Errors

Returns an error if the pubkey is already enrolled, the name collides within the user, or the write fails.

pub async fn get_machine_by_pubkey( &self, pubkey_base64: &str, ) -> Res<Option<MachineRecord>>

Fetches a machine by its base64 public key.

Errors

Returns an error if the query fails.

pub async fn list_machines(&self, user: &str) -> Res<Vec<MachineRecord>>

Lists the machines enrolled under a user.

Errors

Returns an error if the query fails.

pub async fn delete_machine(&self, user: &str, name: &str) -> Void

Revokes a machine by (user, name).

Errors

Returns an error if the delete fails.

pub async fn create_channel( &self, name: &str, visibility: Visibility, created_by: &str, ) -> Res<ChannelRecord>

Creates a channel, enforcing the unique-name constraint.

Errors

Returns an error if the name is already taken or the write fails.

pub async fn get_channel(&self, name: &str) -> Res<Option<ChannelRecord>>

Fetches a channel by name.

Errors

Returns an error if the query fails.

pub async fn create_invite( &self, channel: &str, token: &str, uses_remaining: Option<i64>, expires_at: Option<String>, created_by: &str, ) -> Res<InviteRecord>

Creates an invite token, enforcing the unique-token constraint.

Errors

Returns an error if the token already exists or the write fails.

pub async fn get_invite(&self, token: &str) -> Res<Option<InviteRecord>>

Fetches an invite by token.

Errors

Returns an error if the query fails.

pub async fn list_channels(&self) -> Res<Vec<ChannelRecord>>

Lists every channel; the caller applies visibility / membership gating (DESIGN.md §6).

Errors

Returns an error if the query fails.

pub async fn set_channel_acl(&self, name: &str, acl: &[String]) -> Void

Replaces a channel’s access-control list (e.g. after an ACL add / invite redeem).

Errors

Returns an error if the update fails.

pub async fn set_channel_visibility( &self, name: &str, visibility: Visibility, ) -> Void

Changes a channel’s visibility tier.

Errors

Returns an error if the update fails.

pub async fn rename_channel(&self, old: &str, new: &str) -> Void

Renames a channel, enforcing the unique-name constraint on the new name.

Errors

Returns an error if the new name is already taken or the update fails.

pub async fn delete_channel(&self, name: &str) -> Void

Deletes a channel.

Errors

Returns an error if the delete fails.

pub async fn set_invite_uses(&self, token: &str, uses_remaining: i64) -> Void

Sets an invite’s remaining redemptions (used when redeeming a limited-use token).

Errors

Returns an error if the update fails.

pub async fn delete_invite(&self, token: &str) -> Void

Deletes an invite token (on revoke or when an exhausted token is redeemed).

Errors

Returns an error if the delete fails.

pub async fn list_users(&self) -> Res<Vec<UserRecord>>

Lists every registered user (server-admin user list).

Errors

Returns an error if the query fails.

pub async fn delete_user(&self, username: &str) -> Void

Deletes a user (server-admin user remove); the caller also revokes the user’s machines.

Errors

Returns an error if the delete fails.