Close #441 - Add MdcAdapter for Cats Effect 3 to properly share context through MDC with IO and IOLocal from Cats Effect 3

Author: kevin-lee

.github/workflows/build.yml

@@ -24,7 +24,7 @@ jobs:
         scala:
           - { name: "Scala 2", version: "2.12.18", binary-version: "2.12", java-version: "11", java-distribution: "temurin", report: "" }
           - { name: "Scala 2", version: "2.13.14", binary-version: "2.13", java-version: "11", java-distribution: "temurin", report: "report" }
-          - { name: "Scala 3", version: "3.1.3",   binary-version: "3",    java-version: "11", java-distribution: "temurin", report: "" }
+          - { name: "Scala 3", version: "3.3.0",   binary-version: "3",    java-version: "11", java-distribution: "temurin", report: "" }
 
     steps:
       - uses: actions/checkout@v4

.github/workflows/release.yml

@@ -24,7 +24,7 @@ jobs:
         scala:
           - { name: "Scala 2", version: "2.12.18", binary-version: "2.12", java-version: "11", java-distribution: "temurin", report: "" }
           - { name: "Scala 2", version: "2.13.14", binary-version: "2.13", java-version: "11", java-distribution: "temurin", report: "" }
-          - { name: "Scala 3", version: "3.1.3",   binary-version: "3",    java-version: "11", java-distribution: "temurin", report: "" }
+          - { name: "Scala 3", version: "3.3.0",   binary-version: "3",    java-version: "11", java-distribution: "temurin", report: "" }
 
     steps:
       - uses: actions/checkout@v4

build.sbt

@@ -81,6 +81,7 @@ lazy val loggerF = (project in file("."))
     slf4jMdcJvm,
     logbackMdcMonix3Jvm,
     testLogbackMdcMonix3Jvm,
+    logbackMdcCatsEffect3Jvm,
     testKitJvm,
 //    testKitJs,
     catsEffectJvm,
@@ -109,7 +110,7 @@ lazy val core    =
       ),
     )
 lazy val coreJvm = core.jvm
-lazy val coreJs  = core.js
+lazy val coreJs  = core.js.settings(commonJsSettings)
 
 lazy val slf4jLogger    = module(ProjectName("slf4j"), crossProject(JVMPlatform, JSPlatform))
   .settings(
@@ -124,7 +125,7 @@ lazy val slf4jLogger    = module(ProjectName("slf4j"), crossProject(JVMPlatform,
   )
   .dependsOn(core)
 lazy val slf4jLoggerJvm = slf4jLogger.jvm
-lazy val slf4jLoggerJs  = slf4jLogger.js
+lazy val slf4jLoggerJs  = slf4jLogger.js.settings(commonJsSettings)
 
 lazy val log4sLogger    =
   module(ProjectName("log4s"), crossProject(JVMPlatform, JSPlatform))
@@ -140,7 +141,7 @@ lazy val log4sLogger    =
     )
     .dependsOn(core)
 lazy val log4sLoggerJvm = log4sLogger.jvm
-lazy val log4sLoggerJs  = log4sLogger.js
+lazy val log4sLoggerJs  = log4sLogger.js.settings(commonJsSettings)
 
 lazy val log4jLogger    =
   module(ProjectName("log4j"), crossProject(JVMPlatform, JSPlatform))
@@ -200,7 +201,7 @@ lazy val log4jLogger    =
     )
     .dependsOn(core)
 lazy val log4jLoggerJvm = log4jLogger.jvm
-lazy val log4jLoggerJs  = log4jLogger.js
+lazy val log4jLoggerJs  = log4jLogger.js.settings(commonJsSettings)
 
 lazy val sbtLogging    =
   module(ProjectName("sbt-logging"), crossProject(JVMPlatform, JSPlatform))
@@ -232,7 +233,7 @@ lazy val sbtLogging    =
     )
     .dependsOn(core)
 lazy val sbtLoggingJvm = sbtLogging.jvm
-lazy val sbtLoggingJs  = sbtLogging.js
+lazy val sbtLoggingJs  = sbtLogging.js.settings(commonJsSettings)
 
 lazy val cats    =
   module(ProjectName("cats"), crossProject(JVMPlatform, JSPlatform))
