Feat/2805 Log Entry Fanout Ingestion (#3041)

* ingest entries from qss fanout

* ingest entry correctly and prevent sending multiple messages for the same entry

* setup just one listener

* add e2e test

* fix backend unit tests

* fix state manager tests

* update changelog

* add waits in oneclient to allow app to fully open

* update submodule pointer

* add delay in test

* add additional tor init interval logging to debug multiple clients test fail

* make sure starting panel doesn't occlude after startup

* replace startPanel waitForLoadingToComplete with more suitable test for DOM removal

* avoid crashing renderer if watch is still active

* close join community modal when custom protocol finishes

* wait for starting panel to be either invisible OR not in the DOM

* fix some crashes and e2e test weirdest

* fix hangups

* fix back compat test

* make address required

* allow only one attempts for quicker feedback

* better type safety and address selection for dialing and invites

* extend ping intervals and timeouts

* bring back normal attempt limit

Author: adrastaea

.github/workflows/e2e-linux.yml

@@ -92,5 +92,5 @@ jobs:
         uses: nick-fields/retry@14672906e672a08bd6eeb15720e9ed3ce869cdd4 # v2.9.0
         with:
           timeout_minutes: 25
-          max_attempts: 1
+          max_attempts: 3
           command: cd packages/e2e-tests && npm run test invitationLink.test.ts

3rd-party/qss

@@ -6,6 +6,7 @@
 
 * Adds hcaptcha verification for protected QSS actions [#2908](https://github.com/TryQuiet/quiet/issues/2908)
 * Add ability to adjust image/file auto-download size threshold [#3019](https://github.com/TryQuiet/quiet/pull/3019)
+* Messages can now be relayed using QSS [#2805](https://github.com/TryQuiet/quiet/issues/2805)
 
 ### Fixes
 

CHANGELOG.md

@@ -52,7 +52,7 @@ import {
   SetUserProfileResponse,
 } from '@quiet/types'
 import { CONFIG_OPTIONS, QSS_ALLOWED, QSS_ENDPOINT, SERVER_IO_PROVIDER, SOCKS_PROXY_AGENT } from '../const'
-import { Libp2pService } from '../libp2p/libp2p.service'
+import { Libp2pService, Libp2pState } from '../libp2p/libp2p.service'
 import { CreatedLibp2pPeerId, Libp2pEvents, Libp2pNodeParams, Libp2pPeerInfo } from '../libp2p/libp2p.types'
 import { LocalDbService } from '../local-db/local-db.service'
 import { LocalDBKeys } from '../local-db/local-db.types'
@@ -250,8 +250,7 @@ export class ConnectionsManagerService extends EventEmitter implements OnModuleI
     this.logger.info('Pausing!')
     await this.closeSocket()
     this.logger.info('Pausing libp2pService!')
-    this.peerInfo = await this.libp2pService?.pause()
-    this.logger.info('Found the following peer info on pause: ', this.peerInfo)
+    await this.libp2pService?.pause()
   }
 
   public async resume() {
@@ -794,6 +793,26 @@ export class ConnectionsManagerService extends EventEmitter implements OnModuleI
         callback(await this.storageService?.addUserProfile(payload.profile))
       }
     )
+
+    this.socketService.on(SocketActions.TOGGLE_P2P, async (payload: boolean, callback: (response: boolean) => void) => {
+      try {
+        if (payload) {
+          await this.libp2pService.resume()
+          await this.storageService.startSync()
+        } else {
+          await this.libp2pService.pause()
+          await this.storageService.stopSync()
+        }
+      } catch (e) {
+        this.logger.error('Error toggling libp2p service', e)
+      }
+
+      if (this.libp2pService.state === Libp2pState.Started) {
+        callback(true)
+      } else {
+        callback(false)
+      }
+    })
   }
 
   /**

packages/backend/src/nest/connections-manager/connections-manager.service.ts

@@ -426,9 +426,10 @@ export class Libp2pAuth {
       return
     }
 
+    let id: string
     try {
       this.sigChainService.getActiveChain()
-      this.sigChainService.team
+      id = this.sigChainService.team.id
     } catch (e) {
       this.joinStatus = JoinStatus.NOT_STARTED
       return
@@ -440,7 +441,7 @@ export class Libp2pAuth {
      * information in their chain yet resulting in an invalid device error)
      */
     const oldJoinStatus = this.joinStatus
-    if (this.joinedViaQSS(this.sigChainService.team.id)) {
+    if (this.joinedViaQSS(id)) {
       this.joinStatus = JoinStatus.PENDING_MEMBER
     } else {
       this.joinStatus = JoinStatus.PENDING