<?php

namespace App\Provider\Database;

use App\Entity\StopEntity;
use App\Entity\TrackStopEntity;
use App\Entity\TrackEntity;
use App\Entity\TripEntity;
use App\Entity\TripStopEntity;
use App\Model\Departure;
use App\Model\Line;
use App\Model\Stop;
use App\Model\Vehicle;
use App\Provider\ScheduleRepository;
use Carbon\Carbon;
use Tightenco\Collect\Support\Collection;
use function Kadet\Functional\ref;

class GenericScheduleRepository extends DatabaseRepository implements ScheduleRepository
{
    public function getDeparturesForStop(
        Stop $stop,
        Carbon $from,
        int $count = ScheduleRepository::DEFAULT_DEPARTURES_COUNT
    ): Collection {
        $query = $this->em
            ->createQueryBuilder()
            ->select('ts', 't')
            ->from(TripStopEntity::class, 'ts')
            ->join('ts.trip', 't')
            ->where('ts.departure >= :from')
            ->andWhere('ts.stop = :stop')
            ->orderBy('ts.departure', 'ASC')
            ->setMaxResults($count)
            ->getQuery();

        $schedule = collect($query->execute([
            'from' => $from,
            'stop' => $this->reference(StopEntity::class, $stop),
        ]));

        $this->em->createQueryBuilder()
            ->select('t', 's', 'st')
            ->from(TrackEntity::class, 't')
            ->join('t.stopsInTrack', 's')
            ->join('s.stop', 'st')
            ->where('t.id in (:tracks)')
            ->getQuery()
            ->execute([
                ':tracks' => $schedule->map(function (TripStopEntity $stop) {
                    return $stop->getTrip()->getTrack()->getId();
                })->all()
            ]);

        return $schedule->map(function (TripStopEntity $entity) use ($stop) {
            $trip = $entity->getTrip();
            $track = $trip->getTrack();
            $line = $track->getLine();
            /** @var StopEntity $last */
            $last = $entity->getTrip()->getTrack()->getStopsInTrack()->last()->getStop();

            return Departure::createFromArray([
                'key'       => sprintf('%s::%s', $this->id->of($entity->getTrip()), $entity->getDeparture()->format('H:i')),
                'scheduled' => $entity->getDeparture(),
                'stop'      => $stop,
                'display'   => $last->getName(),
                'line'      => $this->convert($line),
                'track'     => $this->convert($track),
                'trip'      => $this->convert($trip),
            ]);
        });
    }

    protected static function getHandlers()
    {
        return [];
    }
}