MongoGridFS - Code Metrics - Inspection of "Exception handling" - alcaeus/mongo-php-adapter - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#20)

unknown

created 2016-01-10 04:18 UTC

MongoGridFS B

↳ Parent: Project

Complexity

Total Complexity

Size/Duplication

Total Lines	438
Duplicated Lines	1.6 %

Coupling/Cohesion

Components	1
Dependencies	8

Metric	Value
wmc	48
lcom	1
cbo	8
dl	7
loc	438
rs	8.4865

18 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	18	3
A	delete()	0	7	1
A	drop()	0	5	1
A	find()	7	7	1
A	findOne()	0	9	2
A	get()	0	4	1
A	put()	0	4	1
A	remove()	0	12	2
B	storeBytes()	0	24	3
C	storeFile()	0	64	12
B	storeUpload()	0	25	6
A	createChunksIndex()	0	7	2
A	insertChunk()	0	16	2
A	insertChunksFromBytes()	0	11	2
A	insertChunksFromFile()	0	19	2
A	insertFile()	0	16	2
A	getMd5ForFile()	0	5	1
A	isOKResult()	0	5	4

How to fix Duplicated Code Complexity

Duplicated Code

Duplicate code is one of the most pungent code smells. A rule that is often used is to re-structure code once it is duplicated in three or more places.

Common duplication problems, and corresponding solutions are:

If you have the same expression in different places: Extract expression to a method
If you have the same method in different sub-classes: Extract method, and pull up field to the parent class
If you have the same code in unrelated classes: Consider extracting the code to a new class, and injecting that class

Complex Class

Tip: Before tackling complexity, make sure that you eliminate any duplication first. This often can reduce the size of classes significantly.

Complex classes like MongoGridFS often do a lot of different things. To break such a class down, we need to identify a cohesive component within that class. A common approach to find such a component is to look for fields/methods that share the same prefixes, or suffixes. You can also have a look at the cohesion graph to spot any un-connected, or weakly-connected components.

Once you have determined the fields that belong together, you can apply the Extract Class refactoring. If the component makes sense as a sub-class, Extract Subclass is also a candidate, and is often faster.

While breaking up the class, it is a good idea to analyze how other classes use MongoGridFS, and based on these observations, apply Extract Interface, too.

<?php
/*
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 */

class MongoGridFS extends MongoCollection
namespace YourVendor;

class YourClass { }
{
    const DEFAULT_CHUNK_SIZE = 262144; // 256 kb

    const ASCENDING = 1;
    const DESCENDING = -1;

    /**
     * @link http://php.net/manual/en/class.mongogridfs.php#mongogridfs.props.chunks
     * @var $chunks MongoCollection
     */
    public $chunks;

    /**
     * @link http://php.net/manual/en/class.mongogridfs.php#mongogridfs.props.filesname
     * @var $filesName string
     */
    protected $filesName;

    /**
     * @link http://php.net/manual/en/class.mongogridfs.php#mongogridfs.props.chunksname
     * @var $chunksName string
     */
    protected $chunksName;

    /**
     * @var MongoDB
     */
    private $database;

    private $prefix;

    /**
     * Files as stored across two collections, the first containing file meta
     * information, the second containing chunks of the actual file. By default,
     * fs.files and fs.chunks are the collection names used.
     *
     * @link http://php.net/manual/en/mongogridfs.construct.php
     * @param MongoDB $db Database
     * @param string $prefix [optional] <p>Optional collection name prefix.</p>
     * @param mixed $chunks  [optional]
     * @return MongoGridFS

     * @throws \Exception
     */
    public function __construct(MongoDB $db, $prefix = "fs", $chunks = null)
    {
        if ($chunks) {
            trigger_error("The 'chunks' argument is deprecated and ignored", E_DEPRECATED);
        }
        if (empty($prefix)) {
            throw new \Exception('MongoGridFS::__construct(): invalid prefix');
        }

        $this->database = $db;
        $this->prefix = $prefix;
        $this->filesName = $prefix . '.files';
        $this->chunksName = $prefix . '.chunks';

        $this->chunks = $db->selectCollection($this->chunksName);

        parent::__construct($db, $this->filesName);
    }

