src/core/stream/StreamManager.js

import Remote from './Remote';

/**
 * @access protected
 */
export default class StreamManager {
	/**
	 * Constructor
	 * @access protected
	 */
	constructor() {
		/**
		 * Shared local streams
		 * @type {{*: Local}}
		 */
		this.shared = {};
		/**
		 * Subscribed remote streams
		 * @type {{*: Remote}}
		 */
		this.remote = {};
	}

	/**
	 * Get a Remote stream reference
	 * @param {object} streamData
	 * @returns {Remote}
	 */
	getRemote(streamData) {
		let remoteStream = this.remote[streamData.uid];
		if(remoteStream) {
			remoteStream.update(streamData);
		} else {
			this.remote[streamData.uid] = remoteStream = new Remote(streamData);
		}
		return remoteStream;
	}

	/**
	 * Get a Remote stream reference
	 * @param {object} streamData
	 * @returns {Remote}
	 */
	getShared(streamData) {
		// TODO: If it does not exists locally as it should, maybe we should remove it ?
		return this.shared[streamData.uid];
	}

}