Oliverde8\Component\PhpEtl\ChainOperation\Transformer\ExternalFileProcessorOperation::processFile()

Complexity

Conditions	2
Paths	2

Size

Total Lines	24
Code Lines	17

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

<?php
    public function processFile(ExternalFileItem $item, ExecutionContext $context): ItemInterface
    {
        $externalFilePath = $item->getFilePath();
        $externalDir = dirname($externalFilePath);
        $fileName = basename($externalFilePath);
        $externalFileSystem = $item->getFileSystem();
        $localFileSystem = $context->getFileSystem();

        if ($item->getState() == ExternalFileItem::STATE_NEW) {
            var_dump("EXECUTE");

var_dump('EXECUTE') looks like debug code. Are you sure you do not want to remove it?

            // Move file to prevent it to be processed by another process.
            $externalFileSystem->createDirectory($externalDir . "/processing");
            $externalFileSystem->move($externalFilePath, $externalDir . "/processing/" . $fileName);

            $localFileSystem->writeStream($fileName, $externalFileSystem->readStream($externalDir . "/processing/" . $fileName));

            $item->setState(ExternalFileItem::STATE_PROCESSING);
            return new MixItem([new DataItem($fileName), $item]);
        } else {
            $externalFileSystem->createDirectory($externalDir . "/processed");
            $externalFileSystem->move($externalDir . "/processing/" . $fileName, $externalDir . "/processed/" . $fileName);

            $item->setState(ExternalFileItem::STATE_PROCESSED);
            return $item;
        }
}