71 lines
2.4 KiB
TypeScript
71 lines
2.4 KiB
TypeScript
import { mkdtemp, readFile } from 'node:fs/promises';
|
|
import { tmpdir } from 'node:os';
|
|
import { join } from 'node:path';
|
|
import { describe, expect, it } from 'vitest';
|
|
import { PlanningJournal } from './planning-journal.js';
|
|
|
|
describe('PlanningJournal', () => {
|
|
it('appends events with monotonic source sequence numbers', async () => {
|
|
const dir = await mkdtemp(join(tmpdir(), 'gsd-journal-'));
|
|
const journal = new PlanningJournal({ projectDir: dir, sourceId: 'daemon-1', runId: 'run-1' });
|
|
|
|
const first = await journal.append({
|
|
projectId: 'project-1',
|
|
type: 'plan.next',
|
|
actor: { type: 'agent', id: 'agent-1' },
|
|
payload: { itemId: 'item-1' },
|
|
idempotencyKey: 'next-1',
|
|
});
|
|
const second = await journal.append({
|
|
projectId: 'project-1',
|
|
type: 'plan.done',
|
|
actor: { type: 'agent', id: 'agent-1' },
|
|
payload: { itemId: 'item-1' },
|
|
idempotencyKey: 'done-1',
|
|
});
|
|
|
|
expect(first.source.seq).toBe(1);
|
|
expect(second.source.seq).toBe(2);
|
|
expect(await journal.readAll()).toHaveLength(2);
|
|
});
|
|
|
|
it('replays an existing event for duplicate idempotency keys', async () => {
|
|
const dir = await mkdtemp(join(tmpdir(), 'gsd-journal-'));
|
|
const journal = new PlanningJournal({ projectDir: dir, sourceId: 'sdk-1', runId: 'run-1' });
|
|
|
|
const first = await journal.append({
|
|
projectId: 'project-1',
|
|
type: 'plan.checkpoint',
|
|
actor: { type: 'agent', id: 'agent-1' },
|
|
payload: { summary: 'Progress' },
|
|
idempotencyKey: 'checkpoint-1',
|
|
});
|
|
const replay = await journal.append({
|
|
projectId: 'project-1',
|
|
type: 'plan.checkpoint',
|
|
actor: { type: 'agent', id: 'agent-1' },
|
|
payload: { summary: 'Progress' },
|
|
idempotencyKey: 'checkpoint-1',
|
|
});
|
|
|
|
expect(replay.id).toBe(first.id);
|
|
expect(await journal.readAll()).toHaveLength(1);
|
|
});
|
|
|
|
it('writes jsonl under .gsd/journal.jsonl', async () => {
|
|
const dir = await mkdtemp(join(tmpdir(), 'gsd-journal-'));
|
|
const journal = new PlanningJournal({ projectDir: dir, sourceId: 'sdk-1', runId: 'run-1' });
|
|
await journal.append({
|
|
projectId: 'project-1',
|
|
type: 'plan.status',
|
|
actor: { type: 'agent', id: 'agent-1' },
|
|
payload: {},
|
|
idempotencyKey: 'status-1',
|
|
});
|
|
|
|
const raw = await readFile(join(dir, '.gsd', 'journal.jsonl'), 'utf8');
|
|
expect(raw.trim().split('\n')).toHaveLength(1);
|
|
expect(JSON.parse(raw).schemaVersion).toBe(1);
|
|
});
|
|
});
|