john
33 lines
1.1 KiB
JavaScript
33 lines
1.1 KiB
JavaScript
import assert from 'node:assert/strict';
|
|
import test from 'node:test';
|
|
import {
|
|
createOrchestratorCheckpoint,
|
|
orchestratorCheckpointInternals,
|
|
} from './checkpoint.mjs';
|
|
|
|
test('checkpoint defaults to durable PostgreSQL and fails closed without a URL', async () => {
|
|
await assert.rejects(
|
|
createOrchestratorCheckpoint({ mode: undefined, connectionString: '' }),
|
|
(error) => error.code === 'ORCHESTRATOR_DATABASE_URL_REQUIRED',
|
|
);
|
|
});
|
|
|
|
test('memory checkpoint is explicitly non-durable', async () => {
|
|
const checkpoint = await createOrchestratorCheckpoint({ mode: 'memory' });
|
|
assert.equal(checkpoint.kind, 'memory');
|
|
assert.equal(checkpoint.durable, false);
|
|
assert.equal(typeof checkpoint.checkpointer.getTuple, 'function');
|
|
await checkpoint.close();
|
|
});
|
|
|
|
test('checkpoint schema accepts identifiers and rejects SQL fragments', () => {
|
|
assert.equal(
|
|
orchestratorCheckpointInternals.normalizeSchema('memind_orchestrator_v2'),
|
|
'memind_orchestrator_v2',
|
|
);
|
|
assert.throws(
|
|
() => orchestratorCheckpointInternals.normalizeSchema('public; drop schema public'),
|
|
/Invalid orchestrator PostgreSQL schema/,
|
|
);
|
|
});
|