fix: Improve LiveQuery tasks running (#215)

* fix: Improve LiveQuery tasks running

* resume task after creating unless closing socket

* resume task after

Author: cbaker6

Sources/ParseSwift/LiveQuery/LiveQuerySocket.swift

@@ -37,7 +37,6 @@ final class LiveQuerySocket: NSObject, @unchecked Sendable {
     func createTask(_ url: URL, taskDelegate: LiveQuerySocketDelegate) async -> URLSessionWebSocketTask {
         let task = session.webSocketTask(with: url)
         await tasks.updateDelegates([task: taskDelegate])
-		await receive(task)
         return task
     }
 
@@ -97,9 +96,6 @@ extension LiveQuerySocket {
 		let delegates = await self.tasks.getDelegates()
 		do {
 
-			if task.state == .suspended {
-				task.resume()
-			}
 			let result = try await task.receive()
 			await self.tasks.removeReceivers([task])
 

Sources/ParseSwift/LiveQuery/ParseLiveQuery.swift

@@ -316,15 +316,17 @@ extension ParseLiveQuery {
 		}
         switch task.state {
         case .suspended:
+			task.resume()
             await URLSession.liveQuery.receive(task)
         case .completed, .canceling:
             let oldTask = task
-            let newTask = await URLSession.liveQuery.createTask(
+			await URLSession.liveQuery.removeTask(oldTask)
+			let newTask = await URLSession.liveQuery.createTask(
 				self.url,
 				taskDelegate: self
 			)
 			self.task = newTask
-			await URLSession.liveQuery.removeTask(oldTask)
+			try await resumeTask()
         case .running:
             try await self.open(isUserWantsToConnect: false)
         @unknown default:
@@ -468,15 +470,15 @@ extension ParseLiveQuery {
             self.isDisconnectedByUser = true
             let oldTask = self.task
             await self.setStatus(.socketNotEstablished)
-            // Prepare new task for future use.
+			if let oldTask = oldTask {
+				await URLSession.liveQuery.removeTask(oldTask)
+			}
+			// Prepare new task for future use.
             let newTask = await URLSession.liveQuery.createTask(
 				self.url,
 				taskDelegate: self
 			)
 			self.task = newTask
-            if let oldTask = oldTask {
-                await URLSession.liveQuery.removeTask(oldTask)
-            }
         }
     }
 

Sources/ParseSwift/ParseConstants.swift

@@ -10,7 +10,7 @@ import Foundation
 
 enum ParseConstants {
     static let sdk = "swift"
-    static let version = "6.0.0-beta.2"
+    static let version = "6.0.0-beta.3"
     static let fileManagementDirectory = "parse/"
     static let fileManagementPrivateDocumentsDirectory = "Private Documents/"
     static let fileManagementLibraryDirectory = "Library/"