337 lines
12 KiB
JavaScript
337 lines
12 KiB
JavaScript
exports.newBotScripts = function newBotScripts() {
|
|
|
|
let thisObject = {
|
|
loadBotScripts: loadBotScripts,
|
|
initialize: initialize
|
|
}
|
|
|
|
const GITHUB = require('../Server/Github');
|
|
let github = GITHUB.newGithub();
|
|
|
|
const STORAGE = require('../Server/Storage');
|
|
let storage = STORAGE.newStorage();
|
|
|
|
let serverConfig;
|
|
let githubData;
|
|
let storageData;
|
|
let fileSystemData;
|
|
let ecosystem;
|
|
let ecosystemObject;
|
|
|
|
return thisObject;
|
|
|
|
function initialize(pEcosystem, pEcosystemObject, pServerConfig, pGithubData, pStorageData, pFileSystemData, callBackFunction) {
|
|
|
|
serverConfig = pServerConfig;
|
|
githubData = pGithubData;
|
|
fileSystemData = pFileSystemData;
|
|
storageData = pStorageData;
|
|
ecosystem = pEcosystem;
|
|
ecosystemObject = pEcosystemObject;
|
|
|
|
github.initialize(githubData);
|
|
storage.initialize(storageData, serverConfig);
|
|
|
|
callBackFunction();
|
|
}
|
|
|
|
function loadBotScripts(callBackfunction) {
|
|
|
|
try {
|
|
|
|
if (CONSOLE_LOG === true) { console.log("[INFO] BotScripts -> retrieveScripts -> Entering function."); }
|
|
|
|
/*
|
|
|
|
Here we go through the webModules Array and bring them all.
|
|
|
|
*/
|
|
|
|
let modulesToBeRetrieved = 0;
|
|
let modulesRetrieved = 0;
|
|
|
|
for (let i = 0; i < ecosystemObject.devTeams.length; i++) {
|
|
|
|
let devTeam = ecosystemObject.devTeams[i];
|
|
|
|
for (let j = 0; j < devTeam.bots.length; j++) {
|
|
|
|
let bot = devTeam.bots[j];
|
|
|
|
getCommons(devTeam.codeName, bot.repo, onCommons);
|
|
|
|
function onCommons() {
|
|
|
|
for (let k = 0; k < bot.processes.length; k++) {
|
|
|
|
let process = bot.processes[k];
|
|
|
|
modulesToBeRetrieved++;
|
|
getUserBot(devTeam.codeName, bot.repo, process.name, onUserBot);
|
|
|
|
function onUserBot() {
|
|
|
|
modulesRetrieved++;
|
|
|
|
if (modulesRetrieved === modulesToBeRetrieved) {
|
|
|
|
callBackfunction();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
function getCommons(pDevTeam, pRepo, callBack) {
|
|
|
|
let moduleName = "Commons.js";
|
|
let key = pDevTeam + "." + pRepo;
|
|
let path = pDevTeam + "/" + pRepo;
|
|
|
|
switch (serverConfig.configAndPlugins.Location) {
|
|
|
|
case 'Cloud': {
|
|
|
|
if (CONSOLE_LOG === true) { console.log("[INFO] BotScripts -> retrieveScripts -> Cloud -> Entering Case."); }
|
|
|
|
storage.getStorageData(pDevTeam + "/" + "bots", pRepo, moduleName, onDataArrived);
|
|
|
|
function onDataArrived(pData) {
|
|
|
|
try {
|
|
|
|
if (CONSOLE_LOG === true) { console.log("[INFO] BotScripts -> retrieveScripts -> Cloud -> onDataArrived -> Entering function."); }
|
|
|
|
if (pData !== undefined) {
|
|
|
|
let data = pData.toString();
|
|
data = data.trim(); // remove first byte with some encoding.
|
|
|
|
data = browserify(data);
|
|
|
|
storageData.set(key, data);
|
|
|
|
}
|
|
|
|
callBack();
|
|
|
|
}
|
|
catch (err) {
|
|
console.log("[ERROR] BotScripts -> retrieveScripts -> Cloud -> onDataArrived -> Error = " + err);
|
|
}
|
|
}
|
|
|
|
break;
|
|
}
|
|
|
|
case 'File System': {
|
|
|
|
if (CONSOLE_LOG === true) { console.log("[INFO] BotScripts -> retrieveScripts -> File System -> Entering Case."); }
|
|
|
|
let fs = require('fs');
|
|
try {
|
|
let fileName = '../Bots/' + path + "/" + moduleName;
|
|
fs.readFile(fileName, onFileRead);
|
|
|
|
function onFileRead(err, pData) {
|
|
|
|
try {
|
|
|
|
if (CONSOLE_LOG === true) { console.log("[INFO] BotScripts -> retrieveScripts -> File System -> onFileRead -> Entering function."); }
|
|
|
|
if (pData !== undefined) {
|
|
|
|
let data = pData.toString();
|
|
data = data.trim(); // remove first byte with some encoding.
|
|
|
|
data = browserify(data);
|
|
|
|
fileSystemData.set(key, data);
|
|
|
|
}
|
|
|
|
callBack();
|
|
|
|
}
|
|
catch (err) {
|
|
console.log("[ERROR] BotScripts -> retrieveScripts -> File System -> onFileRead -> File = " + fileName + " Error = " + err);
|
|
}
|
|
|
|
}
|
|
}
|
|
catch (err) {
|
|
console.log("[ERROR] BotScripts -> retrieveScripts -> File System -> File = " + fileName + " Error = " + err);
|
|
}
|
|
break;
|
|
}
|
|
|
|
case 'Github': {
|
|
|
|
if (CONSOLE_LOG === true) { console.log("[INFO] BotScripts -> retrieveScripts -> Github -> Entering Case."); }
|
|
|
|
github.getGithubData(path, moduleName, onDataArrived);
|
|
|
|
function onDataArrived(pData) {
|
|
|
|
try {
|
|
|
|
if (pData !== undefined) {
|
|
|
|
let data = pData.toString();
|
|
data = data.trim(); // remove first byte with some encoding.
|
|
|
|
data = browserify(data);
|
|
|
|
githubData.set(key, data);
|
|
|
|
}
|
|
|
|
callBack();
|
|
|
|
}
|
|
catch (err) {
|
|
console.log("[ERROR] BotScripts -> retrieveScripts -> Github -> onDataArrived -> Error = " + err);
|
|
}
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
function getUserBot(pDevTeam, pRepo, pProcess, callBack) {
|
|
|
|
let moduleName = "User.Bot.js";
|
|
let key = pDevTeam + "." + pRepo + "." + pProcess + "/" + moduleName;
|
|
let path = pProcess + "/" + moduleName;
|
|
|
|
switch (serverConfig.configAndPlugins.Location) {
|
|
|
|
case 'Cloud': {
|
|
|
|
if (CONSOLE_LOG === true) { console.log("[INFO] BotScripts -> retrieveScripts -> Cloud -> Entering Case."); }
|
|
|
|
storage.getStorageData(pDevTeam + "/" + "bots", pRepo, path, onDataArrived);
|
|
|
|
function onDataArrived(pData) {
|
|
|
|
try {
|
|
|
|
if (CONSOLE_LOG === true) { console.log("[INFO] BotScripts -> retrieveScripts -> Cloud -> onDataArrived -> Entering function."); }
|
|
|
|
if (pData !== undefined) {
|
|
|
|
let data = pData.toString();
|
|
data = data.trim(); // remove first byte with some encoding.
|
|
|
|
data = browserify(data);
|
|
|
|
storageData.set(key, data);
|
|
|
|
}
|
|
|
|
callBack();
|
|
|
|
}
|
|
catch (err) {
|
|
console.log("[ERROR] BotScripts -> retrieveScripts -> Cloud -> onDataArrived -> Error = " + err);
|
|
}
|
|
}
|
|
|
|
break;
|
|
}
|
|
|
|
case 'File System': {
|
|
|
|
if (CONSOLE_LOG === true) { console.log("[INFO] BotScripts -> retrieveScripts -> File System -> Entering Case."); }
|
|
|
|
let fs = require('fs');
|
|
try {
|
|
let fileName = '../Bots/' + pDevTeam + "/" + pRepo + "/" + path;
|
|
fs.readFile(fileName, onFileRead);
|
|
|
|
function onFileRead(err, pData) {
|
|
|
|
try {
|
|
|
|
if (CONSOLE_LOG === true) { console.log("[INFO] BotScripts -> retrieveScripts -> File System -> onFileRead -> Entering function."); }
|
|
|
|
if (pData !== undefined) {
|
|
|
|
let data = pData.toString();
|
|
data = data.trim(); // remove first byte with some encoding.
|
|
|
|
data = browserify(data);
|
|
|
|
fileSystemData.set(key, data);
|
|
|
|
}
|
|
|
|
callBack();
|
|
|
|
}
|
|
catch (err) {
|
|
console.log("[ERROR] BotScripts -> retrieveScripts -> File System -> onFileRead -> File = " + fileName + " Error = " + err);
|
|
}
|
|
|
|
}
|
|
}
|
|
catch (err) {
|
|
console.log("[ERROR] BotScripts -> retrieveScripts -> File System -> File = " + fileName + " Error = " + err);
|
|
}
|
|
break;
|
|
}
|
|
|
|
case 'Github': {
|
|
|
|
if (CONSOLE_LOG === true) { console.log("[INFO] BotScripts -> retrieveScripts -> Github -> Entering Case."); }
|
|
|
|
github.getGithubData(pDevTeam, pRepo, path, onDataArrived);
|
|
|
|
function onDataArrived(pData) {
|
|
|
|
try {
|
|
|
|
if (pData !== undefined) {
|
|
|
|
let data = pData.toString();
|
|
data = data.trim(); // remove first byte with some encoding.
|
|
|
|
data = browserify(data);
|
|
|
|
githubData.set(key, data);
|
|
|
|
}
|
|
|
|
callBack();
|
|
|
|
}
|
|
catch (err) {
|
|
console.log("[ERROR] BotScripts -> retrieveScripts -> Github -> onDataArrived -> Error = " + err);
|
|
}
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
function browserify(pData) {
|
|
|
|
let result = pData.substring(pData.indexOf('=') + 2);
|
|
|
|
result = replaceAll(result, "require", "webRequire");
|
|
result = replaceAll(result, "global", "window");
|
|
|
|
return result;
|
|
|
|
function replaceAll(text, search, replacement) {
|
|
return text.replace(new RegExp(search, 'g'), replacement);
|
|
}
|
|
}
|
|
|
|
}
|
|
catch (err) {
|
|
console.log("[ERROR] BotScripts -> retrieveScripts -> Error = " + err);
|
|
}
|
|
}
|
|
} |