123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112 |
- import api, { getLinks } from '../api';
- import {
- importFetchedAccounts,
- importFetchedStatuses,
- importFetchedStatus,
- } from './importer';
- export const CONVERSATIONS_MOUNT = 'CONVERSATIONS_MOUNT';
- export const CONVERSATIONS_UNMOUNT = 'CONVERSATIONS_UNMOUNT';
- export const CONVERSATIONS_FETCH_REQUEST = 'CONVERSATIONS_FETCH_REQUEST';
- export const CONVERSATIONS_FETCH_SUCCESS = 'CONVERSATIONS_FETCH_SUCCESS';
- export const CONVERSATIONS_FETCH_FAIL = 'CONVERSATIONS_FETCH_FAIL';
- export const CONVERSATIONS_UPDATE = 'CONVERSATIONS_UPDATE';
- export const CONVERSATIONS_READ = 'CONVERSATIONS_READ';
- export const CONVERSATIONS_DELETE_REQUEST = 'CONVERSATIONS_DELETE_REQUEST';
- export const CONVERSATIONS_DELETE_SUCCESS = 'CONVERSATIONS_DELETE_SUCCESS';
- export const CONVERSATIONS_DELETE_FAIL = 'CONVERSATIONS_DELETE_FAIL';
- export const mountConversations = () => ({
- type: CONVERSATIONS_MOUNT,
- });
- export const unmountConversations = () => ({
- type: CONVERSATIONS_UNMOUNT,
- });
- export const markConversationRead = conversationId => (dispatch, getState) => {
- dispatch({
- type: CONVERSATIONS_READ,
- id: conversationId,
- });
- api(getState).post(`/api/v1/conversations/${conversationId}/read`);
- };
- export const expandConversations = ({ maxId } = {}) => (dispatch, getState) => {
- dispatch(expandConversationsRequest());
- const params = { max_id: maxId };
- if (!maxId) {
- params.since_id = getState().getIn(['conversations', 'items', 0, 'last_status']);
- }
- const isLoadingRecent = !!params.since_id;
- api(getState).get('/api/v1/conversations', { params })
- .then(response => {
- const next = getLinks(response).refs.find(link => link.rel === 'next');
- dispatch(importFetchedAccounts(response.data.reduce((aggr, item) => aggr.concat(item.accounts), [])));
- dispatch(importFetchedStatuses(response.data.map(item => item.last_status).filter(x => !!x)));
- dispatch(expandConversationsSuccess(response.data, next ? next.uri : null, isLoadingRecent));
- })
- .catch(err => dispatch(expandConversationsFail(err)));
- };
- export const expandConversationsRequest = () => ({
- type: CONVERSATIONS_FETCH_REQUEST,
- });
- export const expandConversationsSuccess = (conversations, next, isLoadingRecent) => ({
- type: CONVERSATIONS_FETCH_SUCCESS,
- conversations,
- next,
- isLoadingRecent,
- });
- export const expandConversationsFail = error => ({
- type: CONVERSATIONS_FETCH_FAIL,
- error,
- });
- export const updateConversations = conversation => dispatch => {
- dispatch(importFetchedAccounts(conversation.accounts));
- if (conversation.last_status) {
- dispatch(importFetchedStatus(conversation.last_status));
- }
- dispatch({
- type: CONVERSATIONS_UPDATE,
- conversation,
- });
- };
- export const deleteConversation = conversationId => (dispatch, getState) => {
- dispatch(deleteConversationRequest(conversationId));
- api(getState).delete(`/api/v1/conversations/${conversationId}`)
- .then(() => dispatch(deleteConversationSuccess(conversationId)))
- .catch(error => dispatch(deleteConversationFail(conversationId, error)));
- };
- export const deleteConversationRequest = id => ({
- type: CONVERSATIONS_DELETE_REQUEST,
- id,
- });
- export const deleteConversationSuccess = id => ({
- type: CONVERSATIONS_DELETE_SUCCESS,
- id,
- });
- export const deleteConversationFail = (id, error) => ({
- type: CONVERSATIONS_DELETE_FAIL,
- id,
- error,
- });
|