Lentil Hoffman
60ad920b30
- Refactored delta creation in test files to use createDelta() pattern - Replaced direct Delta instantiations with fluent builder API - Updated relationship deltas to use setProperty with proper entity context - Ensured all tests pass with the new delta creation approach This is part of the ongoing effort to standardize on the DeltaBuilder API across the codebase for better consistency and maintainability.
89 lines
2.1 KiB
TypeScript
89 lines
2.1 KiB
TypeScript
import Debug from 'debug';
|
|
import {
|
|
PointerTarget,
|
|
lastValueFromDeltas,
|
|
valueFromCollapsedDelta,
|
|
Lossless,
|
|
LosslessViewOne,
|
|
Lossy,
|
|
RhizomeNode
|
|
} from "../src";
|
|
import { createDelta } from "../src/core/delta-builder";
|
|
const debug = Debug('test:lossy');
|
|
|
|
type Role = {
|
|
actor: PointerTarget,
|
|
film: PointerTarget,
|
|
role: PointerTarget
|
|
};
|
|
|
|
type Summary = {
|
|
roles: Role[];
|
|
};
|
|
|
|
class Summarizer extends Lossy<Summary, Summary> {
|
|
initializer(): Summary {
|
|
return {
|
|
roles: []
|
|
};
|
|
}
|
|
|
|
// TODO: Add more rigor to this example approach to generating a summary.
|
|
// it's really not CRDT, it likely depends on the order of the pointers.
|
|
// TODO: Prove with failing test
|
|
|
|
reducer(acc: Summary, cur: LosslessViewOne): Summary {
|
|
if (cur.referencedAs.includes("role")) {
|
|
const {delta, value: actor} = lastValueFromDeltas("actor", cur.propertyDeltas["actor"]) ?? {};
|
|
if (!delta) throw new Error('expected to find delta');
|
|
if (!actor) throw new Error('expected to find actor');
|
|
const film = valueFromCollapsedDelta("film", delta);
|
|
if (!film) throw new Error('expected to find film');
|
|
acc.roles.push({
|
|
role: cur.id,
|
|
actor,
|
|
film
|
|
});
|
|
}
|
|
|
|
return acc;
|
|
}
|
|
|
|
resolver(acc: Summary): Summary {
|
|
return acc;
|
|
}
|
|
}
|
|
|
|
describe('Lossy', () => {
|
|
describe('use a provided initializer, reducer, and resolver to resolve entity views', () => {
|
|
const node = new RhizomeNode();
|
|
const lossless = new Lossless(node);
|
|
|
|
const lossy = new Summarizer(lossless);
|
|
|
|
beforeAll(() => {
|
|
lossless.ingestDelta(createDelta('a', 'h')
|
|
.addPointer('actor', 'keanu', 'roles')
|
|
.addPointer('role', 'neo', 'actor')
|
|
.addPointer('film', 'the_matrix', 'cast')
|
|
.addPointer('base_salary', 1000000)
|
|
.addPointer('salary_currency', 'usd')
|
|
.buildV1()
|
|
);
|
|
});
|
|
|
|
it('example summary', () => {
|
|
const result = lossy.resolve();
|
|
debug('result', result);
|
|
expect(result).toEqual({
|
|
roles: [{
|
|
film: "the_matrix",
|
|
role: "neo",
|
|
actor: "keanu"
|
|
}]
|
|
});
|
|
});
|
|
});
|
|
|
|
});
|