ScheduleAuthorizer.php

<?php


namespace Source\UseCases\Door\Access\Authorizers;

use Carbon\Carbon;
use Source\Entities\Door;
use Source\Entities\User;
use InvalidArgumentException;
use Source\Entities\Schedule;
use Source\Gateways\DoorUser\DoorUserRepository;
use Source\UseCases\Door\Access\AccessAuthorizer;
use Source\Gateways\GroupSchedule\GroupScheduleRepository;
use Source\Gateways\RecurrenceSet\RecurrenceSetRepository;

class ScheduleAuthorizer implements AccessAuthorizer
{
    /**
     * @var \Source\Gateways\RecurrenceSet\RecurrenceSetRepository
     */
    protected RecurrenceSetRepository $recurrenceSet;

    /**
     * @var \Source\Gateways\DoorUser\DoorUserRepository
     */
    protected DoorUserRepository $doorUsers;

    /**
     * @var \Source\Gateways\GroupSchedule\GroupScheduleRepository
     */
    protected GroupScheduleRepository $groupSchedule;

    protected int $allowedSchedule = 0;

    public function __construct(
        GroupScheduleRepository $groupSchedule,
        RecurrenceSetRepository $recurrenceSet,
        DoorUserRepository $doorUsers
    ) {
        $this->recurrenceSet = $recurrenceSet;
        $this->doorUsers = $doorUsers;
        $this->groupSchedule = $groupSchedule;
    }

    /**
     * @inheritDoc
     */
    public function check(?User $user, Carbon $date, Door $door, string $doorcode, ?string $commandString): int
    {
        if ($user) {
            $groups = $this->doorUsers->getDoorUserGroupIntersection($door->getId(), $user->getId());
            foreach ($groups as $group) {
                $schedules = $this->groupSchedule->getActiveForGroupAndDate(
                    $group->getId(),
                    $date,
                    Schedule::TYPE_USER_ACCESS
                );

                foreach ($schedules as $schedule) {
                    try {
                        $this->recurrenceSet->parse($schedule->getRset());
                    } catch (InvalidArgumentException $e) {
                        // Invalid recurrence set string, ignore it.
                        continue;
                    }

                    if ($this->recurrenceSet->occurrenceHappeningAtDate($date, $schedule->getDuration())) {
                        $this->allowedSchedule = $schedule->getId();
                        return self::ALLOW;
                    }
                }
            }
        }

        return self::CONTINUE;
    }

    /**
     * @inheritDoc
     */
    public function getReason(): string
    {
        // We only allow, can only be one reason.
        return 'Allowed by user access schedule: ' . $this->allowedSchedule;
    }
}