mirror of
https://github.com/coderaiser/cloudcmd.git
synced 2026-08-03 21:23:05 +00:00
feature(console) consle -> console-io from npm
This commit is contained in:
coderaiser
parent
c96e97f618
commit
21501736cb
35 changed files with 122 additions and 20655 deletions
|
|
@ -1,103 +0,0 @@
|
|||
(function() {
|
||||
'use strict';
|
||||
|
||||
var DIR = '../',
|
||||
DIR_SERVER = './',
|
||||
|
||||
Util = require(DIR + 'util'),
|
||||
CloudFunc = require(DIR + 'cloudfunc'),
|
||||
|
||||
socket = require(DIR_SERVER + 'socket'),
|
||||
spawnify = require(DIR_SERVER + 'spawnify'),
|
||||
|
||||
Clients = [],
|
||||
addNewLine = CloudFunc.addNewLine,
|
||||
|
||||
ConNum = 0,
|
||||
|
||||
CWD = process.cwd(),
|
||||
|
||||
CHANNEL = CloudFunc.CHANNEL_CONSOLE;
|
||||
|
||||
module.exports = function(io, onMsg) {
|
||||
socket.on('connection', io, function(clientSocket) {
|
||||
onConnection(clientSocket, onMsg, function(error, json) {
|
||||
socket.emit(CHANNEL, json, clientSocket);
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
function onConnection(clientSocket, onMsg, callback) {
|
||||
var msg, onDisconnect, onMessage;
|
||||
|
||||
if (!callback) {
|
||||
callback = onMsg;
|
||||
onMsg = null;
|
||||
}
|
||||
|
||||
Util.checkArgs([clientSocket, callback], ['clientSocket', 'callback']);
|
||||
|
||||
++ConNum;
|
||||
|
||||
if (!Clients[ConNum]) {
|
||||
msg = log(ConNum, 'console connected');
|
||||
|
||||
if (onMsg)
|
||||
onMsg('cd .', callback);
|
||||
else
|
||||
callback(null, {
|
||||
stdout : addNewLine(msg),
|
||||
path : CWD
|
||||
});
|
||||
|
||||
Clients[ConNum] = {
|
||||
cwd : CWD
|
||||
},
|
||||
|
||||
onMessage = function(command) {
|
||||
log(ConNum, command);
|
||||
|
||||
if (onMsg)
|
||||
onMsg(command, callback);
|
||||
else
|
||||
spawnify(command, Clients[ConNum], callback);
|
||||
},
|
||||
onDisconnect = function(conNum) {
|
||||
Clients[conNum] = null;
|
||||
|
||||
log(conNum, 'console disconnected');
|
||||
|
||||
socket.removeListener(CHANNEL, clientSocket, onMessage);
|
||||
socket.removeListener('disconnect', clientSocket, onDisconnect);
|
||||
}.bind(null, ConNum);
|
||||
|
||||
socket.on(CHANNEL, clientSocket, onMessage);
|
||||
socket.on('disconnect', clientSocket, onDisconnect);
|
||||
} else {
|
||||
msg = log(ConNum, ' in use. Reconnecting...\n');
|
||||
|
||||
callback(null, {
|
||||
stdout: msg
|
||||
});
|
||||
|
||||
socket.disconnect();
|
||||
}
|
||||
}
|
||||
|
||||
function log(connNum, str, typeParam) {
|
||||
var ret,
|
||||
type = ' ';
|
||||
|
||||
if (str) {
|
||||
|
||||
if (typeParam)
|
||||
type += typeParam + ':';
|
||||
|
||||
ret = 'client #' + connNum + type + str;
|
||||
|
||||
Util.log(ret);
|
||||
}
|
||||
|
||||
return ret;
|
||||
}
|
||||
})();
|
||||
|
|
@ -1,32 +0,0 @@
|
|||
(function() {
|
||||
'use strict';
|
||||
|
||||
var fs = require('fs'),
|
||||
path = require('path'),
|
||||
Util = require('../util');
|
||||
|
||||
module.exports = function(card, callback) {
|
||||
var dir = path.dirname(card),
|
||||
nameCard = path.basename(card),
|
||||
regExp = Util.getRegExp(nameCard);
|
||||
|
||||
if (!callback)
|
||||
throw(Error('Callback is absent!'));
|
||||
|
||||
fs.readdir(dir, function(error, names) {
|
||||
var result = [];
|
||||
|
||||
if (!error)
|
||||
names.forEach(function(name) {
|
||||
var is = name.match(regExp);
|
||||
|
||||
if (is)
|
||||
result.push(path.join(dir, name));
|
||||
|
||||
return is;
|
||||
});
|
||||
|
||||
callback(error, result);
|
||||
});
|
||||
};
|
||||
})();
|
||||
|
|
@ -1,282 +0,0 @@
|
|||
(function() {
|
||||
'use strict';
|
||||
|
||||
var DIR = './',
|
||||
DIR_LIB = DIR + '../',
|
||||
|
||||
path = require('path'),
|
||||
child_process = require('child_process'),
|
||||
|
||||
exec = child_process.exec,
|
||||
|
||||
WIN = process.platform === 'win32',
|
||||
spawn = child_process.spawn,
|
||||
|
||||
Util = require(DIR_LIB + 'util'),
|
||||
CloudFunc = require(DIR_LIB + 'cloudfunc'),
|
||||
|
||||
addNewLine = CloudFunc.addNewLine,
|
||||
|
||||
find = require(DIR + 'find'),
|
||||
win = require(DIR + 'win');
|
||||
|
||||
Util.exec.try(function() {
|
||||
find = require('glob');
|
||||
});
|
||||
|
||||
module.exports = function(command, options, callback) {
|
||||
Util.checkArgs(arguments, ['command', 'callback']);
|
||||
|
||||
if (!callback) {
|
||||
callback = options;
|
||||
|
||||
options = {
|
||||
cwd: process.cwd()
|
||||
};
|
||||
}
|
||||
|
||||
onMessage(command, options, callback);
|
||||
};
|
||||
|
||||
function onMessage(command, options, callback) {
|
||||
var funcExec, firstChar,
|
||||
connName, ret,
|
||||
dir = options.cwd,
|
||||
isVolume = win.isChangeVolume(command),
|
||||
isCD = /^cd ?/.test(command),
|
||||
isCDWin = /^cd ?/i.test(command),
|
||||
|
||||
symbolsExec = ['*', '&', '{', '}', '|', '\'', '"', ';'],
|
||||
isSymbol = Util.isContainStr(command, symbolsExec);
|
||||
|
||||
Util.checkArgs(arguments, ['connNum', 'callback', 'command']);
|
||||
|
||||
if (isCD || isCDWin && WIN || isVolume) {
|
||||
ret = true;
|
||||
|
||||
onCD(command, dir, function(error, json) {
|
||||
var path;
|
||||
|
||||
if (!error && json.path) {
|
||||
path = json.path;
|
||||
options.cwd = path;
|
||||
}
|
||||
|
||||
callback(error, json);
|
||||
});
|
||||
}
|
||||
|
||||
if (!ret) {
|
||||
if (WIN)
|
||||
command = 'cmd /C ' + command;
|
||||
|
||||
funcExec = setExec.bind(null, callback);
|
||||
|
||||
firstChar = command[0];
|
||||
|
||||
if (firstChar === '#') {
|
||||
command = command.slice(1);
|
||||
command = connName + command;
|
||||
command = addNewLine(command);
|
||||
|
||||
Util.exec(callback, {
|
||||
stdout: command
|
||||
}, true);
|
||||
} else if (firstChar === ' ' || isSymbol)
|
||||
exec(command, options, funcExec);
|
||||
else
|
||||
setSpawn(command, options, callback);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* function send result of command to client
|
||||
* @param callback
|
||||
*/
|
||||
function setExec(callback, error, stdout, stderr) {
|
||||
var json,
|
||||
errorStr = '';
|
||||
|
||||
if (stderr)
|
||||
errorStr = stderr;
|
||||
else if (error)
|
||||
errorStr = error.message;
|
||||
|
||||
json = {
|
||||
stdout : stdout,
|
||||
stderr : errorStr
|
||||
};
|
||||
|
||||
callback(error, json);
|
||||
}
|
||||
|
||||
function setSpawn(сommand, options, callback) {
|
||||
var cmd, error,
|
||||
isSended = false,
|
||||
args = сommand.split(' '),
|
||||
func = function(error, stdout, stderr) {
|
||||
var errorStr = '';
|
||||
|
||||
isSended = true;
|
||||
|
||||
if (error)
|
||||
errorStr = error.message;
|
||||
else if (stderr)
|
||||
errorStr = stderr;
|
||||
|
||||
errorStr = addNewLine(errorStr);
|
||||
|
||||
callback(error, {
|
||||
stderr: errorStr,
|
||||
stdout: stdout
|
||||
});
|
||||
};
|
||||
|
||||
Util.checkArgs(arguments, ['command', 'callback']);
|
||||
|
||||
if (!callback) {
|
||||
callback = options;
|
||||
options = null;
|
||||
}
|
||||
|
||||
сommand = args.shift();
|
||||
|
||||
error = Util.exec.tryLog(function() {
|
||||
cmd = spawn(сommand, args, options);
|
||||
});
|
||||
|
||||
if (error) {
|
||||
func(error);
|
||||
} else {
|
||||
cmd.stderr.setEncoding('utf8');
|
||||
cmd.stdout.setEncoding('utf8');
|
||||
|
||||
cmd.stdout.on('data', function(data) {
|
||||
func(null, data);
|
||||
});
|
||||
|
||||
cmd.stderr.on('data', function(error) {
|
||||
func(null, null, error);
|
||||
});
|
||||
|
||||
cmd.on('error', function(error) {
|
||||
func(error);
|
||||
});
|
||||
|
||||
cmd.on('close', function() {
|
||||
cmd = null;
|
||||
|
||||
if (!isSended)
|
||||
func();
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
function onCD(command, currDir, callback) {
|
||||
var CD = 'cd ',
|
||||
HOME = process.env.HOME,
|
||||
|
||||
isChangeVolume = win.isChangeVolume(command),
|
||||
isVolume = win.isVolume(command),
|
||||
paramDir = Util.rmStrOnce(command, [CD, 'cd']),
|
||||
|
||||
regExpHome = new RegExp('^~'),
|
||||
regExpRoot = new RegExp('^[/\\\\]'),
|
||||
|
||||
isWildCard = Util.isContainStr(paramDir, ['*', '?']),
|
||||
isHome = regExpHome.test(paramDir) && !WIN,
|
||||
isRoot = regExpRoot.test(paramDir),
|
||||
|
||||
onExec = function (error, stdout, stderr) {
|
||||
var path = paramDir,
|
||||
errorStr = '';
|
||||
|
||||
if (stderr) {
|
||||
errorStr = stderr;
|
||||
} else if (error) {
|
||||
errorStr = error.message;
|
||||
path = '';
|
||||
}
|
||||
|
||||
callback(error, {
|
||||
stderr : addNewLine(errorStr),
|
||||
stdout : stdout,
|
||||
path : path
|
||||
});
|
||||
};
|
||||
|
||||
if (isHome) {
|
||||
command = command.replace('~', HOME);
|
||||
paramDir = paramDir.replace('~', HOME);
|
||||
}
|
||||
|
||||
if (!paramDir && !WIN)
|
||||
paramDir = '.';
|
||||
|
||||
if (!isChangeVolume || isVolume) {
|
||||
paramDir = getFirstWord(paramDir);
|
||||
paramDir = path.normalize(paramDir);
|
||||
|
||||
command = Util.rmStrOnce(command, [
|
||||
CD,
|
||||
paramDir,
|
||||
'\'' + paramDir + '\'',
|
||||
'"' + paramDir + '"',
|
||||
]);
|
||||
|
||||
if (!isHome && !isRoot)
|
||||
paramDir = path.join(currDir, paramDir);
|
||||
|
||||
if (isWildCard)
|
||||
command = CD + paramDir + ' ' + command;
|
||||
else
|
||||
command = CD + '"' + paramDir + '" ' + command;
|
||||
}
|
||||
|
||||
if (!isWildCard)
|
||||
exec(command, {cwd: paramDir}, onExec);
|
||||
else
|
||||
find(paramDir, function(error, dirs) {
|
||||
var dir;
|
||||
|
||||
if (!error)
|
||||
dir = dirs[0];
|
||||
|
||||
paramDir = dir;
|
||||
exec(command, {cwd: dir}, onExec);
|
||||
});
|
||||
}
|
||||
|
||||
function getFirstWord(str) {
|
||||
var word, result,
|
||||
regStrEnd = getRegStrEnd(),
|
||||
regStr = '^(.*?)',
|
||||
regStrQuotes = '^"(.*)"',
|
||||
regExp = new RegExp(regStr + regStrEnd),
|
||||
regExpQuotes = new RegExp(regStrQuotes + regStrEnd + '?'),
|
||||
is = Util.isString(str);
|
||||
|
||||
if (is) {
|
||||
result = str.match(regExpQuotes);
|
||||
|
||||
if (result) {
|
||||
word = result[1];
|
||||
} else {
|
||||
result = str.match(regExp);
|
||||
word = result && result[1];
|
||||
}
|
||||
|
||||
if (!word)
|
||||
word = str;
|
||||
}
|
||||
|
||||
return word;
|
||||
}
|
||||
|
||||
function getRegStrEnd() {
|
||||
var regStrEnd = '(\\s|\\;|&&|\\|\\|)';
|
||||
|
||||
return regStrEnd;
|
||||
}
|
||||
|
||||
})();
|
||||
Loading…
Add table
Add a link
Reference in a new issue