Improve logging

Especially for when errors happen during a connection,
or when we have an advisory lock

src/migrate.ts

@@ -120,8 +120,9 @@ async function fetchAppliedMigrationFromDB(
 ) {
   let appliedMigrations = []
   if (await doesTableExist(client, migrationTableName)) {
-    log(`Migrations table with name '${migrationTableName}' exists,
-filtering not applied migrations.`)
+    log(
+      `Migrations table with name '${migrationTableName}' exists, filtering not applied migrations.`,
+    )
 
     const {rows} = await client.query(
       `SELECT * FROM ${migrationTableName} ORDER BY id`,

src/run-migration.ts

@@ -20,8 +20,6 @@ const insertMigration = async (
       SQL` ("id", "name", "hash") VALUES (${migration.id},${migration.name},${migration.hash})`,
     )
 
-  log(`Executing query: ${sql.text}:${sql.values}`)
-
   return client.query(sql)
 }
 
@@ -55,8 +53,8 @@ export const runMigration = (
     } catch {
       //
     }
-    throw new Error(`An error occurred running '${migration.name}'. Rolled back this migration.
-No further migrations were run.
-Reason: ${err.message}`)
+    throw new Error(
+      `An error occurred running '${migration.name}'. Rolled back this migration. No further migrations were run. Reason: ${err.message}`,
+    )
   }
 }

src/with-connection.ts

@@ -8,19 +8,25 @@ export function withConnection<T>(
   return async (client: pg.Client): Promise<T> => {
     try {
       try {
+        log("Connecting to database...")
         await client.connect()
-        log("Connected to database")
+        log("... connected to database")
       } catch (e) {
         log(`Error connecting to database: ${e.message}`)
         throw e
       }
 
       const result = await f(client)
       return result
+    } catch (e) {
+      log(`Error using connection: ${e.message}`)
+      throw e
     } finally {
       // always try to close the connection
       try {
+        log("Closing connection...")
         await client.end()
+        log("... connection closed")
       } catch (e) {
         log(`Error closing the connection: ${e.message}`)
       }

src/with-lock.ts

@@ -17,6 +17,9 @@ export function withAdvisoryLock<T>(
 
       const result = await f(client)
       return result
+    } catch (e) {
+      log(`Error while using lock: ${e.message}`)
+      throw e
     } finally {
       try {
         log("Releasing advisory lock...")