43 lines
1.4 KiB
TypeScript
43 lines
1.4 KiB
TypeScript
import assert from 'node:assert/strict';
|
|
import test from 'node:test';
|
|
|
|
import { resolveWithReadModelSnapshotFallback } from '../src/utils/readModelDeltaRecovery.ts';
|
|
|
|
void test('retries any local delta application failure once with a forced snapshot', async () => {
|
|
const requests: boolean[] = [];
|
|
const result = await resolveWithReadModelSnapshotFallback({
|
|
request: async (forceSnapshot) => {
|
|
requests.push(forceSnapshot);
|
|
return forceSnapshot ? { kind: 'snapshot', value: 25 } : { kind: 'patch', value: 20 };
|
|
},
|
|
resolve: (response) => {
|
|
if (response.kind === 'patch') {
|
|
throw new DOMException('[object Object] could not be cloned.', 'DataCloneError');
|
|
}
|
|
return response.value;
|
|
},
|
|
});
|
|
|
|
assert.equal(result, 25);
|
|
assert.deepEqual(requests, [false, true]);
|
|
});
|
|
|
|
void test('does not retry a forced snapshot application failure', async () => {
|
|
const requests: boolean[] = [];
|
|
|
|
await assert.rejects(
|
|
resolveWithReadModelSnapshotFallback({
|
|
forceSnapshot: true,
|
|
request: async (forceSnapshot) => {
|
|
requests.push(forceSnapshot);
|
|
return { kind: 'snapshot' };
|
|
},
|
|
resolve: () => {
|
|
throw new Error('snapshot failure');
|
|
},
|
|
}),
|
|
/snapshot failure/u
|
|
);
|
|
assert.deepEqual(requests, [true]);
|
|
});
|