CodeExplorer
You are a developer and looking for Shopware projects?
Apply Now!
getRequest example
public function __construct(RequestStack $requestStack, string $defaultLocale = 'en', RequestContextAwareInterface $router = null, bool $useAcceptLanguageHeader = false, array $enabledLocales = [])
{
$this->defaultLocale = $defaultLocale;
$this->requestStack = $requestStack;
$this->router = $router;
$this->useAcceptLanguageHeader = $useAcceptLanguageHeader;
$this->enabledLocales = $enabledLocales;
}
public function setDefaultLocale(KernelEvent $event): void
{
$event->getRequest()->setDefaultLocale($this->defaultLocale);
}
public function onKernelRequest(RequestEvent $event): void
{
$request = $event->getRequest();
$this->setLocale($request);
$this->setRouterContext($request);
}
public function onKernelFinishRequest(FinishRequestEvent $event): void
{
{
$this->defaultLocale = $defaultLocale;
$this->requestStack = $requestStack;
$this->router = $router;
$this->useAcceptLanguageHeader = $useAcceptLanguageHeader;
$this->enabledLocales = $enabledLocales;
}
public function setDefaultLocale(KernelEvent $event): void
{
$event->getRequest()->setDefaultLocale($this->defaultLocale);
}
public function onKernelRequest(RequestEvent $event): void
{
$request = $event->getRequest();
$this->setLocale($request);
$this->setRouterContext($request);
}
public function onKernelFinishRequest(FinishRequestEvent $event): void
{
KernelEvents::REQUEST => 'addHttpCacheToCoreRoutes',
KernelEvents::RESPONSE => [
['setResponseCache', -1500],
['setResponseCacheHeader', 1500],
],
BeforeSendResponseEvent::class => 'updateCacheControlForBrowser',
];
}
public function addHttpCacheToCoreRoutes(RequestEvent $event): void
{
$request = $event->getRequest();
$route = $request->attributes->get('_route');
if (\in_array($route, self::CORE_HTTP_CACHED_ROUTES, true)) {
$request->attributes->set(PlatformRequest::ATTRIBUTE_HTTP_CACHE, true);
}
}
public function setResponseCache(ResponseEvent $event): void
{
if (!$this->httpCacheEnabled) {
return;
}
KernelEvents::RESPONSE => [
['setResponseCache', -1500],
['setResponseCacheHeader', 1500],
],
BeforeSendResponseEvent::class => 'updateCacheControlForBrowser',
];
}
public function addHttpCacheToCoreRoutes(RequestEvent $event): void
{
$request = $event->getRequest();
$route = $request->attributes->get('_route');
if (\in_array($route, self::CORE_HTTP_CACHED_ROUTES, true)) {
$request->attributes->set(PlatformRequest::ATTRIBUTE_HTTP_CACHE, true);
}
}
public function setResponseCache(ResponseEvent $event): void
{
if (!$this->httpCacheEnabled) {
return;
}
/**
* @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
*/
public static function getSubscribedEvents()
{
return [KernelEvents::REQUEST => 'onKernelRequest'];
}
public function onKernelRequest(RequestEvent $event): void
{
$timezone = (string) $event->getRequest()->cookies->get(self::TIMEZONE_COOKIE);
if (!$timezone || !\in_array($timezone, timezone_identifiers_list(), true) || $timezone === 'UTC') {
// Default will be UTC @see https://symfony.com/doc/current/reference/configuration/twig.html#timezone return;
}
$twig = $this->container->get('twig');
if (!$twig->hasExtension(CoreExtension::class)) {
return;
}
public static function getSubscribedEvents()
{
return [KernelEvents::REQUEST => 'onKernelRequest'];
}
public function onKernelRequest(RequestEvent $event): void
{
$timezone = (string) $event->getRequest()->cookies->get(self::TIMEZONE_COOKIE);
if (!$timezone || !\in_array($timezone, timezone_identifiers_list(), true) || $timezone === 'UTC') {
// Default will be UTC @see https://symfony.com/doc/current/reference/configuration/twig.html#timezone return;
}
$twig = $this->container->get('twig');
if (!$twig->hasExtension(CoreExtension::class)) {
return;
}
if (class_exists(StorefrontRenderEvent::class)) {
$events[StorefrontRenderEvent::class] = ['render', -10];
}
return $events;
}
public function request(RequestEvent $event): void
{
$request = $event->getRequest();
if (!$request->attributes->has('_route')) {
return;
}
$name = $request->attributes->get('_route') . '.request';
$this->dispatcher->dispatch($event, $name);
}
public function render(StorefrontRenderEvent $event): void
{
$request = $event->getRequest();
return true;
}
/** * Handles the switch to another user. * * @throws \LogicException if switching to a user failed */
public function authenticate(RequestEvent $event): void
{
$request = $event->getRequest();
$username = $request->attributes->get('_switch_user_username');
$request->attributes->remove('_switch_user_username');
if (null === $this->tokenStorage->getToken()) {
throw new AuthenticationCredentialsNotFoundException('Could not find original Token object.');
}
if (self::EXIT_VALUE === $username) {
$this->tokenStorage->setToken($this->attemptExitUser($request));
} else {
}
/** * Handles the switch to another user. * * @throws \LogicException if switching to a user failed */
public function authenticate(RequestEvent $event): void
{
$request = $event->getRequest();
$username = $request->attributes->get('_switch_user_username');
$request->attributes->remove('_switch_user_username');
if (null === $this->tokenStorage->getToken()) {
throw new AuthenticationCredentialsNotFoundException('Could not find original Token object.');
}
if (self::EXIT_VALUE === $username) {
$this->tokenStorage->setToken($this->attemptExitUser($request));
} else {
return;
}
} while (null !== $exception = $exception->getPrevious());
}
private function handleAuthenticationException(ExceptionEvent $event, AuthenticationException $exception): void
{
$this->logger?->info('An AuthenticationException was thrown; redirecting to authentication entry point.', ['exception' => $exception]);
try {
$event->setResponse($this->startAuthentication($event->getRequest(), $exception));
$event->allowCustomResponseCode();
} catch (\Exception $e) {
$event->setThrowable($e);
}
}
private function handleAccessDeniedException(ExceptionEvent $event, AccessDeniedException $exception): void
{
$event->setThrowable(new AccessDeniedHttpException($exception->getMessage(), $exception));
$token = $this->tokenStorage->getToken();
}
} while (null !== $exception = $exception->getPrevious());
}
private function handleAuthenticationException(ExceptionEvent $event, AuthenticationException $exception): void
{
$this->logger?->info('An AuthenticationException was thrown; redirecting to authentication entry point.', ['exception' => $exception]);
try {
$event->setResponse($this->startAuthentication($event->getRequest(), $exception));
$event->allowCustomResponseCode();
} catch (\Exception $e) {
$event->setThrowable($e);
}
}
private function handleAccessDeniedException(ExceptionEvent $event, AccessDeniedException $exception): void
{
$event->setThrowable(new AccessDeniedHttpException($exception->getMessage(), $exception));
$token = $this->tokenStorage->getToken();
/**
* Sets the cache key on the alias manager cache decorator.
*
* KernelEvents::CONTROLLER is used in order to be executed after routing.
*
* @param \Symfony\Component\HttpKernel\Event\ControllerEvent $event
* The Event to process.
*/
public function onKernelController(ControllerEvent $event) {
// Set the cache key on the alias manager cache decorator. if ($event->isMainRequest() && $this->workspaceManager->hasActiveWorkspace()) {
$cache_key = $this->workspaceManager->getActiveWorkspace()->id() . ':' . rtrim($this->currentPath->getPath($event->getRequest()), '/');
$this->aliasManager->setCacheKey($cache_key);
}
}
/** * Adds the active workspace as a cache key part to the route provider. * * @param \Symfony\Component\HttpKernel\Event\RequestEvent $event * An event object. */
public function onKernelRequest(RequestEvent $event) {
public function onKernelController(ControllerEvent $event) {
// Set the cache key on the alias manager cache decorator. if ($event->isMainRequest() && $this->workspaceManager->hasActiveWorkspace()) {
$cache_key = $this->workspaceManager->getActiveWorkspace()->id() . ':' . rtrim($this->currentPath->getPath($event->getRequest()), '/');
$this->aliasManager->setCacheKey($cache_key);
}
}
/** * Adds the active workspace as a cache key part to the route provider. * * @param \Symfony\Component\HttpKernel\Event\RequestEvent $event * An event object. */
public function onKernelRequest(RequestEvent $event) {
ProductSearchResultEvent::class => 'process',
];
}
public function prepare(ProductListingCriteriaEvent $event): void
{
if (Feature::isActive('v6.6.0.0') || $event->getContext()->hasState(self::HANDLED_STATE)) {
return;
}
$this->processor->prepare(
$event->getRequest(),
$event->getCriteria(),
$event->getSalesChannelContext()
);
}
public function process(ProductListingResultEvent $event): void
{
if (Feature::isActive('v6.6.0.0') || $event->getContext()->hasState(self::HANDLED_STATE)) {
return;
}
];
}
public function prepare(ProductListingCriteriaEvent $event): void
{
if (Feature::isActive('v6.6.0.0') || $event->getContext()->hasState(self::HANDLED_STATE)) {
return;
}
$this->processor->prepare(
$event->getRequest(),
$event->getCriteria(),
$event->getSalesChannelContext()
);
}
public function process(ProductListingResultEvent $event): void
{
if (Feature::isActive('v6.6.0.0') || $event->getContext()->hasState(self::HANDLED_STATE)) {
return;
}
return $events;
}
/** * Returns response when site is in maintenance mode and user is not exempt. * * @param \Symfony\Component\HttpKernel\Event\RequestEvent $event * The event to process. */
public function onMaintenanceModeRequest(RequestEvent $event) {
$request = $event->getRequest();
if ($request->getRequestFormat() !== 'api_json') {
return;
}
// Retry-After will be random within a range defined in jsonapi settings. // The goals are to keep it short and to reduce the thundering herd problem. $header_settings = $this->config->get('jsonapi.settings')->get('maintenance_header_retry_seconds');
$retry_after_time = rand($header_settings['min'], $header_settings['max']);
$http_exception = new HttpException(503, $this->maintenanceMode->getSiteMaintenanceMessage());
$document = new JsonApiDocumentTopLevel(new ErrorCollection([$http_exception]), new NullIncludedData(), new LinkCollection([]));
$response = new ResourceResponse($document, $http_exception->getStatusCode(), [
public function onKernelResponse(ResponseEvent $event): void
{
if ($this->onlyMainRequests && !$event->isMainRequest()) {
return;
}
if ($this->onlyException && null === $this->exception) {
return;
}
$request = $event->getRequest();
if (null !== $this->collectParameter && null !== $collectParameterValue = $request->get($this->collectParameter)) {
true === $collectParameterValue || filter_var($collectParameterValue, \FILTER_VALIDATE_BOOL) ? $this->profiler->enable() : $this->profiler->disable();
}
$exception = $this->exception;
$this->exception = null;
if (null !== $this->matcher && !$this->matcher->matches($request)) {
return;
}
public static function getSubscribedEvents(): array
{
return [
ResponseEvent::class => ['onResponse', -10],
];
}
public function onResponse(ResponseEvent $event): void
{
$response = $event->getResponse();
/** @var list<string> $scopes */
$scopes = $event->getRequest()->attributes->get(PlatformRequest::ATTRIBUTE_ROUTE_SCOPE, []);
if (!\in_array(StorefrontRouteScope::ID, $scopes, true) && !$response instanceof StorefrontResponse) {
return;
}
$this->manipulateStorefrontHeader($event->getRequest(), $response);
}
private function manipulateStorefrontHeader(Request $request, Response $response): void
{
$this->removeHeaders($response);
{
return [
ResponseEvent::class => ['onResponse', -10],
];
}
public function onResponse(ResponseEvent $event): void
{
$response = $event->getResponse();
/** @var list<string> $scopes */
$scopes = $event->getRequest()->attributes->get(PlatformRequest::ATTRIBUTE_ROUTE_SCOPE, []);
if (!\in_array(StorefrontRouteScope::ID, $scopes, true) && !$response instanceof StorefrontResponse) {
return;
}
$this->manipulateStorefrontHeader($event->getRequest(), $response);
}
private function manipulateStorefrontHeader(Request $request, Response $response): void
{
$this->removeHeaders($response);
foreach ($arguments as $i => $argument) {
if ($argument instanceof MapQueryString) {
$payloadMapper = 'mapQueryString';
$validationFailedCode = $argument->validationFailedStatusCode;
} elseif ($argument instanceof MapRequestPayload) {
$payloadMapper = 'mapRequestPayload';
$validationFailedCode = $argument->validationFailedStatusCode;
} else {
continue;
}
$request = $event->getRequest();
if (!$type = $argument->metadata->getType()) {
throw new \LogicException(sprintf('Could not resolve the "$%s" controller argument: argument should be typed.', $argument->metadata->getName()));
}
if ($this->validator) {
$violations = new ConstraintViolationList();
try {
$payload = $this->$payloadMapper($request, $type, $argument);
} catch (PartialDenormalizationException $e) {
$trans = $this->translator ? $this->translator->trans(...) : fn ($m, $p) => strtr($m, $p);
if ($argument instanceof MapQueryString) {
$payloadMapper = 'mapQueryString';
$validationFailedCode = $argument->validationFailedStatusCode;
} elseif ($argument instanceof MapRequestPayload) {
$payloadMapper = 'mapRequestPayload';
$validationFailedCode = $argument->validationFailedStatusCode;
} else {
continue;
}
$request = $event->getRequest();
if (!$type = $argument->metadata->getType()) {
throw new \LogicException(sprintf('Could not resolve the "$%s" controller argument: argument should be typed.', $argument->metadata->getName()));
}
if ($this->validator) {
$violations = new ConstraintViolationList();
try {
$payload = $this->$payloadMapper($request, $type, $argument);
} catch (PartialDenormalizationException $e) {
$trans = $this->translator ? $this->translator->trans(...) : fn ($m, $p) => strtr($m, $p);
if (!isset($this->handlers[$type])) {
$this->handlers[$type] = [];
$types = ViewExecutable::getHandlerTypes();
$plural = $types[$type]['plural'];
// Cast to an array so that if the display does not have any handlers of // this type there is no PHP error. foreach ((array) $this->getOption($plural) as $id => $info) {
// If this is during form submission and there are temporary options // which can only appear if the view is in the edit cache, use those // options instead. This is used for AJAX multi-step stuff. if ($this->view->getRequest()->request->get('form_id') && isset($this->view->temporary_options[$type][$id])) {
$info = $this->view->temporary_options[$type][$id];
}
if ($info['id'] != $id) {
$info['id'] = $id;
}
// If aggregation is on, the group type might override the actual // handler that is in use. This piece of code checks that and, // if necessary, sets the override handler. $override = NULL;
$this->handlers[$type] = [];
$types = ViewExecutable::getHandlerTypes();
$plural = $types[$type]['plural'];
// Cast to an array so that if the display does not have any handlers of // this type there is no PHP error. foreach ((array) $this->getOption($plural) as $id => $info) {
// If this is during form submission and there are temporary options // which can only appear if the view is in the edit cache, use those // options instead. This is used for AJAX multi-step stuff. if ($this->view->getRequest()->request->get('form_id') && isset($this->view->temporary_options[$type][$id])) {
$info = $this->view->temporary_options[$type][$id];
}
if ($info['id'] != $id) {
$info['id'] = $id;
}
// If aggregation is on, the group type might override the actual // handler that is in use. This piece of code checks that and, // if necessary, sets the override handler. $override = NULL;
return $value;
}
protected function resolveEntityValueToString(?Entity $entity, string $path, EntityResolverContext $resolverContext): string
{
$content = $this->resolveEntityValue($entity, $path);
if ($content instanceof \DateTimeInterface) {
$dateFormatter = new \IntlDateFormatter(
$resolverContext->getRequest()->getLocale(),
\IntlDateFormatter::MEDIUM,
\IntlDateFormatter::MEDIUM
);
$content = $dateFormatter->format($content);
}
if ($content === null || \is_scalar($content) || (\is_object($content) && \method_exists($content, '__toString'))) {
return (string) $content;
}
return $path;
}
$endpoint = parse_url($configuration->get('endpoint'));
$host = $endpoint['host'].($endpoint['port'] ?? null ? ':'.$endpoint['port'] : '');
} else {
$host = $configuration->get('region');
}
return sprintf('ses+https://%s@%s', $configuration->get('accessKeyId'), $host);
}
protected function doSend(SentMessage $message): void
{
$result = $this->sesClient->sendEmail($this->getRequest($message));
$response = $result->info()['response'];
try {
$message->setMessageId($result->getMessageId());
$message->appendDebug($response->getInfo('debug') ?? '');
} catch (HttpException $e) {
$exception = new HttpTransportException(sprintf('Unable to send an email: %s (code %s).', $e->getAwsMessage() ?: $e->getMessage(), $e->getAwsCode() ?: $e->getCode()), $e->getResponse(), $e->getCode(), $e);
$exception->appendDebug($e->getResponse()->getInfo('debug') ?? '');
throw $exception;
}
}
$host = $endpoint['host'].($endpoint['port'] ?? null ? ':'.$endpoint['port'] : '');
} else {
$host = $configuration->get('region');
}
return sprintf('ses+https://%s@%s', $configuration->get('accessKeyId'), $host);
}
protected function doSend(SentMessage $message): void
{
$result = $this->sesClient->sendEmail($this->getRequest($message));
$response = $result->info()['response'];
try {
$message->setMessageId($result->getMessageId());
$message->appendDebug($response->getInfo('debug') ?? '');
} catch (HttpException $e) {
$exception = new HttpTransportException(sprintf('Unable to send an email: %s (code %s).', $e->getAwsMessage() ?: $e->getMessage(), $e->getAwsCode() ?: $e->getCode()), $e->getResponse(), $e->getCode(), $e);
$exception->appendDebug($e->getResponse()->getInfo('debug') ?? '');
throw $exception;
}
}