HttpProcessExecuteValueResolver.php

<?php

declare(strict_types=1);

/*
 * This file is part of the CleverAge/UiProcessBundle package.
 *
 * Copyright (c) Clever-Age
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace CleverAge\UiProcessBundle\Http\ValueResolver;

use CleverAge\UiProcessBundle\Http\Model\HttpProcessExecution;
use CleverAge\UiProcessBundle\Manager\UploadedFileManager;
use Symfony\Component\Filesystem\Filesystem;
use Symfony\Component\HttpFoundation\File\UploadedFile;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpKernel\Attribute\AsTargetedValueResolver;
use Symfony\Component\HttpKernel\Controller\ValueResolverInterface;
use Symfony\Component\HttpKernel\ControllerMetadata\ArgumentMetadata;
use Symfony\Component\Serializer\SerializerInterface;

/**
 * @internal
 */
#[AsTargetedValueResolver('http_process_execution')]
readonly class HttpProcessExecuteValueResolver implements ValueResolverInterface
{
    /**
     * Request attribute: path of the uploaded input file written by the resolver, to be deleted once the process has
     * been executed or when the request is rejected (an input given by its path is never deleted).
     */
    public const UPLOADED_INPUT_ATTRIBUTE = '_cleverage_ui_process_uploaded_input';

    public function __construct(private string $storageDir, private SerializerInterface $serializer)
    {
    }

    /**
     * @return iterable<HttpProcessExecution>
     */
    public function resolve(Request $request, ArgumentMetadata $argument): iterable
    {
        try {
            $hasRequestData = $request->request->count() > 0 || $request->files->count() > 0;
            // The query string is read with form data, and also without body
            $hasQueryOnly = !$hasRequestData && '' === $request->getContent() && $request->query->count() > 0;

            if (!$hasRequestData && !$hasQueryOnly) {
                $content = $request->getContent();
                if (empty($content)) {
                    return [new HttpProcessExecution()];
                }

                $httpProcessExecution = $this->serializer->deserialize(
                    $content,
                    HttpProcessExecution::class,
                    'json'
                );
            } else {
                $input = $request->request->get('input') ?? $request->query->get('input');

                $input ??= $request->files->get('input');

                if ($input instanceof UploadedFile) {
                    $prefix = date('YmdHis').'_'.uniqid().'_';
                    // A client file name too long for the file system made the writing fail
                    $uploadFileName = $this->storageDir.\DIRECTORY_SEPARATOR.$prefix.UploadedFileManager::getSafeName(
                        $input,
                        UploadedFileManager::MAX_FILENAME_LENGTH - \strlen($prefix)
                    );
                    (new Filesystem())->dumpFile($uploadFileName, $input->getContent());
                    $request->attributes->set(self::UPLOADED_INPUT_ATTRIBUTE, $uploadFileName);
                    $input = $uploadFileName;
                }

                $code = $request->request->get('code') ?? $request->query->get('code');
                $context = $request->request->all('context');
                if ([] === $context) {
                    $context = $request->query->all('context');
                }

                $queue = $request->request->has('queue')
                    ? $request->request->getBoolean('queue')
                    : $request->query->getBoolean('queue', true);

                /** @var string|null $input */
                $httpProcessExecution = new HttpProcessExecution(
                    (string) $code,
                    $input,
                    $context,
                    $queue
                );
            }

            return [$httpProcessExecution];
        } catch (\Throwable) {
            return [new HttpProcessExecution()];
        }
    }
}