Mon 21 Jul 22:43:21 CEST 2025
This commit is contained in:
parent
717490f1d7
commit
d8af5db1a1
279
js/ui/webui/node.js
Normal file
279
js/ui/webui/node.js
Normal file
|
|
@ -0,0 +1,279 @@
|
|||
// TODO: SHELL -> Worker VM
|
||||
function Node(config) {
|
||||
var options = {
|
||||
cmd : null,
|
||||
name : "jam",
|
||||
nameopts : {length:8, memorable:true, lowercase:true},
|
||||
Nameopts : {length:8, memorable:true, uppercase:true},
|
||||
log : { Time: true, Network: false },
|
||||
server : true,
|
||||
verbose : 1,
|
||||
}
|
||||
var _shell,shell,worker;
|
||||
|
||||
Object.assign(options.log,config.log);
|
||||
|
||||
async function init (shell,callback) {
|
||||
_shell=shell;
|
||||
|
||||
console.log(options)
|
||||
if (!config.worker) {
|
||||
options.output = shellCommands.print;
|
||||
shell = options.shell = SHELL(options);
|
||||
options.shell = shell;
|
||||
options.cmd = shell.init().cmd();
|
||||
options.name = options.cmd.name('node');
|
||||
if (callback) callback()
|
||||
} else {
|
||||
// TODO vm.worker; need cmd proxy
|
||||
var vm = VM({
|
||||
VM:JS.VM,
|
||||
verbose:1,
|
||||
})
|
||||
console.log(vm)
|
||||
worker = await vm.worker({
|
||||
print:function () {
|
||||
var args=arguments,
|
||||
msg=Object.keys(args).map(function (index) { return args[index] });
|
||||
if (msg.length==1) msg=msg[0]; else msg=msg.map(function (arg) {
|
||||
if (typeof arg == 'object') return inspect(arg);
|
||||
else return String(arg);
|
||||
}).join(' , ');
|
||||
if (typeof msg == 'object') msg=inspect(msg);
|
||||
msg=(msg==undefined?'undefined':msg);
|
||||
msg = msg.toString();
|
||||
shellCommands.print(msg);
|
||||
},
|
||||
error:shellCommands.error,
|
||||
Environment : {
|
||||
SHELLinit : SHELLinit,
|
||||
},
|
||||
Init : {
|
||||
SHELLinit : function () { SHELLinit() },
|
||||
}
|
||||
})
|
||||
await worker.init()
|
||||
await worker.ready()
|
||||
var name = await worker.eval(function (options) {
|
||||
var cmd;
|
||||
function printAgent (msg) {
|
||||
emit('print-agent',msg);
|
||||
}
|
||||
options.output=print;
|
||||
options.outputAgent = printAgent;
|
||||
shell = SHELL(options);
|
||||
shellOptions = options;
|
||||
options.portIndex = 0;
|
||||
options.ports = [];
|
||||
options.shell = shell;
|
||||
options.cmd = cmd = shell.init().cmd();
|
||||
options.name = cmd.name('node');
|
||||
cmd.on('link+',function (arg){
|
||||
emit('jam-link+',arg)
|
||||
});
|
||||
cmd.on('link-',function (arg){
|
||||
emit('jam-link-',arg)
|
||||
});
|
||||
return options.name;
|
||||
},options);
|
||||
options.name=name;
|
||||
options.cmd = {
|
||||
compile : function (code) {
|
||||
worker.run(function (code) {
|
||||
shellOptions.cmd.compile(code)
|
||||
},code);
|
||||
},
|
||||
connect : function (dir,options) {
|
||||
return worker.eval(function (opts) {
|
||||
shellOptions.cmd.connect(opts.dir,opts.options);
|
||||
},{dir:dir});
|
||||
},
|
||||
connected : function (dir) {
|
||||
return worker.eval(function (dir) { return shellOptions.cmd.connected(dir)},dir);
|
||||
},
|
||||
config : function (opts) {
|
||||
worker.eval(function (config) {
|
||||
shellOptions.cmd.config(config)
|
||||
},opts);
|
||||
},
|
||||
disconnect : function (dir,options) {
|
||||
return worker.eval(function (opts) {
|
||||
shellOptions.cmd.disconnect(opts.dir,opts.options)
|
||||
},{dir:dir,options:options})
|
||||
},
|
||||
exec : function (code) {
|
||||
worker.run(function (code) {
|
||||
shellOptions.cmd.exec(code)
|
||||
},code);
|
||||
},
|
||||
info : function (what,arg) {
|
||||
return worker.eval(function (opts) {
|
||||
var what = opts.what, arg=opts.arg;
|
||||
if (what!='agent-data')
|
||||
return shellOptions.cmd.info(what,arg);
|
||||
else {
|
||||
var agent = shellOptions.cmd.info(what,arg);
|
||||
var ao = {
|
||||
id:agent
|
||||
}
|
||||
for (var p in agent) {
|
||||
switch (p) {
|
||||
case 'act':
|
||||
case 'trans':
|
||||
case 'on':
|
||||
ao[p]={}
|
||||
for(var f in agent[p]) ao[p][f]='function';
|
||||
break;
|
||||
case 'self':
|
||||
break;
|
||||
default :
|
||||
if (typeof agent[p] == 'function') ao[p]='function';
|
||||
else ao[p]=agent[p];
|
||||
}
|
||||
}
|
||||
return ao
|
||||
}
|
||||
},{what:what,arg:arg})
|
||||
},
|
||||
kill : function (agent) {
|
||||
return worker.eval(function (agent) {
|
||||
return shellOptions.cmd.kill(agent)
|
||||
},agent)
|
||||
},
|
||||
marked : SHELL.marked,
|
||||
on : function (ev,handler) {
|
||||
options.cmd.__handlers[ev]=handler;
|
||||
},
|
||||
port : async function (dir,options) {
|
||||
var portid = await worker.eval(function (opts) {
|
||||
var id = shellOptions.portIndex++;
|
||||
var port = shellOptions.cmd.port(opts.dir,opts.options);
|
||||
shellOptions.ports[id]=port;
|
||||
return id;
|
||||
},{dir:dir,options:options})
|
||||
return {
|
||||
amp : {
|
||||
config : function (opts) {
|
||||
opts.id=portid;
|
||||
worker.eval(function (opts) {
|
||||
shellOptions.ports[opts.id].amp.config(opts);
|
||||
},opts);
|
||||
}
|
||||
}
|
||||
}
|
||||
},
|
||||
__handlers:[],
|
||||
stats : function (what) {
|
||||
return worker.eval(function (what) {
|
||||
return shellOptions.cmd.stats(what)
|
||||
},what)
|
||||
},
|
||||
worker:worker,
|
||||
versions : function () {
|
||||
return worker.eval(function () { return shellOptions.cmd.versions()},0);
|
||||
},
|
||||
}
|
||||
options.shell = {
|
||||
env : {
|
||||
compile : function (code) {
|
||||
return worker.eval(function (code) {
|
||||
return shell.env.compile(code)
|
||||
},code);
|
||||
},
|
||||
create : function (ac,args,level) {
|
||||
return worker.eval(function (opts) {
|
||||
return shell.env.create(opts.ac,opts.args,opts.level);
|
||||
},{
|
||||
ac:ac,
|
||||
args:args,
|
||||
level:level
|
||||
})
|
||||
},
|
||||
start : function () {
|
||||
worker.run(function () {
|
||||
shell.env.start();
|
||||
})
|
||||
},
|
||||
stop : function () {
|
||||
worker.run(function () {
|
||||
shell.env.stop();
|
||||
})
|
||||
}
|
||||
},
|
||||
options : {
|
||||
|
||||
}
|
||||
}
|
||||
worker.on('jam-link+', function (arg) {
|
||||
if (options.cmd.__handlers['link+']) options.cmd.__handlers['link+'](arg);
|
||||
})
|
||||
worker.on('jam-link-', function (arg) {
|
||||
if (options.cmd.__handlers['link-']) options.cmd.__handlers['link-'](arg);
|
||||
})
|
||||
worker.on('print-agent', function (msg) {
|
||||
if (options.shell.options.outputAgent) options.shell.options.outputAgent(msg);
|
||||
else shellCommands.print(msg);
|
||||
})
|
||||
if (callback) callback()
|
||||
}
|
||||
}
|
||||
function ask (line) {
|
||||
return options.cmd.exec(question)
|
||||
}
|
||||
|
||||
function println(s, type) {
|
||||
if (/error/.test(type||'')) _shell.env.error(s);
|
||||
else {
|
||||
var hastime = s.match(/^[0-9][0-9]:[0-9][0-9]:[0-9][0-9](.+)/);
|
||||
if (hastime && options.log.Time) s=hastime[1];
|
||||
s='<span style="color:blue; word-break: break-all;">'+s.replace(/&/g,'&')
|
||||
.replace(/</g,'<')
|
||||
.replace(/>/g,'>')
|
||||
.replace(/\n/g,'<br>')
|
||||
.replace(/ /g,' ')+'</span>';
|
||||
_shell.env.print('<div class="jquery-console-message">'+
|
||||
(options.log.Time?'<span style="color:green">'+SHELL.Io.Time()+'</span> ':'')+
|
||||
s+
|
||||
'</div>');
|
||||
}
|
||||
}
|
||||
function run(question) {
|
||||
options.cmd.exec(question)
|
||||
}
|
||||
function setup() {
|
||||
|
||||
}
|
||||
function start() {
|
||||
|
||||
}
|
||||
function stop() {
|
||||
if (worker) {
|
||||
shellCommands.print('Closing worker and JAM instance..')
|
||||
worker.kill();
|
||||
}
|
||||
}
|
||||
var shellCommands = {
|
||||
clear: function () {
|
||||
_shell.env.clear()
|
||||
},
|
||||
error: function (s) {
|
||||
println(s, "error");
|
||||
},
|
||||
print: function (s) {
|
||||
println(s, "print");
|
||||
},
|
||||
reset: function () {
|
||||
|
||||
},
|
||||
}
|
||||
return {
|
||||
ask:ask,
|
||||
commands: shellCommands,
|
||||
init:init,
|
||||
options:options,
|
||||
question:run,
|
||||
setup:setup,
|
||||
start:start,
|
||||
stop:stop
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue
Block a user