1 files changed, 103 insertions, 0 deletions
diff --git a/vendor/ruflin/elastica/test/lib/Elastica/Test/ConnectionTest.php b/vendor/ruflin/elastica/test/lib/Elastica/Test/ConnectionTest.php
new file mode 100644
index 00000000..80cab9f0
--- /dev/null
+++ b/vendor/ruflin/elastica/test/lib/Elastica/Test/ConnectionTest.php
@@ -0,0 +1,103 @@
+<?php
+
+namespace Elastica\Test;
+
+use Elastica\Connection;
+use Elastica\Request;
+use Elastica\Test\Base as BaseTest;
+
+class ConnectionTest extends BaseTest
+{
+
+    public function testEmptyConstructor()
+    {
+        $connection = new Connection();
+        $this->assertEquals(Connection::DEFAULT_HOST, $connection->getHost());
+        $this->assertEquals(Connection::DEFAULT_PORT, $connection->getPort());
+        $this->assertEquals(Connection::DEFAULT_TRANSPORT, $connection->getTransport());
+        $this->assertInstanceOf('Elastica\Transport\AbstractTransport', $connection->getTransportObject());
+        $this->assertEquals(Connection::TIMEOUT, $connection->getTimeout());
+        $this->assertEquals(array(), $connection->getConfig());
+        $this->assertTrue($connection->isEnabled());
+    }
+
+    public function testEnabledDisable()
+    {
+        $connection = new Connection();
+        $this->assertTrue($connection->isEnabled());
+        $connection->setEnabled(false);
+        $this->assertFalse($connection->isEnabled());
+        $connection->setEnabled(true);
+        $this->assertTrue($connection->isEnabled());
+    }
+
+    /**
+     * @expectedException \Elastica\Exception\ConnectionException
+     */
+    public function testInvalidConnection()
+    {
+        $connection = new Connection(array('port' => 9999));
+
+        $request = new Request('_status', Request::GET);
+        $request->setConnection($connection);
+
+        // Throws exception because no valid connection
+        $request->send();
+    }
+
+    public function testCreate()
+    {
+        $connection = Connection::create();
+        $this->assertInstanceOf('Elastica\Connection', $connection);
+
+        $connection = Connection::create(array());
+        $this->assertInstanceOf('Elastica\Connection', $connection);
+
+        $port = 9999;
+        $connection = Connection::create(array('port' => $port));
+        $this->assertInstanceOf('Elastica\Connection', $connection);
+        $this->assertEquals($port, $connection->getPort());
+    }
+
+    /**
+     * @expectedException \Elastica\Exception\InvalidException
+     * @expectedException \Elastica\Exception\InvalidException
+     */
+    public function testCreateInvalid()
+    {
+        Connection::create('test');
+    }
+
+    public function testGetConfig()
+    {
+        $url = 'test';
+        $connection = new Connection(array('config' => array('url' => $url)));
+        $this->assertTrue($connection->hasConfig('url'));
+        $this->assertEquals($url, $connection->getConfig('url'));
+    }
+
+    public function testGetConfigWithArrayUsedForTransport()
+    {
+        $connection = new Connection(array('transport' => array('type' => 'Http')));
+        $this->assertInstanceOf('Elastica\Transport\Http', $connection->getTransportObject());
+    }
+
+    /**
+     * @expectedException Elastica\Exception\InvalidException
+     * @expectedExceptionMessage Invalid transport
+     */
+    public function testGetInvalidConfigWithArrayUsedForTransport()
+    {
+        $connection = new Connection(array('transport' => array('type' => 'invalidtransport')));
+        $connection->getTransportObject();
+    }
+
+    /**
+     * @expectedException \Elastica\Exception\InvalidException
+     */
+    public function testGetConfigInvalidValue()
+    {
+        $connection = new Connection();
+        $connection->getConfig('url');
+    }
+}