insomnia/app/redux/modules/requests.js

import {combineReducers} from 'redux';

import {trackEvent} from '../../lib/analytics';
import * as network from '../../lib/network';

export const REQUEST_CHANGE_FILTER = 'requests/filter';
export const REQUEST_SEND_START = 'requests/start';
export const REQUEST_SEND_STOP = 'requests/stop';


// ~~~~~~~~ //
// REDUCERS //
// ~~~~~~~~ //

function filterReducer(state = '', action) {
  switch (action.type) {

    case REQUEST_CHANGE_FILTER:
      const filter = action.filter;
      return Object.assign({}, state, {filter});

    default:
      return state;
  }
}

function loadingRequestsReducer(state = {}, action) {
  let newState;
  switch (action.type) {

    case REQUEST_SEND_START:
      newState = Object.assign({}, state);
      newState[action.requestId] = Date.now();
      return newState;

    case REQUEST_SEND_STOP:
      newState = Object.assign({}, state);
      delete newState[action.requestId];
      return newState;

    default:
      return state;
  }
}

export default combineReducers({
  filter: filterReducer,
  loadingRequests: loadingRequestsReducer
});


// ~~~~~~~ //
// ACTIONS //
// ~~~~~~~ //

export function changeFilter(filter) {
  return {type: REQUEST_CHANGE_FILTER, filter};
}

export function send(request) {
  return dispatch => {
    dispatch({type: REQUEST_SEND_START, requestId: request._id});

    trackEvent('Request Send');

    network.send(request._id).then(() => {
      dispatch({type: REQUEST_SEND_STOP, requestId: request._id});
    }, err => {
      console.warn('Error sending request', err);
      dispatch({type: REQUEST_SEND_STOP, requestId: request._id});
    });
  }
}