Oliverde8\Component\PhpEtl\ChainOperation\Extract\JsonExtractOperation::processData()

Complexity

Conditions	3
Paths	4

Size

Total Lines	14
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

<?php
    public function processData(DataItemInterface $item, ExecutionContext $context): ItemInterface
    {
        $filename = $item->getData();
        if (is_array($filename)) {
            $filename = AssociativeArray::getFromKey($filename, $this->fileKey);
        }

        if ($this->scoped) {
            $data = json_decode($context->getFileSystem()->read($filename), true);
        } else {
            $data = json_decode(file_get_contents($filename), true);
        }

        return new MixItem([new GroupedItem(new \ArrayIterator($data)), new FileExtractedItem($item->getData())]);
    }