/* * Copyright 2019, 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. */ import Foundation import Logging import NIO import NIOHPACK import NIOHTTP1 import NIOHTTP2 import SwiftProtobuf /// A unary gRPC call. The request is sent on initialization. public final class UnaryCall: UnaryResponseClientCall { private let transport: ChannelTransport /// The options used to make the RPC. public let options: CallOptions /// The `Channel` used to transport messages for this RPC. public var subchannel: EventLoopFuture { return self.transport.streamChannel() } /// The `EventLoop` this call is running on. public var eventLoop: EventLoop { return self.transport.eventLoop } /// Cancel this RPC if it hasn't already completed. public func cancel(promise: EventLoopPromise?) { self.transport.cancel(promise: promise) } // MARK: - Response Parts /// The initial metadata returned from the server. public var initialMetadata: EventLoopFuture { if self.eventLoop.inEventLoop { return self.transport.responseContainer.lazyInitialMetadataPromise.getFutureResult() } else { return self.eventLoop.flatSubmit { return self.transport.responseContainer.lazyInitialMetadataPromise.getFutureResult() } } } /// The response returned by the server. public let response: EventLoopFuture /// The trailing metadata returned from the server. public var trailingMetadata: EventLoopFuture { if self.eventLoop.inEventLoop { return self.transport.responseContainer.lazyTrailingMetadataPromise.getFutureResult() } else { return self.eventLoop.flatSubmit { return self.transport.responseContainer.lazyTrailingMetadataPromise.getFutureResult() } } } /// The final status of the the RPC. public var status: EventLoopFuture { if self.eventLoop.inEventLoop { return self.transport.responseContainer.lazyStatusPromise.getFutureResult() } else { return self.eventLoop.flatSubmit { return self.transport.responseContainer.lazyStatusPromise.getFutureResult() } } } internal init( response: EventLoopFuture, transport: ChannelTransport, options: CallOptions ) { self.response = response self.transport = transport self.options = options } internal func send(_ head: _GRPCRequestHead, request: RequestPayload) { self.transport.sendUnary( head, request: request, compressed: self.options.messageEncoding.enabledForRequests ) } } extension UnaryCall { internal static func makeOnHTTP2Stream< Serializer: MessageSerializer, Deserializer: MessageDeserializer >( multiplexer: EventLoopFuture, serializer: Serializer, deserializer: Deserializer, callOptions: CallOptions, errorDelegate: ClientErrorDelegate?, logger: Logger ) -> UnaryCall where Serializer.Input == RequestPayload, Deserializer.Output == ResponsePayload { let eventLoop = multiplexer.eventLoop let responsePromise: EventLoopPromise = eventLoop.makePromise() let transport = ChannelTransport( multiplexer: multiplexer, serializer: serializer, deserializer: deserializer, responseContainer: .init(eventLoop: eventLoop, unaryResponsePromise: responsePromise), callType: .unary, timeLimit: callOptions.timeLimit, errorDelegate: errorDelegate, logger: logger ) return UnaryCall( response: responsePromise.futureResult, transport: transport, options: callOptions ) } internal static func make( serializer: Serializer, deserializer: Deserializer, fakeResponse: FakeUnaryResponse?, callOptions: CallOptions, logger: Logger ) -> UnaryCall where Serializer.Input == RequestPayload, Deserializer.Output == ResponsePayload { let eventLoop = fakeResponse?.channel.eventLoop ?? EmbeddedEventLoop() let responsePromise: EventLoopPromise = eventLoop.makePromise() let responseContainer = ResponsePartContainer( eventLoop: eventLoop, unaryResponsePromise: responsePromise ) let transport: ChannelTransport if let fakeResponse = fakeResponse { transport = .init( fakeResponse: fakeResponse, responseContainer: responseContainer, timeLimit: callOptions.timeLimit, logger: logger ) fakeResponse.activate() } else { transport = .makeTransportForMissingFakeResponse( eventLoop: eventLoop, responseContainer: responseContainer, logger: logger ) } return UnaryCall( response: responsePromise.futureResult, transport: transport, options: callOptions ) } }