Something went wrong. Try again.
[READ-ONLY] Mirror of https://github.com/improsocial/impro
An extensible Bluesky client for web impro.social
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687import { Poller, wait } from "/js/utils.js";import { Signal } from "/js/signals.js";
const POLLING_INTERVAL_SECONDS = 10;const OPEN_CONVO_CONFIRM_DELAY_MS = 7000;
export class ChatNotificationService { constructor(api) { this.api = api; this.$numNotifications = new Signal.State(null); this.$numUnreadRequestConvos = new Signal.State(0); this._optimisticallyReadIds = new Set(); this._lastServerTotal = 0; this._openConvoId = null; this.poller = new Poller( () => this.fetchNumNotifications(), POLLING_INTERVAL_SECONDS * 1000, ); }
start() { this.poller.start(); // Restart the poller on page visible to fetch notifications immediately const handleVisibilityChange = () => { if (document.visibilityState === "visible") this.poller.restart(); }; document.addEventListener("visibilitychange", handleVisibilityChange); return () => { this.poller.stop(); document.removeEventListener("visibilitychange", handleVisibilityChange); }; }
setOpenConvoId(convoId) { this._openConvoId = convoId; }
clearOpenConvoId(convoId) { if (this._openConvoId === convoId) { this._openConvoId = null; } }
async fetchNumNotifications() { let counts = await this.api.getChatUnreadCounts(); // If a chat it currently open, wait for it to be marked read before updating the count if (this._openConvoId && getServerTotal(counts) > this._lastServerTotal) { await wait(OPEN_CONVO_CONFIRM_DELAY_MS); counts = await this.api.getChatUnreadCounts(); } const { unreadRequestConvos = 0 } = counts; this.$numUnreadRequestConvos.set(unreadRequestConvos); const serverTotal = getServerTotal(counts); // The server total dropped by `delta` since the last poll — that many // optimistic reads have been confirmed, so stop subtracting them. const delta = Math.max(0, this._lastServerTotal - serverTotal); for (const id of [...this._optimisticallyReadIds].slice(0, delta)) { this._optimisticallyReadIds.delete(id); } this._lastServerTotal = serverTotal; const adjusted = Math.max( 0, serverTotal - this._optimisticallyReadIds.size, ); this.$numNotifications.set(adjusted); }
markNotificationsAsReadForConvo(convoId, { isRequest = false } = {}) { if (this._optimisticallyReadIds.has(convoId)) return; this._optimisticallyReadIds.add(convoId); const count = this.$numNotifications.get(); if (count > 0) { this.$numNotifications.set(count - 1); } if (isRequest) { const requestCount = this.$numUnreadRequestConvos.get(); if (requestCount > 0) { this.$numUnreadRequestConvos.set(requestCount - 1); } } }}
function getServerTotal({ unreadAcceptedConvos = 0, unreadRequestConvos = 0 }) { return unreadAcceptedConvos + unreadRequestConvos;}