return $this->createEmptyFormResponse($e);
}
$canonical_url = $this->query->getUrl(static::URL);
if ($request->getServerParams()['REQUEST_URI'] !== $canonical_url) {
return new Response(
Http::PERMANENT_REDIRECT
, ['Location' => $canonical_url]
);
}
$this->cacheMiddleware->query = $this->query;
if ($this->query->station === null) {
return $this->createEmptyFormResponse(null);
}
$date = $this->query->date ?? Date::today();
if ($date->toDateTimeImmutable()->getTimestamp() < time() - 7 * 24 * 60 * 60) {
throw new HttpException('The timetable more than a week ago is no longer available.', Http::GONE);
}
$service_repository = ($this->serviceRepositoryFactory)($this->query->permanentOnly);
return ($this->viewResponseFactory)(
new ScheduleView(
$this->streamFactory
, $this->locationRepository->getAllStations()
, $date
, $this->query
, $this->getFixedLinks()
, $service_repository->getGeneratedDate()
, $this->config->siteName
, $this->getInnerView()
)
);
}
protected function getFixedLinks() : array {
$station = $this->query->station;
if (!$station instanceof Station) {
return [];
/**
* Handle a request and return a response.
*
* The application will first pass the request through the defined middlewares sequentially.
* The {@link run()} method is only called from the innermost middleware.
*
* @param ServerRequestInterface $request
* @return ResponseInterface
*/
public function handle(ServerRequestInterface $request) : ResponseInterface {
$handle = Closure::fromCallable([$this, 'run']);
return MiddlewareApplication::bindMultiple(
$this->getMiddlewares()
, new class($handle) implements RequestHandlerInterface {
public function __construct(callable $handle) {
$this->handle = $handle;
}
public function handle(ServerRequestInterface $request) : ResponseInterface {
return ($this->handle)($request);
}
/** @var callable */
private $handle;
}
)->handle($request);
}
/**
* Process the request after passed through the middlewares
*
* This the main controller. The request processed by the middlewares before it reaches this method,
* and the response is processed by the middlewares before it is send out.
*
* @param ServerRequestInterface $request
* @return ResponseInterface
*/
abstract protected function run(ServerRequestInterface $request) : ResponseInterface;
/**
<?php
declare(strict_types=1);
namespace Metroapps\NationalRailTimetable\Middlewares;
use DateTimeZone;
use Metroapps\NationalRailTimetable\Controllers\BoardQuery;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\MiddlewareInterface;
use Psr\Http\Server\RequestHandlerInterface;
use Safe\DateTimeImmutable as SafeDateTimeImmutable;
use Teapot\StatusCode\Http;
use function str_replace;
class CacheMiddleware implements MiddlewareInterface {
public ?BoardQuery $query = null;
public function process(ServerRequestInterface $request, RequestHandlerInterface $handler) : ResponseInterface {
return $this->addCacheHeader($handler->handle($request));
}
public function addCacheHeader(ResponseInterface $response) : ResponseInterface {
if ($this->query === null || $response->getStatusCode() !== Http::OK) {
return $response;
}
$response = $response->withAddedHeader('Cache-Control', 'public')->withAddedHeader('Cache-Control', 'max-age=7200');
return $this->query->station !== null && $this->query->date === null
? $response->withAddedHeader('Cache-Control', 'public')->withAddedHeader(
'Expires',
str_replace(
'+0000',
'GMT',
(new SafeDateTimeImmutable('tomorrow'))->setTimezone(new DateTimeZone('UTC'))->format('r')
)
)
: $response;
}
}
, function (RequestHandlerInterface $carry, MiddlewareInterface $middleware) : RequestHandlerInterface {
return new static($middleware, $carry);
}
, $application
);
}
/**
* Bind a middleware on top of an application
*
* @param MiddlewareInterface $middleware
* @param RequestHandlerInterface $application
*/
public final function __construct(MiddlewareInterface $middleware, RequestHandlerInterface $application) {
$this->middleware = $middleware;
$this->application = $application;
}
public function handle(ServerRequestInterface $request) : ResponseInterface {
return $this->middleware->process($request, $this->application);
}
/** @var MiddlewareInterface */
private $middleware;
/** @var RequestHandlerInterface */
private $application;
}
* @param ServerRequestInterface $request
* @return ResponseInterface
*/
public function handle(ServerRequestInterface $request) : ResponseInterface {
$handle = Closure::fromCallable([$this, 'run']);
return MiddlewareApplication::bindMultiple(
$this->getMiddlewares()
, new class($handle) implements RequestHandlerInterface {
public function __construct(callable $handle) {
$this->handle = $handle;
}
public function handle(ServerRequestInterface $request) : ResponseInterface {
return ($this->handle)($request);
}
/** @var callable */
private $handle;
}
)->handle($request);
}
/**
* Process the request after passed through the middlewares
*
* This the main controller. The request processed by the middlewares before it reaches this method,
* and the response is processed by the middlewares before it is send out.
*
* @param ServerRequestInterface $request
* @return ResponseInterface
*/
abstract protected function run(ServerRequestInterface $request) : ResponseInterface;
/**
* Get the middlewares for this application.
*
* The middlewares must be sorted from the outermost to the innermost order, i.e. the beginning middleware
* will process the initial request and create the final response.
*
* To disable middlewares of an existing application, override this method to return an empty array.
<?php
declare(strict_types=1);
use GuzzleHttp\Psr7\ServerRequest;
use Metroapps\NationalRailTimetable\Controllers\TimetableController;
use function Http\Response\send;
require_once __DIR__ . '/../initialise.php';
send(get_container()->get(TimetableController::class)->handle(ServerRequest::fromGlobals()));