10 files changed, 15 insertions, 15 deletions
diff --git a/src/compaction/api.rs b/src/compaction/api.rs
index ed2dd9a..3c4f58f 100644
--- a/src/compaction/api.rs
+++ b/src/compaction/api.rs
@@ -40,7 +40,7 @@ use super::local::LocalStatus;
 use super::records::{
     self, AbortRequest, EpochRecord, Phase, Policy, Proposal, Record, Retention, unix_millis,
 };
-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 08e6c18..ce1e98d 100644
--- a/src/compaction/catchup.rs
+++ b/src/compaction/catchup.rs
@@ -37,7 +37,7 @@ use super::delta::{self, ReplayStats};
 use super::local::{CatchUp, LocalStatus, Quarantined, Rejoin};
 use super::records::unix_millis;
 use super::snapshot::{self, EpochMetadata};
-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 cc7755b..b7cb6d7 100644
--- a/src/compaction/coordinator.rs
+++ b/src/compaction/coordinator.rs
@@ -23,7 +23,7 @@ use tracing::{info, warn};
 use super::Host;
 use super::records::{self, Decision, Record};
 use super::snapshot;
-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 609b330..d44fa2f 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 975a093..c3974ea 100644
--- a/src/compaction/local.rs
+++ b/src/compaction/local.rs
@@ -14,7 +14,7 @@ use tokio::time::Instant;
 
 use super::records::{Retention, unix_millis};
 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 e44a840..e4e6bd3 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 581f08c..418a4ab 100644
--- a/src/compaction/quarantine.rs
+++ b/src/compaction/quarantine.rs
@@ -28,7 +28,7 @@ use super::Host;
 use super::api::error_response;
 use super::delta;
 use super::local::Quarantined;
-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 d61a7f0..18e786d 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::{COMPACTIONS, META_ROOT, SnapshotRequest};
-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 44a20a1..841ba18 100644
--- a/src/compaction/snapshot.rs
+++ b/src/compaction/snapshot.rs
@@ -29,8 +29,8 @@ use serde_json::{Map as JsonMap, Value as JsonValue, json};
 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 9a0603e..43a21a4 100644
--- a/src/compaction/switch.rs
+++ b/src/compaction/switch.rs
@@ -30,9 +30,9 @@ use super::delta::{self, ReplayStats};
 use super::local::LocalStatus;
 use super::records::{self, EpochRecord, Record, unix_millis};
 use super::snapshot::{self, COMPACTIONS, META_ROOT};
-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);