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