blob: 96dd970af3e6106a1ef61b8b2e6f4e5aa6be0040 [file] [log] [blame]
/**
* Create database in Cloudant account:
* https://docs.cloudant.com/database.html#get-databases
**/
function main(message) {
var cloudantOrError = getCloudantAccount(message);
if (typeof cloudantOrError !== 'object') {
return Promise.reject(cloudantOrError);
}
var cloudant = cloudantOrError;
var dbName = message.dbname;
if (!dbName) {
return Promise.reject('dbname is required.');
}
var promise = createDatabase(cloudant, dbName);
return promise;
}
function createDatabase(cloudant, dbName) {
return new Promise(function(resolve, reject) {
cloudant.db.create(dbName, function(error, response) {
if (!error) {
console.log('success', response);
resolve(response);
} else {
console.log('error', error);
reject(error);
}
});
});
}
function getCloudantAccount(message) {
// full cloudant URL - Cloudant NPM package has issues creating valid URLs
// when the username contains dashes (common in Bluemix scenarios)
var cloudantUrl;
if (message.url) {
// use bluemix binding
cloudantUrl = message.url;
} else {
if (!message.host) {
return 'cloudant account host is required.';
}
if (!message.username) {
return 'cloudant account username is required.';
}
if (!message.password) {
return 'cloudant account password is required.';
}
cloudantUrl = "https://" + message.username + ":" + message.password + "@" + message.host;
}
return require('cloudant')({
url: cloudantUrl
});
}