Add a new command for uploading files (dbp:relay:cabinet:upload-file)

src/Command/UploadFileCommand.php

@@ -0,0 +1,73 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Dbp\Relay\CabinetBundle\Command;
+
+use Dbp\Relay\BlobLibrary\Api\BlobApiError;
+use Dbp\Relay\CabinetBundle\Service\BlobService;
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Input\InputArgument;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Input\InputOption;
+use Symfony\Component\Console\Output\OutputInterface;
+use Symfony\Component\Filesystem\Filesystem;
+
+class UploadFileCommand extends Command
+{
+    private BlobService $blobService;
+
+    public function __construct(BlobService $blobService)
+    {
+        parent::__construct();
+
+        $this->blobService = $blobService;
+    }
+
+    protected function configure(): void
+    {
+        $this->setName('dbp:relay:cabinet:upload-file');
+        $this->setDescription('Upload a file to the cabinet blob bucket');
+
+        $this->addArgument('filepath', InputArgument::REQUIRED, 'The path to the file to upload');
+        $this->addOption('type', 't', InputOption::VALUE_OPTIONAL, 'The type of the file');
+        $this->addOption('metadata', 'm', InputOption::VALUE_OPTIONAL, 'The metadata of the file');
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output): int
+    {
+        $filepath = $input->getArgument('filepath');
+        $type = $input->getOption('type');
+        $metadata = $input->getOption('metadata');
+
+        $filesystem = new Filesystem();
+
+        if (!$filesystem->exists($filepath)) {
+            $output->writeln("<error>File not found: $filepath</error>");
+
+            return Command::FAILURE;
+        }
+
+        $filename = basename($filepath);
+        $payload = file_get_contents($filepath);
+
+        if ($payload === false) {
+            $output->writeln("<error>Unable to read file: $filepath</error>");
+
+            return Command::FAILURE;
+        }
+
+        try {
+            $fileId = $this->blobService->uploadFile($filename, $payload, $type, $metadata);
+            $output->writeln("<info>File uploaded successfully: $fileId</info>");
+
+            return Command::SUCCESS;
+        } catch (BlobApiError $e) {
+            $output->writeln('<error>Error uploading file: '.$e->getMessage().' </error>');
+            $output->writeln(print_r($e->getErrorId(), true));
+            $output->writeln(print_r($e->getErrorDetails(), true));
+
+            return Command::FAILURE;
+        }
+    }
+}

src/Resources/config/services.yaml

@@ -44,6 +44,10 @@ services:
     autowire: true
     autoconfigure: true
 
+  Dbp\Relay\CabinetBundle\Command\UploadFileCommand:
+    autowire: true
+    autoconfigure: true
+
   Dbp\Relay\CabinetBundle\Authorization\AuthorizationService:
     autowire: true
     autoconfigure: true

src/Service/BlobService.php

@@ -27,14 +27,28 @@ public function __construct(AuthorizationService $auth, ConfigurationService $co
         $this->config = $config;
     }
 
-    public function checkConnection(): void
+    private function getInternalBlobApi(): BlobApi
     {
         $config = $this->config;
         $blobApi = new BlobApi($config->getBlobApiUrlInternal(), $config->getBlobBucketId(), $config->getBlobBucketKey());
         $blobApi->setOAuth2Token($config->getBlobIdpUrl(), $config->getBlobIdpClientId(), $config->getBlobIdpClientSecret());
+
+        return $blobApi;
+    }
+
+    public function checkConnection(): void
+    {
+        $blobApi = $this->getInternalBlobApi();
         $blobApi->getFileDataByPrefix(Uuid::v4()->toRfc4122(), 0);
     }
 
+    public function uploadFile(string $filename, string $payload, ?string $type = null, ?string $metadata = null): string
+    {
+        $blobApi = $this->getInternalBlobApi();
+
+        return $blobApi->uploadFile($this->config->getBlobBucketPrefix(), $filename, $payload, $metadata ?? '', $type ?? '');
+    }
+
     public function getSignatureForGivenRequest(Request $request): Response
     {
         if (!$this->auth->isAuthenticated()) {

src/Service/ConfigurationService.php

@@ -57,4 +57,9 @@ public function getBlobBucketKey(): string
     {
         return $this->config['blob']['bucket_key'];
     }
+
+    public function getBlobBucketPrefix(): string
+    {
+        return 'document-';
+    }
 }