芝麻web文件管理V1.00

编辑当前文件:/home/qrafawbu/joolsmen.com/chat/vendor/cboden/ratchet/tests/unit/Wamp/TopicManagerTest.php

<?php
namespace Ratchet\Wamp;

/**
 * @covers Ratchet\Wamp\TopicManager
 */
class TopicManagerTest extends \PHPUnit_Framework_TestCase {
    private $mock;

/**
     * @var \Ratchet\Wamp\TopicManager
     */
    private $mngr;

/**
     * @var \Ratchet\ConnectionInterface
     */
    private $conn;

public function setUp() {
        $this->conn = $this->getMock('\Ratchet\ConnectionInterface');
        $this->mock = $this->getMock('\Ratchet\Wamp\WampServerInterface');
        $this->mngr = new TopicManager($this->mock);

$this->conn->WAMP = new \StdClass;
        $this->mngr->onOpen($this->conn);
    }

public function testGetTopicReturnsTopicObject() {
        $class  = new \ReflectionClass('Ratchet\Wamp\TopicManager');
        $method = $class->getMethod('getTopic');
        $method->setAccessible(true);

$topic = $method->invokeArgs($this->mngr, array('The Topic'));

$this->assertInstanceOf('Ratchet\Wamp\Topic', $topic);
    }

public function testGetTopicCreatesTopicWithSameName() {
        $name = 'The Topic';

$class  = new \ReflectionClass('Ratchet\Wamp\TopicManager');
        $method = $class->getMethod('getTopic');
        $method->setAccessible(true);

$topic = $method->invokeArgs($this->mngr, array($name));

$this->assertEquals($name, $topic->getId());
    }

public function testGetTopicReturnsSameObject() {
        $class  = new \ReflectionClass('Ratchet\Wamp\TopicManager');
        $method = $class->getMethod('getTopic');
        $method->setAccessible(true);

$topic = $method->invokeArgs($this->mngr, array('No copy'));
        $again = $method->invokeArgs($this->mngr, array('No copy'));

$this->assertSame($topic, $again);
    }

public function testOnOpen() {
        $this->mock->expects($this->once())->method('onOpen');
        $this->mngr->onOpen($this->conn);
    }

public function testOnCall() {
        $id = uniqid();

$this->mock->expects($this->once())->method('onCall')->with(
            $this->conn
          , $id
          , $this->isInstanceOf('Ratchet\Wamp\Topic')
          , array()
        );

$this->mngr->onCall($this->conn, $id, 'new topic', array());
    }

public function testOnSubscribeCreatesTopicObject() {
        $this->mock->expects($this->once())->method('onSubscribe')->with(
            $this->conn, $this->isInstanceOf('Ratchet\Wamp\Topic')
        );

$this->mngr->onSubscribe($this->conn, 'new topic');
    }

public function testTopicIsInConnectionOnSubscribe() {
        $name = 'New Topic';

$class  = new \ReflectionClass('Ratchet\Wamp\TopicManager');
        $method = $class->getMethod('getTopic');
        $method->setAccessible(true);

$topic = $method->invokeArgs($this->mngr, array($name));

$this->mngr->onSubscribe($this->conn, $name);

$this->assertTrue($this->conn->WAMP->subscriptions->contains($topic));
    }

public function testDoubleSubscriptionFiresOnce() {
        $this->mock->expects($this->exactly(1))->method('onSubscribe');

$this->mngr->onSubscribe($this->conn, 'same topic');
        $this->mngr->onSubscribe($this->conn, 'same topic');
    }

public function testUnsubscribeEvent() {
        $name = 'in and out';
        $this->mock->expects($this->once())->method('onUnsubscribe')->with(
            $this->conn, $this->isInstanceOf('Ratchet\Wamp\Topic')
        );

$this->mngr->onSubscribe($this->conn, $name);
        $this->mngr->onUnsubscribe($this->conn, $name);
    }

public function testUnsubscribeFiresOnce() {
        $name = 'getting sleepy';
        $this->mock->expects($this->exactly(1))->method('onUnsubscribe');

$this->mngr->onSubscribe($this->conn,   $name);
        $this->mngr->onUnsubscribe($this->conn, $name);
        $this->mngr->onUnsubscribe($this->conn, $name);
    }

public function testUnsubscribeRemovesTopicFromConnection() {
        $name = 'Bye Bye Topic';

$class  = new \ReflectionClass('Ratchet\Wamp\TopicManager');
        $method = $class->getMethod('getTopic');
        $method->setAccessible(true);

$topic = $method->invokeArgs($this->mngr, array($name));

$this->mngr->onSubscribe($this->conn, $name);
        $this->mngr->onUnsubscribe($this->conn, $name);

$this->assertFalse($this->conn->WAMP->subscriptions->contains($topic));
    }

public function testOnPublishBubbles() {
        $msg = 'Cover all the code!';

$this->mock->expects($this->once())->method('onPublish')->with(
            $this->conn
          , $this->isInstanceOf('Ratchet\Wamp\Topic')
          , $msg
          , $this->isType('array')
          , $this->isType('array')
        );

$this->mngr->onPublish($this->conn, 'topic coverage', $msg, array(), array());
    }

public function testOnCloseBubbles() {
        $this->mock->expects($this->once())->method('onClose')->with($this->conn);
        $this->mngr->onClose($this->conn);
    }

protected function topicProvider($name) {
        $class  = new \ReflectionClass('Ratchet\Wamp\TopicManager');
        $method = $class->getMethod('getTopic');
        $method->setAccessible(true);

$attribute = $class->getProperty('topicLookup');
        $attribute->setAccessible(true);

$topic = $method->invokeArgs($this->mngr, array($name));

return array($topic, $attribute);
    }

public function testConnIsRemovedFromTopicOnClose() {
        $name = 'State Testing';
        list($topic, $attribute) = $this->topicProvider($name);

$this->assertCount(1, $attribute->getValue($this->mngr));

$this->mngr->onSubscribe($this->conn, $name);
        $this->mngr->onClose($this->conn);

$this->assertFalse($topic->has($this->conn));
    }

public static function topicConnExpectationProvider() {
        return [
            [ 'onClose', 0]
          , ['onUnsubscribe', 0]
        ];
    }

/**
     * @dataProvider topicConnExpectationProvider
     */
    public function testTopicRetentionFromLeavingConnections($methodCall, $expectation) {
        $topicName = 'checkTopic';
        list($topic, $attribute) = $this->topicProvider($topicName);

$this->mngr->onSubscribe($this->conn, $topicName);
        call_user_func_array(array($this->mngr, $methodCall), array($this->conn, $topicName));

$this->assertCount($expectation, $attribute->getValue($this->mngr));
    }

public function testOnErrorBubbles() {
        $e = new \Exception('All work and no play makes Chris a dull boy');
        $this->mock->expects($this->once())->method('onError')->with($this->conn, $e);

$this->mngr->onError($this->conn, $e);
    }

public function testGetSubProtocolsReturnsArray() {
        $this->assertInternalType('array', $this->mngr->getSubProtocols());
    }

public function testGetSubProtocolsBubbles() {
        $subs = array('hello', 'world');
        $app  = $this->getMock('Ratchet\Wamp\Stub\WsWampServerInterface');
        $app->expects($this->once())->method('getSubProtocols')->will($this->returnValue($subs));
        $mngr = new TopicManager($app);

$this->assertEquals($subs, $mngr->getSubProtocols());
    }
}