89 lines
1.9 KiB
JavaScript
89 lines
1.9 KiB
JavaScript
'use strict';
|
|
|
|
const net = require('net');
|
|
const fs = require('fs');
|
|
const {CallbackQueue} = require('../utils/callback_queue')
|
|
|
|
class SocketServerJson {
|
|
constructor(args){
|
|
this.socketFile = args.socketFile;
|
|
this.onData = new CallbackQueue(args.onData, this);
|
|
this.onListen = new CallbackQueue(args.onListen, this);
|
|
this.onError = new CallbackQueue(args.onError);
|
|
this.onCLientNew = new CallbackQueue(args.onCLientNew);
|
|
this.onCLientClose = new CallbackQueue(args.onCLientClose);
|
|
this.onCLientError = new CallbackQueue(args.onCLientClose);
|
|
|
|
this.onListen.push(function(){
|
|
fs.chmodSync(args.socketFile, '777');
|
|
})
|
|
|
|
this.listen();
|
|
|
|
}
|
|
|
|
__resetSocketFile(callback){
|
|
let instance = this;
|
|
|
|
fs.stat(this.socketFile, function (err, stats) {
|
|
if (stats) {
|
|
fs.unlink(instance.socketFile, function(err){
|
|
if(err){
|
|
// This should never happen.
|
|
console.error(err);
|
|
}
|
|
callback(...arguments)
|
|
});
|
|
}else{
|
|
callback()
|
|
}
|
|
|
|
});
|
|
}
|
|
|
|
|
|
__setUpServer(){
|
|
|
|
let instance = this;
|
|
this.socket = net.createServer();
|
|
|
|
this.socket.on('connection', function(clientSocket){
|
|
let buffer = '';
|
|
|
|
clientSocket.on('data', function(data){
|
|
buffer += data.toString();
|
|
try{
|
|
instance.onData.call(JSON.parse(data), clientSocket)
|
|
buffer = ''
|
|
// clientSocket.write(JSON.stringify(Host.lookUp(buffer)|| {host: 'none'}));
|
|
|
|
}catch(error){
|
|
;
|
|
}
|
|
});
|
|
|
|
clientSocket.on('close', instance.onCLientClose.call.bind(instance.onCLientClose));
|
|
|
|
clientSocket.on('error', instance.onCLientError.call.bind(instance.onCLientError));
|
|
|
|
});
|
|
|
|
this.socket.on('error', this.onError.call.bind(this.onError))
|
|
|
|
this.socket.on('listening', this.onListen.call.bind(this.onListen));
|
|
}
|
|
|
|
listen(){
|
|
let instance = this;
|
|
|
|
this.__setUpServer();
|
|
|
|
this.__resetSocketFile(function(){
|
|
instance.socket.listen(instance.socketFile);
|
|
});
|
|
|
|
}
|
|
};
|
|
|
|
module.exports = {SocketServerJson};
|