@@ -251,7 +252,7 @@ lazy val cats    =
     )
     .dependsOn(core % props.IncludeTest)
 lazy val catsJvm = cats.jvm
-lazy val catsJs  = cats.js
+lazy val catsJs  = cats.js.settings(commonJsSettings)
 
 lazy val slf4jMdc    = module(ProjectName("slf4j-mdc"), crossProject(JVMPlatform))
   .settings(
@@ -319,6 +320,29 @@ lazy val testLogbackMdcMonix3    = testProject(ProjectName("logback-mdc-monix3")
   )
 lazy val testLogbackMdcMonix3Jvm = testLogbackMdcMonix3.jvm
 
+lazy val logbackMdcCatsEffect3    = module(ProjectName("logback-mdc-cats-effect3"), crossProject(JVMPlatform))
+  .settings(
+    description := "Logger for F[_] - logback MDC context map support for Cats Effect 3",
+    libraryDependencies ++= Seq(
+      libs.logbackClassic,
+      libs.logbackScalaInterop,
+      libs.catsEffect3Eap,
+      libs.tests.effectieCatsEffect3,
+      libs.tests.extrasHedgehogCatsEffect3,
+    ) ++ libs.tests.hedgehogLibs,
+    libraryDependencies := libraryDependenciesRemoveScala3Incompatible(
+      scalaVersion.value,
+      libraryDependencies.value,
+    ),
+    javaOptions += "-Dcats.effect.ioLocalPropagation=true",
+  )
+  .dependsOn(
+    core,
+    monix       % Test,
+    slf4jLogger % Test,
+  )
+lazy val logbackMdcCatsEffect3Jvm = logbackMdcCatsEffect3.jvm
+
 lazy val testKit    =
   module(ProjectName("test-kit"), crossProject(JVMPlatform, JSPlatform))
     .settings(
@@ -335,7 +359,7 @@ lazy val testKit    =
     )
     .dependsOn(core % props.IncludeTest)
 lazy val testKitJvm = testKit.jvm
-lazy val testKitJs  = testKit.js
+lazy val testKitJs  = testKit.js.settings(commonJsSettings)
 
 lazy val catsEffect    =
   module(ProjectName("cats-effect"), crossProject(JVMPlatform, JSPlatform))
@@ -350,14 +374,14 @@ lazy val catsEffect    =
     .settings(noPublish)
     .dependsOn(core % props.IncludeTest, cats)
 lazy val catsEffectJvm = catsEffect.jvm
-lazy val catsEffectJs  = catsEffect.js
+lazy val catsEffectJs  = catsEffect.js.settings(commonJsSettings)
 
 lazy val catsEffect3    =
   module(ProjectName("cats-effect3"), crossProject(JVMPlatform, JSPlatform))
     .settings(
       description := "Logger for F[_] - Cats Effect 3",
       libraryDependencies ++= libs.tests.hedgehogLibs ++ List(
-        libs.effectieCatsEffect3 % Test,
+        libs.tests.effectieCatsEffect3,
         libs.tests.extrasHedgehogCatsEffect3,
       ),
       libraryDependencies := libraryDependenciesRemoveScala3Incompatible(
@@ -368,7 +392,7 @@ lazy val catsEffect3    =
     .settings(noPublish)
     .dependsOn(core % props.IncludeTest, cats)
 lazy val catsEffect3Jvm = catsEffect3.jvm
-lazy val catsEffect3Js  = catsEffect3.js
+lazy val catsEffect3Js  = catsEffect3.js.settings(commonJsSettings)
 
 lazy val monix    =
   module(ProjectName("monix"), crossProject(JVMPlatform, JSPlatform))
@@ -383,7 +407,7 @@ lazy val monix    =
     .settings(noPublish)
     .dependsOn(core % props.IncludeTest, cats)
 lazy val monixJvm = monix.jvm
-lazy val monixJs  = monix.js
+lazy val monixJs  = monix.js.settings(commonJsSettings)
 
 lazy val testCore    =
   testProject(
@@ -601,7 +625,7 @@ lazy val props =
     final val GitHubUsername = "Kevin-Lee"
     final val RepoName       = "logger-f"
 
-    final val Scala3Versions = List("3.1.3")
+    final val Scala3Versions = List("3.3.0")
     final val Scala2Versions = List("2.13.14", "2.12.18")
 
 //    final val ProjectScalaVersion = Scala3Versions.head
@@ -673,6 +697,8 @@ lazy val libs =
 
     lazy val catsEffect3 = "org.typelevel" %% "cats-effect" % props.CatsEffect3Version
 
+    lazy val catsEffect3Eap = "org.typelevel" %% "cats-effect" % "3.6-02a43a6"
+
     lazy val monix3Execution = "io.monix" %% "monix-execution" % props.Monix3Version
 
     lazy val effectieCore: ModuleID        = "io.kevinlee" %% "effectie-core"         % props.EffectieVersion
@@ -709,6 +735,8 @@ lazy val libs =
 
       lazy val extrasTestingTools = "io.kevinlee" %% "extras-testing-tools" % props.ExtrasVersion % Test
 
+      lazy val effectieCatsEffect3 = "io.kevinlee" %% "effectie-cats-effect3" % props.EffectieVersion % Test
+
       lazy val extrasConcurrent        = "io.kevinlee" %% "extras-concurrent"         % props.ExtrasVersion % Test
       lazy val extrasConcurrentTesting = "io.kevinlee" %% "extras-concurrent-testing" % props.ExtrasVersion % Test
 
@@ -771,6 +799,7 @@ def projectCommonSettings(projectName: String, crossProject: CrossProject.Builde
       //      , Compile / compile / wartremoverErrors ++= commonWarts((update / scalaBinaryVersion).value)
       //      , Test / compile / wartremoverErrors ++= commonWarts((update / scalaBinaryVersion).value)
       wartremoverErrors ++= commonWarts((update / scalaBinaryVersion).value),
+      fork := true,
       Compile / console / wartremoverErrors := List.empty,
       Compile / console / wartremoverWarnings := List.empty,
       Compile / console / scalacOptions :=
@@ -794,3 +823,11 @@ def projectCommonSettings(projectName: String, crossProject: CrossProject.Builde
       }),
       /* } Coveralls */
     )
+
+lazy val commonJsSettings: SettingsDefinition = List(
+  Test / fork := false
+//  Test / scalacOptions ++= (if (scalaVersion.value.startsWith("3")) List.empty
+//  else List("-P:scalajs:nowarnGlobalExecutionContext")),
+//  Test / compile / scalacOptions ++= (if (scalaVersion.value.startsWith("3")) List.empty
+//  else List("-P:scalajs:nowarnGlobalExecutionContext")),
+)

modules/logger-f-cats-effect3/shared/src/test/scala/loggerf/cats/testing/ConcurrentSupport.scala

@@ -25,7 +25,10 @@ trait ConcurrentSupport {
           val stringWriter = new StringWriter()
           val printWriter  = new PrintWriter(stringWriter)
           th.printStackTrace(printWriter)
-          logger(s"⚠️ Error in Executor: ${stringWriter.toString}")
+
+          @SuppressWarnings(Array("org.wartremover.warts.ToString"))
+          val message = stringWriter.toString
+          logger(s"⚠️ Error in Executor: $message")
         },
       )
 

modules/logger-f-cats/shared/src/main/scala-3/loggerf/instances/show.scala

@@ -7,7 +7,9 @@ import loggerf.core.ToLog
   * @since 2022-02-19
   */
 trait show {
-  inline given showToLog[A: Show]: ToLog[A] = Show[A].show(_)
+  given showToLog[A: Show]: ToLog[A] with {
+    inline def toLogMessage(a: A): String = Show[A].show(a)
+  }
 }
 
 object show extends show

modules/logger-f-core/shared/src/main/scala-3/loggerf/core/ToLog.scala

@@ -15,5 +15,7 @@ object ToLog {
   @SuppressWarnings(Array("org.wartremover.warts.ToString"))
   def fromToString[A]: ToLog[A] = _.toString
 
-  inline given stringToLog: ToLog[String] = identity(_)
+  given stringToLog: ToLog[String] with {
+    inline def toLogMessage(a: String): String = a
+  }
 }

modules/logger-f-core/shared/src/main/scala-3/loggerf/core/syntax/LogSyntax.scala

@@ -3,9 +3,6 @@ package loggerf.core.syntax
 import loggerf.LeveledMessage
 import loggerf.Ignore
 import loggerf.core.Log
-import loggerf.instances.future.given
-
-import scala.concurrent.Future
 
 /** @author Kevin Lee
   * @since 2022-02-09

modules/logger-f-logback-mdc-cats-effect3/shared/src/main/scala/loggerf/logger/logback/Ce3MdcAdapter.scala

@@ -0,0 +1,85 @@
+package loggerf.logger.logback
+
+import cats.effect.unsafe.IOLocals
+import cats.effect.{IOLocal, SyncIO}
+import cats.syntax.all._
+import ch.qos.logback.classic.LoggerContext
+import logback_scala_interop.JLoggerFMdcAdapter
+import org.slf4j.{LoggerFactory, MDC}
+
+import java.util.{Map => JMap, Set => JSet}
+import scala.jdk.CollectionConverters._
+import scala.util.control.NonFatal
+
+/** @author Kevin Lee
+  * @since 2023-07-07
+  */
+class Ce3MdcAdapter extends JLoggerFMdcAdapter {
+
+  private[this] val localContext: IOLocal[Map[String, String]] =
+    IOLocal[Map[String, String]](Map.empty[String, String])
+      .syncStep(1)
+      .flatMap(
+        _.leftMap(_ =>
+          new Error(
+            "Failed to initialize the local context of the Ce3MdcAdapter."
+          )
+        ).liftTo[SyncIO]
+      )
+      .unsafeRunSync()
+
+  override def put(key: String, `val`: String): Unit =
+    IOLocals.update(localContext)(_ + (key -> `val`))
+
+  @SuppressWarnings(Array("org.wartremover.warts.Null"))
+  override def get(key: String): String =
+    IOLocals.get(localContext).getOrElse(key, null) // scalafix:ok DisableSyntax.null
+
+  override def remove(key: String): Unit = IOLocals.update(localContext)(_ - key)
+
+  override def clear(): Unit = IOLocals.reset(localContext)
+
+  override def getCopyOfContextMap: JMap[String, String] = getPropertyMap0
+
+  override def setContextMap0(contextMap: JMap[String, String]): Unit =
+    IOLocals.set(localContext, contextMap.asScala.toMap)
+
+  private def getPropertyMap0: JMap[String, String] = IOLocals.get(localContext).asJava
+
+  override def getPropertyMap: JMap[String, String] = getPropertyMap0
+
+  override def getKeys: JSet[String] = IOLocals.get(localContext).keySet.asJava
+
+}
+object Ce3MdcAdapter {
+
+  @SuppressWarnings(Array("org.wartremover.warts.Null"))
+  private def initialize0(): Ce3MdcAdapter = {
+    val field   = classOf[MDC].getDeclaredField("mdcAdapter")
+    field.setAccessible(true)
+    val adapter = new Ce3MdcAdapter
+    field.set(null, adapter) // scalafix:ok DisableSyntax.null
+    field.setAccessible(false)
+    adapter
+  }
+
+  @SuppressWarnings(Array("org.wartremover.warts.AsInstanceOf", "scalafix:DisableSyntax.asInstanceOf"))
+  def initialize(): Ce3MdcAdapter = {
+    val loggerContext =
+      LoggerFactory.getILoggerFactory.asInstanceOf[LoggerContext]
+    initializeWithLoggerContext(loggerContext)
+  }
+
+  def initializeWithLoggerContext(loggerContext: LoggerContext): Ce3MdcAdapter = {
+    val adapter = initialize0()
+    try {
+      val field = classOf[LoggerContext].getDeclaredField("mdcAdapter")
+      field.setAccessible(true)
+      field.set(loggerContext, adapter)
+      field.setAccessible(false)
+      adapter
+    } catch {
+      case NonFatal(_) => adapter
+    }
+  }
+}