[WebSocket] RFC Fragmentation

AB tests 5.* passing
Refs #13

src/Ratchet/WebSocket/Version/RFC6455.php

@@ -130,6 +130,14 @@ class RFC6455 implements VersionInterface {
 
             $overflow = $from->WebSocket->frame->extractOverflow();
 
+            if ($frame::OP_CONTINUE == $frame->getOpcode() && 0 == count($from->WebSocket->message)) {
+                return $from->close($frame::CLOSE_PROTOCOL);
+            }
+
+            if (count($from->WebSocket->message) > 0 && $frame::OP_CONTINUE != $frame->getOpcode()) {
+                return $from->close($frame::CLOSE_PROTOCOL);
+            }
+
             $from->WebSocket->message->addFrame($from->WebSocket->frame);
             unset($from->WebSocket->frame);
         }

src/Ratchet/WebSocket/Version/RFC6455/Message.php

@@ -3,7 +3,7 @@ namespace Ratchet\WebSocket\Version\RFC6455;
 use Ratchet\WebSocket\Version\MessageInterface;
 use Ratchet\WebSocket\Version\FrameInterface;
 
-class Message implements MessageInterface {
+class Message implements MessageInterface, \Countable {
     /**
      * @var SplDoublyLinkedList
      */
@@ -13,6 +13,13 @@ class Message implements MessageInterface {
         $this->_frames = new \SplDoublyLinkedList;
     }
 
+    /**
+     * {@inheritdoc}
+     */
+    public function count() {
+        return count($this->_frames);
+    }
+
     /**
      * {@inheritdoc}
      */