graze / data-flow

 * iconv -l

 * ```

 */

class ConvertEncoding extends \Graze\DataFile\Modify\Encoding\ConvertEncoding implements FlowInterface

{

    use InvokeTrait;

    /**

     * @var string

     */

    private $encoding;

    /**

     * @param string $encoding Encoding as defined by iconv

     * @param array  $options  -postfix <string> (Default: toEncoding)

     *                         -keepOldFile <bool> (Default: true)

     */

    public function __construct($encoding, array $options = [])

    {

        $this->encoding = $encoding;

        $this->options = $options;

    }

    /**

     * @param NodeInterface $node

     *

     * @return NodeInterface

     * @throws InvalidArgumentException

     */

    public function flow(NodeInterface $node)

    {

        if (!($node instanceof LocalFile)) {

            throw new InvalidArgumentException("Node: $node should be an instance of LocalFile");

        }

        return $this->toEncoding($node, $this->encoding, $this->options);

    }

}

use Graze\DataNode\NodeInterface;

use InvalidArgumentException;

class Head extends \Graze\DataFile\Modify\Head implements FlowInterface

{

    use InvokeTrait;

    /**

     * @param string $lines   Number of lines to tail (accepts +/- modifiers)

     * @param array  $options List of options:

     *                        -postfix <string> (Default: tail)

     *                        -keepOldFile <bool> (Default: true)

     */

    public function __construct($lines, array $options = [])

    {

        $this->lines = $lines;

        $this->options = $options;

    }

    /**

     * Run a 'flow' through the handler

     *

     * @param NodeInterface $node

     *

     * @return LocalFile

     */

    public function flow(NodeInterface $node)

    {

        if (!($node instanceof LocalFile)) {

            throw new InvalidArgumentException("Node: $node should be an instance of LocalFile");

        }

        return $this->head($node, $this->lines, $this->options);

    }

}

use Graze\DataFlow\FlowInterface;

use Graze\DataNode\NodeInterface;

class Merge extends MergeFiles implements FlowInterface

{

    use InvokeTrait;

    /**

     * @var FileNodeInterface

     */

    private $file;

    /**

     * @param FileNodeInterface $file

     * @param array             $options

     */

    public function __construct(

        FileNodeInterface $file,

        array $options = []

    ) {

        $this->file = $file;

        $this->options = $options;

    }

    /**

     * Add files from a local Directory

     *

     * @param NodeInterface $node

     *

     * @return FileNodeInterface

     */

    public function flow(NodeInterface $node)

    {

        if (!($node instanceof FileNodeCollectionInterface)) {

            throw new \InvalidArgumentException("The supplied $node is not a FileNodeCollectionInterface");

        }

        return $this->contract($node, $this->file, $this->options);

    }

}

use Graze\DataNode\NodeInterface;

use InvalidArgumentException;

class Tail extends \Graze\DataFile\Modify\Tail implements FlowInterface

{

    use InvokeTrait;

    /**

     * @param string $lines   Number of lines to head (accepts +/- modifiers)

     * @param array  $options List of options:

     *                        -postfix <string> (Default: tail)

     *                        -keepOldFile <bool> (Default: true)

     */

    public function __construct($lines, array $options = [])

    {

        $this->lines = $lines;

        $this->options = $options;

    }

    /**

     * Run a 'flow' through the handler

     *

     * @param NodeInterface $node

     *

     * @return LocalFile

     */

    public function flow(NodeInterface $node)

    {

        if (!($node instanceof LocalFile)) {

            throw new InvalidArgumentException("Node: $node should be an instance of LocalFile");

        }

        return $this->tail($node, $this->lines, $this->options);

    }

}