Struct LockingService 

pub struct LockingService { /* private fields */ }

Service for managing file editing locks.

Implementations

impl LockingService

pub fn new( lock_repo: Arc<FileLockRepository>, file_repo: Arc<StoredFileRepository>, ) -> Self

pub async fn acquire_lock( &self, file_id: Uuid, user_id: Uuid, duration_minutes: Option<i64>, ) -> ServiceResult<FileLock>

Acquire an editing lock on a file.

If the file is already locked by the same user, refreshes the lock. If locked by another user and the lock is still valid, returns an error. Expired locks are automatically cleaned up.

pub async fn release_lock( &self, file_id: Uuid, user_id: Uuid, ) -> ServiceResult<()>

Release a lock. Only the lock owner can release it.

pub async fn refresh_lock( &self, file_id: Uuid, user_id: Uuid, ) -> ServiceResult<FileLock>

Refresh an existing lock’s expiry time.

pub async fn break_lock(&self, file_id: Uuid) -> ServiceResult<()>

Admin-only: forcibly break a lock regardless of owner.

pub async fn get_active_lock( &self, file_id: Uuid, ) -> ServiceResult<Option<FileLock>>

Get the active (non-expired) lock for a file, if any. Automatically cleans up expired locks.

pub async fn cleanup_expired(&self) -> ServiceResult<u64>

Cleanup all expired locks. Returns the number of locks removed.