Generated using our own generator (#504)

Scripts/generate.sh

@@ -0,0 +1,24 @@
+#!/usr/bin/env bash
+
+SOURCE_PATH=../chat
+
+if [ ! -d $SOURCE_PATH ]
+then
+  echo "cannot find chat path on the parent folder (${SOURCE_PATH}), do you have a copy of the API source?";
+  exit 1;
+fi
+
+set -ex
+
+# remove old generated code
+rm -rf ./Sources/StreamVideo/OpenApi/generated/Models/*
+
+# cd in API repo, generate new spec and then generate code from it
+(
+  cd $SOURCE_PATH &&
+  go run ./cmd/chat-manager openapi generate-spec -products video -version v1 -clientside -output releases/video-openapi-clientside &&
+  go run ./cmd/chat-manager openapi generate-client --language swift --spec ./releases/video-openapi-clientside.yaml --output ../stream-video-swift/Sources/StreamVideo/OpenApi/generated/
+)
+
+# format the generated code
+mint run swiftformat Sources/StreamVideo/OpenApi/generated

Sources/StreamVideo/Call.swift

@@ -182,7 +182,8 @@ public class Call: @unchecked Sendable, WSEventsSubscriber {
             id: callId,
             membersLimit: membersLimit,
             ring: ring,
-            notify: notify
+            notify: notify,
+            video: nil
         )
         await state.update(from: response)
         if ring {
@@ -819,7 +820,7 @@ public class Call: @unchecked Sendable, WSEventsSubscriber {
             sort: sort,
             type: callType
         )
-        let response = try await coordinatorClient.queryMembers(queryMembersRequest: request)
+        let response = try await coordinatorClient.queryCallMembers(queryMembersRequest: request)
         await state.mergeMembers(response.members)
         return response
     }
@@ -1108,7 +1109,7 @@ public class Call: @unchecked Sendable, WSEventsSubscriber {
     @discardableResult
     @MainActor
     public func collectUserFeedback(
-        rating: Int? = nil,
+        rating: Int,
         reason: String? = nil,
         custom: [String: RawJSON]? = nil
     ) async throws -> CollectUserFeedbackResponse {
@@ -1331,7 +1332,7 @@ public class Call: @unchecked Sendable, WSEventsSubscriber {
 
     /// Handles updates to noise cancellation settings.
     /// - Parameter value: The updated `NoiseCancellationSettings` value.
-    private func didUpdate(_ value: NoiseCancellationSettings?) {
+    private func didUpdate(_ value: NoiseCancellationSettingsRequest?) {
         guard let noiseCancellationFilter = streamVideo.videoConfig.noiseCancellationFilter else {
             log
                 .warning(

Sources/StreamVideo/CallState.swift

@@ -213,6 +213,8 @@ public class CallState: ObservableObject {
         case .typeHealthCheckEvent:
             // note: health checks are not relevant for call state sync'ing
             break
+        case .typeCallUserMutedEvent:
+            break
         case .typeCallDeletedEvent:
             break
         case .typeCallHLSBroadcastingFailedEvent:
@@ -237,12 +239,12 @@ public class CallState: ObservableObject {
             break
         case .typeCallRtmpBroadcastStoppedEvent:
             break
-        case .typeCallUserMutedEvent:
-            break
         case .typeCallRtmpBroadcastFailedEvent:
             break
         case .typeCallSessionParticipantCountsUpdatedEvent:
             break
+        case .typeUserUpdatedEvent:
+            break
         }
     }
 

Sources/StreamVideo/Controllers/CallController.swift

@@ -406,7 +406,7 @@ class CallController: @unchecked Sendable {
     func collectUserFeedback(
         sessionID: String,
         custom: [String: RawJSON]? = nil,
-        rating: Int? = nil,
+        rating: Int,
         reason: String? = nil
     ) async throws -> CollectUserFeedbackResponse {
         try await defaultAPI.collectUserFeedback(

Sources/StreamVideo/Models/CoordinatorModels.swift

@@ -4,31 +4,6 @@
 
 import Foundation
 
-extension CallSettingsResponse: @unchecked Sendable {}
-extension ModelResponse: @unchecked Sendable {}
-extension AcceptCallResponse: @unchecked Sendable {}
-extension RejectCallResponse: @unchecked Sendable {}
-extension CallResponse: @unchecked Sendable {}
-extension OwnCapability: @unchecked Sendable {}
-extension MemberRequest: @unchecked Sendable {}
-extension MemberResponse: @unchecked Sendable {}
-extension UpdateCallMembersResponse: @unchecked Sendable {}
-extension CallSettingsRequest: @unchecked Sendable {}
-extension JoinCallResponse: @unchecked Sendable {}
-extension GetOrCreateCallResponse: @unchecked Sendable {}
-extension GetCallResponse: @unchecked Sendable {}
-extension UpdateCallResponse: @unchecked Sendable {}
-extension BlockUserResponse: @unchecked Sendable {}
-extension UnblockUserResponse: @unchecked Sendable {}
-extension MuteUsersResponse: @unchecked Sendable {}
-extension MuteUsersRequest: @unchecked Sendable {}
-extension PinRequest: @unchecked Sendable {}
-extension UnpinRequest: @unchecked Sendable {}
-extension PinResponse: @unchecked Sendable {}
-extension UnpinResponse: @unchecked Sendable {}
-extension GoLiveResponse: @unchecked Sendable {}
-extension SendReactionResponse: @unchecked Sendable {}
-
 public struct FetchingLocationError: Error {}
 
 public enum RecordingState {

Sources/StreamVideo/Models/User.swift

@@ -73,6 +73,7 @@ public extension User {
 public extension UserResponse {
     static func make(from id: String) -> UserResponse {
         UserResponse(
+            blockedUserIds: [],
             createdAt: Date(),
             custom: [:],
             id: id,

Sources/StreamVideo/Models/VideoOptions.swift

@@ -34,7 +34,7 @@ struct VideoOptions: Sendable {
                     preferredFormat: preferredFormat,
                     preferredDimensions: preferredDimensions,
                     preferredFps: preferredFps,
-                    preferredBitrate: targetResolution.bitrate
+                    preferredBitrate: targetResolution.bitrate ?? .maxBitrate
                 )
             } catch {
                 supportedCodecs = VideoCodec.defaultCodecs
@@ -67,7 +67,7 @@ extension VideoCodec {
     static let full = VideoCodec(
         dimensions: .full,
         quality: "f",
-        maxBitrate: 1_000_000,
+        maxBitrate: .maxBitrate,
         sfuQuality: .high
     )
 
@@ -90,7 +90,11 @@ extension VideoCodec {
     static let screenshare = VideoCodec(
         dimensions: .full,
         quality: "q",
-        maxBitrate: 1_000_000,
+        maxBitrate: .maxBitrate,
         sfuQuality: .high
     )
 }
+
+extension Int {
+    static let maxBitrate = 1_000_000
+}

Sources/StreamVideo/OpenApi/AuthMiddlewares.swift

@@ -41,7 +41,6 @@ struct AnonymousAuth: DefaultAPIClientMiddleware {
         modifiedRequest.headers["stream-auth-type"] = "anonymous"
         return try await next(modifiedRequest)
     }
-
 }
 
 struct DefaultParams: DefaultAPIClientMiddleware {
@@ -58,5 +57,4 @@ struct DefaultParams: DefaultAPIClientMiddleware {
         modifiedRequest.headers["x-client-request-id"] = UUID().uuidString
         return try await next(modifiedRequest)
     }
-
 }

Sources/StreamVideo/OpenApi/OwnCapability+Identifiable.swift

@@ -1,8 +1,11 @@
+//
+// Copyright © 2024 Stream.io Inc. All rights reserved.
+//
+
 import Foundation
 
 extension OwnCapability: Identifiable {
     public var id: String {
         rawValue
     }
 }
-

Sources/StreamVideo/OpenApi/URLSessionTransport.swift

@@ -121,12 +121,13 @@ final class URLSessionTransport: DefaultAPITransport, @unchecked Sendable {
         do {
             return try await execute(request: clone.urlRequest())
         } catch {
-            // Log error and rethrow          
+            // Log error and rethrow
             log.error(
                 "URLSessionTransport: \(String(describing: request.url.absoluteString))\n"
                     + "Headers:\n\(String(describing: request.headers))\n"
                     + "Query items:\n\(request.queryParams)",
-                subsystems: .httpRequests, error: error)
+                subsystems: .httpRequests, error: error
+            )
             throw error
         }
     }

Sources/StreamVideo/OpenApi/generated/APIHelper.swift

@@ -1,12 +1,10 @@
-// APIHelper.swift
 //
-// Generated by openapi-generator
-// https://openapi-generator.tech
+// Copyright © 2024 Stream.io Inc. All rights reserved.
 //
 
 import Foundation
 
-public struct APIHelper {
+public enum APIHelper {
     public static func rejectNil(_ source: [String: Any?]) -> [String: Any]? {
         let destination = source.reduce(into: [String: Any]()) { result, item in
             if let value = item.value {
@@ -21,7 +19,7 @@ public struct APIHelper {
     }
 
     public static func rejectNilHeaders(_ source: [String: Any?]) -> [String: String] {
-        return source.reduce(into: [String: String]()) { result, item in
+        source.reduce(into: [String: String]()) { result, item in
             if let collection = item.value as? [Any?] {
                 result[item.key] = collection
                     .compactMap { value in convertAnyToString(value) }