Struct SafetyManager 

pub struct SafetyManager {
    source: PathBuf,
    config: SafetyConfig,
    index_hash: String,
    trash_dir: PathBuf,
    history_file: PathBuf,
    trash_cache: Arc<RwLock<Vec<TrashEntry>>>,
}

Safety manager for protecting file operations.

Fields

source: PathBuf

Source root; agent paths must stay inside this tree.

config: SafetyConfig

Configuration

index_hash: String

Index hash (used for separating trash/history by index)

trash_dir: PathBuf

Trash directory

history_file: PathBuf

History file

trash_cache: Arc<RwLock<Vec<TrashEntry>>>

In-memory cache of trash entries

Implementations

impl SafetyManager

pub fn new(source: &PathBuf, config: Option<SafetyConfig>) -> Self

Create a new safety manager.

fn jail(&self, path: &Path) -> Result<PathBuf, String>

Resolve path so it stays inside the source root.

pub fn index_hash(&self) -> &str

Get the index hash.

fn load_trash_entries(trash_dir: &PathBuf) -> Result<Vec<TrashEntry>>

Load trash entries from disk.

async fn save_trash_entries(&self) -> Result<()>

Save trash entries to disk.

pub async fn soft_delete(&self, path: &PathBuf) -> Result<TrashEntry, String>

Move a file to trash (soft delete).

pub async fn restore(&self, trash_id: Uuid) -> Result<PathBuf, String>

Restore a file from trash.

pub async fn list_trash(&self) -> Vec<TrashEntry>

List all trash entries.

pub async fn get_trash_entry(&self, id: Uuid) -> Option<TrashEntry>

Get a specific trash entry.

pub fn get_trash_content(&self, id: Uuid) -> Result<Vec<u8>, String>

Get trash content by ID.

pub async fn purge_expired(&self) -> usize

Purge expired trash entries.

pub fn log(&self, entry: HistoryEntry) -> Result<()>

Log an operation to history.

pub fn log_success( &self, operation: HistoryOperation, undo_data: Option<UndoData>, ) -> Uuid

Log a successful operation and return the history entry id.

This id is the undo_id written to .ops/.result.

pub fn log_failure(&self, operation: HistoryOperation, error: String)

Log a failed operation.

pub fn read_history(&self, limit: Option<usize>) -> Vec<HistoryEntry>

Read history entries.

pub fn get_history_json(&self, limit: Option<usize>) -> Vec<u8>

Get history as JSON bytes (for FUSE read).

pub fn find_operation(&self, id: Uuid) -> Option<HistoryEntry>

Find an operation by ID for undo.

pub async fn undo(&self, operation_id: Uuid) -> Result<String, String>

Undo an operation.

pub fn soft_delete_enabled(&self) -> bool

Check if soft delete is enabled.

pub fn trash_dir(&self) -> &PathBuf

Get trash directory path.