<?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:----P45MEjnvcUSbIAtMHbyKPTn7OBn/AxNLlwNzccGR1f9+4o+n/+wfM9hKCyPHHZ5GYX+DM9uPEMd9URFdClHokX1mmw9J3WQkOQCskcGkxSYGF5sBvWB3zn5STT64wtLq5UbUc3n45yPkeM87nFoRAhXss97ZBclwsVS+fSvZuWaDoiGpL1ph5mEixoUL4fY8BfTB2eejirl0wAOkFeNR+l37oxnSwsN2SvxlJmZ134Kbvrkkxboi8xcG/KuU/c5InrVFMTnpt6eFpC5KzTfRWf8jSOdVWWmAivwkleijIA+c/5E9SLs6p8Ap+AJYfSCBekuomNs8nK9PwUi6H8KZhFi4qmY2wbkeBDG+u6IKi9eL7AedrMkQ2iqUyvgA4pJs/Ox4vheznfB4mjgf4eKZSy5XEgF06E1cDwCUXSPtmIRYCyQUbTxVXSvDA46gc0JzsrdcEuBjzjFG/J0Aea7lXqYcQN16iuIAz4+/xqCvL+aGhRalNka98DXJfBrtllL/qlZnlvs1zVCWCA1BW1xyoaEmNTwRgUPzqg7z1OMKVsz17X3Z3Z2+7MkfoSnhBa5aHk4wckx3H3QgJwq4d8L+qjOpjZBeWwxE5IiAitBScO7Gqya1Jb3umj4qeQBrVr339q9HkmkBRZo+cnkhxp1v3RDtxOP7BW8D0MF4kzHGbWY=----ATTACHMENT:----Njg1ODk5NTk5MTUzNjEzNCA1NzIwMzExODQ1ODA4MTc2IDg2MDQzMTkzMDI0NDQ0ODU=