schedule for federated only

wireapp · May 11, 2023 · 943806c · 943806c
1 parent 5459a62
commit 943806c
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 1 deletion.
diff --git a/src/script/conversation/ConversationRepository.test.ts b/src/script/conversation/ConversationRepository.test.ts
@@ -1419,7 +1419,20 @@ describe('ConversationRepository', () => {
       jest.useRealTimers();
     });
 
-    it('should call loadMissingConversations & refreshAllConversationsUnavailableParticipants every 3 hours', async () => {
+    it('should not call loadMissingConversations & refreshAllConversationsUnavailableParticipants for non federated envs', async () => {
+      const conversationRepo = await testFactory.exposeConversationActors();
+
+      spyOn(testFactory.conversation_repository!, 'loadMissingConversations').and.callThrough();
+      spyOn(testFactory.conversation_repository!, 'refreshAllConversationsUnavailableParticipants').and.callThrough();
+
+      expect(conversationRepo.loadMissingConversations).not.toHaveBeenCalled();
+      expect(conversationRepo.refreshAllConversationsUnavailableParticipants).not.toHaveBeenCalled();
+    });
+
+    it('should call loadMissingConversations & refreshAllConversationsUnavailableParticipants every 3 hours for federated envs', async () => {
+      Object.defineProperty(container.resolve(Core).backendFeatures, 'isFederated', {
+        get: jest.fn(() => true),
+      });
       const conversationRepo = await testFactory.exposeConversationActors();
 
       spyOn(testFactory.conversation_repository!, 'loadMissingConversations').and.callThrough();

diff --git a/src/script/conversation/ConversationRepository.ts b/src/script/conversation/ConversationRepository.ts
@@ -484,6 +484,9 @@ export class ConversationRepository {
    * @Note Federation only
    */
   private readonly scheduleMissingUsersAndConversationsMetadataRefresh = () => {
+    if (!this.core.backendFeatures.isFederated) {
+      return;
+    }
     window.setInterval(async () => {
       try {
         await this.loadMissingConversations();