import type { Accessor, JSX } from 'solid-js' import { createContext, createEffect, createMemo, createSignal, useContext } from 'solid-js' import { createStore } from 'solid-js/store' import { Portal } from 'solid-js/web' import { ShowIfAuthenticated } from '../components/_shared/ShowIfAuthenticated' import { NotificationsPanel } from '../components/NotificationsPanel' import { Notification } from '../graphql/types.gen' import { apiClient } from '../utils/apiClient' import { apiBaseUrl } from '../utils/config' import SSEService, { EventData } from '../utils/sseService' import { useSession } from './session' type NotificationsContextType = { notificationEntities: Record unreadNotificationsCount: Accessor sortedNotifications: Accessor loadedNotificationsCount: Accessor totalNotificationsCount: Accessor actions: { showNotificationsPanel: () => void hideNotificationsPanel: () => void markNotificationAsRead: (notification: Notification) => Promise markAllNotificationsAsRead: () => Promise loadNotifications: (options: { limit: number; offset: number }) => Promise } } export const PAGE_SIZE = 20 const NotificationsContext = createContext() export function useNotifications() { return useContext(NotificationsContext) } const sseService = new SSEService() export const NotificationsProvider = (props: { children: JSX.Element }) => { const [isNotificationsPanelOpen, setIsNotificationsPanelOpen] = createSignal(false) const [unreadNotificationsCount, setUnreadNotificationsCount] = createSignal(0) const [totalNotificationsCount, setTotalNotificationsCount] = createSignal(0) const { isAuthenticated, user } = useSession() const [notificationEntities, setNotificationEntities] = createStore>({}) const loadNotifications = async (options: { limit: number; offset?: number }) => { const { notifications, totalUnreadCount, totalCount } = await apiClient.getNotifications(options) const newNotificationEntities = notifications.reduce((acc, notification) => { acc[notification.id] = notification return acc }, {}) setTotalNotificationsCount(totalCount) setUnreadNotificationsCount(totalUnreadCount) setNotificationEntities(newNotificationEntities) return notifications } const sortedNotifications = createMemo(() => { return Object.values(notificationEntities).sort( (a, b) => new Date(b.createdAt).getTime() - new Date(a.createdAt).getTime(), ) }) const loadedNotificationsCount = createMemo(() => Object.keys(notificationEntities).length) createEffect(() => { if (isAuthenticated()) { sseService.connect(`${apiBaseUrl}/subscribe/${user().id}`) sseService.subscribeToEvent('message', (data: EventData) => { if (data.type === 'newNotifications') { loadNotifications({ limit: Math.max(PAGE_SIZE, loadedNotificationsCount()) }) } else { console.error(`[NotificationsProvider] unknown message type: ${JSON.stringify(data)}`) } }) } else { sseService.disconnect() } }) const markNotificationAsRead = async (notification: Notification) => { await apiClient.markNotificationAsRead(notification.id) } const markAllNotificationsAsRead = async () => { await apiClient.markAllNotificationsAsRead() loadNotifications({ limit: loadedNotificationsCount() }) } const showNotificationsPanel = () => { setIsNotificationsPanelOpen(true) } const hideNotificationsPanel = () => { setIsNotificationsPanelOpen(false) } const actions = { showNotificationsPanel, hideNotificationsPanel, markNotificationAsRead, markAllNotificationsAsRead, loadNotifications, } const value: NotificationsContextType = { notificationEntities, sortedNotifications, unreadNotificationsCount, loadedNotificationsCount, totalNotificationsCount, actions, } const handleNotificationPanelClose = () => { setIsNotificationsPanelOpen(false) } return ( {props.children} ) }