47 lines
1.5 KiB
PHP
47 lines
1.5 KiB
PHP
<?php
|
|
namespace Ratchet\WebSocket;
|
|
|
|
class MessageParser {
|
|
public function onData(WsConnection $from, $data) {
|
|
if (!isset($from->WebSocket->message)) {
|
|
$from->WebSocket->message = $from->WebSocket->version->newMessage();
|
|
}
|
|
|
|
// There is a frame fragment attatched to the connection, add to it
|
|
if (!isset($from->WebSocket->frame)) {
|
|
$from->WebSocket->frame = $from->WebSocket->version->newFrame();
|
|
}
|
|
|
|
$from->WebSocket->frame->addBuffer($data);
|
|
if ($from->WebSocket->frame->isCoalesced()) {
|
|
// check if masked
|
|
// close if not
|
|
|
|
if ($from->WebSocket->frame->getOpcode() > 2) {
|
|
// take action on the control frame
|
|
|
|
unset($from->WebSocket->frame);
|
|
|
|
return;
|
|
}
|
|
|
|
// Check frame
|
|
// If is control frame, do your thing
|
|
// Else, add to message
|
|
// Control frames (ping, pong, close) can be sent in between a fragmented message
|
|
|
|
$nextFrame = $from->WebSocket->version->newFrame();
|
|
$nextFrame->addBuffer($from->WebSocket->frame->extractOverflow());
|
|
|
|
$from->WebSocket->message->addFrame($from->WebSocket->frame);
|
|
$from->WebSocket->frame = $nextFrame;
|
|
}
|
|
|
|
if ($from->WebSocket->message->isCoalesced()) {
|
|
$parsed = (string)$from->WebSocket->message;
|
|
unset($from->WebSocket->message);
|
|
|
|
return $parsed;
|
|
}
|
|
}
|
|
} |