Nord\Lumen\Elasticsearch\Pipelines\Stages\DetermineTargetVersionStage

Complexity

Total Complexity

5

Size/Duplication

Total Lines	27
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
A	__invoke()	0	21	5

<?php

namespace Nord\Lumen\Elasticsearch\Pipelines\Stages;

use Nord\Lumen\Elasticsearch\Pipelines\Payloads\ApplyMigrationPayload;
use League\Pipeline\StageInterface;

/**
 * Class DetermineTargetVersionStage
 * @package Nord\Lumen\Elasticsearch\Pipelines\Stages
 */
class DetermineTargetVersionStage implements StageInterface
{

    /**
     * @inheritDoc
     */
    public function __invoke($payload)
    {
        /** @var ApplyMigrationPayload $payload */

        $highestVersion = 0;

        foreach (scandir($payload->getIndexVersionsPath(), SCANDIR_SORT_NONE) as $file) {
            if ($file === '.' || $file === '..') {
                continue;
            }

            $version = (int)substr($file, 0, strpos($file, '.php'));

            if ($version > $highestVersion) {
                $highestVersion = $version;
                
                $payload->setTargetVersionFile($file);
            }
        }

        return $payload;
    }
}