Use StarScream branch which prevents multiple URLSession creation

home-assistant · Mar 27, 2024 · f5547e7 · f5547e7
1 parent 8d1361d
commit f5547e7
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 7 deletions.
diff --git a/Package.resolved b/Package.resolved
@@ -12,11 +12,11 @@
       },
       {
         "package": "Starscream",
-        "repositoryURL": "https://github.com/daltoniam/Starscream",
+        "repositoryURL": "https://github.com/bgoncal/Starscream",
         "state": {
-          "branch": null,
-          "revision": "df8d82047f6654d8e4b655d1b1525c64e1059d21",
-          "version": "4.0.4"
+          "branch": "ha-URLSession-fix",
+          "revision": "7e3d24425c20649105cb4bdd612b6bab66f73ade",
+          "version": null
         }
       }
     ]

diff --git a/Package.swift b/Package.swift
@@ -19,8 +19,8 @@ public let package = Package(
     ],
     dependencies: [
         .package(
-            url: "https://github.com/daltoniam/Starscream",
-            from: "4.0.4"
+            url: "https://github.com/bgoncal/Starscream",
+            .branchItem("ha-URLSession-fix")
         ),
         .package(
             url: "https://github.com/mxcl/PromiseKit",

diff --git a/Source/Internal/HAConnectionImpl+Responses.swift b/Source/Internal/HAConnectionImpl+Responses.swift
@@ -1,7 +1,7 @@
 import Starscream
 
 extension HAConnectionImpl: Starscream.WebSocketDelegate {
-    func didReceive(event: Starscream.WebSocketEvent, client: Starscream.WebSocket) {
+    func didReceive(event: Starscream.WebSocketEvent, client: any Starscream.WebSocketClient) {
         responseController.didReceive(event: event)
     }
 }

diff --git a/Source/Internal/ResponseController/HAResponseController.swift b/Source/Internal/ResponseController/HAResponseController.swift
@@ -124,6 +124,8 @@ internal class HAResponseControllerImpl: HAResponseController {
         case let .error(error):
             HAGlobal.log(.error, "Error: \(String(describing: error))")
             phase = .disconnected(error: error, forReset: false)
+        case .peerClosed:
+            HAGlobal.log(.info, "Peer closed")
         }
     }