elastik-core 8.2.0

//! SQLite error classification shared by protocol adapters and world ops.
//!
//! These helpers classify storage failures without deciding adapter output.
//! Adapters map them to protocol-specific outcomes; `world_ops.rs` uses them
//! to keep transient and permanent storage failures distinct.

pub(crate) fn is_transient_storage_error(err: &rusqlite::Error) -> bool {
    if matches!(
        err.sqlite_error_code(),
        Some(rusqlite::ffi::ErrorCode::DatabaseBusy | rusqlite::ffi::ErrorCode::DatabaseLocked)
    ) {
        return true;
    }
    let msg = err.to_string().to_ascii_lowercase();
    msg.contains("database is locked") || msg.contains("database table is locked")
}

pub(crate) fn is_insufficient_storage_error(err: &rusqlite::Error) -> bool {
    if matches!(
        err.sqlite_error_code(),
        Some(rusqlite::ffi::ErrorCode::DiskFull)
    ) {
        return true;
    }
    let msg = err.to_string().to_ascii_lowercase();
    msg.contains("database or disk is full")
        || msg.contains("disk is full")
        || msg.contains("no space left")
        || msg.contains("not enough space")
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn disk_full_is_insufficient_storage() {
        let err = rusqlite::Error::SqliteFailure(
            rusqlite::ffi::Error::new(rusqlite::ffi::SQLITE_FULL),
            None,
        );
        assert!(is_insufficient_storage_error(&err));
        assert!(!is_transient_storage_error(&err));
    }

    #[test]
    fn busy_and_locked_are_transient_storage() {
        for code in [rusqlite::ffi::SQLITE_BUSY, rusqlite::ffi::SQLITE_LOCKED] {
            let err = rusqlite::Error::SqliteFailure(rusqlite::ffi::Error::new(code), None);
            assert!(is_transient_storage_error(&err));
            assert!(!is_insufficient_storage_error(&err));
        }
    }

    #[test]
    fn corrupt_is_not_quota_or_transient_storage() {
        let err = rusqlite::Error::SqliteFailure(
            rusqlite::ffi::Error::new(rusqlite::ffi::SQLITE_CORRUPT),
            None,
        );
        assert!(!is_insufficient_storage_error(&err));
        assert!(!is_transient_storage_error(&err));
    }
}