CleanTempStorage::start() - Code Metrics - Inspection of "v2.0.3" - gyselroth/balloon - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#141)

by Raffael

created 2018-07-10 08:04 UTC

CleanTempStorage::start() A

↳ Parent: CleanTempStorage

Complexity

Conditions	2
Paths	2

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	6

Importance

Changes

Metric	Value
dl	0
loc	22
ccs	0
cts	18
cp	0
rs	9.568
c	0
b	0
f	0
cc	2
nc	2
nop	0
crap	6

<?php

declare(strict_types=1);

/**
 * balloon
 *
 * @copyright   Copryright (c) 2012-2018 gyselroth GmbH (https://gyselroth.com)
 * @license     GPL-3.0 https://opensource.org/licenses/GPL-3.0
 */

namespace Balloon\Async;

use MongoDB\BSON\UTCDateTime;
use MongoDB\Database;
use Psr\Log\LoggerInterface;
use TaskScheduler\AbstractJob;

class CleanTempStorage extends AbstractJob
{
    /**
     * Databse.
     *
     * @var Database
     */
    protected $db;

    /**
     * Logger.
     *
     * @var LoggerInterface
     */
    protected $logger;

    /**
     * Default data.
     *
     * @var array
     */
    protected $data = [
        'max_age' => 172800,
    ];

    /**
     * Constructor.
     */
    public function __construct(Database $db, LoggerInterface $logger)
    {
        $this->db = $db;
        $this->logger = $logger;
    }

    /**
     * Start.
     */
    public function start(): bool
    {
        $lt = (time() - $this->data['max_age']) * 1000;
        $result = $this->db->selectCollection('fs.files')->find([
            'uploadDate' => ['$lt' => new UTCDateTime($lt)],
            'metadata.temporary' => true,
        ]);

        $count = 0;
        $gridfs = $this->db->selectGridFSBucket();

        foreach ($result as $blob) {
            $gridfs->delete($blob['_id']);
            ++$count;
        }

        $this->logger->info('found ['.$count.'] temporary storage blobs for cleanup', [
            'category' => get_class($this),
        ]);

        return true;
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			/**
6			* balloon
7			*
8			* @copyright Copryright (c) 2012-2018 gyselroth GmbH (https://gyselroth.com)
9			* @license GPL-3.0 https://opensource.org/licenses/GPL-3.0
10			*/
11
12			namespace Balloon\Async;
13
14			use MongoDB\BSON\UTCDateTime;
15			use MongoDB\Database;
16			use Psr\Log\LoggerInterface;
17			use TaskScheduler\AbstractJob;
18
19			class CleanTempStorage extends AbstractJob
20			{
21			/**
22			* Databse.
23			*
24			* @var Database
25			*/
26			protected $db;
27
28			/**
29			* Logger.
30			*
31			* @var LoggerInterface
32			*/
33			protected $logger;
34
35			/**
36			* Default data.
37			*
38			* @var array
39			*/
40			protected $data = [
41			'max_age' => 172800,
42			];
43
44			/**
45			* Constructor.
46			*/
47			public function __construct(Database $db, LoggerInterface $logger)
48			{
49			$this->db = $db;
50			$this->logger = $logger;
51			}
52
53			/**
54			* Start.
55			*/
56			public function start(): bool
57			{
58			$lt = (time() - $this->data['max_age']) * 1000;
59			$result = $this->db->selectCollection('fs.files')->find([
60			'uploadDate' => ['$lt' => new UTCDateTime($lt)],
61			'metadata.temporary' => true,
62			]);
63
64			$count = 0;
65			$gridfs = $this->db->selectGridFSBucket();
66
67			foreach ($result as $blob) {
68			$gridfs->delete($blob['_id']);
69			++$count;
70			}
71
72			$this->logger->info('found ['.$count.'] temporary storage blobs for cleanup', [
73			'category' => get_class($this),
74			]);
75
76			return true;
77			}
78			}
79

gyselroth / balloon

Pull Request — master (#141)

CleanTempStorage::start() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like