phanpy/src/utils/states.js

144 lines
4.1 KiB
JavaScript
Raw Normal View History

2023-02-16 12:51:54 +03:00
import { proxy, subscribe } from 'valtio';
import { subscribeKey } from 'valtio/utils';
2023-01-14 14:42:04 +03:00
import { api } from './api';
2023-01-14 14:42:04 +03:00
import store from './store';
2022-12-10 12:14:48 +03:00
2023-01-09 14:11:34 +03:00
const states = proxy({
// history: [],
prevLocation: null,
currentLocation: null,
statuses: {},
2023-01-10 14:59:02 +03:00
statusThreadNumber: {},
2022-12-10 12:14:48 +03:00
home: [],
// specialHome: [],
2022-12-10 12:14:48 +03:00
homeNew: [],
homeLast: null, // Last item in 'home' list
2022-12-10 12:14:48 +03:00
homeLastFetchTime: null,
notifications: [],
2023-02-12 12:38:50 +03:00
notificationsLast: store.account.get('notificationsLast') || null, // Last read notification
2022-12-10 12:14:48 +03:00
notificationsNew: [],
2023-02-12 12:38:50 +03:00
notificationsShowNew: false,
2022-12-10 12:14:48 +03:00
notificationsLastFetchTime: null,
accounts: {},
2022-12-10 12:14:48 +03:00
reloadStatusPage: 0,
spoilers: {},
scrollPositions: {},
2022-12-10 12:14:48 +03:00
// Modals
showCompose: false,
showSettings: false,
showAccount: false,
showDrafts: false,
showMediaModal: false,
2023-02-16 12:51:54 +03:00
showShortcutsSettings: false,
// Shortcuts
shortcuts: store.account.get('shortcuts') ?? [],
// Settings
2023-01-14 14:42:04 +03:00
settings: {
boostsCarousel: store.account.get('settings-boostsCarousel') ?? true,
2023-01-14 14:42:04 +03:00
},
2022-12-10 12:14:48 +03:00
});
2023-01-09 14:11:34 +03:00
export default states;
subscribeKey(states, 'notificationsLast', (v) => {
console.log('CHANGE', v);
store.account.set('notificationsLast', states.notificationsLast);
});
subscribeKey(states, 'settings-boostsCarousel', (v) => {
store.account.set('settings-boostsCarousel', !!v);
2023-01-14 14:42:04 +03:00
});
2023-02-16 12:51:54 +03:00
subscribe(states, (v) => {
const [action, path, value] = v[0];
if (path?.[0] === 'shortcuts') {
store.account.set('shortcuts', states.shortcuts);
}
});
2023-01-14 14:42:04 +03:00
2023-02-02 05:30:16 +03:00
export function hideAllModals() {
states.showCompose = false;
states.showSettings = false;
states.showAccount = false;
states.showDrafts = false;
states.showMediaModal = false;
2023-02-17 06:29:53 +03:00
states.showShortcutsSettings = false;
2023-02-02 05:30:16 +03:00
}
export function statusKey(id, instance) {
return instance ? `${instance}/${id}` : id;
}
export function getStatus(statusID, instance) {
if (instance) {
const key = statusKey(statusID, instance);
return states.statuses[key];
}
return states.statuses[statusID];
}
export function saveStatus(status, instance, opts) {
if (typeof instance === 'object') {
opts = instance;
instance = null;
}
2023-01-10 14:59:02 +03:00
const { override, skipThreading } = Object.assign(
{ override: true, skipThreading: false },
opts,
);
2023-01-09 14:11:34 +03:00
if (!status) return;
if (!override && getStatus(status.id)) return;
const key = statusKey(status.id, instance);
states.statuses[key] = status;
2023-01-09 14:11:34 +03:00
if (status.reblog) {
const key = statusKey(status.reblog.id, instance);
states.statuses[key] = status.reblog;
2023-01-09 14:11:34 +03:00
}
2023-01-10 14:59:02 +03:00
// THREAD TRAVERSER
if (!skipThreading) {
requestAnimationFrame(() => {
threadifyStatus(status, instance);
2023-01-10 17:58:54 +03:00
if (status.reblog) {
threadifyStatus(status.reblog);
}
2023-01-10 14:59:02 +03:00
});
}
}
export function threadifyStatus(status, propInstance) {
const { masto, instance } = api({ instance: propInstance });
2023-01-10 14:59:02 +03:00
// Return all statuses in the thread, via inReplyToId, if inReplyToAccountId === account.id
let fetchIndex = 0;
async function traverse(status, index = 0) {
const { inReplyToId, inReplyToAccountId } = status;
if (!inReplyToId || inReplyToAccountId !== status.account.id) {
return [status];
}
if (inReplyToId && inReplyToAccountId !== status.account.id) {
throw 'Not a thread';
// Possibly thread of replies by multiple people?
}
let prevStatus = states.statuses[inReplyToId];
if (!prevStatus) {
if (fetchIndex++ > 3) throw 'Too many fetches for thread'; // Some people revive old threads
await new Promise((r) => setTimeout(r, 500 * fetchIndex)); // Be nice to rate limits
prevStatus = await masto.v1.statuses.fetch(inReplyToId);
saveStatus(prevStatus, instance, { skipThreading: true });
2023-01-10 14:59:02 +03:00
}
// Prepend so that first status in thread will be index 0
return [...(await traverse(prevStatus, ++index)), status];
}
return traverse(status)
.then((statuses) => {
if (statuses.length > 1) {
console.debug('THREAD', statuses);
statuses.forEach((status, index) => {
states.statusThreadNumber[status.id] = index + 1;
});
}
})
.catch((e) => {
console.error(e, status);
});
2023-01-09 14:11:34 +03:00
}