Covivo/mobicoop

<?php

/**
 * Copyright (c) 2022, MOBICOOP. All rights reserved.
 * This project is dual licensed under AGPL and proprietary licence.
 ***************************
 *    This program is free software: you can redistribute it and/or modify
 *    it under the terms of the GNU Affero General Public License as
 *    published by the Free Software Foundation, either version 3 of the
 *    License, or (at your option) any later version.
 *
 *    This program is distributed in the hope that it will be useful,
 *    but WITHOUT ANY WARRANTY; without even the implied warranty of
 *    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *    GNU Affero General Public License for more details.
 *
 *    You should have received a copy of the GNU Affero General Public License
 *    along with this program.  If not, see <gnu.org/licenses>.
 ***************************
 *    Licence MOBICOOP described in the file
 *    LICENSE
 */

namespace App\Community\Admin\Service;

use App\Community\Admin\Repository\CommunitySecurityRepository;
use App\Community\Entity\Community;
use App\Community\Entity\CommunitySecurity;
use Doctrine\ORM\EntityManagerInterface;
use LogicException;
use Symfony\Component\HttpFoundation\File\File;

/**
 * Community Security manager.
 *
 * This service contains methods related to community security file management.
 *
 * @author Maxime Bardot <maxime.bardot@mobicoop.org>
 */
class CommunitySecurityManager
{
    public const MIME_TYPES = [
        'text/plain',
        'text/csv',
    ];
    private $communityManager;
    private $entityManager;
    private $communitySecurityRepository;

    public function __construct(
        CommunityManager $communityManager,
        EntityManagerInterface $entityManager,
        CommunitySecurityRepository $communitySecurityRepository
    ) {
        $this->communityManager = $communityManager;
        $this->entityManager = $entityManager;
        $this->communitySecurityRepository = $communitySecurityRepository;
    }

    private function __validateSecurityFile(File $file)
    {
        $openedFile = fopen($file, 'r');

        if (!in_array($file->getMimeType(), self::MIME_TYPES)) {
            throw new LogicException('Incorrect MIME type');
        }

        $numLine = 1;
        while (!feof($openedFile)) {
            $line = fgetcsv($openedFile, 0, ';');
            if ($line) {
                $this->__validate_line($line, $numLine);
            }
            ++$numLine;
        }
    }

    private function __validate_line(array $line, int $numLine)
    {
        if (2 != count($line)) {
            throw new LogicException('Incorrect number of column line '.$numLine.' (2 expected)');
        }
        if (0 == strlen(trim($line[0])) || '' == trim($line[0])) {
            throw new LogicException('First parameter cannot be empty line '.$numLine);
        }
        if (0 == strlen(trim($line[1])) || '' == trim($line[1])) {
            throw new LogicException('Second parameter cannot be empty line '.$numLine);
        }
    }

    private function __removeOldCommunitySecurities(Community $community)
    {
        $communitySecurities = $this->getCommunitySecurities($community);
        foreach ($communitySecurities as $communitySecurity) {
            $this->entityManager->remove($communitySecurity);
        }
        $this->entityManager->flush();
    }

    public function createSecurity(File $file, int $communityId): CommunitySecurity
    {
        if ($community = $this->communityManager->getCommunity($communityId)) {
            $this->__validateSecurityFile($file);

            $this->__removeOldCommunitySecurities($community);

            $communitySecurity = new CommunitySecurity();
            $communitySecurity->setFile($file);
            $communitySecurity->setFileName(time().'-'.$communityId);
            $communitySecurity->setCommunity($community);
            $this->entityManager->persist($communitySecurity);
            $this->entityManager->flush();

            return $communitySecurity;
        }

        throw new LogicException('Community '.$communityId.' not found');
    }

    public function getCommunitySecurities(Community $community): array
    {
        return $this->communitySecurityRepository->findBy(['community' => $community]);
    }
}