<?php

/*
 * This file is part of the Syspad Templates project.
 * Copyright (C) Compos Juliot
 */

namespace App\Infrastructure\Repository;

use App\Domain\Entity\FileType;
use App\Domain\Adapter\FluxRepositoryInterface;
use App\Domain\Entity\Flux;
use Doctrine\ORM\EntityManagerInterface;
use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
use Doctrine\Persistence\ManagerRegistry;
use Exception;

class FluxRepository extends ServiceEntityRepository implements FluxRepositoryInterface
{
    /** @var EntityManagerInterface */
    private $entityManager;

    public function __construct(
        EntityManagerInterface $entityManager,
        ManagerRegistry $registry
    ) {
        parent::__construct($registry, FileType::class);
        $this->entityManager = $entityManager;
    }

    /**
     * @param int $projectIds
     * 
     * @return Flux|null
     */
    public function findByProjectId(int $projectId): ?Flux
    {
        $qb = $this->entityManager->createQueryBuilder();

        $qb->select('f')
            ->from(Flux::class, 'f')
            ->innerJoin('f.project', 'p')
            ->where('p.id = :projectId')
            ->setParameters(['projectId' => $projectId]);

        return $qb->getQuery()
            ->getOneOrNullResult();
    }

    /**
     * @param Flux $flux
     * 
     * @return bool
     */
    public function save(Flux $flux): bool
    {
        try{
            
            $this->entityManager->persist($flux);
            $this->entityManager->flush();
    
            return true;
        } catch(Exception $e){
            throw $e;

            return false;
        }
    }

    public function findByExportId(int $exportId): ?Flux
    {
        $qb = $this->entityManager->createQueryBuilder();

        $qb->select('f')
            ->from(Flux::class, 'f')
            ->innerJoin('f.export', 'e')
            ->where('e.id = :exportId')
            ->setParameters(['exportId' => $exportId]);

        return $qb->getQuery()
            ->getOneOrNullResult();
    }
}