SmsDeliveryReportsProcessor.php in SMS Framework 2.1.x
Same filename and directory in other branches
Namespace
Drupal\sms\EventSubscriberFile
src/EventSubscriber/SmsDeliveryReportsProcessor.phpView source
<?php
declare (strict_types=1);
namespace Drupal\sms\EventSubscriber;
use Drupal\sms\Event\SmsDeliveryReportEvent;
use Drupal\Core\Entity\EntityTypeManagerInterface;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Drupal\sms\Event\SmsEvents;
/**
* Handles delivery reports as they come in and updates storage.
*/
class SmsDeliveryReportsProcessor implements EventSubscriberInterface {
/**
* The entity storage for SMS delivery reports.
*
* @var \Drupal\Core\Entity\EntityStorageInterface
*/
protected $reportStorage;
/**
* Creates a new SmsDeliveryReportsProcessor controller.
*
* @param \Drupal\Core\Entity\EntityTypeManagerInterface $entity_type_manager
* The entity type manager.
*/
public function __construct(EntityTypeManagerInterface $entity_type_manager) {
$this->reportStorage = $entity_type_manager
->getStorage('sms_report');
}
/**
* Updates the delivery status on stored SMS delivery reports.
*
* @param \Drupal\sms\Event\SmsDeliveryReportEvent $event
* The event containing updated delivery reports status.
*/
public function updateDeliveryReports(SmsDeliveryReportEvent $event) {
foreach ($event
->getReports() as $report) {
// Only messages that have message IDs can be tracked and updated.
if ($report
->getMessageId()) {
$existing = $this->reportStorage
->loadByProperties([
'message_id' => $report
->getMessageId(),
]);
if ($existing) {
$existing = reset($existing);
$existing
->setStatus($report
->getStatus())
->setStatusMessage($report
->getStatusMessage())
->setStatusTime($report
->getStatusTime())
->save();
}
}
}
}
/**
* {@inheritdoc}
*/
public static function getSubscribedEvents() {
// Update delivery reports as they are received.
$events[SmsEvents::DELIVERY_REPORT_POST_PROCESS][] = [
'updateDeliveryReports',
1024,
];
return $events;
}
}
Classes
Name | Description |
---|---|
SmsDeliveryReportsProcessor | Handles delivery reports as they come in and updates storage. |