streamline performSpeechRequest

Sources/OpenAI/OpenAI.swift

@@ -112,8 +112,8 @@ final public class OpenAI: OpenAIProtocol {
         performRequest(request: MultipartFormDataRequest<AudioTranslationResult>(body: query, url: buildURL(path: .audioTranslations)), completion: completion)
     }
 
-    public func audioCreateSpeech(query: AudioSpeechQuery, completion: @escaping (Result<AudioSpeechResult, Error>) -> Void) {
-        performSpeechRequest(request: JSONRequest<AudioSpeechResult>(body: query, url: buildURL(path: .audioSpeech)), completion: completion)
+    public func audioCreateSpeech(query: AudioSpeechQuery, completion: @escaping (Result<Data, Error>) -> Void) {
+        performRequest(request: JSONRequest<Data>(body: query, url: buildURL(path: .audioSpeech)), completion: completion)
     }
 
 }
@@ -136,7 +136,11 @@ extension OpenAI {
                 do {
                     completion(.success(try decoder.decode(ResultType.self, from: data)))
                 } catch {
-                    completion(.failure((try? decoder.decode(APIErrorResponse.self, from: data)) ?? error))
+                    if ResultType.self == Data.self {
+                        completion(.success(data as! ResultType))
+                    } else {
+                        completion(.failure((try? decoder.decode(APIErrorResponse.self, from: data)) ?? error))
+                    }
                 }
             }
             task.resume()
@@ -167,28 +171,6 @@ extension OpenAI {
             completion?(error)
         }
     }
-
-    func performSpeechRequest(request: any URLRequestBuildable, completion: @escaping (Result<AudioSpeechResult, Error>) -> Void) {
-        do {
-            let request = try request.build(token: configuration.token, 
-                                            organizationIdentifier: configuration.organizationIdentifier,
-                                            timeoutInterval: configuration.timeoutInterval)
-
-            let task = session.dataTask(with: request) { data, _, error in
-                if let error = error {
-                    return completion(.failure(error))
-                }
-                guard let data = data else {
-                    return completion(.failure(OpenAIError.emptyData))
-                }
-
-                completion(.success(AudioSpeechResult(audio: data)))
-            }
-            task.resume()
-        } catch {
-            completion(.failure(error))
-        }
-    }
 }
 
 extension OpenAI {

Sources/OpenAI/Public/Protocols/OpenAIProtocol+Async.swift

@@ -191,7 +191,7 @@ public extension OpenAIProtocol {
             audioCreateSpeech(query: query) { result in
                 switch result {
                 case let .success(success):
-                    return continuation.resume(returning: success)
+                    return continuation.resume(returning: AudioSpeechResult(audio: success))
                 case let .failure(failure):
                     return continuation.resume(throwing: failure)
                 }

Sources/OpenAI/Public/Protocols/OpenAIProtocol+Combine.swift

@@ -8,6 +8,7 @@
 #if canImport(Combine)
 
 import Combine
+import Foundation
 
 @available(iOS 13.0, *)
 @available(tvOS 13.0, *)
@@ -113,8 +114,8 @@ public extension OpenAIProtocol {
         .eraseToAnyPublisher()
     }
 
-    func audioCreateSpeech(query: AudioSpeechQuery) -> AnyPublisher<AudioSpeechResult, Error> {
-        Future<AudioSpeechResult, Error> {
+    func audioCreateSpeech(query: AudioSpeechQuery) -> AnyPublisher<Data, Error> {
+        Future<Data, Error> {
             audioCreateSpeech(query: query, completion: $0)
         }
         .eraseToAnyPublisher()

Sources/OpenAI/Public/Protocols/OpenAIProtocol.swift

@@ -228,8 +228,8 @@ public protocol OpenAIProtocol {
        - query: An `AudioSpeechQuery` object containing the parameters for the API request. This includes the Text-to-Speech model to be used, input text, voice to be used for generating the audio, the desired audio format, and the speed of the generated audio.
        - completion: A closure which receives the result. The closure's parameter, `Result<AudioSpeechResult, Error>`, will either contain the `AudioSpeechResult` object with the audio data or an error if the request failed.
      */
-    func audioCreateSpeech(query: AudioSpeechQuery, completion: @escaping (Result<AudioSpeechResult, Error>) -> Void)
-    
+    func audioCreateSpeech(query: AudioSpeechQuery, completion: @escaping (Result<Data, Error>) -> Void)
+
     /**
     Transcribes audio data using OpenAI's audio transcription API and completes the operation asynchronously.