Support GitLab Issues

Move GitHub Tasks to github namespace `/tasks/github`
Add a new gitlab route `/tasks/gitlab`
Add a new gitlab serializer

Closes #38

Author: bekicot

app/controllers/tasks.js

@@ -4,4 +4,5 @@ import {inject} from '@ember/service';
 export default Controller.extend({
   organizations: inject(),
   queryParams: ['org'],
+
 });

app/controllers/tasks/github.js

@@ -0,0 +1,5 @@
+import Controller from '@ember/controller';
+
+export default Controller.extend({
+
+});

app/models/gitlab-task.js

@@ -0,0 +1,3 @@
+import TaskModel from './task';
+
+export default TaskModel.extend({});

app/router.js

@@ -7,7 +7,10 @@ const Router = EmberRouter.extend({
 });
 
 Router.map(function() {
-  this.route('tasks');
+  this.route('tasks', function() {
+    this.route('gitlab');
+    this.route('github');
+  });
 });
 
 export default Router;

app/routes/tasks.js

@@ -14,44 +14,11 @@ export default Route.extend({
     },
   },
 
-  currentOrg: computed('params.org', function () {
-    return this.get('organizations').fetch(this.get('params')['org']);
-  }),
-
-  model(params) {
-    this.set('params', params);
-    let org = this.get('organizations').fetch(params['org']);
-    let githubParams = [];
-    let store = this.get('store');
-
-    if(org && org.trackers){
-      githubParams = org.trackers
-        .filter((tracker) => tracker.type == 'github')
-        .map((tracker) => tracker.identifier);
-    } else {
-      throw 'Unsupported Org';
-    }
-
-    let tasks = this.github.tasks({orgs: githubParams});
-    tasks.then((data) => {
-      data.forEach(function(task) {
-        task.organization = params['org'];
-        store.pushPayload('github-task', task);
-      });
-      return data;
-    });
-
-    const onlySelectedOrg = (task) => {
-      return task.organization == params['org'];
-    }
-
-    return tasks.then(() => {
-      return this.store.peekAll('github-task').filter(onlySelectedOrg);
-    });
+  beforeModel(transition) {
+    this.set('currentOrg', transition.queryParams['org']);
   },
 
-  setupController(controller, model) {
+  setupController(controller) {
     controller.set('currentOrg', this.get('currentOrg'));
-    controller.set('tasks', model);
-  },
+  }
 });

app/routes/tasks/github.js

@@ -0,0 +1,39 @@
+import Route from '@ember/routing/route';
+import {inject} from '@ember/service';
+import {getTrackerIdentifiers} from '../../utils/task-utils';
+
+export default Route.extend({
+  // services
+  github: inject(),
+  organizations: inject(),
+  store: inject(),
+
+  model(params, transition) {
+    let currentOrg = transition.queryParams['org']
+    let org = this.get('organizations').fetch(currentOrg);
+    let store = this.get('store');
+    let github = this.get('github');
+    let identifiers = getTrackerIdentifiers(org, 'github');
+
+    let tasks = github.tasks({orgs: identifiers});
+    tasks.then((data) => {
+      data.forEach(function(task) {
+        task.organization = currentOrg;
+        store.pushPayload('github-task', task);
+      });
+      return data;
+    });
+
+    const onlySelectedOrg = (task) => {
+      return task.organization == currentOrg;
+    }
+
+    return tasks.then(() => {
+      return store.peekAll('github-task').filter(onlySelectedOrg);
+    });
+  },
+
+  setupController(controller, model) {
+    controller.set('tasks', model);
+  },
+});

app/routes/tasks/gitlab.js

@@ -0,0 +1,16 @@
+import Route from '@ember/routing/route';
+import {inject} from '@ember/service';
+
+export default Route.extend({
+  gitlab: inject(),
+  store: inject(),
+  model() {
+    const store = this.get('store');
+    return this.get('gitlab').tasks({projects: ['coala/mobans']}).then(data => {
+      for (let task of data) {
+        store.pushPayload('gitlab-task', task);
+      }
+      return store.peekAll('gitlab-task');
+    });
+  }
+});

app/routes/tasks/index.js

@@ -0,0 +1,11 @@
+import Route from '@ember/routing/route';
+
+export default Route.extend({
+  beforeModel(transition) {
+    if (transition.queryParams['org']) {
+      this.transitionTo('tasks.github');
+    } else {
+      this.transitionTo('/');
+    }
+  },
+});

app/serializers/gitlab-task.js

@@ -0,0 +1,27 @@
+import DS from 'ember-data';
+
+export default DS.JSONSerializer.extend({
+  pushPayload(store, payload) {
+    const task = {};
+    task.id = payload.id
+    task.bodyText = payload.description
+    task.commentCount = payload.user_notes_count
+    task.updatedAt = payload.updated_at
+    task.url = payload.web_url
+    task.title = payload.title
+
+    task.author = {}
+    task.author.url = payload.author.web_url
+    task.author.login = payload.author.username
+    task.author.avatarUrl = payload.author.avatar_url
+
+    task.repository = {}
+    task.repository.nameWithOwner = payload.repository.path_with_namespace
+    task.repository.url = payload.repository.web_url
+
+    task.isPullRequest = payload._type == 'PullRequest';
+
+    store.push(this.normalize(store.modelFor('gitlab-task'), task));
+    return task;
+  },
+});

app/services/gitlab.js

@@ -0,0 +1,58 @@
+// https://gitlab.com/api/v4/projects/coala%2Fmobans/issues?order_by=created_at&state=opened
+import AjaxService from 'ember-ajax/services/ajax';
+import RSVP from 'rsvp';
+
+const ENDPOINT = 'https://gitlab.com/api/v4';
+const PROJECT_ENDPOINT = ENDPOINT + '/projects/{projectId}'
+const ISSUE_ENDPOINT = PROJECT_ENDPOINT + '/issues?order_by=created_at&state=opened&per_page=100';
+
+function buildIssuesUrl(projectId) {
+  return ISSUE_ENDPOINT.replace('{projectId}', encodeURIComponent(projectId));
+}
+
+function buildProjectUrl(projectId) {
+  return PROJECT_ENDPOINT.replace('{projectId}', encodeURIComponent(projectId));
+}
+
+export default AjaxService.extend({
+  host: 'https://gitlab.com/',
+  _issueUrl: '',
+  init() {
+    this._super(...arguments);
+    this.set('headers', {'Private-Token':  'sVfZzagWtemrV-suxYK-'});
+  },
+
+  tasks({projects}) {
+    let tasks = projects.map((projectId) => {
+      const embedRepoInfo = (tasks) => {
+        return new Promise((resolve, reject) => {
+          this.fetchRepositoryInfo(projectId).then((repoInfo) => {
+            tasks.map((task) => {
+              task.repository = repoInfo;
+              task.type = 'gitlab-task';
+              return task;
+            })
+            resolve(tasks)
+          }).catch((error) => reject(error));
+        });
+      }
+
+      return this.fetchIssues(projectId).then(embedRepoInfo)
+    });
+
+    return RSVP.all(tasks).then((tasks) => {
+      return tasks.reduce((combinedTasks, tasks) => {
+        return combinedTasks.concat(tasks);
+      }, [])
+    })
+  },
+
+  fetchRepositoryInfo(projectId) {
+    return this.request(buildProjectUrl(projectId));
+  },
+
+  fetchIssues(projectId) {
+    return this.request(buildIssuesUrl(projectId));
+  },
+
+});