//
// Copyright 2023 Signal Messenger, LLC
// SPDX-License-Identifier: AGPL-3.0-only
//

import Foundation
import LibSignalClient

// MARK: -

public protocol SgxWebsocketConnectionFactory {

    /// Connect to an SgxClient-conformant server via websocket and perform the initial handshake.
    ///
    /// - Parameters:
    ///   - queue: The queue to use.
    /// - Returns:
    ///     A Promise for an established connection. If the Promise doesn’t
    ///     resolve to an error, the caller is responsible for ensuring the
    ///     returned connection is properly disconnected.
    func connectAndPerformHandshake<Configurator: SgxWebsocketConfigurator>(
        configurator: Configurator,
    ) async throws -> SgxWebsocketConnection<Configurator>
}

final class SgxWebsocketConnectionFactoryImpl: SgxWebsocketConnectionFactory {

    private let websocketFactory: WebSocketFactory

    init(websocketFactory: WebSocketFactory) {
        self.websocketFactory = websocketFactory
    }

    func connectAndPerformHandshake<Configurator: SgxWebsocketConfigurator>(
        configurator: Configurator,
    ) async throws -> SgxWebsocketConnection<Configurator> {
        let websocketFactory = self.websocketFactory
        let auth = try await configurator.fetchAuth()
        return try await SgxWebsocketConnectionImpl<Configurator>.connectAndPerformHandshake(
            configurator: configurator,
            auth: auth,
            websocketFactory: websocketFactory,
        )
    }
}