Merge pull request #2236 from PraverBajaj/PGJsonSuite

Migrated PGJsonSuite to MunitCatsEffect

Author: jatcwang

modules/postgres-circe/src/test/scala/doobie/postgres/circe/PGJsonSuite.scala

@@ -9,9 +9,7 @@ import doobie.*
 import doobie.implicits.*
 import io.circe.{Decoder, Encoder, Json}
 
-class PGJsonSuite extends munit.FunSuite {
-
-  import cats.effect.unsafe.implicits.global
+class PGJsonSuite extends munit.CatsEffectSuite {
 
   val xa = Transactor.fromDriverManager[IO](
     driver = "org.postgresql.Driver",
@@ -29,13 +27,14 @@ class PGJsonSuite extends munit.FunSuite {
 
   def testInOut[A](col: String, a: A, t: Transactor[IO])(implicit m: Get[A], p: Put[A]) = {
     test(s"Mapping for $col as ${m.typeStack} - write+read $col as ${m.typeStack}") {
-      assertEquals(inOut(col, a).transact(t).attempt.unsafeRunSync(), Right(a))
+      inOut(col, a).transact(t).attempt.assertEquals(Right(a))
     }
     test(s"Mapping for $col as ${m.typeStack} - write+read $col as Option[${m.typeStack}] (Some)") {
-      assertEquals(inOut[Option[A]](col, Some(a)).transact(t).attempt.unsafeRunSync(), Right(Some(a)))
+      inOut[Option[A]](col, Some(a)).transact(t).attempt.assertEquals(Right(Some(a)))
     }
     test(s"Mapping for $col as ${m.typeStack} - write+read $col as Option[${m.typeStack}] (None)") {
-      assertEquals(inOut[Option[A]](col, None).transact(t).attempt.unsafeRunSync(), Right(None))
+      inOut[Option[A]](col, None).transact(t).attempt.assertEquals(
+        Right(None))
     }
   }
 
@@ -54,25 +53,26 @@ class PGJsonSuite extends munit.FunSuite {
   test("json should check ok for read") {
     import doobie.postgres.circe.json.implicits.*
 
-    val a = sql"select '{}' :: json".query[Json].analysis.transact(xa).unsafeRunSync()
-    assertEquals(a.columnTypeErrors, Nil)
+    val a = sql"select '{}' :: json".query[Json].analysis.transact(xa)
+    a.map(_.columnTypeErrors).assertEquals(Nil)
   }
   test("json should check ok for write") {
     import doobie.postgres.circe.json.implicits.*
-    val a = sql"select ${Json.obj()} :: json".query[Json].analysis.transact(xa).unsafeRunSync()
-    assertEquals(a.parameterTypeErrors, Nil)
+    val a = sql"select ${Json.obj()} :: json".query[Json].analysis.transact(xa)
+    a.map(_.parameterTypeErrors).assertEquals(Nil)
+
   }
 
   test("jsonb should check ok for read") {
     import doobie.postgres.circe.jsonb.implicits.*
-    val a = sql"select '{}' :: jsonb".query[Json].analysis.transact(xa).unsafeRunSync()
-    assertEquals(a.columnTypeErrors, Nil)
+    val a = sql"select '{}' :: jsonb".query[Json].analysis.transact(xa)
+    a.map(_.columnTypeErrors).assertEquals(Nil)
   }
 
   test("jsonb should check ok for write") {
     import doobie.postgres.circe.jsonb.implicits.*
-    val a = sql"select ${Json.obj()} :: jsonb".query[Json].analysis.transact(xa).unsafeRunSync()
-    assertEquals(a.parameterTypeErrors, Nil)
+    val a = sql"select ${Json.obj()} :: jsonb".query[Json].analysis.transact(xa)
+    a.map(_.parameterTypeErrors).assertEquals(Nil)
   }
 
   // Encoder / Decoders
@@ -86,12 +86,12 @@ class PGJsonSuite extends munit.FunSuite {
   }
 
   test("fooGet should check ok for read") {
-    val a = sql"select '{}' :: json".query[Foo].analysis.transact(xa).unsafeRunSync()
-    assertEquals(a.columnTypeErrors, Nil)
+    val a = sql"select '{}' :: json".query[Foo].analysis.transact(xa)
+    a.map(_.columnTypeErrors).assertEquals(Nil)
   }
   test("fooPut check ok for write") {
-    val a = sql"select ${Foo(Json.obj())} :: json".query[Foo].analysis.transact(xa).unsafeRunSync()
-    assertEquals(a.parameterTypeErrors, Nil)
+    val a = sql"select ${Foo(Json.obj())} :: json".query[Foo].analysis.transact(xa)
+    a.map(_.parameterTypeErrors).assertEquals(Nil)
   }
 
 }