import { takeLatest, select, take, put, call } from 'redux-saga/effects'; import { MESSAGES, LOGIN } from '../actions/actionsTypes'; import { messagesSuccess, messagesFailure, deleteSuccess, deleteFailure, editSuccess, editFailure, toggleStarSuccess, toggleStarFailure, permalinkSuccess, permalinkFailure, togglePinSuccess, togglePinFailure } from '../actions/messages'; import RocketChat from '../lib/rocketchat'; const deleteMessage = message => RocketChat.deleteMessage(message); const editMessage = message => RocketChat.editMessage(message); const toggleStarMessage = message => RocketChat.toggleStarMessage(message); const getPermalink = message => RocketChat.getPermalink(message); const togglePinMessage = message => RocketChat.togglePinMessage(message); const get = function* get({ rid }) { const auth = yield select(state => state.login.isAuthenticated); if (!auth) { yield take(LOGIN.SUCCESS); } try { yield RocketChat.loadMessagesForRoom(rid, null); yield put(messagesSuccess()); } catch (err) { console.log(err); yield put(messagesFailure(err.status)); } }; const handleDeleteRequest = function* handleDeleteRequest({ message }) { try { yield call(deleteMessage, message); yield put(deleteSuccess()); } catch (error) { yield put(deleteFailure()); } }; const handleEditRequest = function* handleEditRequest({ message }) { try { yield call(editMessage, message); yield put(editSuccess()); } catch (error) { yield put(editFailure()); } }; const handleToggleStarRequest = function* handleToggleStarRequest({ message }) { try { yield call(toggleStarMessage, message); yield put(toggleStarSuccess()); } catch (error) { yield put(toggleStarFailure()); } }; const handlePermalinkRequest = function* handlePermalinkRequest({ message }) { try { const permalink = yield call(getPermalink, message); yield put(permalinkSuccess(permalink)); } catch (error) { yield put(permalinkFailure(error)); } }; const handleTogglePinRequest = function* handleTogglePinRequest({ message }) { try { yield call(togglePinMessage, message); yield put(togglePinSuccess()); } catch (error) { yield put(togglePinFailure(error)); } }; const root = function* root() { yield takeLatest(MESSAGES.REQUEST, get); yield takeLatest(MESSAGES.DELETE_REQUEST, handleDeleteRequest); yield takeLatest(MESSAGES.EDIT_REQUEST, handleEditRequest); yield takeLatest(MESSAGES.TOGGLE_STAR_REQUEST, handleToggleStarRequest); yield takeLatest(MESSAGES.PERMALINK_REQUEST, handlePermalinkRequest); yield takeLatest(MESSAGES.TOGGLE_PIN_REQUEST, handleTogglePinRequest); }; export default root;