Upgrade zio-grpc (#56)

Author: ghostdogpr

build.sbt

@@ -2,8 +2,8 @@ val scala213 = "2.13.8"
 val scala3   = "3.2.1"
 val allScala = Seq(scala213, scala3)
 
-val zioVersion            = "2.0.5"
-val zioGrpcVersion        = "0.6.0-test7"
+val zioVersion            = "2.0.6"
+val zioGrpcVersion        = "0.6.0-rc1"
 val zioK8sVersion         = "2.0.1"
 val zioCacheVersion       = "0.2.1"
 val zioCatsInteropVersion = "23.0.0.0"

project/plugins.sbt

@@ -6,4 +6,4 @@ addSbtPlugin("com.thesamet"   % "sbt-protoc"     % "1.0.6")
 resolvers ++= Resolver.sonatypeOssRepos("snapshots")
 
 libraryDependencies += "com.thesamet.scalapb"          %% "compilerplugin"   % "0.11.10"
-libraryDependencies += "com.thesamet.scalapb.zio-grpc" %% "zio-grpc-codegen" % "0.6.0-test7"
+libraryDependencies += "com.thesamet.scalapb.zio-grpc" %% "zio-grpc-codegen" % "0.6.0-rc1"

protocol-grpc/src/main/scala/com/devsisters/shardcake/GrpcPods.scala

@@ -12,9 +12,9 @@ import zio._
 
 class GrpcPods(
   config: GrpcConfig,
-  connections: Ref.Synchronized[Map[PodAddress, (ShardingServiceClient.ZService[Any], Fiber[Throwable, Nothing])]]
+  connections: Ref.Synchronized[Map[PodAddress, (ShardingServiceClient, Fiber[Throwable, Nothing])]]
 ) extends Pods {
-  private def getConnection(pod: PodAddress): Task[ShardingServiceClient.ZService[Any]] =
+  private def getConnection(pod: PodAddress): Task[ShardingServiceClient] =
     // optimize happy path and only get first
     connections.get.flatMap(_.get(pod) match {
       case Some((channel, _)) => ZIO.succeed(channel)
@@ -34,7 +34,7 @@ class GrpcPods(
               // create a fiber that never ends and keeps the connection alive
               for {
                 _          <- ZIO.logDebug(s"Opening connection to pod $pod")
-                promise    <- Promise.make[Nothing, ShardingServiceClient.ZService[Any]]
+                promise    <- Promise.make[Nothing, ShardingServiceClient]
                 fiber      <-
                   ZIO
                     .scoped(
@@ -93,7 +93,7 @@ object GrpcPods {
         config      <- ZIO.service[GrpcConfig]
         connections <-
           Ref.Synchronized
-            .make(Map.empty[PodAddress, (ShardingServiceClient.ZService[Any], Fiber[Throwable, Nothing])])
+            .make(Map.empty[PodAddress, (ShardingServiceClient, Fiber[Throwable, Nothing])])
             .withFinalizer(
               // stop all connection fibers on release
               _.get.flatMap(connections => ZIO.foreachDiscard(connections) { case (_, (_, fiber)) => fiber.interrupt })

protocol-grpc/src/main/scala/com/devsisters/shardcake/GrpcShardingService.scala

@@ -2,15 +2,15 @@ package com.devsisters.shardcake
 
 import com.devsisters.shardcake.errors.EntityNotManagedByThisPod
 import com.devsisters.shardcake.interfaces.Pods.BinaryMessage
-import com.devsisters.shardcake.protobuf.sharding.ZioSharding.ZShardingService
+import com.devsisters.shardcake.protobuf.sharding.ZioSharding.ShardingService
 import com.devsisters.shardcake.protobuf.sharding._
 import com.google.protobuf.ByteString
 import io.grpc.protobuf.services.ProtoReflectionService
 import io.grpc.{ ServerBuilder, Status, StatusException, StatusRuntimeException }
-import scalapb.zio_grpc.{ ScopedServer, ServerLayer, ServiceList }
+import scalapb.zio_grpc.{ ScopedServer, ServiceList }
 import zio.{ Config => _, _ }
 
-abstract class GrpcShardingService(sharding: Sharding, timeout: Duration) extends ZShardingService[Any] {
+abstract class GrpcShardingService(sharding: Sharding, timeout: Duration) extends ShardingService {
   def assignShards(request: AssignShardsRequest): ZIO[Any, Status, AssignShardsResponse] =
     sharding.assign(request.shards.toSet).as(AssignShardsResponse())