diff --git a/Tests/GRPCCoreTests/Test Utilities/Coding+JSON.swift b/Tests/GRPCCoreTests/Test Utilities/Coding+JSON.swift index 3eb025783..d2c6ef452 100644 --- a/Tests/GRPCCoreTests/Test Utilities/Coding+JSON.swift +++ b/Tests/GRPCCoreTests/Test Utilities/Coding+JSON.swift @@ -13,6 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ + import GRPCCore import struct Foundation.Data diff --git a/Tests/GRPCInProcessTransportTests/InProcessTransportTests.swift b/Tests/GRPCInProcessTransportTests/InProcessTransportTests.swift index 1de0a12bd..5751d74a1 100644 --- a/Tests/GRPCInProcessTransportTests/InProcessTransportTests.swift +++ b/Tests/GRPCInProcessTransportTests/InProcessTransportTests.swift @@ -80,7 +80,7 @@ struct InProcessTransportTests { request: ClientRequest(message: ()), descriptor: .peerInfo, serializer: VoidSerializer(), - deserializer: PeerInfoDeserializer(), + deserializer: JSONDeserializer(), options: .defaults ) { try $0.message @@ -142,7 +142,7 @@ private struct TestService: RegistrableRPCService { router.registerHandler( forMethod: .peerInfo, deserializer: VoidDeserializer(), - serializer: PeerInfoSerializer(), + serializer: JSONSerializer(), handler: { let response = try await self.peerInfo( request: ServerRequest(stream: $0), @@ -171,22 +171,6 @@ private struct PeerInfo: Codable { var remote: String } -private struct PeerInfoSerializer: MessageSerializer { - func serialize(_ message: PeerInfo) throws -> Bytes { - Bytes("\(message.local) \(message.remote)".utf8) - } -} - -private struct PeerInfoDeserializer: MessageDeserializer { - func deserialize(_ serializedMessageBytes: Bytes) throws -> PeerInfo { - let stringPeerInfo = serializedMessageBytes.withUnsafeBytes { - String(decoding: $0, as: UTF8.self) - } - let peerInfoComponents = stringPeerInfo.split(separator: " ") - return PeerInfo(local: String(peerInfoComponents[0]), remote: String(peerInfoComponents[1])) - } -} - private struct UTF8Serializer: MessageSerializer { func serialize(_ message: String) throws -> Bytes { Bytes(message.utf8) diff --git a/Tests/GRPCInProcessTransportTests/Test Utilities/JSONSerializing.swift b/Tests/GRPCInProcessTransportTests/Test Utilities/JSONSerializing.swift new file mode 100644 index 000000000..905e90525 --- /dev/null +++ b/Tests/GRPCInProcessTransportTests/Test Utilities/JSONSerializing.swift @@ -0,0 +1,45 @@ +/* + * Copyright 2025, 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 GRPCCore + +import struct Foundation.Data +import class Foundation.JSONDecoder +import class Foundation.JSONEncoder + +struct JSONSerializer: MessageSerializer { + func serialize(_ message: Message) throws -> Bytes { + do { + let jsonEncoder = JSONEncoder() + let data = try jsonEncoder.encode(message) + return Bytes(data) + } catch { + throw RPCError(code: .internalError, message: "Can't serialize message to JSON. \(error)") + } + } +} + +struct JSONDeserializer: MessageDeserializer { + func deserialize(_ serializedMessageBytes: Bytes) throws -> Message { + do { + let jsonDecoder = JSONDecoder() + let data = serializedMessageBytes.withUnsafeBytes { Data($0) } + return try jsonDecoder.decode(Message.self, from: data) + } catch { + throw RPCError(code: .internalError, message: "Can't deserialze message from JSON. \(error)") + } + } +}