10 files changed, 15 insertions, 15 deletions
diff --git a/src/compaction/api.rs b/src/compaction/api.rs
index 21cdf7b..f972809 100644
--- a/src/compaction/api.rs
+++ b/src/compaction/api.rs
@@ -40,7 +40,7 @@ use super::records::{
     self, unix_millis, AbortRequest, EpochRecord, Phase, Policy, Proposal, Record, Retention,
 };
 use super::Host;
-use crate::store::StoreError;
+use crate::document::store::StoreError;
 
 #[derive(Debug, Default, Deserialize)]
 pub(crate) struct WaitQuery {
diff --git a/src/compaction/catchup.rs b/src/compaction/catchup.rs
index d8bac74..5085669 100644
--- a/src/compaction/catchup.rs
+++ b/src/compaction/catchup.rs
@@ -37,7 +37,7 @@ use super::local::{CatchUp, LocalStatus, Quarantined, Rejoin};
 use super::records::unix_millis;
 use super::snapshot::{self, EpochMetadata};
 use super::Host;
-use crate::replica::Epoch;
+use crate::document::replica::Epoch;
 
 /// Pause before trying the same target again after a failed rejoin.
 const RETRY: Duration = Duration::from_secs(30);
diff --git a/src/compaction/coordinator.rs b/src/compaction/coordinator.rs
index 1b41faf..8ce3928 100644
--- a/src/compaction/coordinator.rs
+++ b/src/compaction/coordinator.rs
@@ -23,7 +23,7 @@ use tracing::{info, warn};
 use super::records::{self, Decision, Record};
 use super::snapshot;
 use super::Host;
-use crate::store::StoreError;
+use crate::document::store::StoreError;
 
 const TICK: Duration = Duration::from_secs(1);
 
diff --git a/src/compaction/delta.rs b/src/compaction/delta.rs
index ba04799..cf556b2 100644
--- a/src/compaction/delta.rs
+++ b/src/compaction/delta.rs
@@ -23,7 +23,7 @@ use automerge::{ActorId, AutoCommit, ChangeHash, PatchAction, Prop};
 use tracing::warn;
 
 use super::snapshot::{COMPACTIONS, EPOCHS, META_ROOT};
-use crate::store::{self, StoreError};
+use crate::document::store::{self, StoreError};
 
 #[derive(Debug, Default, Clone, Copy)]
 pub(crate) struct ReplayStats {
diff --git a/src/compaction/local.rs b/src/compaction/local.rs
index c798a4c..ec40b06 100644
--- a/src/compaction/local.rs
+++ b/src/compaction/local.rs
@@ -14,7 +14,7 @@ use tokio::time::Instant;
 
 use super::records::{unix_millis, Retention};
 use super::snapshot::Snapshot;
-use crate::replica::Epoch;
+use crate::document::replica::Epoch;
 
 #[derive(Default)]
 pub(crate) struct Compaction {
diff --git a/src/compaction/mod.rs b/src/compaction/mod.rs
index e3cdf55..5322058 100644
--- a/src/compaction/mod.rs
+++ b/src/compaction/mod.rs
@@ -38,8 +38,8 @@ use axum::{
 };
 use tokio::sync::broadcast;
 
-use crate::replica::Epoch;
-use crate::sync::ChangeSet;
+use crate::document::replica::Epoch;
+use crate::swarm::sync::ChangeSet;
 
 /// What compaction needs from the node. Implemented by `AppState`.
 ///
diff --git a/src/compaction/quarantine.rs b/src/compaction/quarantine.rs
index da39ec0..ad3c616 100644
--- a/src/compaction/quarantine.rs
+++ b/src/compaction/quarantine.rs
@@ -28,7 +28,7 @@ use super::api::error_response;
 use super::delta;
 use super::local::Quarantined;
 use super::Host;
-use crate::store;
+use crate::document::store;
 
 #[derive(Debug, Serialize)]
 #[serde(rename_all = "camelCase")]
diff --git a/src/compaction/records.rs b/src/compaction/records.rs
index ccd52c3..f533ee2 100644
--- a/src/compaction/records.rs
+++ b/src/compaction/records.rs
@@ -20,8 +20,8 @@ use serde::{Deserialize, Serialize};
 use tracing::warn;
 
 use super::snapshot::{SnapshotRequest, COMPACTIONS, META_ROOT};
-use crate::replica::Epoch;
-use crate::store::{self, StoreError};
+use crate::document::replica::Epoch;
+use crate::document::store::{self, StoreError};
 
 /// One day, for retention defaults.
 const DAY_SECS: u64 = 24 * 60 * 60;
diff --git a/src/compaction/snapshot.rs b/src/compaction/snapshot.rs
index 0a89e23..0d49d48 100644
--- a/src/compaction/snapshot.rs
+++ b/src/compaction/snapshot.rs
@@ -29,8 +29,8 @@ use serde_json::{json, Map as JsonMap, Value as JsonValue};
 use sha2::{Digest, Sha256};
 
 use super::records::{EpochRecord, Policy};
-use crate::replica::Epoch;
-use crate::store::{self, StoreError};
+use crate::document::replica::Epoch;
+use crate::document::store::{self, StoreError};
 
 pub(crate) const META_ROOT: &str = "_continuum";
 pub(crate) const COMPACTIONS: &str = "compactions";
diff --git a/src/compaction/switch.rs b/src/compaction/switch.rs
index 24bcee0..67ff471 100644
--- a/src/compaction/switch.rs
+++ b/src/compaction/switch.rs
@@ -30,9 +30,9 @@ use super::local::LocalStatus;
 use super::records::{self, unix_millis, EpochRecord, Record};
 use super::snapshot::{self, COMPACTIONS, META_ROOT};
 use super::Host;
-use crate::replica::Epoch;
-use crate::store;
-use crate::sync::paths_related;
+use crate::document::replica::Epoch;
+use crate::document::store;
+use crate::swarm::sync::paths_related;
 
 const TICK: Duration = Duration::from_secs(1);