diff --git a/sync-server/src/app_state/database/migrations/20241207143519_bootstrap.sql b/sync-server/src/app_state/database/migrations/20241207143519_bootstrap.sql index 504f89ba..e5a86edc 100644 --- a/sync-server/src/app_state/database/migrations/20241207143519_bootstrap.sql +++ b/sync-server/src/app_state/database/migrations/20241207143519_bootstrap.sql @@ -1,8 +1,7 @@ CREATE TABLE events ( event_id INTEGER PRIMARY KEY AUTOINCREMENT CHECK(event_id <= 9007199254740991), -- JavaScript’s Number.MAX_SAFE_INTEGER request_id TEXT NOT NULL UNIQUE, - request_fingerprint BLOB NOT NULL, - event_json TEXT NOT NULL + request_fingerprint BLOB NOT NULL ); CREATE TABLE documents ( diff --git a/sync-server/src/app_state/database/mutations.rs b/sync-server/src/app_state/database/mutations.rs index 5d7b52b4..b0af9e4a 100644 --- a/sync-server/src/app_state/database/mutations.rs +++ b/sync-server/src/app_state/database/mutations.rs @@ -10,14 +10,14 @@ impl Database { request_id: uuid::Uuid, fingerprint: &[u8], ) -> Result { - Ok(sqlx::query( - "INSERT INTO events(request_id, request_fingerprint, event_json) VALUES (?, ?, '')", + Ok( + sqlx::query("INSERT INTO events(request_id, request_fingerprint) VALUES (?, ?)") + .bind(request_id.to_string()) + .bind(fingerprint) + .execute(&mut **tx) + .await? + .last_insert_rowid(), ) - .bind(request_id.to_string()) - .bind(fingerprint) - .execute(&mut **tx) - .await? - .last_insert_rowid()) } pub async fn insert_document_version(