import './notifications.css'; import { Fragment } from 'preact'; import { memo } from 'preact/compat'; import { useCallback, useEffect, useRef, useState } from 'preact/hooks'; import { useHotkeys } from 'react-hotkeys-hook'; import { InView } from 'react-intersection-observer'; import { useSearchParams } from 'react-router-dom'; import { useSnapshot } from 'valtio'; import { subscribeKey } from 'valtio/utils'; import AccountBlock from '../components/account-block'; import FollowRequestButtons from '../components/follow-request-buttons'; import Icon from '../components/icon'; import Link from '../components/link'; import Loader from '../components/loader'; import Modal from '../components/modal'; import NavMenu from '../components/nav-menu'; import Notification from '../components/notification'; import Status from '../components/status'; import { api } from '../utils/api'; import enhanceContent from '../utils/enhance-content'; import groupNotifications from '../utils/group-notifications'; import handleContentLinks from '../utils/handle-content-links'; import niceDateTime from '../utils/nice-date-time'; import { getRegistration } from '../utils/push-notifications'; import shortenNumber from '../utils/shorten-number'; import showToast from '../utils/show-toast'; import states, { saveStatus } from '../utils/states'; import { getCurrentInstance } from '../utils/store-utils'; import supports from '../utils/supports'; import usePageVisibility from '../utils/usePageVisibility'; import useScroll from '../utils/useScroll'; import useTitle from '../utils/useTitle'; const LIMIT = 30; // 30 is the maximum limit :( const emptySearchParams = new URLSearchParams(); const scrollIntoViewOptions = { block: 'center', inline: 'center', behavior: 'smooth', }; function Notifications({ columnMode }) { useTitle('Notifications', '/notifications'); const { masto, instance } = api(); const snapStates = useSnapshot(states); const [uiState, setUIState] = useState('default'); const [searchParams] = columnMode ? [emptySearchParams] : useSearchParams(); const notificationID = searchParams.get('id'); const notificationAccessToken = searchParams.get('access_token'); const [showMore, setShowMore] = useState(false); const [onlyMentions, setOnlyMentions] = useState(false); const scrollableRef = useRef(); const { nearReachEnd, scrollDirection, reachStart, nearReachStart } = useScroll({ scrollableRef, }); const hiddenUI = scrollDirection === 'end' && !nearReachStart; const [followRequests, setFollowRequests] = useState([]); const [announcements, setAnnouncements] = useState([]); console.debug('RENDER Notifications'); const notificationsIterator = useRef(); async function fetchNotifications(firstLoad) { if (firstLoad || !notificationsIterator.current) { // Reset iterator notificationsIterator.current = masto.v1.notifications.list({ limit: LIMIT, excludeTypes: ['follow_request'], }); } if (/max_id=($|&)/i.test(notificationsIterator.current?.nextParams)) { // Pixelfed returns next paginationed link with empty max_id // I assume, it's done (end of list) return { done: true, }; } const allNotifications = await notificationsIterator.current.next(); const notifications = allNotifications.value; if (notifications?.length) { notifications.forEach((notification) => { saveStatus(notification.status, instance, { skipThreading: true, }); }); // TEST: Slot in a fake notification to test 'severed_relationships' // notifications.unshift({ // id: '123123', // type: 'severed_relationships', // createdAt: '2024-03-22T19:20:08.316Z', // event: { // type: 'account_suspension', // targetName: 'mastodon.dev', // followersCount: 0, // followingCount: 0, // }, // }); // console.log({ notifications }); const groupedNotifications = groupNotifications(notifications); if (firstLoad) { states.notificationsLast = notifications[0]; states.notifications = groupedNotifications; // Update last read marker masto.v1.markers .create({ notifications: { lastReadId: notifications[0].id, }, }) .catch(() => {}); } else { states.notifications.push(...groupedNotifications); } } states.notificationsShowNew = false; states.notificationsLastFetchTime = Date.now(); return allNotifications; } async function fetchFollowRequests() { // Note: no pagination here yet because this better be on a separate page. Should be rare use-case??? try { return await masto.v1.followRequests.list({ limit: 80, }); } catch (e) { // Silently fail return []; } } const loadFollowRequests = () => { setUIState('loading'); (async () => { try { const requests = await fetchFollowRequests(); setFollowRequests(requests); setUIState('default'); } catch (e) { setUIState('error'); } })(); }; async function fetchAnnouncements() { try { return await masto.v1.announcements.list(); } catch (e) { // Silently fail return []; } } const supportsFilteredNotifications = supports( '@mastodon/filtered-notifications', ); const [showNotificationsSettings, setShowNotificationsSettings] = useState(false); const [notificationsPolicy, setNotificationsPolicy] = useState({}); function fetchNotificationsPolicy() { return masto.v1.notifications.policy.fetch().catch(() => {}); } function loadNotificationsPolicy() { fetchNotificationsPolicy() .then((policy) => { console.log('✨ Notifications policy', policy); setNotificationsPolicy(policy); }) .catch(() => {}); } const [notificationsRequests, setNotificationsRequests] = useState(null); function fetchNotificationsRequest() { return masto.v1.notifications.requests.list(); } const loadNotifications = (firstLoad) => { setShowNew(false); setUIState('loading'); (async () => { try { const fetchNotificationsPromise = fetchNotifications(firstLoad); if (firstLoad) { fetchAnnouncements() .then((announcements) => { announcements.sort((a, b) => { // Sort by updatedAt first, then createdAt const aDate = new Date(a.updatedAt || a.createdAt); const bDate = new Date(b.updatedAt || b.createdAt); return bDate - aDate; }); setAnnouncements(announcements); }) .catch(() => {}); fetchFollowRequests() .then((requests) => { setFollowRequests(requests); }) .catch(() => {}); if (supportsFilteredNotifications) { loadNotificationsPolicy(); } } const { done } = await fetchNotificationsPromise; setShowMore(!done); setUIState('default'); } catch (e) { console.error(e); setUIState('error'); } })(); }; useEffect(() => { loadNotifications(true); }, []); useEffect(() => { if (reachStart) { loadNotifications(true); } }, [reachStart]); // useEffect(() => { // if (nearReachEnd && showMore) { // loadNotifications(); // } // }, [nearReachEnd, showMore]); const [showNew, setShowNew] = useState(false); const loadUpdates = useCallback( ({ disableIdleCheck = false } = {}) => { if (uiState === 'loading') { return; } console.log('✨ Load updates', { autoRefresh: snapStates.settings.autoRefresh, scrollTop: scrollableRef.current?.scrollTop, inBackground: inBackground(), disableIdleCheck, }); if ( snapStates.settings.autoRefresh && scrollableRef.current?.scrollTop < 16 && (disableIdleCheck || window.__IDLE__) && !inBackground() ) { loadNotifications(true); } }, [snapStates.notificationsShowNew, snapStates.settings.autoRefresh, uiState], ); // useEffect(loadUpdates, [snapStates.notificationsShowNew]); const lastHiddenTime = useRef(); usePageVisibility((visible) => { if (visible) { const timeDiff = Date.now() - lastHiddenTime.current; if (!lastHiddenTime.current || timeDiff > 1000 * 3) { // 3 seconds loadUpdates({ disableIdleCheck: true, }); } else { lastHiddenTime.current = Date.now(); } } }); useEffect(() => { let unsub = subscribeKey(states, 'notificationsShowNew', (v) => { if (uiState === 'loading') return; if (v) loadUpdates(); setShowNew(v); }); return () => unsub?.(); }, []); const todayDate = new Date(); const yesterdayDate = new Date(todayDate - 24 * 60 * 60 * 1000); let currentDay = new Date(); const showTodayEmpty = !snapStates.notifications.some( (notification) => new Date(notification.createdAt).toDateString() === todayDate.toDateString(), ); const announcementsListRef = useRef(); useEffect(() => { if (notificationID) { states.routeNotification = { id: notificationID, accessToken: atob(notificationAccessToken), }; } }, [notificationID, notificationAccessToken]); // useEffect(() => { // if (uiState === 'default') { // (async () => { // try { // const registration = await getRegistration(); // if (registration?.getNotifications) { // const notifications = await registration.getNotifications(); // console.log('🔔 Push notifications', notifications); // // Close all notifications? // // notifications.forEach((notification) => { // // notification.close(); // // }); // } // } catch (e) {} // })(); // } // }, [uiState]); const itemsSelector = '.notification'; const jRef = useHotkeys('j', () => { const activeItem = document.activeElement.closest(itemsSelector); const activeItemRect = activeItem?.getBoundingClientRect(); const allItems = Array.from( scrollableRef.current.querySelectorAll(itemsSelector), ); if ( activeItem && activeItemRect.top < scrollableRef.current.clientHeight && activeItemRect.bottom > 0 ) { const activeItemIndex = allItems.indexOf(activeItem); let nextItem = allItems[activeItemIndex + 1]; if (nextItem) { nextItem.focus(); nextItem.scrollIntoView(scrollIntoViewOptions); } } else { const topmostItem = allItems.find((item) => { const itemRect = item.getBoundingClientRect(); return itemRect.top >= 44 && itemRect.left >= 0; }); if (topmostItem) { topmostItem.focus(); topmostItem.scrollIntoView(scrollIntoViewOptions); } } }); const kRef = useHotkeys('k', () => { // focus on previous status after active item const activeItem = document.activeElement.closest(itemsSelector); const activeItemRect = activeItem?.getBoundingClientRect(); const allItems = Array.from( scrollableRef.current.querySelectorAll(itemsSelector), ); if ( activeItem && activeItemRect.top < scrollableRef.current.clientHeight && activeItemRect.bottom > 0 ) { const activeItemIndex = allItems.indexOf(activeItem); let prevItem = allItems[activeItemIndex - 1]; if (prevItem) { prevItem.focus(); prevItem.scrollIntoView(scrollIntoViewOptions); } } else { const topmostItem = allItems.find((item) => { const itemRect = item.getBoundingClientRect(); return itemRect.top >= 44 && itemRect.left >= 0; }); if (topmostItem) { topmostItem.focus(); topmostItem.scrollIntoView(scrollIntoViewOptions); } } }); const oRef = useHotkeys(['enter', 'o'], () => { const activeItem = document.activeElement.closest(itemsSelector); const statusLink = activeItem?.querySelector('.status-link'); if (statusLink) { statusLink.click(); } }); return (
{ scrollableRef.current = node; jRef.current = node; kRef.current = node; oRef.current = node; }} tabIndex="-1" >
{announcements.length > 0 && (
{' '} Announcement{announcements.length > 1 ? 's' : ''}{' '} {instance} {announcements.length > 1 && ( {announcements.map((announcement, index) => ( ))} )}
    1 ? 'multiple' : 'single' }`} ref={announcementsListRef} > {announcements.map((announcement) => (
  • ))}
)} {followRequests.length > 0 && ( )} {supportsFilteredNotifications && notificationsPolicy?.summary?.pendingRequestsCount > 0 && (
{ const { open } = e.target; if (open) { const requests = await fetchNotificationsRequest(); setNotificationsRequests(requests); console.log({ open, requests }); } }} > Filtered notifications from{' '} {notificationsPolicy.summary.pendingRequestsCount} people {!notificationsRequests ? (

) : ( notificationsRequests?.length > 0 && (
    {notificationsRequests.map((request) => (
  • {!request.lastStatus?.id && ( )} {request.lastStatus?.id && (
    )}
    { loadNotifications(true); }} />
  • ))}
) )}
)}

Today

{showTodayEmpty && (

{uiState === 'default' ? "You're all caught up." : <>…}

)} {snapStates.notifications.length ? ( <> {snapStates.notifications // This is leaked from Notifications popover .filter((n) => n.type !== 'follow_request') .map((notification) => { if (onlyMentions && notification.type !== 'mention') { return null; } const notificationDay = new Date(notification.createdAt); const differentDay = notificationDay.toDateString() !== currentDay.toDateString(); if (differentDay) { currentDay = notificationDay; } // if notificationDay is yesterday, show "Yesterday" // if notificationDay is before yesterday, show date const heading = notificationDay.toDateString() === yesterdayDate.toDateString() ? 'Yesterday' : niceDateTime(currentDay, { hideTime: true, }); return ( {differentDay &&

{heading}

}
); })} ) : ( <> {uiState === 'loading' && ( <> )} {uiState === 'error' && (

Unable to load notifications

)} )} {showMore && ( { if (inView) { loadNotifications(); } }} > )}
{supportsFilteredNotifications && showNotificationsSettings && ( { if (e.target === e.currentTarget) { setShowNotificationsSettings(false); } }} >

Notifications settings

{ e.preventDefault(); const { filterNotFollowing, filterNotFollowers, filterNewAccounts, filterPrivateMentions, } = e.target; const allFilters = { filterNotFollowing: filterNotFollowing.checked, filterNotFollowers: filterNotFollowers.checked, filterNewAccounts: filterNewAccounts.checked, filterPrivateMentions: filterPrivateMentions.checked, }; setNotificationsPolicy({ ...notificationsPolicy, ...allFilters, }); setShowNotificationsSettings(false); (async () => { try { await masto.v1.notifications.policy.update(allFilters); showToast('Notifications settings updated'); } catch (e) { console.error(e); } })(); }} >

Filter out notifications from people:

)}
); } function inBackground() { return !!document.querySelector('.deck-backdrop, #modal-container > *'); } function AnnouncementBlock({ announcement }) { const { instance } = api(); const { contact } = getCurrentInstance(); const contactAccount = contact?.account; const { id, content, startsAt, endsAt, published, allDay, publishedAt, updatedAt, read, mentions, statuses, tags, emojis, reactions, } = announcement; const publishedAtDate = new Date(publishedAt); const publishedDateText = niceDateTime(publishedAtDate); const updatedAtDate = new Date(updatedAt); const updatedAtText = niceDateTime(updatedAtDate); return (

{updatedAt && updatedAtText !== publishedDateText && ( <> {' '} •{' '} Updated{' '} )}

); } function fetchNotficationsByAccount(accountID) { const { masto } = api(); return masto.v1.notifications.list({ accountID, }); } function NotificationRequestModalButton({ request }) { const { instance } = api(); const [uiState, setUIState] = useState('loading'); const { account, lastStatus } = request; const [showModal, setShowModal] = useState(false); const [notifications, setNotifications] = useState([]); function onClose() { setShowModal(false); } useEffect(() => { if (!request?.account?.id) return; if (!showModal) return; setUIState('loading'); (async () => { const notifs = await fetchNotficationsByAccount(request.account.id); setNotifications(notifs || []); setUIState('default'); })(); }, [showModal, request?.account?.id]); return ( <> {showModal && ( { if (e.target === e.currentTarget) { onClose(); } }} >
Notifications from @{account.username}
{uiState === 'loading' ? (

) : ( notifications.map((notification) => (
{ const { target } = e; // If button or links if ( e.target.tagName === 'BUTTON' || e.target.tagName === 'A' ) { onClose(); } }} >
)) )}
)} ); } function NotificationRequestButtons({ request, onChange }) { const { masto } = api(); const [uiState, setUIState] = useState('default'); const [requestState, setRequestState] = useState(null); // accept, dismiss const hasRequestState = requestState !== null; return (

{' '} {uiState === 'loading' ? ( ) : requestState === 'accept' ? ( ) : ( requestState === 'dismiss' && ( ) )}

); } export default memo(Notifications);