diff --git a/packages/turso-sync-js/src/js_protocol_io.rs b/packages/turso-sync-js/src/js_protocol_io.rs index 40044f6d2..fffd7d026 100644 --- a/packages/turso-sync-js/src/js_protocol_io.rs +++ b/packages/turso-sync-js/src/js_protocol_io.rs @@ -14,7 +14,7 @@ pub enum JsProtocolRequest { Http { method: String, path: String, - body: Option, + body: Option>, }, FullRead { path: String, @@ -134,7 +134,7 @@ impl ProtocolIO for JsProtocolIo { Ok(self.add_request(JsProtocolRequest::Http { method: method.to_string(), path: path.to_string(), - body: body.map(Buffer::from), + body, })) } diff --git a/packages/turso-sync-js/sync_engine.ts b/packages/turso-sync-js/sync_engine.ts index 4a001dfae..dac182a76 100644 --- a/packages/turso-sync-js/sync_engine.ts +++ b/packages/turso-sync-js/sync_engine.ts @@ -66,7 +66,7 @@ async function process(opts, request) { const response = await fetch(`${opts.url}${requestType.path}`, { method: requestType.method, headers: opts.headers, - body: requestType.body + body: requestType.body != null ? new Uint8Array(requestType.body) : null, }); completion.status(response.status); const reader = response.body.getReader();