126 lines
4.2 KiB
JavaScript
126 lines
4.2 KiB
JavaScript
'use strict';
|
|
|
|
var common = require('./common.js'),
|
|
debug = require('debug')('e2e:appstore'),
|
|
request = require('superagent-sync'),
|
|
sleep = require('sleep').sleep,
|
|
stripe = require('stripe');
|
|
|
|
exports = module.exports = AppStore;
|
|
|
|
function AppStore(origin) {
|
|
this._origin = origin;
|
|
|
|
// credentials for api calls
|
|
this._credentials = {
|
|
password: null,
|
|
accessToken: null
|
|
};
|
|
}
|
|
|
|
AppStore.prototype.getAccessToken = function (user) {
|
|
var res = request.get(this._origin + '/api/v1/login').auth(user.email, user.password).end();
|
|
common.verifyResponse(res, 'Could not login as user:' + user.email + ' password:' + user.password);
|
|
return res.body.accessToken;
|
|
};
|
|
|
|
AppStore.prototype.setCredentials = function (password, accessToken) {
|
|
this._credentials = { password: password, accessToken: accessToken };
|
|
};
|
|
|
|
AppStore.prototype.getCloudrons = function () {
|
|
var res = request.get(this._origin + '/api/v1/cloudrons').query({ accessToken: this._credentials.accessToken, page: 1, per_page: 50 }).end();
|
|
return res.body.boxes;
|
|
};
|
|
|
|
AppStore.prototype.waitForCloudron = function (boxId) {
|
|
var creationTime = new Date();
|
|
process.stdout.write('Waiting for cloudron to come up.');
|
|
|
|
var boxInfo = null, res;
|
|
|
|
while (true) {
|
|
sleep(10);
|
|
process.stdout.write('.');
|
|
res = request.get(this._origin + '/api/v1/cloudrons/' + boxId).query({ accessToken: this._credentials.accessToken }).end();
|
|
common.verifyResponse(res, 'Could not query cloudron status');
|
|
|
|
boxInfo = res.body.box;
|
|
if (boxInfo.status === 'ready') {
|
|
debug();
|
|
break;
|
|
}
|
|
}
|
|
|
|
debug('Box created in %s minutes with IP:%s'.green, (new Date() - creationTime) / 60000, res.body.box.ip);
|
|
|
|
// even if the cloudron sent heartbeat to appstore, doesn't mean we can contact the cloudron thanks to DO networking insanity
|
|
process.stdout.write('Waiting for Cloudron to be reachable.');
|
|
while (true) {
|
|
sleep(10);
|
|
process.stdout.write('.');
|
|
res = request.get('https://' + boxInfo.ip).end();
|
|
if (!res.error) break;
|
|
debug(res.error);
|
|
}
|
|
return boxInfo;
|
|
};
|
|
|
|
AppStore.prototype.createCloudron = function (box) {
|
|
var accessToken = this._credentials.accessToken;
|
|
var res = request.post(this._origin + '/api/v1/cloudrons').send(box).query({ accessToken: accessToken }).end();
|
|
common.verifyResponse(res, 'Could not create cloudron');
|
|
|
|
debug('Cloudron %s created'.green, box.domain);
|
|
return res.body.box;
|
|
};
|
|
|
|
AppStore.prototype.deleteCloudron = function (box) {
|
|
var res = request.post(this._origin + '/api/v1/cloudrons/' + box.id)
|
|
.query({ accessToken: this._credentials.accessToken })
|
|
.set('X-HTTP-Method-Override', 'DELETE')
|
|
.send({ password: this._credentials.password })
|
|
.end();
|
|
common. verifyResponse(res, 'Could not delete cloudron');
|
|
};
|
|
|
|
AppStore.prototype.getManifest = function (appId, version) {
|
|
var res = request.get(this._origin + '/api/v1/apps/' + appId + '/versions/' + version).end();
|
|
common.verifyResponse(res, 'Could not get get app manifest');
|
|
return res.body.manifest;
|
|
};
|
|
|
|
AppStore.prototype.restore = function (boxId, backupId) {
|
|
var res = request.post(this._origin + '/api/v1/cloudrons/' + boxId + '/restore/' + backupId).query({ accessToken: this._credentials.accessToken }).end();
|
|
common.verifyResponse(res, 'Could not restore cloudron');
|
|
};
|
|
|
|
AppStore.prototype.setupBilling = function (callback) {
|
|
var stripeApi = stripe(common.stripeSecret());
|
|
|
|
var that = this;
|
|
|
|
stripeApi.tokens.create({
|
|
card: {
|
|
number: '4242424242424242',
|
|
exp_month: 12,
|
|
exp_year: 2016,
|
|
cvc: '123'
|
|
}
|
|
}, function (error, token) {
|
|
if (error) return callback(error);
|
|
|
|
debug('Got stripe token', token.id);
|
|
|
|
var data = {
|
|
password: that._credentials.password,
|
|
billingToken: token.id
|
|
};
|
|
|
|
var res = request.put(that._origin + '/api/v1/users').send(data).query({ accessToken: that._credentials.accessToken }).end();
|
|
common.verifyResponse(res, 'Could not setup billing');
|
|
|
|
callback(null);
|
|
});
|
|
};
|