Simplify API

sync-server/src/app_state/database/models.rs

@@ -123,5 +123,11 @@ pub struct VaultSnapshot {
 pub struct EventBatch {
     #[ts(as = "f64")]
     pub head_event_id: VaultUpdateId,
+
+    /// Last event in this page; `head_event_id` is the vault's current head.
+    #[serde(skip_serializing_if = "Option::is_none")]
+    #[ts(optional, as = "Option<f64>")]
+    pub end_event_id: Option<VaultUpdateId>,
+
     pub events: Vec<EventRecord>,
 }

sync-server/src/app_state/websocket/models.rs

@@ -1,16 +1,13 @@
 use serde::{Deserialize, Serialize};
 use ts_rs::TS;
 
-use crate::app_state::database::models::{DeviceId, DocumentId, EventBatch, VaultUpdateId};
+use crate::app_state::database::models::{DeviceId, DocumentId, VaultUpdateId};
 
 #[derive(TS, Deserialize, Clone, Debug)]
 #[serde(rename_all = "camelCase")]
 pub struct WebSocketHandshake {
     pub token: String,
     pub device_id: DeviceId,
-
-    #[ts(as = "Option<i32>")]
-    pub last_seen_vault_update_id: Option<VaultUpdateId>,
 }
 
 #[derive(TS, Deserialize, Clone, Debug)]
@@ -67,6 +64,6 @@ pub enum WebSocketClientMessage {
 #[serde(rename_all = "camelCase", tag = "type")]
 #[ts(export)]
 pub enum WebSocketServerMessage {
-    VaultEvents(EventBatch),
+    VaultChanged,
     CursorPositions(CursorPositionFromServer),
 }

sync-server/src/server/responses.rs

@@ -2,7 +2,7 @@ use serde::{self, Deserialize, Serialize};
 use ts_rs::TS;
 
 use crate::app_state::database::models::{
-    DocumentVersion, DocumentVersionWithoutContent, FileManifest, VaultUpdateId,
+    DocumentVersionWithoutContent, FileManifest, VaultUpdateId,
 };
 
 /// Response to a ping request.
@@ -34,7 +34,7 @@ pub enum DocumentUpdateResponse {
     Accepted(DocumentVersionWithoutContent),
 
     /// Nothing was written. The client must incorporate this version before retrying.
-    StaleBase(DocumentVersion),
+    StaleBase(DocumentVersionWithoutContent),
 }
 
 #[derive(TS, Debug, Clone, Serialize, Deserialize)]