return;
}
- const dropRegex = getFiltersRegex(getState(), { contextType: timeline })[0];
-
- if (dropRegex && status.account.id !== me) {
- if (dropRegex.test(searchTextFromRawStatus(status))) {
- return;
- }
+ const filters = getFiltersRegex(getState(), { contextType: timeline });
+ const dropRegex = filters[0];
+ const regex = filters[1];
+ const text = searchTextFromRawStatus(status);
+ let filtered = false;
+
+ if (status.account.id !== me) {
+ filtered = (dropRegex && dropRegex.test(text)) || (regex && regex.test(text));
}
dispatch(importFetchedStatus(status));
timeline,
status,
usePendingItems: preferPendingItems,
+ filtered
});
};
};
api(getState).get(path, { params }).then(response => {
const next = getLinks(response).refs.find(link => link.rel === 'next');
- const dropRegex = getFiltersRegex(getState(), { contextType: timelineId })[0];
-
- const statuses = dropRegex ? response.data.filter(status => status.account.id === me || !dropRegex.test(searchTextFromRawStatus(status))) : response.data;
-
- dispatch(importFetchedStatuses(statuses));
- dispatch(expandTimelineSuccess(timelineId, statuses, next ? next.uri : null, response.status === 206, isLoadingRecent, isLoadingMore, isLoadingRecent && preferPendingItems));
+ dispatch(importFetchedStatuses(response.data));
+ dispatch(expandTimelineSuccess(timelineId, response.data, next ? next.uri : null, response.status === 206, isLoadingRecent, isLoadingMore, isLoadingRecent && preferPendingItems));
done();
}).catch(error => {
dispatch(expandTimelineFail(timelineId, error, isLoadingMore));
}));
};
-const updateTimeline = (state, timeline, status, usePendingItems) => {
+const updateTimeline = (state, timeline, status, usePendingItems, filtered) => {
const top = state.getIn([timeline, 'top']);
if (usePendingItems || !state.getIn([timeline, 'pendingItems']).isEmpty()) {
return state;
}
- return state.update(timeline, initialTimeline, map => map.update('pendingItems', list => list.unshift(status.get('id'))).update('unread', unread => unread + 1));
+ state = state.update(timeline, initialTimeline, map => map.update('pendingItems', list => list.unshift(status.get('id'))));
+
+ if (!filtered) {
+ state = state.update('unread', unread => unread + 1);
+ }
+
+ return state;
}
const ids = state.getIn([timeline, 'items'], ImmutableList());
let newIds = ids;
return state.update(timeline, initialTimeline, map => map.withMutations(mMap => {
- if (!top) mMap.set('unread', unread + 1);
+ if (!top && !filtered) mMap.set('unread', unread + 1);
if (top && ids.size > 40) newIds = newIds.take(20);
mMap.set('items', newIds.unshift(status.get('id')));
}));
case TIMELINE_EXPAND_SUCCESS:
return expandNormalizedTimeline(state, action.timeline, fromJS(action.statuses), action.next, action.partial, action.isLoadingRecent, action.usePendingItems);
case TIMELINE_UPDATE:
- return updateTimeline(state, action.timeline, fromJS(action.status), action.usePendingItems);
+ return updateTimeline(state, action.timeline, fromJS(action.status), action.usePendingItems, action.filtered);
case TIMELINE_DELETE:
return deleteStatus(state, action.id, action.accountId, action.references, action.reblogOf);
case TIMELINE_CLEAR: