redux-logic login flow example? about redux-logic HOT 2 CLOSED

const scheduleJWTRefreshLogic = createLogic({
  type: SCHEDULE_JWT_REFRESH,
  cancelType: LOGOUT, // cancel on action LOGOUT
  process({ getState, action, cancelled$ }, dispatch, done) {
    const refreshDelay = action.payload;
    const timer = setTimeout(() => {
      axios.post(url, data) // post to server to get refreshed JWT
        .then(resp => resp.data)
        .then(data => {
          const nextRefreshDelay = calcDelay(data.jwt);
          dispatch({ type: JWT_UPDATE, payload: data.jwt });
          dispatch({ type: SCHEDULE_JWT_REFRESH,
                     payload: nextRefreshDelay });
        })
        .catch(err => {
          console.error(err);
          dispatch({ type: ERROR, payload: err, error: true });
        })
        .then(() => done());  // done dispatching
    }, refreshDelay);

    cancelled$.subscribe(() => clearTimeout(timer));
  }
});

const scheduleJWTRefreshLogic = createLogic({
  type: SCHEDULE_JWT_REFRESH,
  cancelType: LOGOUT, // cancel on action LOGOUT

  processOptions: {
    failType: ERROR
  },
  
  process({ getState, action) {
    const refreshDelay = action.payload;
    return Observable.timer(refreshDelay) // return obs
      .mergeMap(() =>
        Observable.ajax({ url, method: 'POST', responseType: 'json' })  // POST to server to get refreshed JWT
         .map(ret => ret.response)
         .mergeMap(data => { // create a couple actions to dispatch
           const nextRefreshDelay = calcDelay(data.jwt);
           return Observable.of(
             { type: JWT_UPDATE, payload: data.jwt },
             { type: SCHEDULE_JWT_REFRESH,
                     payload: nextRefreshDelay }
           );
         })
       );
  }
});

// check the JWT token in the payload of FETCH_REPOS or FETCH_WIDGETS
// actions. The token could also just been stored in state.
// If expired or expiring soon, refresh before continuing
const checkJWTLogic = createLogic({
  type: [FETCH_REPOS, FETCH_WIDGETS], // action types or regexes
  validate({ getState, action }, allow, reject) {
    checkToken(action.jwt, getState())
      .then(jwt => {
        allow({
          ...action,
          jwt  // using the new or updated jwt token
        });
      })
      .catch(err => {
        console.error(err);        
        reject({ type: AUTH_ERR, payload: err, error: true })
      });
  }
});

function checkToken(jwt, state) {
  const expires = calcExpires(JWT); // negative if already expired
  if (expires < 0) { // expired
    return api.getJWTToken(state.x); // returns a promise to new JWT
  } else if (expires < THRESHOLD) { // expires soon
    return api.refreshJWTToken(jwt); // return a promise to refreshed JWT
  }
  // otherwise not expiring soon nothing to do, still valid
  return Promise.resolve(jwt); // promise to existing JWT    
}