From 2283bdf28856db73eda842accdd584256ccdd0e8 Mon Sep 17 00:00:00 2001
From: Chris Boden <cboden@gmail.com>
Date: Wed, 24 Feb 2016 18:55:04 -0500
Subject: [PATCH] Binary messaging support

Least obtrusive interface
---
 src/Ratchet/WebSocket/BinaryMessageInterface.php | 8 ++++++++
 src/Ratchet/WebSocket/WsConnection.php           | 4 ++--
 tests/autobahn/fuzzingclient-quick.json          | 2 +-
 3 files changed, 11 insertions(+), 3 deletions(-)
 create mode 100644 src/Ratchet/WebSocket/BinaryMessageInterface.php

diff --git a/src/Ratchet/WebSocket/BinaryMessageInterface.php b/src/Ratchet/WebSocket/BinaryMessageInterface.php
new file mode 100644
index 0000000..db28c0b
--- /dev/null
+++ b/src/Ratchet/WebSocket/BinaryMessageInterface.php
@@ -0,0 +1,8 @@
+<?php
+namespace Ratchet\WebSocket;
+use Ratchet\MessageComponentInterface;
+use Ratchet\ConnectionInterface;
+
+interface BinaryMessageInterface extends MessageComponentInterface {
+    public function onMessage(ConnectionInterface $conn, $msg, $isBinary = false);
+}
diff --git a/src/Ratchet/WebSocket/WsConnection.php b/src/Ratchet/WebSocket/WsConnection.php
index d2d04ef..4082fa9 100644
--- a/src/Ratchet/WebSocket/WsConnection.php
+++ b/src/Ratchet/WebSocket/WsConnection.php
@@ -12,10 +12,10 @@ class WsConnection extends AbstractConnectionDecorator {
     /**
      * {@inheritdoc}
      */
-    public function send($msg) {
+    public function send($msg, $isBinary = false) {
         if (!$this->WebSocket->closing) {
             if (!($msg instanceof DataInterface)) {
-                $msg = new Frame($msg);
+                $msg = new Frame($msg, true, ((boolean)$isBinary ? Frame::OP_TEXT : Frame::OP_BINARY));
             }
 
             $this->getConnection()->send($msg->getContents());
diff --git a/tests/autobahn/fuzzingclient-quick.json b/tests/autobahn/fuzzingclient-quick.json
index 3023fb8..c92e805 100644
--- a/tests/autobahn/fuzzingclient-quick.json
+++ b/tests/autobahn/fuzzingclient-quick.json
@@ -7,6 +7,6 @@
     ]
 
   , "cases": ["*"]
-  , "exclude-cases": ["1.2.*", "2.3", "2.4", "2.6", "9.2.*", "9.4.*", "9.6.*", "9.8.*"]
+  , "exclude-cases": []
   , "exclude-agent-cases": {}
 }