Balloon\Migration\Delta\GridfsFlatReferences::start()

Complexity

Conditions	3
Paths	3

Size

Total Lines	28
Code Lines	15

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function start(): bool
    {
        $cursor = $this->db->{'fs.files'}->find([
            'metadata.ref' => ['$exists' => 1],
        ]);

        foreach ($cursor as $object) {
            $references = [];
            foreach ($object['metadata']['ref'] as $reference) {
                $references[] = $reference['id'];
            }

            $this->db->storage->updateOne(
                ['_id' => $object['_id']],
                [
                    '$unset' => [
                        'metadata.ref' => 1,
                        'metadata.share_ref' => 1,
                    ],
                    '$set' => [
                        'metadata.references' => $references,
                    ],
                ]
            );
        }

        return true;
    }
}