<?php

/*
 * This file is part of the Maestro Project.
 * Copyright (C) Compos Juliot
 */

namespace App\Infrastructure\Repository;

use App\Domain\Adapter\WorkflowProjectOptionsRepositoryInterface;
use App\Domain\Entity\WorkflowProjectOptions;
use Doctrine\ORM\EntityManagerInterface;
use Psr\Container\ContainerInterface;

class WorkflowProjectOptionsRepository implements WorkflowProjectOptionsRepositoryInterface
{
    /** @var EntityManagerInterface */
    private $entityManager;

    /** @var ContainerInterface */
    private $container;

    public function __construct(
        ContainerInterface $container,
        EntityManagerInterface $entityManager
    ) {
        $this->entityManager = $entityManager;
        $this->container = $container;
    }

    public function createOptionWithoutFlush(EntityManagerInterface $entityManager, WorkflowProjectOptions $option)
    {
        $entityManager->persist($option);

        return $entityManager;
    }

    public function removeByExport(int $id)
    {
        $connection = $this->container->get('doctrine.dbal.projects_connection');

        $sql = '
        DELETE wpo FROM `export_workflow_options` as wpo
        INNER JOIN export_workflow AS wp ON wpo.workflowProject_id = wp.id
        WHERE wp.export_id = ' . $id;

        $stmt = $connection->prepare($sql);
        $stmt->execute();

        if ($stmt->rowCount() > 0) {
            return true;
        } else {
            return false;
        }
    }
}