lentil/rhizome-node
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

minor stuff

Browse Source
This commit is contained in:
Ladd 2025-01-02 21:26:13 -06:00
parent f1fcd97fe2
commit b5e1acf4e3
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/collection-abstract.ts
View File

@ -20,7 +20,7 @@ export abstract class Collection<View> {
abstract initializeView(): void; abstract initializeView(): void;
abstract resolve(id: string): ResolvedViewOne | undefined; abstract resolve(id: DomainEntityID): ResolvedViewOne | undefined;
rhizomeConnect(rhizomeNode: RhizomeNode) { rhizomeConnect(rhizomeNode: RhizomeNode) {
this.rhizomeNode = rhizomeNode; this.rhizomeNode = rhizomeNode;
@ -36,7 +36,6 @@ export abstract class Collection<View> {
this.eventStream.emit("update", res); this.eventStream.emit("update", res);
}); });
// TODO: Fix this
rhizomeNode.httpServer.httpApi.serveCollection<View>(this); rhizomeNode.httpServer.httpApi.serveCollection<View>(this);
debug(`[${this.rhizomeNode.config.peerId}]`, `Connected ${this.name} to rhizome`); debug(`[${this.rhizomeNode.config.peerId}]`, `Connected ${this.name} to rhizome`);

2
src/delta.ts
View File

@ -17,7 +17,7 @@ type PointerV1 = {
export type Scalar = string | number | null; export type Scalar = string | number | null;
export type Reference = { export type Reference = {
[key: PropertyID]: DomainEntityID [key: DomainEntityID]: PropertyID
}; };
export type PointersV2 = { export type PointersV2 = {

1
src/lossy.ts
View File

@ -23,6 +23,7 @@ export abstract class Lossy<Accumulator, Result> {
this.lossless.eventStream.on("updated", (id, deltaIds) => { this.lossless.eventStream.on("updated", (id, deltaIds) => {
debug(`[${this.lossless.rhizomeNode.config.peerId}] entity ${id} updated, deltaIds:`, debug(`[${this.lossless.rhizomeNode.config.peerId}] entity ${id} updated, deltaIds:`,
JSON.stringify(deltaIds)); JSON.stringify(deltaIds));
this.ingestUpdate(id, deltaIds); this.ingestUpdate(id, deltaIds);
}); });
} }