Code Coverage for /Users/ericduran/Sites/drupal/drupal/core/modules/rest/src/RequestHandler.php

	Code Coverage
	Classes and Traits			Functions and Methods				Lines
Total	0.00% covered (danger)	0.00%	0 / 1	0.00% covered (danger)	0.00%	0 / 3	CRAP	0.00% covered (danger)	0.00%	0 / 61
RequestHandler	0.00% covered (danger)	0.00%	0 / 1	0.00% covered (danger)	0.00%	0 / 3	182	0.00% covered (danger)	0.00%	0 / 61
handle				0.00% covered (danger)	0.00%	0 / 1	132	0.00% covered (danger)	0.00%	0 / 48
anonymous function				0.00% covered (danger)	0.00%	0 / 1	2	0.00% covered (danger)	0.00%	0 / 2
csrfToken				0.00% covered (danger)	0.00%	0 / 1	2	0.00% covered (danger)	0.00%	0 / 2

1	<?php
2
3	/**
4	* @file
5	* Contains \Drupal\rest\RequestHandler.
6	*/
7
8	namespace Drupal\rest;
9
10	use Drupal\Core\Render\RenderContext;
11	use Drupal\Core\Routing\RouteMatchInterface;
12	use Symfony\Component\DependencyInjection\ContainerAwareInterface;
13	use Symfony\Component\DependencyInjection\ContainerAwareTrait;
14	use Symfony\Component\HttpFoundation\Request;
15	use Symfony\Component\HttpFoundation\Response;
16	use Symfony\Component\HttpKernel\Exception\HttpException;
17	use Symfony\Component\HttpKernel\Exception\UnsupportedMediaTypeHttpException;
18	use Symfony\Component\Serializer\Exception\UnexpectedValueException;
19
20	/**
21	* Acts as intermediate request forwarder for resource plugins.
22	*/
23	class RequestHandler implements ContainerAwareInterface {
24
25	use ContainerAwareTrait;
26
27	/**
28	* Handles a web API request.
29	*
30	* @param \Drupal\Core\Routing\RouteMatchInterface $route_match
31	* The route match.
32	* @param \Symfony\Component\HttpFoundation\Request $request
33	* The HTTP request object.
34	*
35	* @return \Symfony\Component\HttpFoundation\Response
36	* The response object.
37	*/
38	public function handle(RouteMatchInterface $route_match, Request $request) {
39
40	$plugin = $route_match->getRouteObject()->getDefault('_plugin');
41	$method = strtolower($request->getMethod());
42
43	$resource = $this->container
44	->get('plugin.manager.rest')
45	->getInstance(array('id' => $plugin));
46
47	// Deserialize incoming data if available.
48	$serializer = $this->container->get('serializer');
49	$received = $request->getContent();
50	$unserialized = NULL;
51	if (!empty($received)) {
52	$format = $request->getContentType();
53
54	// Only allow serialization formats that are explicitly configured. If no
55	// formats are configured allow all and hope that the serializer knows the
56	// format. If the serializer cannot handle it an exception will be thrown
57	// that bubbles up to the client.
58	$config = $this->container->get('config.factory')->get('rest.settings')->get('resources');
59	$method_settings = $config[$plugin][$request->getMethod()];
60	if (empty($method_settings['supported_formats']) \|\| in_array($format, $method_settings['supported_formats'])) {
61	$definition = $resource->getPluginDefinition();
62	$class = $definition['serialization_class'];
63	try {
64	$unserialized = $serializer->deserialize($received, $class, $format, array('request_method' => $method));
65	}
66	catch (UnexpectedValueException $e) {
67	$error['error'] = $e->getMessage();
68	$content = $serializer->serialize($error, $format);
69	return new Response($content, 400, array('Content-Type' => $request->getMimeType($format)));
70	}
71	}
72	else {
73	throw new UnsupportedMediaTypeHttpException();
74	}
75	}
76
77	// Determine the request parameters that should be passed to the resource
78	// plugin.
79	$route_parameters = $route_match->getParameters();
80	$parameters = array();
81	// Filter out all internal parameters starting with "_".
82	foreach ($route_parameters as $key => $parameter) {
83	if ($key{0} !== '_') {
84	$parameters[] = $parameter;
85	}
86	}
87
88	// Invoke the operation on the resource plugin.
89	// All REST routes are restricted to exactly one format, so instead of
90	// parsing it out of the Accept headers again, we can simply retrieve the
91	// format requirement. If there is no format associated, just pick JSON.
92	$format = $route_match->getRouteObject()->getRequirement('_format') ?: 'json';
93	try {
94	$response = call_user_func_array(array($resource, $method), array_merge($parameters, array($unserialized, $request)));
95	}
96	catch (HttpException $e) {
97	$error['error'] = $e->getMessage();
98	$content = $serializer->serialize($error, $format);
99	// Add the default content type, but only if the headers from the
100	// exception have not specified it already.
101	$headers = $e->getHeaders() + array('Content-Type' => $request->getMimeType($format));
102	return new Response($content, $e->getStatusCode(), $headers);
103	}
104
105	if ($response instanceof ResourceResponse) {
106	$data = $response->getResponseData();
107	// Serialization can invoke rendering (e.g., generating URLs), but the
108	// serialization API does not provide a mechanism to collect the
109	// bubbleable metadata associated with that (e.g., language and other
110	// contexts), so instead, allow those to "leak" and collect them here in
111	// a render context.
112	// @todo Add test coverage for language negotiation contexts in
113	// https://www.drupal.org/node/2135829.
114	$context = new RenderContext();
115	$output = $this->container->get('renderer')->executeInRenderContext($context, function() use ($serializer, $data, $format) {
116	return $serializer->serialize($data, $format);
117	});
118	$response->setContent($output);
119	if (!$context->isEmpty()) {
120	$response->addCacheableDependency($context->pop());
121	}
122
123	$response->headers->set('Content-Type', $request->getMimeType($format));
124	// Add rest settings config's cache tags.
125	$response->addCacheableDependency($this->container->get('config.factory')->get('rest.settings'));
126	}
127	return $response;
128	}
129
130	/**
131	* Generates a CSRF protecting session token.
132	*
133	* @return \Symfony\Component\HttpFoundation\Response
134	* The response object.
135	*/
136	public function csrfToken() {
137	return new Response(\Drupal::csrfToken()->get('rest'), 200, array('Content-Type' => 'text/plain'));
138	}
139	}