use super::{
BackupLayoutGuard, JournalLock, JournalLockError, PersistenceError, create_json_durable,
read_json,
};
use crate::model::{
artifacts::ArtifactChecksumRecord,
inventory::{InventoryRecord, MAX_INVENTORY_BYTES},
};
use thiserror::Error;
pub fn create_inventory(
layout: &BackupLayoutGuard,
record: &InventoryRecord,
) -> Result<(), InventoryError> {
layout.check_root()?;
let path = layout.root().join("inventory.json");
let _lock = JournalLock::acquire(&path)?;
check_size(record)?;
create_json_durable(&path, record)?;
Ok(())
}
pub fn read_inventory(
layout: &BackupLayoutGuard,
expected: &ArtifactChecksumRecord,
) -> Result<InventoryRecord, InventoryError> {
layout.check_root()?;
let path = layout.root().join("inventory.json");
let _lock = JournalLock::acquire(&path)?;
let record: InventoryRecord = read_json(&path, MAX_INVENTORY_BYTES)?;
check_size(&record)?;
if &record.digest() != expected {
return Err(InventoryError::DigestMismatch);
}
Ok(record)
}
fn check_size(record: &InventoryRecord) -> Result<(), PersistenceError> {
super::json::check_json_size(record, MAX_INVENTORY_BYTES)
}
#[derive(Debug, Error)]
pub enum InventoryError {
#[error("inventory digest mismatch")]
DigestMismatch,
#[error(transparent)]
Lock(#[from] JournalLockError),
#[error(transparent)]
Persistence(#[from] PersistenceError),
}
#[cfg(all(test, unix))]
mod tests;