From 4c2764c747f1480ee7752e43357663f3c321f571 Mon Sep 17 00:00:00 2001
From: Roger Braun <roger@rogerbraun.net>
Date: Wed, 26 Oct 2016 19:03:55 +0200
Subject: .

---
 .../timeline_fetcher/timeline_fetcher.service.js   | 53 ++++++++++++++++++++++
 1 file changed, 53 insertions(+)
 create mode 100644 src/services/timeline_fetcher/timeline_fetcher.service.js

(limited to 'src/services/timeline_fetcher/timeline_fetcher.service.js')

diff --git a/src/services/timeline_fetcher/timeline_fetcher.service.js b/src/services/timeline_fetcher/timeline_fetcher.service.js
new file mode 100644
index 00000000..9013c82e
--- /dev/null
+++ b/src/services/timeline_fetcher/timeline_fetcher.service.js
@@ -0,0 +1,53 @@
+import { upperFirst, camelCase } from 'lodash';
+
+const timelineFetcherServiceFactory = ($ngRedux, apiService, $interval) => {
+  let fetcher;
+
+  const update = ({statuses, timeline, showImmediately}) => {
+    const ccTimeline = camelCase(timeline);
+
+    const action = {
+      type: 'ADD_NEW_STATUSES',
+      data: {
+        statuses,
+        timeline: ccTimeline,
+        showImmediately
+      }
+    };
+
+    $ngRedux.dispatch(action);
+    $ngRedux.dispatch({type: 'UPDATE_TIMESTAMPS'});
+  };
+
+  const fetchAndUpdate = ({timeline = 'friends', older = false, showImmediately = false}) => {
+    const args = { timeline };
+    const timelineData = $ngRedux.getState().statuses.timelines[camelCase(timeline)];
+
+    if(older) {
+      args['until'] = timelineData.minVisibleId;
+    } else {
+      args['since'] = timelineData.maxId;
+    }
+
+    apiService.fetchTimeline(args).
+      then((statuses) => update({statuses, timeline, showImmediately}));
+  };
+
+  const startFetching = ({timeline = 'friends'}) => {
+    fetchAndUpdate({timeline, showImmediately: true});
+
+    const boundFetchAndUpdate = () => fetchAndUpdate({timeline});
+    fetcher = $interval(boundFetchAndUpdate, 10000);
+  };
+
+  const timelineFetcherService = {
+    startFetching,
+    fetchAndUpdate
+  };
+
+  return timelineFetcherService;
+};
+
+timelineFetcherServiceFactory.$inject = ['$ngRedux', 'apiService', '$interval'];
+
+export default timelineFetcherServiceFactory;
-- 
cgit v1.2.3-70-g09d2