mirror of https://gitee.com/bigwinds/arangodb
339 lines
11 KiB
JavaScript
339 lines
11 KiB
JavaScript
'use strict';
|
|
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
/// @brief ArangoDB Application Launcher Utilities
|
|
///
|
|
/// @file
|
|
///
|
|
/// DISCLAIMER
|
|
///
|
|
/// Copyright 2013 triAGENS GmbH, Cologne, Germany
|
|
///
|
|
/// Licensed under the Apache License, Version 2.0 (the "License");
|
|
/// you may not use this file except in compliance with the License.
|
|
/// You may obtain a copy of the License at
|
|
///
|
|
/// http://www.apache.org/licenses/LICENSE-2.0
|
|
///
|
|
/// Unless required by applicable law or agreed to in writing, software
|
|
/// distributed under the License is distributed on an "AS IS" BASIS,
|
|
/// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
/// See the License for the specific language governing permissions and
|
|
/// limitations under the License.
|
|
///
|
|
/// Copyright holder is triAGENS GmbH, Cologne, Germany
|
|
///
|
|
/// @author Jan Steemann
|
|
/// @author Dr. Frank Celler
|
|
/// @author Michael Hackstein
|
|
/// @author Copyright 2014, triAGENS GmbH, Cologne, Germany
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
|
|
var joi = require("joi");
|
|
var fs = require("fs");
|
|
var _ = require('lodash');
|
|
var arangodb = require("@arangodb");
|
|
var db = arangodb.db;
|
|
var internal = require('internal');
|
|
|
|
var throwFileNotFound = arangodb.throwFileNotFound;
|
|
var errors = arangodb.errors;
|
|
var ArangoError = arangodb.ArangoError;
|
|
var mountRegEx = /^(\/[a-zA-Z0-9_\-%]+)+$/;
|
|
var mountAppRegEx = /\/APP(\/|$)/i;
|
|
var mountNumberRegEx = /^\/[\d\-%]/;
|
|
var pathRegex = /^((\.{0,2}(\/|\\))|(~\/)|[a-zA-Z]:\\)/;
|
|
|
|
var getReadableName = function(name) {
|
|
return name.split(/([-_]|\s)+/).map(function (token) {
|
|
return token.slice(0, 1).toUpperCase() + token.slice(1);
|
|
}).join(' ');
|
|
};
|
|
|
|
var getStorage = function() {
|
|
var c = db._collection("_apps");
|
|
if (c === null) {
|
|
c = db._create("_apps", {isSystem: true, replicationFactor: 1,
|
|
distributeShardsLike: "_graphs", journalSize: 4 * 1024 * 1024});
|
|
c.ensureIndex({ type: "hash", fields: [ "mount" ], unique: true });
|
|
}
|
|
return c;
|
|
};
|
|
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
/// @brief comparator for mount points
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
|
|
var compareMounts = function(l, r) {
|
|
var left = l.mount.toLowerCase();
|
|
var right = r.mount.toLowerCase();
|
|
|
|
if (left < right) {
|
|
return -1;
|
|
}
|
|
return 1;
|
|
};
|
|
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
/// @brief builds a github repository URL
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
|
|
function buildGithubUrl (repository, version) {
|
|
if (version === undefined) {
|
|
version = "master";
|
|
}
|
|
|
|
var urlPrefix = require("process").env.FOXX_BASE_URL;
|
|
if (urlPrefix === undefined) {
|
|
urlPrefix = 'https://github.com/';
|
|
}
|
|
return urlPrefix + repository + '/archive/' + version + '.zip';
|
|
}
|
|
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
/// @brief returns all running Foxx applications
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
|
|
function listJson (showPrefix, onlyDevelopment) {
|
|
var mounts = getStorage();
|
|
var cursor;
|
|
if (onlyDevelopment) {
|
|
cursor = mounts.byExample({isDevelopment: true});
|
|
} else {
|
|
cursor = mounts.all();
|
|
}
|
|
return cursor.toArray().map(function (doc) {
|
|
return {
|
|
mountId: doc._key,
|
|
mount: doc.mount,
|
|
name: doc.manifest.name,
|
|
description: doc.manifest.description,
|
|
author: doc.manifest.author,
|
|
system: doc.isSystem || false,
|
|
development: doc.isDevelopment || false,
|
|
contributors: doc.manifest.contributors || false,
|
|
license: doc.manifest.license,
|
|
version: doc.manifest.version,
|
|
path: fs.join(fs.makeAbsolute(doc.root || internal.appPath), doc.path),
|
|
config: getConfiguration(doc.manifest.configuration, doc.options.configuration),
|
|
deps: getDependencies(doc.manifest.dependencies, doc.options.dependencies),
|
|
scripts: getScripts(doc.manifest.scripts),
|
|
collectionPrefix: showPrefix ? doc.options.collectionPrefix : undefined
|
|
};
|
|
});
|
|
}
|
|
|
|
function getScripts(scripts) {
|
|
var names = {};
|
|
_.each(scripts, function (script, name) {
|
|
names[name] = getReadableName(name);
|
|
});
|
|
return names;
|
|
}
|
|
|
|
function getConfiguration(definitions, options) {
|
|
var cfg = {};
|
|
_.each(definitions, function (definition, name) {
|
|
cfg[name] = _.clone(definition);
|
|
cfg[name].title = getReadableName(name);
|
|
cfg[name].current = options[name];
|
|
});
|
|
return cfg;
|
|
}
|
|
|
|
function getDependencies(definitions, options) {
|
|
var deps = {};
|
|
_.each(definitions, function (definition, name) {
|
|
deps[name] = {
|
|
definition: definition,
|
|
title: getReadableName(name),
|
|
current: options[name]
|
|
};
|
|
});
|
|
return deps;
|
|
}
|
|
|
|
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
/// @brief prints all running Foxx applications
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
|
|
function list(onlyDevelopment) {
|
|
var apps = listJson(undefined, onlyDevelopment);
|
|
|
|
arangodb.printTable(
|
|
apps.sort(compareMounts),
|
|
[ "mount", "name", "author", "description", "version", "development" ],
|
|
{
|
|
prettyStrings: true,
|
|
totalString: "%s application(s) found",
|
|
emptyString: "no applications found",
|
|
rename: {
|
|
"mount": "Mount",
|
|
"name" : "Name",
|
|
"author" : "Author",
|
|
"description" : "Description",
|
|
"version" : "Version",
|
|
"development" : "Development"
|
|
}
|
|
}
|
|
);
|
|
}
|
|
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
/// @brief returns all running Foxx applications in development mode
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
|
|
function listDevelopmentJson (showPrefix) {
|
|
return listJson(showPrefix, true);
|
|
}
|
|
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
/// @brief prints all running Foxx applications
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
|
|
function listDevelopment() {
|
|
return list(true);
|
|
}
|
|
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
/// @brief validate the mount point of an app
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
|
|
function validateMount(mount, internal) {
|
|
if (mount[0] !== "/") {
|
|
throw new ArangoError({
|
|
errorNum: errors.ERROR_INVALID_MOUNTPOINT.code,
|
|
errorMessage: "Mountpoint has to start with /."
|
|
});
|
|
}
|
|
if (!mountRegEx.test(mount)) {
|
|
// Controller routes may be /. Foxxes are not allowed to
|
|
if (!internal || mount.length !== 1) {
|
|
throw new ArangoError({
|
|
errorNum: errors.ERROR_INVALID_MOUNTPOINT.code,
|
|
errorMessage: "Mountpoint can only contain a-z, A-Z, 0-9 or _."
|
|
});
|
|
}
|
|
}
|
|
if (!internal) {
|
|
// routes starting with _ are disallowed...
|
|
// ...except they start with _open. the _open prefix provides a non-authenticated
|
|
// way to access routes
|
|
if (mount[1] === "_" && ! /^\/_open\//.test(mount)) {
|
|
throw new ArangoError({
|
|
errorNum: errors.ERROR_INVALID_MOUNTPOINT.code,
|
|
errorMessage: "/_ apps are reserved for internal use."
|
|
});
|
|
}
|
|
if (mountNumberRegEx.test(mount)) {
|
|
throw new ArangoError({
|
|
errorNum: errors.ERROR_INVALID_MOUNTPOINT.code,
|
|
errorMessage: "Mointpoints are not allowed to start with a number, - or %."
|
|
});
|
|
}
|
|
if (mountAppRegEx.test(mount)) {
|
|
throw new ArangoError({
|
|
errorNum: errors.ERROR_INVALID_MOUNTPOINT.code,
|
|
errorMessage: "Mountpoint is not allowed to contain /app/."
|
|
});
|
|
}
|
|
}
|
|
return true;
|
|
}
|
|
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
/// @brief validate an app name and fail if it is invalid
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
|
|
function validateServiceName (name) {
|
|
if (typeof name === 'string' && name.length > 0) {
|
|
return;
|
|
}
|
|
|
|
throw new ArangoError({
|
|
errorNum: errors.ERROR_APPLICATION_INVALID_NAME.code,
|
|
errorMessage: errors.ERROR_APPLICATION_INVALID_NAME.message
|
|
});
|
|
}
|
|
|
|
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
/// @brief get the app mounted at this mount point
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
|
|
function mountedService (mount) {
|
|
return getStorage().firstExample({mount: mount});
|
|
}
|
|
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
/// @brief Update the app mounted at this mountpoint with the new app
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
|
|
function updateService (mount, update) {
|
|
return getStorage().updateByExample({mount: mount}, update);
|
|
}
|
|
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
/// @brief define validators for parameter types
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
|
|
var parameterTypes = {
|
|
integer: joi.number().integer(),
|
|
boolean: joi.boolean(),
|
|
string: joi.string(),
|
|
number: joi.number(),
|
|
json: function (v) {return v && JSON.parse(v);}
|
|
};
|
|
parameterTypes.password = parameterTypes.string;
|
|
parameterTypes.int = parameterTypes.integer;
|
|
parameterTypes.bool = parameterTypes.boolean;
|
|
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
/// @brief creates a zip archive of a foxx app. Returns the absolute path
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
var zipDirectory = function(directory) {
|
|
if (!fs.isDirectory(directory)) {
|
|
throw directory + " is not a directory.";
|
|
}
|
|
var tempFile = fs.getTempFile("zip", false);
|
|
|
|
var tree = fs.listTree(directory);
|
|
var files = [];
|
|
var i;
|
|
var filename;
|
|
|
|
for (i = 0; i < tree.length; ++i) {
|
|
filename = fs.join(directory, tree[i]);
|
|
|
|
if (fs.isFile(filename)) {
|
|
files.push(tree[i]);
|
|
}
|
|
}
|
|
if (files.length === 0) {
|
|
throwFileNotFound("Directory '" + String(directory) + "' is empty");
|
|
}
|
|
fs.zipFile(tempFile, directory, files);
|
|
return tempFile;
|
|
};
|
|
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
/// @brief Exports
|
|
////////////////////////////////////////////////////////////////////////////////
|
|
|
|
exports.mountedService = mountedService;
|
|
exports.updateService = updateService;
|
|
exports.getReadableName = getReadableName;
|
|
exports.list = list;
|
|
exports.listJson = listJson;
|
|
exports.listDevelopment = listDevelopment;
|
|
exports.listDevelopmentJson = listDevelopmentJson;
|
|
exports.buildGithubUrl = buildGithubUrl;
|
|
exports.validateServiceName = validateServiceName;
|
|
exports.validateMount = validateMount;
|
|
exports.parameterTypes = parameterTypes;
|
|
exports.zipDirectory = zipDirectory;
|
|
exports.getStorage = getStorage;
|
|
exports.pathRegex = pathRegex;
|
|
|