ft: add Postgres.js integration tests to the tree

flake.nix

@@ -53,7 +53,12 @@
             {
               pre-commit.hooks = {
                 alejandra.enable = true;
-                typos.enable = true;
+                typos = {
+                  enable = true;
+                  excludes = [
+                    "test/integration/"
+                  ];
+                };
               };
             }
             {
@@ -78,6 +83,7 @@
 
               services.postgres = {
                 enable = true;
+                package = pkgs.postgresql_15;
                 initialScript = ''
                   ${builtins.readFile ./dev/postgres/00-setup.sql}
 
@@ -87,11 +93,18 @@
                 port = 6432;
               };
 
-              process.implementation = "honcho";
+              process.manager.implementation = "honcho";
 
               # Force connection through TCP instead of Unix socket
               env.PGHOST = lib.mkForce "";
             }
+            {
+              languages.javascript = {
+                enable = true;
+                bun.enable = true;
+                yarn.enable = true;
+              };
+            }
             ({
               pkgs,
               lib,

test/integration/js/.gitignore

@@ -0,0 +1 @@
+/node_modules

test/integration/js/package.json

@@ -0,0 +1,13 @@
+{
+  "name": "supavisor-integration",
+  "version": "1.0.0",
+  "main": "index.js",
+  "type": "module",
+  "license": "MIT",
+  "scripts": {
+    "test:postgres": "node ./postgres/index.js"
+  },
+  "dependencies": {
+    "postgres": "^3.4.5"
+  }
+}

test/integration/js/postgres/bootstrap.js

@@ -0,0 +1,36 @@
+import { spawnSync } from 'child_process'
+
+//exec('dropdb', ['postgres_js_test'])
+
+//exec('psql', ['-c', 'alter system set ssl=on'])
+//exec('psql', ['-c', 'drop user postgres_js_test'])
+//exec('psql', ['-c', 'create user postgres_js_test'])
+//exec('psql', ['-c', 'alter system set password_encryption=md5'])
+//exec('psql', ['-c', 'select pg_reload_conf()'])
+//exec('psql', ['-c', 'drop user if exists postgres_js_test_md5'])
+//exec('psql', ['-c', 'create user postgres_js_test_md5 with password \'postgres_js_test_md5\''])
+//exec('psql', ['-c', 'alter system set password_encryption=\'scram-sha-256\''])
+//exec('psql', ['-c', 'select pg_reload_conf()'])
+//exec('psql', ['-c', 'drop user if exists postgres_js_test_scram'])
+//exec('psql', ['-c', 'create user postgres_js_test_scram with password \'postgres_js_test_scram\''])
+//
+//exec('createdb', ['postgres_js_test'])
+//exec('psql', ['-c', 'grant all on database postgres_js_test to postgres_js_test'])
+//exec('psql', ['-c', 'alter database postgres_js_test owner to postgres_js_test'])
+
+exec('psql', ['-c', 'drop table test'])
+
+export function exec(cmd, args) {
+  const { stderr } = spawnSync(cmd, args, { stdio: 'pipe', encoding: 'utf8' })
+  if (stderr && !stderr.includes('already exists') && !stderr.includes('does not exist'))
+    throw stderr
+}
+
+async function execAsync(cmd, args) { // eslint-disable-line
+  let stderr = ''
+  const cp = await spawn(cmd, args, { stdio: 'pipe', encoding: 'utf8' }) // eslint-disable-line
+  cp.stderr.on('data', x => stderr += x)
+  await new Promise(x => cp.on('exit', x))
+  if (stderr && !stderr.includes('already exists') && !stderr.includes('does not exist'))
+    throw new Error(stderr)
+}

test/integration/js/postgres/copy.csv

@@ -0,0 +1,2 @@
+1	2	3
+4	5	6