chore: added tests

test/admin-app.test.ts

@@ -0,0 +1,17 @@
+import { expect, test, describe } from 'vitest'
+import { build } from '../src/server/admin-app.js'
+
+describe('admin-app', () => {
+  test('should register metrics endpoint', async () => {
+    const app = build()
+
+    // Test that the app can be started (this will trigger plugin registration)
+    await app.ready()
+
+    // Verify that metrics endpoint is available
+    const routes = app.printRoutes()
+    expect(routes).toContain('metrics')
+
+    await app.close()
+  })
+})

test/app.test.ts

@@ -0,0 +1,31 @@
+import { expect, test, describe } from 'vitest'
+import { build } from '../src/server/app.js'
+
+describe('server/app', () => {
+  test('should handle root endpoint', async () => {
+    const app = build()
+    const response = await app.inject({
+      method: 'GET',
+      url: '/',
+    })
+    expect(response.statusCode).toBe(200)
+    const data = JSON.parse(response.body)
+    expect(data).toHaveProperty('status')
+    expect(data).toHaveProperty('name')
+    expect(data).toHaveProperty('version')
+    expect(data).toHaveProperty('documentation')
+    await app.close()
+  })
+
+  test('should handle health endpoint', async () => {
+    const app = build()
+    const response = await app.inject({
+      method: 'GET',
+      url: '/health',
+    })
+    expect(response.statusCode).toBe(200)
+    const data = JSON.parse(response.body)
+    expect(data).toHaveProperty('date')
+    await app.close()
+  })
+})

test/config.test.ts

@@ -0,0 +1,127 @@
+import { expect, test, describe } from 'vitest'
+import { build } from '../src/server/app.js'
+import { TEST_CONNECTION_STRING } from './lib/utils.js'
+
+describe('server/routes/config', () => {
+  test('should list config with query parameters', async () => {
+    const app = build()
+    const response = await app.inject({
+      method: 'GET',
+      url: '/config?limit=5&offset=0',
+      headers: {
+        pg: TEST_CONNECTION_STRING,
+      },
+    })
+    expect(response.statusCode).toBe(200)
+    expect(response.json()).toMatchInlineSnapshot(`
+      [
+        {
+          "boot_val": "on",
+          "category": "Autovacuum",
+          "context": "sighup",
+          "enumvals": null,
+          "extra_desc": null,
+          "group": "Autovacuum",
+          "max_val": null,
+          "min_val": null,
+          "name": "autovacuum",
+          "pending_restart": false,
+          "reset_val": "on",
+          "setting": "on",
+          "short_desc": "Starts the autovacuum subprocess.",
+          "source": "default",
+          "sourcefile": null,
+          "sourceline": null,
+          "subgroup": "",
+          "unit": null,
+          "vartype": "bool",
+        },
+        {
+          "boot_val": "0.1",
+          "category": "Autovacuum",
+          "context": "sighup",
+          "enumvals": null,
+          "extra_desc": null,
+          "group": "Autovacuum",
+          "max_val": "100",
+          "min_val": "0",
+          "name": "autovacuum_analyze_scale_factor",
+          "pending_restart": false,
+          "reset_val": "0.1",
+          "setting": "0.1",
+          "short_desc": "Number of tuple inserts, updates, or deletes prior to analyze as a fraction of reltuples.",
+          "source": "default",
+          "sourcefile": null,
+          "sourceline": null,
+          "subgroup": "",
+          "unit": null,
+          "vartype": "real",
+        },
+        {
+          "boot_val": "50",
+          "category": "Autovacuum",
+          "context": "sighup",
+          "enumvals": null,
+          "extra_desc": null,
+          "group": "Autovacuum",
+          "max_val": "2147483647",
+          "min_val": "0",
+          "name": "autovacuum_analyze_threshold",
+          "pending_restart": false,
+          "reset_val": "50",
+          "setting": "50",
+          "short_desc": "Minimum number of tuple inserts, updates, or deletes prior to analyze.",
+          "source": "default",
+          "sourcefile": null,
+          "sourceline": null,
+          "subgroup": "",
+          "unit": null,
+          "vartype": "integer",
+        },
+        {
+          "boot_val": "200000000",
+          "category": "Autovacuum",
+          "context": "postmaster",
+          "enumvals": null,
+          "extra_desc": null,
+          "group": "Autovacuum",
+          "max_val": "2000000000",
+          "min_val": "100000",
+          "name": "autovacuum_freeze_max_age",
+          "pending_restart": false,
+          "reset_val": "200000000",
+          "setting": "200000000",
+          "short_desc": "Age at which to autovacuum a table to prevent transaction ID wraparound.",
+          "source": "default",
+          "sourcefile": null,
+          "sourceline": null,
+          "subgroup": "",
+          "unit": null,
+          "vartype": "integer",
+        },
+        {
+          "boot_val": "3",
+          "category": "Autovacuum",
+          "context": "postmaster",
+          "enumvals": null,
+          "extra_desc": null,
+          "group": "Autovacuum",
+          "max_val": "262143",
+          "min_val": "1",
+          "name": "autovacuum_max_workers",
+          "pending_restart": false,
+          "reset_val": "3",
+          "setting": "3",
+          "short_desc": "Sets the maximum number of simultaneously running autovacuum worker processes.",
+          "source": "default",
+          "sourcefile": null,
+          "sourceline": null,
+          "subgroup": "",
+          "unit": null,
+          "vartype": "integer",
+        },
+      ]
+    `)
+    await app.close()
+  })
+})

