League\Geotools\Cache\MongoDB

Complexity

Total Complexity

8

Size/Duplication

Total Lines	96
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

0%

Importance

Changes	2
Bugs	0	Features	1

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	2
A	getKey()	0	4	1
A	cache()	0	13	2
A	isCached()	0	15	2
A	flush()	0	4	1

<?php

/*
 * This file is part of the Geotools library.
 *
 * (c) Antoine Corcy <contact@sbin.dk>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace League\Geotools\Cache;

use League\Geotools\Batch\BatchGeocoded;
use League\Geotools\Exception\InvalidArgumentException;
use League\Geotools\Exception\RuntimeException;

/**
 * MongoDB cache class.
 *
 * @author Antoine Corcy <contact@sbin.dk>
 */
class MongoDB extends AbstractCache implements CacheInterface
{
    /**
     * The database name.
     *
     * @var string
     */
    const DATABASE = 'geotools';

    /**
     * The collection name.
     *
     * @var string
     */
    const COLLECTION = 'geotools_cache';


    /**
     * The collection to work with.
     *
     * @var MongoCollection
     */
    protected $collection;


    /**
     * Constructor.
     *
     * @param string $server     The server information (optional).
     * @param string $database   The database name (optional).
     * @param string $collection The collection name (optional).
     *
     * @throws InvalidArgumentException
     */
    public function __construct($server = null, $database = self::DATABASE, $collection = self::COLLECTION)
    {
        try {
            $mongoDB          = new \MongoClient($server);
            $this->collection = $mongoDB->$database->$collection;
        } catch (\Exception $e) {
            throw new InvalidArgumentException($e->getMessage());
        }
    }

    /**
     * {@inheritDoc}
     */
    public function getKey($providerName, $query)
    {
        return md5($providerName . $query);
    }

    /**
     * {@inheritDoc}
     */
    public function cache(BatchGeocoded $geocoded)
    {
        try {
            $this->collection->insert(
                array_merge(
                    array('id' => $this->getKey($geocoded->getProviderName(), $geocoded->getQuery())),
                    $this->normalize($geocoded)
                )
            );
        } catch (\Exception $e) {
            throw new RuntimeException($e->getMessage());
        }
    }

    /**
     * {@inheritDoc}
     */
    public function isCached($providerName, $query)
    {
        $result = $this->collection->findOne(
            array('id' => $this->getKey($providerName, $query))
        );

        if (null === $result) {
            return false;
        }

        $cached = new BatchGeocoded;
        $cached->fromArray($result);

        return $cached;
    }

    /**
     * {@inheritDoc}
     */
    public function flush()
    {
        $this->collection->drop();
    }
}