    /**
     * Delete a file from the database
     *
     * @link http://php.net/manual/en/mongogridfs.delete.php
     * @param mixed $id _id of the file to remove
     * @return boolean Returns true if the remove was successfully sent to the database.
     */
    public function delete($id)
    {
        $this->createChunksIndex();

        $this->chunks->remove(['files_id' => $id], ['justOne' => false]);
        return parent::remove(['_id' => $id]);
class Daddy
{
    protected function getFirstName()
    {
        return "Eidur";
    }

    protected function getSurName()
    {
        return "Gudjohnsen";
    }
}

class Son
{
    public function getFirstName()
    {
        return parent::getSurname();
    }
}
    }

    /**
     * Drops the files and chunks collections
     * @link http://php.net/manual/en/mongogridfs.drop.php
     * @return array The database response
     */
    public function drop()
    {
        $this->chunks->drop();
        return parent::drop();
    }

    /**
     * @link http://php.net/manual/en/mongogridfs.find.php
     * @param array $query The query
     * @param array $fields Fields to return
     * @param array $options Options for the find command
/**
 * @param array $germany
 * @param array $island
 * @param array $italy
 */
function finale($germany, $island) {
    return "2:1";
}
     * @return MongoGridFSCursor A MongoGridFSCursor
     */
    public function find(array $query = [], array $fields = [])

    {
        $cursor = new MongoGridFSCursor($this, $this->db->getConnection(), (string) $this, $query, $fields);
        $cursor->setReadPreference($this->getReadPreference());
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);

