Completed
Push — master ( f7beba...93105c )
by Raffael
23:29
created

RemoveStorageReferenceFromHistory::__construct()   A

Complexity

Conditions 1
Paths 1

Size

Total Lines 4

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 0
CRAP Score 2

Importance

Changes 0
Metric Value
dl 0
loc 4
ccs 0
cts 4
cp 0
rs 10
c 0
b 0
f 0
cc 1
nc 1
nop 1
crap 2
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\Migration\Delta;
13
14
use MongoDB\Database;
15
16
class RemoveStorageReferenceFromHistory implements DeltaInterface
17
{
18
    /**
19
     * Database.
20
     *
21
     * @var Database
22
     */
23
    protected $db;
24
25
    /**
26
     * Construct.
27
     */
28
    public function __construct(Database $db)
29
    {
30
        $this->db = $db;
31
    }
32
33
    /**
34
     * Start.
35
     */
36
    public function start(): bool
37
    {
38
        $cursor = $this->db->storage->aggregate([
39
            ['$unwind' => '$history'],
40
            ['$match' => [
41
                '$or' => [
42
                    ['history.storage_reference' => ['$exists' => 1]],
43
                    ['history.storage_adapter' => ['$exists' => 1]],
44
                ],
45
            ]],
46
        ]);
47
48
        foreach ($cursor as $object) {
49
            $this->db->storage->updateOne(
50
                [
51
                    '_id' => $object['_id'],
52
                    'history.version' => $object['history']['version'],
53
                ],
54
                [
55
                    '$unset' => [
56
                        'history.$.storage_adapter' => true,
57
                        'history.$.storage_reference' => true,
58
                    ],
59
                ]
60
            );
61
        }
62
63
        return true;
64
    }
65
}
66