2019-07-02 08:10:25 +01:00
|
|
|
import api, { getLinks } from '../api';
|
|
|
|
import IntlMessageFormat from 'intl-messageformat';
|
|
|
|
import { fetchRelationships } from './accounts';
|
|
|
|
import {
|
|
|
|
importFetchedAccount,
|
|
|
|
importFetchedAccounts,
|
|
|
|
importFetchedStatus,
|
|
|
|
importFetchedStatuses,
|
|
|
|
} from './importer';
|
|
|
|
import { defineMessages } from 'react-intl';
|
|
|
|
import { List as ImmutableList } from 'immutable';
|
|
|
|
import { unescapeHTML } from '../utils/html';
|
|
|
|
import { getFilters, regexFromFilters } from '../selectors';
|
2020-01-29 16:45:17 +00:00
|
|
|
import { me } from '../initial_state';
|
2019-07-02 08:10:25 +01:00
|
|
|
|
2020-04-09 20:18:14 +01:00
|
|
|
export const NOTIFICATIONS_INITIALIZE = 'NOTIFICATIONS_INITIALIZE';
|
|
|
|
export const NOTIFICATIONS_UPDATE = 'NOTIFICATIONS_UPDATE';
|
2019-07-11 05:02:18 +01:00
|
|
|
export const NOTIFICATIONS_UPDATE_QUEUE = 'NOTIFICATIONS_UPDATE_QUEUE';
|
2020-04-09 20:18:14 +01:00
|
|
|
export const NOTIFICATIONS_DEQUEUE = 'NOTIFICATIONS_DEQUEUE';
|
2019-07-02 08:10:25 +01:00
|
|
|
|
|
|
|
export const NOTIFICATIONS_EXPAND_REQUEST = 'NOTIFICATIONS_EXPAND_REQUEST';
|
|
|
|
export const NOTIFICATIONS_EXPAND_SUCCESS = 'NOTIFICATIONS_EXPAND_SUCCESS';
|
2020-04-09 20:18:14 +01:00
|
|
|
export const NOTIFICATIONS_EXPAND_FAIL = 'NOTIFICATIONS_EXPAND_FAIL';
|
2019-07-02 08:10:25 +01:00
|
|
|
|
|
|
|
export const NOTIFICATIONS_FILTER_SET = 'NOTIFICATIONS_FILTER_SET';
|
|
|
|
|
2020-04-09 20:18:14 +01:00
|
|
|
export const NOTIFICATIONS_CLEAR = 'NOTIFICATIONS_CLEAR';
|
2019-07-02 08:10:25 +01:00
|
|
|
export const NOTIFICATIONS_SCROLL_TOP = 'NOTIFICATIONS_SCROLL_TOP';
|
2020-04-09 20:18:14 +01:00
|
|
|
export const NOTIFICATIONS_MARK_READ = 'NOTIFICATIONS_MARK_READ';
|
2019-07-02 08:10:25 +01:00
|
|
|
|
2020-03-04 03:45:16 +00:00
|
|
|
export const MAX_QUEUED_NOTIFICATIONS = 40
|
2019-07-11 05:02:18 +01:00
|
|
|
|
2019-07-02 08:10:25 +01:00
|
|
|
defineMessages({
|
|
|
|
mention: { id: 'notification.mention', defaultMessage: '{name} mentioned you' },
|
|
|
|
group: { id: 'notifications.group', defaultMessage: '{count} notifications' },
|
|
|
|
});
|
|
|
|
|
|
|
|
const fetchRelatedRelationships = (dispatch, notifications) => {
|
|
|
|
const accountIds = notifications.filter(item => item.type === 'follow').map(item => item.account.id);
|
|
|
|
|
|
|
|
if (accountIds.length > 0) {
|
|
|
|
dispatch(fetchRelationships(accountIds));
|
|
|
|
}
|
2020-03-04 03:45:16 +00:00
|
|
|
}
|
2019-07-02 08:10:25 +01:00
|
|
|
|
2020-01-16 23:24:10 +00:00
|
|
|
export function initializeNotifications() {
|
|
|
|
return {
|
|
|
|
type: NOTIFICATIONS_INITIALIZE,
|
2020-03-04 03:45:16 +00:00
|
|
|
}
|
2020-01-16 23:24:10 +00:00
|
|
|
}
|
|
|
|
|
2019-07-02 08:10:25 +01:00
|
|
|
export function updateNotifications(notification, intlMessages, intlLocale) {
|
|
|
|
return (dispatch, getState) => {
|
2020-04-09 20:18:14 +01:00
|
|
|
const showInColumn = getState().getIn(['notifications', 'filter', notification.type], true);
|
2019-07-02 08:10:25 +01:00
|
|
|
|
|
|
|
if (showInColumn) {
|
|
|
|
dispatch(importFetchedAccount(notification.account));
|
|
|
|
|
|
|
|
if (notification.status) {
|
|
|
|
dispatch(importFetchedStatus(notification.status));
|
|
|
|
}
|
|
|
|
|
|
|
|
dispatch({
|
|
|
|
type: NOTIFICATIONS_UPDATE,
|
|
|
|
notification,
|
|
|
|
});
|
|
|
|
|
|
|
|
fetchRelatedRelationships(dispatch, [notification]);
|
2019-07-11 05:02:18 +01:00
|
|
|
}
|
|
|
|
};
|
|
|
|
};
|
|
|
|
|
|
|
|
export function updateNotificationsQueue(notification, intlMessages, intlLocale, curPath) {
|
|
|
|
return (dispatch, getState) => {
|
2020-04-09 20:18:14 +01:00
|
|
|
// : todo :
|
|
|
|
// const showAlert = getState().getIn(['settings', 'notifications', 'alerts', notification.type], true);
|
2019-07-11 05:02:18 +01:00
|
|
|
const filters = getFilters(getState(), { contextType: 'notifications' });
|
|
|
|
|
|
|
|
let filtered = false;
|
|
|
|
|
|
|
|
const isOnNotificationsPage = curPath === '/notifications';
|
|
|
|
|
|
|
|
if (notification.type === 'mention') {
|
|
|
|
const regex = regexFromFilters(filters);
|
|
|
|
const searchIndex = notification.status.spoiler_text + '\n' + unescapeHTML(notification.status.content);
|
|
|
|
filtered = regex && regex.test(searchIndex);
|
2019-07-02 08:10:25 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
// Desktop notifications
|
2020-04-09 20:18:14 +01:00
|
|
|
// : todo :
|
|
|
|
// if (typeof window.Notification !== 'undefined' && showAlert && !filtered) {
|
|
|
|
// const title = new IntlMessageFormat(intlMessages[`notification.${notification.type}`], intlLocale).format({ name: notification.account.display_name.length > 0 ? notification.account.display_name : notification.account.username });
|
|
|
|
// const body = (notification.status && notification.status.spoiler_text.length > 0) ? notification.status.spoiler_text : unescapeHTML(notification.status ? notification.status.content : '');
|
2019-07-02 08:10:25 +01:00
|
|
|
|
2020-04-09 20:18:14 +01:00
|
|
|
// const notify = new Notification(title, { body, icon: notification.account.avatar, tag: notification.id });
|
2019-07-02 08:10:25 +01:00
|
|
|
|
2020-04-09 20:18:14 +01:00
|
|
|
// notify.addEventListener('click', () => {
|
|
|
|
// window.focus();
|
|
|
|
// notify.close();
|
|
|
|
// });
|
|
|
|
// }
|
2019-07-11 05:02:18 +01:00
|
|
|
|
|
|
|
if (isOnNotificationsPage) {
|
|
|
|
dispatch({
|
|
|
|
type: NOTIFICATIONS_UPDATE_QUEUE,
|
|
|
|
notification,
|
|
|
|
intlMessages,
|
|
|
|
intlLocale,
|
|
|
|
});
|
2020-04-08 02:06:59 +01:00
|
|
|
} else {
|
2019-07-11 05:02:18 +01:00
|
|
|
dispatch(updateNotifications(notification, intlMessages, intlLocale));
|
|
|
|
}
|
|
|
|
}
|
|
|
|
};
|
|
|
|
|
|
|
|
export function dequeueNotifications() {
|
|
|
|
return (dispatch, getState) => {
|
|
|
|
const queuedNotifications = getState().getIn(['notifications', 'queuedNotifications'], ImmutableList());
|
|
|
|
const totalQueuedNotificationsCount = getState().getIn(['notifications', 'totalQueuedNotificationsCount'], 0);
|
|
|
|
|
2020-04-08 02:06:59 +01:00
|
|
|
if (totalQueuedNotificationsCount === 0) {
|
2019-07-11 05:02:18 +01:00
|
|
|
return;
|
2020-04-08 02:06:59 +01:00
|
|
|
} else if (totalQueuedNotificationsCount > 0 && totalQueuedNotificationsCount <= MAX_QUEUED_NOTIFICATIONS) {
|
2019-07-11 05:02:18 +01:00
|
|
|
queuedNotifications.forEach(block => {
|
|
|
|
dispatch(updateNotifications(block.notification, block.intlMessages, block.intlLocale));
|
|
|
|
});
|
2020-04-08 02:06:59 +01:00
|
|
|
} else {
|
2019-07-11 05:02:18 +01:00
|
|
|
dispatch(expandNotifications());
|
|
|
|
}
|
|
|
|
|
|
|
|
dispatch({
|
|
|
|
type: NOTIFICATIONS_DEQUEUE,
|
|
|
|
});
|
2020-01-16 23:24:10 +00:00
|
|
|
dispatch(markReadNotifications());
|
2019-07-11 05:02:18 +01:00
|
|
|
}
|
2019-07-02 08:10:25 +01:00
|
|
|
};
|
|
|
|
|
|
|
|
const excludeTypesFromFilter = filter => {
|
|
|
|
const allTypes = ImmutableList(['follow', 'favourite', 'reblog', 'mention', 'poll']);
|
|
|
|
return allTypes.filterNot(item => item === filter).toJS();
|
|
|
|
};
|
|
|
|
|
2020-04-09 20:18:14 +01:00
|
|
|
const noOp = () => { };
|
2019-07-02 08:10:25 +01:00
|
|
|
|
|
|
|
export function expandNotifications({ maxId } = {}, done = noOp) {
|
|
|
|
return (dispatch, getState) => {
|
2020-04-09 20:18:14 +01:00
|
|
|
if (!me) return
|
2019-07-02 08:10:25 +01:00
|
|
|
|
2020-04-09 20:18:14 +01:00
|
|
|
const onlyVerified = getState().getIn(['notifications', 'filter', 'onlyVerified'])
|
|
|
|
const onlyFollowing = getState().getIn(['notifications', 'filter', 'onlyFollowing'])
|
|
|
|
const activeFilter = getState().getIn(['notifications', 'filter', 'active'])
|
|
|
|
const notifications = getState().get('notifications')
|
|
|
|
const isLoadingMore = !!maxId
|
2019-07-02 08:10:25 +01:00
|
|
|
|
|
|
|
if (notifications.get('isLoading')) {
|
|
|
|
done();
|
|
|
|
return;
|
|
|
|
}
|
2020-04-08 02:06:59 +01:00
|
|
|
|
2020-05-09 03:17:19 +01:00
|
|
|
console.log("activeFilter:", activeFilter)
|
|
|
|
|
2019-07-02 08:10:25 +01:00
|
|
|
const params = {
|
|
|
|
max_id: maxId,
|
2020-04-11 23:29:19 +01:00
|
|
|
exclude_types: activeFilter === 'all' ? null : excludeTypesFromFilter(activeFilter),
|
2020-05-01 06:50:27 +01:00
|
|
|
// : todo : ?
|
2020-04-11 23:29:19 +01:00
|
|
|
// exclude_types: activeFilter === 'all'
|
|
|
|
// ? excludeTypesFromSettings(getState())
|
|
|
|
// : excludeTypesFromFilter(activeFilter),
|
2019-07-02 08:10:25 +01:00
|
|
|
};
|
|
|
|
|
2020-04-17 06:35:46 +01:00
|
|
|
if (!!onlyVerified) params.only_verified = onlyVerified
|
|
|
|
if (!!onlyFollowing) params.only_following = onlyFollowing
|
|
|
|
|
2019-07-02 08:10:25 +01:00
|
|
|
if (!maxId && notifications.get('items').size > 0) {
|
|
|
|
params.since_id = notifications.getIn(['items', 0, 'id']);
|
|
|
|
}
|
|
|
|
|
|
|
|
dispatch(expandNotificationsRequest(isLoadingMore));
|
|
|
|
|
|
|
|
api(getState).get('/api/v1/notifications', { params }).then(response => {
|
|
|
|
const next = getLinks(response).refs.find(link => link.rel === 'next');
|
|
|
|
|
|
|
|
dispatch(importFetchedAccounts(response.data.map(item => item.account)));
|
|
|
|
dispatch(importFetchedStatuses(response.data.map(item => item.status).filter(status => !!status)));
|
|
|
|
|
|
|
|
dispatch(expandNotificationsSuccess(response.data, next ? next.uri : null, isLoadingMore));
|
|
|
|
fetchRelatedRelationships(dispatch, response.data);
|
|
|
|
done();
|
|
|
|
}).catch(error => {
|
|
|
|
dispatch(expandNotificationsFail(error, isLoadingMore));
|
|
|
|
done();
|
|
|
|
});
|
|
|
|
};
|
|
|
|
};
|
|
|
|
|
|
|
|
export function expandNotificationsRequest(isLoadingMore) {
|
|
|
|
return {
|
|
|
|
type: NOTIFICATIONS_EXPAND_REQUEST,
|
|
|
|
skipLoading: !isLoadingMore,
|
|
|
|
};
|
|
|
|
};
|
|
|
|
|
|
|
|
export function expandNotificationsSuccess(notifications, next, isLoadingMore) {
|
|
|
|
return {
|
|
|
|
type: NOTIFICATIONS_EXPAND_SUCCESS,
|
|
|
|
notifications,
|
|
|
|
next,
|
|
|
|
skipLoading: !isLoadingMore,
|
|
|
|
};
|
|
|
|
};
|
|
|
|
|
|
|
|
export function expandNotificationsFail(error, isLoadingMore) {
|
|
|
|
return {
|
|
|
|
type: NOTIFICATIONS_EXPAND_FAIL,
|
|
|
|
error,
|
|
|
|
skipLoading: !isLoadingMore,
|
|
|
|
};
|
|
|
|
};
|
|
|
|
|
|
|
|
export function clearNotifications() {
|
|
|
|
return (dispatch, getState) => {
|
|
|
|
if (!me) return;
|
2019-07-11 05:02:18 +01:00
|
|
|
|
2019-07-02 08:10:25 +01:00
|
|
|
dispatch({
|
|
|
|
type: NOTIFICATIONS_CLEAR,
|
|
|
|
});
|
|
|
|
|
|
|
|
api(getState).post('/api/v1/notifications/clear');
|
|
|
|
};
|
|
|
|
};
|
|
|
|
|
|
|
|
export function scrollTopNotifications(top) {
|
2020-01-16 23:24:10 +00:00
|
|
|
return (dispatch, getState) => {
|
|
|
|
dispatch({
|
|
|
|
type: NOTIFICATIONS_SCROLL_TOP,
|
|
|
|
top,
|
|
|
|
});
|
|
|
|
dispatch(markReadNotifications());
|
|
|
|
}
|
2019-07-02 08:10:25 +01:00
|
|
|
};
|
|
|
|
|
2020-04-09 20:18:14 +01:00
|
|
|
export function setFilter(path, value) {
|
2019-07-02 08:10:25 +01:00
|
|
|
return dispatch => {
|
|
|
|
dispatch({
|
|
|
|
type: NOTIFICATIONS_FILTER_SET,
|
2020-04-09 20:18:14 +01:00
|
|
|
path: path,
|
|
|
|
value: value,
|
|
|
|
})
|
|
|
|
dispatch(expandNotifications())
|
|
|
|
}
|
|
|
|
}
|
2020-01-16 23:24:10 +00:00
|
|
|
|
|
|
|
export function markReadNotifications() {
|
|
|
|
return (dispatch, getState) => {
|
|
|
|
if (!me) return;
|
|
|
|
const top_notification = parseInt(getState().getIn(['notifications', 'items', 0, 'id']));
|
|
|
|
const last_read = getState().getIn(['notifications', 'lastRead']);
|
|
|
|
|
|
|
|
if (top_notification && top_notification > last_read) {
|
2020-04-08 02:06:59 +01:00
|
|
|
api(getState).post('/api/v1/notifications/mark_read', { id: top_notification }).then(response => {
|
2020-01-16 23:24:10 +00:00
|
|
|
dispatch({
|
|
|
|
type: NOTIFICATIONS_MARK_READ,
|
|
|
|
notification: top_notification,
|
|
|
|
});
|
|
|
|
});
|
|
|
|
}
|
|
|
|
}
|
|
|
|
};
|