chore: added tests

Author: georgiy.rusanov

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,33 @@
+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/functions.test.ts

@@ -0,0 +1,33 @@
+import { expect, test, describe } from 'vitest'
+import { build } from '../src/server/app.js'
+import { TEST_CONNECTION_STRING } from './lib/utils.js'
+
+describe('server/routes/functions', () => {
+  test('should list functions', async () => {
+    const app = build()
+    const response = await app.inject({
+      method: 'GET',
+      url: '/functions',
+      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 functions with query parameters', async () => {
+    const app = build()
+    const response = await app.inject({
+      method: 'GET',
+      url: '/functions?include_system_schemas=true&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/index.test.ts

@@ -24,3 +24,15 @@ import './server/table-privileges'
 import './server/typegen'
 import './server/result-size-limit'
 import './server/query-timeout'
+// New tests for increased coverage - commented out to avoid import issues
+// import './server/app'
+// import './server/utils'
+// import './server/functions'
+// import './server/config'
+// import './server/extensions'
+// import './server/publications'
+// import './server/schemas'
+// import './server/roles'
+// import './server/triggers'
+// import './server/types'
+// import './server/views'

test/lib/utils.ts

@@ -1,9 +1,11 @@
 import { afterAll } from 'vitest'
 import { PostgresMeta } from '../../src/lib'
 
+export const TEST_CONNECTION_STRING = 'postgresql://postgres:postgres@localhost:5433'
+
 export const pgMeta = new PostgresMeta({
   max: 1,
-  connectionString: 'postgresql://postgres:postgres@localhost:5432/postgres',
+  connectionString: TEST_CONNECTION_STRING,
 })
 
 afterAll(() => pgMeta.end())

test/publications.test.ts

@@ -0,0 +1,33 @@
+import { expect, test, describe } from 'vitest'
+import { build } from '../src/server/app.js'
+import { TEST_CONNECTION_STRING } from './lib/utils.js'
+
+describe('server/routes/publications', () => {
+  test('should list publications', async () => {
+    const app = build()
+    const response = await app.inject({
+      method: 'GET',
+      url: '/publications',
+      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 publications with query parameters', async () => {
+    const app = build()
+    const response = await app.inject({
+      method: 'GET',
+      url: '/publications?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/roles.test.ts

@@ -0,0 +1,33 @@
+import { expect, test, describe } from 'vitest'
+import { build } from '../src/server/app.js'
+import { TEST_CONNECTION_STRING } from './lib/utils.js'
+
+describe('server/routes/roles', () => {
+  test('should list roles', async () => {
+    const app = build()
+    const response = await app.inject({
+      method: 'GET',
+      url: '/roles',
+      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 roles with query parameters', async () => {
+    const app = build()
+    const response = await app.inject({
+      method: 'GET',
+      url: '/roles?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/schemas.test.ts

@@ -0,0 +1,33 @@
+import { expect, test, describe } from 'vitest'
+import { build } from '../src/server/app.js'
+import { TEST_CONNECTION_STRING } from './lib/utils.js'
+
+describe('server/routes/schemas', () => {
+  test('should list schemas', async () => {
+    const app = build()
+    const response = await app.inject({
+      method: 'GET',
+      url: '/schemas',
+      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 schemas with query parameters', async () => {
+    const app = build()
+    const response = await app.inject({
+      method: 'GET',
+      url: '/schemas?include_system_schemas=true&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()
+  })
+})