cloudron-e2e-test/appstore.js
Girish Ramakrishnan eafda6ce77 Fix path again
2015-07-22 21:03:54 -07:00

122 lines
4.0 KiB
JavaScript

'use strict';
var debug = require('debug')('e2e:appstore'),
fs = require('fs'),
path = require('path'),
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
};
if (fs.existsSync(path.join(__dirname, '../ecosystem.json'))) {
this._ecosystem = require(path.join(__dirname, '../ecosystem.json')); // staging appstore
} else {
this._ecosystem = require(path.join(__dirname, '../keys/appstore/ecosystem-staging.json'));
}
}
function verifyResponse(res, errorMessage) {
if (res.statusCode < 200 || res.statusCode > 299) {
debug('Response error statusCode:%s error:%s body:%j', res.statusCode, res.error, res.body);
debug(errorMessage.red);
throw new Error(errorMessage);
}
}
AppStore.prototype.getAccessToken = function (user) {
var res = request.get(this._origin + '/api/v1/login').auth(user.email, user.password).end();
verifyResponse(res, 'Could not login');
return res.body.accessToken;
};
AppStore.prototype.setCredentials = function (password, accessToken) {
this._credentials = { password: password, accessToken: accessToken };
};
AppStore.prototype.waitForCloudron = function (boxId) {
var creationTime = new Date();
process.stdout.write('Waiting for cloudron to come up.');
while (true) {
sleep(10);
process.stdout.write('.');
var res = request.get(this._origin + '/api/v1/cloudrons/' + boxId).query({ accessToken: this._credentials.accessToken }).end();
verifyResponse(res, 'Could not query cloudron status');
if (res.body.box.status === 'ready') {
debug();
break;
}
}
debug('Box created in %s minutes'.green, (new Date() - creationTime) / 60000);
};
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();
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();
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();
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();
verifyResponse(res, 'Could not restore cloudron');
};
AppStore.prototype.setupBilling = function (callback) {
var stripeApi = stripe(this._ecosystem.env['STRIPE_SECRET']);
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();
verifyResponse(res, 'Could not setup billing');
callback(null);
});
};