Differential D2233 Diff 6319 src/app/Observers/OpenVidu/ConnectionObserver.php

Changeset View

Standalone View

src/app/Observers/OpenVidu/ConnectionObserver.php

Show All 9 Lines	class ConnectionObserver
* Handle the OpenVidu connection "updated" event.		* Handle the OpenVidu connection "updated" event.
*		*
* @param \App\OpenVidu\Connection $connection The connection.		* @param \App\OpenVidu\Connection $connection The connection.
*		*
* @return void		* @return void
*/		*/
public function updated(Connection $connection)		public function updated(Connection $connection)
{		{
if ($connection->role != $connection->getOriginal('role')) {		$params = [];
$params = [
'connectionId' => $connection->id,
'role' => $connection->role
];

// Send the signal to all participants		// Role change
$connection->room->signal('connectionUpdate', $params);		if ($connection->role != $connection->getOriginal('role')) {
		$params['role'] = $connection->role;

// TODO: When demoting publisher to subscriber maybe we should		// TODO: When demoting publisher to subscriber maybe we should
// destroy all streams using REST API. For now we trust the		// destroy all streams using REST API. For now we trust the
// participant browser to do this.		// participant browser to do this.
}		}

		// Rised hand state change
		$newState = $connection->metadata['hand'] ?? null;
		$oldState = $this->getOriginal($connection, 'metadata')['hand'] ?? null;

		if ($newState !== $oldState) {
		$params['hand'] = !empty($newState);
		}

		// Send the signal to all participants
		if (!empty($params)) {
		$params['connectionId'] = $connection->id;
		$connection->room->signal('connectionUpdate', $params);
		}
		}

		/**
		* A wrapper to getOriginal() on an object
		*
		* @param \App\OpenVidu\Connection $connection The connection.
		* @param string $property The property name
		*
		* @return mixed
		*/
		private function getOriginal($connection, $property)
		{
		$original = $connection->getOriginal($property);

		// The original value for a property is in a format stored in database
		// I.e. for 'metadata' it is a JSON string instead of an array
		if ($property == 'metadata') {
		$original = json_decode($original, true);
		}

		return $original;
}		}
}		}