<?php

/**
 * @copyright © Melograno Ventures. All rights reserved.
 * @licence   See LICENCE.md for license details.
 */

namespace AmeliaBooking\Application\Commands\Calendar;

use AmeliaBooking\Application\Commands\CommandHandler;
use AmeliaBooking\Application\Commands\CommandResult;
use AmeliaBooking\Application\Common\Exceptions\AccessDeniedException;
use AmeliaBooking\Domain\Common\Exceptions\InvalidArgumentException;
use AmeliaBooking\Domain\Entity\Entities;
use AmeliaBooking\Domain\Entity\Schedule\BlockTime;
use AmeliaBooking\Domain\Entity\User\AbstractUser;
use AmeliaBooking\Domain\Factory\Schedule\BlockTimeFactory;
use AmeliaBooking\Domain\Services\DateTime\DateTimeService;
use AmeliaBooking\Infrastructure\Common\Exceptions\QueryExecutionException;
use AmeliaBooking\Infrastructure\Repository\Schedule\DayOffRepository;
use AmeliaVendor\Psr\Container\ContainerExceptionInterface;
use Exception;

class ManageCalendarBlockTimeCommandHandler extends CommandHandler
{
    /**
     * @var array
     */
    public $mandatoryFields = [
        'name',
        'startDateTime',
        'endDateTime',
    ];

    /**
     * @param ManageCalendarBlockTimeCommand $command
     * @return CommandResult
     * @throws AccessDeniedException
     * @throws ContainerExceptionInterface
     * @throws InvalidArgumentException
     * @throws QueryExecutionException
     */
    public function handle(ManageCalendarBlockTimeCommand $command): CommandResult
    {
        if (!$command->getPermissionService()->currentUserCanWrite(Entities::EMPLOYEES)) {
            throw new AccessDeniedException('You are not allowed to delete block time');
        }

        $this->checkMandatoryFields($command);

        $result = new CommandResult();
        $fields = $command->getFields();

        /** @var DayOffRepository $dayOffRepository */
        $dayOffRepository = $this->container->get('domain.schedule.dayOff.repository');

        $blockTimeId = !empty($fields['id']) ? $fields['id'] : null;
        $isUpdate = $blockTimeId !== null;
        $employeeIds = !empty($fields['employeeIds']) ? $fields['employeeIds'] : [null];

        /** @var AbstractUser $currentUser */
        $currentUser = $this->container->get('logged.in.user');

        if ($currentUser && $currentUser->getType() === Entities::PROVIDER) {
            $providerId = $currentUser->getId()->getValue();

            if ($isUpdate) {
                $blockTime = $dayOffRepository->getBlockTimeById($blockTimeId);
                if ($blockTime->getUserId() === null || (int)$blockTime->getUserId()->getValue() !== (int)$providerId) {
                    throw new AccessDeniedException('You are not allowed to manage this block time.');
                }
            }

            foreach ($employeeIds as $employeeId) {
                if ($employeeId === null || (int)$employeeId !== (int)$providerId) {
                    throw new AccessDeniedException('You are not allowed to manage this block time.');
                }
            }
            $employeeIds = [$providerId];
        }

        $dayOffRepository->beginTransaction();

        try {
            foreach ($employeeIds as $employeeId) {
                $blockTime = $this->createBlockTime($fields, $blockTimeId, $employeeId);

                if ($isUpdate) {
                    $dayOffRepository->update($blockTime, $blockTimeId);
                } else {
                    $dayOffRepository->add($blockTime, $employeeId);
                }
            }

            $dayOffRepository->commit();
        } catch (Exception $e) {
            $dayOffRepository->rollback();
            throw $e;
        }

        $result->setResult(CommandResult::RESULT_SUCCESS);
        $result->setMessage('Successfully blocked.');
        $result->setData([]);

        return $result;
    }

    private function createBlockTime(array $fields, ?int $blockTimeId, ?int $employeeId): BlockTime
    {
        return BlockTimeFactory::create([
            'id'        => $blockTimeId,
            'name'      => $fields['name'],
            'userId'    => $employeeId,
            'startDate' => DateTimeService::getCustomDateTimeObjectInUtc($fields['startDateTime'])->format('Y-m-d H:i:s'),
            'endDate'   => DateTimeService::getCustomDateTimeObjectInUtc($fields['endDateTime'])->format('Y-m-d H:i:s'),
        ]);
    }
}