Skip to content

Instantly share code, notes, and snippets.

@FarhanMS123

FarhanMS123/#0 ARCHIVE.md

Last active January 26, 2023 10:10
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save FarhanMS123/c90a77f80170bb467db6056a49e52bac to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save FarhanMS123/c90a77f80170bb467db6056a49e52bac to your computer and use it in GitHub Desktop.
Download ZIP
Archived from farhanms123/lib repository
Raw
#0 ARCHIVE.md

Archive

List

  1. handler4cp
  2. handler4proc
  3. taskmgr
  4. Vue Directive HTML2
  5. Ajax 2 Write
Raw
ajax2write.php
<?php
$url=isset($_GET["url"]) ? $_GET["url"] : "url_nothing";
$save=isset($_GET["save"]) ? $_GET["save"] : "save_nothing";
if(!isset($_GET["url"]) || !isset($_GET["save"])){exit;}
echo $url . " & " . $save;
$infile = file_get_contents($url);
echo "<br><br>" . $infile;
$fp = fopen($save, 'w+');
fwrite($fp, $infile);
fclose($fp);
?>
Raw
handler4cp.js
function log(p, f){
p.on("close", function(code, signal){
f("close", {code, signal});
}).on("disconnect", function(){
f("close", "");
}).on("error", function(error){
f("error", error);
}).on("exit", function(code, signal){
f("exit", {code, signal});
});
p.stdout.on("stdout_close", function(){
f("stdout_close", "");
}).on("data", function(data){
f("stdout_data", data);
}).on("end", function(){
f("stdout_end", "");
}).on("error", function(error){
f("stdout_error", error);
}).on("readable", function(){
f("stdout_readable", "");
});
p.stderr.on("stderr_close", function(){
f("stderr_close", "");
}).on("data", function(data){
f("stderr_data", data);
}).on("end", function(){
f("stderr_end", "");
}).on("error", function(error){
f("stderr_error", error);
}).on("readable", function(){
f("stderr_readable", "");
});
p.stdin.on("close", function(){
f("stdin_close", "");
}).on("drain", function(){
f("stdin_drain", "");
}).on("error", function(error){
f("stdin_error", error);
}).on("finish", function(){
f("stdin_finish", "");
}).on("unpipe", function(src){
f("stdin_unpipe", src);
});
}
Raw
handler4proc.js
global.cp = require("child_process");
global.net = require("net");
function listen(){
s.listen({}); //using listen
}
function createProcess(){
global.proc = cp.spawn("node", ["file.js"]); //spawning
}
global.s = net.createServer(); //listen here
s.on("error", function(e){
console.log(JSON.stringify(["server_error", e]));
if(s._handle == null) listen();
}).on("close", function(){
s.members = [];
console.log(JSON.stringify(["server_close", e]));
listen();
}).on("connection", function(c){
s.members.push(c);
}).on("listening", function(){
s.members = [];
console.log(JSON.stringify(["server_listen", ""]));
});
listen();
createProcess()
log(proc, function(name, desc){
console.log(JSON.stringify([name, desc]));
s.members.forEach(function(c){
if(c._handle !== null) c.write(JSON.stringify([name, desc]));
});
if(proc.killed) createProccess();
});
function log(p, f){
p.on("close", function(code, signal){
f("close", {code, signal});
}).on("disconnect", function(){
f("close", "");
}).on("error", function(error){
f("error", error);
}).on("exit", function(code, signal){
f("exit", {code, signal});
});
p.stdout.on("stdout_close", function(){
f("stdout_close", "");
}).on("data", function(data){
f("stdout_data", data);
}).on("end", function(){
f("stdout_end", "");
}).on("error", function(error){
f("stdout_error", error);
}).on("readable", function(){
f("stdout_readable", "");
});
p.stderr.on("stderr_close", function(){
f("stderr_close", "");
}).on("data", function(data){
f("stderr_data", data);
}).on("end", function(){
f("stderr_end", "");
}).on("error", function(error){
f("stderr_error", error);
}).on("readable", function(){
f("stderr_readable", "");
});
p.stdin.on("close", function(){
f("stdin_close", "");
}).on("drain", function(){
f("stdin_drain", "");
}).on("error", function(error){
f("stdin_error", error);
}).on("finish", function(){
f("stdin_finish", "");
}).on("unpipe", function(src){
f("stdin_unpipe", src);
});
}
Raw
taskmgr.js
global.cp = require("child_process");
global.net = require("net");
global.util = require("util");
global.vm = require("vm");
global.opt = {
time:[0,0],
listen:false,
port:9999,
proc:[
/*
proc, proc, proc,...
proc :
{
id:#id,
type:"type", <= exec, execFile, fork, spawn
log:[
[
"type", <=stdout_
"data",
#time
]
],
run:bool(run),
clients:[],
time:[],
intv:
}
*/
],
buff2str : true
};
opt.itv = setInterval(function(){opt.time[1] = (new Date()).getTime();}, 1);
global.n = net.createServer();
/*
vv exec cmd
vv execFile cmd
v? fork cmd
vv spawn cmd
vv list all
vv list run
vv list stop
vv info #id
vv info #id --full
vv kill #id
vv log #id full
vv log #id listen --start
vv log #id listen --stop
vv msg #id text_support_metacharacter...
vv write #id text_support_metacharacter...
vv cmd command
return JSON;
*/
n.listen(opt.port || 9999, function(){ console.log(`listening on ${opt.port || 9999}`) });
n.log = [];
n.on("connection", function(s){
s.on("data", function(dt){
n.log.push(["sock_data", {sock:s, data:dt}, opt.time[1]]);
dt = dt.toString();
if(dt.slice(-1) == "\n" || dt.slice(-1) == "\r") dt = dt.slice(0, -1);
if(dt.slice(-1) == "\n" || dt.slice(-1) == "\r") dt = dt.slice(0, -1);
dt = txt2meta(dt);
try{
var cmd = dt.slice(0, (dt.indexOf(" ") > -1 ? dt.indexOf(" ") : dt.length));
switch(cmd){
case "exec":
case "execFile":
case "fork":
case "spawn":
if(dt.indexOf(" ") > -1){
var i = opt.proc.length;
if(cmd == "exec"){
opt.proc[i] = cp.exec(dt.slice(dt.indexOf(" ") + 1));
}else{
var arg = splitArgs(dt.slice(dt.indexOf(" ") + 1));
var arg0 = arg[0], arg1 = JSON.parse(JSON.stringify(arg));
arg1.shift();
opt.proc[i] = cp[cmd](arg[0], arg1);
}
opt.proc[i].id = i
opt.proc[i].clients = [];
opt.proc[i].time = [opt.time[1], 0];
opt.proc[i].intv = setInterval(function(){
opt.proc[i].time[1] = opt.time[1];
}, 1);
opt.proc[i].type = cmd;
opt.proc[i].log = [];
opt.proc[i].run = true;
log(opt.proc[i], function(type, dt){
if(type == "exit"){
opt.proc[i].run = false;
}
if(opt.buff2str) dt = dt.toString();
opt.proc[i].log.push([type, dt, opt.proc[i].time[1]]);
opt.proc[i].clients.forEach(function(sn){
if(!sn.destroyed) sn.write(JSON.stringify([type, opt.proc[i].id, dt]));
if(sn.destroyed) opt.proc[i].clients = kickMid(opt.proc[i].clients, opt.proc[i].clients.indexOf(sn));
});
});
}else{
n.log.push(["sock_data_resp", {sock:s, data:dt, res:"error, cmd should : exec fileorapps.ext"}, opt.time[1]]);
s.write(`error, cmd should : ${cmd} appsorfile.ext cmd`);
}
break;
case "list":
var arg1 = dt.slice(dt.indexOf(" ") + 1);
var p = [], i=undefined;
switch(arg1){
case "all":
for(i=0;i<opt.proc.length;i++){
p.push({
id:opt.proc[i].id,
type:opt.proc[i].type,
spawnargs:opt.proc[i].spawnargs,
run:opt.proc[i].run,
time:opt.proc[i].time
});
}
break;
case "run":
for(i=0;i<opt.proc.length;i++){
if(opt.proc[i].run == true){
p.push({
id:opt.proc[i].id,
type:opt.proc[i].type,
spawnargs:opt.proc[i].spawnargs,
run:opt.proc[i].run,
time:opt.proc[i].time
});
}
}
break;
case "stop":
for(i=0;i<opt.proc.length;i++){
if(opt.proc[i].run == false){
p.push({
id:opt.proc[i].id,
type:opt.proc[i].type,
spawnargs:opt.proc[i].spawnargs,
run:opt.proc[i].run,
time:opt.proc[i].time
});
}
}
break;
default:
p = "error, cmd should : list (all|run|stop)";
}
n.log.push(["sock_data_resp", {sock:s, data:dt, res:(p.constructor == String ? p : JSON.stringify(p))}, opt.time[1]]);
s.write((p.constructor == String? p : JSON.stringify(p)));
break;
case "info":
var arg1 = splitArgs(dt.slice(dt.indexOf(" ") + 1));
var id = arg1[0];
var arg2 = dt.slice(dt.indexOf(" ") + id.length + 2)
var res="";
console.log([arg1, id, arg2])
switch(arg2){
case "":
res = JSON.stringify({
id:opt.proc[id].id,
type:opt.proc[id].type,
spawnargs:opt.proc[id].spawnargs,
run:opt.proc[id].run,
time:opt.proc[id].time
});
break;
case "--full": //signalCode, exitCode, killed, spawnfile, spawnargs, pid, readable, writeable
res = JSON.stringify({
id:opt.proc[id].id,
type:opt.proc[id].type,
spawnargs:opt.proc[id].spawnargs,
run:opt.proc[id].run,
log:opt.proc[id].log,
stdout_readable:opt.proc[id].stdout.readable,
stderr_readable:opt.proc[id].stdout.readable,
stdin_writable:opt.proc[id].stdin.writeable,
time:opt.proc[id].time
});
break;
default:
res = "error, cmd should : info #id [-full]"
}
n.log.push(["sock_data_resp", {sock:s, data:dt, res:res}, opt.time[1]]);
s.write(res);
break;
case "kill":
var arg1 = splitArgs(dt.slice(dt.indexOf(" ") + 1));
var id = arg1[0];
opt.proc[id].kill();
break;
case "log":
var arg1 = splitArgs(dt.slice(dt.indexOf(" ") + 1));
var id = arg1[0], res = "created";
switch(arg1[1]){
case "full":
res = JSON.stringify(opt.proc[id].log);
break;
case "listen":
if(arg1[2] == "--start"){
var is = false;
opt.proc[id].clients.forEach(function(sn, ind){
if(sn == s){
is = true;
res = `error, you are listening in this process (#${id})`;
}
});
if(!is){
opt.proc[id].clients.push(s);
}
}else if(arg1[2] == "--stop"){
opt.proc[id].clients.forEach(function(sn, ind){
if(sn == s){
opt.proc[id].clients = kickMid(opt.proc[id].clients, ind);
}
});
res = "deleted";
}
break;
default :
res = "error, cmd should : log (full | listen (--start|--stop))";
}
n.log.push(["sock_data_resp", {sock:s, data:dt, res:res}, opt.time[1]]);
s.write(res);
break;
case "msg":
var arg1 = splitArgs(dt.slice(dt.indexOf(" ") + 1));
var id = arg1[0];
var arg2 = dt.slice(dt.indexOf(" ") + id.length + 2)
opt.proc[id].send(arg2);
break;
case "write":
var arg1 = splitArgs(dt.slice(dt.indexOf(" ") + 1));
var id = arg1[0];
var arg2 = dt.slice(dt.indexOf(" ") + id.length + 2);
arg2 = txt2meta(arg2);
opt.proc[id].stdin.write(arg2);
break;
case "cmd":
var res = util.inspect(vm.runInNewContext(dt.slice(dt.indexOf(" ") + 1), global));
n.log.push(["sock_data_resp", {sock:s, data:dt, res:res}, opt.time[1]]);
s.write(res);
break;
default :
var res = "cmd not found";
if(dt == "") res = ""
n.log.push(["sock_data_resp", {sock:s, data:dt, res:res}, opt.time[1]]);
s.write(res);
}
}catch(e){
var res = JSON.stringify({type:"error", data:util.inspect(e)});
n.log.push(["sock_data_resp", {sock:s, data:dt, res:res}, opt.time[1]]);
s.write(res);
console.log(`cmd : "${dt}"`)
console.log(e)
}
}).on("error", function(e){
n.log.push(["error", {sock:s, error:e}, opt.time[1]]);
});
}).on("close", function(){
n.log.push(["close", "reconnecting", opt.time[1]]);
n.listen(opt.port || 9999);
}).on("error", function(e){
if(n._handle == null) n.listen(opt.port || 9999);
n.log.push(["error", e, opt.time[1]]);
}).on("listening", function(){
n.log.push(["listening", "", opt.time[1]]);
});
function log(p, f){
p.on("close", function(code, signal){
f("close", {code, signal});
}).on("disconnect", function(){
f("close", "");
}).on("error", function(error){
f("error", error);
}).on("exit", function(code, signal){
f("exit", {code, signal});
});
p.stdout.on("stdout_close", function(){
f("stdout_close", "");
}).on("data", function(data){
f("stdout_data", data);
}).on("end", function(){
f("stdout_end", "");
}).on("error", function(error){
f("stdout_error", error);
}).on("readable", function(){
f("stdout_readable", "");
});
p.stderr.on("stderr_close", function(){
f("stderr_close", "");
}).on("data", function(data){
f("stderr_data", data);
}).on("end", function(){
f("stderr_end", "");
}).on("error", function(error){
f("stderr_error", error);
}).on("readable", function(){
f("stderr_readable", "");
});
p.stdin.on("close", function(){
f("stdin_close", "");
}).on("drain", function(){
f("stdin_drain", "");
}).on("error", function(error){
f("stdin_error", error);
}).on("finish", function(){
f("stdin_finish", "");
}).on("unpipe", function(src){
f("stdin_unpipe", src);
});
}
function kickMid(arr, index){
var dt = []; var i;
for(i=0;i<arr.length;i++){
if(i==index) continue;
dt.push(arr[i])
}
return dt;
}
function splitArgs(arg){
var full = arg.split(" ");
var u=-1, x=[], l="", i=undefined;
for(i=0;i<full.length;i++){
if(u>-1){
full[u] += ` ${full[i]}`;
x.push(i);
}
if(u == -1 && (full[i].slice(0,1) == "\"" || full[i].slice(0,1) == "\'")){
u=i;
l=full[i].slice(0,1);
full[i] = full[i].slice(1);
}
if(u > -1 && full[i].slice(-1) == l){
full[u] = full[u].slice(0, -1);
u=-1;
}
}
var i = undefined;
for(i=x.length - 1;i>-1;i--){
full = kickMid(full, x[i]);
}
return full;
}
function txt2meta(txt){
//hello \" \' \r\n \123 \xff \u2f3a
//\\" \\' \\` \\r\\n \\123 \\xff \\u2f3a
txt = txt.replace(/\\"/g, "\"").replace(/\\'/g, "\'").replace(/\\`/g, "\`").replace(/\\r/g, "\r").replace(/\\n/g, "\n").replace(/\\\\/g, "\\");
var rg = [[/\\([abcdef]|[ABCDEF]|[0-9]){3}/g, 8], [/\\x([abcdef]|[ABCDEF]|[0-9]){2}/g, 16], [/\\u([abcdef]|[ABCDEF]|[0-9]){4}/g, 16]];
var i;
for(i=0;i<rg.length;i++){
if(txt.match(rg[i][0]) != null){
txt.match(rg[i][0]).forEach(function(s){
txt = txt.replace(s, String.fromCharCode(parseInt( (/([abcdef]|[ABCDEF]|[0-9])+/).exec(s)[0] , rg[i][1])));
});
}
}
return txt;
}
Raw
vue.directive.html2.js
Vue.directive("html2", function(el, bind){
var dom = new DOMParser().parseFromString(bind.value, "text/html");
el.innerHTML = bind.value;
var scr = dom.querySelectorAll("script");
for(var i=0;i<scr.length;i++){
if(scr[i].attributes.src){
var xhttpData = new XMLHttpRequest()
xhttpData.onreadystatechange = function(){
if(xhttpData.status == 200 && httpData.readyState == 4){
eval(xhttpData.response);
}
}
xhttpData.open("GET", scr[i].attributes.src.value, true);
xhttpData.send();
}
if(scr[i].innerHTML){
eval(scr[i].innerHTML);
}
}
console.log(bind.value);
});
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment