Epic getProducts.js

epicGetProducts.js

import {
  ajax
} from 'rxjs/observable/dom/ajax';
import 'rxjs/add/operator/catch'
import 'rxjs/add/operator/debounceTime'
import queryString from 'query-string'
import {
  Observable
} from 'rxjs/Observable';

import {
  REQUEST_PRODUCTS,
  CANCEL_PRODUCTS_REQUEST,
  PRODUCTS_REQUEST_FAILED
} from '../actions/actionTypes';

import {
  productsRequestFulfilled,
  productsRequestFailed
} from '../actions/doFetchProducts';

export default function epicGetProducts(action$, store) {
  return action$.ofType(REQUEST_PRODUCTS)
    .debounceTime(500)
    .map(function(action) {
      let search = store.getState().catalog.search
      let searchString = queryString.stringify(search)
      return Object.assign(action, {
        searchString
      })
    })
    .mergeMap(action =>
      ajax.get(`/products?${action.searchString}`)
      .map(response => productsRequestFulfilled(response))
      .catch(error => productsRequestFailed(error))
      .takeUntil(action$.ofType(CANCEL_PRODUCTS_REQUEST))
    );
}