Start with subscription logic

Author: simolus3

crates/core/src/sync/mod.rs

@@ -9,6 +9,7 @@ pub mod line;
 pub mod operations;
 pub mod storage_adapter;
 mod streaming_sync;
+mod subscriptions;
 mod sync_status;
 
 pub use bucket_priority::BucketPriority;

crates/core/src/sync/subscriptions.rs

@@ -0,0 +1,30 @@
+use core::time::Duration;
+
+use alloc::string::String;
+use serde::Deserialize;
+use serde_with::{serde_as, DurationSeconds};
+
+use crate::sync::BucketPriority;
+
+/// A request sent from a PowerSync SDK to alter the subscriptions managed by this client.
+#[derive(Deserialize)]
+pub enum SubscriptionChangeRequest {
+    Subscribe(SubscribeToStream),
+}
+
+#[serde_as]
+#[derive(Deserialize)]
+pub struct SubscribeToStream {
+    pub stream: String,
+    pub params: Option<serde_json::value::RawValue>,
+    #[serde_as(as = "Option<DurationSeconds>")]
+    pub ttl: Option<Duration>,
+    pub priority: Option<BucketPriority>,
+}
+
+#[derive(Deserialize)]
+pub struct UnsubscribeFromStream {
+    pub stream: String,
+    pub params: Option<serde_json::value::RawValue>,
+    pub immediate: bool,
+}