Feature: Synchronise all packages command (#536)

xvilo · akondas · web-flow · commit 322570d68d05 · 2022-01-06T10:47:43.000+01:00
* Add the SynchronizeAllPackages Command

* Add tests

Co-authored-by: Arkadiusz Kondas &lt;arkadiusz.kondas@gmail.com&gt;
diff --git a/src/Command/SynchronizeAllPackagesCommand.php b/src/Command/SynchronizeAllPackagesCommand.php
@@ -0,0 +1,77 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Buddy\Repman\Command;
+
+use Buddy\Repman\Entity\Organization;
+use Buddy\Repman\Message\Organization\SynchronizePackage;
+use Buddy\Repman\Repository\OrganizationRepository;
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Input\InputArgument;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+use Symfony\Component\Messenger\MessageBusInterface;
+
+final class SynchronizeAllPackagesCommand extends Command
+{
+    protected static $defaultName = 'repman:package:synchronize-all';
+
+    private MessageBusInterface $bus;
+
+    private OrganizationRepository $organizations;
+
+    public function __construct(MessageBusInterface $bus, OrganizationRepository $organizations)
+    {
+        $this->bus = $bus;
+        $this->organizations = $organizations;
+
+        parent::__construct();
+    }
+
+    /**
+     * @return void
+     */
+    protected function configure()
+    {
+        $this
+            ->setDescription('Synchronize all packages')
+            ->addArgument('organization', InputArgument::OPTIONAL, 'Organization alias')
+        ;
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output)
+    {
+        $organizations = $this->getOrganizationsToSync($input->getArgument('organization'));
+        $output->writeln(sprintf('Synchronizing packages of %d organizations.', count($organizations)));
+
+        foreach ($organizations as $organization) {
+            $output->writeln(sprintf('Synchronizing packages for %s.', $organization->name()));
+
+            foreach ($organization->synchronizedPackages() as $package) {
+                $output->writeln(sprintf('- %s.', $package->name()));
+                $this->bus->dispatch(new SynchronizePackage($package->id()->toString()));
+            }
+        }
+
+        return 0;
+    }
+
+    /**
+     * @return Organization[]
+     */
+    protected function getOrganizationsToSync(?string $organizationAlias): array
+    {
+        if ($organizationAlias === null) {
+            return $this->organizations->findAll();
+        }
+
+        $organization = $this->organizations->findOneBy(['alias' => $organizationAlias]);
+
+        if (!$organization instanceof Organization) {
+            throw new \InvalidArgumentException(sprintf('Organization with alias %s not found.', $organizationAlias));
+        }
+
+        return [$organization];
+    }
+}
diff --git a/tests/Functional/Command/SynchronizeAllPackagesCommandTest.php b/tests/Functional/Command/SynchronizeAllPackagesCommandTest.php
@@ -0,0 +1,71 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Buddy\Repman\Tests\Functional\Command;
+
+use Buddy\Repman\Command\SynchronizeAllPackagesCommand;
+use Buddy\Repman\Message\Security\ScanPackage;
+use Buddy\Repman\Tests\Functional\FunctionalTestCase;
+use Symfony\Component\Console\Tester\CommandTester;
+use Symfony\Component\Messenger\Transport\InMemoryTransport;
+
+final class SynchronizeAllPackagesCommandTest extends FunctionalTestCase
+{
+    private string $buddyId;
+
+    protected function setUp(): void
+    {
+        parent::setUp();
+
+        $userId = $this->createAndLoginAdmin();
+        $this->buddyId = $this->fixtures->createOrganization('buddy', $userId);
+
+        $packageId = $this->fixtures->addPackage($this->buddyId, 'https://buddy.com');
+        $this->fixtures->syncPackageWithData($packageId, 'buddy-works/buddy', 'Test', '1.1.1', new \DateTimeImmutable());
+    }
+
+    public function testSynchronizeAllSuccess(): void
+    {
+        /** @var InMemoryTransport $transport */
+        $transport = $this->container()->get('messenger.transport.async');
+        $transport->reset();
+
+        $commandTester = new CommandTester($this->container()->get(SynchronizeAllPackagesCommand::class));
+        $result = $commandTester->execute([]);
+
+        self::assertCount(1, $transport->getSent());
+        self::assertInstanceOf(ScanPackage::class, $transport->getSent()[0]->getMessage());
+        self::assertEquals($result, 0);
+    }
+
+    public function testSynchronizeAllOrganizationSuccess(): void
+    {
+        $alias = 'buddy';
+        /** @var InMemoryTransport $transport */
+        $transport = $this->container()->get('messenger.transport.async');
+        $transport->reset();
+
+        $commandTester = new CommandTester($this->container()->get(SynchronizeAllPackagesCommand::class));
+        $result = $commandTester->execute(['organization' => $alias]);
+
+        self::assertCount(1, $transport->getSent());
+        self::assertInstanceOf(ScanPackage::class, $transport->getSent()[0]->getMessage());
+        self::assertEquals($result, 0);
+    }
+
+    public function testSynchronizeAllOrganizationFailure(): void
+    {
+        $alias = 'non-existing-alias';
+
+        $this->expectException(\InvalidArgumentException::class);
+        $this->expectExceptionMessage(sprintf('Organization with alias %s not found.', $alias));
+
+        /** @var InMemoryTransport $transport */
+        $transport = $this->container()->get('messenger.transport.async');
+        $transport->reset();
+
+        $commandTester = new CommandTester($this->container()->get(SynchronizeAllPackagesCommand::class));
+        $commandTester->execute(['organization' => $alias]);
+    }
+}
