Skip to content

Commit

Permalink
feat: add ProcessWatchlists command
Browse files Browse the repository at this point in the history
  • Loading branch information
maelgangloff committed Aug 3, 2024
1 parent 44898eb commit cd030bd
Showing 1 changed file with 42 additions and 0 deletions.
42 changes: 42 additions & 0 deletions src/Command/ProcessWatchlistsCommand.php
Original file line number Diff line number Diff line change
@@ -0,0 +1,42 @@
<?php

namespace App\Command;

use App\Message\ProcessWatchListsTrigger;
use Symfony\Component\Console\Attribute\AsCommand;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Style\SymfonyStyle;
use Symfony\Component\Messenger\Exception\ExceptionInterface;
use Symfony\Component\Messenger\MessageBusInterface;

#[AsCommand(
name: 'app:process-watchlists',
description: 'Process watchlists and send emails if necessary',
)]
class ProcessWatchlistsCommand extends Command
{
public function __construct(private readonly MessageBusInterface $bus)
{
parent::__construct();
}

protected function configure(): void
{
}

/**
* @throws ExceptionInterface
*/
protected function execute(InputInterface $input, OutputInterface $output): int
{
$io = new SymfonyStyle($input, $output);

$this->bus->dispatch(new ProcessWatchListsTrigger());

$io->success('Watchlist processing triggered!');

return Command::SUCCESS;
}
}

0 comments on commit cd030bd

Please sign in to comment.