Method updateBadgeCount

native/push/push-handler.react.js:323–422

()

  }

  async updateBadgeCount() {
    const curThinUnreadCounts = this.props.thinThreadsUnreadCount;
    const curConnections = this.props.connection;

    const currentUnreadThickThreads = this.props.unreadThickThreadIDs;
    const isTunnelbrokerAuthorized =
      this.props.tunnelbrokerSocketState.connected &&
      this.props.tunnelbrokerSocketState.isAuthorized;

    const currentFarcasterUnreadCount = this.props.farcasterUnreadCount;

    const notifStorageUpdates: Array<{
      +id: string,
      +unreadCount: number,
    }> = [];
    const notifsStorageQueries: Array<string> = [];

    for (const keyserverID in curThinUnreadCounts) {
      if (curConnections[keyserverID]?.status !== 'connected') {
        notifsStorageQueries.push(keyserverID);
        continue;
      }

      notifStorageUpdates.push({
        id: keyserverID,
        unreadCount: curThinUnreadCounts[keyserverID],
      });
    }

    let queriedKeyserverData: $ReadOnlyArray<{
      +id: string,
      +unreadCount: number,
    }> = [];

    const handleUnreadThickThreadIDsInNotifsStorage = (async () => {
      if (isTunnelbrokerAuthorized) {
        await commCoreModule.updateUnreadThickThreadsInNotifsStorage(
          currentUnreadThickThreads,
        );
        return currentUnreadThickThreads;
      }
      return await commCoreModule.getUnreadThickThreadIDsFromNotifsStorage();
    })();

    const handleUnreadFarcasterInNotifsStorage = (async () => {
      if (isTunnelbrokerAuthorized) {
        const farcasterEntry = {
          id: 'FARCASTER',
          unreadCount: currentFarcasterUnreadCount,
        };
        await commCoreModule.updateDataInNotifStorage([farcasterEntry]);
        return currentFarcasterUnreadCount;
      }
      const farcasterData = await commCoreModule.getDataFromNotifStorage([
        'FARCASTER',
      ]);
      if (farcasterData.length > 0) {
        return farcasterData[0].unreadCount;