Merge pull request #958 from wheniwork/support_env-adapter_input

Allow console input to be used within adapters

src/Phinx/Migration/Manager.php

@@ -489,6 +489,7 @@ public function getEnvironment($name)
         // create an environment instance and cache it
         $environment = new Environment($name, $this->getConfig()->getEnvironment($name));
         $this->environments[$name] = $environment;
+        $environment->setInput($this->getInput());
         $environment->setOutput($this->getOutput());
 
         return $environment;

src/Phinx/Migration/Manager/Environment.php

@@ -32,6 +32,7 @@
 use Phinx\Db\Adapter\AdapterInterface;
 use Phinx\Migration\MigrationInterface;
 use Phinx\Seed\SeedInterface;
+use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Output\OutputInterface;
 
 class Environment
@@ -46,6 +47,11 @@ class Environment
      */
     protected $options;
 
+    /**
+     * @var InputInterface
+     */
+    protected $input;
+
     /**
      * @var OutputInterface
      */
@@ -196,6 +202,28 @@ public function getOptions()
         return $this->options;
     }
 
+    /**
+     * Sets the console input.
+     *
+     * @param InputInterface $input
+     * @return Environment
+     */
+    public function setInput(InputInterface $input)
+    {
+        $this->input = $input;
+        return $this;
+    }
+
+    /**
+     * Gets the console input.
+     *
+     * @return InputInterface
+     */
+    public function getInput()
+    {
+        return $this->input;
+    }
+
     /**
      * Sets the console output.
      *
@@ -312,6 +340,10 @@ public function getAdapter()
                 ->getWrapper($this->options['wrapper'], $adapter);
         }
 
+        if ($this->getInput()) {
+            $adapter->setInput($this->getInput());
+        }
+
         if ($this->getOutput()) {
             $adapter->setOutput($this->getOutput());
         }

tests/Phinx/Migration/Manager/EnvironmentTest.php

@@ -211,4 +211,11 @@ public function testExecutingAChangeMigrationDown()
 
         $this->environment->executeMigration($migration, MigrationInterface::DOWN);
     }
+
+    public function testGettingInputObject()
+    {
+        $this->environment->setInput($this->getMock('\Symfony\Component\Console\Input\InputInterface'));
+        $inputObject = $this->environment->getInput();
+        $this->assertInstanceOf('\Symfony\Component\Console\Input\InputInterface', $inputObject);
+    }
 }