Johannes Zellner
47d2d957aa
This allows us to logout if any request fails due to invalid token. This can for example happen if you revoke the tokens for the webadmin.
515 lines
19 KiB
JavaScript
515 lines
19 KiB
JavaScript
'use strict';
|
|
|
|
/* global angular */
|
|
/* global EventSource */
|
|
|
|
angular.module('Application').service('Client', function ($http) {
|
|
var client = null;
|
|
|
|
function ClientError(statusCode, message) {
|
|
Error.call(this);
|
|
this.name = this.constructor.name;
|
|
this.statusCode = statusCode;
|
|
if (typeof message == 'string') {
|
|
this.message = message;
|
|
} else {
|
|
this.message = JSON.stringify(message);
|
|
}
|
|
}
|
|
|
|
function defaultErrorHandler(callback) {
|
|
return function (data, status) {
|
|
if (status === 401) return client.logout();
|
|
callback(new ClientError(status, data));
|
|
};
|
|
}
|
|
|
|
function Client() {
|
|
this._ready = false;
|
|
this._configListener = [];
|
|
this._readyListener = [];
|
|
this._userInfo = {
|
|
username: null,
|
|
email: null,
|
|
admin: false
|
|
};
|
|
this._token = null;
|
|
this._clientId = 'cid-webadmin';
|
|
this._clientSecret = 'unused';
|
|
this._config = {
|
|
appServerUrl: null,
|
|
fqdn: null,
|
|
ip: null,
|
|
revision: null,
|
|
update: null,
|
|
isDev: false
|
|
};
|
|
this._installedApps = [];
|
|
|
|
this.setToken(localStorage.token);
|
|
}
|
|
|
|
Client.prototype.setReady = function () {
|
|
if (this._ready) return;
|
|
|
|
this._ready = true;
|
|
this._readyListener.forEach(function (callback) {
|
|
callback();
|
|
});
|
|
};
|
|
|
|
Client.prototype.onReady = function (callback) {
|
|
if (this._ready) callback();
|
|
this._readyListener.push(callback);
|
|
};
|
|
|
|
Client.prototype.onConfig = function (callback) {
|
|
this._configListener.push(callback);
|
|
callback(this._config);
|
|
};
|
|
|
|
Client.prototype.setUserInfo = function (userInfo) {
|
|
// In order to keep the angular bindings alive, set each property individually
|
|
this._userInfo.username = userInfo.username;
|
|
this._userInfo.email = userInfo.email;
|
|
this._userInfo.admin = !!userInfo.admin;
|
|
};
|
|
|
|
Client.prototype.setConfig = function (config) {
|
|
// In order to keep the angular bindings alive, set each property individually
|
|
this._config.appServerUrl = config.appServerUrl;
|
|
this._config.version = config.version;
|
|
this._config.fqdn = config.fqdn;
|
|
this._config.ip = config.ip;
|
|
this._config.revision = config.revision;
|
|
this._config.update = config.update;
|
|
this._config.isDev = config.appServerUrl === 'https://appstore-dev.herokuapp.com' || config.appServerUrl === 'https://selfhost.io:5050';
|
|
|
|
var that = this;
|
|
|
|
this._configListener.forEach(function (callback) {
|
|
callback(that._config);
|
|
});
|
|
};
|
|
|
|
Client.prototype.getInstalledApps = function () {
|
|
return this._installedApps;
|
|
};
|
|
|
|
Client.prototype.getUserInfo = function () {
|
|
return this._userInfo;
|
|
};
|
|
|
|
Client.prototype.getConfig = function () {
|
|
return this._config;
|
|
};
|
|
|
|
Client.prototype.setToken = function (token) {
|
|
$http.defaults.headers.common.Authorization = 'Bearer ' + token;
|
|
if (!token) localStorage.removeItem('token');
|
|
else localStorage.token = token;
|
|
this._token = token;
|
|
};
|
|
|
|
/*
|
|
* Rest API wrappers
|
|
*/
|
|
Client.prototype.config = function (callback) {
|
|
$http.get('/api/v1/config').success(function(data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null, data);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.userInfo = function (callback) {
|
|
$http.get('/api/v1/profile').success(function(data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null, data);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.createVolume = function (name, password, callback) {
|
|
var data = { password: password, name: name };
|
|
$http.post('/api/v1/volume/create', data).success(function(data, status) {
|
|
if (status !== 201) return callback(new ClientError(status, data));
|
|
callback(null, data);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.deleteVolume = function (name, password, callback) {
|
|
var data = { password: password };
|
|
$http.post('/api/v1/volume/' + name + '/delete', data).success(function(data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null, data);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.mount = function (name, password, callback) {
|
|
var data = { password: password };
|
|
$http.post('/api/v1/volume/' + name + '/mount', data).success(function(data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null, data);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.unmount = function (name, password, callback) {
|
|
var data = { password: password };
|
|
$http.post('/api/v1/volume/' + name + '/unmount', data).success(function(data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null, data);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.isMounted = function (name, callback) {
|
|
$http.get('/api/v1/volume/' + name + '/ismounted').success(function(data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null, data.mounted);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.listVolumes = function (callback) {
|
|
$http.get('/api/v1/volume/list').success(function(data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null, data.volumes);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.addUserToVolume = function (username, volumeId, password, callback) {
|
|
var data = { username: username, password: password };
|
|
$http.post('/api/v1/volume/' + volumeId + '/users', data).success(function (data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.removeUserFromVolume = function (username, volumeId, password, callback) {
|
|
var data = { headers: {password: password} };
|
|
$http({ method: 'DELETE', url: '/api/v1/volume/' + volumeId + '/users/' + username, data: data, headers: { 'Content-Type': 'application/json' }}).success(function (data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.installApp = function (id, password, title, config, callback) {
|
|
var that = this;
|
|
var data = { appStoreId: id, password: password, location: config.location, portBindings: config.portBindings };
|
|
$http.post('/api/v1/app/install', data).success(function (data, status) {
|
|
if (status !== 200 || !data.id) return callback(new ClientError(status, data));
|
|
|
|
// put new app with amended title in cache
|
|
data.manifest = { title: title };
|
|
that._installedApps.push(data);
|
|
|
|
callback(null, data.id);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.configureApp = function (id, password, config, callback) {
|
|
var data = { appId: id, password: password, location: config.location, portBindings: config.portBindings };
|
|
$http.post('/api/v1/app/' + id + '/configure', data).success(function (data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.updateApp = function (id, callback) {
|
|
$http.post('/api/v1/app/' + id + '/update', { }).success(function (data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.startApp = function (id, callback) {
|
|
var data = { };
|
|
$http.post('/api/v1/app/' + id + '/start', data).success(function (data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.stopApp = function (id, callback) {
|
|
var data = { };
|
|
$http.post('/api/v1/app/' + id + '/stop', data).success(function (data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.version = function (callback) {
|
|
$http.get('/api/v1/version').success(function(data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null, data);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.isServerFirstTime = function (callback) {
|
|
$http.get('/api/v1/firsttime').success(function(data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null, !data.activated);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.getNakedDomain = function (callback) {
|
|
$http.get('/api/v1/settings/naked_domain')
|
|
.success(function (data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null, data.appid);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.setNakedDomain = function (appid, callback) {
|
|
$http.post('/api/v1/settings/naked_domain', { appid: appid || '' }).success(function (data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.getApps = function (callback) {
|
|
$http.get('/api/v1/apps').success(function (data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null, data.apps);
|
|
});
|
|
};
|
|
|
|
Client.prototype.getApp = function (appId, callback) {
|
|
var appFound = null;
|
|
this._installedApps.some(function (app) {
|
|
if (app.id === appId) {
|
|
appFound = app;
|
|
return true;
|
|
} else {
|
|
return false;
|
|
}
|
|
});
|
|
|
|
if (appFound) return callback(null, appFound);
|
|
else return callback(new Error('App not found'));
|
|
};
|
|
|
|
Client.prototype.removeApp = function (appId, callback) {
|
|
$http.post('/api/v1/app/' + appId + '/uninstall').success(function (data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.getAppLogStream = function (appId) {
|
|
var source = new EventSource('/api/v1/app/' + appId + '/logstream');
|
|
return source;
|
|
};
|
|
|
|
Client.prototype.getAppLogUrl = function (appId) {
|
|
return '/api/v1/app/' + appId + '/logs?access_token=' + this._token;
|
|
};
|
|
|
|
Client.prototype.setAdmin = function (username, admin, callback) {
|
|
var payload = {
|
|
username: username,
|
|
admin: admin
|
|
};
|
|
|
|
$http.post('/api/v1/users/' + username + '/admin', payload).success(function (data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.createAdmin = function (username, password, email, callback) {
|
|
var payload = {
|
|
username: username,
|
|
password: password,
|
|
email: email
|
|
};
|
|
|
|
var that = this;
|
|
|
|
$http.post('/api/v1/createadmin', payload).success(function(data, status) {
|
|
if (status !== 201) return callback(new ClientError(status, data));
|
|
|
|
that.setToken(data.token);
|
|
that.setUserInfo(data.userInfo);
|
|
|
|
callback(null, data.activated);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.listUsers = function (callback) {
|
|
$http.get('/api/v1/users').success(function(data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null, data);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.stats = function (callback) {
|
|
$http.get('/api/v1/stats').success(function(data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null, data);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.getOAuthClients = function (callback) {
|
|
$http.get('/api/v1/oauth/clients').success(function(data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null, data.clients);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.delTokensByClientId = function (id, callback) {
|
|
$http.delete('/api/v1/oauth/clients/' + id + '/tokens').success(function(data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null, data);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.update = function (callback) {
|
|
$http.get('/api/v1/update').success(function(data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null, data);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.reboot = function (callback) {
|
|
$http.get('/api/v1/reboot').success(function(data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null, data);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.backup = function (callback) {
|
|
$http.post('/api/v1/backups').success(function(data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null, data);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.graphs = function (targets, from, callback) {
|
|
var config = {
|
|
params: {
|
|
target: targets,
|
|
format: 'json',
|
|
from: from
|
|
}
|
|
};
|
|
|
|
$http.get('/api/v1/graphs', config).success(function (data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null, data);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.createUser = function (username, password, email, callback) {
|
|
var data = {
|
|
username: username,
|
|
password: password,
|
|
email: email
|
|
};
|
|
|
|
$http.post('/api/v1/users', data).success(function(data, status) {
|
|
if (status !== 201) return callback(new ClientError(status, data));
|
|
callback(null, data);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.removeUser = function (username, password, callback) {
|
|
var data = {
|
|
username: username,
|
|
password: password
|
|
};
|
|
|
|
$http({ method: 'DELETE', url: '/api/v1/users/' + username, data: data, headers: { 'Content-Type': 'application/json' }}).success(function(data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null, data);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.changePassword = function (currentPassword, newPassword, callback) {
|
|
var data = {
|
|
password: currentPassword,
|
|
newPassword: newPassword
|
|
};
|
|
|
|
$http.post('/api/v1/users/' + this._userInfo.username + '/password', data).success(function(data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
callback(null, data);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
Client.prototype.refreshConfig = function (callback) {
|
|
var that = this;
|
|
|
|
callback = typeof callback === 'function' ? callback : function () {};
|
|
|
|
this.config(function (error, result) {
|
|
if (error) return callback(error);
|
|
|
|
that.setConfig(result);
|
|
callback(null);
|
|
});
|
|
};
|
|
|
|
Client.prototype.refreshInstalledApps = function (callback) {
|
|
var that = this;
|
|
|
|
callback = typeof callback === 'function' ? callback : function () {};
|
|
|
|
this.getApps(function (error, apps) {
|
|
if (error) return callback(error);
|
|
|
|
// insert or update new apps
|
|
apps.forEach(function (app) {
|
|
var found = false;
|
|
|
|
for (var i = 0; i < that._installedApps.length; ++i) {
|
|
if (that._installedApps[i].id === app.id) {
|
|
found = i;
|
|
break;
|
|
}
|
|
}
|
|
|
|
if (found !== false) {
|
|
angular.copy(app, that._installedApps[found]);
|
|
} else {
|
|
that._installedApps.push(app);
|
|
}
|
|
});
|
|
|
|
// filter out old entries, going backwards to allow splicing
|
|
for(var i = that._installedApps.length - 1; i >= 0; --i) {
|
|
if (!apps.some(function (elem) { return (elem.id === that._installedApps[i].id); })) {
|
|
that._installedApps.splice(i, 1);
|
|
}
|
|
|
|
}
|
|
|
|
callback(null);
|
|
});
|
|
};
|
|
|
|
Client.prototype.logout = function () {
|
|
this.setToken(null);
|
|
this._userInfo = {};
|
|
|
|
// logout from OAuth session
|
|
window.location.href = '/api/v1/session/logout';
|
|
};
|
|
|
|
Client.prototype.exchangeCodeForToken = function (authCode, callback) {
|
|
var data = {
|
|
grant_type: 'authorization_code',
|
|
code: authCode,
|
|
redirect_uri: window.location.origin,
|
|
client_id: this._clientId,
|
|
client_secret: this._clientSecret
|
|
};
|
|
|
|
$http.post('/api/v1/oauth/token?response_type=token&client_id=' + this._clientId, data).success(function(data, status) {
|
|
if (status !== 200) return callback(new ClientError(status, data));
|
|
|
|
callback(null, data.access_token);
|
|
}).error(defaultErrorHandler(callback));
|
|
};
|
|
|
|
client = new Client();
|
|
return client;
|
|
});
|