Method run

apps/wallet/src/workers/notifications.worker.ts:119–157

()

  }

  private async run(): Promise<void> {
    if (!this.enabled || this.loading) {
      return;
    }

    try {
      this.loading = true;
      await icAgent.loadIdentity();

      const notifications = await this.stationService.listUnreadNotifications(
        this.lastNotificationDate ?? undefined,
        this.lastNotificationId ?? undefined,
      );
      const lastNotification = notifications?.[0];
      this.lastNotificationId = lastNotification?.id ?? null;
      if (lastNotification) {
        this.lastNotificationDate = new Date(lastNotification.created_at);
      }

      postMessage({
        type: 'notifications',
        data: {
          notifications,
        },
      } as NotificationsWorkerResponseMessage);
    } catch (err) {
      logger.error(`Failed to fetch notifications`, { err });

      postMessage({
        type: 'error',
        data: {
          code: 'ERR_FETCH_NOTIFICATIONS',
          msg: `Failed to fetch notifications: ${err}`,
        },
      } as NotificationsWorkerResponseMessage);
    } finally {
      this.loading = false;
    }
  }
}

NotificationsWorkerImpl.register();