JDesrosiers\Resourceful\Controller\PutResourceController

Complexity

Total Complexity

10

Size/Duplication

Total Lines	42
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	__invoke()	0	18	5
A	validate()	0	11	4

<?php

namespace JDesrosiers\Resourceful\Controller;

use Doctrine\Common\Cache\Cache;
use JDesrosiers\Resourceful\Resourceful;
use Symfony\Component\HttpFoundation\JsonResponse;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\HttpKernel\Exception\BadRequestHttpException;
use Symfony\Component\HttpKernel\Exception\ServiceUnavailableHttpException;

class PutResourceController
{
    private $service;
    private $schema;

    public function __construct(Cache $service, $schema)
    {
        $this->service = $service;
        $this->schema = $schema;
    }

    public function __invoke(Resourceful $app, Request $request, $id)
    {
        $requestJson = $request->getContent() ?: "{}";
        $data = json_decode($requestJson);
        if (json_last_error() !== JSON_ERROR_NONE) {
            throw new BadRequestHttpException("Invalid JSON: " . json_last_error_msg());
        }

        $this->validate($app, $id, $data);

        $isCreated = !$this->service->contains($request->getRequestUri());
        if ($this->service->save($request->getRequestUri(), $data) === false) {
            throw new ServiceUnavailableHttpException(null, "Failed to save resource");
        }

        $response = JsonResponse::create($data, $isCreated ? Response::HTTP_CREATED : Response::HTTP_OK);
        return $app["allow"]($request, $response, $app);
    }

    private function validate(Resourceful $app, $id, $data)
    {
        if (!property_exists($data, "id") || $id !== $data->id) {
            throw new BadRequestHttpException("The `id` in the body must match the `id` in the URI");
        }
        $schema = $app["json-schema.schema-store"]->get($this->schema);
        $validation = $app["json-schema.validator"]->validate($data, $schema);
        if (!$validation->valid) {
            throw new BadRequestHttpException(json_encode($validation->errors));
        }
    }
}