build

dist/worker-wrapper.mjs

@@ -231,14 +231,42 @@ var Worker = class {
       exitCode,
       output
     });
+    const postgresClient = new pg.Pool({
+      connectionString: `postgresql://postgres:@${startedContainer.getHost()}:${startedContainer.getMappedPort(
+        5432
+      )}/postgres`
+    });
+    postgresClient.on("error", (err) => {
+      parentPort.postMessage({
+        type: "ava-postgres",
+        message: "postgres client error",
+        errMessage: err.message,
+        stack: err.stack
+      });
+    });
+    const heartbeat = async () => {
+      try {
+        const { rows } = await postgresClient.query("SELECT 1");
+        parentPort.postMessage({
+          type: "ava-postgres",
+          message: "postgres heartbeat success",
+          rows
+        });
+      } catch (err) {
+        parentPort.postMessage({
+          type: "ava-postgres",
+          message: "postgres heartbeat failure",
+          errMessage: err.message,
+          stack: err.stack
+        });
+      }
+      setTimeout(heartbeat, 5e3);
+    };
+    heartbeat();
     return {
       container: startedContainer,
       network,
-      postgresClient: new pg.Pool({
-        connectionString: `postgresql://postgres:@${startedContainer.getHost()}:${startedContainer.getMappedPort(
-          5432
-        )}/postgres`
-      })
+      postgresClient
     };
   }
 };