mirror/spacedrive
1
0
Fork 0
mirror of https://github.com/spacedriveapp/spacedrive.git synced 2026-05-18 13:26:00 -04:00
Code Issues Packages Projects Releases Wiki Activity

Add device-owned space models to sync registry

Browse Source
This commit is contained in:
Jamie Pine
2025-11-25 09:15:20 -08:00
parent b4ee11e631
commit 8b8bade25c
1 changed files with 79 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

80
core/src/infra/sync/registry.rs
View File

@@ -180,7 +180,8 @@ pub async fn register_shared(
fn initialize_registry() -> HashMap<String, SyncableModelRegistration> {
use crate::infra::db::entities::{
audit_log, collection, collection_entry, content_identity, device, entry, location, sidecar,
tag, tag_relationship, user_metadata, user_metadata_tag, volume,
space, space_group, space_item, tag, tag_relationship, user_metadata, user_metadata_tag,
volume,
};
let mut registry = HashMap::new();
@@ -475,6 +476,83 @@ fn initialize_registry() -> HashMap<String, SyncableModelRegistration> {
),
);
// Space models (device-owned)
registry.insert(
"space".to_string(),
SyncableModelRegistration::device_owned(
"space",
"spaces",
|data, db| {
Box::pin(async move { space::Model::apply_state_change(data, db.as_ref()).await })
},
|device_id, since, cursor, batch_size, db| {
Box::pin(async move {
space::Model::query_for_sync(device_id, since, cursor, batch_size, db.as_ref())
.await
})
},
Some(|uuid, db| {
Box::pin(async move { space::Model::apply_deletion(uuid, db.as_ref()).await })
}),
),
);
registry.insert(
"space_group".to_string(),
SyncableModelRegistration::device_owned(
"space_group",
"space_groups",
|data, db| {
Box::pin(async move {
space_group::Model::apply_state_change(data, db.as_ref()).await
})
},
|device_id, since, cursor, batch_size, db| {
Box::pin(async move {
space_group::Model::query_for_sync(
device_id,
since,
cursor,
batch_size,
db.as_ref(),
)
.await
})
},
Some(|uuid, db| {
Box::pin(async move { space_group::Model::apply_deletion(uuid, db.as_ref()).await })
}),
),
);
registry.insert(
"space_item".to_string(),
SyncableModelRegistration::device_owned(
"space_item",
"space_items",
|data, db| {
Box::pin(async move {
space_item::Model::apply_state_change(data, db.as_ref()).await
})
},
|device_id, since, cursor, batch_size, db| {
Box::pin(async move {
space_item::Model::query_for_sync(
device_id,
since,
cursor,
batch_size,
db.as_ref(),
)
.await
})
},
Some(|uuid, db| {
Box::pin(async move { space_item::Model::apply_deletion(uuid, db.as_ref()).await })
}),
),
);
registry
}