mirror of
https://github.com/tiennm99/ccs.git
synced 2026-09-05 14:22:12 +00:00
test(cursor): reclassify daemon lifecycle smoke coverage
This commit is contained in:
+13
-11
@@ -11,7 +11,7 @@ tests/
|
|||||||
├── native/ # Native installation tests (bash/PowerShell)
|
├── native/ # Native installation tests (bash/PowerShell)
|
||||||
│ ├── unix/ # Unix/Linux/macOS tests
|
│ ├── unix/ # Unix/Linux/macOS tests
|
||||||
│ └── windows/ # Windows PowerShell tests
|
│ └── windows/ # Windows PowerShell tests
|
||||||
├── integration/ # Integration tests (manual execution)
|
├── integration/ # Integration + smoke tests
|
||||||
└── shared/ # Shared utilities
|
└── shared/ # Shared utilities
|
||||||
├── fixtures/ # Test configuration and environment
|
├── fixtures/ # Test configuration and environment
|
||||||
├── unit/ # Helper function tests
|
├── unit/ # Helper function tests
|
||||||
@@ -22,9 +22,9 @@ tests/
|
|||||||
## Running Tests
|
## Running Tests
|
||||||
|
|
||||||
```bash
|
```bash
|
||||||
bun run test # All automated tests (unit + npm)
|
bun run test # All automated tests (unit + integration + npm)
|
||||||
bun run test:unit # Unit tests only (Mocha)
|
bun run test:unit # Unit tests only
|
||||||
bun run test:npm # npm package tests (Mocha)
|
bun run test:npm # npm package tests
|
||||||
bun run test:native # Native Unix tests (bash)
|
bun run test:native # Native Unix tests (bash)
|
||||||
```
|
```
|
||||||
|
|
||||||
@@ -48,16 +48,18 @@ Installation tests for curl|bash (Unix) and irm|iex (Windows):
|
|||||||
- `native/windows/edge-cases.ps1` - Windows edge case tests
|
- `native/windows/edge-cases.ps1` - Windows edge case tests
|
||||||
|
|
||||||
### Integration Tests (`integration/`)
|
### Integration Tests (`integration/`)
|
||||||
Manual execution tests for specific scenarios:
|
Integration and smoke coverage for scenarios that exercise multiple layers:
|
||||||
- `token-counting-test.js` - Token counting validation
|
- Automated `*.test.ts` files run as part of `bun run test:all` and CI
|
||||||
- `z-ai-streaming-test.js` - Z.AI streaming
|
- Shell and standalone probe scripts remain on-demand for targeted debugging
|
||||||
- `glmt-integration-test.sh` - GLMT integration
|
- `cursor-daemon-lifecycle.test.ts` - local daemon process + HTTP smoke coverage
|
||||||
|
- `image-analyzer-hook.test.ts` - hook integration coverage
|
||||||
|
- `glmt-integration-test.sh` - GLMT integration probe
|
||||||
- `symlink-chain-test.sh` - Symlink chain handling
|
- `symlink-chain-test.sh` - Symlink chain handling
|
||||||
- `ux-integration-test.sh` - CLI UX integration
|
- `ux-integration-test.sh` - CLI UX integration
|
||||||
|
|
||||||
## Adding New Tests
|
## Adding New Tests
|
||||||
|
|
||||||
- **Unit tests**: Add to `unit/<module>/` using Mocha + Node.js assert
|
- **Unit tests**: Add to `unit/<module>/` for isolated module behavior
|
||||||
- **npm tests**: Add to `npm/` using Mocha
|
- **npm tests**: Add to `npm/` for package behavior
|
||||||
- **Native tests**: Add to `native/unix/` or `native/windows/`
|
- **Native tests**: Add to `native/unix/` or `native/windows/`
|
||||||
- **Integration tests**: Add to `integration/`
|
- **Integration tests**: Add automated cross-layer smoke coverage to `integration/*.test.ts`
|
||||||
|
|||||||
@@ -0,0 +1,165 @@
|
|||||||
|
import { afterEach, beforeEach, describe, expect, it } from 'bun:test';
|
||||||
|
import * as fs from 'fs';
|
||||||
|
import * as os from 'os';
|
||||||
|
import * as path from 'path';
|
||||||
|
import { isDaemonRunning, startDaemon, stopDaemon } from '../../src/cursor/cursor-daemon';
|
||||||
|
import { saveCredentials } from '../../src/cursor/cursor-auth';
|
||||||
|
|
||||||
|
let originalCcsHome: string | undefined;
|
||||||
|
let tempDir: string;
|
||||||
|
|
||||||
|
beforeEach(() => {
|
||||||
|
originalCcsHome = process.env.CCS_HOME;
|
||||||
|
tempDir = fs.mkdtempSync(path.join(os.tmpdir(), 'ccs-daemon-integration-'));
|
||||||
|
process.env.CCS_HOME = tempDir;
|
||||||
|
});
|
||||||
|
|
||||||
|
afterEach(async () => {
|
||||||
|
await stopDaemon();
|
||||||
|
|
||||||
|
if (originalCcsHome !== undefined) {
|
||||||
|
process.env.CCS_HOME = originalCcsHome;
|
||||||
|
} else {
|
||||||
|
delete process.env.CCS_HOME;
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
fs.rmSync(tempDir, { recursive: true, force: true });
|
||||||
|
} catch {
|
||||||
|
// Ignore cleanup errors
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
describe('cursor daemon lifecycle smoke', () => {
|
||||||
|
it('starts, serves expected routes, and stops cleanly', async () => {
|
||||||
|
const port = 10000 + Math.floor(Math.random() * 50000);
|
||||||
|
const result = await startDaemon({ port, ghost_mode: true });
|
||||||
|
expect(result.success).toBe(true);
|
||||||
|
expect(result.pid).toBeDefined();
|
||||||
|
|
||||||
|
expect(await isDaemonRunning(port)).toBe(true);
|
||||||
|
|
||||||
|
const modelsResponse = await fetch(`http://127.0.0.1:${port}/v1/models`);
|
||||||
|
expect(modelsResponse.status).toBe(200);
|
||||||
|
const modelsJson = (await modelsResponse.json()) as { object?: string; data?: unknown[] };
|
||||||
|
expect(modelsJson.object).toBe('list');
|
||||||
|
expect(Array.isArray(modelsJson.data)).toBe(true);
|
||||||
|
|
||||||
|
const chatResponse = await fetch(`http://127.0.0.1:${port}/v1/chat/completions`, {
|
||||||
|
method: 'POST',
|
||||||
|
headers: { 'Content-Type': 'application/json' },
|
||||||
|
body: JSON.stringify({
|
||||||
|
model: 'gpt-4.1',
|
||||||
|
messages: [{ role: 'user', content: 'hello' }],
|
||||||
|
}),
|
||||||
|
});
|
||||||
|
expect(chatResponse.status).toBe(401);
|
||||||
|
|
||||||
|
const anthropicResponse = await fetch(`http://127.0.0.1:${port}/v1/messages`, {
|
||||||
|
method: 'POST',
|
||||||
|
headers: {
|
||||||
|
'Content-Type': 'application/json',
|
||||||
|
'anthropic-version': '2023-06-01',
|
||||||
|
},
|
||||||
|
body: JSON.stringify({
|
||||||
|
model: 'claude-sonnet-4.5',
|
||||||
|
max_tokens: 256,
|
||||||
|
messages: [{ role: 'user', content: 'hello' }],
|
||||||
|
}),
|
||||||
|
});
|
||||||
|
expect(anthropicResponse.status).toBe(401);
|
||||||
|
|
||||||
|
const stopResult = await stopDaemon();
|
||||||
|
expect(stopResult.success).toBe(true);
|
||||||
|
expect(await isDaemonRunning(port)).toBe(false);
|
||||||
|
}, 35000);
|
||||||
|
|
||||||
|
it('returns 404 for unknown routes', async () => {
|
||||||
|
const port = 10000 + Math.floor(Math.random() * 50000);
|
||||||
|
const result = await startDaemon({ port, ghost_mode: true });
|
||||||
|
expect(result.success).toBe(true);
|
||||||
|
|
||||||
|
const response = await fetch(`http://127.0.0.1:${port}/unknown`);
|
||||||
|
expect(response.status).toBe(404);
|
||||||
|
});
|
||||||
|
|
||||||
|
it('returns 401 when credentials are expired', async () => {
|
||||||
|
const port = 10000 + Math.floor(Math.random() * 50000);
|
||||||
|
const expiredAt = new Date(Date.now() - 26 * 60 * 60 * 1000).toISOString();
|
||||||
|
|
||||||
|
saveCredentials({
|
||||||
|
accessToken: 'a'.repeat(60),
|
||||||
|
machineId: '1234567890abcdef1234567890abcdef',
|
||||||
|
authMethod: 'manual',
|
||||||
|
importedAt: expiredAt,
|
||||||
|
});
|
||||||
|
|
||||||
|
const result = await startDaemon({ port, ghost_mode: true });
|
||||||
|
expect(result.success).toBe(true);
|
||||||
|
|
||||||
|
const response = await fetch(`http://127.0.0.1:${port}/v1/chat/completions`, {
|
||||||
|
method: 'POST',
|
||||||
|
headers: { 'Content-Type': 'application/json' },
|
||||||
|
body: JSON.stringify({
|
||||||
|
model: 'gpt-4.1',
|
||||||
|
messages: [{ role: 'user', content: 'hello' }],
|
||||||
|
}),
|
||||||
|
});
|
||||||
|
|
||||||
|
expect(response.status).toBe(401);
|
||||||
|
const body = (await response.json()) as { error?: { message?: string } };
|
||||||
|
expect(body.error?.message).toContain('expired');
|
||||||
|
});
|
||||||
|
|
||||||
|
it('validates invalid JSON, invalid message schema, and oversized body', async () => {
|
||||||
|
const port = 10000 + Math.floor(Math.random() * 50000);
|
||||||
|
const result = await startDaemon({ port, ghost_mode: true });
|
||||||
|
expect(result.success).toBe(true);
|
||||||
|
|
||||||
|
const invalidJson = await fetch(`http://127.0.0.1:${port}/v1/chat/completions`, {
|
||||||
|
method: 'POST',
|
||||||
|
headers: { 'Content-Type': 'application/json' },
|
||||||
|
body: '{invalid-json',
|
||||||
|
});
|
||||||
|
expect(invalidJson.status).toBe(400);
|
||||||
|
|
||||||
|
const invalidSchema = await fetch(`http://127.0.0.1:${port}/v1/chat/completions`, {
|
||||||
|
method: 'POST',
|
||||||
|
headers: { 'Content-Type': 'application/json' },
|
||||||
|
body: JSON.stringify({
|
||||||
|
model: 'gpt-4.1',
|
||||||
|
messages: { role: 'user', content: 'hello' },
|
||||||
|
}),
|
||||||
|
});
|
||||||
|
expect(invalidSchema.status).toBe(400);
|
||||||
|
|
||||||
|
const invalidAnthropic = await fetch(`http://127.0.0.1:${port}/v1/messages`, {
|
||||||
|
method: 'POST',
|
||||||
|
headers: {
|
||||||
|
'Content-Type': 'application/json',
|
||||||
|
'anthropic-version': '2023-06-01',
|
||||||
|
},
|
||||||
|
body: JSON.stringify({
|
||||||
|
model: 'claude-sonnet-4.5',
|
||||||
|
max_tokens: 256,
|
||||||
|
messages: [{ role: 'user', content: [{ type: 'image' }] }],
|
||||||
|
}),
|
||||||
|
});
|
||||||
|
expect(invalidAnthropic.status).toBe(400);
|
||||||
|
|
||||||
|
const oversized = await fetch(`http://127.0.0.1:${port}/v1/chat/completions`, {
|
||||||
|
method: 'POST',
|
||||||
|
headers: { 'Content-Type': 'application/json' },
|
||||||
|
body: JSON.stringify({
|
||||||
|
model: 'gpt-4.1',
|
||||||
|
messages: [
|
||||||
|
{
|
||||||
|
role: 'user',
|
||||||
|
content: 'x'.repeat(10 * 1024 * 1024 + 1024),
|
||||||
|
},
|
||||||
|
],
|
||||||
|
}),
|
||||||
|
});
|
||||||
|
expect(oversized.status).toBe(413);
|
||||||
|
});
|
||||||
|
});
|
||||||
@@ -19,7 +19,7 @@ import {
|
|||||||
} from '../../../src/cursor/cursor-daemon';
|
} from '../../../src/cursor/cursor-daemon';
|
||||||
import { getCcsDir } from '../../../src/utils/config-manager';
|
import { getCcsDir } from '../../../src/utils/config-manager';
|
||||||
import { handleCursorCommand } from '../../../src/commands/cursor-command';
|
import { handleCursorCommand } from '../../../src/commands/cursor-command';
|
||||||
import { loadCredentials, saveCredentials } from '../../../src/cursor/cursor-auth';
|
import { loadCredentials } from '../../../src/cursor/cursor-auth';
|
||||||
|
|
||||||
// Test isolation
|
// Test isolation
|
||||||
let originalCcsHome: string | undefined;
|
let originalCcsHome: string | undefined;
|
||||||
@@ -140,158 +140,6 @@ describe('startDaemon', () => {
|
|||||||
expect(result.success).toBe(false);
|
expect(result.success).toBe(false);
|
||||||
expect(result.error).toContain('Invalid port');
|
expect(result.error).toContain('Invalid port');
|
||||||
});
|
});
|
||||||
|
|
||||||
it('starts and stops daemon successfully', async () => {
|
|
||||||
const port = 10000 + Math.floor(Math.random() * 50000);
|
|
||||||
const result = await startDaemon({ port, ghost_mode: true });
|
|
||||||
expect(result.success).toBe(true);
|
|
||||||
expect(result.pid).toBeDefined();
|
|
||||||
|
|
||||||
// Verify health
|
|
||||||
const running = await isDaemonRunning(port);
|
|
||||||
expect(running).toBe(true);
|
|
||||||
|
|
||||||
// Verify models endpoint exists and is OpenAI-compatible list shape
|
|
||||||
const modelsResponse = await fetch(`http://127.0.0.1:${port}/v1/models`);
|
|
||||||
expect(modelsResponse.status).toBe(200);
|
|
||||||
const modelsJson = (await modelsResponse.json()) as { object?: string; data?: unknown[] };
|
|
||||||
expect(modelsJson.object).toBe('list');
|
|
||||||
expect(Array.isArray(modelsJson.data)).toBe(true);
|
|
||||||
|
|
||||||
// Verify chat endpoint exists (requires auth, should not be 404)
|
|
||||||
const chatResponse = await fetch(`http://127.0.0.1:${port}/v1/chat/completions`, {
|
|
||||||
method: 'POST',
|
|
||||||
headers: { 'Content-Type': 'application/json' },
|
|
||||||
body: JSON.stringify({
|
|
||||||
model: 'gpt-4.1',
|
|
||||||
messages: [{ role: 'user', content: 'hello' }],
|
|
||||||
}),
|
|
||||||
});
|
|
||||||
expect(chatResponse.status).toBe(401);
|
|
||||||
|
|
||||||
const anthropicResponse = await fetch(`http://127.0.0.1:${port}/v1/messages`, {
|
|
||||||
method: 'POST',
|
|
||||||
headers: {
|
|
||||||
'Content-Type': 'application/json',
|
|
||||||
'anthropic-version': '2023-06-01',
|
|
||||||
},
|
|
||||||
body: JSON.stringify({
|
|
||||||
model: 'claude-sonnet-4.5',
|
|
||||||
max_tokens: 256,
|
|
||||||
messages: [{ role: 'user', content: 'hello' }],
|
|
||||||
}),
|
|
||||||
});
|
|
||||||
expect(anthropicResponse.status).toBe(401);
|
|
||||||
|
|
||||||
// Stop
|
|
||||||
const stopResult = await stopDaemon();
|
|
||||||
expect(stopResult.success).toBe(true);
|
|
||||||
|
|
||||||
// Verify stopped
|
|
||||||
const stillRunning = await isDaemonRunning(port);
|
|
||||||
expect(stillRunning).toBe(false);
|
|
||||||
}, 35000);
|
|
||||||
|
|
||||||
it('returns 404 for unknown routes', async () => {
|
|
||||||
const port = 10000 + Math.floor(Math.random() * 50000);
|
|
||||||
const result = await startDaemon({ port, ghost_mode: true });
|
|
||||||
expect(result.success).toBe(true);
|
|
||||||
|
|
||||||
try {
|
|
||||||
const response = await fetch(`http://127.0.0.1:${port}/unknown`);
|
|
||||||
expect(response.status).toBe(404);
|
|
||||||
} finally {
|
|
||||||
await stopDaemon();
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
it('returns 401 when credentials are expired', async () => {
|
|
||||||
const port = 10000 + Math.floor(Math.random() * 50000);
|
|
||||||
const expiredAt = new Date(Date.now() - 26 * 60 * 60 * 1000).toISOString();
|
|
||||||
|
|
||||||
saveCredentials({
|
|
||||||
accessToken: 'a'.repeat(60),
|
|
||||||
machineId: '1234567890abcdef1234567890abcdef',
|
|
||||||
authMethod: 'manual',
|
|
||||||
importedAt: expiredAt,
|
|
||||||
});
|
|
||||||
|
|
||||||
const result = await startDaemon({ port, ghost_mode: true });
|
|
||||||
expect(result.success).toBe(true);
|
|
||||||
|
|
||||||
try {
|
|
||||||
const response = await fetch(`http://127.0.0.1:${port}/v1/chat/completions`, {
|
|
||||||
method: 'POST',
|
|
||||||
headers: { 'Content-Type': 'application/json' },
|
|
||||||
body: JSON.stringify({
|
|
||||||
model: 'gpt-4.1',
|
|
||||||
messages: [{ role: 'user', content: 'hello' }],
|
|
||||||
}),
|
|
||||||
});
|
|
||||||
|
|
||||||
expect(response.status).toBe(401);
|
|
||||||
const body = (await response.json()) as { error?: { message?: string } };
|
|
||||||
expect(body.error?.message).toContain('expired');
|
|
||||||
} finally {
|
|
||||||
await stopDaemon();
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
it('validates invalid JSON, invalid message schema, and oversized body', async () => {
|
|
||||||
const port = 10000 + Math.floor(Math.random() * 50000);
|
|
||||||
const result = await startDaemon({ port, ghost_mode: true });
|
|
||||||
expect(result.success).toBe(true);
|
|
||||||
|
|
||||||
try {
|
|
||||||
const invalidJson = await fetch(`http://127.0.0.1:${port}/v1/chat/completions`, {
|
|
||||||
method: 'POST',
|
|
||||||
headers: { 'Content-Type': 'application/json' },
|
|
||||||
body: '{invalid-json',
|
|
||||||
});
|
|
||||||
expect(invalidJson.status).toBe(400);
|
|
||||||
|
|
||||||
const invalidSchema = await fetch(`http://127.0.0.1:${port}/v1/chat/completions`, {
|
|
||||||
method: 'POST',
|
|
||||||
headers: { 'Content-Type': 'application/json' },
|
|
||||||
body: JSON.stringify({
|
|
||||||
model: 'gpt-4.1',
|
|
||||||
messages: { role: 'user', content: 'hello' },
|
|
||||||
}),
|
|
||||||
});
|
|
||||||
expect(invalidSchema.status).toBe(400);
|
|
||||||
|
|
||||||
const invalidAnthropic = await fetch(`http://127.0.0.1:${port}/v1/messages`, {
|
|
||||||
method: 'POST',
|
|
||||||
headers: {
|
|
||||||
'Content-Type': 'application/json',
|
|
||||||
'anthropic-version': '2023-06-01',
|
|
||||||
},
|
|
||||||
body: JSON.stringify({
|
|
||||||
model: 'claude-sonnet-4.5',
|
|
||||||
max_tokens: 256,
|
|
||||||
messages: [{ role: 'user', content: [{ type: 'image' }] }],
|
|
||||||
}),
|
|
||||||
});
|
|
||||||
expect(invalidAnthropic.status).toBe(400);
|
|
||||||
|
|
||||||
const oversized = await fetch(`http://127.0.0.1:${port}/v1/chat/completions`, {
|
|
||||||
method: 'POST',
|
|
||||||
headers: { 'Content-Type': 'application/json' },
|
|
||||||
body: JSON.stringify({
|
|
||||||
model: 'gpt-4.1',
|
|
||||||
messages: [
|
|
||||||
{
|
|
||||||
role: 'user',
|
|
||||||
content: 'x'.repeat(10 * 1024 * 1024 + 1024),
|
|
||||||
},
|
|
||||||
],
|
|
||||||
}),
|
|
||||||
});
|
|
||||||
expect(oversized.status).toBe(413);
|
|
||||||
} finally {
|
|
||||||
await stopDaemon();
|
|
||||||
}
|
|
||||||
});
|
|
||||||
});
|
});
|
||||||
|
|
||||||
describe('isDaemonRunning', () => {
|
describe('isDaemonRunning', () => {
|
||||||
|
|||||||
Reference in New Issue
Block a user