Soupmix\MongoDB

Complexity

Total Complexity

42

Size/Duplication

Total Lines	226
Duplicated Lines	10.62 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	3
Bugs	1	Features	1

13 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	connect()	0	5	1
A	create()	0	4	1
A	drop()	0	4	1
A	truncate()	0	6	1
A	createIndexes()	0	6	1
A	insert()	0	11	2
B	get()	8	43	6
A	update()	4	17	3
A	delete()	0	12	2
C	find()	12	54	13
A	query()	0	4	1
D	buildFilter()	0	34	9

<?php

namespace Soupmix;
/*
MongoDB Adapter
*/
Use MongoDB as MongoDBLib;

class MongoDB implements Base
{
    public $conn = null;

    private $dbName = null;

    public $db = null;

    public function __construct($config)
    {
        $this->dbName = $config['db_name'];
        $this->connect($config);
    }

    public function connect($config)
    {
        $this->conn = new MongoDBLib\Client($config['connection_string'], $config['options']);
        $this->db = $this->conn->{$this->dbName};
    }

    public function create($collection, $config)
    {
        return $this->db->createCollection($collection);
    }

    public function drop($collection, $config)
    {
        return $this->db->dropCollection($collection);
    }

    public function truncate($collection, $config)
    {
        $this->db->dropCollection($collection);

        return $this->db->createCollection($collection);
    }

    public function createIndexes($collection, $indexes)
    {
        $collection = $this->db->selectCollection($collection);

        return $collection->createIndexes($indexes);
    }

    public function insert($collection, $values)
    {
        $collection = $this->db->selectCollection($collection);
        $result = $collection->insertOne($values);
        $docId = $result->getInsertedId();
        if (is_object($docId)) {
            return (string) $docId;
        }
        return null;
        
    }

    public function get($collection, $docId)
    {
        $collection = $this->db->selectCollection($collection);

        $options = [
            'typeMap' => ['root' => 'array', 'document' => 'array'],
        ];

        if (gettype($docId) == "array") {

            $idList = [];
            foreach ($docId as $itemId){
                $idList[]=['_id'=>new MongoDBLib\BSON\ObjectID($itemId)];
            }

            //$filter = ['_id' => new MongoDBLib\BSON\ObjectID($docId)];

53% of this comment could be valid code. Did you maybe forget this after debugging?

            // {'$or':[{"_id":ObjectId("574d5b38a102fd10905a9183")}, {'_id':ObjectId("574d5b38a102fd10905a9182")}]}

84% of this comment could be valid code. Did you maybe forget this after debugging?

            $filter = ['$or'=>$idList];
            $cursor = $collection->find($filter, $options);
            $iterator = new \IteratorIterator($cursor);
            $iterator->rewind();
            $results=[];
            while ($doc = $iterator->current()) {

This code seems to be duplicated across your project.

                if (isset($doc['_id'])) {
                    $doc['id'] = (string) $doc['_id'];
                    unset($doc['_id']);
                }
                $results[$doc['id']] = $doc;
                $iterator->next();
            }
            return $results;
        } else {
            $filter = ['_id' => new MongoDBLib\BSON\ObjectID($docId)];
            $result = $collection->findOne($filter, $options);
            if ($result!==null) {
                $result['id'] = (string) $result['_id'];
                unset($result['_id']);
            }

        }

        return $result;
    }

    public function update($collection, $filters, $values)
    {
        $collection = $this->db->selectCollection($collection);
        if (isset($filters['id'])) {

This code seems to be duplicated across your project.

            $filters['_id'] = new MongoDBLib\BSON\ObjectID($filters['id']);
            unset($filters['id']);
        }
        $query_filters = [];
        if ($filters != null) {
            $query_filters = ['$and' => self::buildFilter($filters)];
        }
        $values_set = ['$set' => $values];

        $result = $collection->updateMany($query_filters, $values_set);

        return $result->getModifiedCount();
    }

    public function delete($collection, $filter)
    {
        $collection = $this->db->selectCollection($collection);
        $filter = self::buildFilter($filter)[0];
        if (isset($filter['id'])) {
            $filter['_id'] = new MongoDBLib\BSON\ObjectID($filter['id']);
            unset($filter['id']);
        }
        $result = $collection->deleteMany($filter);

        return $result->getDeletedCount();
    }

    public function find($collection, $filters, $fields = null, $sort = null, $start = 0, $limit = 25, $debug = false)
    {
        $collection = $this->db->selectCollection($collection);
        if (isset($filters['id'])) {

This code seems to be duplicated across your project.

            $filters['_id'] = new MongoDBLib\BSON\ObjectID($filters['id']);
            unset($filters['id']);
        }
        $query_filters = [];
        if ($filters != null) {
            $query_filters = ['$and' => self::buildFilter($filters)];
        }
        $count = $collection->count($query_filters);
        if ($count > 0) {
            $results = [];
            $options = [
                'limit' => (int) $limit,
                'skip' => (int) $start,
                'typeMap' => ['root' => 'array', 'document' => 'array'],
            ];
            if ($fields!==null) {
                $projection = [];
                foreach ($fields as $field) {
                    if ($field=='id') {
                        $field = '_id';
                    }
                    $projection[$field] = true;
                }
                $options['projection'] = $projection;
            }
            if ($sort!==null) {
                foreach ($sort as $sort_key => $sort_dir) {
                    $sort[$sort_key] = ($sort_dir=='desc') ? -1 : 1;
                    if ($sort_key=='id') {
                        $sort['_id'] = $sort[$sort_key];
                        unset($sort['id']);
                    }
                }
                $options['sort'] = $sort;
            }
            $cursor = $collection->find($query_filters, $options);
            $iterator = new \IteratorIterator($cursor);
            $iterator->rewind();
            while ($doc = $iterator->current()) {

This code seems to be duplicated across your project.

                if (isset($doc['_id'])) {
                    $doc['id'] = (string) $doc['_id'];
                    unset($doc['_id']);
                }
                $results[] = $doc;
                $iterator->next();
            }
            return ['total' => $count, 'data' => $results];
        }
        return ['total' => 0, 'data' => null];
    }

    public function query($query)
    {
        // reserved
    }

    public static function buildFilter($filter)
    {
        $filters = [];
        foreach ($filter as $key => $value) {
            if (strpos($key, '__')!==false) {
                preg_match('/__(.*?)$/i', $key, $matches);
                $operator = $matches[1];
                switch ($operator) {
                    case '!in':
                        $operator = 'nin';
                        break;
                    case 'not':
                        $operator = 'ne';
                        break;
                    case 'wildcard':
                        $operator = 'regex';
                        $value = str_replace(array('?'), array('.'), $value);
                        break;
                    case 'prefix':
                        $operator = 'regex';
                        $value = $value.'*';
                        break;
                }
                $key = str_replace($matches[0], '', $key);
                $filters[] = [$key => ['$'.$operator => $value]];
            } elseif (strpos($key, '__')===false && is_array($value)) {
                $filters[]['$or'] = self::buildFilter($value);
            } else {
                $filters[][$key] = $value;
            }
        }

        return $filters;
    }
}