test/extensions.test.ts

@@ -0,0 +1,144 @@
+import { expect, test, describe } from 'vitest'
+import { build } from '../src/server/app.js'
+import { TEST_CONNECTION_STRING } from './lib/utils.js'
+
+describe('server/routes/extensions', () => {
+  test('should list extensions', async () => {
+    const app = build()
+    const response = await app.inject({
+      method: 'GET',
+      url: '/extensions',
+      headers: {
+        pg: TEST_CONNECTION_STRING,
+      },
+    })
+    expect(response.statusCode).toBe(200)
+    expect(Array.isArray(JSON.parse(response.body))).toBe(true)
+    await app.close()
+  })
+
+  test('should list extensions with query parameters', async () => {
+    const app = build()
+    const response = await app.inject({
+      method: 'GET',
+      url: '/extensions?limit=5&offset=0',
+      headers: {
+        pg: TEST_CONNECTION_STRING,
+      },
+    })
+    expect(response.statusCode).toBe(200)
+    expect(Array.isArray(JSON.parse(response.body))).toBe(true)
+    await app.close()
+  })
+
+  test('should return 404 for non-existent extension', async () => {
+    const app = build()
+    const response = await app.inject({
+      method: 'GET',
+      url: '/extensions/non-existent-extension',
+      headers: {
+        pg: TEST_CONNECTION_STRING,
+      },
+    })
+    expect(response.statusCode).toBe(404)
+    await app.close()
+  })
+
+  test('should create extension, retrieve, update, delete', async () => {
+    const app = build()
+    const response = await app.inject({
+      method: 'POST',
+      url: '/extensions',
+      headers: {
+        pg: TEST_CONNECTION_STRING,
+      },
+      payload: { name: 'pgcrypto', version: '1.3' },
+    })
+    expect(response.statusCode).toBe(200)
+    expect(response.json()).toMatchInlineSnapshot(`
+        {
+          "comment": "cryptographic functions",
+          "default_version": "1.3",
+          "installed_version": "1.3",
+          "name": "pgcrypto",
+          "schema": "public",
+        }
+      `)
+
+    const retrieveResponse = await app.inject({
+      method: 'GET',
+      url: '/extensions/pgcrypto',
+      headers: {
+        pg: TEST_CONNECTION_STRING,
+      },
+    })
+    expect(retrieveResponse.statusCode).toBe(200)
+    expect(retrieveResponse.json()).toMatchInlineSnapshot(`
+        {
+          "comment": "cryptographic functions",
+          "default_version": "1.3",
+          "installed_version": "1.3",
+          "name": "pgcrypto",
+          "schema": "public",
+        }
+      `)
+
+    const updateResponse = await app.inject({
+      method: 'PATCH',
+      url: '/extensions/pgcrypto',
+      headers: {
+        pg: TEST_CONNECTION_STRING,
+      },
+      payload: { schema: 'public' },
+    })
+    expect(updateResponse.statusCode).toBe(200)
+    expect(updateResponse.json()).toMatchInlineSnapshot(`
+      {
+        "comment": "cryptographic functions",
+        "default_version": "1.3",
+        "installed_version": "1.3",
+        "name": "pgcrypto",
+        "schema": "public",
+      }
+    `)
+
+    const deleteResponse = await app.inject({
+      method: 'DELETE',
+      url: '/extensions/pgcrypto',
+      headers: {
+        pg: TEST_CONNECTION_STRING,
+      },
+    })
+    expect(deleteResponse.statusCode).toBe(200)
+    expect(deleteResponse.json()).toMatchInlineSnapshot(`
+      {
+        "comment": "cryptographic functions",
+        "default_version": "1.3",
+        "installed_version": "1.3",
+        "name": "pgcrypto",
+        "schema": "public",
+      }
+    `)
+
+    await app.close()
+  })
+
+  test('should return 400 for invalid extension name', async () => {
+    const app = build()
+    const response = await app.inject({
+      method: 'POST',
+      url: '/extensions',
+      headers: {
+        pg: TEST_CONNECTION_STRING,
+      },
+      payload: { name: 'invalid-extension', version: '1.3' },
+    })
+    expect(response.statusCode).toBe(400)
+    expect(response.json()).toMatchInlineSnapshot(`
+      {
+        "error": "could not open extension control file "/usr/share/postgresql/14/extension/invalid-extension.control": No such file or directory",
+      }
+    `)
+    await app.close()
+  })
+})