for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
declare(strict_types=1);
namespace Oliverde8\Component\PhpEtl\ChainOperation\Loader;
use Oliverde8\Component\PhpEtl\ChainOperation\AbstractChainOperation;
use Oliverde8\Component\PhpEtl\ChainOperation\DataChainOperationInterface;
use Oliverde8\Component\PhpEtl\Item\DataItemInterface;
use Oliverde8\Component\PhpEtl\Item\StopItem;
use Oliverde8\Component\PhpEtl\Load\File\FileWriterInterface;
use Oliverde8\Component\PhpEtl\Model\ExecutionContext;
/**
* Class FileWriter
*
* @author de Cramer Oliver<[email protected]>
* @copyright 2022 Oliverde8
* @package Oliverde8\Component\PhpEtl\ChainOperation\Loader
*/
class FileWriterOperation extends AbstractChainOperation implements DataChainOperationInterface
{
/** @var FileWriterInterface */
protected $writer;
protected string $fileName;
public function __construct(FileWriterInterface $writer, string $fileName)
$this->writer = $writer;
$this->fileName = $fileName;
}
* @inheritdoc
public function processData(DataItemInterface $item, ExecutionContext $context): DataItemInterface
$this->writer->write($item->getData());
return $item;
public function processStop(StopItem $stopItem, ExecutionContext $context): StopItem
$resource = $this->writer->getResource();
$meta_data = stream_get_meta_data($resource);
$filename = $meta_data["uri"];
$context->getFileSystem()->writeStream($this->fileName, fopen($filename, 'r'));
return $stopItem;
oliverde8 /
php-etl
