Save local distributions to the database

Author: codedmonkey

src/Package/PackageDistributionResolver.php

@@ -5,7 +5,9 @@
 namespace CodedMonkey\Dirigent\Package;
 
 use CodedMonkey\Dirigent\Composer\ComposerClient;
+use CodedMonkey\Dirigent\Doctrine\Entity\Distribution;
 use CodedMonkey\Dirigent\Doctrine\Entity\Metadata;
+use CodedMonkey\Dirigent\Doctrine\Repository\DistributionRepository;
 use CodedMonkey\Dirigent\Message\ResolveDistribution;
 use Symfony\Component\DependencyInjection\Attribute\Autowire;
 use Symfony\Component\Filesystem\Filesystem;
@@ -20,6 +22,7 @@
     public function __construct(
         private MessageBusInterface $messenger,
         private ComposerClient $composer,
+        private DistributionRepository $distributionRepository,
         #[Autowire(param: 'dirigent.distributions.dev_versions')]
         private bool $includeDevVersions,
         #[Autowire(param: 'dirigent.storage.path')]
@@ -68,6 +71,14 @@ public function resolve(Metadata $metadata, string $type, bool $async): bool
             return false;
         }
 
+        $distribution = $this->distributionRepository->findOneBy(['metadata' => $metadata, 'type' => $type]);
+        if (null === $distribution) {
+            $distribution = new Distribution($metadata);
+            $distribution->setReference($reference);
+            $distribution->setType($type);
+            $distribution->setReleasedAt($metadata->getReleasedAt());
+        }
+
         $distUrl = $metadata->getDistUrl();
         $path = $this->path($packageName, $versionName, $reference, $type);
 
@@ -76,6 +87,8 @@ public function resolve(Metadata $metadata, string $type, bool $async): bool
         $httpDownloader = $this->composer->createHttpDownloader();
         $httpDownloader->copy($distUrl, $path);
 
+        $this->distributionRepository->save($distribution);
+
         return true;
     }
 }