multiparty-meeting/server/lib/Peer.js

const EventEmitter = require('events').EventEmitter;
const Logger = require('./Logger');

const logger = new Logger('Peer');

class Peer extends EventEmitter
{
	constructor({ id, socket })
	{
		logger.info('constructor() [id:"%s", socket:"%s"]', id, socket.id);
		super();

		this._id = id;

		this._socket = socket;

		this._closed = false;

		this._joined = false;

		this._authenticated = false;

		this._displayName = false;

		this._picture = null;

		this._device = null;

		this._rtpCapabilities = null;

		this._raisedHand = false;

		this._transports = new Map();

		this._producers = new Map();

		this._consumers = new Map();

		this._checkAuthentication();

		this._handlePeer();
	}

	close()
	{
		logger.info('close()');

		this._closed = true;

		// Iterate and close all mediasoup Transport associated to this Peer, so all
		// its Producers and Consumers will also be closed.
		this.transports.forEach((transport) =>
		{
			transport.close();
		});

		if (this._socket)
			this._socket.disconnect(true);

		this.emit('close');
	}

	_handlePeer()
	{
		this.socket.use((packet, next) =>
		{
			this._checkAuthentication();

			return next();
		});

		this.socket.on('disconnect', () =>
		{
			if (this.closed)
				return;

			logger.debug('"disconnect" event [id:%s]', this.id);

			this.close();
		});
	}

	_checkAuthentication()
	{
		this.authenticated =
			Boolean(this.socket.handshake.session.passport) &&
			Boolean(this.socket.handshake.session.passport.user);
	}

	get id()
	{
		return this._id;
	}

	set id(id)
	{
		this._id = id;
	}

	get socket()
	{
		return this._socket;
	}

	set socket(socket)
	{
		this._socket = socket;
	}

	get closed()
	{
		return this._closed;
	}

	get joined()
	{
		return this._joined;
	}

	set joined(joined)
	{
		this._joined = joined;
	}

	get authenticated()
	{
		return this._authenticated;
	}

	set authenticated(authenticated)
	{
		if (authenticated !== this._authenticated)
		{
			this._authenticated = authenticated;
			this.emit('authenticationChange');
		}
	}

	get displayName()
	{
		return this._displayName;
	}

	set displayName(displayName)
	{
		this._displayName = displayName;
	}

	get picture()
	{
		return this._picture;
	}

	set picture(picture)
	{
		this._picture = picture;
	}

	get device()
	{
		return this._device;
	}

	set device(device)
	{
		this._device = device;
	}

	get rtpCapabilities()
	{
		return this._rtpCapabilities;
	}

	set rtpCapabilities(rtpCapabilities)
	{
		this._rtpCapabilities = rtpCapabilities;
	}

	get raisedHand()
	{
		return this._raisedHand;
	}

	set raisedHand(raisedHand)
	{
		this._raisedHand = raisedHand;
	}

	get transports()
	{
		return this._transports;
	}

	get producers()
	{
		return this._producers;
	}

	get consumers()
	{
		return this._consumers;
	}

	addTransport(id, transport)
	{
		this.transports.set(id, transport);
	}

	getTransport(id)
	{
		return this.transports.get(id);
	}

	getConsumerTransport()
	{
		return Array.from(this.transports.values())
			.find((t) => t.appData.consuming);
	}

	removeTransport(id)
	{
		this.transports.delete(id);
	}

	addProducer(id, producer)
	{
		this.producers.set(id, producer);
	}

	getProducer(id)
	{
		return this.producers.get(id);
	}

	removeProducer(id)
	{
		this.producers.delete(id);
	}

	addConsumer(id, consumer)
	{
		this.consumers.set(id, consumer);
	}

	getConsumer(id)
	{
		return this.consumers.get(id);
	}

	removeConsumer(id)
	{
		this.consumers.delete(id);
	}

	get peerInfo()
	{
		const peerInfo =
		{
			id          : this.id,
			displayName : this.displayName,
			picture     : this.picture,
			device      : this.device
		};

		return peerInfo;
	}
}

module.exports = Peer;