124 lines
3.8 KiB
JavaScript
124 lines
3.8 KiB
JavaScript
import { Observable } from 'rx';
|
|
import { combineEpics, ofType } from 'redux-epic';
|
|
|
|
import { types, onRouteSettings } from './';
|
|
import { makeToast } from '../../../Toasts/redux';
|
|
import {
|
|
fetchChallenges,
|
|
doActionOnError,
|
|
userSelector
|
|
} from '../../../redux';
|
|
import {
|
|
updateUserFlag,
|
|
updateUserEmail,
|
|
updateUserLang
|
|
} from '../../../entities';
|
|
|
|
import { postJSON$ } from '../../../../utils/ajax-stream';
|
|
import langs from '../../../../utils/supported-languages';
|
|
|
|
const urlMap = {
|
|
isLocked: 'lockdown',
|
|
isAvailableForHire: 'available-for-hire',
|
|
sendQuincyEmail: 'quincy-email',
|
|
sendNotificationEmail: 'notification-email',
|
|
sendMonthlyEmail: 'announcement-email'
|
|
};
|
|
|
|
export function updateUserEmailEpic(actions, { getState }) {
|
|
return actions::ofType(types.updateMyEmail)
|
|
.flatMap(({ payload: email }) => {
|
|
const {
|
|
app: { user: username, csrfToken: _csrf },
|
|
entities: { user: userMap }
|
|
} = getState();
|
|
const { email: oldEmail } = userMap[username] || {};
|
|
const body = { _csrf, email };
|
|
const optimisticUpdate = Observable.just(
|
|
updateUserEmail(username, email)
|
|
);
|
|
const ajaxUpdate = postJSON$('/update-my-email', body)
|
|
.map(({ message }) => makeToast({ message }))
|
|
.catch(doActionOnError(() => oldEmail ?
|
|
updateUserEmail(username, oldEmail) :
|
|
null
|
|
));
|
|
return Observable.merge(optimisticUpdate, ajaxUpdate);
|
|
});
|
|
}
|
|
|
|
export function updateUserLangEpic(actions, { getState }) {
|
|
const updateLang = actions
|
|
.filter(({ type, payload }) => (
|
|
type === types.updateMyLang && !!langs[payload]
|
|
))
|
|
.map(({ payload }) => {
|
|
const state = getState();
|
|
const { languageTag } = userSelector(state);
|
|
return { lang: payload, oldLang: languageTag };
|
|
});
|
|
const ajaxUpdate = updateLang
|
|
.debounce(250)
|
|
.flatMap(({ lang, oldLang }) => {
|
|
const { app: { user: username, csrfToken: _csrf } } = getState();
|
|
const body = { _csrf, lang };
|
|
return postJSON$('/update-my-lang', body)
|
|
.flatMap(({ message }) => {
|
|
return Observable.of(
|
|
// show user that we have updated their lang
|
|
makeToast({ message }),
|
|
// update url to reflect change
|
|
onRouteSettings({ lang }),
|
|
// refetch challenges in new language
|
|
fetchChallenges()
|
|
);
|
|
})
|
|
.catch(doActionOnError(() => {
|
|
return updateUserLang(username, oldLang);
|
|
}));
|
|
});
|
|
const optimistic = updateLang
|
|
.map(({ lang }) => {
|
|
const { app: { user: username } } = getState();
|
|
return updateUserLang(username, lang);
|
|
});
|
|
return Observable.merge(ajaxUpdate, optimistic);
|
|
}
|
|
export function updateUserFlagEpic(actions, { getState }) {
|
|
const toggleFlag = actions
|
|
.filter(({ type, payload }) => type === types.toggleUserFlag && payload)
|
|
.map(({ payload }) => payload);
|
|
const optimistic = toggleFlag.map(flag => {
|
|
const { app: { user: username } } = getState();
|
|
return updateUserFlag(username, flag);
|
|
});
|
|
const serverUpdate = toggleFlag
|
|
.debounce(500)
|
|
.flatMap(flag => {
|
|
const url = `/toggle-${urlMap[ flag ]}`;
|
|
const {
|
|
app: { user: username, csrfToken: _csrf },
|
|
entities: { user: userMap }
|
|
} = getState();
|
|
const user = userMap[username];
|
|
const currentValue = user[ flag ];
|
|
return postJSON$(url, { _csrf })
|
|
.map(({ flag, value }) => {
|
|
if (currentValue === value) {
|
|
return null;
|
|
}
|
|
return updateUserFlag(username, flag);
|
|
})
|
|
.catch(doActionOnError(() => {
|
|
return updateUserFlag(username, currentValue);
|
|
}));
|
|
});
|
|
return Observable.merge(optimistic, serverUpdate);
|
|
}
|
|
|
|
export default combineEpics(
|
|
updateUserFlagEpic,
|
|
updateUserEmailEpic,
|
|
updateUserLangEpic
|
|
);
|