use std::sync::Arc;
use tokio::sync::Mutex as AsyncMutex;
use fakecloud_persistence::SnapshotStore;
use crate::state::{
CloudControlSnapshot, SharedCloudControlState, CLOUDCONTROL_SNAPSHOT_SCHEMA_VERSION,
};
#[derive(Debug, PartialEq, Eq)]
pub enum LoadOutcome {
Empty,
Loaded(usize),
}
#[derive(Debug, thiserror::Error)]
pub enum LoadError {
#[error("failed to read cloudcontrol persistence snapshot: {0}")]
Io(String),
#[error("failed to parse cloudcontrol persistence snapshot: {0}")]
Parse(String),
#[error(
"cloudcontrol persistence schema too new: on-disk={on_disk}, max supported={supported}"
)]
SchemaTooNew { on_disk: u32, supported: u32 },
}
pub fn load_into(
store: &dyn SnapshotStore,
state: &SharedCloudControlState,
) -> Result<LoadOutcome, LoadError> {
let Some(bytes) = store.load().map_err(|e| LoadError::Io(e.to_string()))? else {
return Ok(LoadOutcome::Empty);
};
let snapshot: CloudControlSnapshot =
serde_json::from_slice(&bytes).map_err(|e| LoadError::Parse(e.to_string()))?;
if snapshot.schema_version > CLOUDCONTROL_SNAPSHOT_SCHEMA_VERSION {
return Err(LoadError::SchemaTooNew {
on_disk: snapshot.schema_version,
supported: CLOUDCONTROL_SNAPSHOT_SCHEMA_VERSION,
});
}
let accounts = snapshot.accounts.account_count();
*state.write() = snapshot.accounts;
Ok(LoadOutcome::Loaded(accounts))
}
pub async fn save_snapshot(
state: &SharedCloudControlState,
store: Option<Arc<dyn SnapshotStore>>,
lock: &AsyncMutex<()>,
) {
let Some(store) = store else {
return;
};
let _guard = lock.lock().await;
let snapshot = CloudControlSnapshot {
schema_version: CLOUDCONTROL_SNAPSHOT_SCHEMA_VERSION,
accounts: state.read().clone(),
};
let join = tokio::task::spawn_blocking(move || -> std::io::Result<()> {
let bytes = serde_json::to_vec(&snapshot)
.map_err(|e| std::io::Error::new(std::io::ErrorKind::InvalidData, e.to_string()))?;
store.save(&bytes)
})
.await;
match join {
Ok(Ok(())) => {}
Ok(Err(err)) => tracing::error!(%err, "failed to write cloudcontrol snapshot"),
Err(err) => tracing::error!(%err, "cloudcontrol snapshot task panicked"),
}
}
#[cfg(test)]
mod tests {
use super::*;
use crate::state::CloudControlState;
use fakecloud_core::multi_account::MultiAccountState;
use parking_lot::RwLock;
use std::sync::Mutex;
struct MemStore(Mutex<Option<Vec<u8>>>);
impl SnapshotStore for MemStore {
fn load(&self) -> std::io::Result<Option<Vec<u8>>> {
Ok(self.0.lock().unwrap().clone())
}
fn save(&self, bytes: &[u8]) -> std::io::Result<()> {
*self.0.lock().unwrap() = Some(bytes.to_vec());
Ok(())
}
}
fn state() -> SharedCloudControlState {
Arc::new(RwLock::new(MultiAccountState::new(
"000000000000",
"us-east-1",
"",
)))
}
#[test]
fn empty_store_is_empty() {
assert_eq!(
load_into(&MemStore(Mutex::new(None)), &state()).unwrap(),
LoadOutcome::Empty
);
}
#[test]
fn round_trip_restores_accounts() {
let mut accounts: MultiAccountState<CloudControlState> =
MultiAccountState::new("000000000000", "us-east-1", "");
accounts.get_or_create("111122223333");
let snap = CloudControlSnapshot {
schema_version: CLOUDCONTROL_SNAPSHOT_SCHEMA_VERSION,
accounts,
};
let store = MemStore(Mutex::new(Some(serde_json::to_vec(&snap).unwrap())));
assert_eq!(load_into(&store, &state()).unwrap(), LoadOutcome::Loaded(2));
}
#[test]
fn rejects_future_schema() {
let accounts: MultiAccountState<CloudControlState> =
MultiAccountState::new("000000000000", "us-east-1", "");
let bytes = serde_json::to_vec(&serde_json::json!({
"schema_version": CLOUDCONTROL_SNAPSHOT_SCHEMA_VERSION + 1,
"accounts": accounts,
}))
.unwrap();
let store = MemStore(Mutex::new(Some(bytes)));
assert!(matches!(
load_into(&store, &state()),
Err(LoadError::SchemaTooNew { .. })
));
}
}