29 lines
953 B
JavaScript
29 lines
953 B
JavaScript
import { put, takeLatest } from 'redux-saga/effects';
|
|
|
|
import * as types from '../actions/actionsTypes';
|
|
import { roomsSuccess, roomsFailure } from '../actions/rooms';
|
|
import RocketChat from '../lib/rocketchat';
|
|
import database from '../lib/realm';
|
|
import log from '../utils/log';
|
|
import mergeSubscriptionsRooms from '../lib/methods/helpers/mergeSubscriptionsRooms';
|
|
|
|
const handleRoomsRequest = function* handleRoomsRequest() {
|
|
try {
|
|
const [subscriptionsResult, roomsResult] = yield RocketChat.getRooms();
|
|
const { subscriptions } = mergeSubscriptionsRooms(subscriptionsResult, roomsResult);
|
|
|
|
database.write(() => {
|
|
subscriptions.forEach(subscription => database.create('subscriptions', subscription, true));
|
|
});
|
|
yield put(roomsSuccess());
|
|
} catch (e) {
|
|
yield put(roomsFailure(e));
|
|
log('handleRoomsRequest', e);
|
|
}
|
|
};
|
|
|
|
const root = function* root() {
|
|
yield takeLatest(types.ROOMS.REQUEST, handleRoomsRequest);
|
|
};
|
|
export default root;
|