mirror of
https://github.com/swift-server/swift-openapi-async-http-client.git
synced 2026-05-03 07:42:29 +00:00
PARAIPAN SORIN
e48b152d18
### Motivation - Relates to [#230](https://github.com/apple/swift-openapi-generator/issues/230) ### Modifications - Disable respectsExistingLineBreaks .swift-format rule and address changes requested ### Result - One of the .swift-format rules will be disabled ### Test Plan - Run Tests
111 lines
4.2 KiB
Swift
111 lines
4.2 KiB
Swift
//===----------------------------------------------------------------------===//
|
|
//
|
|
// This source file is part of the SwiftOpenAPIGenerator open source project
|
|
//
|
|
// Copyright (c) 2023 Apple Inc. and the SwiftOpenAPIGenerator project authors
|
|
// Licensed under Apache License v2.0
|
|
//
|
|
// See LICENSE.txt for license information
|
|
// See CONTRIBUTORS.txt for the list of SwiftOpenAPIGenerator project authors
|
|
//
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
//
|
|
//===----------------------------------------------------------------------===//
|
|
import XCTest
|
|
import OpenAPIRuntime
|
|
import NIOCore
|
|
import NIOPosix
|
|
import AsyncHTTPClient
|
|
@testable import OpenAPIAsyncHTTPClient
|
|
import HTTPTypes
|
|
|
|
class Test_AsyncHTTPClientTransport: XCTestCase {
|
|
|
|
static var testData: Data { get throws { try XCTUnwrap(#"[{}]"#.data(using: .utf8)) } }
|
|
|
|
static var testBuffer: ByteBuffer { ByteBuffer(string: #"[{}]"#) }
|
|
|
|
static var testUrl: URL {
|
|
get throws { try XCTUnwrap(URL(string: "http://example.com/api/v1/hello/Maria?greeting=Howdy")) }
|
|
}
|
|
|
|
func testConvertRequest() throws {
|
|
let request: HTTPRequest = .init(
|
|
method: .post,
|
|
scheme: nil,
|
|
authority: nil,
|
|
path: "/hello%20world/Maria?greeting=Howdy",
|
|
headerFields: [.contentType: "application/json"]
|
|
)
|
|
let requestBody = try HTTPBody(Self.testData)
|
|
let httpRequest = try AsyncHTTPClientTransport.convertRequest(
|
|
request,
|
|
body: requestBody,
|
|
baseURL: try XCTUnwrap(URL(string: "http://example.com/api/v1"))
|
|
)
|
|
XCTAssertEqual(httpRequest.url, "http://example.com/api/v1/hello%20world/Maria?greeting=Howdy")
|
|
XCTAssertEqual(httpRequest.method, .POST)
|
|
XCTAssertEqual(httpRequest.headers, ["content-type": "application/json"])
|
|
// TODO: Not sure how to test that httpRequest.body is what we expect, can't
|
|
// find an API for reading it back.
|
|
}
|
|
|
|
func testConvertResponse() async throws {
|
|
let httpResponse = HTTPClientResponse(
|
|
status: .ok,
|
|
headers: ["content-type": "application/json"],
|
|
body: .bytes(Self.testBuffer)
|
|
)
|
|
let (response, maybeResponseBody) = try await AsyncHTTPClientTransport.convertResponse(
|
|
method: .get,
|
|
httpResponse: httpResponse
|
|
)
|
|
let responseBody = try XCTUnwrap(maybeResponseBody)
|
|
XCTAssertEqual(response.status.code, 200)
|
|
XCTAssertEqual(response.headerFields, [.contentType: "application/json"])
|
|
let bufferedResponseBody = try await Data(collecting: responseBody, upTo: .max)
|
|
XCTAssertEqual(bufferedResponseBody, try Self.testData)
|
|
}
|
|
|
|
func testSend() async throws {
|
|
let transport = AsyncHTTPClientTransport(configuration: .init(), requestSender: TestSender.test)
|
|
let request: HTTPRequest = .init(
|
|
method: .get,
|
|
scheme: nil,
|
|
authority: nil,
|
|
path: "/api/v1/hello/Maria",
|
|
headerFields: [.init("x-request")!: "yes"]
|
|
)
|
|
let (response, maybeResponseBody) = try await transport.send(
|
|
request,
|
|
body: nil,
|
|
baseURL: Self.testUrl,
|
|
operationID: "sayHello"
|
|
)
|
|
let responseBody = try XCTUnwrap(maybeResponseBody)
|
|
let bufferedResponseBody = try await String(collecting: responseBody, upTo: .max)
|
|
XCTAssertEqual(bufferedResponseBody, "[{}]")
|
|
XCTAssertEqual(response.status.code, 200)
|
|
}
|
|
}
|
|
|
|
struct TestSender: HTTPRequestSending {
|
|
var sendClosure:
|
|
@Sendable (AsyncHTTPClientTransport.Request, HTTPClient, TimeAmount) async throws ->
|
|
AsyncHTTPClientTransport.Response
|
|
func send(request: AsyncHTTPClientTransport.Request, with client: HTTPClient, timeout: TimeAmount) async throws
|
|
-> AsyncHTTPClientTransport.Response
|
|
{ try await sendClosure(request, client, timeout) }
|
|
|
|
static var test: Self {
|
|
TestSender { request, _, _ in
|
|
XCTAssertEqual(request.headers.first(name: "x-request"), "yes")
|
|
return HTTPClientResponse(
|
|
status: .ok,
|
|
headers: ["content-type": "application/json"],
|
|
body: .bytes(Test_AsyncHTTPClientTransport.testBuffer)
|
|
)
|
|
}
|
|
}
|
|
}
|