Initial commit

.gitignore

@@ -0,0 +1,2 @@
+composer.lock
+vendor/

.travis.yml

@@ -0,0 +1,25 @@
+sudo: false
+language: php
+
+php:
+  - 5.5
+  - 5.6
+  - 7.0
+
+env:
+  matrix:
+    - DRIVER_VERSION=1.1.1
+
+addons:
+  apt:
+    sources:
+    - mongodb-upstart
+    packages:
+    - mongodb-org-server
+
+before_script:
+  - pecl install -f mongodb-${DRIVER_VERSION}
+  - composer install --dev
+
+script:
+    - vendor/bin/phpunit

LICENSE

@@ -0,0 +1,19 @@
+Copyright (c) 2006-2015 Doctrine Project
+
+Permission is hereby granted, free of charge, to any person obtaining a copy of
+this software and associated documentation files (the "Software"), to deal in
+the Software without restriction, including without limitation the rights to
+use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies
+of the Software, and to permit persons to whom the Software is furnished to do
+so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

README.md

@@ -0,0 +1,23 @@
+# Mongo PHP Adapter
+
+The Mongo PHP Adapter is a userland library designed to act as an adapter 
+between applications relying on ext-mongo and the new driver (ext-mongodb).
+
+It provides the API of ext-mongo built on top of mongo-php-library, thus being
+compatible with PHP7.
+
+# Stability
+
+This library is not yet stable enough to be used in production. Use at your own
+risk.
+
+# Installation
+
+This library requires you to have the mongodb extension installed and conflicts
+with the legacy mongo extension.
+
+The preferred method of installing this library is with
+[Composer](https://getcomposer.org/) by running the following from your project
+root:
+
+    $ composer require "alcaeus/mongo-php-adapter=dev-master"

composer.json

@@ -0,0 +1,36 @@
+{
+    "name": "alcaeus/mongo-php-adapter",
+    "type": "library",
+    "description": "Adapter to provide ext-mongo interface on top of mongo-php-libary",
+    "keywords": ["mongodb", "database"],
+    "authors": [
+        { "name": "alcaeus", "email": "alcaeus@alcaeus.org" }
+    ],
+    "require": {
+        "php": "^5.5 || ^7.0",
+        "mongodb/mongodb": "1.0.0-beta2"
+    },
+    "require-dev": {
+        "phpunit/phpunit": "^4.8 || ^5.0"
+    },
+    "conflict": {
+        "ext-mongo": "*"
+    },
+    "replace": {
+        "ext-mongo": "self.version"
+    },
+    "autoload": {
+        "psr-4": {
+            "": "lib/Mongo",
+            "Alcaeus\\MongoDbAdapter\\": "lib/Alcaeus/MongoDbAdapter"
+        }
+    },
+    "autoload-dev": {
+        "psr-4": { "Alcaeus\\MongoDbAdapter\\Tests\\": "tests/Alcaeus/MongoDbAdapter" }
+    },
+    "extra": {
+        "branch-alias": {
+            "dev-master": "1.0.x-dev"
+        }
+    }
+}

lib/Alcaeus/MongoDbAdapter/TypeConverter.php

@@ -0,0 +1,68 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+namespace Alcaeus\MongoDbAdapter;
+
+/**
+ * @internal
+ */
+class TypeConverter
+{
+    public static function convertLegacyArrayToObject($array)
+    {
+        // TODO: provide actual class
+        $result = new \stdClass();
+
+        foreach ($array as $key => $value) {
+            $result->$key = (is_array($value)) ? static::convertLegacyArrayToObject($value) : static::convertToModernType($value);
+        }
+
+        return $result;
+    }
+
+    public static function convertObjectToLegacyArray($object)
+    {
+        $result = [];
+
+        foreach ($object as $key => $value) {
+            // TODO: maybe add a more meaningful check instead of stdClass?
+            $result[$key] = ($value instanceof \stdClass) ? static::convertObjectToLegacyArray($value) : static::convertToLegacyType($value);
+        }
+
+        return $result;
+    }
+
+    public static function convertToLegacyType($value)
+    {
+        switch (true) {
+            case $value instanceof \MongoDB\Driver\ObjectID:
+                return new \MongoId($value);
+
+            default:
+                return $value;
+        }
+    }
+
+    public static function convertToModernType($value)
+    {
+        switch (true) {
+            case $value instanceof \MongoId:
+                return $value->getObjectID();
+
+            default:
+                return $value;
+        }
+    }
+}

lib/Mongo/Mongo.php

@@ -0,0 +1,167 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+/**
+ * The connection point between MongoDB and PHP.
+ * This class is used to initiate a connection and for database server commands.
+ * @link http://www.php.net/manual/en/class.mongo.php
+ * @deprecated This class has been DEPRECATED as of version 1.3.0.
+ * Relying on this feature is highly discouraged. Please use MongoClient instead.
+ * @see MongoClient
+ */
+class Mongo extends MongoClient {
+    /**
+     * @deprecated This feature has been DEPRECATED as of version 1.2.3. Relying on this feature is highly discouraged. Please use MongoPool::getSize() instead.
+     * (PECL mongo &gt;= 1.2.0)<br/>
+     * Get pool size for connection pools
+     * @link http://php.net/manual/en/mongo.getpoolsize.php
+     * @return int Returns the current pool size.
+     */
+    public function getPoolSize() {}
+    /**
+     * (PECL mongo &gt;= 1.1.0)<br/>
+     * Returns the address being used by this for slaveOkay reads
+     * @link http://php.net/manual/en/mongo.getslave.php
+     * @return bool <p>The address of the secondary this connection is using for reads.
+     * </p>
+     * <p>
+     * This returns <b>NULL</b> if this is not connected to a replica set or not yet
+     * initialized.
+     * </p>
+     */
+    public function getSlave() {}
+    /**
+     * (PECL mongo &gt;= 1.1.0)<br/>
+     * Get slaveOkay setting for this connection
+     * @link http://php.net/manual/en/mongo.getslaveokay.php
+     * @return bool Returns the value of slaveOkay for this instance.
+     */
+    public function getSlaveOkay() {}
+    /**
+     * Connects to paired database server
+     * @deprecated Pass a string of the form "mongodb://server1,server2" to the constructor instead of using this method.
+     * @link http://www.php.net/manual/en/mongo.pairconnect.php
+     * @throws MongoConnectionException
+     * @return boolean
+     */
+    public function pairConnect() {}
+
+    /**
+     * (PECL mongo &gt;= 1.2.0)<br/>
+     * @deprecated This feature has been DEPRECATED as of version 1.2.3. Relying on this feature is highly discouraged. Please use MongoPool::info() instead.
+     * Returns information about all connection pools.
+     * @link http://php.net/manual/en/mongo.pooldebug.php
+     * @return array  Each connection pool has an identifier, which starts with the host. For each pool, this function shows the following fields:
+     * <p><b>in use</b></p>
+     * <p>The number of connections currently being used by MongoClient instances.
+     * in pool
+     * The number of connections currently in the pool (not being used).</p>
+     * <p><b>remaining</b></p>
+     *
+     * <p>The number of connections that could be created by this pool. For example, suppose a pool had 5 connections remaining and 3 connections in the pool. We could create 8 new instances of MongoClient before we exhausted this pool (assuming no instances of MongoClient went out of scope, returning their connections to the pool).
+     *
+     * A negative number means that this pool will spawn unlimited connections.
+     *
+     * Before a pool is created, you can change the max number of connections by calling Mongo::setPoolSize(). Once a pool is showing up in the output of this function, its size cannot be changed.</p>
+     * <p><b>timeout</b></p>
+     *
+     * <p>The socket timeout for connections in this pool. This is how long connections in this pool will attempt to connect to a server before giving up.</p>
+     *
+     */
+    public function poolDebug() {}
+
+    /**
+     * (PECL mongo &gt;= 1.1.0)<br/>
+     * Change slaveOkay setting for this connection
+     * @link http://php.net/manual/en/mongo.setslaveokay.php
+     * @param bool $ok [optional] <p class="para">
+     * If reads should be sent to secondary members of a replica set for all
+     * possible queries using this {@see MongoClient} instance.
+     * </p>
+     * @return bool returns the former value of slaveOkay for this instance.
+     */
+    public function setSlaveOkay ($ok) {}
+    /**
+     * @deprecated Relying on this feature is highly discouraged. Please use MongoPool::setSize() instead.
+     *(PECL mongo &gt;= 1.2.0)<br/>
+     * Set the size for future connection pools.
+     * @link http://php.net/manual/en/mongo.setpoolsize.php
+     * @param $size <p>The max number of connections future pools will be able to create. Negative numbers mean that the pool will spawn an infinite number of connections.</p>
+     * @return bool Returns the former value of pool size.
+     */
+    public function setPoolSize($size) {}
+    /**
+     * Creates a persistent connection with a database server
+     * @link http://www.php.net/manual/en/mongo.persistconnect.php
+     * @deprecated Pass array("persist" => $id) to the constructor instead of using this method.
+     * @param string $username A username used to identify the connection.
+     * @param string $password A password used to identify the connection.
+     * @throws MongoConnectionException
+     * @return boolean If the connection was successful.
+     */
+    public function persistConnect($username = "", $password = "") {}
+
+    /**
+     * Creates a persistent connection with paired database servers
+     * @deprecated Pass "mongodb://server1,server2" and array("persist" => $id) to the constructor instead of using this method.
+     * @link http://www.php.net/manual/en/mongo.pairpersistconnect.php
+     * @param string $username A username used to identify the connection.
+     * @param string $password A password used to identify the connection.
+     * @throws MongoConnectionException
+     * @return boolean If the connection was successful.
+     */
+    public function pairPersistConnect($username = "", $password = "") {}
+
+    /**
+     * Connects with a database server
+     *
+     * @link http://www.php.net/manual/en/mongo.connectutil.php
+     * @throws MongoConnectionException
+     * @return boolean If the connection was successful.
+     */
+    protected function connectUtil() {}
+
+    /**
+     * Check if there was an error on the most recent db operation performed
+     * @deprecated Use MongoDB::lastError() instead.
+     * @link http://www.php.net/manual/en/mongo.lasterror.php
+     * @return array|null Returns the error, if there was one, or NULL.
+     */
+    public function lastError() {}
+
+    /**
+     * Checks for the last error thrown during a database operation
+     * @deprecated Use MongoDB::prevError() instead.
+     * @link http://www.php.net/manual/en/mongo.preverror.php
+     * @return array Returns the error and the number of operations ago it occurred.
+     */
+    public function prevError() {}
+
+    /**
+     * Clears any flagged errors on the connection
+     * @deprecated Use MongoDB::resetError() instead.
+     * @link http://www.php.net/manual/en/mongo.reseterror.php
+     * @return array Returns the database response.
+     */
+    public function resetError() {}
+
+    /**
+     * Creates a database error on the database.
+     * @deprecated Use MongoDB::forceError() instead.
+     * @link http://www.php.net/manual/en/mongo.forceerror.php
+     * @return boolean The database response.
+     */
+    public function forceError() {}
+}

lib/Mongo/MongoBinData.php

@@ -0,0 +1,89 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+class MongoBinData {
+    /**
+     * Generic binary data.
+     * @link http://php.net/manual/en/class.mongobindata.php#mongobindata.constants.custom
+     */
+    const GENERIC = 0x0;
+
+    /**
+     * Function
+     * @link http://php.net/manual/en/class.mongobindata.php#mongobindata.constants.func
+     */
+    const FUNC = 0x1;
+
+    /**
+     * Generic binary data (deprecated in favor of MongoBinData::GENERIC)
+     * @link http://php.net/manual/en/class.mongobindata.php#mongobindata.constants.byte-array
+     */
+    const BYTE_ARRAY = 0x2;
+
+    /**
+     * Universally unique identifier (deprecated in favor of MongoBinData::UUID_RFC4122)
+     * @link http://php.net/manual/en/class.mongobindata.php#mongobindata.constants.uuid
+     */
+    const UUID = 0x3;
+
+    /**
+     * Universally unique identifier (according to » RFC 4122)
+     * @link http://php.net/manual/en/class.mongobindata.php#mongobindata.constants.custom
+     */
+    const UUID_RFC4122 = 0x4;
+
+
+    /**
+     * MD5
+     * @link http://php.net/manual/en/class.mongobindata.php#mongobindata.constants.md5
+     */
+    const MD5 = 0x5;
+
+    /**
+     * User-defined type
+     * @link http://php.net/manual/en/class.mongobindata.php#mongobindata.constants.custom
+     */
+    const CUSTOM = 0x80;
+
+
+    /**
+     * @link http://php.net/manual/en/class.mongobindata.php#mongobindata.props.bin
+     * @var $bin
+     */
+    public $bin;
+
+    /**
+     * @link http://php.net/manual/en/class.mongobindata.php#mongobindata.props.type
+     * @var $type
+     */
+    public $type;
+
+
+    /**
+     * Creates a new binary data object.
+     *
+     * @link http://php.net/manual/en/mongobindata.construct.php
+     * @param string $data Binary data
+     * @param int $type Data type
+     * @return MongoBinData Returns a new binary data object
+     */
+    public function __construct($data, $type = 2) {}
+
+    /**
+     * Returns the string representation of this binary data object.
+     * @return string
+     */
+    public function __toString() {}
+}

lib/Mongo/MongoClient.php

@@ -0,0 +1,279 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+use MongoDB\Client;
+
+/**
+ * A connection between PHP and MongoDB. This class is used to create and manage connections
+ * See MongoClient::__construct() and the section on connecting for more information about creating connections.
+ * @link http://www.php.net/manual/en/class.mongoclient.php
+ */
+class MongoClient
+{
+    const VERSION = '1.6.12';
+    const DEFAULT_HOST = "localhost" ;
+    const DEFAULT_PORT = 27017 ;
+    const RP_PRIMARY = "primary" ;
+    const RP_PRIMARY_PREFERRED = "primaryPreferred" ;
+    const RP_SECONDARY = "secondary" ;
+    const RP_SECONDARY_PREFERRED = "secondaryPreferred" ;
+    const RP_NEAREST = "nearest" ;
+
+    /**
+     * @var bool
+     * @deprecated This will not properly work as the underlying driver connects lazily
+     */
+    public $connected = false;
+
+    /**
+     * @var
+     */
+    public $status;
+
+    /**
+     * @var string
+     */
+    protected $server;
+
+    /**
+     * @var
+     */
+    protected $persistent;
+
+    /**
+     * @var Client
+     */
+    private $client;
+
+    /**
+     * Creates a new database connection object
+     *
+     * @link http://php.net/manual/en/mongo.construct.php
+     * @param string $server The server name.
+     * @param array $options An array of options for the connection.
+     * @param array $driverOptions An array of options for the MongoDB driver.
+     * @throws MongoConnectionException
+     */
+    public function __construct($server = 'mongodb://' . self::DEFAULT_HOST . ':' . self::DEFAULT_PORT, array $options = ["connect" => true], array $driverOptions = [])
+    {
+        $this->server = $server;
+        $this->client = new Client($server, $options, $driverOptions);
+
+        if (isset($options['connect']) && $options['connect']) {
+            $this->connect();
+        }
+    }
+
+    /**
+     * Closes this database connection
+     *
+     * @link http://www.php.net/manual/en/mongoclient.close.php
+     * @param  boolean|string $connection
+     * @return boolean If the connection was successfully closed.
+     */
+    public function close($connection = null)
+    {
+        $this->connected = false;
+
+        return false;
+    }
+
+    /**
+     * Connects to a database server
+     *
+     * @link http://www.php.net/manual/en/mongoclient.connect.php
+     *
+     * @throws MongoConnectionException
+     * @return boolean If the connection was successful.
+     */
+    public function connect()
+    {
+        $this->connected = true;
+
+        return true;
+    }
+
+    /**
+     * Drops a database
+     *
+     * @link http://www.php.net/manual/en/mongoclient.dropdb.php
+     * @param mixed $db The database to drop. Can be a MongoDB object or the name of the database.
+     * @return array The database response.
+     * @deprecated Use MongoDB::drop() instead.
+     */
+    public function dropDB($db)
+    {
+        return $this->selectDB($db)->drop();
+    }
+
+    /**
+     * Gets a database
+     *
+     * @link http://php.net/manual/en/mongoclient.get.php
+     * @param string $dbname The database name.
+     * @return MongoDB The database name.
+     */
+    public function __get($dbname)
+    {
+        return $this->selectDB($dbname);
+    }
+
+    /**
+     * Gets the client for this object
+     *
+     * @internal This part is not of the ext-mongo API and should not be used
+     * @return Client
+     */
+    public function getClient()
+    {
+        return $this->client;
+    }
+
+    /**
+     * Get connections
+     *
+     * Returns an array of all open connections, and information about each of the servers
+     *
+     * @return array
+     */
+    static public function getConnections()
+    {
+        return [];
+    }
+
+    /**
+     * Get hosts
+     *
+     * This method is only useful with a connection to a replica set. It returns the status of all of the hosts in the
+     * set. Without a replica set, it will just return an array with one element containing the host that you are
+     * connected to.
+     *
+     * @return array
+     */
+    public function getHosts()
+    {
+        return [];
+    }
+
+    /**
+     * Get the read preference for this connection
+     *
+     * @return array
+     */
+    public function getReadPreference()
+    {
+        return [];
+    }
+
+    /**
+     * Get the write concern for this connection
+     *
+     * @return array Returns an array describing the write concern.
+     */
+    public function getWriteConcern()
+    {
+        return [];
+    }
+
+    /**
+     * Kills a specific cursor on the server
+     *
+     * @link http://www.php.net/manual/en/mongoclient.killcursor.php
+     * @param string $server_hash The server hash that has the cursor. This can be obtained through
+     * {@link http://www.php.net/manual/en/mongocursor.info.php MongoCursor::info()}.
+     * @param int|MongoInt64 $id The ID of the cursor to kill. You can either supply an {@link http://www.php.net/manual/en/language.types.integer.php int}
+     * containing the 64 bit cursor ID, or an object of the
+     * {@link http://www.php.net/manual/en/class.mongoint64.php MongoInt64} class. The latter is necessary on 32
+     * bit platforms (and Windows).
+     */
+    public function killCursor($server_hash , $id)
+    {
+
+    }
+
+    /**
+     * Lists all of the databases available
+     *
+     * @link http://php.net/manual/en/mongoclient.listdbs.php
+     * @return array Returns an associative array containing three fields. The first field is databases, which in turn contains an array. Each element of the array is an associative array corresponding to a database, giving the database's name, size, and if it's empty. The other two fields are totalSize (in bytes) and ok, which is 1 if this method ran successfully.
+     */
+    public function listDBs()
+    {
+        return $this->client->listDatabases();
+    }
+
+    /**
+     * Gets a database collection
+     *
+     * @link http://www.php.net/manual/en/mongoclient.selectcollection.php
+     * @param string $db The database name.
+     * @param string $collection The collection name.
+     * @return MongoCollection Returns a new collection object.
+     * @throws Exception Throws Exception if the database or collection name is invalid.
+     */
+    public function selectCollection($db, $collection)
+    {
+        return new MongoCollection($this->selectDB($db), $collection);
+    }
+
+    /**
+     * Gets a database
+     *
+     * @link http://www.php.net/manual/en/mongo.selectdb.php
+     * @param string $name The database name.
+     * @return MongoDB Returns a new db object.
+     * @throws InvalidArgumentException
+     */
+    public function selectDB($name)
+    {
+        return new MongoDB($this, $name);
+    }
+
+    /**
+     * Set read preference
+     *
+     * @param string $readPreference
+     * @param array $tags
+     * @return bool
+     */
+    public function setReadPreference($readPreference, $tags = null)
+    {
+        return false;
+    }
+
+    /**
+     * Choose a new secondary for slaveOkay reads
+     *
+     * @link www.php.net/manual/en/mongo.switchslave.php
+     * @return string The address of the secondary this connection is using for reads. This may be the same as the previous address as addresses are randomly chosen. It may return only one address if only one secondary (or only the primary) is available.
+     * @throws MongoException (error code 15) if it is called on a non-replica-set connection. It will also throw MongoExceptions if it cannot find anyone (primary or secondary) to read from (error code 16).
+     */
+    public function switchSlave()
+    {
+        return $this->server;
+    }
+
+    /**
+     * String representation of this connection
+     *
+     * @link http://www.php.net/manual/en/mongoclient.tostring.php
+     * @return string Returns hostname and port for this connection.
+     */
+    public function __toString()
+    {
+        return $this->server;
+    }
+}
+

lib/Mongo/MongoCode.php

@@ -0,0 +1,42 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+class MongoCode {
+    /**
+     * @var $code
+     */
+    public $code;
+
+    /**
+     * @var $scope
+     */
+    public $scope;
+
+    /**
+     * .
+     *
+     * @link http://php.net/manual/en/mongocode.construct.php
+     * @param string $code A string of code
+     * @param array $scope The scope to use for the code
+     * @return MongoCode Returns a new code object
+     */
+    public function __construct($code, array $scope = array()) {}
+
+    /**
+     * Returns this code as a string
+     * @return string
+     */
+    public function __toString() {}
+}

lib/Mongo/MongoCollection.php

@@ -0,0 +1,538 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+use Alcaeus\MongoDbAdapter\TypeConverter;
+
+/**
+ * Represents a database collection.
+ * @link http://www.php.net/manual/en/class.mongocollection.php
+ */
+class MongoCollection
+{
+    const ASCENDING = 1;
+    const DESCENDING = -1;
+
+    /**
+     * @var MongoDB
+     */
+    public $db = NULL;
+
+    /**
+     * @var string
+     */
+    protected $name;
+
+    /**
+     * @var \MongoDB\Collection
+     */
+    protected $collection;
+
+    /**
+     * @var int<p>
+     */
+    public $w;
+
+    /**
+     * @var int <p>
+     */
+    public $wtimeout;
+
+    /**
+     * Creates a new collection
+     * @link http://www.php.net/manual/en/mongocollection.construct.php
+     * @param MongoDB $db Parent database.
+     * @param string $name Name for this collection.
+     * @throws Exception
+     * @return MongoCollection
+     */
+    public function __construct(MongoDB $db, $name)
+    {
+        $this->db = $db;
+        $this->name = $name;
+        $this->collection = $this->db->getDb()->selectCollection($name);
+    }
+
+    /**
+     * Gets the underlying collection for this object
+     *
+     * @internal This part is not of the ext-mongo API and should not be used
+     * @return \MongoDB\Collection
+     */
+    public function getCollection()
+    {
+        return $this->collection;
+    }
+
+    /**
+     * String representation of this collection
+     * @link http://www.php.net/manual/en/mongocollection.--tostring.php
+     * @return string Returns the full name of this collection.
+     */
+    public function __toString()
+    {
+        return (string) $this->db . '.' . $this->name;
+    }
+
+    /**
+     * Gets a collection
+     * @link http://www.php.net/manual/en/mongocollection.get.php
+     * @param string $name The next string in the collection name.
+     * @return MongoCollection
+     */
+    public function __get($name)
+    {
+        return $this->db->selectCollection($this->name . '.' . $name);
+    }
+
+    /**
+     * (PECL mongo &gt;= 1.3.0)<br/>
+     * <p>
+     * The MongoDB
+     * {@link http://docs.mongodb.org/manual/applications/aggregation/ aggregation framework}
+     * provides a means to calculate aggregated values without having to use
+     * MapReduce. While MapReduce is powerful, it is often more difficult than
+     * necessary for many simple aggregation tasks, such as totaling or averaging
+     * field values.
+     * </p>
+     * <p>
+     * This method accepts either a variable amount of pipeline operators, or a
+     * single array of operators constituting the pipeline.
+     * </p>
+     * @link http://www.php.net/manual/en/mongocollection.aggregate.php
+     * @param array $pipeline <p> An array of pipeline operators, or just the first operator. </p>
+     * @param array $op [optional] <p> The second pipeline operator.</p>
+     * @param array $pipelineOperators [optional] <p> Additional pipeline operators. </p>
+     * @return array The result of the aggregation as an array. The ok will be set to 1 on success, 0 on failure.
+     */
+    public function aggregate(array $pipeline, array $op, array $pipelineOperators)
+    {
+//        return $this->collection
+    }
+
+    /**
+     * (PECL mongo &gt;= 1.5.0)<br/>
+     *
+     * <p>
+     * With this method you can execute Aggregation Framework pipelines and retrieve the results
+     * through a cursor, instead of getting just one document back as you would with
+     * {@link http://php.net/manual/en/mongocollection.aggregate.php MongoCollection::aggregate()}.
+     * This method returns a {@link http://php.net/manual/en/class.mongocommandcursor.php MongoCommandCursor} object.
+     * This cursor object implements the {@link http://php.net/manual/en/class.iterator.php Iterator} interface
+     * just like the {@link http://php.net/manual/en/class.mongocursor.php MongoCursor} objects that are returned
+     * by the {@link http://php.net/manual/en/mongocollection.find.php MongoCollection::find()} method
+     * </p>
+     *
+     * @link http://php.net/manual/en/mongocollection.aggregatecursor.php
+     *
+     * @param array $pipeline          <p> The Aggregation Framework pipeline to execute. </p>
+     * @param array $options            [optional] <p> Options for the aggregation command </p>
+     *
+     * @return MongoCommandCursor Returns a {@link http://php.net/manual/en/class.mongocommandcursor.php MongoCommandCursor} object
+     */
+    public function aggregateCursor(array $pipeline, array $options)
+    {
+        return $this->collection->aggregate($pipeline, $options);
+    }
+
+    /**
+     * Returns this collection's name
+     * @link http://www.php.net/manual/en/mongocollection.getname.php
+     * @return string
+     */
+    public function getName()
+    {
+        return $this->name;
+    }
+
+    /**
+     * (PECL mongo &gt;= 1.1.0)<br/>
+     * <p>
+     * See {@link http://www.php.net/manual/en/mongo.queries.php the query section} of this manual for
+     * information on distributing reads to secondaries.
+     * </p>
+     * @link http://www.php.net/manual/en/mongocollection.getslaveokay.php
+     * @return bool Returns the value of slaveOkay for this instance.
+     */
+    public function getSlaveOkay()
+    {
+        $this->notImplemented();
+    }
+
+    /**
+     * (PECL mongo &gt;= 1.1.0)<br/>
+     * <p>
+     * See {@link http://www.php.net/manual/en/mongo.queries.php the query section} of this manual for
+     * information on distributing reads to secondaries.
+     * </p>
+     * @link http://www.php.net/manual/en/mongocollection.setslaveokay.php
+     * @param bool $ok [optional] <p>
+     * If reads should be sent to secondary members of a replica set for all
+     * possible queries using this {@link http://www.php.net/manual/en/class.mongocollection.php MongoCollection}
+     * instance.
+     * @return bool Returns the former value of slaveOkay for this instance.
+     * </p>
+     */
+    public function setSlaveOkay($ok = true)
+    {
+        $this->notImplemented();
+    }
+
+    /**
+     * (PECL mongo &gt;= 1.3.0)<br/>
+     * @link http://www.php.net/manual/en/mongocollection.getreadpreference.php
+     * @return array This function returns an array describing the read preference. The array contains the values <em>type</em> for the string read preference mode
+     * (corresponding to the {@link http://www.php.net/manual/en/class.mongoclient.php MongoClient} constants), and <em>tagsets</em> containing a list of all tag set criteria. If no tag sets were specified, <em>tagsets</em> will not be present in the array.
+     */
+    public function getReadPreference()
+    {
+        $this->notImplemented();
+    }
+
+    /**
+     * (PECL mongo &gt;= 1.3.0)<br/>
+     * @param string $read_preference <p>The read preference mode: <b>MongoClient::RP_PRIMARY</b>, <b>MongoClient::RP_PRIMARY_PREFERRED</b>, <b>MongoClient::RP_SECONDARY</b>, <b>MongoClient::RP_SECONDARY_PREFERRED</b>, or <b>MongoClient::RP_NEAREST</b>.</p>
+     * @param array $tags [optional] <p>An array of zero or more tag sets, where each tag set is itself an array of criteria used to match tags on replica set members.<p>
+     * @return bool Returns <b>TRUE</b> on success, or <b>FALSE</b> otherwise.
+     */
+    public function setReadPreference($read_preference, array $tags)
+    {
+        $this->notImplemented();
+    }
+
+    /**
+     * Drops this collection
+     * @link http://www.php.net/manual/en/mongocollection.drop.php
+     * @return array Returns the database response.
+     */
+    public function drop()
+    {
+        return $this->collection->drop();
+    }
+
+    /**
+     * Validates this collection
+     * @link http://www.php.net/manual/en/mongocollection.validate.php
+     * @param bool $scan_data Only validate indices, not the base collection.
+     * @return array Returns the database's evaluation of this object.
+     */
+    public function validate($scan_data = FALSE)
+    {
+        $this->notImplemented();
+    }
+
+    /**
+     * Inserts an array into the collection
+     * @link http://www.php.net/manual/en/mongocollection.insert.php
+     * @param array|object $a An array or object. If an object is used, it may not have protected or private properties.
+     * Note: If the parameter does not have an _id key or property, a new MongoId instance will be created and assigned to it.
+     * This special behavior does not mean that the parameter is passed by reference.
+     * @param array $options Options for the insert.
+     * <dl>
+     * <dt>"w"
+     * <dd>See WriteConcerns. The default value for MongoClient is 1.
+     * <dt>"fsync"
+     * <dd>Boolean, defaults to FALSE. Forces the insert to be synced to disk before returning success. If TRUE, an acknowledged insert is implied and will override setting w to 0.
+     * <dt>"timeout"
+     * <dd>Integer, defaults to MongoCursor::$timeout. If "safe" is set, this sets how long (in milliseconds) for the client to wait for a database response. If the database does not respond within the timeout period, a MongoCursorTimeoutException will be thrown.
+     * <dt>"safe"
+     * <dd>Deprecated. Please use the WriteConcern w option.
+     * </dl>
+     * @throws MongoException if the inserted document is empty or if it contains zero-length keys. Attempting to insert an object with protected and private properties will cause a zero-length key error.
+     * @throws MongoCursorException if the "w" option is set and the write fails.
+     * @throws MongoCursorTimeoutException if the "w" option is set to a value greater than one and the operation takes longer than MongoCursor::$timeout milliseconds to complete. This does not kill the operation on the server, it is a client-side timeout. The operation in MongoCollection::$wtimeout is milliseconds.
+     * @return bool|array Returns an array containing the status of the insertion if the "w" option is set.
+     * Otherwise, returns TRUE if the inserted array is not empty (a MongoException will be thrown if the inserted array is empty).
+     * If an array is returned, the following keys may be present:
+     * <dl>
+     * <dt>ok
+     * <dd>This should almost be 1 (unless last_error itself failed).
+     * <dt>err
+     * <dd>If this field is non-null, an error occurred on the previous operation. If this field is set, it will be a string describing the error that occurred.
+     * <dt>code
+     * <dd>If a database error occurred, the relevant error code will be passed back to the client.
+     * <dt>errmsg
+     * <dd>This field is set if something goes wrong with a database command. It is coupled with ok being 0. For example, if w is set and times out, errmsg will be set to "timed out waiting for slaves" and ok will be 0. If this field is set, it will be a string describing the error that occurred.
+     * <dt>n
+     * <dd>If the last operation was an update, upsert, or a remove, the number of documents affected will be returned. For insert operations, this value is always 0.
+     * <dt>wtimeout
+     * <dd>If the previous option timed out waiting for replication.
+     * <dt>waited
+     * <dd>How long the operation waited before timing out.
+     * <dt>wtime
+     * <dd>If w was set and the operation succeeded, how long it took to replicate to w servers.
+     * <dt>upserted
+     * <dd>If an upsert occurred, this field will contain the new record's _id field. For upserts, either this field or updatedExisting will be present (unless an error occurred).
+     * <dt>updatedExisting
+     * <dd>If an upsert updated an existing element, this field will be true. For upserts, either this field or upserted will be present (unless an error occurred).
+     * </dl>
+     */
+    public function insert($a, array $options = array())
+    {
+        return $this->collection->insertOne(TypeConverter::convertLegacyArrayToObject($a), $options);
+    }
+
+    /**
+     * Inserts multiple documents into this collection
+     * @link http://www.php.net/manual/en/mongocollection.batchinsert.php
+     * @param array $a An array of arrays.
+     * @param array $options Options for the inserts.
+     * @throws MongoCursorException
+     * @return mixed f "safe" is set, returns an associative array with the status of the inserts ("ok") and any error that may have occured ("err"). Otherwise, returns TRUE if the batch insert was successfully sent, FALSE otherwise.
+     */
+    public function batchInsert(array $a, array $options = array())
+    {
+        return $this->collection->insertMany($a, $options);
+    }
+
+    /**
+     * Update records based on a given criteria
+     * @link http://www.php.net/manual/en/mongocollection.update.php
+     * @param array $criteria Description of the objects to update.
+     * @param array $newobj The object with which to update the matching records.
+     * @param array $options This parameter is an associative array of the form
+     *        array("optionname" => boolean, ...).
+     *
+     *        Currently supported options are:
+     *          "upsert": If no document matches $$criteria, a new document will be created from $$criteria and $$new_object (see upsert example).
+     *
+     *          "multiple": All documents matching $criteria will be updated. MongoCollection::update has exactly the opposite behavior of MongoCollection::remove- it updates one document by
+     *          default, not all matching documents. It is recommended that you always specify whether you want to update multiple documents or a single document, as the
+     *          database may change its default behavior at some point in the future.
+     *
+     *          "safe" Can be a boolean or integer, defaults to false. If false, the program continues executing without waiting for a database response. If true, the program will wait for
+     *          the database response and throw a MongoCursorException if the update did not succeed. If you are using replication and the master has changed, using "safe" will make the driver
+     *          disconnect from the master, throw and exception, and attempt to find a new master on the next operation (your application must decide whether or not to retry the operation on the new master).
+     *          If you do not use "safe" with a replica set and the master changes, there will be no way for the driver to know about the change so it will continuously and silently fail to write.
+     *          If safe is an integer, will replicate the update to that many machines before returning success (or throw an exception if the replication times out, see wtimeout).
+     *          This overrides the w variable set on the collection.
+     *
+     *         "fsync": Boolean, defaults to false. Forces the update to be synced to disk before returning success. If true, a safe update is implied and will override setting safe to false.
+     *
+     *         "timeout" Integer, defaults to MongoCursor::$timeout. If "safe" is set, this sets how long (in milliseconds) for the client to wait for a database response. If the database does
+     *         not respond within the timeout period, a MongoCursorTimeoutException will be thrown
+     * @throws MongoCursorException
+     * @return boolean
+     */
+    public function update(array $criteria , array $newobj, array $options = array())
+    {
+        $multiple = ($options['multiple']) ? $options['multiple'] : false;
+//        $multiple = $options['multiple'] ?? false;
+        $method = $multiple ? 'updateMany' : 'updateOne';
+
+        return $this->collection->$method($criteria, $newobj, $options);
+    }
+
+    /**
+     * (PECL mongo &gt;= 0.9.0)<br/>
+     * Remove records from this collection
+     * @link http://www.php.net/manual/en/mongocollection.remove.php
+     * @param array $criteria [optional] <p>Query criteria for the documents to delete.</p>
+     * @param array $options [optional] <p>An array of options for the remove operation. Currently available options
+     * include:
+     * </p><ul>
+     * <li><p><em>"w"</em></p><p>See {@link http://www.php.net/manual/en/mongo.writeconcerns.php Write Concerns}. The default value for <b>MongoClient</b> is <em>1</em>.</p></li>
+     * <li>
+     * <p>
+     * <em>"justOne"</em>
+     * </p>
+     * <p>
+     * Specify <strong><code>TRUE</code></strong> to limit deletion to just one document. If <strong><code>FALSE</code></strong> or
+     * omitted, all documents matching the criteria will be deleted.
+     * </p>
+     * </li>
+     * <li><p><em>"fsync"</em></p><p>Boolean, defaults to <b>FALSE</b>. If journaling is enabled, it works exactly like <em>"j"</em>. If journaling is not enabled, the write operation blocks until it is synced to database files on disk. If <strong><code>TRUE</code></strong>, an acknowledged insert is implied and this option will override setting <em>"w"</em> to <em>0</em>.</p><blockquote class="note"><p><strong class="note">Note</strong>: <span class="simpara">If journaling is enabled, users are strongly encouraged to use the <em>"j"</em> option instead of <em>"fsync"</em>. Do not use <em>"fsync"</em> and <em>"j"</em> simultaneously, as that will result in an error.</p></blockquote></li>
+     * <li><p><em>"j"</em></p><p>Boolean, defaults to <b>FALSE</b>. Forces the write operation to block until it is synced to the journal on disk. If <strong><code>TRUE</code></strong>, an acknowledged write is implied and this option will override setting <em>"w"</em> to <em>0</em>.</p><blockquote class="note"><p><strong class="note">Note</strong>: <span class="simpara">If this option is used and journaling is disabled, MongoDB 2.6+ will raise an error and the write will fail; older server versions will simply ignore the option.</p></blockquote></li>
+     * <li><p><em>"socketTimeoutMS"</em></p><p>This option specifies the time limit, in milliseconds, for socket communication. If the server does not respond within the timeout period, a <b>MongoCursorTimeoutException</b> will be thrown and there will be no way to determine if the server actually handled the write or not. A value of <em>-1</em> may be specified to block indefinitely. The default value for <b>MongoClient</b> is <em>30000</em> (30 seconds).</p></li>
+     * <li><p><em>"w"</em></p><p>See {@link http://www.php.net/manual/en/mongo.writeconcerns.php Write Concerns }. The default value for <b>MongoClient</b> is <em>1</em>.</p></li>
+     * <li><p><em>"wTimeoutMS"</em></p><p>This option specifies the time limit, in milliseconds, for {@link http://www.php.net/manual/en/mongo.writeconcerns.php write concern} acknowledgement. It is only applicable when <em>"w"</em> is greater than <em>1</em>, as the timeout pertains to replication. If the write concern is not satisfied within the time limit, a <a href="class.mongocursorexception.php" class="classname">MongoCursorException</a> will be thrown. A value of <em>0</em> may be specified to block indefinitely. The default value for {@link http://www.php.net/manual/en/class.mongoclient.php MongoClient} is <em>10000</em> (ten seconds).</p></li>
+     * </ul>
+     *
+     * <p>
+     * The following options are deprecated and should no longer be used:
+     * </p><ul>
+     * <li><p><em>"safe"</em></p><p>Deprecated. Please use the {@link http://www.php.net/manual/en/mongo.writeconcerns.php write concern} <em>"w"</em> option.</p></li>
+     * <li><p><em>"timeout"</em></p><p>Deprecated alias for <em>"socketTimeoutMS"</em>.</p></li>
+     * <li><p><b>"wtimeout"</b></p><p>Deprecated alias for <em>"wTimeoutMS"</em>.</p></p>
+     * @throws MongoCursorException
+     * @throws MongoCursorTimeoutException
+     * @return bool|array <p>Returns an array containing the status of the removal if the
+     * <em>"w"</em> option is set. Otherwise, returns <b>TRUE</b>.
+     * </p>
+     * <p>
+     * Fields in the status array are described in the documentation for
+     * <b>MongoCollection::insert()</b>.
+     * </p>
+     */
+    public function remove(array $criteria = array(), array $options = array())
+    {
+        $multiple = isset($options['justOne']) ? !$options['justOne'] : false;
+//        $multiple = !$options['justOne'] ?? false;
+        $method = $multiple ? 'deleteMany' : 'deleteOne';
+
+        return $this->collection->$method($criteria, $options);
+    }
+
+    /**
+     * Querys this collection
+     * @link http://www.php.net/manual/en/mongocollection.find.php
+     * @param array $query The fields for which to search.
+     * @param array $fields Fields of the results to return.
+     * @return MongoCursor
+     */
+    public function find(array $query = array(), array $fields = array()) {}
+
+    /**
+     * Retrieve a list of distinct values for the given key across a collection
+     * @link http://www.php.net/manual/ru/mongocollection.distinct.php
+     * @param string $key The key to use.
+     * @param array $query An optional query parameters
+     * @return array|bool Returns an array of distinct values, or <b>FALSE</b> on failure
+     */
+    public function distinct ($key, array $query = NULL) {}
+
+    /**
+     * Update a document and return it
+     * @link http://www.php.net/manual/ru/mongocollection.findandmodify.php
+     * @param array $query The query criteria to search for.
+     * @param array $update The update criteria.
+     * @param array $fields Optionally only return these fields.
+     * @param array $options An array of options to apply, such as remove the match document from the DB and return it.
+     * @return array Returns the original document, or the modified document when new is set.
+     */
+    public function findAndModify (array $query, array $update = NULL, array $fields = NULL, array $options = NULL) {}
+
+    /**
+     * Querys this collection, returning a single element
+     * @link http://www.php.net/manual/en/mongocollection.findone.php
+     * @param array $query The fields for which to search.
+     * @param array $fields Fields of the results to return.
+     * @return array|null
+     */
+    public function findOne(array $query = array(), array $fields = array()) {}
+
+    /**
+     * Creates an index on the given field(s), or does nothing if the index already exists
+     * @link http://www.php.net/manual/en/mongocollection.createindex.php
+     * @param array $keys Field or fields to use as index.
+     * @param array $options [optional] This parameter is an associative array of the form array("optionname" => <boolean>, ...).
+     * @return array Returns the database response.
+     */
+    public function createIndex(array $keys, array $options = array()) {}
+
+    /**
+     * @deprecated Use MongoCollection::createIndex() instead.
+     * Creates an index on the given field(s), or does nothing if the index already exists
+     * @link http://www.php.net/manual/en/mongocollection.ensureindex.php
+     * @param array $keys Field or fields to use as index.
+     * @param array $options [optional] This parameter is an associative array of the form array("optionname" => <boolean>, ...).
+     * @return boolean always true
+     */
+    public function ensureIndex(array $keys, array $options = array()) {}
+
+    /**
+     * Deletes an index from this collection
+     * @link http://www.php.net/manual/en/mongocollection.deleteindex.php
+     * @param string|array $keys Field or fields from which to delete the index.
+     * @return array Returns the database response.
+     */
+    public function deleteIndex($keys) {}
+
+    /**
+     * Delete all indexes for this collection
+     * @link http://www.php.net/manual/en/mongocollection.deleteindexes.php
+     * @return array Returns the database response.
+     */
+    public function deleteIndexes() {}
+
+    /**
+     * Returns an array of index names for this collection
+     * @link http://www.php.net/manual/en/mongocollection.getindexinfo.php
+     * @return array Returns a list of index names.
+     */
+    public function getIndexInfo() {}
+
+    /**
+     * Counts the number of documents in this collection
+     * @link http://www.php.net/manual/en/mongocollection.count.php
+     * @param array|stdClass $query
+     * @return int Returns the number of documents matching the query.
+     */
+    public function count($query = array()) {}
+
+    /**
+     * Saves an object to this collection
+     * @link http://www.php.net/manual/en/mongocollection.save.php
+     * @param array|object $a Array to save. If an object is used, it may not have protected or private properties.
+     * Note: If the parameter does not have an _id key or property, a new MongoId instance will be created and assigned to it.
+     * See MongoCollection::insert() for additional information on this behavior.
+     * @param array $options Options for the save.
+     * <dl>
+     * <dt>"w"
+     * <dd>See WriteConcerns. The default value for MongoClient is 1.
+     * <dt>"fsync"
+     * <dd>Boolean, defaults to FALSE. Forces the insert to be synced to disk before returning success. If TRUE, an acknowledged insert is implied and will override setting w to 0.
+     * <dt>"timeout"
+     * <dd>Integer, defaults to MongoCursor::$timeout. If "safe" is set, this sets how long (in milliseconds) for the client to wait for a database response. If the database does not respond within the timeout period, a MongoCursorTimeoutException will be thrown.
+     * <dt>"safe"
+     * <dd>Deprecated. Please use the WriteConcern w option.
+     * </dl>
+     * @throws MongoException if the inserted document is empty or if it contains zero-length keys. Attempting to insert an object with protected and private properties will cause a zero-length key error.
+     * @throws MongoCursorException if the "w" option is set and the write fails.
+     * @throws MongoCursorTimeoutException if the "w" option is set to a value greater than one and the operation takes longer than MongoCursor::$timeout milliseconds to complete. This does not kill the operation on the server, it is a client-side timeout. The operation in MongoCollection::$wtimeout is milliseconds.
+     * @return array|boolean If w was set, returns an array containing the status of the save.
+     * Otherwise, returns a boolean representing if the array was not empty (an empty array will not be inserted).
+     */
+    public function save($a, array $options = array()) {}
+
+    /**
+     * Creates a database reference
+     * @link http://www.php.net/manual/en/mongocollection.createdbref.php
+     * @param array $a Object to which to create a reference.
+     * @return array Returns a database reference array.
+     */
+    public function createDBRef(array $a) {}
+
+    /**
+     * Fetches the document pointed to by a database reference
+     * @link http://www.php.net/manual/en/mongocollection.getdbref.php
+     * @param array $ref A database reference.
+     * @return array Returns the database document pointed to by the reference.
+     */
+    public function getDBRef(array $ref) {}
+
+    /**
+     * @param  mixed $keys
+     * @static
+     * @return string
+     */
+    protected static function toIndexString($keys) {}
+
+    /**
+     * Performs an operation similar to SQL's GROUP BY command
+     * @link http://www.php.net/manual/en/mongocollection.group.php
+     * @param mixed $keys Fields to group by. If an array or non-code object is passed, it will be the key used to group results.
+     * @param array $initial Initial value of the aggregation counter object.
+     * @param MongoCode $reduce A function that aggregates (reduces) the objects iterated.
+     * @param array $condition An condition that must be true for a row to be considered.
+     * @return array
+     */
+    public function group($keys, array $initial, MongoCode $reduce, array $condition = array()) {}
+
+    protected function notImplemented()
+    {
+        throw new \Exception('Not implemented');
+    }
+}
+

lib/Mongo/MongoCommandCursor.php

@@ -0,0 +1,69 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+class MongoCommandCursor implements MongoCursorInterface, Iterator{
+    /**
+     * Return the current element
+     * @link http://php.net/manual/en/iterator.current.php
+     * @return mixed Can return any type.
+     * @since 5.0.0
+     */
+    public function current(){}
+
+    /**
+     * Move forward to next element
+     * @link http://php.net/manual/en/iterator.next.php
+     * @return void Any returned value is ignored.
+     * @since 5.0.0
+     */
+    public function next(){}
+
+    /**
+     * Return the key of the current element
+     * @link http://php.net/manual/en/iterator.key.php
+     * @return mixed scalar on success, or null on failure.
+     * @since 5.0.0
+     */
+    public function key(){}
+
+    /**
+     * Checks if current position is valid
+     * @link http://php.net/manual/en/iterator.valid.php
+     * @return boolean The return value will be casted to boolean and then evaluated.
+     * Returns true on success or false on failure.
+     * @since 5.0.0
+     */
+    public function valid(){}
+
+    /**
+     * Rewind the Iterator to the first element
+     * @link http://php.net/manual/en/iterator.rewind.php
+     * @return void Any returned value is ignored.
+     * @since 5.0.0
+     */
+    public function rewind(){}
+
+    function batchSize(int $batchSize):MongoCursorInterface{}
+
+    function dead():bool{}
+
+    function info():array{}
+
+    function getReadPreference():array{}
+
+    function setReadPreference(string $read_preference, array $tags = null):MongoCursorInterface{}
+
+    function timeout(int $ms):MongoCursorInterface{}
+}

lib/Mongo/MongoConnectionException.php

@@ -0,0 +1,18 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+class MongoConnectionException extends MongoException {
+
+}

lib/Mongo/MongoCursor.php

@@ -0,0 +1,326 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+/**
+ * Result object for database query.
+ * @link http://www.php.net/manual/en/class.mongocursor.php
+ */
+class MongoCursor implements Iterator, Traversable {
+    /**
+     * @link http://php.net/manual/en/class.mongocursor.php#mongocursor.props.slaveokay
+     * @static
+     * @var bool $slaveOkay
+     */
+    public static $slaveOkay = FALSE;
+
+    /**
+     * @var int <p>
+     * Set timeout in milliseconds for all database responses. Use
+     * <em>-1</em> to wait forever. Can be overridden with
+     * {link http://php.net/manual/en/mongocursor.timeout.php MongoCursor::timeout()}. This does not cause the
+     * MongoDB server to cancel the operation; it only instructs the driver to
+     * stop waiting for a response and throw a
+     * {@link http://php.net/manual/en/class.mongocursortimeoutexception.php MongoCursorTimeoutException} after a set time.
+     * </p>
+     */
+    static $timeout = 30000;
+    /**
+     * Create a new cursor
+     * @link http://www.php.net/manual/en/mongocursor.construct.php
+     * @param MongoClient $connection Database connection.
+     * @param string $ns Full name of database and collection.
+     * @param array $query Database query.
+     * @param array $fields Fields to return.
+     * @return MongoCursor Returns the new cursor
+     */
+    public function __construct($connection, $ns, array $query = array(), array $fields = array()) {}
+
+    /**
+     * (PECL mongo &gt;= 1.2.11)<br/>
+     * Sets whether this cursor will wait for a while for a tailable cursor to return more data
+     * @param bool $wait [optional] <p>If the cursor should wait for more data to become available.</p>
+     * @return MongoCursor Returns this cursor.
+     */
+    public function awaitData ($wait = true) {}
+    /**
+     * Checks if there are any more elements in this cursor
+     * @link http://www.php.net/manual/en/mongocursor.hasnext.php
+     * @throws MongoConnectionException
+     * @throws MongoCursorTimeoutException
+     * @return bool Returns true if there is another element
+     */
+    public function hasNext() {}
+
+    /**
+     * Return the next object to which this cursor points, and advance the cursor
+     * @link http://www.php.net/manual/en/mongocursor.getnext.php
+     * @throws MongoConnectionException
+     * @throws MongoCursorTimeoutException
+     * @return array Returns the next object
+     */
+    public function getNext() {}
+
+    /**
+     * (PECL mongo &gt;= 1.3.3)<br/>
+     * @link http://www.php.net/manual/en/mongocursor.getreadpreference.php
+     * @return array This function returns an array describing the read preference. The array contains the values <em>type</em> for the string
+     * read preference mode (corresponding to the {@link http://www.php.net/manual/en/class.mongoclient.php MongoClient} constants), and <em>tagsets</em> containing a list of all tag set criteria. If no tag sets were specified, <em>tagsets</em> will not be present in the array.
+     */
+    public function getReadPreference () { }
+
+    /**
+     * Limits the number of results returned
+     * @link http://www.php.net/manual/en/mongocursor.limit.php
+     * @param int $num The number of results to return.
+     * @throws MongoCursorException
+     * @return MongoCursor Returns this cursor
+     */
+    public function limit($num) {}
+
+    /**
+     * (PECL mongo &gt;= 1.2.0)<br/>
+     * @link http://www.php.net/manual/en/mongocursor.partial.php
+     * @param bool $okay [optional] <p>If receiving partial results is okay.</p>
+     * @return MongoCursor Returns this cursor.
+     */
+    public function partial ($okay = true) {}
+
+    /**
+     * (PECL mongo &gt;= 1.2.1)<br/>
+     * @link http://www.php.net/manual/en/mongocursor.setflag.php
+     * @param int $flag <p>
+     * Which flag to set. You can not set flag 6 (EXHAUST) as the driver does
+     * not know how to handle them. You will get a warning if you try to use
+     * this flag. For available flags, please refer to the wire protocol
+     * {@link http://www.mongodb.org/display/DOCS/Mongo+Wire+Protocol#MongoWireProtocol-OPQUERY documentation}.
+     * </p>
+     * @param bool $set [optional] <p>Whether the flag should be set (<b>TRUE</b>) or unset (<b>FALSE</b>).</p>
+     * @return MongoCursor
+     */
+    public function setFlag ($flag, $set = true ) {}
+
+    /**
+     * (PECL mongo &gt;= 1.3.3)<br/>
+     * @link http://www.php.net/manual/en/mongocursor.setreadpreference.php
+     * @param string $read_preference <p>The read preference mode: MongoClient::RP_PRIMARY, MongoClient::RP_PRIMARY_PREFERRED, MongoClient::RP_SECONDARY, MongoClient::RP_SECONDARY_PREFERRED, or MongoClient::RP_NEAREST.</p>
+     * @param array $tags [optional] <p>The read preference mode: MongoClient::RP_PRIMARY, MongoClient::RP_PRIMARY_PREFERRED, MongoClient::RP_SECONDARY, MongoClient::RP_SECONDARY_PREFERRED, or MongoClient::RP_NEAREST.</p>
+     * @return MongoCursor Returns this cursor.
+     */
+    public function setReadPreference ($read_preference, array $tags) {}
+
+    /**
+     * Skips a number of results
+     * @link http://www.php.net/manual/en/mongocursor.skip.php
+     * @param int $num The number of results to skip.
+     * @throws MongoCursorException
+     * @return MongoCursor Returns this cursor
+     */
+    public function skip($num) {}
+
+    /**
+     * Sets whether this query can be done on a slave
+     * This method will override the static class variable slaveOkay.
+     * @link http://www.php.net/manual/en/mongocursor.slaveOkay.php
+     * @param boolean $okay If it is okay to query the slave.
+     * @throws MongoCursorException
+     * @return MongoCursor Returns this cursor
+     */
+    public function slaveOkay($okay = true) {}
+
+    /**
+     * Sets whether this cursor will be left open after fetching the last results
+     * @link http://www.php.net/manual/en/mongocursor.tailable.php
+     * @param bool $tail If the cursor should be tailable.
+     * @return MongoCursor Returns this cursor
+     */
+    public function tailable($tail = true) {}
+
+    /**
+     * Sets whether this cursor will timeout
+     * @link http://www.php.net/manual/en/mongocursor.immortal.php
+     * @param bool $liveForever If the cursor should be immortal.
+     * @throws MongoCursorException
+     * @return MongoCursor Returns this cursor
+     */
+    public function immortal($liveForever = true) {}
+
+    /**
+     * Sets a client-side timeout for this query
+     * @link http://www.php.net/manual/en/mongocursor.timeout.php
+     * @param int $ms The number of milliseconds for the cursor to wait for a response. By default, the cursor will wait forever.
+     * @throws MongoCursorTimeoutException
+     * @return MongoCursor Returns this cursor
+     */
+    public function timeout($ms) {}
+
+    /**
+     * Checks if there are documents that have not been sent yet from the database for this cursor
+     * @link http://www.php.net/manual/en/mongocursor.dead.php
+     * @return boolean Returns if there are more results that have not been sent to the client, yet.
+     */
+    public function dead() {}
+
+    /**
+     * Use snapshot mode for the query
+     * @link http://www.php.net/manual/en/mongocursor.snapshot.php
+     * @throws MongoCursorException
+     * @return MongoCursor Returns this cursor
+     */
+    public function snapshot() {}
+
+    /**
+     * Sorts the results by given fields
+     * @link http://www.php.net/manual/en/mongocursor.sort.php
+     * @param array $fields An array of fields by which to sort. Each element in the array has as key the field name, and as value either 1 for ascending sort, or -1 for descending sort
+     * @throws MongoCursorException
+     * @return MongoCursor Returns the same cursor that this method was called on
+     */
+    public function sort(array $fields) {}
+
+    /**
+     * Gives the database a hint about the query
+     * @link http://www.php.net/manual/en/mongocursor.hint.php
+     * @param array $key_pattern Indexes to use for the query.
+     * @throws MongoCursorException
+     * @return MongoCursor Returns this cursor
+     */
+    public function hint(array $key_pattern) {}
+
+
+    /**
+     * Adds a top-level key/value pair to a query
+     * @link http://www.php.net/manual/en/mongocursor.addoption.php
+     * @param string $key Fieldname to add.
+     * @param mixed $value Value to add.
+     * @throws MongoCursorException
+     * @return MongoCursor Returns this cursor
+     */
+    public function addOption($key, $value) {}
+
+    /**
+     * Execute the query
+     * @link http://www.php.net/manual/en/mongocursor.doquery.php
+     * @throws MongoConnectionException if it cannot reach the database.
+     * @return void
+     */
+    protected function doQuery() {}
+
+    /**
+     * Returns the current element
+     * @link http://www.php.net/manual/en/mongocursor.current.php
+     * @return array
+     */
+    public function current() {}
+
+    /**
+     * Returns the current result's _id
+     * @link http://www.php.net/manual/en/mongocursor.key.php
+     * @return string The current result's _id as a string.
+     */
+    public function key() {}
+
+    /**
+     * Advances the cursor to the next result
+     * @link http://www.php.net/manual/en/mongocursor.next.php
+     * @throws MongoConnectionException
+     * @throws MongoCursorTimeoutException
+     * @return void
+     */
+    public function next() {}
+
+    /**
+     * Returns the cursor to the beginning of the result set
+     * @throws MongoConnectionException
+     * @throws MongoCursorTimeoutException
+     * @return void
+     */
+    public function rewind() {}
+
+    /**
+     * Checks if the cursor is reading a valid result.
+     * @link http://www.php.net/manual/en/mongocursor.valid.php
+     * @return boolean If the current result is not null.
+     */
+    public function valid() {}
+
+    /**
+     * Clears the cursor
+     * @link http://www.php.net/manual/en/mongocursor.reset.php
+     * @return void
+     */
+    public function reset() {}
+
+    /**
+     * Return an explanation of the query, often useful for optimization and debugging
+     * @link http://www.php.net/manual/en/mongocursor.explain.php
+     * @return array Returns an explanation of the query.
+     */
+    public function explain() {}
+
+    /**
+     * Counts the number of results for this query
+     * @link http://www.php.net/manual/en/mongocursor.count.php
+     * @param bool $all Send cursor limit and skip information to the count function, if applicable.
+     * @return int The number of documents returned by this cursor's query.
+     */
+    public function count($all = FALSE) {}
+
+    /**
+     * Sets the fields for a query
+     * @link http://www.php.net/manual/en/mongocursor.fields.php
+     * @param array $f Fields to return (or not return).
+     * @throws MongoCursorException
+     * @return MongoCursor
+     */
+    public function fields(array $f){}
+
+    /**
+     * Gets the query, fields, limit, and skip for this cursor
+     * @link http://www.php.net/manual/en/mongocursor.info.php
+     * @return array The query, fields, limit, and skip for this cursor as an associative array.
+     */
+    public function info(){}
+
+    /**
+     * PECL mongo >=1.0.11
+     * Limits the number of elements returned in one batch.
+     * <p>A cursor typically fetches a batch of result objects and store them locally.
+     * This method sets the batchSize value to configure the amount of documents retrieved from the server in one data packet.
+     * However, it will never return more documents than fit in the max batch size limit (usually 4MB).
+     *
+     * @param int $batchSize The number of results to return per batch. Each batch requires a round-trip to the server.
+     * <p>If batchSize is 2 or more, it represents the size of each batch of objects retrieved.
+     * It can be adjusted to optimize performance and limit data transfer.
+     *
+     * <p>If batchSize is 1 or negative, it will limit of number returned documents to the absolute value of batchSize,
+     * and the cursor will be closed. For example if batchSize is -10, then the server will return a maximum of 10
+     * documents and as many as can fit in 4MB, then close the cursor.
+     * <b>Warning</b>
+     * <p>A batchSize of 1 is special, and means the same as -1, i.e. a value of 1 makes the cursor only capable of returning one document.
+     * <p>Note that this feature is different from MongoCursor::limit() in that documents must fit within a maximum size,
+     * and it removes the need to send a request to close the cursor server-side.
+     * The batch size can be changed even after a cursor is iterated, in which case the setting will apply on the next batch retrieval.
+     * <p>This cannot override MongoDB's limit on the amount of data it will return to the client (i.e.,
+     * if you set batch size to 1,000,000,000, MongoDB will still only return 4-16MB of results per batch).
+     * <p>To ensure consistent behavior, the rules of MongoCursor::batchSize() and MongoCursor::limit() behave a little complex
+     * but work "as expected". The rules are: hard limits override soft limits with preference given to MongoCursor::limit() over
+     * MongoCursor::batchSize(). After that, whichever is set and lower than the other will take precedence.
+     * See below. section for some examples.
+     * @return MongoCursor Returns this cursor.
+     * @link http://docs.php.net/manual/en/mongocursor.batchsize.php
+     */
+    public function batchSize($batchSize){}
+}
+

lib/Mongo/MongoCursorException.php

@@ -0,0 +1,18 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+class MongoCursorException extends MongoException {
+
+}

lib/Mongo/MongoCursorInterface.php

@@ -0,0 +1,51 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+interface MongoCursorInterface extends Iterator
+{
+    /**
+     * @param int $batchSize
+     * @return MongoCursorInterface
+     */
+    function batchSize($batchSize);
+
+    /**
+     * @return bool
+     */
+    function dead();
+
+    /**
+     * @return array
+     */
+    function info();
+
+    /**
+     * @return array
+     */
+    function getReadPreference();
+
+    /**
+     * @param string $read_preference
+     * @param array|null $tags
+     * @return MongoCursorInterface
+     */
+    function setReadPreference($read_preference, $tags = null);
+
+    /**
+     * @param int $ms
+     * @return MongoCursorInterface
+     */
+    function timeout($ms);
+}

lib/Mongo/MongoCursorTimeoutException.php

@@ -0,0 +1,18 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+class MongoCursorTimeoutException extends MongoCursorException {
+
+}

lib/Mongo/MongoDB.php

@@ -0,0 +1,487 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+use MongoDB\Model\CollectionInfo;
+
+/**
+ * Instances of this class are used to interact with a database.
+ * @link http://www.php.net/manual/en/class.mongodb.php
+ */
+class MongoDB
+{
+    const PROFILING_OFF = 0;
+    const PROFILING_SLOW = 1;
+    const PROFILING_ON = 2;
+
+    /**
+     * @var int
+     */
+    public $w = 1;
+
+    /**
+     * @var int
+     */
+    public $wtimeout = 10000;
+
+    /**
+     * @var \MongoDB\Database
+     */
+    protected $db;
+
+    /**
+     * Creates a new database
+     *
+     * This method is not meant to be called directly. The preferred way to create an instance of MongoDB is through {@see Mongo::__get()} or {@see Mongo::selectDB()}.
+     * @link http://www.php.net/manual/en/mongodb.construct.php
+     * @param MongoClient $conn Database connection.
+     * @param string $name Database name.
+     * @throws Exception
+     * @return MongoDB Returns the database.
+     */
+    public function __construct($conn, $name)
+    {
+        $this->connection = $conn;
+        $this->name = $name;
+        $this->db = $this->connection->getClient()->selectDatabase($name);
+    }
+
+    /**
+     * @return \MongoDB\Database
+     * @internal
+     */
+    public function getDb()
+    {
+        return $this->db;
+    }
+
+    /**
+     * The name of this database
+     * @link http://www.php.net/manual/en/mongodb.--tostring.php
+     * @return string Returns this database's name.
+     */
+    public function __toString()
+    {
+        return $this->name;
+    }
+
+    /**
+     * (PECL mongo &gt;= 1.0.2)<br/>
+     * Gets a collection
+     * @link http://www.php.net/manual/en/mongodb.get.php
+     * @param string $name The name of the collection.
+     * @return MongoCollection
+     */
+    public function __get($name)
+    {
+        return $this->selectCollection($name);
+    }
+
+    /**
+     * (PECL mongo &gt;= 1.3.0)<br/>
+     * @link http://www.php.net/manual/en/mongodb.getcollectionnames.php
+     * Get all collections from this database
+     * @return array Returns the names of the all the collections in the database as an
+     * {@link http://www.php.net/manual/en/language.types.array.php array}.
+     */
+    public function getCollectionNames(array $options = [])
+    {
+        if (is_bool($options)) {
+            $options = ['includeSystemCollections' => $options];
+        }
+
+        $collections = $this->db->listCollections($options);
+
+        $getCollectionName = function (CollectionInfo $collectionInfo) {
+            return $collectionInfo->getName();
+        };
+
+        return array_map($getCollectionName, (array) $collections);
+    }
+
+    /**
+     * (PECL mongo &gt;= 0.9.0)<br/>
+     * Fetches toolkit for dealing with files stored in this database
+     * @link http://www.php.net/manual/en/mongodb.getgridfs.php
+     * @param string $prefix [optional] The prefix for the files and chunks collections.
+     * @return MongoGridFS Returns a new gridfs object for this database.
+     */
+    public function getGridFS($prefix = "fs")
+    {
+        return new \MongoGridFS($this, $prefix, $prefix);
+    }
+
+    /**
+     * (PECL mongo &gt;= 0.9.0)<br/>
+     * Gets this database's profiling level
+     * @link http://www.php.net/manual/en/mongodb.getprofilinglevel.php
+     * @return int Returns the profiling level.
+     */
+    public function getProfilingLevel()
+    {
+        return static::PROFILING_OFF;
+    }
+
+    /**
+     * (PECL mongo &gt;= 1.1.0)<br/>
+     * Get slaveOkay setting for this database
+     * @link http://www.php.net/manual/en/mongodb.getslaveokay.php
+     * @return bool Returns the value of slaveOkay for this instance.
+     */
+    public function getSlaveOkay()
+    {
+        return false;
+    }
+
+    /**
+     * (PECL mongo &gt;= 0.9.0)<br/>
+     * Sets this database's profiling level
+     * @link http://www.php.net/manual/en/mongodb.setprofilinglevel.php
+     * @param int $level Profiling level.
+     * @return int Returns the previous profiling level.
+     */
+    public function setProfilingLevel($level)
+    {
+        return static::PROFILING_OFF;
+    }
+
+    /**
+     * (PECL mongo &gt;= 0.9.0)<br/>
+     * Drops this database
+     * @link http://www.php.net/manual/en/mongodb.drop.php
+     * @return array Returns the database response.
+     */
+    public function drop()
+    {
+        return $this->db->drop();
+    }
+
+    /**
+     * Repairs and compacts this database
+     * @link http://www.php.net/manual/en/mongodb.repair.php
+     * @param bool $preserve_cloned_files [optional] <p>If cloned files should be kept if the repair fails.</p>
+     * @param bool $backup_original_files [optional] <p>If original files should be backed up.</p>
+     * @return array <p>Returns db response.</p>
+     */
+    public function repair($preserve_cloned_files = FALSE, $backup_original_files = FALSE)
+    {
+        return [];
+    }
+
+    /**
+     * (PECL mongo &gt;= 0.9.0)<br/>
+     * Gets a collection
+     * @link http://www.php.net/manual/en/mongodb.selectcollection.php
+     * @param string $name <b>The collection name.</b>
+     * @throws Exception if the collection name is invalid.
+     * @return MongoCollection <p>
+     * Returns a new collection object.
+     * </p>
+     */
+    public function selectCollection($name)
+    {
+        return new MongoCollection($this, $name);
+    }
+
+    /**
+     * (PECL mongo &gt;= 1.1.0)<br/>
+     * Change slaveOkay setting for this database
+     * @link http://php.net/manual/en/mongodb.setslaveokay.php
+     * @param bool $ok [optional] <p>
+     * If reads should be sent to secondary members of a replica set for all
+     * possible queries using this {@link http://www.php.net/manual/en/class.mongodb.php MongoDB} instance.
+     * </p>
+     * @return bool Returns the former value of slaveOkay for this instance.
+     */
+    public function setSlaveOkay ($ok = true)
+    {
+        return false;
+    }
+
+    /**
+     * Creates a collection
+     * @link http://www.php.net/manual/en/mongodb.createcollection.php
+     * @param string $name The name of the collection.
+     * @param array $options [optional] <p>
+     * <p>
+     * An array containing options for the collections. Each option is its own
+     * element in the options array, with the option name listed below being
+     * the key of the element. The supported options depend on the MongoDB
+     * server version. At the moment, the following options are supported:
+     * </p>
+     * <p>
+     * <b>capped</b>
+     * <p>
+     * If the collection should be a fixed size.
+     * </p>
+     * </p>
+     * <p>
+     * <b>size</b>
+     * <p>
+     * If the collection is fixed size, its size in bytes.</p></p>
+     * <p><b>max</b>
+     * <p>If the collection is fixed size, the maximum number of elements to store in the collection.</p></p>
+     * <i>autoIndexId</i>
+     *
+     * <p>
+     * If capped is <b>TRUE</b> you can specify <b>FALSE</b> to disable the
+     * automatic index created on the <em>_id</em> field.
+     * Before MongoDB 2.2, the default value for
+     * <em>autoIndexId</em> was <b>FALSE</b>.
+     * </p>
+     * </p>
+     * @return MongoCollection <p>Returns a collection object representing the new collection.</p>
+     */
+    public function createCollection($name, $options)
+    {
+        $this->db->createCollection($name, $options);
+        return $this->selectCollection($name);
+    }
+
+    /**
+     * (PECL mongo &gt;= 0.9.0)<br/>
+     * @deprecated Use MongoCollection::drop() instead.
+     * Drops a collection
+     * @link http://www.php.net/manual/en/mongodb.dropcollection.php
+     * @param MongoCollection|string $coll MongoCollection or name of collection to drop.
+     * @return array Returns the database response.
+     */
+    public function dropCollection($coll)
+    {
+        return $this->db->dropCollection((string) $coll);
+    }
+
+    /**
+     * (PECL mongo &gt;= 0.9.0)<br/>
+     * Get a list of collections in this database
+     * @link http://www.php.net/manual/en/mongodb.listcollections.php
+     * @param bool $includeSystemCollections [optional] <p>Include system collections.</p>
+     * @return array Returns a list of MongoCollections.
+     */
+    public function listCollections(array $options = [])
+    {
+        return array_map([$this, 'selectCollection'], $this->getCollectionNames($options));
+    }
+
+    /**
+     * (PECL mongo &gt;= 0.9.0)<br/>
+     * Creates a database reference
+     * @link http://www.php.net/manual/en/mongodb.createdbref.php
+     * @param string $collection The collection to which the database reference will point.
+     * @param mixed $document_or_id <p>
+     * If an array or object is given, its <em>_id</em> field will be
+     * used as the reference ID. If a {@see MongoId} or scalar
+     * is given, it will be used as the reference ID.
+     * </p>
+     * @return array <p>Returns a database reference array.</p>
+     * <p>
+     * If an array without an <em>_id</em> field was provided as the
+     * <em>document_or_id</em> parameter, <b>NULL</b> will be returned.
+     * </p>
+     */
+    public function createDBRef($collection, $document_or_id)
+    {
+        if (is_object($document_or_id)) {
+            $id = isset($document_or_id->_id) ? $document_or_id->_id : null;
+//            $id = $document_or_id->_id ?? null;
+        } elseif (is_array($document_or_id)) {
+            if (! isset($document_or_id['_id'])) {
+                return null;
+            }
+
+            $id = $document_or_id['_id'];
+        } else {
+            $id = $document_or_id;
+        }
+
+        return [
+            '$ref' => $collection,
+            '$id' => $id,
+            '$db' => $this->name,
+        ];
+    }
+
+
+    /**
+     * (PECL mongo &gt;= 0.9.0)<br/>
+     * Fetches the document pointed to by a database reference
+     * @link http://www.php.net/manual/en/mongodb.getdbref.php
+     * @param array $ref A database reference.
+     * @return array Returns the document pointed to by the reference.
+     */
+    public function getDBRef(array $ref)
+    {
+        $this->notImplemented();
+    }
+
+    /**
+     * (PECL mongo &gt;= 1.5.0)<br/>
+     * Get the write concern for this database
+     * @link http://php.net/manual/en/mongodb.getwriteconcern.php
+     * @return array <p>This function returns an array describing the write concern.
+     * The array contains the values w for an integer acknowledgement level or string mode,
+     * and wtimeout denoting the maximum number of milliseconds to wait for the server to satisfy the write concern.</p>
+     */
+    public function getWriteConcern()
+    {
+        $this->notImplemented();
+    }
+
+    /**
+     * (PECL mongo &gt;= 0.9.3)<br/>
+     * Runs JavaScript code on the database server.
+     * @link http://www.php.net/manual/en/mongodb.execute.php
+     * @param MongoCode|string $code Code to execute.
+     * @param array $args [optional] Arguments to be passed to code.
+     * @return array Returns the result of the evaluation.
+     */
+    public function execute($code, array $args = array())
+    {
+        $this->notImplemented();
+    }
+
+    /**
+     * Execute a database command
+     * @link http://www.php.net/manual/en/mongodb.command.php
+     * @param array $data The query to send.
+     * @param array() $options [optional] <p>
+     * This parameter is an associative array of the form
+     * <em>array("optionname" =&gt; &lt;boolean&gt;, ...)</em>. Currently
+     * supported options are:
+     * </p><ul>
+     * <li><p><em>"timeout"</em></p><p>Deprecated alias for <em>"socketTimeoutMS"</em>.</p></li>
+     * </ul>
+     * @return array Returns database response.
+     * Every database response is always maximum one document,
+     * which means that the result of a database command can never exceed 16MB.
+     * The resulting document's structure depends on the command,
+     * but most results will have the ok field to indicate success or failure and results containing an array of each of the resulting documents.
+     */
+    public function command(array $data, $options)
+    {
+        $this->notImplemented();
+    }
+
+    /**
+     * (PECL mongo &gt;= 0.9.5)<br/>
+     * Check if there was an error on the most recent db operation performed
+     * @link http://www.php.net/manual/en/mongodb.lasterror.php
+     * @return array Returns the error, if there was one.
+     */
+    public function lastError()
+    {
+        $this->notImplemented();
+    }
+
+    /**
+     * (PECL mongo &gt;= 0.9.5)<br/>
+     * Checks for the last error thrown during a database operation
+     * @link http://www.php.net/manual/en/mongodb.preverror.php
+     * @return array Returns the error and the number of operations ago it occurred.
+     */
+    public function prevError()
+    {
+        $this->notImplemented();
+    }
+
+    /**
+     * (PECL mongo &gt;= 0.9.5)<br/>
+     * Clears any flagged errors on the database
+     * @link http://www.php.net/manual/en/mongodb.reseterror.php
+     * @return array Returns the database response.
+     */
+    public function resetError()
+    {
+        $this->notImplemented();
+    }
+
+    /**
+     * (PECL mongo &gt;= 0.9.5)<br/>
+     * Creates a database error
+     * @link http://www.php.net/manual/en/mongodb.forceerror.php
+     * @return boolean Returns the database response.
+     */
+    public function forceError()
+    {
+        $this->notImplemented();
+    }
+
+    /**
+     * (PECL mongo &gt;= 1.0.1)<br/>
+     * Log in to this database
+     * @link http://www.php.net/manual/en/mongodb.authenticate.php
+     * @param string $username The username.
+     * @param string $password The password (in plaintext).
+     * @return array <p>Returns database response. If the login was successful, it will return 1.</p>
+     * <p>
+     * <span style="color: #0000BB">&lt;?php<br></span><span style="color: #007700">array(</span><span style="color: #DD0000">"ok"&nbsp;</span><span style="color: #007700">=&gt;&nbsp;</span><span style="color: #0000BB">1</span><span style="color: #007700">);<br></span><span style="color: #0000BB">?&gt;</span>
+     * </span>
+     * </code></div>
+     * </div>
+     * </p>
+     * <p> If something went wrong, it will return </p>
+     * <p>
+     * <div class="example-contents">
+     * <div class="phpcode"><code><span style="color: #000000">
+     * <span style="color: #0000BB">&lt;?php<br></span><span style="color: #007700">array(</span><span style="color: #DD0000">"ok"&nbsp;</span><span style="color: #007700">=&gt;&nbsp;</span><span style="color: #0000BB">0</span><span style="color: #007700">,&nbsp;</span><span style="color: #DD0000">"errmsg"&nbsp;</span><span style="color: #007700">=&gt;&nbsp;</span><span style="color: #DD0000">"auth&nbsp;fails"</span><span style="color: #007700">);<br></span><span style="color: #0000BB">?&gt;</span></p>
+     *         <p>("auth fails" could be another message, depending on database version and
+     *         what went wrong)</p>
+     */
+    public function authenticate($username, $password)
+    {
+        $this->notImplemented();
+    }
+
+    /**
+     * (PECL mongo &gt;= 1.3.0)<br/>
+     * Get the read preference for this database
+     * @link http://www.php.net/manual/en/mongodb.getreadpreference.php
+     * @return array This function returns an array describing the read preference. The array contains the values type for the string read preference mode (corresponding to the MongoClient constants), and tagsets containing a list of all tag set criteria. If no tag sets were specified, tagsets will not be present in the array.
+     */
+    public function getReadPreference()
+    {
+        $this->notImplemented();
+    }
+
+    /**
+     * (PECL mongo &gt;= 1.3.0)<br/>
+     * Set the read preference for this database
+     * @link http://www.php.net/manual/en/mongodb.setreadpreference.php
+     * @param string $read_preference <p>The read preference mode: <b>MongoClient::RP_PRIMARY</b>, <b>MongoClient::RP_PRIMARY_PREFERRED</b>, <b>MongoClient::RP_SECONDARY</b>, <b>MongoClient::RP_SECONDARY_PREFERRED</b>, or <b>MongoClient::RP_NEAREST</b>.</p>
+     * @param array $tags [optional] <p>An array of zero or more tag sets, where each tag set is itself an array of criteria used to match tags on replica set members.</p>
+     * @return boolean Returns <b>TRUE</b> on success, or <b>FALSE</b> otherwise.
+     */
+    public function setReadPreference($read_preference, array $tags)
+    {
+        $this->notImplemented();
+    }
+
+    /**
+     * (PECL mongo &gt;= 1.5.0)<br/>
+     * @link http://php.net/manual/en/mongodb.setwriteconcern.php
+     * Set the write concern for this database
+     * @param mixed $w <p>The write concern. This may be an integer denoting the number of servers required to acknowledge the write, or a string mode (e.g. "majority").</p>
+     * @param int $wtimeout[optional] <p>The maximum number of milliseconds to wait for the server to satisfy the write concern.</p>
+     * @return boolean Returns <b>TRUE</b> on success, or <b>FALSE</b> otherwise.
+     */
+    public function setWriteConcern($w, $wtimeout)
+    {
+        $this->notImplemented();
+    }
+
+    protected function notImplemented()
+    {
+        throw new \Exception('Not implemented');
+    }
+}

lib/Mongo/MongoDBRef.php

@@ -0,0 +1,61 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+class MongoDBRef {
+    /**
+     * @static
+     * @var $refKey
+     */
+    protected static $refKey = '$ref';
+
+    /**
+     * @static
+     * @var $idKey
+     */
+    protected static $idKey = '$id';
+
+    /**
+     * If no database is given, the current database is used.
+     *
+     * @link http://php.net/manual/en/mongodbref.create.php
+     * @static
+     * @param string $collection Collection name (without the database name)
+     * @param mixed $id The _id field of the object to which to link
+     * @param string $database Database name
+     * @return array Returns the reference
+     */
+    public static function create($collection, $id, $database = null) {}
+
+    /**
+     * This not actually follow the reference, so it does not determine if it is broken or not.
+     * It merely checks that $ref is in valid database reference format (in that it is an object or array with $ref and $id fields).
+     *
+     * @link http://php.net/manual/en/mongodbref.isref.php
+     * @static
+     * @param mixed $ref Array or object to check
+     * @return boolean Returns true if $ref is a reference
+     */
+    public static function isRef($ref) {}
+
+    /**
+     * Fetches the object pointed to by a reference
+     * @link http://php.net/manual/en/mongodbref.get.php
+     * @static
+     * @param MongoDB $db Database to use
+     * @param array $ref Reference to fetch
+     * @return array|null Returns the document to which the reference refers or null if the document does not exist (the reference is broken)
+     */
+    public static function get($db, $ref) {}
+}

lib/Mongo/MongoDate.php

@@ -0,0 +1,51 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+class MongoDate {
+    /**
+     * @link http://php.net/manual/en/class.mongodate.php#mongodate.props.sec
+     * @var int $sec
+     */
+    public $sec;
+
+    /**
+     * @link http://php.net/manual/en/class.mongodate.php#mongodate.props.usec
+     * @var int $usec
+     */
+    public $usec;
+
+    /**
+     * Creates a new date. If no parameters are given, the current time is used.
+     *
+     * @link http://php.net/manual/en/mongodate.construct.php
+     * @param int $sec Number of seconds since January 1st, 1970
+     * @param int $usec Microseconds
+     * @return MongoDate Returns this new date
+     */
+    public function __construct($sec = 0, $usec = 0) {}
+
+    /**
+     * Returns a DateTime object representing this date
+     * @link http://php.net/manual/en/mongodate.todatetime.php
+     * @return DateTime
+     */
+    public function toDateTime() {}
+
+    /**
+     * Returns a string representation of this date
+     * @return string
+     */
+    public function __toString() {}
+}

lib/Mongo/MongoDuplicateKeyException.php

@@ -0,0 +1,22 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+/**
+ * <p>(PECL mongo &gt;= 1.5.0)</p>
+ * @link http://php.net/manual/en/class.mongoduplicatekeyexception.php
+ */
+class MongoDuplicateKeyException extends MongoWriteConcernException {
+
+}

lib/Mongo/MongoException.php

@@ -0,0 +1,17 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+class MongoException extends Exception {
+}

lib/Mongo/MongoExecutionTimeoutException.php

@@ -0,0 +1,20 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+/**
+ * <p>(PECL mongo &gt;= 1.5.0)</p>
+ * @link http://php.net/manual/en/class.mongoexecutiontimeoutexception.php
+ */
+class MongoExecutionTimeoutException extends MongoException {}

lib/Mongo/MongoGridFS.php

@@ -0,0 +1,142 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+class MongoGridFS extends MongoCollection {
+    const ASCENDING = 1;
+    const DESCENDING = -1;
+
+    /**
+     * @link http://php.net/manual/en/class.mongogridfs.php#mongogridfs.props.chunks
+     * @var $chunks MongoCollection
+     */
+    public $chunks;
+
+    /**
+     * @link http://php.net/manual/en/class.mongogridfs.php#mongogridfs.props.filesname
+     * @var $filesName string
+     */
+    protected $filesName;
+
+    /**
+     * @link http://php.net/manual/en/class.mongogridfs.php#mongogridfs.props.chunksname
+     * @var $chunksName string
+     */
+    protected $chunksName;
+
+
+
+    /**
+     * Files as stored across two collections, the first containing file meta
+     * information, the second containing chunks of the actual file. By default,
+     * fs.files and fs.chunks are the collection names used.
+     *
+     * @link http://php.net/manual/en/mongogridfs.construct.php
+     * @param MongoDB $db Database
+     * @param string $prefix [optional] <p>Optional collection name prefix.</p>
+     * @param mixed $chunks  [optional]
+     * @return MongoGridFS
+     */
+    public function __construct($db, $prefix = "fs", $chunks = "fs") {}
+
+    /**
+     * Drops the files and chunks collections
+     * @link http://php.net/manual/en/mongogridfs.drop.php
+     * @return array The database response
+     */
+    public function drop() {}
+
+    /**
+     * @link http://php.net/manual/en/mongogridfs.find.php
+     * @param array $query The query
+     * @param array $fields Fields to return
+     * @return MongoGridFSCursor A MongoGridFSCursor
+     */
+    public function find(array $query = array(), array $fields = array()) {}
+
+    /**
+     * Stores a file in the database
+     * @link http://php.net/manual/en/mongogridfs.storefile.php
+     * @param string $filename The name of the file
+     * @param array $extra Other metadata to add to the file saved
+     * @param array $options Options for the store. "safe": Check that this store succeeded
+     * @return mixed Returns the _id of the saved object
+     */
+    public function storeFile($filename, $extra = array(), $options = array()) {}
+
+    /**
+     * Chunkifies and stores bytes in the database
+     * @link http://php.net/manual/en/mongogridfs.storebytes.php
+     * @param string $bytes A string of bytes to store
+     * @param array $extra Other metadata to add to the file saved
+     * @param array $options Options for the store. "safe": Check that this store succeeded
+     * @return mixed The _id of the object saved
+     */
+    public function storeBytes($bytes, $extra = array(), $options = array()) {}
+
+    /**
+     * Returns a single file matching the criteria
+     * @link http://www.php.net/manual/en/mongogridfs.findone.php
+     * @param array $query The fields for which to search.
+     * @param array $fields Fields of the results to return.
+     * @return MongoGridFSFile|null
+     */
+    public function findOne(array $query = array(), array $fields = array()) {}
+
+    /**
+     * Removes files from the collections
+     * @link http://www.php.net/manual/en/mongogridfs.remove.php
+     * @param array $criteria Description of records to remove.
+     * @param array $options Options for remove. Valid options are: "safe"- Check that the remove succeeded.
+     * @throws MongoCursorException
+     * @return boolean
+     */
+    public function remove(array $criteria = array(), array $options = array()) {}
+
+    /**
+     * Delete a file from the database
+     * @link http://php.net/manual/en/mongogridfs.delete.php
+     * @param mixed $id _id of the file to remove
+     * @return boolean Returns true if the remove was successfully sent to the database.
+     */
+    public function delete($id) {}
+
+    /**
+     * Saves an uploaded file directly from a POST to the database
+     * @link http://www.php.net/manual/en/mongogridfs.storeupload.php
+     * @param string $name The name attribute of the uploaded file, from <input type="file" name="something"/>.
+     * @param array $metadata An array of extra fields for the uploaded file.
+     * @return mixed Returns the _id of the uploaded file.
+     */
+    public function storeUpload($name, array $metadata = array()) {}
+
+
+    /**
+     * Retrieve a file from the database
+     * @link http://www.php.net/manual/en/mongogridfs.get.php
+     * @param mixed $id _id of the file to find.
+     * @return MongoGridFSFile|null Returns the file, if found, or NULL.
+     */
+    public function __get($id) {}
+
+    /**
+     * Stores a file in the database
+     * @link http://php.net/manual/en/mongogridfs.put.php
+     * @param string $filename The name of the file
+     * @param array $extra Other metadata to add to the file saved
+     * @return mixed Returns the _id of the saved object
+     */
+    public function put($filename, array $extra = array()) {}
+
+}

lib/Mongo/MongoGridFSCursor.php

@@ -0,0 +1,62 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+class MongoGridFSCursor extends MongoCursor implements Traversable, Iterator {
+    /**
+     * @static
+     * @var $slaveOkay
+     */
+    public static $slaveOkay;
+
+    /**
+     * @link http://php.net/manual/en/class.mongogridfscursor.php#mongogridfscursor.props.gridfs
+     * @var $gridfs
+     */
+    protected $gridfs;
+
+    /**
+     * Create a new cursor
+     * @link http://php.net/manual/en/mongogridfscursor.construct.php
+     * @param MongoGridFS $gridfs Related GridFS collection
+     * @param resource $connection Database connection
+     * @param string $ns Full name of database and collection
+     * @param array $query Database query
+     * @param array $fields Fields to return
+     * @return MongoGridFSCursor Returns the new cursor
+     */
+    public function __construct($gridfs, $connection, $ns, $query, $fields) {}
+
+    /**
+     * Return the next file to which this cursor points, and advance the cursor
+     * @link http://php.net/manual/en/mongogridfscursor.getnext.php
+     * @return MongoGridFSFile Returns the next file
+     */
+    public function getNext() {}
+
+    /**
+     * Returns the current file
+     * @link http://php.net/manual/en/mongogridfscursor.current.php
+     * @return MongoGridFSFile The current file
+     */
+    public function current() {}
+
+    /**
+     * Returns the current result's filename
+     * @link http://php.net/manual/en/mongogridfscursor.key.php
+     * @return string The current results filename
+     */
+    public function key() {}
+
+}

lib/Mongo/MongoGridFSException.php

@@ -0,0 +1,18 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+class MongoGridFSException extends MongoException {
+
+}

lib/Mongo/MongoGridFSFile.php

@@ -0,0 +1,75 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+class MongoGridFSFile {
+    /**
+     * @link http://php.net/manual/en/class.mongogridfsfile.php#mongogridfsfile.props.file
+     * @var $file
+     */
+    public $file;
+
+    /**
+     * @link http://php.net/manual/en/class.mongogridfsfile.php#mongogridfsfile.props.gridfs
+     * @var $gridfs
+     */
+    protected $gridfs;
+
+    /**
+     * @link http://php.net/manual/en/mongogridfsfile.construct.php
+     * @param MongoGridFS $gridfs The parent MongoGridFS instance
+     * @param array $file A file from the database
+     * @return MongoGridFSFile Returns a new MongoGridFSFile
+     */
+    public function __construct($gridfs, array $file) {}
+
+    /**
+     * Returns this file's filename
+     * @link http://php.net/manual/en/mongogridfsfile.getfilename.php
+     * @return string Returns the filename
+     */
+    public function getFilename() {}
+
+    /**
+     * Returns this file's size
+     * @link http://php.net/manual/en/mongogridfsfile.getsize.php
+     * @return int Returns this file's size
+     */
+    public function getSize() {}
+
+    /**
+     * Writes this file to the filesystem
+     * @link http://php.net/manual/en/mongogridfsfile.write.php
+     * @param string $filename The location to which to write the file (path+filename+extension). If none is given, the stored filename will be used.
+     * @return int Returns the number of bytes written
+     */
+    public function write($filename = null) {}
+
+    /**
+     * This will load the file into memory. If the file is bigger than your memory, this will cause problems!
+     * @link http://php.net/manual/en/mongogridfsfile.getbytes.php
+     * @return string Returns a string of the bytes in the file
+     */
+    public function getBytes() {}
+
+    /**
+     * This method returns a stream resource that can be used to read the stored file with all file functions in PHP.
+     * The contents of the file are pulled out of MongoDB on the fly, so that the whole file does not have to be loaded into memory first.
+     * At most two GridFSFile chunks will be loaded in memory.
+     *
+     * @link http://php.net/manual/en/mongogridfsfile.getresource.php
+     * @return resource Returns a resource that can be used to read the file with
+     */
+    public function getResource() {}
+}

lib/Mongo/MongoId.php

@@ -0,0 +1,220 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+use MongoDB\BSON\ObjectID;
+
+class MongoId implements Serializable
+{
+    /*
+     * @var ObjectID
+     */
+    private $objectID;
+
+    private $attributes = [];
+
+    /**
+     * Creates a new id
+     *
+     *
+     * @link http://www.php.net/manual/en/mongoid.construct.php
+     * @param string $id [optional] A string to use as the id. Must be 24 hexidecimal characters. If an invalid string is passed to this constructor, the constructor will ignore it and create a new id value.
+     * @return MongoId
+     *
+     * @throws MongoException
+     */
+    public function __construct($id = null)
+    {
+        $this->createObjectID($id);
+    }
+
+    /**
+     * Check if a value is a valid ObjectId
+     *
+     * @link http://php.net/manual/en/mongoid.isvalid.php
+     * @param mixed $value The value to check for validity.
+     * @return bool
+     */
+    public static function isValid($value)
+    {
+        if ($value instanceof ObjectID || $value instanceof MongoId) {
+            return true;
+        }
+
+        return (bool) preg_match('#^[a-f0-9]{24}$#i', $value);
+    }
+
+    /**
+     * Returns a hexidecimal representation of this id
+     * @link http://www.php.net/manual/en/mongoid.tostring.php
+     * @return string
+     */
+    public function __toString()
+    {
+        return (string) $this->objectID;
+    }
+
+    /**
+     * Returns the ObjectID used internally
+     * @return ObjectID
+     * @internal This method is not part of the ext-mongo API. Do not use this!
+     */
+    public function getObjectID()
+    {
+        return $this->objectID;
+    }
+
+    /**
+     * @param string $name
+     *
+     * @return null|string
+     */
+    public function __get($name)
+    {
+        if ($name === '$id') {
+            return (string) $this->objectID;
+        }
+
+        return $this->attributes[$name];
+    }
+
+    /**
+     * @param string $name
+     * @param mixed $value
+     */
+    public function __set($name, $value)
+    {
+        if ($name === 'id') {
+            trigger_error("The '\$id' property is read-only", E_DEPRECATED);
+            return;
+        }
+
+        $this->attributes[$name] = $value;
+    }
+
+    /**
+     * @param string $name
+     * @return bool
+     */
+    public function __isset($name)
+    {
+        return $name === 'id' || array_key_exists($name, $this->attributes);
+    }
+
+    /**
+     * @param string $name
+     */
+    public function __unset($name)
+    {
+        if ($name === 'id') {
+            trigger_error("The '\$id' property is read-only", E_DEPRECATED);
+            return;
+        }
+
+        unset($this->attributes[$name]);
+    }
+
+    /**
+     * @return string
+     */
+    public function serialize()
+    {
+        return (string) $this->objectID;
+    }
+
+    /**
+     * @param string $serialized
+     */
+    public function unserialize($serialized)
+    {
+        $this->createObjectID($serialized);
+    }
+
+    /**
+     * Gets the incremented value to create this id
+     * @link http://php.net/manual/en/mongoid.getinc.php
+     * @return int Returns the incremented value used to create this MongoId.
+     */
+    public function getInc()
+    {
+        return hexdec(substr((string) $this->objectID, -6));
+    }
+
+    /**
+     * (PECL mongo &gt;= 1.0.11)
+     * Gets the process ID
+     * @link http://php.net/manual/en/mongoid.getpid.php
+     * @return int Returns the PID of the MongoId.
+     */
+    public function getPID()
+    {
+        $id = (string) $this->objectID;
+
+        // PID is stored as little-endian, flip it around
+        $pid = substr($id, 16, 2) . substr($id, 14, 2);
+        return hexdec($pid);
+    }
+
+    /**
+     * (PECL mongo &gt;= 1.0.1)
+     * Gets the number of seconds since the epoch that this id was created
+     * @link http://www.php.net/manual/en/mongoid.gettimestamp.php
+     * @return int
+     */
+    public function getTimestamp()
+    {
+        return hexdec(substr((string) $this->objectID, 0, 8));
+    }
+
+    /**
+     * Gets the hostname being used for this machine's ids
+     * @link http://www.php.net/manual/en/mongoid.gethostname.php
+     * @return string
+     */
+    public static function getHostname()
+    {
+        return gethostname();
+    }
+
+    /**
+     * (PECL mongo &gt;= 1.0.8)
+     * Create a dummy MongoId
+     * @link http://php.net/manual/en/mongoid.set-state.php
+     * @param array $props <p>Theoretically, an array of properties used to create the new id. However, as MongoId instances have no properties, this is not used.</p>
+     * @return MongoId A new id with the value "000000000000000000000000".
+     */
+    public static function __set_state(array $props)
+    {
+
+    }
+
+    /**
+     * @param $id
+     * @throws MongoException
+     */
+    private function createObjectID($id)
+    {
+        try {
+            if (is_string($id)) {
+                $this->objectID = new ObjectID($id);
+            } elseif ($id instanceof self || $id instanceof ObjectID) {
+                $this->objectID = new ObjectID((string) $id);
+            } else {
+                $this->objectID = new ObjectId();
+            }
+        } catch (\Exception $e) {
+            throw new MongoException('Invalid object ID', 19);
+        }
+    }
+}

lib/Mongo/MongoInt32.php

@@ -0,0 +1,36 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+class MongoInt32 {
+    /**
+     * @link http://php.net/manual/en/class.mongoint32.php#mongoint32.props.value
+     * @var $value
+     */
+    public $value;
+
+
+    /**
+     * Creates a new 32-bit number with the given value.
+     *
+     * @link http://php.net/manual/en/mongoint32.construct.php
+     * @param string $value A number
+     */
+    public function __construct($value) {}
+
+    /**
+     * @return string
+     */
+    public function __toString() {}
+}

lib/Mongo/MongoInt64.php

@@ -0,0 +1,36 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+class MongoInt64 {
+    /**
+     * @link http://php.net/manual/en/class.mongoint64.php#mongoint64.props.value
+     * @var $value
+     */
+    public $value;
+
+
+    /**
+     * Creates a new 64-bit number with the given value.
+     *
+     * @link http://php.net/manual/en/mongoint64.construct.php
+     * @param string $value A number
+     */
+    public function __construct($value) {}
+
+    /**
+     * @return string
+     */
+    public function __toString() {}
+}

lib/Mongo/MongoLog.php

@@ -0,0 +1,148 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+class MongoLog {
+    /**
+     * @link http://php.net/manual/en/class.mongolog.php#mongolog.constants.none
+     */
+    const NONE = 0;
+
+    /**
+     * @link http://php.net/manual/en/class.mongolog.php#mongolog.constants.all
+     */
+    const ALL = 0;
+
+    /**
+     * @link http://php.net/manual/en/class.mongolog.php#mongolog.constants.warning
+     */
+    const WARNING = 0;
+
+    /**
+     * @link http://php.net/manual/en/class.mongolog.php#mongolog.constants.info
+     */
+    const INFO = 0;
+
+    /**
+     * @link http://php.net/manual/en/class.mongolog.php#mongolog.constants.fine
+     */
+    const FINE = 0;
+
+    /**
+     * @link http://php.net/manual/en/class.mongolog.php#mongolog.constants.rs
+     */
+    const RS = 0;
+
+    /**
+     * @link http://php.net/manual/en/class.mongolog.php#mongolog.constants.pool
+     */
+    const POOL = 0;
+
+    /**
+     * @link http://php.net/manual/en/class.mongolog.php#mongolog.constants.io
+     */
+    const IO = 0;
+
+    /**
+     * @link http://php.net/manual/en/class.mongolog.php#mongolog.constants.server
+     */
+    const SERVER = 0;
+
+    /**
+     * @link http://php.net/manual/en/class.mongolog.php#mongolog.constants.parse
+     */
+    const PARSE = 0;
+
+    const CON = 2;
+
+    /**
+     * (PECL mongo &gt;= 1.3.0)<br/>
+     * <p>
+     * This function will set a callback function to be called for {@link http://www.php.net/manual/en/class.mongolog.php MongoLog} events
+     * instead of triggering warnings.
+     * </p>
+     * @link http://www.php.net/manual/en/mongolog.setcallback.php
+     * @param callable $log_function   <p>
+     * The function to be called on events.
+     * </p>
+     * <p>
+     * The function should have the following prototype
+     * </p>
+     *
+     * <em>log_function</em> ( <em>int</em> <em>$module</em> , <em>int</em> <em>$level</em>, <em>string</em> <em>$message</em>)
+     * <ul>
+     * <li>
+     * <b><i>module</i></b>
+     *
+     * <p>One of the {@link http://www.php.net/manual/en/class.mongolog.php#mongolog.constants.module MongoLog module constants}.</p>
+     * </li>
+     * <li>
+     * <b><i>level</i></b>
+     *
+     * <p>One of the {@link http://www.php.net/manual/en/class.mongolog.php#mongolog.constants.level MongoLog level constants}.</p>
+     * </li
+     * <li>
+     * <b><i>message</i></b>
+     *
+     * <p>The log message itself.</p></li>
+     * <ul>
+     * @return boolean Returns <b>TRUE</b> on success or <b>FALSE</b> on failure.
+     */
+    public static function setCallback ( callable $log_function ) {}
+
+    /**
+     * This function can be used to set how verbose logging should be and the types of
+     * activities that should be logged. Use the constants described in the MongoLog
+     * section with bitwise operators to specify levels.
+     *
+     * @link http://php.net/manual/en/mongolog.setlevel.php
+     * @static
+     * @param int $level The levels you would like to log
+     * @return void
+     */
+    public static function setLevel($level) {}
+
+    /**
+     * This can be used to see the log level. Use the constants described in the
+     * MongoLog section with bitwise operators to check the level.
+     *
+     * @link http://php.net/manual/en/mongolog.getlevel.php
+     * @static
+     * @return int Returns the current level
+     */
+    public static function getLevel() {}
+
+    /**
+     * This function can be used to set which parts of the driver's functionality
+     * should be logged. Use the constants described in the MongoLog section with
+     * bitwise operators to specify modules.
+     *
+     * @link http://php.net/manual/en/mongolog.setmodule.php
+     * @static
+     * @param int $module The module(s) you would like to log
+     * @return void
+     */
+    public static function setModule($module) {}
+
+    /**
+     * This function can be used to see which parts of the driver's functionality are
+     * being logged. Use the constants described in the MongoLog section with bitwise
+     * operators to check if specific modules are being logged.
+     *
+     * @link http://php.net/manual/en/mongolog.getmodule.php
+     * @static
+     * @return int Returns the modules currently being logged
+     */
+    public static function getModule() {}
+}

lib/Mongo/MongoMaxKey.php

@@ -0,0 +1,17 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+class MongoMaxKey {
+}

lib/Mongo/MongoMinKey.php

@@ -0,0 +1,17 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+class MongoMinKey {
+}

lib/Mongo/MongoPool.php

@@ -0,0 +1,65 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+class MongoPool {
+    /**
+     * Returns an array of information about all connection pools.
+     *
+     * @link http://php.net/manual/en/mongopool.info.php
+     * @static
+     * @return array Each connection pool has an identifier, which starts with the host. For
+     *         each pool, this function shows the following fields: $in use The number of
+     *         connections currently being used by Mongo instances. $in pool The number of
+     *         connections currently in the pool (not being used). $remaining The number of
+     *         connections that could be created by this pool. For example, suppose a pool had
+     *         5 connections remaining and 3 connections in the pool. We could create 8 new
+     *         instances of Mongo before we exhausted this pool (assuming no instances of Mongo
+     *         went out of scope, returning their connections to the pool). A negative number
+     *         means that this pool will spawn unlimited connections. Before a pool is created,
+     *         you can change the max number of connections by calling Mongo::setPoolSize. Once
+     *         a pool is showing up in the output of this function, its size cannot be changed.
+     *         $total The total number of connections allowed for this pool. This should be
+     *         greater than or equal to "in use" + "in pool" (or -1). $timeout The socket
+     *         timeout for connections in this pool. This is how long connections in this pool
+     *         will attempt to connect to a server before giving up. $waiting If you have
+     *         capped the pool size, workers requesting connections from the pool may block
+     *         until other workers return their connections. This field shows how many
+     *         milliseconds workers have blocked for connections to be released. If this number
+     *         keeps increasing, you may want to use MongoPool::setSize to add more connections
+     *         to your pool
+     */
+    public static function info() {}
+
+    /**
+     * Sets the max number of connections new pools will be able to create.
+     *
+     * @link http://php.net/manual/en/mongopool.setsize.php
+     * @static
+     * @param int $size The max number of connections future pools will be able to
+     *        create. Negative numbers mean that the pool will spawn an infinite number of
+     *        connections
+     * @return boolean Returns the former value of pool size
+     */
+    public static function setSize($size) {}
+
+    /**
+     * .
+     *
+     * @link http://php.net/manual/en/mongopool.getsize.php
+     * @static
+     * @return int Returns the current pool size
+     */
+    public static function getSize() {}
+}

lib/Mongo/MongoProtocolException.php

@@ -0,0 +1,19 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+/**
+ * <p>(PECL mongo &gt;= 1.5.0)</p>
+ */
+class MongoProtocolException extends MongoException {}

lib/Mongo/MongoRegex.php

@@ -0,0 +1,43 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+class MongoRegex {
+    /**
+     * @link http://php.net/manual/en/class.mongoregex.php#mongoregex.props.regex
+     * @var $regex
+     */
+    public $regex;
+
+    /**
+     * @link http://php.net/manual/en/class.mongoregex.php#mongoregex.props.flags
+     * @var $flags
+     */
+    public $flags;
+
+    /**
+     * Creates a new regular expression.
+     *
+     * @link http://php.net/manual/en/mongoregex.construct.php
+     * @param string $regex Regular expression string of the form /expr/flags
+     * @return MongoRegex Returns a new regular expression
+     */
+    public function __construct($regex) {}
+
+    /**
+     * Returns a string representation of this regular expression.
+     * @return string This regular expression in the form "/expr/flags".
+     */
+    public function __toString() {}
+}

lib/Mongo/MongoResultException.php

@@ -0,0 +1,33 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+/**
+ * <p>(PECL mongo &gt;= 1.3.0)</p>
+ * @link http://php.net/manual/en/class.mongoresultexception.php#mongoresultexception.props.document
+ *
+ */
+class MongoResultException extends MongoException {
+    /**
+     * <p>(PECL mongo &gt;= 1.3.0)</p>
+     * Retrieve the full result document
+     * http://php.net/manual/en/mongoresultexception.getdocument.php
+     * @return array <p>The full result document as an array, including partial data if available and additional keys.</p>
+     */
+    public function getDocument () {}
+
+    public $document;
+
+
+}

lib/Mongo/MongoTimestamp.php

@@ -0,0 +1,45 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+class MongoTimestamp {
+    /**
+     * @link http://php.net/manual/en/class.mongotimestamp.php#mongotimestamp.props.sec
+     * @var $sec
+     */
+    public $sec;
+
+    /**
+     * @link http://php.net/manual/en/class.mongotimestamp.php#mongotimestamp.props.inc
+     * @var $inc
+     */
+    public $inc;
+
+    /**
+     * Creates a new timestamp. If no parameters are given, the current time is used
+     * and the increment is automatically provided. The increment is set to 0 when the
+     * module is loaded and is incremented every time this constructor is called
+     * (without the $inc parameter passed in).
+     *
+     * @link http://php.net/manual/en/mongotimestamp.construct.php
+     * @param int $sec [optional] Number of seconds since January 1st, 1970
+     * @param int $inc [optional] Increment
+     */
+    public function __construct($sec = 0, $inc) {}
+
+    /**
+     * @return string
+     */
+    public function __toString() {}
+}

lib/Mongo/MongoWriteConcernException.php

@@ -0,0 +1,27 @@
+<?php
+/*
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+/**
+ * <p>(PECL mongo &gt;= 1.5.0)</p>
+ * @link http://php.net/manual/en/class.mongowriteconcernexception.php#class.mongowriteconcernexception
+ */
+class MongoWriteConcernException extends MongoCursorException {
+    /**
+     * Get the error document
+     * @link http://php.net/manual/en/mongowriteconcernexception.getdocument.php
+     * @return array <p>A MongoDB document, if available, as an array.</p>
+     */
+    public function getDocument() {}
+}

phpunit.xml.dist

@@ -0,0 +1,23 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<phpunit backupGlobals="false"
+         backupStaticAttributes="false"
+         colors="false"
+         convertErrorsToExceptions="true"
+         convertNoticesToExceptions="true"
+         convertWarningsToExceptions="true"
+         stopOnFailure="false"
+         syntaxCheck="false"
+>
+    <testsuites>
+        <testsuite name="Mongo driver adapter test suite">
+            <directory>./tests/Alcaeus/MongoDbAdapter/</directory>
+        </testsuite>
+    </testsuites>
+
+    <filter>
+        <whitelist>
+            <directory suffix=".php">./lib/Alcaeus/MongoDbAdapter</directory>
+        </whitelist>
+    </filter>
+</phpunit>

tests/Alcaeus/MongoDbAdapter/MongoClientTest.php

@@ -0,0 +1,65 @@
+<?php
+
+namespace Alcaeus\MongoDbAdapter\Tests;
+
+/**
+ * @author alcaeus <alcaeus@alcaeus.org>
+ * @covers MongoClient
+ */
+class MongoClientTest extends TestCase
+{
+    public function testConnectAndDisconnect()
+    {
+        $client = $this->getClient();
+        $this->assertTrue($client->connected);
+
+        $client->close();
+        $this->assertFalse($client->connected);
+    }
+
+    public function testClientWithoutAutomaticConnect()
+    {
+        $client = $this->getClient([]);
+        $this->assertFalse($client->connected);
+    }
+
+    public function testGetDb()
+    {
+        $client = $this->getClient();
+        $db = $client->selectDB('mongo-php-adapter');
+        $this->assertInstanceOf('\MongoDB', $db);
+        $this->assertSame('mongo-php-adapter', (string) $db);
+    }
+
+    public function testGetDbProperty()
+    {
+        $client = $this->getClient();
+        $db = $client->{'mongo-php-adapter'};
+        $this->assertInstanceOf('\MongoDB', $db);
+        $this->assertSame('mongo-php-adapter', (string) $db);
+    }
+
+    public function testGetCollection()
+    {
+        $client = $this->getClient();
+        $collection = $client->selectCollection('mongo-php-adapter', 'test');
+        $this->assertInstanceOf('MongoCollection', $collection);
+        $this->assertSame('mongo-php-adapter.test', (string) $collection);
+    }
+
+    /**
+     * @param array|null $options
+     * @return \MongoClient
+     */
+    protected function getClient($options = null)
+    {
+        $args = ['mongodb://localhost'];
+        if ($options !== null) {
+            $args[] = $options;
+        }
+
+        $reflection = new \ReflectionClass('MongoClient');
+
+        return $reflection->newInstanceArgs($args);
+    }
+}

tests/Alcaeus/MongoDbAdapter/MongoCollectionTest.php

@@ -0,0 +1,38 @@
+<?php
+
+namespace Alcaeus\MongoDbAdapter\Tests;
+
+/**
+ * @author alcaeus <alcaeus@alcaeus.org>
+ * @covers MongoCollection
+ */
+class MongoCollectionTest extends TestCase
+{
+    public function testCreateRecord()
+    {
+        $id = '54203e08d51d4a1f868b456e';
+        $collection = $this->getCollection();
+
+        $collection->insert(['_id' => new \MongoId($id), 'foo' => 'bar']);
+
+        $newCollection = $this->getCheckDatabase()->selectCollection('test');
+        $this->assertSame(1, $newCollection->count());
+        $object = $newCollection->findOne();
+
+        $this->assertNotNull($object);
+        $this->assertAttributeInstanceOf('MongoDB\BSON\ObjectID', '_id', $object);
+        $this->assertSame($id, (string) $object->_id);
+        $this->assertObjectHasAttribute('foo', $object);
+        $this->assertAttributeSame('bar', 'foo', $object);
+    }
+
+    /**
+     * @return \MongoCollection
+     */
+    protected function getCollection($name = 'test')
+    {
+        $client = new \MongoClient();
+
+        return $client->selectCollection('mongo-php-adapter', $name);
+    }
+}

tests/Alcaeus/MongoDbAdapter/MongoDBTest.php

@@ -0,0 +1,36 @@
+<?php
+
+namespace Alcaeus\MongoDbAdapter\Tests;
+
+/**
+ * @author alcaeus <alcaeus@alcaeus.org>
+ * @covers MongoDB
+ */
+class MongoDBTest extends TestCase
+{
+    public function testGetCollection()
+    {
+        $db = $this->getDatabase();
+        $collection = $db->selectCollection('test');
+        $this->assertInstanceOf('MongoCollection', $collection);
+        $this->assertSame('mongo-php-adapter.test', (string) $collection);
+    }
+
+    public function testGetCollectionProperty()
+    {
+        $db = $this->getDatabase();
+        $collection = $db->test;
+        $this->assertInstanceOf('MongoCollection', $collection);
+        $this->assertSame('mongo-php-adapter.test', (string) $collection);
+    }
+
+    /**
+     * @return \MongoDB
+     */
+    protected function getDatabase()
+    {
+        $client = new \MongoClient();
+
+        return $client->selectDB('mongo-php-adapter');
+    }
+}

tests/Alcaeus/MongoDbAdapter/MongoIdTest.php

@@ -0,0 +1,77 @@
+<?php
+
+namespace Alcaeus\MongoDbAdapter\Tests;
+
+/**
+ * @author alcaeus <alcaeus@alcaeus.org>
+ * @covers MongoId
+ */
+class MongoIdTest extends TestCase
+{
+    public function testCreateWithoutParameter()
+    {
+        $id = new \MongoId();
+        $stringId = (string) $id;
+
+        $this->assertSame(24, strlen($stringId));
+        $this->assertSame($stringId, $id->{'$id'});
+
+        $serialized = serialize($id);
+        $this->assertSame(sprintf('C:7:"MongoId":24:{%s}', $stringId), $serialized);
+
+        $unserialized = unserialize($serialized);
+        $this->assertInstanceOf('MongoId', $unserialized);
+        $this->assertSame($stringId, (string) $unserialized);
+    }
+
+    public function testCreateWithString()
+    {
+        $original = '54203e08d51d4a1f868b456e';
+        $id = new \MongoId($original);
+        $this->assertSame($original, (string) $id);
+
+        $this->assertSame(9127278, $id->getInc());
+        $this->assertSame(1411399176, $id->getTimestamp());
+        $this->assertSame(34335, $id->getPID());
+    }
+
+    /**
+     * @expectedException \MongoException
+     * @expectedExceptionMessage Invalid object ID
+     */
+    public function testCreateWithInvalidStringThrowsMongoException()
+    {
+        new \MongoId('invalid');
+    }
+
+    public function testCreateWithObjetId()
+    {
+        $original = '54203e08d51d4a1f868b456e';
+        $objectId = new \MongoDB\BSON\ObjectID($original);
+
+        $id = new \MongoId($objectId);
+        $this->assertSame($original, (string) $id);
+
+        $this->assertAttributeNotSame($objectId, 'objectID', $id);
+    }
+
+    /**
+     * @dataProvider dataIsValid
+     */
+    public function testIsValid($expected, $value)
+    {
+        $this->assertSame($expected, \MongoId::isValid($value));
+    }
+
+    public static function dataIsValid()
+    {
+        $original = '54203e08d51d4a1f868b456e';
+
+        return [
+            'validId' => [true, '' . $original . ''],
+            'MongoId' => [true, new \MongoId($original)],
+            'ObjectID' => [true, new \MongoDB\BSON\ObjectID($original)],
+            'invalidString' => [false, 'abc'],
+        ];
+    }
+}

tests/Alcaeus/MongoDbAdapter/TestCase.php

@@ -0,0 +1,22 @@
+<?php
+
+namespace Alcaeus\MongoDbAdapter\Tests;
+
+use MongoDB\Client;
+
+abstract class TestCase extends \PHPUnit_Framework_TestCase
+{
+    protected function tearDown()
+    {
+        $this->getCheckDatabase()->drop();
+    }
+
+    /**
+     * @return \MongoDB\Database
+     */
+    protected function getCheckDatabase()
+    {
+        $client = new Client('mongodb://localhost', ['connect' => true]);
+        return $client->selectDatabase('mongo-php-adapter');
+    }
+}

tests/native/.gitignore

@@ -0,0 +1 @@
+mongo-php-driver

tests/native/cfg.inc

@@ -0,0 +1,32 @@
+<?php
+
+#
+# This file was shamelessly copied over from mongofill. All credits belong to them:
+# https://github.com/mongofill/mongofill
+#
+
+# Enable to debug test-suite meltdown
+# Should not be enabled unless you know what you are doing
+if (!defined("DEBUG")) {
+    define("DEBUG", false);
+}
+
+# Path to your mongo shell. The shell is used to launch mongod If you have
+# multiple MongoDBs versions installed, you can change between the version used
+# by using the shell belonging to the version you want to test against
+$mongo = trim(shell_exec("which mongo"));
+$SHELL = $mongo;
+$DBDIR = "/tmp/data/db/";
+
+
+/* You probably don't want to change this */
+$SUPER_USER  = (object)array("username" => "root", "password" => "complicated password");
+$NORMAL_USER = (object)array("username" => "user", "password" => "this isn't it, is it?");
+
+$JSFILE       = dirname(__FILE__) . "/myconfig.js";
+$SHELL_PARAMS = "--nodb --norc --shell $JSFILE";
+$MARKER       = "COMMAND DONE";
+$QUIT         = "Sorry Matt Damon, we're out of time";
+
+
+

tests/native/helper.sh

@@ -0,0 +1,46 @@
+#!/bin/bash
+
+#
+# This file was shamelessly copied over from mongofill. All credits belong to them:
+# https://github.com/mongofill/mongofill
+#
+
+case "$1" in
+setup)  echo "Creating mongo-php-driver-legacy tests environment ..."
+    git clone git@github.com:mongodb/mongo-php-driver-legacy.git
+    cd mongo-php-driver-legacy
+    phpize
+    ./configure --quiet
+    mv tests/utils/server.inc tests/utils/server.original.inc
+    ;;
+
+clean)  echo  "Cleaning ..."
+    rm -rf mongo-php-driver-legacy
+    ;;
+
+run)  echo  "Running tests ..."
+    cd mongo-php-driver-legacy
+    echo "<?php" > tests/utils/server.inc
+    echo "require_once __DIR__ . '/../../../../../vendor/autoload.php';" >> tests/utils/server.inc
+    echo "require_once 'server.original.inc';" >> tests/utils/server.inc
+    PHP=`make findphp`
+    SHOW_ONLY_GROUPS="FAIL,XFAIL,BORK,WARN,LEAK,SKIP" REPORT_EXIT_STATUS=1 TEST_PHP_EXECUTABLE=$PHP $PHP run-tests.php -n -q -x --show-diff
+    ;;
+
+boot) echo  "Boot tests server ..."
+    cd mongo-php-driver-legacy
+    cp ../cfg.inc tests/utils/cfg.inc
+    echo "<?php" > tests/utils/server.inc
+    echo "require_once 'server.original.inc';" >> tests/utils/server.inc
+    MONGO_SERVER_STANDALONE=yes MONGO_SERVER_STANDALONE_AUTH=yes MONGO_SERVER_REPLICASET=yes MONGO_SERVER_REPLICASET_AUTH=yes make servers
+    ;;
+    
+*)  echo "Native mongo-php-driver-legacy tests helper"
+    echo ""
+    echo "Usage: $0 [setup|clean|run|boot]"
+    echo "   - setup: create the mongo-php-driver-legacy tests environment"
+    echo "   - boot: starts the mongodb servers, required by the tests"
+    echo "   - run: run the tests"
+    echo "   - clean: remove all the tests environment"
+   ;;
+esac