Skip to content

Commit e9428d5

Browse files
committed
fix: schedule only on successful sync
1 parent 676661e commit e9428d5

File tree

2 files changed

+9
-13
lines changed

2 files changed

+9
-13
lines changed

src/channel_manager.ts

Lines changed: 4 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -361,14 +361,10 @@ export class ChannelManager {
361361

362362
if (!this.client.offlineDb.syncManager.syncStatus) {
363363
// FIXME: Should only schedule for true syncStatus, not otherwise
364-
this.client.offlineDb.syncManager.scheduleSyncStatusChangeCallback(
365-
async (syncStatus) => {
366-
console.log('WILL TRY NOW VAL: ', syncStatus);
367-
if (syncStatus) {
368-
await queryChannelsRequest();
369-
}
370-
},
371-
);
364+
this.client.offlineDb.syncManager.scheduleSyncStatusChangeCallback(async () => {
365+
console.log('WILL TRY NOW RUNNING SCHEDULED NOW !');
366+
await queryChannelsRequest();
367+
});
372368
return;
373369
}
374370
// await queryChannelsRequest();

src/offline_support_api.ts

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -881,12 +881,12 @@ export class OfflineDBSyncManager {
881881
this.syncStatus = status;
882882
this.syncStatusListeners.forEach((l) => l(status));
883883

884-
console.log('WILL TRY LISTENERS', this.scheduledSyncStatusCallbacks.length);
885-
const promises = this.scheduledSyncStatusCallbacks.map((cb) => cb(status));
886-
await Promise.all(promises);
887-
console.log('DONE LISTENERS !');
884+
if (status) {
885+
const promises = this.scheduledSyncStatusCallbacks.map((cb) => cb(status));
886+
await Promise.all(promises);
888887

889-
this.scheduledSyncStatusCallbacks = [];
888+
this.scheduledSyncStatusCallbacks = [];
889+
}
890890
};
891891

892892
private handleEventToSyncDB = async (event: Event, flush?: boolean) => {

0 commit comments

Comments
 (0)