| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643 |
- /*
- * Copyright 2023, gRPC Authors All rights reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
- #if os(macOS) || os(Linux) // swift-format doesn't like canImport(Foundation.Process)
- import XCTest
- @testable import GRPCCodeGen
- final class ClientCodeTranslatorSnippetBasedTests: XCTestCase {
- typealias MethodDescriptor = GRPCCodeGen.CodeGenerationRequest.ServiceDescriptor.MethodDescriptor
- typealias ServiceDescriptor = GRPCCodeGen.CodeGenerationRequest.ServiceDescriptor
- typealias Name = GRPCCodeGen.CodeGenerationRequest.Name
- func testClientCodeTranslatorUnaryMethod() throws {
- let method = MethodDescriptor(
- documentation: "/// Documentation for MethodA",
- name: Name(base: "MethodA", generatedUpperCase: "MethodA", generatedLowerCase: "methodA"),
- isInputStreaming: false,
- isOutputStreaming: false,
- inputType: "NamespaceA_ServiceARequest",
- outputType: "NamespaceA_ServiceAResponse"
- )
- let service = ServiceDescriptor(
- documentation: "/// Documentation for ServiceA",
- name: Name(base: "ServiceA", generatedUpperCase: "ServiceA", generatedLowerCase: ""),
- namespace: Name(base: "namespaceA", generatedUpperCase: "NamespaceA", generatedLowerCase: ""),
- methods: [method]
- )
- let expectedSwift =
- """
- /// Documentation for ServiceA
- @available(macOS 13.0, iOS 16.0, watchOS 9.0, tvOS 16.0, *)
- public protocol NamespaceA_ServiceAClientProtocol: Sendable {
- /// Documentation for MethodA
- func methodA<R>(
- request: ClientRequest.Single<NamespaceA_ServiceA.Method.MethodA.Input>,
- serializer: some MessageSerializer<NamespaceA_ServiceA.Method.MethodA.Input>,
- deserializer: some MessageDeserializer<NamespaceA_ServiceA.Method.MethodA.Output>,
- options: CallOptions,
- _ body: @Sendable @escaping (ClientResponse.Single<NamespaceA_ServiceA.Method.MethodA.Output>) async throws -> R
- ) async throws -> R where R: Sendable
- }
- @available(macOS 13.0, iOS 16.0, watchOS 9.0, tvOS 16.0, *)
- extension NamespaceA_ServiceA.ClientProtocol {
- public func methodA<R>(
- request: ClientRequest.Single<NamespaceA_ServiceA.Method.MethodA.Input>,
- options: CallOptions = .defaults,
- _ body: @Sendable @escaping (ClientResponse.Single<NamespaceA_ServiceA.Method.MethodA.Output>) async throws -> R
- ) async throws -> R where R: Sendable {
- try await self.methodA(
- request: request,
- serializer: ProtobufSerializer<NamespaceA_ServiceA.Method.MethodA.Input>(),
- deserializer: ProtobufDeserializer<NamespaceA_ServiceA.Method.MethodA.Output>(),
- options: options,
- body
- )
- }
- }
- /// Documentation for ServiceA
- @available(macOS 13.0, iOS 16.0, watchOS 9.0, tvOS 16.0, *)
- public struct NamespaceA_ServiceAClient: NamespaceA_ServiceA.ClientProtocol {
- private let client: GRPCCore.GRPCClient
-
- public init(client: GRPCCore.GRPCClient) {
- self.client = client
- }
-
- /// Documentation for MethodA
- public func methodA<R>(
- request: ClientRequest.Single<NamespaceA_ServiceA.Method.MethodA.Input>,
- serializer: some MessageSerializer<NamespaceA_ServiceA.Method.MethodA.Input>,
- deserializer: some MessageDeserializer<NamespaceA_ServiceA.Method.MethodA.Output>,
- options: CallOptions = .defaults,
- _ body: @Sendable @escaping (ClientResponse.Single<NamespaceA_ServiceA.Method.MethodA.Output>) async throws -> R
- ) async throws -> R where R: Sendable {
- try await self.client.unary(
- request: request,
- descriptor: NamespaceA_ServiceA.Method.MethodA.descriptor,
- serializer: serializer,
- deserializer: deserializer,
- options: options,
- handler: body
- )
- }
- }
- """
- try self.assertClientCodeTranslation(
- codeGenerationRequest: makeCodeGenerationRequest(services: [service]),
- expectedSwift: expectedSwift,
- accessLevel: .public
- )
- }
- func testClientCodeTranslatorClientStreamingMethod() throws {
- let method = MethodDescriptor(
- documentation: "/// Documentation for MethodA",
- name: Name(base: "MethodA", generatedUpperCase: "MethodA", generatedLowerCase: "methodA"),
- isInputStreaming: true,
- isOutputStreaming: false,
- inputType: "NamespaceA_ServiceARequest",
- outputType: "NamespaceA_ServiceAResponse"
- )
- let service = ServiceDescriptor(
- documentation: "/// Documentation for ServiceA",
- name: Name(base: "ServiceA", generatedUpperCase: "ServiceA", generatedLowerCase: ""),
- namespace: Name(base: "namespaceA", generatedUpperCase: "NamespaceA", generatedLowerCase: ""),
- methods: [method]
- )
- let expectedSwift =
- """
- /// Documentation for ServiceA
- @available(macOS 13.0, iOS 16.0, watchOS 9.0, tvOS 16.0, *)
- public protocol NamespaceA_ServiceAClientProtocol: Sendable {
- /// Documentation for MethodA
- func methodA<R>(
- request: ClientRequest.Stream<NamespaceA_ServiceA.Method.MethodA.Input>,
- serializer: some MessageSerializer<NamespaceA_ServiceA.Method.MethodA.Input>,
- deserializer: some MessageDeserializer<NamespaceA_ServiceA.Method.MethodA.Output>,
- options: CallOptions,
- _ body: @Sendable @escaping (ClientResponse.Single<NamespaceA_ServiceA.Method.MethodA.Output>) async throws -> R
- ) async throws -> R where R: Sendable
- }
- @available(macOS 13.0, iOS 16.0, watchOS 9.0, tvOS 16.0, *)
- extension NamespaceA_ServiceA.ClientProtocol {
- public func methodA<R>(
- request: ClientRequest.Stream<NamespaceA_ServiceA.Method.MethodA.Input>,
- options: CallOptions = .defaults,
- _ body: @Sendable @escaping (ClientResponse.Single<NamespaceA_ServiceA.Method.MethodA.Output>) async throws -> R
- ) async throws -> R where R: Sendable {
- try await self.methodA(
- request: request,
- serializer: ProtobufSerializer<NamespaceA_ServiceA.Method.MethodA.Input>(),
- deserializer: ProtobufDeserializer<NamespaceA_ServiceA.Method.MethodA.Output>(),
- options: options,
- body
- )
- }
- }
- /// Documentation for ServiceA
- @available(macOS 13.0, iOS 16.0, watchOS 9.0, tvOS 16.0, *)
- public struct NamespaceA_ServiceAClient: NamespaceA_ServiceA.ClientProtocol {
- private let client: GRPCCore.GRPCClient
-
- public init(client: GRPCCore.GRPCClient) {
- self.client = client
- }
-
- /// Documentation for MethodA
- public func methodA<R>(
- request: ClientRequest.Stream<NamespaceA_ServiceA.Method.MethodA.Input>,
- serializer: some MessageSerializer<NamespaceA_ServiceA.Method.MethodA.Input>,
- deserializer: some MessageDeserializer<NamespaceA_ServiceA.Method.MethodA.Output>,
- options: CallOptions = .defaults,
- _ body: @Sendable @escaping (ClientResponse.Single<NamespaceA_ServiceA.Method.MethodA.Output>) async throws -> R
- ) async throws -> R where R: Sendable {
- try await self.client.clientStreaming(
- request: request,
- descriptor: NamespaceA_ServiceA.Method.MethodA.descriptor,
- serializer: serializer,
- deserializer: deserializer,
- options: options,
- handler: body
- )
- }
- }
- """
- try self.assertClientCodeTranslation(
- codeGenerationRequest: makeCodeGenerationRequest(services: [service]),
- expectedSwift: expectedSwift,
- accessLevel: .public
- )
- }
- func testClientCodeTranslatorServerStreamingMethod() throws {
- let method = MethodDescriptor(
- documentation: "/// Documentation for MethodA",
- name: Name(base: "MethodA", generatedUpperCase: "MethodA", generatedLowerCase: "methodA"),
- isInputStreaming: false,
- isOutputStreaming: true,
- inputType: "NamespaceA_ServiceARequest",
- outputType: "NamespaceA_ServiceAResponse"
- )
- let service = ServiceDescriptor(
- documentation: "/// Documentation for ServiceA",
- name: Name(base: "ServiceA", generatedUpperCase: "ServiceA", generatedLowerCase: ""),
- namespace: Name(base: "namespaceA", generatedUpperCase: "NamespaceA", generatedLowerCase: ""),
- methods: [method]
- )
- let expectedSwift =
- """
- /// Documentation for ServiceA
- @available(macOS 13.0, iOS 16.0, watchOS 9.0, tvOS 16.0, *)
- public protocol NamespaceA_ServiceAClientProtocol: Sendable {
- /// Documentation for MethodA
- func methodA<R>(
- request: ClientRequest.Single<NamespaceA_ServiceA.Method.MethodA.Input>,
- serializer: some MessageSerializer<NamespaceA_ServiceA.Method.MethodA.Input>,
- deserializer: some MessageDeserializer<NamespaceA_ServiceA.Method.MethodA.Output>,
- options: CallOptions,
- _ body: @Sendable @escaping (ClientResponse.Stream<NamespaceA_ServiceA.Method.MethodA.Output>) async throws -> R
- ) async throws -> R where R: Sendable
- }
- @available(macOS 13.0, iOS 16.0, watchOS 9.0, tvOS 16.0, *)
- extension NamespaceA_ServiceA.ClientProtocol {
- public func methodA<R>(
- request: ClientRequest.Single<NamespaceA_ServiceA.Method.MethodA.Input>,
- options: CallOptions = .defaults,
- _ body: @Sendable @escaping (ClientResponse.Stream<NamespaceA_ServiceA.Method.MethodA.Output>) async throws -> R
- ) async throws -> R where R: Sendable {
- try await self.methodA(
- request: request,
- serializer: ProtobufSerializer<NamespaceA_ServiceA.Method.MethodA.Input>(),
- deserializer: ProtobufDeserializer<NamespaceA_ServiceA.Method.MethodA.Output>(),
- options: options,
- body
- )
- }
- }
- /// Documentation for ServiceA
- @available(macOS 13.0, iOS 16.0, watchOS 9.0, tvOS 16.0, *)
- public struct NamespaceA_ServiceAClient: NamespaceA_ServiceA.ClientProtocol {
- private let client: GRPCCore.GRPCClient
-
- public init(client: GRPCCore.GRPCClient) {
- self.client = client
- }
-
- /// Documentation for MethodA
- public func methodA<R>(
- request: ClientRequest.Single<NamespaceA_ServiceA.Method.MethodA.Input>,
- serializer: some MessageSerializer<NamespaceA_ServiceA.Method.MethodA.Input>,
- deserializer: some MessageDeserializer<NamespaceA_ServiceA.Method.MethodA.Output>,
- options: CallOptions = .defaults,
- _ body: @Sendable @escaping (ClientResponse.Stream<NamespaceA_ServiceA.Method.MethodA.Output>) async throws -> R
- ) async throws -> R where R: Sendable {
- try await self.client.serverStreaming(
- request: request,
- descriptor: NamespaceA_ServiceA.Method.MethodA.descriptor,
- serializer: serializer,
- deserializer: deserializer,
- options: options,
- handler: body
- )
- }
- }
- """
- try self.assertClientCodeTranslation(
- codeGenerationRequest: makeCodeGenerationRequest(services: [service]),
- expectedSwift: expectedSwift,
- accessLevel: .public
- )
- }
- func testClientCodeTranslatorBidirectionalStreamingMethod() throws {
- let method = MethodDescriptor(
- documentation: "/// Documentation for MethodA",
- name: Name(base: "MethodA", generatedUpperCase: "MethodA", generatedLowerCase: "methodA"),
- isInputStreaming: true,
- isOutputStreaming: true,
- inputType: "NamespaceA_ServiceARequest",
- outputType: "NamespaceA_ServiceAResponse"
- )
- let service = ServiceDescriptor(
- documentation: "/// Documentation for ServiceA",
- name: Name(base: "ServiceA", generatedUpperCase: "ServiceA", generatedLowerCase: ""),
- namespace: Name(base: "namespaceA", generatedUpperCase: "NamespaceA", generatedLowerCase: ""),
- methods: [method]
- )
- let expectedSwift =
- """
- /// Documentation for ServiceA
- @available(macOS 13.0, iOS 16.0, watchOS 9.0, tvOS 16.0, *)
- public protocol NamespaceA_ServiceAClientProtocol: Sendable {
- /// Documentation for MethodA
- func methodA<R>(
- request: ClientRequest.Stream<NamespaceA_ServiceA.Method.MethodA.Input>,
- serializer: some MessageSerializer<NamespaceA_ServiceA.Method.MethodA.Input>,
- deserializer: some MessageDeserializer<NamespaceA_ServiceA.Method.MethodA.Output>,
- options: CallOptions,
- _ body: @Sendable @escaping (ClientResponse.Stream<NamespaceA_ServiceA.Method.MethodA.Output>) async throws -> R
- ) async throws -> R where R: Sendable
- }
- @available(macOS 13.0, iOS 16.0, watchOS 9.0, tvOS 16.0, *)
- extension NamespaceA_ServiceA.ClientProtocol {
- public func methodA<R>(
- request: ClientRequest.Stream<NamespaceA_ServiceA.Method.MethodA.Input>,
- options: CallOptions = .defaults,
- _ body: @Sendable @escaping (ClientResponse.Stream<NamespaceA_ServiceA.Method.MethodA.Output>) async throws -> R
- ) async throws -> R where R: Sendable {
- try await self.methodA(
- request: request,
- serializer: ProtobufSerializer<NamespaceA_ServiceA.Method.MethodA.Input>(),
- deserializer: ProtobufDeserializer<NamespaceA_ServiceA.Method.MethodA.Output>(),
- options: options,
- body
- )
- }
- }
- /// Documentation for ServiceA
- @available(macOS 13.0, iOS 16.0, watchOS 9.0, tvOS 16.0, *)
- public struct NamespaceA_ServiceAClient: NamespaceA_ServiceA.ClientProtocol {
- private let client: GRPCCore.GRPCClient
-
- public init(client: GRPCCore.GRPCClient) {
- self.client = client
- }
-
- /// Documentation for MethodA
- public func methodA<R>(
- request: ClientRequest.Stream<NamespaceA_ServiceA.Method.MethodA.Input>,
- serializer: some MessageSerializer<NamespaceA_ServiceA.Method.MethodA.Input>,
- deserializer: some MessageDeserializer<NamespaceA_ServiceA.Method.MethodA.Output>,
- options: CallOptions = .defaults,
- _ body: @Sendable @escaping (ClientResponse.Stream<NamespaceA_ServiceA.Method.MethodA.Output>) async throws -> R
- ) async throws -> R where R: Sendable {
- try await self.client.bidirectionalStreaming(
- request: request,
- descriptor: NamespaceA_ServiceA.Method.MethodA.descriptor,
- serializer: serializer,
- deserializer: deserializer,
- options: options,
- handler: body
- )
- }
- }
- """
- try self.assertClientCodeTranslation(
- codeGenerationRequest: makeCodeGenerationRequest(services: [service]),
- expectedSwift: expectedSwift,
- accessLevel: .public
- )
- }
- func testClientCodeTranslatorMultipleMethod() throws {
- let methodA = MethodDescriptor(
- documentation: "/// Documentation for MethodA",
- name: Name(base: "MethodA", generatedUpperCase: "MethodA", generatedLowerCase: "methodA"),
- isInputStreaming: true,
- isOutputStreaming: false,
- inputType: "NamespaceA_ServiceARequest",
- outputType: "NamespaceA_ServiceAResponse"
- )
- let methodB = MethodDescriptor(
- documentation: "/// Documentation for MethodB",
- name: Name(base: "MethodB", generatedUpperCase: "MethodB", generatedLowerCase: "methodB"),
- isInputStreaming: false,
- isOutputStreaming: true,
- inputType: "NamespaceA_ServiceARequest",
- outputType: "NamespaceA_ServiceAResponse"
- )
- let service = ServiceDescriptor(
- documentation: "/// Documentation for ServiceA",
- name: Name(base: "ServiceA", generatedUpperCase: "ServiceA", generatedLowerCase: ""),
- namespace: Name(base: "namespaceA", generatedUpperCase: "NamespaceA", generatedLowerCase: ""),
- methods: [methodA, methodB]
- )
- let expectedSwift =
- """
- /// Documentation for ServiceA
- @available(macOS 13.0, iOS 16.0, watchOS 9.0, tvOS 16.0, *)
- package protocol NamespaceA_ServiceAClientProtocol: Sendable {
- /// Documentation for MethodA
- func methodA<R>(
- request: ClientRequest.Stream<NamespaceA_ServiceA.Method.MethodA.Input>,
- serializer: some MessageSerializer<NamespaceA_ServiceA.Method.MethodA.Input>,
- deserializer: some MessageDeserializer<NamespaceA_ServiceA.Method.MethodA.Output>,
- options: CallOptions,
- _ body: @Sendable @escaping (ClientResponse.Single<NamespaceA_ServiceA.Method.MethodA.Output>) async throws -> R
- ) async throws -> R where R: Sendable
-
- /// Documentation for MethodB
- func methodB<R>(
- request: ClientRequest.Single<NamespaceA_ServiceA.Method.MethodB.Input>,
- serializer: some MessageSerializer<NamespaceA_ServiceA.Method.MethodB.Input>,
- deserializer: some MessageDeserializer<NamespaceA_ServiceA.Method.MethodB.Output>,
- options: CallOptions,
- _ body: @Sendable @escaping (ClientResponse.Stream<NamespaceA_ServiceA.Method.MethodB.Output>) async throws -> R
- ) async throws -> R where R: Sendable
- }
- @available(macOS 13.0, iOS 16.0, watchOS 9.0, tvOS 16.0, *)
- extension NamespaceA_ServiceA.ClientProtocol {
- package func methodA<R>(
- request: ClientRequest.Stream<NamespaceA_ServiceA.Method.MethodA.Input>,
- options: CallOptions = .defaults,
- _ body: @Sendable @escaping (ClientResponse.Single<NamespaceA_ServiceA.Method.MethodA.Output>) async throws -> R
- ) async throws -> R where R: Sendable {
- try await self.methodA(
- request: request,
- serializer: ProtobufSerializer<NamespaceA_ServiceA.Method.MethodA.Input>(),
- deserializer: ProtobufDeserializer<NamespaceA_ServiceA.Method.MethodA.Output>(),
- options: options,
- body
- )
- }
-
- package func methodB<R>(
- request: ClientRequest.Single<NamespaceA_ServiceA.Method.MethodB.Input>,
- options: CallOptions = .defaults,
- _ body: @Sendable @escaping (ClientResponse.Stream<NamespaceA_ServiceA.Method.MethodB.Output>) async throws -> R
- ) async throws -> R where R: Sendable {
- try await self.methodB(
- request: request,
- serializer: ProtobufSerializer<NamespaceA_ServiceA.Method.MethodB.Input>(),
- deserializer: ProtobufDeserializer<NamespaceA_ServiceA.Method.MethodB.Output>(),
- options: options,
- body
- )
- }
- }
- /// Documentation for ServiceA
- @available(macOS 13.0, iOS 16.0, watchOS 9.0, tvOS 16.0, *)
- package struct NamespaceA_ServiceAClient: NamespaceA_ServiceA.ClientProtocol {
- private let client: GRPCCore.GRPCClient
-
- package init(client: GRPCCore.GRPCClient) {
- self.client = client
- }
-
- /// Documentation for MethodA
- package func methodA<R>(
- request: ClientRequest.Stream<NamespaceA_ServiceA.Method.MethodA.Input>,
- serializer: some MessageSerializer<NamespaceA_ServiceA.Method.MethodA.Input>,
- deserializer: some MessageDeserializer<NamespaceA_ServiceA.Method.MethodA.Output>,
- options: CallOptions = .defaults,
- _ body: @Sendable @escaping (ClientResponse.Single<NamespaceA_ServiceA.Method.MethodA.Output>) async throws -> R
- ) async throws -> R where R: Sendable {
- try await self.client.clientStreaming(
- request: request,
- descriptor: NamespaceA_ServiceA.Method.MethodA.descriptor,
- serializer: serializer,
- deserializer: deserializer,
- options: options,
- handler: body
- )
- }
-
- /// Documentation for MethodB
- package func methodB<R>(
- request: ClientRequest.Single<NamespaceA_ServiceA.Method.MethodB.Input>,
- serializer: some MessageSerializer<NamespaceA_ServiceA.Method.MethodB.Input>,
- deserializer: some MessageDeserializer<NamespaceA_ServiceA.Method.MethodB.Output>,
- options: CallOptions = .defaults,
- _ body: @Sendable @escaping (ClientResponse.Stream<NamespaceA_ServiceA.Method.MethodB.Output>) async throws -> R
- ) async throws -> R where R: Sendable {
- try await self.client.serverStreaming(
- request: request,
- descriptor: NamespaceA_ServiceA.Method.MethodB.descriptor,
- serializer: serializer,
- deserializer: deserializer,
- options: options,
- handler: body
- )
- }
- }
- """
- try self.assertClientCodeTranslation(
- codeGenerationRequest: makeCodeGenerationRequest(services: [service]),
- expectedSwift: expectedSwift,
- accessLevel: .package
- )
- }
- func testClientCodeTranslatorNoNamespaceService() throws {
- let method = MethodDescriptor(
- documentation: "/// Documentation for MethodA",
- name: Name(base: "MethodA", generatedUpperCase: "MethodA", generatedLowerCase: "methodA"),
- isInputStreaming: false,
- isOutputStreaming: false,
- inputType: "ServiceARequest",
- outputType: "ServiceAResponse"
- )
- let service = ServiceDescriptor(
- documentation: "/// Documentation for ServiceA",
- name: Name(base: "ServiceA", generatedUpperCase: "ServiceA", generatedLowerCase: ""),
- namespace: Name(base: "", generatedUpperCase: "", generatedLowerCase: ""),
- methods: [method]
- )
- let expectedSwift =
- """
- /// Documentation for ServiceA
- @available(macOS 13.0, iOS 16.0, watchOS 9.0, tvOS 16.0, *)
- internal protocol ServiceAClientProtocol: Sendable {
- /// Documentation for MethodA
- func methodA<R>(
- request: ClientRequest.Single<ServiceA.Method.MethodA.Input>,
- serializer: some MessageSerializer<ServiceA.Method.MethodA.Input>,
- deserializer: some MessageDeserializer<ServiceA.Method.MethodA.Output>,
- options: CallOptions,
- _ body: @Sendable @escaping (ClientResponse.Single<ServiceA.Method.MethodA.Output>) async throws -> R
- ) async throws -> R where R: Sendable
- }
- @available(macOS 13.0, iOS 16.0, watchOS 9.0, tvOS 16.0, *)
- extension ServiceA.ClientProtocol {
- internal func methodA<R>(
- request: ClientRequest.Single<ServiceA.Method.MethodA.Input>,
- options: CallOptions = .defaults,
- _ body: @Sendable @escaping (ClientResponse.Single<ServiceA.Method.MethodA.Output>) async throws -> R
- ) async throws -> R where R: Sendable {
- try await self.methodA(
- request: request,
- serializer: ProtobufSerializer<ServiceA.Method.MethodA.Input>(),
- deserializer: ProtobufDeserializer<ServiceA.Method.MethodA.Output>(),
- options: options,
- body
- )
- }
- }
- /// Documentation for ServiceA
- @available(macOS 13.0, iOS 16.0, watchOS 9.0, tvOS 16.0, *)
- internal struct ServiceAClient: ServiceA.ClientProtocol {
- private let client: GRPCCore.GRPCClient
-
- internal init(client: GRPCCore.GRPCClient) {
- self.client = client
- }
-
- /// Documentation for MethodA
- internal func methodA<R>(
- request: ClientRequest.Single<ServiceA.Method.MethodA.Input>,
- serializer: some MessageSerializer<ServiceA.Method.MethodA.Input>,
- deserializer: some MessageDeserializer<ServiceA.Method.MethodA.Output>,
- options: CallOptions = .defaults,
- _ body: @Sendable @escaping (ClientResponse.Single<ServiceA.Method.MethodA.Output>) async throws -> R
- ) async throws -> R where R: Sendable {
- try await self.client.unary(
- request: request,
- descriptor: ServiceA.Method.MethodA.descriptor,
- serializer: serializer,
- deserializer: deserializer,
- options: options,
- handler: body
- )
- }
- }
- """
- try self.assertClientCodeTranslation(
- codeGenerationRequest: makeCodeGenerationRequest(services: [service]),
- expectedSwift: expectedSwift,
- accessLevel: .internal
- )
- }
- func testClientCodeTranslatorMultipleServices() throws {
- let serviceA = ServiceDescriptor(
- documentation: "/// Documentation for ServiceA",
- name: Name(base: "ServiceA", generatedUpperCase: "ServiceA", generatedLowerCase: ""),
- namespace: Name(
- base: "nammespaceA",
- generatedUpperCase: "NamespaceA",
- generatedLowerCase: ""
- ),
- methods: []
- )
- let serviceB = ServiceDescriptor(
- documentation: """
- /// Documentation for ServiceB
- ///
- /// Line 2
- """,
- name: Name(base: "ServiceB", generatedUpperCase: "ServiceB", generatedLowerCase: ""),
- namespace: Name(base: "", generatedUpperCase: "", generatedLowerCase: ""),
- methods: []
- )
- let expectedSwift =
- """
- /// Documentation for ServiceA
- @available(macOS 13.0, iOS 16.0, watchOS 9.0, tvOS 16.0, *)
- public protocol NamespaceA_ServiceAClientProtocol: Sendable {}
- @available(macOS 13.0, iOS 16.0, watchOS 9.0, tvOS 16.0, *)
- extension NamespaceA_ServiceA.ClientProtocol {
- }
- /// Documentation for ServiceA
- @available(macOS 13.0, iOS 16.0, watchOS 9.0, tvOS 16.0, *)
- public struct NamespaceA_ServiceAClient: NamespaceA_ServiceA.ClientProtocol {
- private let client: GRPCCore.GRPCClient
-
- public init(client: GRPCCore.GRPCClient) {
- self.client = client
- }
- }
- /// Documentation for ServiceB
- ///
- /// Line 2
- @available(macOS 13.0, iOS 16.0, watchOS 9.0, tvOS 16.0, *)
- public protocol ServiceBClientProtocol: Sendable {}
- @available(macOS 13.0, iOS 16.0, watchOS 9.0, tvOS 16.0, *)
- extension ServiceB.ClientProtocol {
- }
- /// Documentation for ServiceB
- ///
- /// Line 2
- @available(macOS 13.0, iOS 16.0, watchOS 9.0, tvOS 16.0, *)
- public struct ServiceBClient: ServiceB.ClientProtocol {
- private let client: GRPCCore.GRPCClient
-
- public init(client: GRPCCore.GRPCClient) {
- self.client = client
- }
- }
- """
- try self.assertClientCodeTranslation(
- codeGenerationRequest: makeCodeGenerationRequest(services: [serviceA, serviceB]),
- expectedSwift: expectedSwift,
- accessLevel: .public
- )
- }
- private func assertClientCodeTranslation(
- codeGenerationRequest: CodeGenerationRequest,
- expectedSwift: String,
- accessLevel: SourceGenerator.Configuration.AccessLevel
- ) throws {
- let translator = ClientCodeTranslator(accessLevel: accessLevel)
- let codeBlocks = try translator.translate(from: codeGenerationRequest)
- let renderer = TextBasedRenderer.default
- renderer.renderCodeBlocks(codeBlocks)
- let contents = renderer.renderedContents()
- try XCTAssertEqualWithDiff(contents, expectedSwift)
- }
- }
- #endif // os(macOS) || os(Linux)
|