<?php

namespace App\Monitor\Framework\Scheduler;

use App\Monitor\Action\Command\MonitorMovieCommand;
use App\Monitor\Action\Command\MonitorTvEpisodeCommand;
use App\Monitor\Action\Command\MonitorTvSeasonCommand;
use App\Monitor\Action\Command\MonitorTvShowCommand;
use App\Monitor\Framework\Repository\MonitorRepository;
use Psr\Log\LoggerInterface;
use Symfony\Component\Messenger\MessageBusInterface;
use Symfony\Component\Scheduler\Attribute\AsCronTask;

#[AsCronTask('* * * * *', schedule: 'monitor')]
class MonitorDispatcher
{
    public function __construct(
        private readonly LoggerInterface $logger,
        private readonly MonitorRepository $monitorRepository,
        private readonly MessageBusInterface $bus,
    ) {}

    public function __invoke() {
        $this->logger->info('[MonitorDispatcher] Executing MonitorDispatcher');

        $monitorHandlers = [
            'movie' => MonitorMovieCommand::class,
            'tvepisode' => MonitorTvEpisodeCommand::class,
            'tvseason' => MonitorTvSeasonCommand::class,
            'tvshows' => MonitorTvShowCommand::class,
        ];

        $monitors = $this->monitorRepository->findBy(['status' => ['New', 'Active']]);

        foreach ($monitors as $monitor) {
            $monitor->setStatus('In Progress');
            $this->monitorRepository->getEntityManager()->flush();

            $command = $monitorHandlers[$monitor->getMonitorType()];
            $this->logger->info('[MonitorDispatcher] Dispatching ' . $command . ' for ' . $monitor->getTitle());
            $this->bus->dispatch(new $command($monitor->getId()));
        }
    }
}