From 3add6c9e7b2d8315e4e5359a6011bcc6aaa7be8f Mon Sep 17 00:00:00 2001
From: Jonathan Poltak Samosir <jonathan.samosir@gmail.com>
Date: Sat, 6 Apr 2024 12:49:51 +0700
Subject: [PATCH] Set sync DL to trigger on successful login

- This was prev managed by the sync FB backend, though not enough control with it triggering on every single auth state change
---
 external/@worldbrain/memex-common      | 2 +-
 src/background-mv3.ts                  | 3 +++
 src/personal-cloud/background/index.ts | 5 ++++-
 3 files changed, 8 insertions(+), 2 deletions(-)

diff --git a/external/@worldbrain/memex-common b/external/@worldbrain/memex-common
index 838c7d4b58..32bb5e2ddd 160000
--- a/external/@worldbrain/memex-common
+++ b/external/@worldbrain/memex-common
@@ -1 +1 @@
-Subproject commit 838c7d4b5880bd74e6d9bb9f0d57b40f2698d632
+Subproject commit 32bb5e2ddd80b787ef183fd44d07f0d7a66efe56
diff --git a/src/background-mv3.ts b/src/background-mv3.ts
index 8790ffd4f7..d94214f94b 100644
--- a/src/background-mv3.ts
+++ b/src/background-mv3.ts
@@ -147,6 +147,9 @@ async function main() {
             process.env.NODE_ENV === 'production' ? 'production' : 'staging',
     })
     pushMessagingClient.bgModules = backgroundModules
+    authServices.auth.events.on('loginSuccess', () => {
+        backgroundModules.personalCloud.triggerSyncContinuation()
+    })
 
     registerBackgroundModuleCollections({
         storageManager,
diff --git a/src/personal-cloud/background/index.ts b/src/personal-cloud/background/index.ts
index b36d7bdbc7..a2b7ceba3c 100644
--- a/src/personal-cloud/background/index.ts
+++ b/src/personal-cloud/background/index.ts
@@ -246,7 +246,10 @@ export class PersonalCloudBackground {
     async integrateContinuously() {
         const { backend, settingStore } = this.options
         try {
-            for await (const { batch, lastSeen } of backend.streamUpdates()) {
+            for await (const { batch, lastSeen } of backend.streamUpdates({
+                mode: 'continuous-invocation',
+                skipInvocationOnUserChange: true,
+            })) {
                 try {
                     await keepWorkerAlive(
                         (async () => {