Fathomminds\Rest\Database\MongoDB\Resource

Complexity

Total Complexity

17

Size/Duplication

Total Lines	95
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

0%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	11	3
A	get()	0	7	2
A	getOne()	0	5	1
A	getAll()	0	5	1
A	post()	0	10	2
A	patch()	0	16	3
A	put()	0	16	3
A	delete()	0	9	2

<?php
namespace Fathomminds\Rest\Database\MongoDB;

use MongoDB\Client;
use Fathomminds\Rest\Exceptions\RestException;
use Fathomminds\Rest\Contracts\IResource;

class Resource implements IResource
{
    protected $client;
    protected $databaseName;
    protected $collection;
    protected $resourceName;
    protected $primaryKey;

    public function __construct($resourceName, $primaryKey, Client $client = null, $databaseName = null)
    {
        $this->resourceName = $resourceName;
        $this->primaryKey = $primaryKey;
        $this->client = $client === null ?
            new Client(Database::getUri(), Database::getUriOptions(), Database::getDriverOptions()) :
            $client;
        $this->databaseName = $databaseName === null ? getenv('MONGODB_DATABASE') : $databaseName;
        $mongodb = $this->client->selectDatabase($this->databaseName);
        $this->collection = $mongodb->selectCollection($this->resourceName);
    }

    public function get($resourceId = null)
    {
        if ($resourceId !== null) {
            return $this->getOne($resourceId);
        }
        return $this->getAll();
    }

    protected function getOne($resourceId)
    {
        $res = $this->collection->findOne([$this->primaryKey => $resourceId]);
        return json_decode(json_encode($res));
    }

    protected function getAll()
    {
        $res = $this->collection->find();
        return json_decode(json_encode($res->toArray()));
    }

    public function post($newResource)
    {
        try {
            $res = $this->collection->insertOne($newResource);
            $newResource->{$this->primaryKey} = $res->getInsertedId();
            return $newResource;
        } catch (\Exception $ex) {
            throw new RestException($ex->getMessage(), []);
        }
    }

    public function patch($resourceId, $newResource)
    {
        try {
            if (isset($newResource->{$this->primaryKey})) {
                unset($newResource->{$this->primaryKey});
            }
            $this->collection->updateOne(
                [$this->primaryKey => $resourceId],
                ['$set' => get_object_vars($newResource)]
            );
            $newResource->{$this->primaryKey} = $resourceId;
            return $newResource;
        } catch (\Exception $ex) {
            throw new RestException($ex->getMessage(), []);
        }
    }

    public function put($resourceId, $newResource)
    {
        try {
            if (isset($newResource->{$this->primaryKey})) {
                unset($newResource->{$this->primaryKey});
            }
            $this->collection->replaceOne(
                [$this->primaryKey => $resourceId],
                $newResource
            );
            $newResource->{$this->primaryKey} = $resourceId;
            return $newResource;
        } catch (\Exception $ex) {
            throw new RestException($ex->getMessage(), []);
        }
    }

    public function delete($resourceId)
    {
        try {
            $this->collection->deleteOne([$this->primaryKey => $resourceId]);
            return null;
        } catch (\Exception $ex) {
            throw new RestException($ex->getMessage(), []);
        }
    }
}