Log instead of throw when publishAndApply cannot apply locally (RTO20c, RTO20d1)

Replace throwing errors with logging when publishAndApply cannot apply
operations on ACK. The publish has already succeeded on the server, so
throwing would be misleading — operations will be applied via the echo
path instead.

RTO20c1: log error and return if siteCode unavailable
RTO20c2: log error and return if PublishResult.serials has wrong length
RTO20d1: log debug and skip individual operations with null serial

Up to date with spec c57a8f3.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: lawrence-forooghian

src/plugins/liveobjects/realtimeobject.ts

@@ -290,36 +290,58 @@ export class RealtimeObject {
       `received ACK for ${objectMessages.length} message(s), applying locally; channel=${this._channel.name}`,
     );
 
-    // RTO20c
+    // RTO20c - check required information is available
     const siteCode = this._channel.connectionManager.connectionDetails?.siteCode;
+    // RTO20c1
     if (!siteCode) {
-      throw new this._client.ErrorInfo(
-        'cannot apply operation locally: siteCode not available from connectionDetails',
-        40000,
-        400,
+      this._client.Logger.logAction(
+        this._client.logger,
+        this._client.Logger.LOG_ERROR,
+        'RealtimeObject.publishAndApply()',
+        `operations will not be applied locally: siteCode not available from connectionDetails; channel=${this._channel.name}`,
       );
+      return;
+    }
+    // RTO20c2
+    if (!publishResult.serials || publishResult.serials.length !== objectMessages.length) {
+      this._client.Logger.logAction(
+        this._client.logger,
+        this._client.Logger.LOG_ERROR,
+        'RealtimeObject.publishAndApply()',
+        `operations will not be applied locally: PublishResult.serials has unexpected length (expected ${objectMessages.length}, got ${publishResult.serials?.length}); channel=${this._channel.name}`,
+      );
+      return;
     }
 
     // RTO20d
-    const syntheticMessages = objectMessages.map((originalMsg, i) => {
+    const syntheticMessages: ObjectMessage[] = [];
+    for (let i = 0; i < objectMessages.length; i++) {
       const serial = publishResult.serials[i];
 
       // RTO20d1
       if (serial === null) {
-        throw new this._client.ErrorInfo('cannot apply operation locally: serial is null in PublishResult', 40000, 400);
+        this._client.Logger.logAction(
+          this._client.logger,
+          this._client.Logger.LOG_MICRO,
+          'RealtimeObject.publishAndApply()',
+          `operation will not be applied locally: serial is null in PublishResult (index ${i}); channel=${this._channel.name}`,
+        );
+        continue;
       }
 
-      // RTO20d2
-      return ObjectMessage.fromValues(
-        {
-          ...originalMsg,
-          serial, // RTO20d2a
-          siteCode, // RTO20d2b
-        },
-        this._client.Utils,
-        this._client.MessageEncoding,
+      // RTO20d2, RTO20d3
+      syntheticMessages.push(
+        ObjectMessage.fromValues(
+          {
+            ...objectMessages[i],
+            serial, // RTO20d2a
+            siteCode, // RTO20d2b
+          },
+          this._client.Utils,
+          this._client.MessageEncoding,
+        ),
       );
-    });
+    }
 
     // RTO20e - Wait for sync to complete if not synced
     if (this._state !== ObjectsState.synced) {