feat:filter csrs on replicated event

packages/backend/src/nest/storage/storage.service.ts

@@ -9,6 +9,7 @@ import {
   verifyUserCert,
   parseCertificationRequest,
   getReqFieldValue,
+  loadCSR,
 } from '@quiet/identity'
 import type { IPFS } from 'ipfs-core'
 import OrbitDB from 'orbit-db'
@@ -400,8 +401,26 @@ export class StorageService extends EventEmitter {
     this.certificatesRequests.events.on('replicated', async () => {
       this.logger('REPLICATED: CSRs')
       const allCsrs = this.getAllEventLogEntries(this.certificatesRequests)
+
+      const filteredCsrsMap: Map<string, string> = new Map()
+
+      await Promise.all(
+        allCsrs.map(async csr => {
+          const parsedCsr = await loadCSR(csr)
+          const pubKey = keyFromCertificate(parsedCsr)
+
+          if (filteredCsrsMap.has(pubKey)) {
+            filteredCsrsMap.delete(pubKey)
+          }
+
+          filteredCsrsMap.set(pubKey, csr)
+        })
+      )
+
+      const filteredCsrsArr = [...filteredCsrsMap.values()]
+
       const allCertificates = this.getAllEventLogEntries(this.certificates)
-      this.emit(StorageEvents.REPLICATED_CSR, { csrs: allCsrs, certificates: allCertificates })
+      this.emit(StorageEvents.REPLICATED_CSR, { csrs: filteredCsrsArr, certificates: allCertificates })
       await this.updatePeersList()
     })
     this.certificatesRequests.events.on('write', async (_address, entry) => {