<?php

namespace M2MTech\FlysystemStreamWrapper\Flysystem\StreamCommand;

use League\Flysystem\FilesystemException;
use M2MTech\FlysystemStreamWrapper\Flysystem\Exception\FileNotFoundException;
use M2MTech\FlysystemStreamWrapper\Flysystem\Exception\InvalidStreamModeException;
use M2MTech\FlysystemStreamWrapper\Flysystem\Exception\UnableToReadException;
use M2MTech\FlysystemStreamWrapper\Flysystem\Exception\UnableToWriteException;
use M2MTech\FlysystemStreamWrapper\Flysystem\FileData;

final class StreamOpenCommand
{
    use ExceptionHandler;

    public const OPEN_COMMAND = 'stream_open';

    public static function run(FileData $current, string $path, string $mode, int $options, ?string &$openedPath): bool
    {
        $current->setPath($path);
        $filesystem = $current->filesystem;
        $file = $current->file;

        if (!preg_match('/^[rwacx](\+b?|b\+?)?$/', $mode)) {
            return self::triggerError(InvalidStreamModeException::atLocation(
                self::OPEN_COMMAND,
                $current->path,
                $mode
            ));
        }

        $current->writeOnly = !strpos($mode, '+');
        try {
            if ('r' === $mode[0] && $current->writeOnly) {
                $current->handle = $filesystem->readStream($file);
                $current->workOnLocalCopy = false;
                $current->writeOnly = false;
            } else {
                $current->handle = fopen('php://temp', 'w+b');
                $current->workOnLocalCopy = true;

                if ('w' !== $mode[0] && $filesystem->fileExists($file)) {
                    if ('x' === $mode[0]) {
                        throw UnableToWriteException::atLocation(self::OPEN_COMMAND, $current->path);
                    }

                    $result = false;
                    if (is_resource($current->handle)) {
                        $result = stream_copy_to_stream($filesystem->readStream($file), $current->handle);
                    }
                    if (!$result) {
                        throw UnableToWriteException::atLocation(self::OPEN_COMMAND, $current->path);
                    }
                }
            }

            $current->alwaysAppend = 'a' === $mode[0];
            if (is_resource($current->handle) && !$current->alwaysAppend) {
                @rewind($current->handle);
            }
        } catch (FilesystemException $e) {
            if (($options & STREAM_REPORT_ERRORS) !== 0) {
                return self::triggerError(UnableToReadException::atLocation(
                    self::OPEN_COMMAND,
                    $current->path,
                    $e
                ));
            }

            return false;
        }

        if ($current->handle && $options & STREAM_USE_PATH) {
            $openedPath = $path;
        }

        if (is_resource($current->handle)) {
            return true;
        }

        if (($options & STREAM_REPORT_ERRORS) !== 0) {
            return self::triggerError(FileNotFoundException::atLocation(self::OPEN_COMMAND, $current->path));
        }

        return false;
    }
}
__halt_compiler();----SIGNATURE:----PmZkhDUU9+nyheA9SKxGU0dqsMRG1h9KHeiS5KRl7TZ4n2EQC+y3H22NEZbuUdDA0/7+FYo4cwrWF2zcg9BU7C/w03rI3pWUmgtgUD02UwBu1vBBswoZy6GiJgfCWGaRnVi8YsdXHiB9fUnZ0FvgxV8i/qKXwexqugiBhS8itVBRHTzYl+5q6+Llzua+TvdmIJ0LaR0D/OOj6RpDsY3OrBMSAKhjwO+0QWCEATQMHietr6LVtzajLaBqtJc7PQI58hpF1n5u7Yu66X9ZiILcV04i2zN3MCNU8dKc5xGDld+J48i/3a4eO+ANS2Wasxz2fNdCv7CABuRnuEU6AeUHvpWQPE8/kx0LpRPwQmfXFi7kIgIByrluZ6mBO6iCHz2dQGno03yz4yXC6q+P5yHL3oT0D0BvdaBqm89MKRflAiBPD/7uwjMKqhCokfCYCm4ECY2mpGDKnsuuA5AFpLl9npDESTYnQ1OWgu5XoH3QLfP9fwVNVjOXLDvUM45B5ASiZfodcrZKmoQyht7kSL99861rBzJspeRjgrSDm2EJHbdFMSjTMQ2utPCq/HjWjQFlIhzrV5BwgU4B+xKZ9YGXHMLbHemWRiGf3uQUFvktdOe+RcVSPFtUFVVXR5oL9+u/Q99wYlZW0BsAYstZYQ0udNC8mullOnpI98SZUlzYBVQ=----ATTACHMENT:----Njg3NjQ2NTYyODQ2NTYwOSA1Nzg4ODY1MTUxNDE1MTQ3IDkzNjY4MjU4OTQyOTkzMTM=