summaryrefslogtreecommitdiffstats
path: root/src/swarm/bootstrap.rs
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-10-25 13:38:59 +0100
committertv <tv@krebsco.de>2026-10-25 13:38:59 +0100
commitf52ae6973299fa3c1d81758838951e39904e1d84 (patch)
treeeeadc6f698d1fa99d33268f997e8def5ee403038 /src/swarm/bootstrap.rs
parent022ddb4bf167a12cd45b4a5cac27739f92449eff (diff)
add files module to consistently track stats
Diffstat (limited to 'src/swarm/bootstrap.rs')
-rw-r--r--src/swarm/bootstrap.rs12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/swarm/bootstrap.rs b/src/swarm/bootstrap.rs
index 3be462e..f41a00b 100644
--- a/src/swarm/bootstrap.rs
+++ b/src/swarm/bootstrap.rs
@@ -26,6 +26,7 @@ use uuid::Uuid;
use crate::document::replica::Epoch;
use crate::document::store;
+use crate::files::{FileKind, Files};
use crate::remake::snapshot::{self, META_ROOT, SWARM};
use crate::state::AppState;
use crate::swarm::peer::{remember_peer, send_hello_once};
@@ -148,14 +149,14 @@ pub(crate) struct Backup {
pub(crate) doc: AutoCommit,
pub(crate) epoch: Epoch,
pub(crate) swarm_id: String,
- /// The file's size (`swarm::stats`, disk).
- pub(crate) bytes: u64,
}
/// Loads a backup to recover from, as `GET /admin/document` saves it.
-pub(crate) fn load_backup(path: &Path) -> Result<Backup> {
- let bytes =
- std::fs::read(path).with_context(|| format!("Reading the backup {}", path.display()))?;
+pub(crate) fn load_backup(path: &Path, files: &Files) -> Result<Backup> {
+ let bytes = files
+ .read(FileKind::Backup, path)
+ .with_context(|| format!("Reading the backup {}", path.display()))?
+ .with_context(|| format!("The backup {} doesn't exist", path.display()))?;
let mut doc = AutoCommit::load(&bytes)
.with_context(|| format!("Loading the backup {}", path.display()))?
.with_actor(ActorId::random());
@@ -171,7 +172,6 @@ pub(crate) fn load_backup(path: &Path) -> Result<Backup> {
doc,
epoch,
swarm_id,
- bytes: bytes.len() as u64,
})
}