        return $cursor;
    }

    /**
     * Returns a single file matching the criteria
     *
     * @link http://www.php.net/manual/en/mongogridfs.findone.php
     * @param array $query The fields for which to search.
     * @param array $fields Fields of the results to return.
     * @param array $options Options for the find command
     * @return MongoGridFSFile|null
     */
    public function findOne(array $query = [], array $fields = [], array $options = [])
    {
        if (is_string($query)) {
            $query = ['filename' => $query];
        }

        $items = iterator_to_array($this->find($query, $fields)->limit(1));
        return current($items);
    }

    /**
     * Retrieve a file from the database
     *
     * @link http://www.php.net/manual/en/mongogridfs.get.php
     * @param mixed $id _id of the file to find.
     * @return MongoGridFSFile|null
     */
    public function get($id)
    {
        return $this->findOne(['_id' => $id]);
    }

    /**
     * Stores a file in the database
     *
     * @link http://php.net/manual/en/mongogridfs.put.php
     * @param string $filename The name of the file
     * @param array $extra Other metadata to add to the file saved
     * @param array $options An array of options for the insert operations executed against the chunks and files collections.
     * @return mixed Returns the _id of the saved object
     */
    public function put($filename, array $extra = [], array $options = [])
    {
        return $this->storeFile($filename, $extra, $options);
    }

    /**
     * Removes files from the collections
     *
     * @link http://www.php.net/manual/en/mongogridfs.remove.php
     * @param array $criteria Description of records to remove.
     * @param array $options Options for remove.
     * @throws MongoCursorException
     * @return boolean
     */
    public function remove(array $criteria = [], array $options = [])
    {
        $this->createChunksIndex();

        $matchingFiles = parent::find($criteria, ['_id' => 1]);
class Daddy
{
    protected function getFirstName()
    {
        return "Eidur";
    }

    protected function getSurName()
    {
        return "Gudjohnsen";
    }
}

class Son
{
    public function getFirstName()
    {
        return parent::getSurname();
    }
}
        $ids = [];
        foreach ($matchingFiles as $file) {
            $ids[] = $file['_id'];
        }
        $this->chunks->remove(['files_id' => ['$in' => $ids]], ['justOne' => false] + $options);
        return parent::remove(['_id' => ['$in' => $ids]], ['justOne' => false] + $options);
    }

    /**
     * Chunkifies and stores bytes in the database
     * @link http://php.net/manual/en/mongogridfs.storebytes.php
     * @param string $bytes A string of bytes to store
     * @param array $extra Other metadata to add to the file saved
     * @param array $options Options for the store. "safe": Check that this store succeeded
     * @return mixed The _id of the object saved
     */
    public function storeBytes($bytes, array $extra = [], array $options = [])
    {
        $this->createChunksIndex();

        $record = $extra + [
            'length' => mb_strlen($bytes, '8bit'),
            'md5' => md5($bytes),
        ];

        try {
            $file = $this->insertFile($record, $options);
        } catch (MongoException $e) {
            throw new MongoGridFSException('Cannot insert file record', 0, $e);
        }

        try {
            $this->insertChunksFromBytes($bytes, $file);
        } catch (MongoException $e) {
            $this->delete($file['_id']);
            throw new MongoGridFSException('Error while inserting chunks', 0, $e);
        }

        return $file['_id'];
    }

    /**
     * Stores a file in the database
     *
     * @link http://php.net/manual/en/mongogridfs.storefile.php
     * @param string $filename The name of the file
     * @param array $extra Other metadata to add to the file saved
     * @param array $options Options for the store. "safe": Check that this store succeeded
     * @return mixed Returns the _id of the saved object
     * @throws MongoGridFSException
     * @throws Exception
     */
    public function storeFile($filename, array $extra = [], array $options = [])
    {
        $this->createChunksIndex();

        $record = $extra;
        if (is_string($filename)) {
            $record += [
                'md5' => md5_file($filename),
                'length' => filesize($filename),
                'filename' => $filename,
            ];

            $handle = fopen($filename, 'r');
            if (! $handle) {
                throw new MongoGridFSException('could not open file: ' . $filename);
            }
        } elseif (! is_resource($filename)) {
            throw new \Exception('first argument must be a string or stream resource');
        } else {
            $handle = $filename;
        }

        try {
            $file = $this->insertFile($record, $options);
        } catch (MongoException $e) {
            throw new MongoGridFSException('Cannot insert file record', 0, $e);
        }

        try {
            $length = $this->insertChunksFromFile($handle, $file);
        } catch (MongoException $e) {
            $this->delete($file['_id']);
            throw new MongoGridFSException('Error while inserting chunks', 0, $e);
        }


        // Add length and MD5 if they were not present before
        $update = [];
        if (! isset($record['length'])) {
            $update['length'] = $length;
        }
        if (! isset($record['md5'])) {
            try {
                $update['md5'] = $this->getMd5ForFile($file['_id']);
            } catch (MongoException $e) {
                throw new MongoGridFSException('Error computing MD5 checksum', 0, $e);
            }
        }

        if (count($update)) {
            try {
                $result = $this->update(['_id' => $file['_id']], ['$set' => $update]);
                if (! $this->isOKResult($result)) {
                    throw new MongoGridFSException('Error updating file record');
                }
            } catch (MongoException $e) {
                $this->delete($file['_id']);
                throw new MongoGridFSException('Error updating file record', 0, $e);
            }

        }

        return $file['_id'];
    }

    /**
     * Saves an uploaded file directly from a POST to the database
     *
     * @link http://www.php.net/manual/en/mongogridfs.storeupload.php
     * @param string $name The name attribute of the uploaded file, from <input type="file" name="something"/>.
     * @param array $metadata An array of extra fields for the uploaded file.
     * @return mixed Returns the _id of the uploaded file.
     * @throws MongoGridFSException
     */
    public function storeUpload($name, array $metadata = [])
// Bad
class Router
{
    public function generate($path)
    {
        return $_SERVER['HOST'].$path;
    }
}

// Better
class Router
{
    private $host;

    public function __construct($host)
    {
        $this->host = $host;
    }

    public function generate($path)
    {
        return $this->host.$path;
    }
}

