mirror of https://gitee.com/bigwinds/arangodb
369 lines
14 KiB
JavaScript
369 lines
14 KiB
JavaScript
/*jshint -W051:true, evil:true */
|
|
/*eslint-disable */
|
|
;(function () {
|
|
'use strict'
|
|
/*eslint-enable */
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief module "internal"
|
|
// /
|
|
// / @file
|
|
// /
|
|
// / DISCLAIMER
|
|
// /
|
|
// / Copyright 2004-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 Dr. Frank Celler
|
|
// / @author Copyright 2010-2013, triAGENS GmbH, Cologne, Germany
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
var exports = require('internal');
|
|
var console = require('console');
|
|
var fs = require('fs');
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief db
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
exports.db = global.db;
|
|
delete global.db;
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief ArangoCollection
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
exports.ArangoCollection = global.ArangoCollection;
|
|
delete global.ArangoCollection;
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief ArangoDatabase
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
exports.ArangoDatabase = global.ArangoDatabase;
|
|
delete global.ArangoDatabase;
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief ShapedJson stub object - only here for compatibility with 2.8
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
exports.ShapedJson = function () {};
|
|
delete global.ShapedJson;
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief enableStatistics
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
exports.enableStatistics = global.ENABLE_STATISTICS;
|
|
delete global.ENABLE_STATISTICS;
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief dispatcherThreads
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
exports.dispatcherThreads = global.DISPATCHER_THREADS;
|
|
delete global.DISPATCHER_THREADS;
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief frontendVersionCheck
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
exports.frontendVersionCheck = global.FE_VERSION_CHECK;
|
|
delete global.FE_VERSION_CHECK;
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief reloadRouting
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
exports.reloadRouting = function () {
|
|
require('@arangodb/actions').reloadRouting();
|
|
};
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief resets engine in development mode
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
exports.resetEngine = function () {
|
|
require('@arangodb/actions').reloadRouting();
|
|
};
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief rebuilds the authentication cache
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
exports.reloadAuth = global.RELOAD_AUTH;
|
|
delete global.RELOAD_AUTH;
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief write-ahead log object
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
exports.wal = {
|
|
flush: function () {
|
|
return global.WAL_FLUSH.apply(null, arguments);
|
|
},
|
|
|
|
properties: function () {
|
|
return global.WAL_PROPERTIES.apply(null, arguments);
|
|
},
|
|
|
|
transactions: function () {
|
|
return global.WAL_TRANSACTIONS.apply(null, arguments);
|
|
},
|
|
|
|
waitForCollector: function () {
|
|
return global.WAL_WAITCOLLECTOR.apply(null, arguments);
|
|
}
|
|
};
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief defines an action
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
if (global.SYS_DEFINE_ACTION) {
|
|
exports.defineAction = global.SYS_DEFINE_ACTION;
|
|
delete global.SYS_DEFINE_ACTION;
|
|
}
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief throw-collection-not-loaded
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
if (global.THROW_COLLECTION_NOT_LOADED) {
|
|
exports.throwOnCollectionNotLoaded = global.THROW_COLLECTION_NOT_LOADED;
|
|
delete global.THROW_COLLECTION_NOT_LOADED;
|
|
}
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief autoload modules from database
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
// autoload specific modules
|
|
exports.autoloadModules = function () {
|
|
console.debug('autoloading actions');
|
|
var modules = exports.db._collection('_modules');
|
|
|
|
if (modules !== null) {
|
|
modules = modules.byExample({ autoload: true }).toArray();
|
|
modules.forEach(function (module) {
|
|
|
|
// this module is only meant to be executed in one thread
|
|
if (exports.threadNumber !== 0 && !module.perThread) {
|
|
return;
|
|
}
|
|
|
|
console.debug('autoloading module: %s', module.path);
|
|
|
|
try {
|
|
|
|
// require a module
|
|
if (module.path !== undefined) {
|
|
require(module.path);
|
|
}
|
|
|
|
// execute a user function
|
|
else if (module.func !== undefined) {
|
|
/*eslint-disable */
|
|
var func = new Function(module.func)
|
|
/*eslint-enable */
|
|
func();
|
|
}
|
|
} catch (err) {
|
|
console.error('error while loading startup module "%s": %s', module.name || module.path, String(err));
|
|
}
|
|
});
|
|
}
|
|
|
|
console.debug('autoloading actions finished');
|
|
};
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief executes a string in all V8 contexts
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
if (global.SYS_EXECUTE_GLOBAL_CONTEXT_FUNCTION) {
|
|
exports.executeGlobalContextFunction = global.SYS_EXECUTE_GLOBAL_CONTEXT_FUNCTION;
|
|
}else {
|
|
exports.executeGlobalContextFunction = function () {
|
|
// nothing to do. we're probably in --no-server mode
|
|
};
|
|
}
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief reloads the AQL user functions
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
if (global.SYS_EXECUTE_GLOBAL_CONTEXT_FUNCTION) {
|
|
exports.reloadAqlFunctions = function () {
|
|
exports.executeGlobalContextFunction('reloadAql');
|
|
require('@arangodb/aql').reload();
|
|
};
|
|
delete global.SYS_EXECUTE_GLOBAL_CONTEXT_FUNCTION;
|
|
}else {
|
|
exports.reloadAqlFunctions = function () {
|
|
require('@arangodb/aql').reload();
|
|
};
|
|
}
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief getStateReplicationLogger
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
if (global.REPLICATION_LOGGER_STATE) {
|
|
exports.getStateReplicationLogger = global.REPLICATION_LOGGER_STATE;
|
|
delete global.REPLICATION_LOGGER_STATE;
|
|
}
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief tickRangesReplicationLogger
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
if (global.REPLICATION_LOGGER_TICK_RANGES) {
|
|
exports.tickRangesReplicationLogger = global.REPLICATION_LOGGER_TICK_RANGES;
|
|
delete global.REPLICATION_LOGGER_TICK_RANGES;
|
|
}
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief firstTickReplicationLogger
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
if (global.REPLICATION_LOGGER_FIRST_TICK) {
|
|
exports.firstTickReplicationLogger = global.REPLICATION_LOGGER_FIRST_TICK;
|
|
delete global.REPLICATION_LOGGER_FIRST_TICK;
|
|
}
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief configureReplicationApplier
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
if (global.REPLICATION_APPLIER_CONFIGURE) {
|
|
exports.configureReplicationApplier = global.REPLICATION_APPLIER_CONFIGURE;
|
|
delete global.REPLICATION_APPLIER_CONFIGURE;
|
|
}
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief startReplicationApplier
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
if (global.REPLICATION_APPLIER_START) {
|
|
exports.startReplicationApplier = global.REPLICATION_APPLIER_START;
|
|
delete global.REPLICATION_APPLIER_START;
|
|
}
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief shutdownReplicationApplier
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
if (global.REPLICATION_APPLIER_SHUTDOWN) {
|
|
exports.shutdownReplicationApplier = global.REPLICATION_APPLIER_SHUTDOWN;
|
|
delete global.REPLICATION_APPLIER_SHUTDOWN;
|
|
}
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief getStateReplicationApplier
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
if (global.REPLICATION_APPLIER_STATE) {
|
|
exports.getStateReplicationApplier = global.REPLICATION_APPLIER_STATE;
|
|
delete global.REPLICATION_APPLIER_STATE;
|
|
}
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief forgetStateReplicationApplier
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
if (global.REPLICATION_APPLIER_FORGET) {
|
|
exports.forgetStateReplicationApplier = global.REPLICATION_APPLIER_FORGET;
|
|
delete global.REPLICATION_APPLIER_FORGET;
|
|
}
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief sychronizeReplication
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
if (global.REPLICATION_SYNCHRONIZE) {
|
|
exports.synchronizeReplication = global.REPLICATION_SYNCHRONIZE;
|
|
delete global.REPLICATION_SYNCHRONIZE;
|
|
}
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief serverId
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
if (global.REPLICATION_SERVER_ID) {
|
|
exports.serverId = global.REPLICATION_SERVER_ID;
|
|
delete global.REPLICATION_SERVER_ID;
|
|
}
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief loadStartup
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
exports.loadStartup = function (path) {
|
|
return exports.load(fs.join(exports.startupPath, path));
|
|
};
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief raw request body
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
if (global.SYS_RAW_REQUEST_BODY) {
|
|
const $_RAW_BODY_BUFFER = Symbol.for('@arangodb/request.rawBodyBuffer');
|
|
const getRawBodyBuffer = global.SYS_RAW_REQUEST_BODY;
|
|
exports.rawRequestBody = function (req) {
|
|
return req[$_RAW_BODY_BUFFER] || getRawBodyBuffer(req);
|
|
};
|
|
delete global.SYS_RAW_REQUEST_BODY;
|
|
}
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief request parts
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
if (global.SYS_REQUEST_PARTS) {
|
|
exports.requestParts = global.SYS_REQUEST_PARTS;
|
|
delete global.SYS_REQUEST_PARTS;
|
|
}
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief send chunks
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
if (global.SYS_SEND_CHUNK) {
|
|
exports.sendChunk = global.SYS_SEND_CHUNK;
|
|
delete global.SYS_SEND_CHUNK;
|
|
}
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief default replication factor
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
if (global.SYS_DEFAULT_REPLICATION_FACTOR_SYSTEM) {
|
|
exports.DEFAULT_REPLICATION_FACTOR_SYSTEM = global.SYS_DEFAULT_REPLICATION_FACTOR_SYSTEM;
|
|
delete global.SYS_DEFAULT_REPLICATION_FACTOR_SYSTEM;
|
|
}
|
|
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
// / @brief returns if we are in enterprise version or not
|
|
// //////////////////////////////////////////////////////////////////////////////
|
|
|
|
if (global.SYS_IS_ENTERPRISE) {
|
|
exports.isEnterprise = global.SYS_IS_ENTERPRISE;
|
|
delete global.SYS_IS_ENTERPRISE;
|
|
}
|
|
|
|
}());
|