123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293 |
- import { importAccounts } from '../accounts_typed';
- import { normalizeStatus, normalizePoll } from './normalizer';
- export const STATUS_IMPORT = 'STATUS_IMPORT';
- export const STATUSES_IMPORT = 'STATUSES_IMPORT';
- export const POLLS_IMPORT = 'POLLS_IMPORT';
- export const FILTERS_IMPORT = 'FILTERS_IMPORT';
- function pushUnique(array, object) {
- if (array.every(element => element.id !== object.id)) {
- array.push(object);
- }
- }
- export function importStatus(status) {
- return { type: STATUS_IMPORT, status };
- }
- export function importStatuses(statuses) {
- return { type: STATUSES_IMPORT, statuses };
- }
- export function importFilters(filters) {
- return { type: FILTERS_IMPORT, filters };
- }
- export function importPolls(polls) {
- return { type: POLLS_IMPORT, polls };
- }
- export function importFetchedAccount(account) {
- return importFetchedAccounts([account]);
- }
- export function importFetchedAccounts(accounts) {
- const normalAccounts = [];
- function processAccount(account) {
- pushUnique(normalAccounts, account);
- if (account.moved) {
- processAccount(account.moved);
- }
- }
- accounts.forEach(processAccount);
- return importAccounts({ accounts: normalAccounts });
- }
- export function importFetchedStatus(status) {
- return importFetchedStatuses([status]);
- }
- export function importFetchedStatuses(statuses) {
- return (dispatch, getState) => {
- const accounts = [];
- const normalStatuses = [];
- const polls = [];
- const filters = [];
- function processStatus(status) {
- pushUnique(normalStatuses, normalizeStatus(status, getState().getIn(['statuses', status.id])));
- pushUnique(accounts, status.account);
- if (status.filtered) {
- status.filtered.forEach(result => pushUnique(filters, result.filter));
- }
- if (status.reblog && status.reblog.id) {
- processStatus(status.reblog);
- }
- if (status.poll && status.poll.id) {
- pushUnique(polls, normalizePoll(status.poll, getState().getIn(['polls', status.poll.id])));
- }
- }
- statuses.forEach(processStatus);
- dispatch(importPolls(polls));
- dispatch(importFetchedAccounts(accounts));
- dispatch(importStatuses(normalStatuses));
- dispatch(importFilters(filters));
- };
- }
- export function importFetchedPoll(poll) {
- return (dispatch, getState) => {
- dispatch(importPolls([normalizePoll(poll, getState().getIn(['polls', poll.id]))]));
- };
- }
|