kurento-client-php:当前PHP客户端

<?php /* * This file is part of the Kurento Client php package. * * (c) Milan Rukavina * * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. */ require_once("../../vendor/autoload.php"); use Devristo\Phpws\Framing\WebSocketFrame; use Devristo\Phpws\Framing\WebSocketOpcode; use Devristo\Phpws\Messaging\WebSocketMessageInterface; use Devristo\Phpws\Protocol\WebSocketTransportInterface; use Devristo\Phpws\Server\IWebSocketServerObserver; use Devristo\Phpws\Server\UriHandler\WebSocketUriHandler; use Devristo\Phpws\Server\WebSocketServer; /** * This CallHandler handler below will respond to all messages sent to /call (e.g. ws://localhost:8080/call) * * first run WS server with php index.php */ class CallHandler extends WebSocketUriHandler { protected $loop = null; protected $registry = array(); protected $pipelines = array(); /** * * @var \MgKurentoClient\KurentoClient */ protected $client = null; /** * * @var \MgKurentoClient\Interfaces\MediaPipeline */ protected $pipeline = null; protected $wsUrl = 'ws://127.0.0.1:8888/kurento'; /** * * @var \MgKurentoClient\WebRtcEndpoint */ protected $webRtcEndpoint = null; function __construct($logger, $loop) { $this->loop = $loop; parent::__construct($logger); $this->client = \MgKurentoClient\KurentoClient::create($this->wsUrl, $this->loop, $this->logger, function($client){ $this->logger->notice("KurentoClient created"); }); } /** * A client disconnected * * @param WebSocketTransportInterface $session */ public function onDisconnect(WebSocketTransportInterface $session){ unset($this->registry[$session->getId()]); } protected function sendResponse(WebSocketTransportInterface $session, $id, $response, $message = '', $params = array()){ $resultParams = array_merge(array( "id" => $id, "response" => $response, "message" => $message ), $params); $session->sendString(json_encode($resultParams, JSON_UNESCAPED_SLASHES)); } /** * New message * * @param WebSocketTransportInterface $session * @param WebSocketMessageInterface $msg */ public function onMessage(WebSocketTransportInterface $session, WebSocketMessageInterface $msg) { $message = json_decode($msg->getData(), true); /* @var $user UserSession */ $user = null; if(isset($this->registry[$session->getId()])){ $user = $this->registry[$session->getId()]; $this->logger->notice("message: " . $msg->getData() . " from User: " . $user->getName()); } else{ $this->logger->notice("message: " . $msg->getData() . " from new User"); } switch ($message['id']) { case 'register': $this->register($session, $message); break; case 'call': $this->call($user, $message); break; case 'incomingCallResponse': $this->incomingCallResponse($user, $message); break; case 'play': $this->play($session, $message); case 'stop': $this->stop($session); break; default: break; } } /** * Name exists * * @param string $name * @return boolean */ protected function registryNameExists($name){ return $this->registryGetByName($name) !== false; } /** * Get user * * @param string $name * @return boolean|UserSession */ protected function registryGetByName($name){ /* @var $user UserSession */ foreach ($this->registry as $sessionId => $user) { if($name == $user->getName()){ return $this->registry[$sessionId]; } } return false; } public function register(WebSocketTransportInterface $session, array $message){ $responseMsg = "accepted"; if (!isset($message['name']) || $message['name'] == '') { $responseMsg = "rejected: empty user name"; } elseif ($this->registryNameExists($message['name'])) { $responseMsg = "rejected: user '" . $message['name'] . "' already registered"; } else { $user = new UserSession($session, $message['name']); $this->registry[$session->getId()] = $user; } return $this->sendResponse($session, 'resgisterResponse', $responseMsg); } public function call(UserSession $caller, array $message){ $to = $message['to']; $from = $message['from']; if ($this->registryNameExists($to)) { $callee = $this->registryGetByName($to); $callee->setCallingFrom($from); $caller->setSdpOffer($message["sdpOffer"]); $caller->setCallingTo($to); return $this->sendResponse($callee->getSession(), 'incomingCall', '', '', array('from' => $from)); } else { return $this->sendResponse($caller->getSession(), 'callResponse', "rejected: user '" . $to . "' is not registered"); } } public function incomingCallResponse(UserSession $callee, array $message){ $callResponse = $message['callResponse']; $caller = $this->registryGetByName($message['from']); if ("accept" == $callResponse) { $this->logger->notice("Accepted call from: " . $message['from'] . " from User: " . $callee->getName()); $pipeline = null; $callee->setSdpOffer($message["sdpOffer"]); try { $pipeline = new CallMediaPipeline($this->client, $caller->getName(), $callee->getName(), function($pipeline) use ($message, $callee, $caller) { $this->pipelines[$caller->getSession()->getId()] = $pipeline; $this->pipelines[$callee->getSession()->getId()] = $pipeline; $pipeline->generateSdpAnswerForCallee($callee->getSdpOffer(), function ($success, $data) use($pipeline, $caller, $callee){ $calleeSdpAnswer = $data['value']; $pipeline->generateSdpAnswerForCaller($caller->getSdpOffer(), function ($success, $data) use ($pipeline, $calleeSdpAnswer, $caller, $callee){ //start recoding imidiatelly $pipeline->record(function($success, $data){}); $callerSdpAnswer = $data['value']; $this->sendResponse($callee->getSession(), 'startCommunication', '', '', array('sdpAnswer' => $calleeSdpAnswer)); $this->sendResponse($caller->getSession(), 'callResponse', 'accepted', '', array('sdpAnswer' => $callerSdpAnswer)); }); }); }); } catch (Exception $exc) { $this->logger->error($exc->getMessage()); if($pipeline != null){ $pipeline->release(); } unset($this->pipelines[$caller->getSession()->getId()]); unset($this->pipelines[$callee->getSession()->getId()]); $this->sendResponse($caller->getSession(), 'callResponse', "rejected"); $this->sendResponse($callee->getSession(), 'stopCommunication', ""); } } else { return $this->sendResponse($caller['session'], 'callResponse', "rejected"); } } pu