src/EventSubscriber/ApiRequestLogSubscriber.php line 67

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use Psr\Log\LoggerInterface;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  7. use Symfony\Component\HttpKernel\Event\ControllerEvent;
  8. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  9. use Symfony\Component\HttpKernel\KernelEvents;
  10. use Symfony\Component\HttpFoundation\Request;
  11. use Symfony\Component\HttpFoundation\Response;
  13. class ApiRequestLogSubscriber implements EventSubscriberInterface
  14. {
  15. private const IGNORED_ROUTES = [
  16. 'app_api_overall_saleorder_getsaleorders',
  17. ];
  19. public function __construct(private readonly LoggerInterface $logger)
  20. {
  21. }
  23. public static function getSubscribedEvents(): array
  24. {
  25. return [
  26. KernelEvents::CONTROLLER => 'onKernelController',
  27. KernelEvents::RESPONSE => 'onKernelResponse',
  28. ];
  29. }
  31. public function onKernelController(ControllerEvent $event): void
  32. {
  33. if (!$event->isMainRequest()) {
  34. return;
  35. }
  37. $controller = $event->getController();
  39. if (is_array($controller)) {
  40. $controllerClass = get_class($controller[0]);
  41. $controllerMethod = $controller[1];
  42. } elseif (is_object($controller)) {
  43. $controllerClass = get_class($controller);
  44. $controllerMethod = '__invoke';
  45. } else {
  46. return;
  47. }
  49. if (!str_starts_with($controllerClass, 'App\\Controller\\API\\')) {
  50. return;
  51. }
  53. $request = $event->getRequest();
  54. if ($this->shouldIgnoreRoute($request)) {
  55. return;
  56. }
  58. $this->logger->info('API call', [
  59. 'route' => $request->attributes->get('_route'),
  60. 'method' => $request->getMethod(),
  61. 'path' => $request->getPathInfo(),
  62. 'query' => $request->query->all(),
  63. 'controller' => $controllerClass . '::' . $controllerMethod
  64. ]);
  65. }
  67. public function onKernelResponse(ResponseEvent $event): void
  68. {
  69. if (!$event->isMainRequest()) {
  70. return;
  71. }
  73. $request = $event->getRequest();
  74. if ($this->shouldIgnoreRoute($request)) {
  75. return;
  76. }
  77. if (!$this->isApiController($request)) {
  78. return;
  79. }
  81. $controller = $request->attributes->get('_controller');
  82. if (!is_string($controller)) {
  83. return;
  84. }
  86. $response = $event->getResponse();
  87. $statusCode = $response->getStatusCode();
  89. $context = [
  90. 'route' => $request->attributes->get('_route'),
  91. 'method' => $request->getMethod(),
  92. 'path' => $request->getPathInfo(),
  93. 'controller' => $controller,
  94. 'status_code' => $statusCode,
  95. ];
  97. if ($statusCode >= 400) {
  98. $errorMessage = $this->extractErrorMessage($response);
  99. if ($errorMessage !== null) {
  100. $context['error_message'] = $errorMessage;
  101. }
  103. $this->logger->error('API response', $context);
  104. return;
  105. }
  107. $this->logger->info('API response', $context);
  108. }
  110. private function isApiController(Request $request): bool
  111. {
  112. $controller = $request->attributes->get('_controller');
  114. if (is_array($controller)) {
  115. $controller = get_class($controller[0]) . '::' . $controller[1];
  116. } elseif (is_object($controller)) {
  117. $controller = get_class($controller) . '::__invoke';
  118. }
  120. return is_string($controller) && str_starts_with($controller, 'App\\Controller\\API\\');
  121. }
  123. private function extractErrorMessage(Response $response): ?string
  124. {
  125. $content = trim($response->getContent());
  126. if ($content === '') {
  127. return Response::$statusTexts[$response->getStatusCode()] ?? null;
  128. }
  130. $contentType = strtolower((string) $response->headers->get('content-type'));
  131. if (str_contains($contentType, 'application/json') || str_contains($contentType, '+json')) {
  132. $decoded = json_decode($content, true);
  133. if (json_last_error() === JSON_ERROR_NONE) {
  134. if (is_string($decoded)) {
  135. return $decoded;
  136. }
  138. if (is_array($decoded)) {
  139. foreach (['message', 'error_description', 'detail', 'title', 'error'] as $key) {
  140. $value = $decoded[$key] ?? null;
  141. if (is_string($value) && trim($value) !== '') {
  142. return $value;
  143. }
  144. }
  146. if (isset($decoded['error']) && is_array($decoded['error'])) {
  147. foreach (['message', 'error_description', 'detail', 'title', 'error'] as $key) {
  148. $value = $decoded['error'][$key] ?? null;
  149. if (is_string($value) && trim($value) !== '') {
  150. return $value;
  151. }
  152. }
  153. }
  154. }
  155. }
  156. }
  158. if (strlen($content) > 500) {
  159. return substr($content, 0, 500) . '...[truncated]';
  160. }
  162. return $content;
  163. }
  165. private function shouldIgnoreRoute(Request $request): bool
  166. {
  167. return in_array((string) $request->attributes->get('_route'), self::IGNORED_ROUTES, true);
  168. }
  169. }