Completed
Branch master (3adcdb)
by Raffael
08:09 queued 04:17
created

JsonEncodeFilteredCollection::start()   B

Complexity

Conditions 2
Paths 2

Size

Total Lines 26
Code Lines 13

Duplication

Lines 0
Ratio 0 %

Importance

Changes 0
Metric Value
dl 0
loc 26
rs 8.8571
c 0
b 0
f 0
cc 2
eloc 13
nc 2
nop 0
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 JsonEncodeFilteredCollection implements DeltaInterface
17
{
18
    /**
19
     * Database.
20
     *
21
     * @var Database
22
     */
23
    protected $db;
24
25
    /**
26
     * Construct.
27
     *
28
     * @param Database $db
29
     */
30
    public function __construct(Database $db)
31
    {
32
        $this->db = $db;
33
    }
34
35
    /**
36
     * Start.
37
     *
38
     * @return bool
39
     */
40
    public function start(): bool
41
    {
42
        $this->db->storage->updateMany(['directory' => true, 'filter' => []], [
43
            '$unset' => [
44
                'filter' => 1,
45
            ],
46
        ]);
47
48
        $cursor = $this->db->storage->find(
49
            [
50
            'directory' => true,
51
            'filter' => ['$type' => 3], ]
52
        );
53
54
        foreach ($cursor as $object) {
55
            $filter = json_encode($object['filter']);
56
            $this->db->storage->updateOne(
57
                ['_id' => $object['_id']],
58
                [
59
                   '$set' => ['filter' => $filter],
60
                ]
61
            );
62
        }
63
64
        return true;
65
    }
66
}
67