BinaryEcho.swift 3.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104
  1. /*
  2. * Copyright 2023, gRPC Authors All rights reserved.
  3. *
  4. * Licensed under the Apache License, Version 2.0 (the "License");
  5. * you may not use this file except in compliance with the License.
  6. * You may obtain a copy of the License at
  7. *
  8. * http://www.apache.org/licenses/LICENSE-2.0
  9. *
  10. * Unless required by applicable law or agreed to in writing, software
  11. * distributed under the License is distributed on an "AS IS" BASIS,
  12. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13. * See the License for the specific language governing permissions and
  14. * limitations under the License.
  15. */
  16. import GRPCCore
  17. import XCTest
  18. struct BinaryEcho: RegistrableRPCService {
  19. func get(
  20. _ request: ServerRequest.Single<[UInt8]>
  21. ) async throws -> ServerResponse.Single<[UInt8]> {
  22. ServerResponse.Single(message: request.message, metadata: request.metadata)
  23. }
  24. func collect(
  25. _ request: ServerRequest.Stream<[UInt8]>
  26. ) async throws -> ServerResponse.Single<[UInt8]> {
  27. let collected = try await request.messages.reduce(into: []) { $0.append(contentsOf: $1) }
  28. return ServerResponse.Single(message: collected, metadata: request.metadata)
  29. }
  30. func expand(
  31. _ request: ServerRequest.Single<[UInt8]>
  32. ) async throws -> ServerResponse.Stream<[UInt8]> {
  33. return ServerResponse.Stream(metadata: request.metadata) {
  34. for byte in request.message {
  35. try await $0.write([byte])
  36. }
  37. return [:]
  38. }
  39. }
  40. func update(
  41. _ request: ServerRequest.Stream<[UInt8]>
  42. ) async throws -> ServerResponse.Stream<[UInt8]> {
  43. return ServerResponse.Stream(metadata: request.metadata) {
  44. for try await message in request.messages {
  45. try await $0.write(message)
  46. }
  47. return [:]
  48. }
  49. }
  50. func registerMethods(with router: inout RPCRouter) {
  51. let serializer = IdentitySerializer()
  52. let deserializer = IdentityDeserializer()
  53. router.registerHandler(
  54. forMethod: Methods.get,
  55. deserializer: deserializer,
  56. serializer: serializer
  57. ) { streamRequest in
  58. let singleRequest = try await ServerRequest.Single(stream: streamRequest)
  59. let singleResponse = try await self.get(singleRequest)
  60. return ServerResponse.Stream(single: singleResponse)
  61. }
  62. router.registerHandler(
  63. forMethod: Methods.collect,
  64. deserializer: deserializer,
  65. serializer: serializer
  66. ) { streamRequest in
  67. let singleResponse = try await self.collect(streamRequest)
  68. return ServerResponse.Stream(single: singleResponse)
  69. }
  70. router.registerHandler(
  71. forMethod: Methods.expand,
  72. deserializer: deserializer,
  73. serializer: serializer
  74. ) { streamRequest in
  75. let singleRequest = try await ServerRequest.Single(stream: streamRequest)
  76. let streamResponse = try await self.expand(singleRequest)
  77. return streamResponse
  78. }
  79. router.registerHandler(
  80. forMethod: Methods.update,
  81. deserializer: deserializer,
  82. serializer: serializer
  83. ) { streamRequest in
  84. let streamResponse = try await self.update(streamRequest)
  85. return streamResponse
  86. }
  87. }
  88. enum Methods {
  89. static let get = MethodDescriptor(service: "echo.Echo", method: "Get")
  90. static let collect = MethodDescriptor(service: "echo.Echo", method: "Collect")
  91. static let expand = MethodDescriptor(service: "echo.Echo", method: "Expand")
  92. static let update = MethodDescriptor(service: "echo.Echo", method: "Update")
  93. }
  94. }