AzuraCast/src/Controller/Api/Internal/SftpEventAction.php

<?php

declare(strict_types=1);

namespace App\Controller\Api\Internal;

use App\Entity\SftpUser;
use App\Entity\StorageLocation;
use App\Http\Response;
use App\Http\ServerRequest;
use App\Media\BatchUtilities;
use App\Message\AddNewMediaMessage;
use Doctrine\ORM\EntityManagerInterface;
use League\Flysystem\PathPrefixer;
use Psr\Http\Message\ResponseInterface;
use Psr\Log\LoggerInterface;
use Symfony\Component\Messenger\MessageBus;

final class SftpEventAction
{
    public function __construct(
        private readonly EntityManagerInterface $em,
        private readonly MessageBus $messageBus,
        private readonly LoggerInterface $logger,
        private readonly BatchUtilities $batchUtilities,
    ) {
    }

    public function __invoke(
        ServerRequest $request,
        Response $response
    ): ResponseInterface {
        $errorResponse = $response->withStatus(500)->withJson(['success' => false]);

        $parsedBody = $request->getParsedBody();

        $action = $parsedBody['action'] ?? null;
        $username = $parsedBody['username'] ?? null;
        $path = $parsedBody['path'] ?? null;
        $targetPath = $parsedBody['target_path'] ?? null;
        $sshCmd = $parsedBody['ssh_cmd'] ?? null;

        $this->logger->notice(
            'SFTP file event triggered',
            [
                'action' => $action,
                'username' => $username,
                'path' => $path,
                'targetPath' => $targetPath,
                'sshCmd' => $sshCmd,
            ]
        );

        // Determine which station the username belongs to.
        $sftpUser = $this->em->getRepository(SftpUser::class)->findOneBy(
            [
                'username' => $username,
            ]
        );

        if (!$sftpUser instanceof SftpUser) {
            $this->logger->error('SFTP Username not found.', ['username' => $username]);
            return $errorResponse;
        }

        $storageLocation = $sftpUser->getStation()->getMediaStorageLocation();

        if (!$storageLocation->isLocal()) {
            $this->logger->error(sprintf('Storage location "%s" is not local.', $storageLocation));
            return $errorResponse;
        }

        if (null === $path) {
            $this->logger->error('No path specified for action.');
            return $errorResponse;
        }

        try {
            match ($action) {
                'upload' => $this->handleNewUpload($storageLocation, $path),
                'pre-delete' => $this->handleDelete($storageLocation, $path),
                'rename' => $this->handleRename($storageLocation, $path, $targetPath),
                default => null,
            };

            return $response->withJson(['success' => true]);
        } catch (\Throwable $e) {
            $this->logger->error(
                sprintf('SFTP Event: %s', $e->getMessage()),
                [
                    'exception' => $e,
                ]
            );

            return $errorResponse;
        }
    }

    private function handleNewUpload(
        StorageLocation $storageLocation,
        string $path
    ): void {
        $pathPrefixer = new PathPrefixer($storageLocation->getPath(), DIRECTORY_SEPARATOR);
        $relativePath = $pathPrefixer->stripPrefix($path);

        $this->logger->notice(
            'Processing new SFTP upload.',
            [
                'storageLocation' => (string)$storageLocation,
                'path' => $relativePath,
            ]
        );

        $message = new AddNewMediaMessage();
        $message->storage_location_id = $storageLocation->getIdRequired();
        $message->path = $relativePath;

        $this->messageBus->dispatch($message);
    }

    private function handleDelete(
        StorageLocation $storageLocation,
        string $path
    ): void {
        $pathPrefixer = new PathPrefixer($storageLocation->getPath(), DIRECTORY_SEPARATOR);
        $relativePath = $pathPrefixer->stripPrefix($path);

        $this->logger->notice(
            'Processing SFTP file/folder deletion.',
            [
                'storageLocation' => (string)$storageLocation,
                'path' => $relativePath,
            ]
        );

        $directories = [];
        $files = [];

        if (is_dir($path)) {
            $directories[] = $relativePath;
        } else {
            $files[] = $relativePath;
        }

        $fs = $storageLocation->getFilesystem();

        $this->batchUtilities->handleDelete(
            $files,
            $directories,
            $storageLocation,
            $fs
        );

        $fs->delete($relativePath);
    }

    private function handleRename(
        StorageLocation $storageLocation,
        string $path,
        ?string $newPath
    ): void {
        if (null === $newPath) {
            throw new \LogicException('No new path specified for rename.');
        }

        $pathPrefixer = new PathPrefixer($storageLocation->getPath(), DIRECTORY_SEPARATOR);

        $from = $pathPrefixer->stripPrefix($path);
        $to = $pathPrefixer->stripPrefix($newPath);

        $this->logger->notice(
            'Processing SFTP file/folder rename.',
            [
                'storageLocation' => (string)$storageLocation,
                'from' => $from,
                'to' => $to,
            ]
        );

        $this->batchUtilities->handleRename(
            $from,
            $to,
            $storageLocation
        );
    }
}