Improvements (#2007)

* Add delete flag

* Add Command to run mail sync

src/Command/ConsumeMailCommand.php

@@ -0,0 +1,40 @@
+<?php
+
+namespace App\Command;
+
+use App\Message\SyncMenuMessage;
+use Symfony\Component\Console\Attribute\AsCommand;
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Input\InputArgument;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Input\InputOption;
+use Symfony\Component\Console\Output\OutputInterface;
+use Symfony\Component\Console\Style\SymfonyStyle;
+use Symfony\Component\Messenger\MessageBusInterface;
+
+#[AsCommand(
+    name: 'app:consume:mail',
+    description: 'Add a short description for your command',
+)]
+class ConsumeMailCommand extends Command
+{
+    public function __construct(private readonly MessageBusInterface $messageBus)
+    {
+        parent::__construct();
+    }
+
+    protected function configure(): void
+    {
+        $this->addOption('delete', 'd', InputOption::VALUE_NONE, 'Delete all messages');
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output): int
+    {
+        $io = new SymfonyStyle($input, $output);
+        $delete = $input->getOption('delete');
+
+        $this->messageBus->dispatch(new SyncMenuMessage(!!$delete));
+
+        return Command::SUCCESS;
+    }
+}

src/Message/SyncMenuMessage.php

@@ -9,8 +9,8 @@ final class SyncMenuMessage
      * to hold the data for this message class.
      */
 
-    // public function __construct(
-    //     public readonly string $name,
-    // ) {
-    // }
+     public function __construct(
+         public readonly bool $delete = true,
+     ) {
+     }
 }

src/MessageHandler/SyncMenuMessageHandler.php

@@ -178,7 +178,8 @@ public function __invoke(SyncMenuMessage $message): void
                     break;
                 }
                 // delete the mails so the inbox is empty again
-                imap_delete($mbox, $emailId);
+                if ($message->delete)
+                    imap_delete($mbox, $emailId);
             }
         }