Skip to content

Commit

Permalink
WIP
Browse files Browse the repository at this point in the history
  • Loading branch information
keynmol committed Jun 4, 2024
1 parent 2783bcf commit a955897
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 2 deletions.
4 changes: 3 additions & 1 deletion modules/queue-processor/src/main/scala/PgCredentials.scala
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,9 @@ case class PgCredentials(
database: String,
password: Option[String],
ssl: Boolean
)
):
override def toString(): String =
s"PgCredentials[host=$host:$port,user=$user,database=$database]"

object PgCredentials:
def defaults(mp: Map[String, String]) =
Expand Down
4 changes: 3 additions & 1 deletion modules/queue-processor/src/main/scala/Store.scala
Original file line number Diff line number Diff line change
Expand Up @@ -342,7 +342,9 @@ object Store:

given Tracer[IO] = Tracer.Implicits.noop[IO]

creds.toResource
creds
.flatTap(cr => Log.info(s"Credentials: $cr"))
.toResource
.evalTap(migrate(_))
.flatMap(
open(_, SkunkConfig)
Expand Down

0 comments on commit a955897

Please sign in to comment.