Refactor ProtoSerDeser to use type class pattern for serialization and deserialization

Author: igor-vovk

conformance/src/main/scala/org/ivovk/connect_rpc_scala/conformance/Http4sServerLauncher.scala

@@ -33,7 +33,7 @@ object Http4sServerLauncher extends IOApp.Simple {
 
   override def run: IO[Unit] = {
     val res = for
-      req <- ProtoSerDeser.read[IO, ServerCompatRequest](System.in).toResource
+      req <- ProtoSerDeser[IO].read[ServerCompatRequest](System.in).toResource
 
       service <- ConformanceServiceFs2GrpcTrailers.bindServiceResource(
         ConformanceServiceImpl[IO]()
@@ -65,7 +65,7 @@ object Http4sServerLauncher extends IOApp.Simple {
       addr = server.address
       resp = ServerCompatResponse(addr.getHostString, addr.getPort)
 
-      _ <- ProtoSerDeser.write[IO](System.out, resp).toResource
+      _ <- ProtoSerDeser[IO].write(System.out, resp).toResource
 
       _ = System.err.println(s"Server started on $addr...")
     yield ()

conformance/src/main/scala/org/ivovk/connect_rpc_scala/conformance/NettyServerLauncher.scala

@@ -30,7 +30,7 @@ object NettyServerLauncher extends IOApp.Simple {
 
   override def run: IO[Unit] = {
     val res = for
-      req <- ProtoSerDeser.read[IO, ServerCompatRequest](System.in).toResource
+      req <- ProtoSerDeser[IO].read[ServerCompatRequest](System.in).toResource
 
       service <- ConformanceServiceFs2GrpcTrailers.bindServiceResource(
         ConformanceServiceImpl[IO]()
@@ -49,7 +49,7 @@ object NettyServerLauncher extends IOApp.Simple {
 
       resp = ServerCompatResponse(server.host, server.port)
 
-      _ <- ProtoSerDeser.write[IO](System.out, resp).toResource
+      _ <- ProtoSerDeser[IO].write(System.out, resp).toResource
 
       _ = System.err.println(s"Server started on ${server.host}:${server.port}...")
       _ = logger.info(s"Netty-server started on ${server.host}:${server.port}...")

conformance/src/main/scala/org/ivovk/connect_rpc_scala/conformance/util/ProtoSerDeser.scala

@@ -6,17 +6,21 @@ import scalapb.{GeneratedMessage as Message, GeneratedMessageCompanion as Compan
 import java.io.{InputStream, OutputStream}
 
 object ProtoSerDeser {
-  def read[F[_]: Sync, T <: Message](in: InputStream)(using comp: Companion[T]): F[T] =
-    Sync[F].delay {
-      val size = IntSerDeser.read(in)
-      comp.parseFrom(in.readNBytes(size))
-    }
+  def apply[F[_]: Sync]: ProtoSerDeser[F] = new ProtoSerDeser[F]() {}
 
-  def write[F[_]: Sync](out: OutputStream, msg: Message): F[Unit] =
-    Sync[F].delay {
-      IntSerDeser.write(out, msg.serializedSize)
-      out.flush()
-      out.write(msg.toByteArray)
-      out.flush()
-    }
+  trait ProtoSerDeser[F[_]: Sync] {
+    def read[T <: Message](in: InputStream)(using comp: Companion[T]): F[T] =
+      Sync[F].delay {
+        val size = IntSerDeser.read(in)
+        comp.parseFrom(in.readNBytes(size))
+      }
+
+    def write(out: OutputStream, msg: Message): F[Unit] =
+      Sync[F].delay {
+        IntSerDeser.write(out, msg.serializedSize)
+        out.flush()
+        out.write(msg.toByteArray)
+        out.flush()
+      }
+  }
 }