Universal Saga: Magic helper for handling api-calls with its side effects

callApiSaga.js

import { call, put, takeEvery, select } from 'redux-saga/effects'

// все экшены названы по паттерну _REQUEST, _SUCCESS, _FAILED
// like AUTH_SUCCESS, AUTH_FAILED, AUTH_REQUEST

function * callAPI (action) {
  const { payload, data: { method, params } } = action
  const user = yield select(state => state.user)
  try {
    const authHeaders = user.headers
    const response = yield call(method, { ...params, authHeaders })
    if (!response.ok) {
      throw response
    }
    // если все ок переделывает экшен на _SUCCESS
    const newType = action.type.replace('_REQUEST', '_SUCCESS')
    // вызываем экшн _SUCCESS и передаем данные в стейт
    yield put({ type: newType, payload, response, params })
  } catch (e) {
    // если все плохо переделываем экшен на _FAILED
    const newType = action.type.replace('_REQUEST', '_FAILED')
    // заносим в стейт статус беды
    yield put({
      type: newType,
      problem: e.problem,
      status: e.status,
      payload,
      response: e
    })
  }
}

// эта штука палит все реквест-экшены и перенаправляет их в сагу callApi
export default function * watchRequest () {
  yield takeEvery(action => /^.*_REQUEST/.test(action.type), callAPI)
}

// эксперментальные версия для GraphQL

function * graphApi (action) {
  const { payload, data: { method, params } } = action
  const user = yield select(state => state.user)
  const currentWallet = yield select(state => state.currentWallet)
  const bankId = currentWallet.id
  try {
    const authHeaders = user.headers
    const response = yield call(method, { bankId, ...params, authHeaders })
    if (
      (response.data && response.data.errors) ||
      response.errors
    ) {
      throw response
    }
    const newType = action.type.replace('_GRAPHQL', '_SUCCESS')
    yield put({ type: newType, payload, response, params })
  } catch (e) {
    const newType = action.type.replace('_GRAPHQL', '_FAILED')
    yield put({
      type: newType,
      problem: e.problem,
      status: e.status,
      payload,
      response: e
    })
  }
}

export function * watchGraphql () {
  yield takeEvery(action => /^.*_GRAPHQL/.test(action.type), graphApi)
}