[rbdr/forum] / app / socket_coordinator.js

import { socketServer } from './config/config';

const internals = {

  socket: null, // stores the socket connection

  connect() {

    internals.socket = new WebSocket(socketServer);
  }
};

export const onMessage = function (listener) {

  if (!internals.socket) {
    internals.connect();
  }

  internals.socket.addEventListener('message', (message) => {

    listener(JSON.parse(message.data));
  });
};
Commit	Line	Data
38416066 BB	1	import { socketServer } from './config/config';
	2
	3	const internals = {
	4
	5	socket: null, // stores the socket connection
	6
	7	connect() {
	8
	9	internals.socket = new WebSocket(socketServer);
	10	}
	11	};
	12
	13	export const onMessage = function (listener) {
	14
	15	if (!internals.socket) {
	16	internals.connect();
	17	}
	18
	19	internals.socket.addEventListener('message', (message) => {
	20
	21	listener(JSON.parse(message.data));
	22	});
	23	};