summaryrefslogtreecommitdiff
path: root/app/assets/javascripts/vue_pipelines_index/stores/pipelines_store.js
blob: 7ac10086a55cac7b35ff13fda90993c2d649c1c5 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
/* eslint-disable no-underscore-dangle*/
import '../../vue_realtime_listener';

export default class PipelinesStore {
  constructor() {
    this.state = {};

    this.state.pipelines = [];
    this.state.count = {};
    this.state.pageInfo = {};
  }

  storePipelines(pipelines = []) {
    this.state.pipelines = pipelines;
  }

  storeCount(count = {}) {
    this.state.count = count;
  }

  storePagination(pagination = {}) {
    let paginationInfo;

    if (Object.keys(pagination).length) {
      const normalizedHeaders = gl.utils.normalizeHeaders(pagination);
      paginationInfo = gl.utils.parseIntPagination(normalizedHeaders);
    } else {
      paginationInfo = pagination;
    }

    this.state.pageInfo = paginationInfo;
  }

  /**
   * FIXME: Move this inside the component.
   *
   * Once the data is received we will start the time ago loops.
   *
   * Everytime a request is made like retry or cancel a pipeline, every 10 seconds we
   * update the time to show how long as passed.
   *
   */
  startTimeAgoLoops() {
    const startTimeLoops = () => {
      this.timeLoopInterval = setInterval(() => {
        this.$children[0].$children.reduce((acc, component) => {
          const timeAgoComponent = component.$children.filter(el => el.$options._componentTag === 'time-ago')[0];
          acc.push(timeAgoComponent);
          return acc;
        }, []).forEach(e => e.changeTime());
      }, 10000);
    };

    startTimeLoops();

    const removeIntervals = () => clearInterval(this.timeLoopInterval);
    const startIntervals = () => startTimeLoops();

    gl.VueRealtimeListener(removeIntervals, startIntervals);
  }
}