freeCodeCamp/api-server/server/rss/index.js

import _ from 'lodash';
import compareDesc from 'date-fns/compare_desc';
import debug from 'debug';

import { getLybsynFeed } from './lybsyn';

const log = debug('fcc:rss:news-feed');

const fiveMinutes = 1000 * 60 * 5;

class NewsFeed {
  constructor() {
    this.state = {
      readyState: false,
      lybsynFeed: [],
      combinedFeed: []
    };
    this.refreshFeeds();

    setInterval(this.refreshFeeds, fiveMinutes);
  }

  setState = stateUpdater => {
    const newState = stateUpdater(this.state);
    this.state = _.merge({}, this.state, newState);
    return;
  };

  refreshFeeds = () => {
    const currentFeed = this.state.combinedFeed.slice(0);
    log('grabbing feeds');
    return Promise.all([getLybsynFeed()])
      .then(([lybsynFeed]) =>
        this.setState(state => ({
          ...state,
          lybsynFeed
        }))
      )
      .then(() => {
        log('crossing the streams');
        const { lybsynFeed } = this.state;
        const combinedFeed = [...lybsynFeed].sort((a, b) => {
          return compareDesc(a.isoDate, b.isoDate);
        });
        this.setState(state => ({
          ...state,
          combinedFeed,
          readyState: true
        }));
      })
      .catch(err => {
        console.log(err);
        this.setState(state => ({
          ...state,
          combinedFeed: currentFeed
        }));
      });
  };

  getFeed = () =>
    new Promise(resolve => {
      let notReadyCount = 0;

      function waitForReady() {
        log('notReadyCount', notReadyCount);
        notReadyCount++;
        return this.state.readyState || notReadyCount === 5
          ? resolve(this.state.combinedFeed)
          : setTimeout(waitForReady, 100);
      }
      log('are we ready?', this.state.readyState);
      return this.state.readyState
        ? resolve(this.state.combinedFeed)
        : setTimeout(waitForReady, 100);
    });
}

export default NewsFeed;