Merge pull request #4 from CharlotteDunoisLabs/close-code

Properly do close code and reason

Author: mbonneau

src/WebSocketConnection.php

@@ -32,22 +32,17 @@ function (Frame $frame) {
                         $this->stream->write((new Frame($frame->getPayload(), true, Frame::OP_PONG))->getContents());
                         return;
                     case Frame::OP_CLOSE:
-                        $closeCode = 1000;
-                        if ($frame->getPayloadLength() >= 2) {
-                            list($closeCode) = array_merge(unpack('n*', substr($frame->getPayload(), 0, 2)));
-                        }
-
-                        $this->stream->end($frame->getContents());
+                        $closeCode = unpack('n*', substr($frame->getPayload(), 0, 2));
+                        $closeCode = reset($closeCode) ?: 1000;
+                        $reason = '';
 
-                        if ($closeCode >= 2000) {
-                            // emit close code as error
-                            $exception = new \Exception('WebSocket closed with code ' . $closeCode);
-                            $this->emit('error', [$exception, $this]);
-                            return;
+                        if ($frame->getPayloadLength() > 2) {
+                            $reason = substr($frame->getPayload(), 2);
                         }
 
-                        $this->emit('close', [$closeCode, $this]);
+                        $this->stream->end($frame->getContents());
 
+                        $this->emit('close', [$closeCode, $this, $reason]);
                         return;
                 }
             },