From 00e49473ec45e03a8b441c2eb5a6c95df8236f56 Mon Sep 17 00:00:00 2001
From: Hiroshi Horie <548776+hiroshihorie@users.noreply.github.com>
Date: Wed, 1 Nov 2023 04:53:03 +0800
Subject: [PATCH] async: Engine.sendSyncState

---
 Sources/LiveKit/Core/Engine.swift | 18 ++++++++----------
 1 file changed, 8 insertions(+), 10 deletions(-)

diff --git a/Sources/LiveKit/Core/Engine.swift b/Sources/LiveKit/Core/Engine.swift
index c367960fe..a16375b7f 100644
--- a/Sources/LiveKit/Core/Engine.swift
+++ b/Sources/LiveKit/Core/Engine.swift
@@ -452,7 +452,7 @@ internal extension Engine {
                             return promise(from: self.primaryTransportConnectedCompleter.wait)
                            }.then(on: queue) { _ in
                             // send SyncState before offer
-                            self.sendSyncState()
+                            promise(from: self.sendSyncState)
                            }.then(on: queue) { () -> Promise<Void> in
 
                             self.subscriber?.restartingIce = true
@@ -547,18 +547,18 @@ internal extension Engine {
 
 internal extension Engine {
 
-    func sendSyncState() -> Promise<Void> {
+    func sendSyncState() async throws {
 
         guard let room = room else {
             // this should never happen
             log("Room is nil", .error)
-            return Promise(())
+            return
         }
 
         guard let subscriber = subscriber,
               let previousAnswer = subscriber.localDescription else {
             // No-op
-            return Promise(())
+            return
         }
 
         let previousOffer = subscriber.remoteDescription
@@ -583,12 +583,10 @@ internal extension Engine {
             $0.subscribe = !autoSubscribe
         }
 
-        return promise(from: signalClient.sendSyncState,
-                       param1: previousAnswer.toPBType(),
-                       param2: previousOffer?.toPBType(),
-                       param3: subscription,
-                       param4: room._state.localParticipant?.publishedTracksInfo(),
-                       param5: publisherDC.infos())
+        try await signalClient.sendSyncState(answer: previousAnswer.toPBType(),
+                                             offer: previousOffer?.toPBType(),
+                                             subscription: subscription, publishTracks: room._state.localParticipant?.publishedTracksInfo(),
+                                             dataChannels: publisherDC.infos())
     }
 }