fix(core,cli): resolve S2 dependency version drift and align SDK schemas

Author: bharathkumar39293

packages/cli-v3/src/commands/deploy.ts

@@ -1149,9 +1149,9 @@ async function handleNativeBuildServerDeploy({
   const [readSessionError, readSession] = await tryCatch(
     stream.readSession(
       {
-        seq_num: 0,
-        clamp: true,
-        wait: 60 * 20, // 20 minutes
+        start: {
+          from: { seqNum: 0 },
+        },
       },
       { signal: abortController.signal }
     )
@@ -1187,7 +1187,7 @@ async function handleNativeBuildServerDeploy({
 
     switch (event.type) {
       case "log": {
-        if (record.seq_num === 0) {
+        if (record.seqNum === 0) {
           $queuedSpinner.stop("Build started");
           console.log("│");
           queuedSpinnerStopped = true;

packages/core/src/v3/realtimeStreams/streamsWriterV2.ts

@@ -135,7 +135,7 @@ export class StreamsWriterV2<T = any> implements StreamsWriter {
       const stream = basin.stream(this.options.stream);
 
       const session = await stream.appendSession({
-        maxQueuedBytes: this.maxInflightBytes,
+        maxInflightBytes: this.maxInflightBytes,
       });
 
       this.sessionWritable = session.writable;
@@ -152,7 +152,9 @@ export class StreamsWriterV2<T = any> implements StreamsWriter {
                 return;
               }
               // Convert each chunk to JSON string and wrap in AppendRecord
-              controller.enqueue(AppendRecord.make(JSON.stringify({ data: chunk, id: nanoid(7) })));
+              controller.enqueue(
+                AppendRecord.string({ body: JSON.stringify({ data: chunk, id: nanoid(7) }) })
+              );
             },
           })
         )
@@ -169,9 +171,9 @@ export class StreamsWriterV2<T = any> implements StreamsWriter {
       const lastAcked = session.lastAckedPosition();
 
       if (lastAcked?.end) {
-        const recordsWritten = lastAcked.end.seq_num;
+        const recordsWritten = lastAcked.end.seqNum;
         this.log(
-          `[S2MetadataStream] Written ${recordsWritten} records, ending at seq_num=${lastAcked.end.seq_num}`
+          `[S2MetadataStream] Written ${recordsWritten} records, ending at seqNum=${lastAcked.end.seqNum}`
         );
       }
     } catch (error) {