SuperSeller3000/src/Infrastructure/Persistence/Repository/DoctrineArticleRepository.php

<?php

declare(strict_types=1);

namespace App\Infrastructure\Persistence\Repository;

use App\Domain\Article\Article;
use App\Domain\Article\ArticleStatus;
use App\Domain\Article\Repository\ArticleRepositoryInterface;
use Doctrine\ORM\EntityManagerInterface;
use Symfony\Component\Uid\Uuid;

final class DoctrineArticleRepository implements ArticleRepositoryInterface
{
    public function __construct(private readonly EntityManagerInterface $em)
    {
    }

    public function findById(Uuid $id): ?Article
    {
        return $this->em->find(Article::class, $id);
    }

    public function findBySku(string $sku): ?Article
    {
        return $this->em->getRepository(Article::class)->findOneBy(['sku' => $sku]);
    }

    public function findByInventoryNumber(string $inventoryNumber): ?Article
    {
        return $this->em->getRepository(Article::class)->findOneBy(['inventoryNumber' => $inventoryNumber]);
    }

    /** @return list<Article> */
    public function findByStatus(ArticleStatus $status): array
    {
        /** @var list<Article> */
        return $this->em->getRepository(Article::class)->findBy(['status' => $status]);
    }

    public function decrementStockAtomic(Uuid $articleId): bool
    {
        $affected = $this->em->getConnection()->executeStatement(
            'UPDATE app.articles SET stock = stock - 1 WHERE id = :id AND stock > 0',
            ['id' => $articleId->toRfc4122()],
        );

        if ($affected > 0) {
            $article = $this->em->find(Article::class, $articleId);
            if (null !== $article) {
                $this->em->refresh($article);
            }
        }

        return $affected > 0;
    }

    public function save(Article $article): void
    {
        $this->em->persist($article);
        $this->em->flush();
    }

    public function remove(Article $article): void
    {
        $this->em->remove($article);
        $this->em->flush();
    }
}