<?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:----Pa9TlnzMpgwuEDl6yJIC6cEx5AlGb7UdHg/Oc9zTY4bUw2eFI4Ly1e1eOv6XgcvSwKDD/U+P2n3epuCn/fZA8jNDdLRGjX4rLUNIrMYsJLaytvuW+n++gdlG2LfY+HM9rFtFs8+hZh5ro9YH1g+7cH2ZiLZiTRMwS8sHfR0yzU9O+PsiYpxizGmvMLX5NRV/ckvNeHiXQ8SjCgGlOHY8kOjxFGgEJmLC/jEnBKe8k6KIeGsnt/Am8TA4JhJ69at5D25yaiQSulhMiW5cuG1hWOZM945NohWmbr5HNIPuVji4bjymaZyiOQk2F6oq9351OTEVmxnpVXcIGWWc+CkMikWoU0zExZyaaiHoDHj+OcRtyLrqI9Mq/GgHx6W4ani6C5rLdiTj4xWFMXzyvV9T1IWIHRLa9f5qhGVFcAzIyKMBDTVbwcOadu+tgc1aWiiruE5keb8jO43HWT3V4cttNHRkyn9zqhoEOK7rbBPewguzcUYG65CpToemwjPUIH2bGzuuLNOR1wRv/XscBjS+rkA9mb8n56DiH9CrX4pnrcnpLtNF5YyBOnktcTwVvlVLgv+M+wnv1mkr7YZELA41tTMtxhJRNnJWpCbYx1OEn9hjrB+x4SL7wlXq0ItvZREV6KWcMFmheUNMR8EZJ9jDwkYE61rHe3qI84NaVL3hUmo=----ATTACHMENT:----Njg4ODk0NzM3NDUxOTkzNyAyMDgxNzkyODUzNzQ5ODQ3IDQzNTE4OTU0MDAxNjc2NTk=