linting

Author: softinio

duck4s-cats-effect/src/DuckDBException.scala

@@ -47,8 +47,11 @@ object DuckDBException:
     *   A DuckDBException wrapping the given error
     */
   def from(error: DuckDBError): DuckDBException = error match
-    case DuckDBError.ConnectionError(msg, cause)  => DuckDBException(error, msg, cause)
-    case DuckDBError.QueryError(msg, _, cause)     => DuckDBException(error, msg, cause)
-    case DuckDBError.TransactionError(msg, cause)  => DuckDBException(error, msg, cause)
-    case DuckDBError.ConfigurationError(msg)       => DuckDBException(error, msg)
-    case DuckDBError.InvalidStateError(msg)        => DuckDBException(error, msg)
+    case DuckDBError.ConnectionError(msg, cause) =>
+      DuckDBException(error, msg, cause)
+    case DuckDBError.QueryError(msg, _, cause) =>
+      DuckDBException(error, msg, cause)
+    case DuckDBError.TransactionError(msg, cause) =>
+      DuckDBException(error, msg, cause)
+    case DuckDBError.ConfigurationError(msg) => DuckDBException(error, msg)
+    case DuckDBError.InvalidStateError(msg)  => DuckDBException(error, msg)

duck4s-cats-effect/src/DuckDBIO.scala

@@ -57,7 +57,9 @@ object DuckDBIO:
     * @return
     *   A [[Resource]] that manages the connection lifecycle.
     */
-  def connect(config: DuckDBConfig = DuckDBConfig.inMemory): Resource[IO, DuckDBConnection] =
+  def connect(
+      config: DuckDBConfig = DuckDBConfig.inMemory
+  ): Resource[IO, DuckDBConnection] =
     Resource.make(
       IO.blocking(DuckDBConnection.connect(config)).flatMap(liftE)
     )(conn => IO.blocking(conn.close()))
@@ -80,7 +82,9 @@ object DuckDBIO:
     * @return
     *   A [[fs2.Stream]] that emits one element per row.
     */
-  def stream[A](conn: DuckDBConnection, sql: String)(f: DuckDBResultSet => A): Stream[IO, A] =
+  def stream[A](conn: DuckDBConnection, sql: String)(
+      f: DuckDBResultSet => A
+  ): Stream[IO, A] =
     Stream
       .resource(
         Resource.make(
@@ -89,7 +93,8 @@ object DuckDBIO:
       )
       .flatMap: rs =>
         Stream.unfoldEval(rs): rs =>
-          IO.blocking(rs.next()).map(hasNext => Option.when(hasNext)(f(rs) -> rs))
+          IO.blocking(rs.next())
+            .map(hasNext => Option.when(hasNext)(f(rs) -> rs))
 
 /** Extension methods providing effectful versions of [[DuckDBConnection]]
   * operations. Import `com.softinio.duck4s.effect.*` to use these.
@@ -140,7 +145,9 @@ extension (conn: DuckDBConnection)
     * @return
     *   An `IO[T]` with the result of the block.
     */
-  def withPreparedStatementIO[T](sql: String)(block: DuckDBPreparedStatement => IO[T]): IO[T] =
+  def withPreparedStatementIO[T](
+      sql: String
+  )(block: DuckDBPreparedStatement => IO[T]): IO[T] =
     Resource
       .make(conn.prepareStatementIO(sql))(stmt => IO.blocking(stmt.close()))
       .use(block)
@@ -175,8 +182,8 @@ extension (conn: DuckDBConnection)
     *
     * Disables auto-commit before running the block. On success, commits the
     * transaction. On failure (any raised error), rolls back the transaction.
-    * Auto-commit is restored to `true` in a `guarantee` finalizer regardless
-    * of outcome.
+    * Auto-commit is restored to `true` in a `guarantee` finalizer regardless of
+    * outcome.
     *
     * @param block
     *   A function receiving this connection and returning an `IO[T]`.

duck4s-cats-effect/test/src/DuckDBIOTest.scala

@@ -31,7 +31,9 @@ class DuckDBIOTest extends CatsEffectSuite:
   test("executeUpdateIO / executeQueryIO round-trip") {
     DuckDBIO.connect().use { conn =>
       for
-        _ <- conn.executeUpdateIO("CREATE TABLE test (id INTEGER, name VARCHAR)")
+        _ <- conn.executeUpdateIO(
+          "CREATE TABLE test (id INTEGER, name VARCHAR)"
+        )
         _ <- conn.executeUpdateIO("INSERT INTO test VALUES (1, 'Alice')")
         rs <- conn.executeQueryIO("SELECT * FROM test")
         _ <- IO(assert(rs.next()))
@@ -47,7 +49,10 @@ class DuckDBIOTest extends CatsEffectSuite:
       for
         _ <- conn.executeUpdateIO("CREATE TABLE nums (n INTEGER)")
         _ <- conn.executeUpdateIO("INSERT INTO nums VALUES (1),(2),(3)")
-        rows <- DuckDBIO.stream(conn, "SELECT n FROM nums")(_.getInt("n")).compile.toList
+        rows <- DuckDBIO
+          .stream(conn, "SELECT n FROM nums")(_.getInt("n"))
+          .compile
+          .toList
         _ <- IO(assertEquals(rows, List(1, 2, 3)))
       yield ()
     }
@@ -86,7 +91,7 @@ class DuckDBIOTest extends CatsEffectSuite:
 
   test("DuckDBException wraps ConnectionError") {
     val error = DuckDBError.ConnectionError("test connection error")
-    val ex    = DuckDBException.from(error)
+    val ex = DuckDBException.from(error)
     assertEquals(ex.getMessage, "test connection error")
     assertEquals(ex.error, error)
     assert(ex.getCause == null)
@@ -95,7 +100,7 @@ class DuckDBIOTest extends CatsEffectSuite:
   test("DuckDBException wraps QueryError with cause") {
     val cause = new RuntimeException("jdbc failure")
     val error = DuckDBError.QueryError("query failed", "SELECT 1", Some(cause))
-    val ex    = DuckDBException.from(error)
+    val ex = DuckDBException.from(error)
     assertEquals(ex.getMessage, "query failed")
     assertEquals(ex.error, error)
     assertEquals(ex.getCause, cause)