mirror of
https://github.com/Ylianst/MeshCentral.git
synced 2024-12-18 19:32:18 +03:00
Deleted un-needed files, becuase they are integrated into the agent
This commit is contained in:
Bryan Roe
parent
4a2f3e3289
commit
fcc8008e06
@ -1,128 +0,0 @@
|
|||||||
/*
|
|
||||||
Copyright 2018-2019 Intel Corporation
|
|
||||||
|
|
||||||
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.
|
|
||||||
*/
|
|
||||||
|
|
||||||
try { Object.defineProperty(Array.prototype, "peek", { value: function () { return (this.length > 0 ? this[this.length - 1] : undefined); } }); } catch (e) { }
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
function dbus(address, uid)
|
|
||||||
{
|
|
||||||
this._ObjectID = 'linux-dbus';
|
|
||||||
require('events').EventEmitter.call(this, true)
|
|
||||||
.createEvent('signal');
|
|
||||||
Object.defineProperty(this, "uid", { value: uid });
|
|
||||||
this._child = require('child_process').execFile("/bin/sh", ["sh"], { type: require('child_process').SpawnTypes.TERM, uid: uid == null ? -1 : uid });
|
|
||||||
this._child.stdin.write('dbus-monitor --session "type=\'signal\', interface=\'' + address + '\'" | ( while read X; do echo "$X"; done )\n');
|
|
||||||
this._child.stdout.dbus = this;
|
|
||||||
this._child.stdout.on('data', function (chunk)
|
|
||||||
{
|
|
||||||
// Parse DBUS Data
|
|
||||||
if (!this.ready) { this.ready = true; return; }
|
|
||||||
|
|
||||||
var lines = [];
|
|
||||||
var tokens = chunk.toString().split('\r\n');
|
|
||||||
for (var i in tokens)
|
|
||||||
{
|
|
||||||
if (tokens[i] == '')
|
|
||||||
{
|
|
||||||
// End of record
|
|
||||||
this.dbus.preParseRecords(lines);
|
|
||||||
lines = [];
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
lines.push(tokens[i]);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
});
|
|
||||||
this.preParseRecords = function (lines)
|
|
||||||
{
|
|
||||||
var record = [];
|
|
||||||
for (var i in lines)
|
|
||||||
{
|
|
||||||
if(lines[i].startsWith('signal '))
|
|
||||||
{
|
|
||||||
if(record.length>0)
|
|
||||||
{
|
|
||||||
this.parseRecords(record);
|
|
||||||
}
|
|
||||||
record = [];
|
|
||||||
}
|
|
||||||
record.push(lines[i]);
|
|
||||||
}
|
|
||||||
if (record.length > 0)
|
|
||||||
{
|
|
||||||
this.parseRecords(record);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
this.parseRecords = function (lines)
|
|
||||||
{
|
|
||||||
if (lines[0].startsWith('signal '))
|
|
||||||
{
|
|
||||||
var signal = {};
|
|
||||||
var sigtokens = lines[0].split(' ');
|
|
||||||
sigtokens.shift();
|
|
||||||
|
|
||||||
for (var i in sigtokens) {
|
|
||||||
var sigitems = sigtokens[i].split('=');
|
|
||||||
if (sigitems.length == 2) {
|
|
||||||
signal[sigitems[0]] = sigitems[1];
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
lines.shift();
|
|
||||||
signal.data = lines;
|
|
||||||
|
|
||||||
this.parseSignal(signal);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
this.parseSignal = function(signal)
|
|
||||||
{
|
|
||||||
var data = signal.data;
|
|
||||||
signal.data = [];
|
|
||||||
|
|
||||||
for(var i=0; i<data.length; ++i)
|
|
||||||
{
|
|
||||||
if (data[i].startsWith('array '))
|
|
||||||
{
|
|
||||||
signal.data.push([]);
|
|
||||||
for(i=i+1; i<data.length; ++i)
|
|
||||||
{
|
|
||||||
this.parseSignal2(data[i], signal.data.peek());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
this.parseSignal2(data[i], signal.data);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
this.emit('signal', signal);
|
|
||||||
}
|
|
||||||
this.parseSignal2 = function (inputStr, outArray)
|
|
||||||
{
|
|
||||||
if(inputStr.startsWith('string '))
|
|
||||||
{
|
|
||||||
outArray.push(JSON.parse(inputStr.slice(7)));
|
|
||||||
}
|
|
||||||
else if(inputStr.startsWith('boolean '))
|
|
||||||
{
|
|
||||||
outArray.push(JSON.parse(inputStr.slice(8)));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
module.exports = dbus;
|
|
||||||
@ -1 +0,0 @@
|
|||||||
try{Object.defineProperty(Array.prototype,"peek",{value:function(){return(this.length>0?this[this.length-1]:undefined)}})}catch(e){}function dbus(a,b){this._ObjectID="linux-dbus";require("events").EventEmitter.call(this,true).createEvent("signal");Object.defineProperty(this,"uid",{value:b});this._child=require("child_process").execFile("/bin/sh",["sh"],{type:require("child_process").SpawnTypes.TERM,uid:b==null?-1:b});this._child.stdin.write("dbus-monitor --session \"type='signal', interface='"+a+'\'" | ( while read X; do echo "$X"; done )\n');this._child.stdout.dbus=this;this._child.stdout.on("data",function(c){if(!this.ready){this.ready=true;return}var f=[];var g=c.toString().split("\r\n");for(var d in g){if(g[d]==""){this.dbus.preParseRecords(f);f=[]}else{f.push(g[d])}}});this.preParseRecords=function(d){var f=[];for(var c in d){if(d[c].startsWith("signal ")){if(f.length>0){this.parseRecords(f)}f=[]}f.push(d[c])}if(f.length>0){this.parseRecords(f)}};this.parseRecords=function(d){if(d[0].startsWith("signal ")){var g={};var h=d[0].split(" ");h.shift();for(var c in h){var f=h[c].split("=");if(f.length==2){g[f[0]]=f[1]}}d.shift();g.data=d;this.parseSignal(g)}};this.parseSignal=function(f){var c=f.data;f.data=[];for(var d=0;d<c.length;++d){if(c[d].startsWith("array ")){f.data.push([]);for(d=d+1;d<c.length;++d){this.parseSignal2(c[d],f.data.peek())}}else{this.parseSignal2(c[d],f.data)}}this.emit("signal",f)};this.parseSignal2=function(c,d){if(c.startsWith("string ")){d.push(JSON.parse(c.slice(7)))}else{if(c.startsWith("boolean ")){d.push(JSON.parse(c.slice(8)))}}}}module.exports=dbus;
|
|
||||||
Loading…
Reference in New Issue
Block a user