martin/databag
1
0
Fork 0
mirror of https://github.com/balzack/databag.git synced 2025-05-05 07:55:15 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

removed debug print

Browse Source
This commit is contained in:
balzack 2025-01-05 22:57:32 -08:00
parent c5de88bdad
commit 970057351b
1 changed files with 0 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
app/sdk/src/stream.ts
View File

@ -120,7 +120,6 @@ export class StreamModule {
private async sync(): Promise<void> { private async sync(): Promise<void> {
if (!this.syncing) { if (!this.syncing) {
console.log("--- SYNCING!");
this.syncing = true; this.syncing = true;
const { guid, node, secure, token, channelTypes } = this; const { guid, node, secure, token, channelTypes } = this;
while ((this.unsealAll || this.nextRevision) && !this.closing) { while ((this.unsealAll || this.nextRevision) && !this.closing) {
@ -135,7 +134,6 @@ console.log("--- SYNCING!");
const entry = await this.getChannelEntry(id); const entry = await this.getChannelEntry(id);
if (detailRevision !== entry.item.detail.revision) { if (detailRevision !== entry.item.detail.revision) {
console.log("--- SYNCING: detail");
const detail = channelDetail ? channelDetail : await getChannelDetail(node, secure, token, id); const detail = channelDetail ? channelDetail : await getChannelDetail(node, secure, token, id);
entry.item.detail = { entry.item.detail = {
revision: detailRevision, revision: detailRevision,
@ -176,7 +174,6 @@ console.log("--- SYNCING: detail");
} }
if (topicRevision !== entry.item.summary.revision) { if (topicRevision !== entry.item.summary.revision) {
console.log("--- SYNCING: summary");
const summary = channelSummary ? channelSummary : await getChannelSummary(node, secure, token, id); const summary = channelSummary ? channelSummary : await getChannelSummary(node, secure, token, id);
entry.item.summary = { entry.item.summary = {
revision: topicRevision, revision: topicRevision,
@ -204,7 +201,6 @@ console.log("--- SYNCING: summary");
await this.focus.setRevision(null, id, topicRevision); await this.focus.setRevision(null, id, topicRevision);
} }
} else { } else {
console.log("--- SYNCING: delete");
this.channelEntries.delete(id); this.channelEntries.delete(id);
if (this.focus) { if (this.focus) {
this.focus.disconnect(null, id); this.focus.disconnect(null, id);
@ -231,7 +227,6 @@ console.log("--- SYNCING: delete");
} }
if (this.unsealAll) { if (this.unsealAll) {
console.log("--- SYNCING: unseal");
for (const [channelId, entry] of this.channelEntries.entries()) { for (const [channelId, entry] of this.channelEntries.entries()) {
try { try {
const { item } = entry; const { item } = entry;
@ -256,7 +251,6 @@ console.log("--- SYNCING: unseal");
await this.store.setMarker(this.guid, 'first_sync_complete', 'stream', ''); await this.store.setMarker(this.guid, 'first_sync_complete', 'stream', '');
} }
this.syncing = false; this.syncing = false;
console.log("--- SYNCING: DONE");
} }
} }