Currently experimenting with setting up a WebSocket using rxjs webSocket
I have managed to create a node server without any errors, but it is not sending messages to the server or connected users
When I switch to 'ws://echo.websocket.org/', I can see messages echoed back to me, however, there is no communication between users subscribed to the websocket in other open browsers
All I need is a straightforward method to exchange basic information among users
index.js
var express = require('express');
var WebSocketServer = require('websocket').server;
var app2 = express()//There is already another app var for main app server
var server2 = http.createServer(app2);
var server2 = app2.listen(8081, function () {
console.log((new Date()) + ' Server is listening on port 8081');
})
wsServer = new WebSocketServer({
httpServer: server2,
autoAcceptConnections: false
});
function originIsAllowed(origin) {
if (origin === 'http://localhost:1234'){
return true;
}
// Add logic here to determine if the specified origin is permitted.
}
wsServer.on('request', function(request) {
if (!originIsAllowed(request.origin)) {
// Ensure that requests are only accepted from an allowed origin
request.reject();
console.log((new Date()) + ' Connection from origin ' + request.origin + ' rejected.');
return;
}
var connection = request.accept(null, request.origin);
console.log((new Date()) + ' Connection accepted.');
connection.on('message', function(message) {
// console.log(message)
if (message.type === 'utf8') {
console.log('Received Message from: ' + connection.remoteAddress);
connection.sendUTF(message.utf8Data);
}
else if (message.type === 'binary') {
console.log('Received Binary Message of ' + message.binaryData.length + ' bytes');
connection.sendBytes(message.binaryData);
}
});
connection.on('close', function(reasonCode, description) {
console.log((new Date()) + ' Peer ' + connection.remoteAddress + ' disconnected.');
});
});
in my clientside socket service:
import { Injectable } from '@angular/core';
import { Observable } from '../../../node_modules/rxjs';
@Injectable()
export class SocketService {
socket$ = Observable.webSocket( 'ws://localhost:8081');
constructor() {
this.connectToSocket()
}
connectToSocket(){
this.socket$.subscribe(
(message) => console.log('message received: ' + message),
(err) => console.log(err),
() => console.log('complete')
);
}
}
To send a message from another component, I use:
this.socketService.socket$.next(JSON.stringify('test'))