woodpecker/cmd/drone-server/static/scripts/services/repos.js

'use strict';

(function () {

	/**
	 * The RepoService provides access to repository
	 * data using REST API calls.
	 */
	function RepoService($http, $window) {

		var callback,
			websocket,
			token = localStorage.getItem('access_token');

		/**
		 * Gets a list of all repositories.
		 */
		this.list = function() {
			return $http.get('/api/user/repos');
		};

		/**
		 * Gets a repository by name.
		 *
		 * @param {string} Name of the repository.
		 */
		this.get = function(repoName) {
			return $http.get('/api/repos/'+repoName);
		};

		/**
		 * Creates a new repository.
		 *
		 * @param {object} JSON representation of a repository.
		 */
		this.post = function(repoName) {
			return $http.post('/api/repos/' + repoName);
		};

		/**
		 * Updates an existing repository.
		 *
		 * @param {object} JSON representation of a repository.
		 */
		this.update = function(repo) {
			return $http.patch('/api/repos/'+repo.full_name, repo);
		};

		/**
		 * Deletes a repository.
		 *
		 * @param {string} Name of the repository.
		 */
		this.delete = function(repoName) {
			return $http.delete('/api/repos/'+repoName);
		};

		/**
		 * Watch a repository.
		 *
		 * @param {string} Name of the repository.
		 */
		this.watch = function(repoName) {
			return $http.post('/api/repos/'+repoName+'/watch');
		};

		/**
		 * Unwatch a repository.
		 *
		 * @param {string} Name of the repository.
		 */
		this.unwatch = function(repoName) {
			return $http.delete('/api/repos/'+repoName+'/unwatch');
		};


		var callback,
			events,
			token = localStorage.getItem('access_token');

		/**
		 * Subscribes to a live update feed for a repository
		 *
		 * @param {string} Name of the repository.
		 */
		this.subscribe = function(repo, _callback) {
			callback = _callback;

			events = new EventSource("/api/stream/" + repo + "?access_token=" + token, { withCredentials: true });
			events.onmessage = function (event) {
				if (callback !== undefined) {
					callback(angular.fromJson(event.data));
				}
			};
			events.onerror = function (event) {
				callback = undefined;
				if (events !== undefined) {
					events.close();
					events = undefined;
				}
				console.log('user event stream closed due to error.', event);
			};
		};

		this.unsubscribe = function() {
			callback = undefined;
			if (events !== undefined) {
				events.close();
				events = undefined;
			}
		};
	}

	angular
		.module('drone')
		.service('repos', RepoService);
})();