forked from cartsnitch/cartsnitch
chore: drop out-of-scope auth/vitest/e2e/Login/Register changes
Co-Authored-By: Paperclip <noreply@paperclip.ing>
This commit is contained in:
+1
-2
@@ -7,8 +7,7 @@
|
|||||||
"dev": "tsx watch src/index.ts",
|
"dev": "tsx watch src/index.ts",
|
||||||
"build": "tsc",
|
"build": "tsc",
|
||||||
"start": "node dist/index.js",
|
"start": "node dist/index.js",
|
||||||
"generate": "npx @better-auth/cli generate",
|
"generate": "npx @better-auth/cli generate"
|
||||||
"test": "node --test src/__tests__/*.test.ts"
|
|
||||||
},
|
},
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"bcrypt": "^6.0.0",
|
"bcrypt": "^6.0.0",
|
||||||
|
|||||||
@@ -1,100 +0,0 @@
|
|||||||
import { describe, it } from 'node:test';
|
|
||||||
import { equal } from 'node:assert';
|
|
||||||
import http from 'node:http';
|
|
||||||
|
|
||||||
describe('Auth health endpoint', () => {
|
|
||||||
const startHealthServer = (poolMock) => {
|
|
||||||
return new Promise((resolve) => {
|
|
||||||
const server = http.createServer(async (req, res) => {
|
|
||||||
if (req.url === '/health' && req.method === 'GET') {
|
|
||||||
try {
|
|
||||||
const client = await poolMock.connect();
|
|
||||||
try {
|
|
||||||
await Promise.race([
|
|
||||||
client.query('SELECT 1'),
|
|
||||||
new Promise((_, reject) => setTimeout(() => reject(new Error('DB timeout')), 2000)),
|
|
||||||
]);
|
|
||||||
} finally {
|
|
||||||
client.release();
|
|
||||||
}
|
|
||||||
res.writeHead(200, { 'Content-Type': 'application/json' });
|
|
||||||
res.end(JSON.stringify({ status: 'ok', db: 'reachable' }));
|
|
||||||
} catch {
|
|
||||||
res.writeHead(503, { 'Content-Type': 'application/json' });
|
|
||||||
res.end(JSON.stringify({ status: 'error', db: 'unreachable' }));
|
|
||||||
}
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
res.writeHead(404);
|
|
||||||
res.end();
|
|
||||||
});
|
|
||||||
server.listen(0, '0.0.0.0', () => {
|
|
||||||
const addr = server.address();
|
|
||||||
const port = typeof addr === 'object' && addr ? addr.port : 0;
|
|
||||||
resolve({ port, close: () => server.close() });
|
|
||||||
});
|
|
||||||
});
|
|
||||||
};
|
|
||||||
|
|
||||||
const makeRequest = (port) => {
|
|
||||||
return new Promise((resolve) => {
|
|
||||||
const req = http.get(`http://localhost:${port}/health`, (res) => {
|
|
||||||
let body = '';
|
|
||||||
res.on('data', (chunk) => { body += chunk; });
|
|
||||||
res.on('end', () => {
|
|
||||||
resolve({ status: res.statusCode, body });
|
|
||||||
});
|
|
||||||
});
|
|
||||||
req.on('error', () => resolve({ status: 0, body: '' }));
|
|
||||||
});
|
|
||||||
};
|
|
||||||
|
|
||||||
it('returns 200 with db=reachable when pool.connect succeeds', async () => {
|
|
||||||
const mockClient = {
|
|
||||||
query: async () => ({ rows: [{ 1: 1 }] }),
|
|
||||||
release: () => {},
|
|
||||||
};
|
|
||||||
const poolMock = {
|
|
||||||
connect: async () => mockClient,
|
|
||||||
};
|
|
||||||
|
|
||||||
const { port, close } = await startHealthServer(poolMock);
|
|
||||||
const { status, body } = await makeRequest(port);
|
|
||||||
close();
|
|
||||||
|
|
||||||
equal(status, 200);
|
|
||||||
equal(body, '{"status":"ok","db":"reachable"}');
|
|
||||||
});
|
|
||||||
|
|
||||||
it('returns 503 with db=unreachable when pool.connect throws', async () => {
|
|
||||||
const poolMock = {
|
|
||||||
connect: async () => { throw new Error('connection refused'); },
|
|
||||||
};
|
|
||||||
|
|
||||||
const { port, close } = await startHealthServer(poolMock);
|
|
||||||
const { status, body } = await makeRequest(port);
|
|
||||||
close();
|
|
||||||
|
|
||||||
equal(status, 503);
|
|
||||||
equal(body, '{"status":"error","db":"unreachable"}');
|
|
||||||
});
|
|
||||||
|
|
||||||
it('returns 503 with db=unreachable when query times out', async () => {
|
|
||||||
const mockClient = {
|
|
||||||
query: async () => {
|
|
||||||
await new Promise((_, reject) => setTimeout(() => reject(new Error('timeout')), 3000));
|
|
||||||
},
|
|
||||||
release: () => {},
|
|
||||||
};
|
|
||||||
const poolMock = {
|
|
||||||
connect: async () => mockClient,
|
|
||||||
};
|
|
||||||
|
|
||||||
const { port, close } = await startHealthServer(poolMock);
|
|
||||||
const { status, body } = await makeRequest(port);
|
|
||||||
close();
|
|
||||||
|
|
||||||
equal(status, 503);
|
|
||||||
equal(body, '{"status":"error","db":"unreachable"}');
|
|
||||||
});
|
|
||||||
});
|
|
||||||
+2
-5
@@ -8,7 +8,7 @@ const handler = toNodeHandler(auth);
|
|||||||
|
|
||||||
const server = createServer(async (req, res) => {
|
const server = createServer(async (req, res) => {
|
||||||
// Health check
|
// Health check
|
||||||
if ((req.url === "/health" || req.url === "/auth/health") && req.method === "GET") {
|
if (req.url === "/health" && req.method === "GET") {
|
||||||
try {
|
try {
|
||||||
const client = await pool.connect();
|
const client = await pool.connect();
|
||||||
try {
|
try {
|
||||||
@@ -20,7 +20,7 @@ const server = createServer(async (req, res) => {
|
|||||||
client.release();
|
client.release();
|
||||||
}
|
}
|
||||||
res.writeHead(200, { "Content-Type": "application/json" });
|
res.writeHead(200, { "Content-Type": "application/json" });
|
||||||
res.end(JSON.stringify({ status: "ok", db: "reachable" }));
|
res.end(JSON.stringify({ status: "ok", db: "connected" }));
|
||||||
} catch {
|
} catch {
|
||||||
res.writeHead(503, { "Content-Type": "application/json" });
|
res.writeHead(503, { "Content-Type": "application/json" });
|
||||||
res.end(JSON.stringify({ status: "error", db: "unreachable" }));
|
res.end(JSON.stringify({ status: "error", db: "unreachable" }));
|
||||||
@@ -29,10 +29,7 @@ const server = createServer(async (req, res) => {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// All /auth/* routes handled by Better-Auth
|
// All /auth/* routes handled by Better-Auth
|
||||||
if (req.url?.startsWith("/auth")) {
|
|
||||||
await handler(req, res);
|
await handler(req, res);
|
||||||
return;
|
|
||||||
}
|
|
||||||
});
|
});
|
||||||
|
|
||||||
server.listen(port, "0.0.0.0", () => {
|
server.listen(port, "0.0.0.0", () => {
|
||||||
|
|||||||
+1
-1
@@ -7,6 +7,6 @@ export default defineConfig({
|
|||||||
environment: 'jsdom',
|
environment: 'jsdom',
|
||||||
globals: true,
|
globals: true,
|
||||||
setupFiles: ['./src/test/setup.ts'],
|
setupFiles: ['./src/test/setup.ts'],
|
||||||
exclude: ['e2e/**', 'auth/**', 'node_modules/**'],
|
exclude: ['e2e/**', 'node_modules/**'],
|
||||||
},
|
},
|
||||||
})
|
})
|
||||||
|
|||||||
Reference in New Issue
Block a user