class Controller
{
    public function myAction(Request $request)
    {
        // Instead of
        $page = isset($_GET['page']) ? intval($_GET['page']) : 1;

        // Better (assuming you use the Symfony2 request)
        $page = $request->query->get('page', 1);
    }
}
    {
        if (! isset($_FILES[$name]) || $_FILES[$name]['error'] !== UPLOAD_ERR_OK) {
            throw new MongoGridFSException("Could not find uploaded file $name");
        }
        if (! isset($_FILES[$name]['tmp_name'])) {
            throw new MongoGridFSException("Couldn't find tmp_name in the \$_FILES array. Are you sure the upload worked?");
        }

        $uploadedFile = $_FILES[$name];
        $uploadedFile['tmp_name'] = (array) $uploadedFile['tmp_name'];
        $uploadedFile['name'] = (array) $uploadedFile['name'];

        if (count($uploadedFile['tmp_name']) > 1) {
            foreach ($uploadedFile['tmp_name'] as $key => $file) {
                $metadata['filename'] = $uploadedFile['name'][$key];
                $this->storeFile($file, $metadata);
            }

            return null;
        } else {
            $metadata += ['filename' => array_pop($uploadedFile['name'])];
            return $this->storeFile(array_pop($uploadedFile['tmp_name']), $metadata);
        }
    }

    /**
     * Creates the index on the chunks collection
     */
    private function createChunksIndex()
    {
        try {
            $this->chunks->createIndex(['files_id' => 1, 'n' => 1], ['unique' => true]);
        } catch (MongoDuplicateKeyException $e) {}


    }

    /**
     * Inserts a single chunk into the database
     *
     * @param mixed $fileId
     * @param string $data
     * @param int $chunkNumber
     * @return array|bool
     */
    private function insertChunk($fileId, $data, $chunkNumber)
    {
        $chunk = [
            'files_id' => $fileId,
            'n' => $chunkNumber,
            'data' => new MongoBinData($data),
        ];

        $result = $this->chunks->insert($chunk);

        if (! $this->isOKResult($result)) {
            throw new \MongoException('error inserting chunk');
        }

        return $result;
    }

    /**
     * Splits a string into chunks and writes them to the database
     *
     * @param string $bytes
     * @param array $record
     */
    private function insertChunksFromBytes($bytes, $record)
    {
        $chunkSize = $record['chunkSize'];
        $fileId = $record['_id'];
        $i = 0;

        $chunks = str_split($bytes, $chunkSize);
        foreach ($chunks as $chunk) {
            $this->insertChunk($fileId, $chunk, $i++);
        }
    }

    /**
     * Reads chunks from a file and writes them to the database
     *
     * @param resource $handle
     * @param array $record
     * @return int Returns the number of bytes written to the database
     */
    private function insertChunksFromFile($handle, $record)
    {
        $written = 0;
        $offset = 0;
        $i = 0;

        $fileId = $record['_id'];
        $chunkSize = $record['chunkSize'];

        rewind($handle);
        while (! feof($handle)) {
            $data = stream_get_contents($handle, $chunkSize);
            $this->insertChunk($fileId, $data, $i++);
            $written += strlen($data);
            $offset += $chunkSize;
        }

        return $written;
    }

    /**
     * Writes a file record to the database
     *
     * @param $record
     * @param array $options
     * @return array
     */
    private function insertFile($record, array $options = [])
    {
        $record += [
            '_id' => new MongoId(),
            'uploadDate' => new MongoDate(),
            'chunkSize' => self::DEFAULT_CHUNK_SIZE,
        ];

        $result = $this->insert($record, $options);

        if (! $this->isOKResult($result)) {
            throw new \MongoException('error inserting file');
        }

        return $record;
    }

    /**
     * Returns the MD5 string for a file previously stored to the database
     *
     * @param $id
     * @return string
     */
    private function getMd5ForFile($id)
    {
        $result = $this->db->command(['filemd5' => $id, 'root' => $this->prefix]);
        return $result['md5'];
    }

    private function isOKResult($result)
    {
        return (is_array($result) && $result['ok'] == 1.0) ||
               (is_bool($result) && $result);
    }
}


1		<?php
2		/*
3		* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
4		* "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
5		* LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
6		* A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
7		* OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
8		* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
9		* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
10		* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
11		* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
12		* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
13		* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
14		*/
15
16		class MongoGridFS extends MongoCollection
		1 ignored issue – show Coding Style Compatibility introduced 2015-12-29 16:10 UTC by Report Bug Copy Issue Report PSR1 recommends that each class must be in a namespace of at least one level to avoid collisions. You can fix this by adding a namespace to your class: namespace YourVendor; class YourClass { } When choosing a vendor namespace, try to pick something that is not too generic to avoid conflicts with other libraries. Loading history...
