done working
parent
ffb21a78a3
commit
9b1bb5aa73
43
index.js
43
index.js
|
@ -1,23 +1,40 @@
|
||||||
const WebSocket = require('ws');
|
const WebSocket = require('ws');
|
||||||
const R3 = require('./r3.js');
|
|
||||||
const config = require('./config');
|
const config = require('./config');
|
||||||
const http = require('http');
|
const http = require('http');
|
||||||
const https = require('https');
|
|
||||||
|
|
||||||
var server = null;
|
var server = http.createServer();
|
||||||
|
|
||||||
if (config.websocket.protocol === R3.API.Server.PROTOCOL_WEBSOCKET_SSL) {
|
|
||||||
server = https.createServer();
|
|
||||||
} else {
|
|
||||||
server = http.createServer();
|
|
||||||
}
|
|
||||||
|
|
||||||
const wss = new WebSocket.Server(
|
const wss = new WebSocket.Server(
|
||||||
{
|
{
|
||||||
port : config.websocket.port,
|
server : server,
|
||||||
host : config.websocket.url,
|
perMessageDeflate: false
|
||||||
perMessageDeflate: false,
|
}
|
||||||
server : server
|
);
|
||||||
|
|
||||||
|
server.on(
|
||||||
|
'listening',
|
||||||
|
function() {
|
||||||
|
|
||||||
|
var address = server.address();
|
||||||
|
|
||||||
|
console.log(
|
||||||
|
'R3 Websocket Server started listening on ' + address.address +
|
||||||
|
':' + address.port,
|
||||||
|
'(' + address.family + ')'
|
||||||
|
);
|
||||||
|
|
||||||
|
}
|
||||||
|
);
|
||||||
|
|
||||||
|
wss.on(
|
||||||
|
'connection',
|
||||||
|
function connection(websocket) {
|
||||||
|
|
||||||
|
websocket.on('message', function incoming(message) {
|
||||||
|
console.log('received: %s', message);
|
||||||
|
});
|
||||||
|
|
||||||
|
websocket.send('something');
|
||||||
}
|
}
|
||||||
);
|
);
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue