temp

Author: codedmonkey

src/Controller/ApiController.php

@@ -81,7 +81,9 @@ public function packageMetadata(string $packageName): Response
             throw $this->createNotFoundException();
         }
 
-        $this->messenger->dispatch(new UpdatePackage($package->getId()));
+        if ($this->getParameter('dirigent.packages.dynamic_updates')) {
+            $this->messenger->dispatch(new UpdatePackage($package->getId()));
+        }
 
         if (!$this->providerManager->exists($packageName)) {
             throw $this->createNotFoundException();

src/Doctrine/Entity/Distribution.php

@@ -3,6 +3,7 @@
 namespace CodedMonkey\Dirigent\Doctrine\Entity;
 
 use CodedMonkey\Dirigent\Doctrine\Repository\DistributionRepository;
+use Doctrine\DBAL\Types\Types;
 use Doctrine\ORM\Mapping as ORM;
 
 #[ORM\Entity(repositoryClass: DistributionRepository::class)]
@@ -18,6 +19,12 @@ class Distribution
     #[ORM\Column]
     private ?string $reference = null;
 
+    #[ORM\Column]
+    private ?string $type = null;
+
+    #[ORM\Column(Types::TEXT)]
+    private ?string $source = null;
+
     public function getId(): ?int
     {
         return $this->id;
@@ -42,4 +49,14 @@ public function setReference(string $reference): void
     {
         $this->reference = $reference;
     }
+
+    public function getType(): ?string
+    {
+        return $this->type;
+    }
+
+    public function setType(string $type): void
+    {
+        $this->type = $type;
+    }
 }

src/Doctrine/Entity/Version.php

@@ -114,6 +114,9 @@ class Version
     #[ORM\ManyToOne(targetEntity: Package::class, inversedBy: 'versions')]
     private ?Package $package = null;
 
+    #[ORM\OneToMany(mappedBy: 'version')]
+    private Collection $distributions;
+
     #[ORM\OneToOne(mappedBy: 'version', cascade: ['persist', 'detach', 'remove'])]
     private VersionInstallations $installations;
 

src/Package/PackageDistributionResolver.php

@@ -42,11 +42,28 @@ public function __construct(
         $this->distributionStoragePath = "$storagePath/distribution";
     }
 
+    public function isAvailable(): bool
+    {
+
+    }
+
+    /**
+     * Check if the distribution exists on the filesystem, circumventing the database.
+     */
     public function exists(string $packageName, string $packageVersion, ?string $reference, ?string $type): bool
     {
         return null !== $reference && null !== $type && $this->filesystem->exists($this->path($packageName, $packageVersion, $reference, $type));
     }
 
+    public function findEntity(Version $version, string $reference, string $type): ?Distribution
+    {
+        return $this->distributionRepository->findOneBy([
+            'version' => $version,
+            'reference' => $reference,
+            'type' => $type,
+        ]);
+    }
+
     public function path(string $packageName, string $packageVersion, string $reference, string $type): string
     {
         return "$this->distributionStoragePath/$packageName/$packageVersion-$reference.$type";
@@ -66,6 +83,14 @@ public function resolve(Version $version, ?string $reference, ?string $type, boo
             return false;
         }
 
+        $distribution = $this->findEntity($version, $reference, $type);
+        if (!$distribution) {
+            $distribution = new Distribution();
+            $distribution->setVersion($version);
+            $distribution->setReference($reference);
+            $distribution->setType($type);
+        }
+
         if ($async) {
             // Resolve the distribution asynchronously so it's available in the future now that we know it was requested
             $message = Envelope::wrap(new ResolveDistribution($version->getId(), $reference, $type))
@@ -120,6 +145,7 @@ private function build(Version $version, ?string $reference, ?string $type): boo
         $distribution = new Distribution();
         $distribution->setVersion($version);
         $distribution->setReference($reference);
+        $distribution->setType($type);
 
         $this->distributionRepository->save($distribution, flush: true);
 
@@ -150,6 +176,7 @@ private function mirror(Version $version, ?string $reference, ?string $type): bo
         $distribution = new Distribution();
         $distribution->setVersion($version);
         $distribution->setReference($reference);
+        $distribution->setType($type);
 
         $this->distributionRepository->save($distribution, flush: true);