Split API classes and interfaces

docs/api/MongoDB/Command/Command.php

@@ -0,0 +1,14 @@
+<?php
+
+namespace MongoDB\Command;
+
+final class Command
+{
+    /**
+     * @param array|object $document Command document
+     */
+    public function __construct($document)
+    {
+        // ...
+    }
+}

docs/api/MongoDB/Command/CommandCursor.php

@@ -0,0 +1,58 @@
+<?php
+
+namespace MongoDB\Command;
+
+// Note: consider combining implementation with \MongoDB\Query\QueryCursor
+final class CommandCursor implements \MongoDB\Cursor
+{
+    private $server;
+    private $batchSize;
+    private $cursorId;
+    private $firstBatch;
+
+    /**
+     * @param Server  $server
+     * @param integer $cursorId
+     * @param array   $firstBatch
+     */
+    public function __construct(Server $server, $cursorId, array $firstBatch)
+    {
+        $this->server = $server;
+        $this->cursorId = (integer) $cursorId;
+        $this->firstBatch = $firstBatch;
+    }
+
+    // Iterator methods...
+
+    /**
+     * @see \MongoDB\Cursor::getId()
+     */
+    public function getId()
+    {
+        return $this->cursorId;
+    }
+
+    /**
+     * @see \MongoDB\ServerResult::getServer()
+     */
+    public function getServer()
+    {
+        return $this->server;
+    }
+
+    /**
+     * @see \MongoDB\Cursor::setBatchSize()
+     */
+    public function setBatchSize($batchSize)
+    {
+        $this->batchSize = (integer) $batchSize;
+    }
+
+    // Note: this expects consistent command response documents from the server
+    static public function createFromCommandResult(CommandResult $result)
+    {
+        // extract $cursorId and $firstBatch from $result->getResponse()
+
+        return new static($result->getServer(), $cursorId, $firstBatch);
+    }
+}

docs/api/MongoDB/Command/CommandResult.php

@@ -0,0 +1,11 @@
+<?php
+
+namespace MongoDB\Command;
+
+interface CommandResult extends \MongoDB\ServerResult
+{
+    /**
+     * @return array Original response document from the server
+     */
+    function getResponse();
+}

docs/api/MongoDB/Cursor.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace MongoDB;
+
+interface Cursor extends ServerResult, \Iterator
+{
+    /**
+     * @return integer Cursor identifier
+     */
+    function getId();
+
+    /**
+     * @param integer $batchSize
+     */
+    function setBatchSize($batchSize);
+}

docs/api/MongoDB/Manager.php

@@ -0,0 +1,50 @@
+<?php
+
+namespace MongoDB;
+
+final class Manager extends \SplObjectStorage
+{
+    /**
+     * @param Server[] $servers
+     * @param string   $db      Database name
+     * @param array    $options Connection options
+     */
+    public function __construct(array $servers, $db, $options)
+    {
+    }
+
+    static public function fromDSN($dsn)
+    {
+    }
+
+    final public function executeCommand($namespace, \MongoDB\Query $query, \MongoDB\ReadPreference $rp)
+    {
+        foreach($this->getConnectedServers() as $server) {
+            if ($server->matchesReadPreference($rp)) {
+                return $server->executeQuery($namespace, $query);
+            }
+        }
+        throw new NoServerMatchingReadPreference($rp);
+    }
+
+    final public function executeQuery($namespace, \MongoDB\Query $query, \MongoDB\ReadPreference $rp)
+    {
+        foreach($this->getConnectedServers() as $server) {
+            if ($server->matchesReadPreference($rp)) {
+                return $server->executeQuery($namespace, $query);
+            }
+        }
+        throw new NoServerMatchingReadPreference($rp);
+    }
+
+    final function executeWrite($namespace, \MongoDB\WriteBatch $batch, \MongoDB\WriteOptions $wo)
+    {
+        foreach($this->getConnectedServers() as $server) {
+            if ($server->isPrimary()) {
+                return $server->executeWrite($namespace, $batch, $wo);
+            }
+        }
+
+        throw new NoPrimaryAvailable;
+    }
+}

docs/api/MongoDB/Query/Query.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace MongoDB\Query;
+
+final class Query
+{
+    /**
+     * @param array|object $query    Query document
+     * @param array|object $selector Selector document
+     * @param integer      $flags    Query flags
+     * @param integer      $limit    Limit
+     * @param integer      $skip     Skip
+     */
+    public function __construct($query, $selector, $flags, $skip, $limit)
+    {
+        // ...
+    }
+}

docs/api/MongoDB/Query/QueryCursor.php

@@ -0,0 +1,47 @@
+<?php
+
+namespace MongoDB\Query;
+
+// Note: consider combining implementation with \MongoDB\Command\CommandCursor
+final class QueryCursor implements \MongoDB\Cursor
+{
+    private $server;
+    private $batchSize;
+    private $cursorId;
+
+    /**
+     * @param Server  $server
+     * @param integer $cursorId
+     */
+    public function __construct(Server $server, $cursorId)
+    {
+        $this->server = $server;
+        $this->cursorId = (integer) $cursorId;
+    }
+
+    // Iterator methods...
+
+    /**
+     * @see \MongoDB\Cursor::getId()
+     */
+    public function getId()
+    {
+        return $this->cursorId;
+    }
+
+    /**
+     * @see \MongoDB\ServerResult::getServer()
+     */
+    public function getServer()
+    {
+        return $this->server;
+    }
+
+    /**
+     * @see \MongoDB\Cursor::setBatchSize()
+     */
+    public function setBatchSize($batchSize)
+    {
+        $this->batchSize = (integer) $batchSize;
+    }
+}

docs/api/MongoDB/Query/QueryResult.php

@@ -0,0 +1,7 @@
+<?php
+
+namespace MongoDB\Query;
+
+interface QueryResult extends \MongoDB\ServerResult, \Traversable
+{
+}

docs/api/MongoDB/Server.php

@@ -0,0 +1,30 @@
+<?php
+
+namespace MongoDB;
+
+class Server
+{
+    const TYPE_MONGOS     = 0x01;
+    const TYPE_STANDALONE = 0x02;
+    const TYPE_ARBITER    = 0x03;
+    const TYPE_SECONDARY  = 0x04;
+    const TYPE_PRIMARY    = 0x05;
+
+    /* These need to be final as they will not be called by the driver to
+     * retrieve the information; these getters are only useful for userland.
+     */
+    final public function getHostname() {}
+    final public function getPort() {}
+    final public function getLatency() {}
+    final public function getMaxWireVersion() {}
+    final public function getMinWireVersion() {}
+    final public function getServerType() {}
+
+    // extracting config info
+    final public function isPassive() {}
+    final public function isDelayed() {}
+
+    final public function executeCommand($namespace, \MongoDB\Command\Command $command, \MongoDB\ReadPreference $rp) {}
+    final public function executeQuery($namespace, \MongoDB\Query\Query $query, \MongoDB\ReadPreference $rp) {}
+    final public function executeWrite($namespace, \MongoDB\Write\WriteBatch $batch, \MongoDB\WriteOptions $wo) {}
+}

docs/api/MongoDB/ServerError.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace MongoDB;
+
+interface ServerError extends ServerResult
+{
+    /**
+     * @return integer Server error code
+     */
+    function getCode();
+
+    /**
+     * @return string Server error message
+     */
+    function getMessage();
+}