Enable transition chunks (#42095)

GitOrigin-RevId: 7776fea425bfb79ae3a63678963108cfce069631

Author: thomasballinger

crates/common/src/version.rs

@@ -51,7 +51,7 @@ pub static MIN_NPM_VERSION_FOR_TRANSITION_CHUNKS: LazyLock<Version> = LazyLock::
     env_config(
         // Until clients can handle these better use a large number we'll never hit.
         "MIN_NPM_VERSION_FOR_TRANSITION_CHUNKS",
-        Version::parse("1.999.0").expect("Invalid version"),
+        Version::parse("1.28.0").expect("Invalid version"),
     )
 });
 

crates/local_backend/src/subs/mod.rs

@@ -232,12 +232,12 @@ async fn run_sync_socket(
                         Some(m) => m,
                         None => break 'top,
                     };
-                    let delay = st.runtime.monotonic_now() - send_time;
-                    log_websocket_message_out(&message, delay);
                     message.inject_server_ts(st.runtime.generate_timestamp()?);
                     let messages =
                         maybe_split_transition(message, config.supports_transition_chunks)?;
                     for msg in messages {
+                        let delay = st.runtime.monotonic_now() - send_time;
+                        log_websocket_message_out(&msg, delay);
                         let serialized = serde_json::to_string(&JsonValue::from(msg))?;
                         if tx.send(Message::Text(serialized.into())).await.is_err() {
                             break 'top;

npm-packages/js-integration-tests/convex/largeResponse.ts

@@ -3,9 +3,9 @@ import { query } from "./_generated/server";
 
 // Will be a bit over for serialization and the array.
 export const largeArray = query({
-  args: { bytes: v.number() },
+  args: { count: v.number(), character: v.string() },
   handler: async (_ctx, args) => {
-    let left = args.bytes;
+    let left = args.count;
     const items = [];
     const largeString = "x".repeat(1_000_000);
     while (left > 0) {

npm-packages/js-integration-tests/largeResponse.test.ts

@@ -16,15 +16,17 @@ describe("Large query responses", () => {
 
   test("query with small response works", async () => {
     const result = await client.query(api.largeResponse.largeArray, {
-      bytes: 1000,
+      count: 1000,
+      character: "€", // 3 bytes in utf-8, 2 bytes in utf-16, one character in JS
     });
     expect(result).toBeDefined();
     expect(Array.isArray(result)).toBe(true);
   });
 
   test("query with >5MB response", async () => {
     const result = await client.query(api.largeResponse.largeArray, {
-      bytes: 6_000_000,
+      count: 6_000_000,
+      character: "€", // 3 bytes in utf-8, 2 bytes in utf-16, one character in JS
     });
     expect(result).toBeDefined();
     // The result should be close to 6MB