46 lines
1.1 KiB
PHP
46 lines
1.1 KiB
PHP
<?php
|
|
namespace Ratchet\WebSocket;
|
|
use Ratchet\AbstractConnectionDecorator;
|
|
use Ratchet\RFC6455\Messaging\DataInterface;
|
|
use Ratchet\RFC6455\Messaging\Frame;
|
|
|
|
/**
|
|
* {@inheritdoc}
|
|
* @property \StdClass $WebSocket
|
|
*/
|
|
class WsConnection extends AbstractConnectionDecorator {
|
|
/**
|
|
* {@inheritdoc}
|
|
*/
|
|
public function send($msg, $isBinary = false) {
|
|
if (!$this->WebSocket->closing) {
|
|
if (!($msg instanceof DataInterface)) {
|
|
$msg = new Frame($msg, true, ((boolean)$isBinary ? Frame::OP_TEXT : Frame::OP_BINARY));
|
|
}
|
|
|
|
$this->getConnection()->send($msg->getContents());
|
|
}
|
|
|
|
return $this;
|
|
}
|
|
|
|
/**
|
|
* @param int|\Ratchet\RFC6455\Messaging\DataInterface
|
|
*/
|
|
public function close($code = 1000) {
|
|
if ($this->WebSocket->closing) {
|
|
return;
|
|
}
|
|
|
|
if ($code instanceof DataInterface) {
|
|
$this->send($code);
|
|
} else {
|
|
$this->send(new Frame(pack('n', $code), true, Frame::OP_CLOSE));
|
|
}
|
|
|
|
$this->getConnection()->close();
|
|
|
|
$this->WebSocket->closing = true;
|
|
}
|
|
}
|