From 6d790e0165d2e1c1fb1a1acc0d750ab1593b9724 Mon Sep 17 00:00:00 2001
From: Nicolas MELONI <nicolas.meloni@synolia.com>
Date: Tue, 26 Dec 2023 14:50:55 +0100
Subject: [PATCH] added missing batch assets command

---
 src/Command/BatchImportAssetsCommand.php | 48 ++++++++++++++++++++++++
 1 file changed, 48 insertions(+)
 create mode 100644 src/Command/BatchImportAssetsCommand.php

diff --git a/src/Command/BatchImportAssetsCommand.php b/src/Command/BatchImportAssetsCommand.php
new file mode 100644
index 00000000..db81e076
--- /dev/null
+++ b/src/Command/BatchImportAssetsCommand.php
@@ -0,0 +1,48 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Synolia\SyliusAkeneoPlugin\Command;
+
+use Psr\Log\LoggerInterface;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+use Synolia\SyliusAkeneoPlugin\Client\ClientFactoryInterface;
+use Synolia\SyliusAkeneoPlugin\Payload\Asset\AssetPayload;
+use Synolia\SyliusAkeneoPlugin\Task\Asset\BatchAssetTask;
+
+final class BatchImportAssetsCommand extends AbstractBatchCommand
+{
+    protected static $defaultDescription = 'Import batch assets ids from Akeneo PIM.';
+
+    /** @var string */
+    public static $defaultName = 'akeneo:batch:assets';
+
+    public function __construct(
+        private ClientFactoryInterface $clientFactory,
+        private LoggerInterface $logger,
+        private BatchAssetTask $batchAssetTask,
+    ) {
+        parent::__construct(self::$defaultName);
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    protected function execute(
+        InputInterface $input,
+        OutputInterface $output,
+    ) {
+        $ids = explode(',', $input->getArgument('ids'));
+
+        $this->logger->notice('Processing batch', ['from_id' => $ids[0], 'to_id' => $ids[\count($ids) - 1]]);
+        $this->logger->debug(self::$defaultName, ['batched_ids' => $ids]);
+
+        $batchPayload = new AssetPayload($this->clientFactory->createFromApiCredentials());
+        $batchPayload->setIds($ids);
+
+        $this->batchAssetTask->__invoke($batchPayload);
+
+        return 0;
+    }
+}