Struct SpaceManager 

pub struct SpaceManager { /* private fields */ }

Manages Spaces and routes messages to appropriate Spaces.

Implementations

impl SpaceManager

pub async fn new( state_store: Arc<StateStore>, event_bus: EventBus, ) -> Result<Self>

Create a new SpaceManager.

Initializes from state store, creates default Space if none exist.

pub fn set_knowledge_bridge(&mut self, bridge: Arc<KnowledgeBridge>)

Set the knowledge bridge (called after construction).

pub async fn detect_or_create( &self, message: &str, buffer: &ConversationBuffer, ) -> Result<SpaceId>

Detect or create the appropriate Space for a message.

Implements the 3-layer detection strategy:

1. Filesystem path extraction (fast, free)
2. Keyword/tag matching (fast, free)
3. LLM topic classification (slow, only when needed)

pub async fn create_from_topic(&self, topic: &str) -> Result<Space>

Create a new Space from a detected topic.

pub async fn create_from_path(&self, name: &str, path: &Path) -> Result<Space>

Create a Space from a filesystem path.

pub async fn activate(&self, space_id: &SpaceId) -> Result<()>

Activate a Space (set as current).

pub async fn get_space(&self, space_id: &SpaceId) -> Result<Option<Space>>

Get a Space by ID.

pub fn list(&self) -> Vec<Space>

List all Spaces.

pub fn current_space_id(&self) -> SpaceId

Get the current Space ID.

pub fn default_space_id(&self) -> SpaceId

Get the default Space ID.

pub fn current_space(&self) -> Option<Space>

Get the current Space.

pub fn is_in_default_space(&self) -> bool

Check if currently in the default (unnamed) Space.

pub async fn merge_spaces( &self, survivor_id: SpaceId, absorbed_id: SpaceId, ) -> Result<()>

Merge two Spaces.

The absorbed Space is merged into survivor. Memory entries from absorbed are transferred to survivor.

pub fn should_auto_merge(&self, a: &Space, b: &Space) -> bool

Check if two Spaces should be auto-merged.

pub async fn archive_stale(&self) -> Result<Vec<SpaceId>>

Archive Spaces that haven’t been active for MAX_ARCHIVE_AGE_DAYS.

pub async fn restore_from_archive(&self, space_id: &SpaceId) -> Result<()>

Restore an archived Space.

pub fn knowledge_bridge(&self) -> Option<Arc<KnowledgeBridge>>

Get the knowledge bridge.

pub fn root_dir(&self) -> &PathBuf

Get the root directory.

pub fn buffer(&self) -> Arc<Mutex<ConversationBuffer>>

Get the conversation buffer.