Give command handlers the ability to save and restore their state bef…

…ore injecting input / output objects. Do not inject into objects that do not do this.
consolidation · Aug 28, 2020 · ddb522e · ddb522e
1 parent 4f7a58b
commit ddb522e
Show file tree

Hide file tree

Showing 11 changed files with 155 additions and 84 deletions.
diff --git a/src/AnnotatedCommand.php b/src/AnnotatedCommand.php
@@ -6,6 +6,8 @@
 use Consolidation\AnnotatedCommand\Hooks\HookManager;
 use Consolidation\AnnotatedCommand\Output\OutputAwareInterface;
 use Consolidation\AnnotatedCommand\Parser\CommandInfo;
+use Consolidation\AnnotatedCommand\State\State;
+use Consolidation\AnnotatedCommand\State\StateHelper;
 use Symfony\Component\Console\Command\Command;
 use Symfony\Component\Console\Input\InputArgument;
 use Symfony\Component\Console\Input\InputAwareInterface;
@@ -276,7 +278,6 @@ public function optionsHookForHookAnnotations($commandInfoList)
      */
     protected function interact(InputInterface $input, OutputInterface $output)
     {
-        $this->injectIntoCommandfileInstance($input, $output);
         $this->commandProcessor()->interact(
             $input,
             $output,
@@ -287,7 +288,6 @@ protected function interact(InputInterface $input, OutputInterface $output)
 
     protected function initialize(InputInterface $input, OutputInterface $output)
     {
-        $this->injectIntoCommandfileInstance($input, $output);
         // Allow the hook manager a chance to provide configuration values,
         // if there are any registered hooks to do that.
         $this->commandProcessor()->initializeHook($input, $this->getNames(), $this->annotationData);
@@ -298,7 +298,6 @@ protected function initialize(InputInterface $input, OutputInterface $output)
      */
     protected function execute(InputInterface $input, OutputInterface $output)
     {
-        $this->injectIntoCommandfileInstance($input, $output);
         // Validate, run, process, alter, handle results.
         return $this->commandProcessor()->process(
             $output,
@@ -316,7 +315,6 @@ protected function execute(InputInterface $input, OutputInterface $output)
      */
     public function processResults(InputInterface $input, OutputInterface $output, $results)
     {
-        $this->injectIntoCommandfileInstance($input, $output);
         $commandData = $this->createCommandData($input, $output);
         $commandProcessor = $this->commandProcessor();
         $names = $this->getNames();
@@ -353,15 +351,4 @@ protected function createCommandData(InputInterface $input, OutputInterface $out
 
         return $commandData;
     }
-
-    /**
-     * Inject $input and $output into the command instance if it is set up to receive them.
-     *
-     * @param callable $commandCallback
-     * @param CommandData $commandData
-     */
-    public function injectIntoCommandfileInstance(InputInterface $input, OutputInterface $output)
-    {
-        InjectionHelper::injectIntoCallbackObject($this->commandCallback, $input, $output);
-    }
 }
diff --git a/src/Hooks/Dispatchers/CommandEventHookDispatcher.php b/src/Hooks/Dispatchers/CommandEventHookDispatcher.php
@@ -4,7 +4,8 @@
 
 use Consolidation\AnnotatedCommand\AnnotatedCommand;
 use Consolidation\AnnotatedCommand\Hooks\HookManager;
-use Consolidation\AnnotatedCommand\InjectionHelper;
+use Consolidation\AnnotatedCommand\State\State;
+use Consolidation\AnnotatedCommand\State\StateHelper;
 use Symfony\Component\Console\Command\Command;
 use Symfony\Component\Console\ConsoleEvents;
 use Symfony\Component\Console\Event\ConsoleCommandEvent;
@@ -21,14 +22,9 @@ class CommandEventHookDispatcher extends HookDispatcher
      */
     public function callCommandEventHooks(ConsoleCommandEvent $event)
     {
-        $command = $event->getCommand();
         $input = $event->getInput();
         $output = $event->getOutput();
 
-        if ($command instanceof AnnotatedCommand) {
-            $command->injectIntoCommandfileInstance($input, $output);
-        }
-
         $hooks = [
             HookManager::PRE_COMMAND_EVENT,
             HookManager::COMMAND_EVENT,
@@ -40,8 +36,9 @@ public function callCommandEventHooks(ConsoleCommandEvent $event)
                 $commandEvent->dispatch($event, ConsoleEvents::COMMAND);
             }
             if (is_callable($commandEvent)) {
-                InjectionHelper::injectIntoCallbackObject($commandEvent, $input, $output);
+                $state = StateHelper::injectIntoCallbackObject($commandEvent, $input, $output);
                 $commandEvent($event);
+                $state->restore();
             }
         }
     }

diff --git a/src/Hooks/Dispatchers/InitializeHookDispatcher.php b/src/Hooks/Dispatchers/InitializeHookDispatcher.php
@@ -5,7 +5,8 @@
 use Consolidation\AnnotatedCommand\AnnotationData;
 use Consolidation\AnnotatedCommand\Hooks\HookManager;
 use Consolidation\AnnotatedCommand\Hooks\InitializeHookInterface;
-use Consolidation\AnnotatedCommand\InjectionHelper;
+use Consolidation\AnnotatedCommand\State\State;
+use Consolidation\AnnotatedCommand\State\StateHelper;
 use Symfony\Component\Console\Command\Command;
 use Symfony\Component\Console\Input\InputInterface;
 
@@ -31,7 +32,14 @@ public function initialize(
 
     protected function callInitializeHook($provider, $input, AnnotationData $annotationData)
     {
-        InjectionHelper::injectIntoCallbackObject($provider, $input);
+        $state = StateHelper::injectIntoCallbackObject($provider, $input);
+        $result = $this->doInitializeHook($provider, $input, $annotationData);
+        $state->restore();
+        return $result;
+    }
+
+    private function doInitializeHook($provider, $input, AnnotationData $annotationData)
+    {
         if ($provider instanceof InitializeHookInterface) {
             return $provider->initialize($input, $annotationData);
         }

diff --git a/src/Hooks/Dispatchers/InteractHookDispatcher.php b/src/Hooks/Dispatchers/InteractHookDispatcher.php
@@ -5,7 +5,8 @@
 use Consolidation\AnnotatedCommand\AnnotationData;
 use Consolidation\AnnotatedCommand\Hooks\HookManager;
 use Consolidation\AnnotatedCommand\Hooks\InteractorInterface;
-use Consolidation\AnnotatedCommand\InjectionHelper;
+use Consolidation\AnnotatedCommand\State\State;
+use Consolidation\AnnotatedCommand\State\StateHelper;
 use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Output\OutputInterface;
 
@@ -32,7 +33,14 @@ public function interact(
 
     protected function callInteractor($interactor, $input, $output, AnnotationData $annotationData)
     {
-        InjectionHelper::injectIntoCallbackObject($interactor, $input, $output);
+        $state = StateHelper::injectIntoCallbackObject($interactor, $input, $output);
+        $result = $this->doInteractor($interactor, $input, $output, $annotationData);
+        $state->restore();
+        return $result;
+    }
+
+    private function doInteractor($interactor, $input, $output, AnnotationData $annotationData)
+    {
         if ($interactor instanceof InteractorInterface) {
             return $interactor->interact($input, $output, $annotationData);
         }

diff --git a/src/Hooks/Dispatchers/ProcessResultHookDispatcher.php b/src/Hooks/Dispatchers/ProcessResultHookDispatcher.php
@@ -6,7 +6,8 @@
 use Consolidation\AnnotatedCommand\CommandData;
 use Consolidation\AnnotatedCommand\Hooks\HookManager;
 use Consolidation\AnnotatedCommand\Hooks\ProcessResultInterface;
-use Consolidation\AnnotatedCommand\InjectionHelper;
+use Consolidation\AnnotatedCommand\State\State;
+use Consolidation\AnnotatedCommand\State\StateHelper;
 
 /**
  * Call hooks
@@ -39,7 +40,14 @@ public function process($result, CommandData $commandData)
 
     protected function callProcessor($processor, $result, CommandData $commandData)
     {
-        InjectionHelper::injectIntoCallbackObject($processor, $commandData->input(), $commandData->output());
+        $state = StateHelper::injectIntoCallbackObject($processor, $commandData->input(), $commandData->output());
+        $result = $this->doProcessor($processor, $result, $commandData);
+        $state->restore();
+        return $result;
+    }
+
+    private function doProcessor($processor, $result, CommandData $commandData)
+    {
         $processed = null;
         if ($processor instanceof ProcessResultInterface) {
             $processed = $processor->process($result, $commandData);

diff --git a/src/Hooks/Dispatchers/ValidateHookDispatcher.php b/src/Hooks/Dispatchers/ValidateHookDispatcher.php
@@ -7,7 +7,8 @@
 use Consolidation\AnnotatedCommand\CommandError;
 use Consolidation\AnnotatedCommand\Hooks\HookManager;
 use Consolidation\AnnotatedCommand\Hooks\ValidatorInterface;
-use Consolidation\AnnotatedCommand\InjectionHelper;
+use Consolidation\AnnotatedCommand\State\State;
+use Consolidation\AnnotatedCommand\State\StateHelper;
 
 /**
  * Call hooks
@@ -37,7 +38,14 @@ public function validate(CommandData $commandData)
 
     protected function callValidator($validator, CommandData $commandData)
     {
-        InjectionHelper::injectIntoCallbackObject($validator, $commandData->input(), $commandData->output());
+        $state = StateHelper::injectIntoCallbackObject($validator, $commandData->input(), $commandData->output());
+        $result = $this->doValidator($validator, $commandData);
+        $state->restore();
+        return $result;
+    }
+
+    private function doValidator($validator, CommandData $commandData)
+    {
         if ($validator instanceof ValidatorInterface) {
             return $validator->validate($commandData);
         }

diff --git a/src/InjectionHelper.php b/src/InjectionHelper.php
diff --git a/src/State.php b/src/State.php
@@ -0,0 +1,10 @@
+<?php
+namespace Consolidation\AnnotatedCommand;
+
+interface State
+{
+    /**
+     * Restore state to a previously cached value.
+     */
+    public function restore();
+}
diff --git a/src/State/SavableState.php b/src/State/SavableState.php
@@ -0,0 +1,12 @@
+<?php
+namespace Consolidation\AnnotatedCommand\State;
+
+interface SavableState
+{
+    /**
+     * Return the current state of this object.
+     *
+     * @return State
+     */
+    public function currentState();
+}
diff --git a/src/State/State.php b/src/State/State.php
@@ -0,0 +1,10 @@
+<?php
+namespace Consolidation\AnnotatedCommand\State;
+
+interface State
+{
+    /**
+     * Restore state to a previously cached value.
+     */
+    public function restore();
+}
diff --git a/src/State/StateHelper.php b/src/State/StateHelper.php
@@ -0,0 +1,77 @@
+<?php
+namespace Consolidation\AnnotatedCommand\State;
+
+use Consolidation\AnnotatedCommand\Output\OutputAwareInterface;
+use Consolidation\AnnotatedCommand\State\SavableState;
+use Consolidation\AnnotatedCommand\State\State;
+use Symfony\Component\Console\Input\InputAwareInterface;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+
+class StateHelper
+{
+    /**
+     * Inject $input and $output into the command instance if it is set up to receive them.
+     *
+     * @param Callable|object $callback
+     * @param OutputInterface $output
+     * @return State
+     */
+    public static function injectIntoCallbackObject($callback, InputInterface $input, OutputInterface $output = null)
+    {
+        return static::inject(static::recoverCallbackObject($callback), $input, $output);
+    }
+
+    /**
+     * Inject $input and $output into the command instance if it is set up to receive them.
+     *
+     * @param Callable|object $callback
+     * @param OutputInterface $output
+     * @return State
+     */
+    public static function inject($target, InputInterface $input, OutputInterface $output = null)
+    {
+        // Do not allow injection unless the target can save its state
+        if (!$target || !($target instanceof SavableState)) {
+            return new class implements State {
+                public function restore()
+                {
+                }
+            };
+        }
+
+        $state = $target->currentState();
+
+        if ($target instanceof InputAwareInterface) {
+            $target->setInput($input);
+        }
+        if (isset($output) && $target instanceof OutputAwareInterface) {
+            $target->setOutput($output);
+        }
+
+        return $state;
+    }
+
+    /**
+     * If the command callback is a method of an object, return the object.
+     *
+     * @param Callable|object $callback
+     * @return object|bool
+     */
+    protected static function recoverCallbackObject($callback)
+    {
+        if (is_object($callback)) {
+            return $callback;
+        }
+
+        if (!is_array($callback)) {
+            return false;
+        }
+
+        if (!is_object($callback[0])) {
+            return false;
+        }
+
+        return $callback[0];
+    }
+}