import './app.css'; import 'toastify-js/src/toastify.css'; import { createHashHistory } from 'history'; import { login } from 'masto'; import Router, { route } from 'preact-router'; import { useEffect, useLayoutEffect, useState } from 'preact/hooks'; import Toastify from 'toastify-js'; import { useSnapshot } from 'valtio'; import Account from './components/account'; import Compose from './components/compose'; import Icon from './components/icon'; import Loader from './components/loader'; import Modal from './components/modal'; import Home from './pages/home'; import Login from './pages/login'; import Notifications from './pages/notifications'; import Settings from './pages/settings'; import Status from './pages/status'; import Welcome from './pages/welcome'; import { getAccessToken } from './utils/auth'; import openCompose from './utils/open-compose'; import states from './utils/states'; import store from './utils/store'; const { VITE_CLIENT_NAME: CLIENT_NAME } = import.meta.env; window.__STATES__ = states; async function startStream() { const stream = await masto.v1.stream.streamUser(); console.log('STREAM START', { stream }); stream.on('update', (status) => { console.log('UPDATE', status); const inHomeNew = states.homeNew.find((s) => s.id === status.id); const inHome = states.home.find((s) => s.id === status.id); if (!inHomeNew && !inHome) { states.homeNew.unshift({ id: status.id, reblog: status.reblog?.id, reply: !!status.inReplyToAccountId, }); } states.statuses.set(status.id, status); if (status.reblog) { states.statuses.set(status.reblog.id, status.reblog); } }); stream.on('status.update', (status) => { console.log('STATUS.UPDATE', status); states.statuses.set(status.id, status); if (status.reblog) { states.statuses.set(status.reblog.id, status.reblog); } }); stream.on('delete', (statusID) => { console.log('DELETE', statusID); // states.statuses.delete(statusID); const s = states.statuses.get(statusID); if (s) s._deleted = true; }); stream.on('notification', (notification) => { console.log('NOTIFICATION', notification); const inNotificationsNew = states.notificationsNew.find( (n) => n.id === notification.id, ); const inNotifications = states.notifications.find( (n) => n.id === notification.id, ); if (!inNotificationsNew && !inNotifications) { states.notificationsNew.unshift(notification); } if (notification.status && !states.statuses.has(notification.status.id)) { states.statuses.set(notification.status.id, notification.status); if ( notification.status.reblog && !states.statuses.has(notification.status.reblog.id) ) { states.statuses.set( notification.status.reblog.id, notification.status.reblog, ); } } }); stream.ws.onclose = () => { console.log('STREAM CLOSED!'); requestAnimationFrame(() => { startStream(); }); }; return { stream, stopStream: () => { stream.ws.close(); }, }; } function startVisibility() { const handleVisibilityChange = () => { if (document.hidden) { const timestamp = Date.now(); store.session.set('lastHidden', timestamp); } else { const timestamp = Date.now(); const lastHidden = store.session.get('lastHidden'); const diff = timestamp - lastHidden; const diffMins = Math.round(diff / 1000 / 60); if (diffMins > 1) { console.log('visible', { lastHidden, diffMins }); setTimeout(() => { // Buffer for WS reconnect (async () => { try { const fetchHome = masto.v1.timelines.listHome({ limit: 1, }); const fetchNotifications = masto.v1.notifications.list({ limit: 1, }); const newStatuses = await fetchHome; if ( newStatuses.length && newStatuses[0].id !== states.home[0].id ) { states.homeNew = newStatuses.map((status) => { states.statuses.set(status.id, status); if (status.reblog) { states.statuses.set(status.reblog.id, status.reblog); } return { id: status.id, reblog: status.reblog?.id, reply: !!status.inReplyToAccountId, }; }); } const newNotifications = await fetchNotifications; if (newNotifications.length) { const notification = newNotifications[0]; const inNotificationsNew = states.notificationsNew.find( (n) => n.id === notification.id, ); const inNotifications = states.notifications.find( (n) => n.id === notification.id, ); if (!inNotificationsNew && !inNotifications) { states.notificationsNew.unshift(notification); } if ( notification.status && !states.statuses.has(notification.status.id) ) { states.statuses.set( notification.status.id, notification.status, ); if ( notification.status.reblog && !states.statuses.has(notification.status.reblog.id) ) { states.statuses.set( notification.status.reblog.id, notification.status.reblog, ); } } } } catch (e) { // Silently fail console.error(e); } })(); }, 100); } } }; document.addEventListener('visibilitychange', handleVisibilityChange); return { stop: () => { document.removeEventListener('visibilitychange', handleVisibilityChange); }, }; } export function App() { const snapStates = useSnapshot(states); const [isLoggedIn, setIsLoggedIn] = useState(false); const [uiState, setUIState] = useState('loading'); useLayoutEffect(() => { const theme = store.local.get('theme'); if (theme) { document.documentElement.classList.add(`is-${theme}`); document .querySelector('meta[name="color-scheme"]') .setAttribute('content', theme); } }, []); useEffect(() => { const instanceURL = store.local.get('instanceURL'); const accounts = store.local.getJSON('accounts') || []; const code = (window.location.search.match(/code=([^&]+)/) || [])[1]; if (code) { console.log({ code }); // Clear the code from the URL window.history.replaceState({}, document.title, '/'); const clientID = store.session.get('clientID'); const clientSecret = store.session.get('clientSecret'); (async () => { setUIState('loading'); const tokenJSON = await getAccessToken({ instanceURL, client_id: clientID, client_secret: clientSecret, code, }); const { access_token: accessToken } = tokenJSON; store.session.set('accessToken', accessToken); window.masto = await login({ url: `https://${instanceURL}`, accessToken, disableVersionCheck: true, timeout: 30_000, }); const mastoAccount = await masto.v1.accounts.verifyCredentials(); console.log({ tokenJSON, mastoAccount }); let account = accounts.find((a) => a.info.id === mastoAccount.id); if (account) { account.info = mastoAccount; account.instanceURL = instanceURL; account.accessToken = accessToken; } else { account = { info: mastoAccount, instanceURL, accessToken, }; accounts.push(account); } store.local.setJSON('accounts', accounts); store.session.set('currentAccount', account.info.id); setIsLoggedIn(true); setUIState('default'); })(); } else if (accounts.length) { const currentAccount = store.session.get('currentAccount'); const account = accounts.find((a) => a.info.id === currentAccount) || accounts[0]; const instanceURL = account.instanceURL; const accessToken = account.accessToken; store.session.set('currentAccount', account.info.id); (async () => { try { setUIState('loading'); window.masto = await login({ url: `https://${instanceURL}`, accessToken, disableVersionCheck: true, timeout: 30_000, }); setIsLoggedIn(true); } catch (e) { setIsLoggedIn(false); } setUIState('default'); })(); } else { setUIState('default'); } }, []); const [currentDeck, setCurrentDeck] = useState('home'); useEffect(() => { // HACK: prevent this from running again due to HMR if (states.init) return; if (isLoggedIn) { requestAnimationFrame(() => { startStream(); startVisibility(); // Collect instance info (async () => { const info = await masto.v2.instance.fetch(); console.log(info); const { uri } = info; const instances = store.local.getJSON('instances') || {}; instances[uri] = info; store.local.setJSON('instances', instances); })(); }); states.init = true; } }, [isLoggedIn]); return ( <> {isLoggedIn && currentDeck && ( <>