Add consumer key to checker

FiveLab · Feb 22, 2024 · ef57c1f · ef57c1f
1 parent a68b185
commit ef57c1f
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 4 deletions.
diff --git a/src/Command/RunConsumerCommand.php b/src/Command/RunConsumerCommand.php
@@ -88,14 +88,14 @@ protected function execute(InputInterface $input, OutputInterface $output): int
 
         if ($input->getOption('dry-run')) {
             $checker = $this->runCheckerRegistry->get($consumerKey);
-            $checker->checkBeforeRun();
+            $checker->checkBeforeRun($consumerKey);
 
             return 0;
         }
 
         try {
             $checker = $this->runCheckerRegistry->get($consumerKey);
-            $checker->checkBeforeRun();
+            $checker->checkBeforeRun($consumerKey);
         } catch (RunConsumerCheckerNotFoundException) {
             // Normal flow. Checker not found.
         }

diff --git a/src/Consumer/Checker/RunConsumerCheckerInterface.php b/src/Consumer/Checker/RunConsumerCheckerInterface.php
@@ -23,7 +23,9 @@ interface RunConsumerCheckerInterface
     /**
      * Call to this method before run consumer.
      *
+     * @param string $consumer
+     *
      * @throws CannotRunConsumerException
      */
-    public function checkBeforeRun(): void;
+    public function checkBeforeRun(string $consumer): void;
 }
diff --git a/tests/Unit/Command/RunConsumerCommandTest.php b/tests/Unit/Command/RunConsumerCommandTest.php
@@ -395,7 +395,9 @@ private function configureChecker(string $key, ?\Throwable $error): void
     {
         $checker = $this->createMock(RunConsumerCheckerInterface::class);
 
-        $matcher = $checker->expects(self::once())->method('checkBeforeRun');
+        $matcher = $checker->expects(self::once())
+            ->method('checkBeforeRun')
+            ->with($key);
 
         if ($error) {
             $matcher->willThrowException($error);