5189: Improved digital post test command

Author: rimi-itk

modules/os2forms_digital_post/src/Drush/Commands/DigitalPostTestCommands.php

@@ -2,6 +2,9 @@
 
 namespace Drupal\os2forms_digital_post\Drush\Commands;
 
+use DigitalPost\MeMo\Action;
+use DigitalPost\MeMo\EntryPoint;
+use DigitalPost\MeMo\Reservation;
 use Drupal\Component\Serialization\Yaml;
 use Drupal\Core\DependencyInjection\AutowireTrait;
 use Drupal\Core\Utility\Token;
@@ -10,10 +13,16 @@
 use Drupal\os2forms_digital_post\Helper\Settings;
 use Drupal\os2forms_digital_post\Model\Document;
 use Drush\Commands\DrushCommands;
+use ItkDev\Serviceplatformen\Service\SF1601\Serializer;
 use ItkDev\Serviceplatformen\Service\SF1601\SF1601;
 use Symfony\Component\Console\Exception\InvalidArgumentException;
+use Symfony\Component\Console\Exception\InvalidOptionException;
 use Symfony\Component\Console\Style\SymfonyStyle;
 use Symfony\Component\DependencyInjection\Attribute\Autowire;
+use Symfony\Component\OptionsResolver\Exception\ExceptionInterface;
+use Symfony\Component\OptionsResolver\Exception\InvalidOptionsException;
+use Symfony\Component\OptionsResolver\Options;
+use Symfony\Component\OptionsResolver\OptionsResolver;
 use Symfony\Contracts\HttpClient\Exception\ClientExceptionInterface;
 
 /**
@@ -44,14 +53,20 @@ public function __construct(
    * @param array $options
    *   The options.
    *
-   * @option string subject
-   *     The subject. Can contain HTML.
-   * @option string message
-   *    The message to send. Can contain HTML.
-   * @option string digital-post-type
-   *      The digital post type to use.
-   * @option bool dump-digital-post-settings
-   *     Dump digital post settings.
+   * @option subject
+   *   The subject. Can contain HTML.
+   * @option message
+   *   The message to send. Can contain HTML.
+   * @option digital-post-type
+   *   The digital post type to use.
+   * @option dump-digital-post-settings
+   *   Dump digital post settings.
+   * @option memo-version
+   *   MeMo version (1.1 or 1.2). If not set, a proper default will be used.
+   * @option action
+   *   MeMo actions, e.g. 'action=INFORMATION&label=Vigtig%20information&entrypoint=https://example.com'
+   * @option filename
+   *   The main document filename (used to test invalid filenames (cf. https://digitaliser.dk/digital-post/nyhedsarkiv/2024/nov/oeget-validering-i-digital-post))
    *
    * @phpstan-param array<string> $recipients
    * @phpstan-param array<string, mixed> $options
@@ -66,6 +81,9 @@ public function send(
       'message' => 'This is a test message from os2forms_digital_post sent on [current-date:html_datetime].',
       'digital-post-type' => SF1601::TYPE_AUTOMATISK_VALG,
       'dump-digital-post-settings' => FALSE,
+      'memo-version' => NULL,
+      'action' => [],
+      'filename' => 'os2forms_digital_post',
     ],
   ): void {
     $io = new SymfonyStyle($this->input(), $this->output());
@@ -89,7 +107,7 @@ public function send(
     $document = new Document(
       $content,
       Document::MIME_TYPE_PDF,
-      'os2forms_digital_post.pdf'
+      $options['filename'] . '.pdf',
     );
 
     $type = $options['digital-post-type'];
@@ -98,21 +116,41 @@ public function send(
       throw new InvalidArgumentException(sprintf('Invalid type: %s. Must be one of %s.', $quote($type), implode(', ', array_map($quote, SF1601::TYPES))));
     }
 
+    $meMoVersion = $options['memo-version'];
+    if ($meMoVersion) {
+      $meMoVersion = (float) $meMoVersion;
+      $allowedValues = [SF1601::MEMO_1_1, SF1601::MEMO_1_2];
+      if (!in_array($meMoVersion, $allowedValues, TRUE)) {
+        $quote = static fn($value) => var_export($value, TRUE);
+        throw new InvalidArgumentException(sprintf(
+          'Invalid MeMo version: %s. Must be one of %s.',
+          $quote($meMoVersion),
+          implode(', ', array_map($quote, $allowedValues))
+        ));
+      }
+    }
+
     $io->section('Digital post');
     $io->definitionList(
       ['Type' => $type],
+      ['Document' => sprintf('%s (%s) (sanitized: %s)', $document->filename, $document->mimeType, SF1601::sanitizeFilename($document->filename))],
       ['Subject' => $subject],
-      ['Message' => $message]
+      ['Message' => $message],
+      ['MeMe version' => $meMoVersion],
     );
 
+    $actions = array_map($this->buildAction(...), $options['action']);
+
     foreach ($recipients as $recipient) {
       try {
         $io->writeln(sprintf('Recipient: %s', $recipient));
         $recipientLookupResult = $this->digitalPostHelper->lookupRecipient($recipient);
-        $actions = [];
 
         $meMoMessage = $this->digitalPostHelper->getMeMoHelper()->buildMessage($recipientLookupResult, $senderLabel,
           $messageLabel, $document, $actions);
+        if ($meMoVersion) {
+          $meMoMessage->setMemoVersion($meMoVersion);
+        }
         $forsendelse = $this->digitalPostHelper->getForsendelseHelper()->buildForsendelse($recipientLookupResult,
           $messageLabel, $document);
 
@@ -122,7 +160,7 @@ public function send(
           $forsendelse
         );
 
-        $io->success(sprintf('Digital post sent to %s', $recipient));
+        $io->success(sprintf('Digital post sent to %s (MeMo %s)', $recipient, $meMoMessage->getMemoVersion()));
       }
       catch (\Throwable $throwable) {
         $io->error(sprintf('Error sending digital post to %s:', $recipient));
@@ -158,4 +196,91 @@ private function dumpDigitalPostSettings(SymfonyStyle $io): void {
     ]);
   }
 
+  /**
+   * Build MeMo action.
+   *
+   * Lifted from KombiPostAfsendCommand::buildAction().
+   *
+   * @see KombiPostAfsendCommand::buildAction()
+   */
+  private function buildAction(string $spec): Action {
+    parse_str($spec, $options);
+    $resolver = $this->getActionOptionsResolver();
+    try {
+      $options = $resolver->resolve($options);
+    }
+    catch (ExceptionInterface $exception) {
+      throw new InvalidOptionException(sprintf(
+        'Invalid action %s: %s',
+        json_encode($spec),
+        $exception->getMessage()
+      ));
+    }
+
+    $action = (new Action())
+      ->setActionCode($options['action'])
+      ->setLabel($options['label']);
+    if (SF1601::ACTION_AFTALE === $options['action']) {
+      $reservation = (new Reservation())
+        ->setStartDateTime(new \DateTime('+2 days'))
+        ->setEndDateTime(new \DateTime('+2 days 1 hour'))
+        ->setLocation('Meeting room 1')
+        ->setAbstract('Abstract')
+        ->setDescription('Description')
+        ->setOrganizerName('Organizer')
+        ->setOrganizerMail('[email protected]')
+        ->setReservationUUID(Serializer::createUuid());
+      $action->setReservation($reservation);
+    }
+    elseif ($options['entrypoint']) {
+      $action->setEntryPoint(
+        (new EntryPoint())
+          ->setUrl($options['entrypoint'])
+          );
+    }
+
+    if ($options['endDateTime']) {
+      $action->setEndDateTime(new \DateTime($options['endDateTime']));
+    }
+
+    return $action;
+  }
+
+  /**
+   * Get actions options resolver.
+   *
+   * @see KombiPostAfsendCommand::getActionOptionsResolver()
+   */
+  private function getActionOptionsResolver(): OptionsResolver {
+    $resolver = new OptionsResolver();
+    $resolver
+      ->setRequired([
+        'action',
+        'label',
+      ])
+      ->setDefaults([
+        'endDateTime' => NULL,
+        'entrypoint' => NULL,
+      ])
+      ->setInfo('action', sprintf('The action name (one of %s)', implode(', ', SF1601::ACTIONS)))
+      ->setInfo('label', 'The action label')
+      ->setInfo('endDateTime', 'The end time e.g. "2022-12-02" or "14 days"')
+      ->setInfo('entrypoint', 'The entry point (an URL)')
+      ->setAllowedValues('action', static function ($value) {
+        return in_array($value, SF1601::ACTIONS, TRUE);
+      })
+      ->setNormalizer('entrypoint', static function (Options $options, $value) {
+        if (NULL === $value && SF1601::ACTION_AFTALE !== $options['action']) {
+          throw new InvalidOptionsException(sprintf(
+            'Action entrypoint is required for all actions but %s',
+            SF1601::ACTION_AFTALE
+          ));
+        }
+
+        return $value;
+      });
+
+    return $resolver;
+  }
+
 }