17		{
18		const DEFAULT_CHUNK_SIZE = 262144; // 256 kb
19
20		const ASCENDING = 1;
21		const DESCENDING = -1;
22
23		/**
24		* @link http://php.net/manual/en/class.mongogridfs.php#mongogridfs.props.chunks
25		* @var $chunks MongoCollection
26		*/
27		public $chunks;
28
29		/**
30		* @link http://php.net/manual/en/class.mongogridfs.php#mongogridfs.props.filesname
31		* @var $filesName string
32		*/
33		protected $filesName;
34
35		/**
36		* @link http://php.net/manual/en/class.mongogridfs.php#mongogridfs.props.chunksname
37		* @var $chunksName string
38		*/
39		protected $chunksName;
40
41		/**
42		* @var MongoDB
43		*/
44		private $database;
45
46		private $prefix;
47
48		/**
49		* Files as stored across two collections, the first containing file meta
50		* information, the second containing chunks of the actual file. By default,
51		* fs.files and fs.chunks are the collection names used.
52		*
53		* @link http://php.net/manual/en/mongogridfs.construct.php
54		* @param MongoDB $db Database
55		* @param string $prefix [optional] <p>Optional collection name prefix.</p>
56		* @param mixed $chunks [optional]
57		* @return MongoGridFS
		0 ignored issues – show Comprehensibility Best Practice introduced 2015-12-29 16:10 UTC by Report Bug Copy Issue Report Adding a `@return` annotation to constructors is generally not recommended as a constructor does not have a meaningful return value. Adding a `@return` annotation to a constructor is not recommended, since a constructor does not have a meaningful return value. Please refer to the PHP core documentation on constructors. Loading history...
58		* @throws \Exception
59		*/
60		public function __construct(MongoDB $db, $prefix = "fs", $chunks = null)
61		{
62		if ($chunks) {
63		trigger_error("The 'chunks' argument is deprecated and ignored", E_DEPRECATED);
64		}
65		if (empty($prefix)) {
66		throw new \Exception('MongoGridFS::__construct(): invalid prefix');
67		}
68
69		$this->database = $db;
70		$this->prefix = $prefix;
71		$this->filesName = $prefix . '.files';
72		$this->chunksName = $prefix . '.chunks';
73
74		$this->chunks = $db->selectCollection($this->chunksName);
75
76		parent::__construct($db, $this->filesName);
77		}
78
79		/**
80		* Delete a file from the database
81		*
82		* @link http://php.net/manual/en/mongogridfs.delete.php
83		* @param mixed $id _id of the file to remove
84		* @return boolean Returns true if the remove was successfully sent to the database.
85		*/
86		public function delete($id)
87		{
88		$this->createChunksIndex();
89
90		$this->chunks->remove(['files_id' => $id], ['justOne' => false]);
91		return parent::remove(['_id' => $id]);
		0 ignored issues – show Comprehensibility Bug introduced 2016-01-03 08:54 UTC by Report Bug Copy Issue Report It seems like you call parent on a different method (`remove()` instead of `delete()`). Are you sure this is correct? If so, you might want to change this to `$this->remove()`. This check looks for a call to a parent method whose name is different than the method from which it is called. Consider the following code: class Daddy { protected function getFirstName() { return "Eidur"; } protected function getSurName() { return "Gudjohnsen"; } } class Son { public function getFirstName() { return parent::getSurname(); } } The `getFirstName()` method in the `Son` calls the wrong method in the parent class. Loading history...
92		}
93
94		/**
95		* Drops the files and chunks collections
96		* @link http://php.net/manual/en/mongogridfs.drop.php
97		* @return array The database response
98		*/
99		public function drop()
100		{
101		$this->chunks->drop();
102		return parent::drop();
103		}
104
105		/**
106		* @link http://php.net/manual/en/mongogridfs.find.php
107		* @param array $query The query
108		* @param array $fields Fields to return
109		* @param array $options Options for the find command
		0 ignored issues – show Bug introduced 2016-01-06 12:44 UTC by Report Bug Copy Issue Report There is no parameter named `$options`. Was it maybe removed? This check looks for PHPDoc comments describing methods or function parameters that do not exist on the corresponding method or function. Consider the following example. The parameter `$italy` is not defined by the method `finale(...)`. /** * @param array $germany * @param array $island * @param array $italy */ function finale($germany, $island) { return "2:1"; } The most likely cause is that the parameter was removed, but the annotation was not. Loading history...
110		* @return MongoGridFSCursor A MongoGridFSCursor
111		*/
112	View Code Duplication	public function find(array $query = [], array $fields = [])
		0 ignored issues – show Duplication introduced 2016-01-06 12:44 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
113		{
114		$cursor = new MongoGridFSCursor($this, $this->db->getConnection(), (string) $this, $query, $fields);
115		$cursor->setReadPreference($this->getReadPreference());
		0 ignored issues – show Documentation introduced 2016-01-03 08:54 UTC by Report Bug Copy Issue Report `$this->getReadPreference()` is of type `array`, but the function expects a `string`. It seems like the type of the argument is not accepted by the function/method which you are calling. In some cases, in particular if PHP’s automatic type-juggling kicks in this might be fine. In other cases, however this might be a bug. We suggest to add an explicit type cast like in the following example: function acceptsInteger($int) { } $x = '123'; // string "123" // Instead of acceptsInteger($x); // we recommend to use acceptsInteger((integer) $x); Loading history...
116
117		return $cursor;
118		}
119
120		/**
121		* Returns a single file matching the criteria
122		*
123		* @link http://www.php.net/manual/en/mongogridfs.findone.php
124		* @param array $query The fields for which to search.
125		* @param array $fields Fields of the results to return.
126		* @param array $options Options for the find command
127		* @return MongoGridFSFile\|null
128		*/
129		public function findOne(array $query = [], array $fields = [], array $options = [])
130		{
131		if (is_string($query)) {
132		$query = ['filename' => $query];
133		}
134
135		$items = iterator_to_array($this->find($query, $fields)->limit(1));
136		return current($items);
137		}
138
139		/**
140		* Retrieve a file from the database
141		*
142		* @link http://www.php.net/manual/en/mongogridfs.get.php
143		* @param mixed $id _id of the file to find.
144		* @return MongoGridFSFile\|null
145		*/
146		public function get($id)
147		{
148		return $this->findOne(['_id' => $id]);
149		}
150
151		/**
152		* Stores a file in the database
153		*
154		* @link http://php.net/manual/en/mongogridfs.put.php
155		* @param string $filename The name of the file
156		* @param array $extra Other metadata to add to the file saved
157		* @param array $options An array of options for the insert operations executed against the chunks and files collections.
158		* @return mixed Returns the _id of the saved object
159		*/
160		public function put($filename, array $extra = [], array $options = [])
161		{
162		return $this->storeFile($filename, $extra, $options);
163		}
164
165		/**
166		* Removes files from the collections
167		*
168		* @link http://www.php.net/manual/en/mongogridfs.remove.php
169		* @param array $criteria Description of records to remove.
170		* @param array $options Options for remove.
171		* @throws MongoCursorException
172		* @return boolean
173		*/
174		public function remove(array $criteria = [], array $options = [])
175		{
176		$this->createChunksIndex();
177
178		$matchingFiles = parent::find($criteria, ['_id' => 1]);
		1 ignored issue – show Comprehensibility Bug introduced 2016-01-03 08:54 UTC by Report Bug Copy Issue Report It seems like you call parent on a different method (`find()` instead of `remove()`). Are you sure this is correct? If so, you might want to change this to `$this->find()`. This check looks for a call to a parent method whose name is different than the method from which it is called. Consider the following code: class Daddy { protected function getFirstName() { return "Eidur"; } protected function getSurName() { return "Gudjohnsen"; } } class Son { public function getFirstName() { return parent::getSurname(); } } The `getFirstName()` method in the `Son` calls the wrong method in the parent class. Loading history...
179		$ids = [];
180		foreach ($matchingFiles as $file) {
181		$ids[] = $file['_id'];
182		}
183		$this->chunks->remove(['files_id' => ['$in' => $ids]], ['justOne' => false] + $options);
184		return parent::remove(['_id' => ['$in' => $ids]], ['justOne' => false] + $options);
185		}
186
187		/**
188		* Chunkifies and stores bytes in the database
189		* @link http://php.net/manual/en/mongogridfs.storebytes.php
190		* @param string $bytes A string of bytes to store
191		* @param array $extra Other metadata to add to the file saved
192		* @param array $options Options for the store. "safe": Check that this store succeeded
193		* @return mixed The _id of the object saved
194		*/
195		public function storeBytes($bytes, array $extra = [], array $options = [])
196		{
197		$this->createChunksIndex();
198
199		$record = $extra + [
200		'length' => mb_strlen($bytes, '8bit'),
201		'md5' => md5($bytes),
202		];
203
204		try {
205		$file = $this->insertFile($record, $options);
206		} catch (MongoException $e) {
207		throw new MongoGridFSException('Cannot insert file record', 0, $e);
208		}
209
210		try {
211		$this->insertChunksFromBytes($bytes, $file);
212		} catch (MongoException $e) {
213		$this->delete($file['_id']);
214		throw new MongoGridFSException('Error while inserting chunks', 0, $e);
215		}
216
217		return $file['_id'];
218		}
219
220		/**
221		* Stores a file in the database
222		*
223		* @link http://php.net/manual/en/mongogridfs.storefile.php
224		* @param string $filename The name of the file
225		* @param array $extra Other metadata to add to the file saved
226		* @param array $options Options for the store. "safe": Check that this store succeeded
227		* @return mixed Returns the _id of the saved object
228		* @throws MongoGridFSException
229		* @throws Exception
230		*/
231		public function storeFile($filename, array $extra = [], array $options = [])
232		{
233		$this->createChunksIndex();
234
235		$record = $extra;
236		if (is_string($filename)) {
237		$record += [
238		'md5' => md5_file($filename),
239		'length' => filesize($filename),
240		'filename' => $filename,
241		];
242
243		$handle = fopen($filename, 'r');
244		if (! $handle) {
245		throw new MongoGridFSException('could not open file: ' . $filename);
246		}
247		} elseif (! is_resource($filename)) {
248		throw new \Exception('first argument must be a string or stream resource');
249		} else {
250		$handle = $filename;
251		}
252
253		try {
254		$file = $this->insertFile($record, $options);
255		} catch (MongoException $e) {
256		throw new MongoGridFSException('Cannot insert file record', 0, $e);
257		}
258
259		try {
260		$length = $this->insertChunksFromFile($handle, $file);
261		} catch (MongoException $e) {
262		$this->delete($file['_id']);
263		throw new MongoGridFSException('Error while inserting chunks', 0, $e);
264		}
265
266
267		// Add length and MD5 if they were not present before
268		$update = [];
269		if (! isset($record['length'])) {
270		$update['length'] = $length;
271		}
272		if (! isset($record['md5'])) {
273		try {
274		$update['md5'] = $this->getMd5ForFile($file['_id']);
275		} catch (MongoException $e) {
276		throw new MongoGridFSException('Error computing MD5 checksum', 0, $e);
277		}
278		}
279
280		if (count($update)) {
281		try {
282		$result = $this->update(['_id' => $file['_id']], ['$set' => $update]);
283		if (! $this->isOKResult($result)) {
284		throw new MongoGridFSException('Error updating file record');
285		}
286		} catch (MongoException $e) {
287		$this->delete($file['_id']);
288		throw new MongoGridFSException('Error updating file record', 0, $e);
289		}
290
291		}
292
293		return $file['_id'];
294		}
295
296		/**
297		* Saves an uploaded file directly from a POST to the database
298		*
299		* @link http://www.php.net/manual/en/mongogridfs.storeupload.php
300		* @param string $name The name attribute of the uploaded file, from <input type="file" name="something"/>.
301		* @param array $metadata An array of extra fields for the uploaded file.
302		* @return mixed Returns the _id of the uploaded file.
303		* @throws MongoGridFSException
304		*/
305		public function storeUpload($name, array $metadata = [])
		0 ignored issues – show Coding Style introduced 2016-01-03 08:54 UTC by Report Bug Copy Issue Report `storeUpload` uses the super-global variable `$_FILES` which is generally not recommended. Instead of super-globals, we recommend to explicitly inject the dependencies of your class. This makes your code less dependent on global state and it becomes generally more testable: // Bad class Router { public function generate($path) { return $_SERVER['HOST'].$path; } } // Better class Router { private $host; public function __construct($host) { $this->host = $host; } public function generate($path) { return $this->host.$path; } } class Controller { public function myAction(Request $request) { // Instead of $page = isset($_GET['page']) ? intval($_GET['page']) : 1; // Better (assuming you use the Symfony2 request) $page = $request->query->get('page', 1); } } Loading history...
306		{
307		if (! isset($_FILES[$name]) \|\| $_FILES[$name]['error'] !== UPLOAD_ERR_OK) {
308		throw new MongoGridFSException("Could not find uploaded file $name");
309		}
310		if (! isset($_FILES[$name]['tmp_name'])) {
311		throw new MongoGridFSException("Couldn't find tmp_name in the \$_FILES array. Are you sure the upload worked?");
312		}
313
314		$uploadedFile = $_FILES[$name];
315		$uploadedFile['tmp_name'] = (array) $uploadedFile['tmp_name'];
316		$uploadedFile['name'] = (array) $uploadedFile['name'];
317
318		if (count($uploadedFile['tmp_name']) > 1) {
319		foreach ($uploadedFile['tmp_name'] as $key => $file) {
320		$metadata['filename'] = $uploadedFile['name'][$key];
321		$this->storeFile($file, $metadata);
322		}
323
324		return null;
325		} else {
326		$metadata += ['filename' => array_pop($uploadedFile['name'])];
327		return $this->storeFile(array_pop($uploadedFile['tmp_name']), $metadata);
328		}
329		}
330
331		/**
332		* Creates the index on the chunks collection
333		*/
334		private function createChunksIndex()
335		{
336		try {
337		$this->chunks->createIndex(['files_id' => 1, 'n' => 1], ['unique' => true]);
338		} catch (MongoDuplicateKeyException $e) {}
		1 ignored issue – show Coding Style Comprehensibility introduced 2016-01-10 04:21 UTC by Report Bug Copy Issue Report Consider adding a comment why this CATCH block is empty. Loading history...
339
340		}
341
342		/**
343		* Inserts a single chunk into the database
344		*
345		* @param mixed $fileId
346		* @param string $data
347		* @param int $chunkNumber
348		* @return array\|bool
349		*/
350		private function insertChunk($fileId, $data, $chunkNumber)
351		{
352		$chunk = [
353		'files_id' => $fileId,
354		'n' => $chunkNumber,
355		'data' => new MongoBinData($data),
356		];
357
358		$result = $this->chunks->insert($chunk);
359
360		if (! $this->isOKResult($result)) {
361		throw new \MongoException('error inserting chunk');
362		}
363
364		return $result;
365		}
366
367		/**
368		* Splits a string into chunks and writes them to the database
369		*
370		* @param string $bytes
371		* @param array $record
372		*/
373		private function insertChunksFromBytes($bytes, $record)
374		{
375		$chunkSize = $record['chunkSize'];
376		$fileId = $record['_id'];
377		$i = 0;
378
379		$chunks = str_split($bytes, $chunkSize);
380		foreach ($chunks as $chunk) {
381		$this->insertChunk($fileId, $chunk, $i++);
382		}
383		}
384
385		/**
386		* Reads chunks from a file and writes them to the database
387		*
388		* @param resource $handle
389		* @param array $record
390		* @return int Returns the number of bytes written to the database
391		*/
392		private function insertChunksFromFile($handle, $record)
393		{
394		$written = 0;
395		$offset = 0;
396		$i = 0;
397
398		$fileId = $record['_id'];
399		$chunkSize = $record['chunkSize'];
400
401		rewind($handle);
402		while (! feof($handle)) {
403		$data = stream_get_contents($handle, $chunkSize);
404		$this->insertChunk($fileId, $data, $i++);
405		$written += strlen($data);
406		$offset += $chunkSize;
407		}
408
409		return $written;
410		}
411
412		/**
413		* Writes a file record to the database
414		*
415		* @param $record
416		* @param array $options
417		* @return array
418		*/
419		private function insertFile($record, array $options = [])
420		{
421		$record += [
422		'_id' => new MongoId(),
423		'uploadDate' => new MongoDate(),
424		'chunkSize' => self::DEFAULT_CHUNK_SIZE,
425		];
426
427		$result = $this->insert($record, $options);
428
429		if (! $this->isOKResult($result)) {
430		throw new \MongoException('error inserting file');
431		}
432
433		return $record;
434		}
435
436		/**
437		* Returns the MD5 string for a file previously stored to the database
438		*
439		* @param $id
440		* @return string
441		*/
442		private function getMd5ForFile($id)
443		{
444		$result = $this->db->command(['filemd5' => $id, 'root' => $this->prefix]);
445		return $result['md5'];
446		}
447
448		private function isOKResult($result)
449		{
450		return (is_array($result) && $result['ok'] == 1.0) \|\|
451		(is_bool($result) && $result);
452		}
453		}
454

alcaeus / mongo-php-adapter