<?php

namespace Analog\Handler;

/**
 * Send the log message to the specified collection in a
 * MongoDB database.
 *
 * Usage:
 *
 *     Analog::handler (Analog\Handler\Mongo::init (
 *         'localhost:27017', // connection string
 *         'mydb',            // database name
 *         'log'              // collection name
 *     ));
 *
 * Alternately, if you have an existing Mongo connection,
 * you can simply initialize it with that:
 *
 *     $conn = new MongoClient ('localhost:27017');           // mongo driver
 *     $conn = new MongoDB\Driver\Manager('localhost:27017'); // mongodb driver
 *     Analog::handler (Analog\Handler\Mongo::init (
 *         $conn,  // Mongo object
 *         'mydb', // database name
 *         'log'   // collection name
 *     ));
 */
class Mongo {
	public static function init ($server, $database, $collection) {
		if ($server instanceof \MongoDB\Driver\Manager) {
			$driver = 'mongodb';
			$manager = $server;
		} elseif ($server instanceof \MongoClient) {
			$db = $server->{$database};
		} else {
			if (class_exists('\MongoDB\Driver\Manager')) {
				$driver = 'mongodb';
				$manager = new \MongoDB\Driver\Manager("mongodb://$server");
			} else {
				$conn = new \MongoClient ("mongodb://$server");
				$db = $conn->{$database};
			}
		}
		if ($driver == 'mongodb') {
			return function ($info) use ($manager, $database, $collection) {
				$bulk = new \MongoDB\Driver\BulkWrite;
				$bulk->insert($info);
				$dbAndColl = $database.'.'.$collection;
				$manager->executeBulkWrite($dbAndColl, $bulk);
			};
		} else {
			return function ($info) use ($db, $collection) {
				$db->{$collection}->insert ($info);
			};
		}
	}
}