feat: RedisLogger for redis-client

build.sbt

@@ -157,10 +157,12 @@ lazy val commonSettings = Seq(
   ),
   Compile / console / scalacOptions := (Compile / scalacOptions).value.filterNot(_ == "-Xfatal-warnings"),
   Test / console / scalacOptions := (Compile / console / scalacOptions).value,
+  libraryDependencies ++= (
+      Dependencies.scribe
+    ),
   libraryDependencies ++= (
       Dependencies.catsEffectMunit ++
-        Dependencies.scalacheckEffectMunit ++
-        Dependencies.scribe
+        Dependencies.scalacheckEffectMunit
     ).map(_ % Test),
   // Format: on
   organizationName := "Swiss Data Science Center (SDSC)",

modules/redis-client/src/main/scala/io/renku/redis/client/RedisLogger.scala

@@ -0,0 +1,36 @@
+/*
+ * Copyright 2024 Swiss Data Science Center (SDSC)
+ * A partnership between École Polytechnique Fédérale de Lausanne (EPFL) and
+ * Eidgenössische Technische Hochschule Zürich (ETHZ).
+ *
+ * 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.
+ */
+
+package io.renku.redis.client
+
+import dev.profunktor.redis4cats.effect.Log
+import scribe.Scribe
+
+class RedisLogger[F[_]](scribe: Scribe[F]) extends Log[F]:
+
+  override def debug(msg: => String): F[Unit] =
+    scribe.debug(msg)
+
+  override def info(msg: => String): F[Unit] =
+    scribe.info(msg)
+
+  override def error(msg: => String): F[Unit] =
+    scribe.error(msg)
+
+object RedisLogger:
+  def apply[F[_]: Scribe]: Log[F] = new RedisLogger[F](Scribe[F])

modules/redis-client/src/main/scala/io/renku/redis/client/RedisQueueClient.scala

@@ -23,12 +23,19 @@ import cats.syntax.all.*
 import dev.profunktor.redis4cats.connection.RedisClient
 import dev.profunktor.redis4cats.data.RedisCodec
 import dev.profunktor.redis4cats.effect.Log
+import dev.profunktor.redis4cats.effect.MkRedis.forAsync
 import dev.profunktor.redis4cats.streams.RedisStream
 import dev.profunktor.redis4cats.streams.data.{StreamingOffset, XAddMessage, XReadMessage}
 import dev.profunktor.redis4cats.{Redis, RedisCommands}
 import fs2.Stream
 import io.renku.queue.client.*
 import scodec.bits.ByteVector
+import scribe.Scribe
+
+object RedisQueueClient:
+  def apply[F[_]: Async: Scribe]: Resource[F, QueueClient[F]] =
+    given Log[F] = RedisLogger[F]
+    RedisClient[F].from("url").map(new RedisQueueClient[F](_))
 
 class RedisQueueClient[F[_]: Async: Log](client: RedisClient) extends QueueClient[F] {