Loading src/Commands/WebformDigestsCommands.php 0 → 100644 +25 −0 Original line number Diff line number Diff line <?php namespace Drupal\webform_digests\Commands; use Drush\Commands\DrushCommands; /** * Class WebformDigestsCommands * * @package Drupal\webform_digests\Commands */ class WebformDigestsCommands extends DrushCommands { /** * Queue webform digests to be sent. * * @command webform:queue-digests */ public function queueDigests(): void { $queue_count = \Drupal::service('webform_digests.queue_builder')->queueSubmissions(); $this->output()->writeln(dt('@queue digest email(s) queued', ['@queue' => $queue_count])); } } src/WebformDigestsQueueBuilder.php +1 −2 Original line number Diff line number Diff line Loading @@ -40,7 +40,7 @@ class WebformDigestsQueueBuilder { $digests = $this->webformDigestStorage->loadMultiple(); $digestFrequency = $this->settings->get('cron.frequency'); if (empty($digests)) { return; return 0; } $queue = $this->queueFactory->get('webform_digest_queue'); foreach ($digests as $digest) { Loading @@ -53,5 +53,4 @@ class WebformDigestsQueueBuilder { } return count($digests); } } webform_digests.services.yml +7 −0 Original line number Diff line number Diff line Loading @@ -17,3 +17,10 @@ services: arguments: ['@current_route_match'] tags: - { name: 'context_provider' } # Drush commands webform_digests.drush: class: \Drupal\webform_digests\Commands\WebformDigestsCommands tags: - { name: drush.command } Loading
src/Commands/WebformDigestsCommands.php 0 → 100644 +25 −0 Original line number Diff line number Diff line <?php namespace Drupal\webform_digests\Commands; use Drush\Commands\DrushCommands; /** * Class WebformDigestsCommands * * @package Drupal\webform_digests\Commands */ class WebformDigestsCommands extends DrushCommands { /** * Queue webform digests to be sent. * * @command webform:queue-digests */ public function queueDigests(): void { $queue_count = \Drupal::service('webform_digests.queue_builder')->queueSubmissions(); $this->output()->writeln(dt('@queue digest email(s) queued', ['@queue' => $queue_count])); } }
src/WebformDigestsQueueBuilder.php +1 −2 Original line number Diff line number Diff line Loading @@ -40,7 +40,7 @@ class WebformDigestsQueueBuilder { $digests = $this->webformDigestStorage->loadMultiple(); $digestFrequency = $this->settings->get('cron.frequency'); if (empty($digests)) { return; return 0; } $queue = $this->queueFactory->get('webform_digest_queue'); foreach ($digests as $digest) { Loading @@ -53,5 +53,4 @@ class WebformDigestsQueueBuilder { } return count($digests); } }
webform_digests.services.yml +7 −0 Original line number Diff line number Diff line Loading @@ -17,3 +17,10 @@ services: arguments: ['@current_route_match'] tags: - { name: 'context_provider' } # Drush commands webform_digests.drush: class: \Drupal\webform_digests\Commands\WebformDigestsCommands tags: - { name: drush.command }