class SubscriptionController in Feeds 8.3
Returns responses for PuSH module routes.
Hierarchy
- class \Drupal\Core\Controller\ControllerBase implements ContainerInjectionInterface uses LoggerChannelTrait, MessengerTrait, LinkGeneratorTrait, RedirectDestinationTrait, UrlGeneratorTrait, StringTranslationTrait
- class \Drupal\feeds\Controller\SubscriptionController implements ContainerInjectionInterface
Expanded class hierarchy of SubscriptionController
1 file declares its use of SubscriptionController
- SubscriptionControllerTest.php in tests/
src/ Unit/ Controller/ SubscriptionControllerTest.php
File
- src/
Controller/ SubscriptionController.php, line 19
Namespace
Drupal\feeds\ControllerView source
class SubscriptionController extends ControllerBase implements ContainerInjectionInterface {
/**
* The key value expirable factory.
*
* @var \Drupal\Core\KeyValueStore\KeyValueExpirableFactoryInterface
*/
protected $keyValueExpireFactory;
/**
* Constructs a SubscriptionController object.
*
* @param \Drupal\Core\KeyValueStore\KeyValueExpirableFactoryInterface $key_value_expire_factory
* The key value expirable factory.
* @param \Drupal\Core\Entity\EntityTypeManagerInterface $entity_type_manager
* The entity type manager.
*/
public function __construct(KeyValueExpirableFactoryInterface $key_value_expire_factory, EntityTypeManagerInterface $entity_type_manager) {
$this->keyValueExpireFactory = $key_value_expire_factory;
$this->entityTypeManager = $entity_type_manager;
}
/**
* {@inheritdoc}
*/
public static function create(ContainerInterface $container) {
return new static($container
->get('keyvalue.expirable'), $container
->get('entity_type.manager'));
}
/**
* Handles subscribe/unsubscribe requests.
*
* @param int $feeds_subscription_id
* The subscription entity id.
* @param string $feeds_push_token
* The subscription token.
* @param \Symfony\Component\HttpFoundation\Request $request
* The request object.
*
* @return Symfony\Component\HttpFoundation\Response
* The response object.
*
* @throws \Symfony\Component\HttpKernel\Exception\NotFoundHttpException
* Thrown if the subscription was not found, or if the request is invalid.
*/
public function subscribe($feeds_subscription_id, $feeds_push_token, Request $request) {
// This is an invalid request.
if ($request->query
->get('hub_challenge') === NULL || $request->query
->get('hub_topic') === NULL) {
throw new NotFoundHttpException();
}
// A subscribe request.
if ($request->query
->get('hub_mode') === 'subscribe') {
return $this
->handleSubscribe((int) $feeds_subscription_id, $feeds_push_token, $request);
}
// An unsubscribe request.
if ($request->query
->get('hub_mode') === 'unsubscribe') {
return $this
->handleUnsubscribe((int) $feeds_subscription_id, $feeds_push_token, $request);
}
// Whatever.
throw new NotFoundHttpException();
}
/**
* Handles a subscribe request.
*
* @param int $subscription_id
* The subscription entity id.
* @param string $token
* The subscription token.
* @param \Symfony\Component\HttpFoundation\Request $request
* The request object.
*
* @return \Symfony\Component\HttpFoundation\Response
* The response challenge.
*
* @throws \Symfony\Component\HttpKernel\Exception\NotFoundHttpException
* Thrown if anything seems amiss.
*/
protected function handleSubscribe($subscription_id, $token, Request $request) {
if (!($subscription = $this
->entityTypeManager()
->getStorage('feeds_subscription')
->load($subscription_id))) {
throw new NotFoundHttpException();
}
if ($subscription
->getToken() !== $token || $subscription
->getTopic() !== $request->query
->get('hub_topic')) {
throw new NotFoundHttpException();
}
if ($subscription
->getState() !== 'subscribing' && $subscription
->getState() !== 'subscribed') {
throw new NotFoundHttpException();
}
if ($lease_time = $request->query
->get('hub_lease_seconds')) {
$subscription
->setLease($lease_time);
}
$subscription
->setState('subscribed');
$subscription
->save();
return new Response(Html::escape($request->query
->get('hub_challenge')), 200);
}
/**
* Handles an unsubscribe request.
*
* @param int $subscription_id
* The subscription entity id.
* @param string $token
* The subscription token.
* @param \Symfony\Component\HttpFoundation\Request $request
* The request object.
*
* @return \Symfony\Component\HttpFoundation\Response
* The response challenge.
*
* @throws \Symfony\Component\HttpKernel\Exception\NotFoundHttpException
* Thrown if anything seems amiss.
*/
protected function handleUnsubscribe($subscription_id, $token, Request $request) {
// The subscription id already deleted, but waiting in the keyvalue store.
$id = $token . ':' . $subscription_id;
$subscription = $this->keyValueExpireFactory
->get('feeds_push_unsubscribe')
->get($id);
if (!$subscription) {
throw new NotFoundHttpException();
}
$this->keyValueExpireFactory
->get('feeds_push_unsubscribe')
->delete($id);
return new Response(Html::escape($request->query
->get('hub_challenge')), 200);
}
/**
* Receives a notification.
*
* @param \Drupal\feeds\SubscriptionInterface $feeds_subscription
* The subscription entity.
* @param string $feeds_push_token
* The subscription token.
* @param \Symfony\Component\HttpFoundation\Request $request
* The request object.
*
* @return Symfony\Component\HttpFoundation\Response
* The response object.
*
* @throws \Symfony\Component\HttpKernel\Exception\NotFoundHttpException
* Thrown if anything seems amiss.
*/
public function receive(SubscriptionInterface $feeds_subscription, $feeds_push_token, Request $request) {
if ($feeds_subscription
->getToken() !== $feeds_push_token) {
throw new NotFoundHttpException();
}
// X-Hub-Signature is in the format sha1=signature.
parse_str($request->headers
->get('X-Hub-Signature'), $result);
if (empty($result['sha1']) || !$feeds_subscription
->checkSignature($result['sha1'], $request
->getContent())) {
throw new NotFoundHttpException();
}
$feed = $this
->entityTypeManager()
->getStorage('feeds_feed')
->load($feeds_subscription
->id());
try {
$feed
->pushImport($request
->getContent());
} catch (\Exception $e) {
return new Response('', 500);
}
return new Response('', 200);
}
}
Members
Name | Modifiers | Type | Description | Overrides |
---|---|---|---|---|
ControllerBase:: |
protected | property | The configuration factory. | |
ControllerBase:: |
protected | property | The current user service. | 1 |
ControllerBase:: |
protected | property | The entity form builder. | |
ControllerBase:: |
protected | property | The entity manager. | |
ControllerBase:: |
protected | property | The entity type manager. | |
ControllerBase:: |
protected | property | The form builder. | 2 |
ControllerBase:: |
protected | property | The key-value storage. | 1 |
ControllerBase:: |
protected | property | The language manager. | 1 |
ControllerBase:: |
protected | property | The module handler. | 2 |
ControllerBase:: |
protected | property | The state service. | |
ControllerBase:: |
protected | function | Returns the requested cache bin. | |
ControllerBase:: |
protected | function | Retrieves a configuration object. | |
ControllerBase:: |
private | function | Returns the service container. | |
ControllerBase:: |
protected | function | Returns the current user. | 1 |
ControllerBase:: |
protected | function | Retrieves the entity form builder. | |
ControllerBase:: |
protected | function | Retrieves the entity manager service. | |
ControllerBase:: |
protected | function | Retrieves the entity type manager. | |
ControllerBase:: |
protected | function | Returns the form builder service. | 2 |
ControllerBase:: |
protected | function | Returns a key/value storage collection. | 1 |
ControllerBase:: |
protected | function | Returns the language manager service. | 1 |
ControllerBase:: |
protected | function | Returns the module handler. | 2 |
ControllerBase:: |
protected | function |
Returns a redirect response object for the specified route. Overrides UrlGeneratorTrait:: |
|
ControllerBase:: |
protected | function | Returns the state storage service. | |
LinkGeneratorTrait:: |
protected | property | The link generator. | 1 |
LinkGeneratorTrait:: |
protected | function | Returns the link generator. | |
LinkGeneratorTrait:: |
protected | function | Renders a link to a route given a route name and its parameters. | |
LinkGeneratorTrait:: |
public | function | Sets the link generator service. | |
LoggerChannelTrait:: |
protected | property | The logger channel factory service. | |
LoggerChannelTrait:: |
protected | function | Gets the logger for a specific channel. | |
LoggerChannelTrait:: |
public | function | Injects the logger channel factory. | |
MessengerTrait:: |
protected | property | The messenger. | 29 |
MessengerTrait:: |
public | function | Gets the messenger. | 29 |
MessengerTrait:: |
public | function | Sets the messenger. | |
RedirectDestinationTrait:: |
protected | property | The redirect destination service. | 1 |
RedirectDestinationTrait:: |
protected | function | Prepares a 'destination' URL query parameter for use with \Drupal\Core\Url. | |
RedirectDestinationTrait:: |
protected | function | Returns the redirect destination service. | |
RedirectDestinationTrait:: |
public | function | Sets the redirect destination service. | |
StringTranslationTrait:: |
protected | property | The string translation service. | 1 |
StringTranslationTrait:: |
protected | function | Formats a string containing a count of items. | |
StringTranslationTrait:: |
protected | function | Returns the number of plurals supported by a given language. | |
StringTranslationTrait:: |
protected | function | Gets the string translation service. | |
StringTranslationTrait:: |
public | function | Sets the string translation service to use. | 2 |
StringTranslationTrait:: |
protected | function | Translates a string to the current language or to a given language. | |
SubscriptionController:: |
protected | property | The key value expirable factory. | |
SubscriptionController:: |
public static | function |
Instantiates a new instance of this class. Overrides ControllerBase:: |
|
SubscriptionController:: |
protected | function | Handles a subscribe request. | |
SubscriptionController:: |
protected | function | Handles an unsubscribe request. | |
SubscriptionController:: |
public | function | Receives a notification. | |
SubscriptionController:: |
public | function | Handles subscribe/unsubscribe requests. | |
SubscriptionController:: |
public | function | Constructs a SubscriptionController object. | |
UrlGeneratorTrait:: |
protected | property | The url generator. | |
UrlGeneratorTrait:: |
protected | function | Returns the URL generator service. | |
UrlGeneratorTrait:: |
public | function | Sets the URL generator service. | |
UrlGeneratorTrait:: |
protected | function | Generates a URL or path for a specific route based on the given parameters. |