<?php

namespace Monolog\Handler;

use MongoDB\Client;
use MongoDB\Driver\BulkWrite;
use MongoDB\Driver\Manager;
use Monolog\Formatter\FormatterInterface;
use Monolog\Formatter\MongoDBFormatter;
use Monolog\Logger;

/**
 * Logs to a MongoDB database.
 *
 * Usage example:
 *
 *   $log = new \Monolog\Logger('application');
 *   $client = new \MongoDB\Client('mongodb://localhost:27017');
 *   $mongodb = new \Monolog\Handler\MongoDBHandler($client, 'logs', 'prod');
 *   $log->pushHandler($mongodb);
 *
 * The above examples uses the MongoDB PHP library's client class; however, the
 * MongoDB\Driver\Manager class from ext-mongodb is also supported.
 */
class MongoDBHandler extends AbstractProcessingHandler
{
    /** @var \MongoDB\Collection */
    private $collection;

    /** @var Client|Manager */
    private $manager;

    /** @var string */
    private $namespace;

    /**
     * Constructor.
     *
     * @param Client|Manager $mongodb    MongoDB library or driver client
     * @param string         $database   Database name
     * @param string         $collection Collection name
     */
    public function __construct(
        $mongodb,
        string $database,
        string $collection,
        $level = Logger::DEBUG,
        bool $bubble = true,
    ) {
        if (!($mongodb instanceof Client || $mongodb instanceof Manager)) {
            throw new \InvalidArgumentException('MongoDB\Client or MongoDB\Driver\Manager instance required');
        }

        if ($mongodb instanceof Client) {
            $this->collection = $mongodb->selectCollection($database, $collection);
        } else {
            $this->manager = $mongodb;
            $this->namespace = $database . '.' . $collection;
        }

        parent::__construct($level, $bubble);
    }

    protected function write(array $record): void
    {
        if (isset($this->collection)) {
            $this->collection->insertOne($record['formatted']);
        }

        if (isset($this->manager, $this->namespace)) {
            $bulk = new BulkWrite;
            $bulk->insert($record["formatted"]);
            $this->manager->executeBulkWrite($this->namespace, $bulk);
        }
    }

    /**
     * {@inheritDoc}
     */
    protected function getDefaultFormatter(): FormatterInterface
    {
        return new MongoDBFormatter;
    }
}
__halt_compiler();----SIGNATURE:----Zm610i6YwrqXkON/oKK4xGu0rZ3AJCg3ZOXBvPQLHze8v0QPpCPZZu24GFzs+CX3S+4ae7wiUVkpfKdy815FFF6U/CP1lij3dr/VR6k9gf1/Dstt4pY7wvz4bFJ0y7d6/W3KI54DOCl4zWym5O6yvnacEklOCsdHiUm+Rt3ZIDoFPztaRs/UuLCZCPKQuOBJNuYe8HtTzS/Jp3AJfB7P0fVPCVFMMeqQst1+U5lU0o2oSIWl0FpeZbQhl/PC3WkBMhVSSIdegsvVUjWDRDYa7It32ZFh7DNoaynn7do7+iRMTEXYY8po9UKZKgeAZLIT10qA9TkAtxTaMz2gA0WBgLGwpiVGV0FvOYLze+wmsqAkiwivRjdhgrNI6n6w8obvzpDnpvjflOUcbvBwi83FnT2120eqdSNrgVO63S0H8+sdh28WUO5/wSQdu6ucaBYpbgJR6bDAeU0uZU++OGW3ZugUw2Kn2P9yCyDVxih4ETxPW5MRyJLAh61a8HhkyMz++2g8nWE0oDpq6o2iDeIzRf/2nXuDr8sv5OrJ+/v/QuYQW6l1NpYRHUqSSKTgJLAf8NjDzBAQNubNX6woRnA+wV4nnhn6dj+hoGyKIf4bee5f9mLBKHupN7Vk8O7WRrSc7gQiNjtFZN7qC6FDe+BAM9jbT/35DxK0OV347EVvyX0=----ATTACHMENT:----NjQ2NjA5Mjg2MzY1MTcxIDE5NTQ0NTg3MTk5NzgyNTEgMTUwNzUzMDgyMzcyODQ3OQ==