Subversion Repositories php-qbpwcf

<?php
namespace Ratchet\WebSocket\Version;
use Ratchet\WebSocket\Version\Hixie76;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;

/**
 * @covers Ratchet\WebSocket\Version\Hixie76
 */
class Hixie76Test extends \PHPUnit_Framework_TestCase {
    protected $_crlf = "\r\n";
    protected $_body = '6dW+XgKfWV0=';

    protected $_version;

    public function setUp() {
        $this->_version = new Hixie76;
    }

    public function testClassImplementsVersionInterface() {
        $constraint = $this->isInstanceOf('\\Ratchet\\WebSocket\\Version\\VersionInterface');
        $this->assertThat($this->_version, $constraint);
    }

    /**
     * @dataProvider keyProvider
     */
    public function testKeySigningForHandshake($accept, $key) {
        $this->assertEquals($accept, $this->_version->generateKeyNumber($key));
    }

    public static function keyProvider() {
        return array(
            array(179922739, '17  9 G`ZD9   2 2b 7X 3 /r90')
          , array(906585445, '3e6b263  4 17 80')
          , array(0, '3e6b26341780')
        );
    }

    public function headerProvider() {
        $key1 = base64_decode('QTN+ICszNiA2IDJvICBWOG4gNyAgc08yODhZ');
        $key2 = base64_decode('TzEyICAgeVsgIFFSNDUgM1IgLiAyOFggNC00dn4z');

        $headers  = "GET / HTTP/1.1";
        $headers .= "Upgrade: WebSocket{$this->_crlf}";
        $headers .= "Connection: Upgrade{$this->_crlf}";
        $headers .= "Host: socketo.me{$this->_crlf}";
        $headers .= "Origin: http://fiddle.jshell.net{$this->_crlf}";
        $headers .= "Sec-WebSocket-Key1:17 Z4< F94 N3  7P41  7{$this->_crlf}";
        $headers .= "Sec-WebSocket-Key2:1 23C3:,2% 1-29  4 f0{$this->_crlf}";
        $headers .= "(Key3):70:00:EE:6E:33:20:90:69{$this->_crlf}";
        $headers .= $this->_crlf;

        return $headers;
    }

    public function testNoUpgradeBeforeBody() {
        $headers = $this->headerProvider();

        $mockConn = $this->getMock('\Ratchet\ConnectionInterface');
        $mockApp  = $this->getMock('\Ratchet\MessageComponentInterface');

        $server = new HttpServer(new WsServer($mockApp));
        $server->onOpen($mockConn);
        $mockApp->expects($this->exactly(0))->method('onOpen');
        $server->onMessage($mockConn, $headers);
    }

    public function testTcpFragmentedUpgrade() {
        $headers = $this->headerProvider();
        $body    = base64_decode($this->_body);

        $mockConn = $this->getMock('\Ratchet\ConnectionInterface');
        $mockApp  = $this->getMock('\Ratchet\MessageComponentInterface');

        $server = new HttpServer(new WsServer($mockApp));
        $server->onOpen($mockConn);
        $server->onMessage($mockConn, $headers);

        $mockApp->expects($this->once())->method('onOpen');
        $server->onMessage($mockConn, $body . $this->_crlf . $this->_crlf);
    }

    public function testTcpFragmentedBodyUpgrade() {
        $headers = $this->headerProvider();
        $body    = base64_decode($this->_body);
        $body1   = substr($body, 0, 4);
        $body2   = substr($body, 4);

        $mockConn = $this->getMock('\Ratchet\ConnectionInterface');
        $mockApp  = $this->getMock('\Ratchet\MessageComponentInterface');

        $server = new HttpServer(new WsServer($mockApp));
        $server->onOpen($mockConn);
        $server->onMessage($mockConn, $headers);

        $mockApp->expects($this->once())->method('onOpen');

        $server->onMessage($mockConn, $body1);
        $server->onMessage($mockConn, $body2);
        $server->onMessage($mockConn, $this->_crlf . $this->_crlf);
    }
}