diff --git a/backend/sync_server/src/server/update_document.rs b/backend/sync_server/src/server/update_document.rs index a572394..fdbbfd6 100644 --- a/backend/sync_server/src/server/update_document.rs +++ b/backend/sync_server/src/server/update_document.rs @@ -104,32 +104,6 @@ async fn internal_update_document( let sanitized_relative_path = sanitize_path(&relative_path); - // Return the latest version if the update is a no-op from the client's - // perspective - if content == parent_document.content - && sanitized_relative_path == parent_document.relative_path - { - info!("Document content is the same as the parent version, skipping update"); - - let latest_version = state - .database - .get_latest_document(&vault_id, &document_id, None) - .await - .map_err(server_error)? - .map_or_else( - || { - Err(not_found_error(anyhow!( - "Document with id `{document_id}` not found", - ))) - }, - Ok, - )?; - - return Ok(Json(DocumentUpdateResponse::FastForwardUpdate( - latest_version.into(), - ))); - } - let mut transaction = state .database .create_write_transaction(&vault_id) diff --git a/frontend/sync-client/src/sync-operations/syncer.ts b/frontend/sync-client/src/sync-operations/syncer.ts index ef35d10..ff10266 100644 --- a/frontend/sync-client/src/sync-operations/syncer.ts +++ b/frontend/sync-client/src/sync-operations/syncer.ts @@ -274,9 +274,8 @@ export class Syncer { typeof globalThis !== "undefined" && typeof globalThis.WebSocket === "undefined" ) { - // polyfill for WebSocket in Node.js // eslint-disable-next-line - globalThis.WebSocket = require("ws"); + globalThis.WebSocket = require("ws"); // polyfill for WebSocket in Node.js } this.applyRemoteChangesWebSocket = new WebSocket(wsUri); diff --git a/frontend/test-client/src/agent/mock-client.ts b/frontend/test-client/src/agent/mock-client.ts index 29d808f..a1e2b9e 100644 --- a/frontend/test-client/src/agent/mock-client.ts +++ b/frontend/test-client/src/agent/mock-client.ts @@ -108,7 +108,7 @@ export class MockClient implements FileSystemOperations { { assert( newParts.includes(part), - `Part ${part} not found in new content` + `Part ${part} not found in new content: ${newContent}` ); } ); diff --git a/frontend/test-client/src/cli.ts b/frontend/test-client/src/cli.ts index 799ee79..98dff41 100644 --- a/frontend/test-client/src/cli.ts +++ b/frontend/test-client/src/cli.ts @@ -25,10 +25,12 @@ async function runTest({ const settings = `with ${agentCount} agents, concurrency ${concurrency}, iterations ${iterations}, doDeletes ${doDeletes}, jitterScaleInSeconds ${jitterScaleInSeconds}, useSlowFileEvents ${useSlowFileEvents}`; console.info(`Running test ${settings}`); + const vaultName = uuidv4(); + console.info(`Using vault name: ${vaultName}`); const initialSettings: Partial = { isSyncEnabled: true, token: "test-token-change-me", // same as in backend/config-e2e.yml - vaultName: uuidv4(), + vaultName, syncConcurrency: concurrency, remoteUri: "http://localhost:3000" };