diff options
Diffstat (limited to 'bank/src/main/kotlin')
| -rw-r--r-- | bank/src/main/kotlin/tech/libeufin/bank/Main.kt | 3 | ||||
| -rw-r--r-- | bank/src/main/kotlin/tech/libeufin/bank/db/NotificationWatcher.kt | 2 |
2 files changed, 3 insertions, 2 deletions
diff --git a/bank/src/main/kotlin/tech/libeufin/bank/Main.kt b/bank/src/main/kotlin/tech/libeufin/bank/Main.kt index 0663e49e..31488c03 100644 --- a/bank/src/main/kotlin/tech/libeufin/bank/Main.kt +++ b/bank/src/main/kotlin/tech/libeufin/bank/Main.kt @@ -261,13 +261,14 @@ class BankDbInit : CliktCommand("Initialize the libeufin-bank database", name = val config = talerConfig(common.config) val cfg = config.loadDbConfig() val ctx = config.loadBankConfig() - Database(cfg.dbConnStr, ctx.regionalCurrency, ctx.fiatCurrency).use { db -> + Database(cfg.dbConnStr, ctx.regionalCurrency, ctx.fiatCurrency).use { db -> db.conn { conn -> if (requestReset) { resetDatabaseTables(conn, cfg, sqlFilePrefix = "libeufin-bank") } initializeDatabaseTables(conn, cfg, sqlFilePrefix = "libeufin-bank") } + // Create admin account if missing val res = createAdminAccount(db, ctx) // logs provided by the helper when (res) { diff --git a/bank/src/main/kotlin/tech/libeufin/bank/db/NotificationWatcher.kt b/bank/src/main/kotlin/tech/libeufin/bank/db/NotificationWatcher.kt index eb95e2c4..cd64e77f 100644 --- a/bank/src/main/kotlin/tech/libeufin/bank/db/NotificationWatcher.kt +++ b/bank/src/main/kotlin/tech/libeufin/bank/db/NotificationWatcher.kt @@ -52,7 +52,7 @@ internal class NotificationWatcher(private val pgSource: PGSimpleDataSource) { runBlocking { while (true) { try { - val conn = pgSource.pgConnection() + val conn = pgSource.pgConnection("libeufin_bank") // Listen to all notifications channels conn.execSQLUpdate("LISTEN bank_tx") |