From d2fe696d236b279591e4b542c4cf4facf5765601 Mon Sep 17 00:00:00 2001
From: Lawrence Forooghian <lawrence@forooghian.com>
Date: Wed, 13 Nov 2024 13:40:25 -0300
Subject: [PATCH] Link the SUSPENDED status to a RETRY operation
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

This is to allow us to make the tests for the upcoming RETRY operation
more realistic. Our initial implementation of the RETRY operation won’t
actually put the room into the SUSPENDED status, though; I’ll figure out
the right place to do that once we actually trigger this operation
internally in #50.
---
 Sources/AblyChat/RoomLifecycleManager.swift | 13 +++++++------
 1 file changed, 7 insertions(+), 6 deletions(-)

diff --git a/Sources/AblyChat/RoomLifecycleManager.swift b/Sources/AblyChat/RoomLifecycleManager.swift
index de1dedf8..64e99de4 100644
--- a/Sources/AblyChat/RoomLifecycleManager.swift
+++ b/Sources/AblyChat/RoomLifecycleManager.swift
@@ -185,7 +185,7 @@ internal actor DefaultRoomLifecycleManager<Contributor: RoomLifecycleContributor
         case attached
         case detaching(detachOperationID: UUID)
         case detached
-        case suspended(error: ARTErrorInfo)
+        case suspended(retryOperationID: UUID, error: ARTErrorInfo)
         case failed(error: ARTErrorInfo)
         case releasing(releaseOperationID: UUID)
         case released
@@ -204,7 +204,7 @@ internal actor DefaultRoomLifecycleManager<Contributor: RoomLifecycleContributor
                 .detaching
             case .detached:
                 .detached
-            case let .suspended(error):
+            case let .suspended(_, error):
                 .suspended(error: error)
             case let .failed(error):
                 .failed(error: error)
@@ -223,8 +223,9 @@ internal actor DefaultRoomLifecycleManager<Contributor: RoomLifecycleContributor
                 detachOperationID
             case let .releasing(releaseOperationID):
                 releaseOperationID
-            case .suspended,
-                 .initialized,
+            case let .suspended(retryOperationID, _):
+                retryOperationID
+            case .initialized,
                  .attached,
                  .detached,
                  .failed,
@@ -462,7 +463,7 @@ internal actor DefaultRoomLifecycleManager<Contributor: RoomLifecycleContributor
 
                 clearTransientDisconnectTimeouts()
 
-                changeStatus(to: .suspended(error: reason))
+                changeStatus(to: .suspended(retryOperationID: UUID(), error: reason))
             }
         case .attaching:
             if !hasOperationInProgress, !contributorAnnotations[contributor].hasTransientDisconnectTimeout {
@@ -706,7 +707,7 @@ internal actor DefaultRoomLifecycleManager<Contributor: RoomLifecycleContributor
                 case .suspended:
                     // CHA-RL1h2
                     let error = ARTErrorInfo(chatError: .attachmentFailed(feature: contributor.feature, underlyingError: contributorAttachError))
-                    changeStatus(to: .suspended(error: error))
+                    changeStatus(to: .suspended(retryOperationID: UUID(), error: error))
 
                     // CHA-RL1h3
                     throw error