workstand/bikeshop_project/assets/js/bikes/sagas.js

import { call, put, takeEvery, takeLatest } from 'redux-saga/effects';
import { fetchBikes as fetchBikesAction, setBikes, setBikesIsFetching, setBikesFetched,
         setBikesFetchFailed, setBikeSaved, setBikeSaveFailed, setBikeIsSaving, saveBike as saveBikeAction } from './actions';
import { normalize, denormalize } from 'normalizr';
import * as schema from './schema';
import Api from './services';


// worker Saga: will be fired on USER_FETCH_REQUESTED actions
function* fetchBikes(action) {
  try {
    yield put({ type: setBikesIsFetching.toString(), payload: true });
    const bikes = yield call(Api.fetchBikes);
    yield put({ type: setBikes.toString(), payload: normalize(bikes, schema.bikes) });
    yield put({ type: setBikesFetched.toString(), payload: true });
  } catch (e) {
    yield put({ type: setBikesFetchFailed.toString(), payload: e.message });
    throw e;
  } finally {
    yield put({ type: setBikesIsFetching.toString(), payload: false });
  }
}

function* watchFetchBikes() {
  yield takeEvery(fetchBikesAction.toString(), fetchBikes);
}

function* saveBike(action) {
  try {
    yield put({ type: setBikeIsSaving.toString(), payload: true });
    const bike = yield call(Api.saveBike(action.payload));
    yield put({ type: setBikes.toString(), payload: normalize([state])})
    yield put({ type: setBikeSaved, payload: true})
  } catch (e) {
    yield put({ type: setBikeSaveFailed, payload: false });
    throw(e);
  } finally {
    yield put({ type: setBikeIsSaving.toSource(), payload: false });
  }
}

function* watchSaveBike() {
  yield takeEvery(saveBikeAction.toString(), saveBike)
}

export default function* rootSaga() {
  yield [
    watchFetchBikes(),
    watchSaveBike(),
  ];
};