Create distribution database entity

Author: codedmonkey

migrations/Version20260708083050.php

@@ -0,0 +1,54 @@
+<?php
+
+declare(strict_types=1);
+
+namespace DoctrineMigrations;
+
+use Doctrine\DBAL\Schema\Schema;
+use Doctrine\Migrations\AbstractMigration;
+
+final class Version20260708083050 extends AbstractMigration
+{
+    public function getDescription(): string
+    {
+        return 'Create distribution table';
+    }
+
+    public function up(Schema $schema): void
+    {
+        $this->addSql(<<<'SQL'
+            CREATE TABLE distribution (
+              id INT GENERATED BY DEFAULT AS IDENTITY NOT NULL,
+              type VARCHAR(255) NOT NULL,
+              source TEXT DEFAULT NULL,
+              resolved_at TIMESTAMP(0) WITHOUT TIME ZONE NOT NULL,
+              created_at TIMESTAMP(0) WITHOUT TIME ZONE NOT NULL,
+              last_modified_at TIMESTAMP(0) WITHOUT TIME ZONE DEFAULT NULL,
+              metadata_id INT NOT NULL,
+              PRIMARY KEY (id)
+            )
+        SQL);
+        $this->addSql(<<<'SQL'
+            CREATE INDEX IDX_A4483781DC9EE959 ON distribution (metadata_id)
+        SQL);
+        $this->addSql(<<<'SQL'
+            CREATE UNIQUE INDEX UNIQ_A4483781DC9EE959AEA349138CDE5729 ON distribution (metadata_id, type)
+        SQL);
+        $this->addSql(<<<'SQL'
+            ALTER TABLE
+              distribution
+            ADD
+              CONSTRAINT FK_A4483781DC9EE959 FOREIGN KEY (metadata_id) REFERENCES metadata (id) NOT DEFERRABLE
+        SQL);
+    }
+
+    public function down(Schema $schema): void
+    {
+        $this->addSql(<<<'SQL'
+            ALTER TABLE distribution DROP CONSTRAINT FK_A4483781DC9EE959
+        SQL);
+        $this->addSql(<<<'SQL'
+            DROP TABLE distribution
+        SQL);
+    }
+}

src/Doctrine/Entity/Distribution.php

@@ -0,0 +1,77 @@
+<?php
+
+declare(strict_types=1);
+
+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)]
+#[ORM\ChangeTrackingPolicy('DEFERRED_EXPLICIT')]
+#[ORM\UniqueConstraint(columns: ['metadata_id', 'type'])]
+class Distribution extends TrackedEntity
+{
+    #[ORM\Column, ORM\GeneratedValue, ORM\Id]
+    private ?int $id = null;
+
+    #[ORM\Column]
+    private ?string $type;
+
+    /**
+     * Source URL.
+     *
+     * Contains the source URL if the distribution is mirrored.
+     */
+    #[ORM\Column(type: Types::TEXT, nullable: true)]
+    private ?string $source = null;
+
+    #[ORM\Column]
+    private \DateTimeImmutable $resolvedAt;
+
+    #[ORM\ManyToOne(inversedBy: 'distributions')]
+    #[ORM\JoinColumn(nullable: false)]
+    private Metadata $metadata;
+
+    public function __construct(Metadata $metadata, string $type)
+    {
+        $this->metadata = $metadata;
+        $this->type = $type;
+    }
+
+    public function getId(): ?int
+    {
+        return $this->id;
+    }
+
+    public function getType(): string
+    {
+        return $this->type;
+    }
+
+    public function getSource(): ?string
+    {
+        return $this->source;
+    }
+
+    public function setSource(?string $source): void
+    {
+        $this->source = $source;
+    }
+
+    public function getResolvedAt(): \DateTimeImmutable
+    {
+        return $this->resolvedAt;
+    }
+
+    public function setResolvedAt(): void
+    {
+        $this->resolvedAt = new \DateTimeImmutable();
+    }
+
+    public function getMetadata(): Metadata
+    {
+        return $this->metadata;
+    }
+}

src/Doctrine/Entity/Metadata.php

@@ -119,6 +119,9 @@ class Metadata extends TrackedEntity implements \Stringable
     #[ORM\JoinColumn(nullable: false, onDelete: 'CASCADE')]
     private MetadataFiles $files;
 
+    #[ORM\OneToMany(targetEntity: Distribution::class, mappedBy: 'metadata')]
+    private Collection $distributions;
+
     /**
      * @var Collection<int, MetadataRequireLink>&Selectable
      */
@@ -167,6 +170,7 @@ public function __construct(Version $version)
         $this->package = $version->getPackage();
         $this->files = new MetadataFiles($this);
 
+        $this->distributions = new ArrayCollection();
         $this->requireLinks = new ArrayCollection();
         $this->devRequireLinks = new ArrayCollection();
         $this->conflictLinks = new ArrayCollection();
@@ -415,6 +419,14 @@ public function getPackage(): Package
         return $this->package;
     }
 
+    /**
+     * @return Collection<int, Distribution>
+     */
+    public function getDistributions(): Collection
+    {
+        return $this->distributions;
+    }
+
     /**
      * @return Collection<int, MetadataRequireLink>
      */

src/Doctrine/Repository/DistributionRepository.php

@@ -0,0 +1,43 @@
+<?php
+
+declare(strict_types=1);
+
+namespace CodedMonkey\Dirigent\Doctrine\Repository;
+
+use CodedMonkey\Dirigent\Doctrine\Entity\Distribution;
+use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
+use Doctrine\Persistence\ManagerRegistry;
+
+/**
+ * @extends ServiceEntityRepository<Distribution>
+ *
+ * @method Distribution|null find($id, $lockMode = null, $lockVersion = null)
+ * @method Distribution[]    findAll()
+ * @method Distribution[]    findBy(array $criteria, array $orderBy = null, $limit = null, $offset = null)
+ * @method Distribution|null findOneBy(array $criteria, array $orderBy = null)
+ */
+class DistributionRepository extends ServiceEntityRepository
+{
+    public function __construct(ManagerRegistry $registry)
+    {
+        parent::__construct($registry, Distribution::class);
+    }
+
+    public function save(Distribution $entity, bool $flush = false): void
+    {
+        $this->getEntityManager()->persist($entity);
+
+        if ($flush) {
+            $this->getEntityManager()->flush();
+        }
+    }
+
+    public function remove(Distribution $entity, bool $flush = false): void
+    {
+        $this->getEntityManager()->remove($entity);
+
+        if ($flush) {
+            $this->getEntityManager()->flush();
+        }
+    }
+}