process contract (fixes #6)

src/Event/AbstractProcessEvent.php

@@ -2,27 +2,26 @@
 
 namespace Liuggio\Spawn\Event;
 
-use Liuggio\Spawn\Process\ClosureProcess;
-use Liuggio\Spawn\Process\Process;
+use Liuggio\Spawn\Process\ProcessInterface;
 use Symfony\Component\EventDispatcher\Event;
 
 abstract class AbstractProcessEvent extends Event
 {
     /**
-     * @var ClosureProcess|Process
+     * @var ProcessInterface
      */
     protected $process;
 
     /**
-     * @param ClosureProcess|Process $process
+     * @param ProcessInterface $process
      */
-    public function __construct($process)
+    public function __construct(ProcessInterface $process)
     {
         $this->process = $process;
     }
 
     /**
-     * @return ClosureProcess|Process
+     * @return ProcessInterface
      */
     public function getProcess()
     {

src/Event/ProcessGeneratedBufferEvent.php

@@ -2,27 +2,26 @@
 
 namespace Liuggio\Spawn\Event;
 
-use Liuggio\Spawn\Process\ClosureProcess;
-use Liuggio\Spawn\Process\Process;
+use Liuggio\Spawn\Process\ProcessInterface;
 use Symfony\Component\EventDispatcher\Event;
 
 final class ProcessGeneratedBufferEvent extends Event
 {
     /**
-     * @var Process|ClosureProcess
+     * @var ProcessInterface
      */
     private $process;
 
     /**
-     * @param Process|ClosureProcess $process
+     * @param ProcessInterface $process
      */
-    public function __construct($process)
+    public function __construct(ProcessInterface $process)
     {
         $this->process = $process;
     }
 
     /**
-     * @return Process|ClosureProcess
+     * @return ProcessInterface
      */
     public function getProcess()
     {

src/Process/Channel/Channels.php

@@ -2,7 +2,7 @@
 
 namespace Liuggio\Spawn\Process\Channel;
 
-use Liuggio\Spawn\Process\Process;
+use Liuggio\Spawn\Process\ProcessInterface;
 
 class Channels
 {
@@ -38,10 +38,10 @@ public static function createWaiting($channelsNumber)
     /**
      * Assign a channel to a processes.
      *
-     * @param Channel $channel
-     * @param Process $process
+     * @param Channel          $channel
+     * @param ProcessInterface $process
      */
-    public function assignAProcess(Channel $channel, Process $process)
+    public function assignAProcess(Channel $channel, ProcessInterface $process)
     {
         $this->channels[$channel->getId()] = $channel->assignToAProcess($process);
     }

src/Process/ClosureProcess.php

@@ -6,7 +6,7 @@
 use Liuggio\Spawn\Process\Channel\Channel;
 use Symfony\Component\Process\PhpProcess;
 
-class ClosureProcess extends PhpProcess
+class ClosureProcess extends PhpProcess implements ProcessInterface
 {
     /**
      * @var ProcessEnvironment
@@ -85,7 +85,7 @@ public function getIncrementalNumber()
     }
 
     /**
-     * The channel where the processes is executed.
+     * The channel where the process is executed.
      *
      * @return Channel
      */

src/Process/Process.php

@@ -5,7 +5,7 @@
 use Liuggio\Spawn\CommandLine;
 use Symfony\Component\Process\Process as BaseProcess;
 
-class Process extends BaseProcess
+class Process extends BaseProcess implements ProcessInterface
 {
     /**
      * @var ProcessEnvironment
@@ -52,11 +52,21 @@ public function getCommandLine()
         return new CommandLine(parent::getCommandLine());
     }
 
+    /**
+     * The current Id of the processes.
+     *
+     * @return int
+     */
     public function getIncrementalNumber()
     {
         return $this->processEnvironment->getIncrementalNumber();
     }
 
+    /**
+     * The channel where the process is executed.
+     *
+     * @return Channel
+     */
     public function getChannel()
     {
         return $this->processEnvironment->getChannel();

src/Process/ProcessInterface.php

@@ -0,0 +1,45 @@
+<?php
+
+namespace Liuggio\Spawn\Process;
+
+use Liuggio\Spawn\CommandLine;
+
+interface ProcessInterface
+{
+    /**
+     * @param CommandLine        $commandLine
+     * @param ProcessEnvironment $processEnvironment
+     * @param int|float|null     $timeout
+     * @param string|null        $cwd
+     */
+    public function __construct(
+        CommandLine $commandLine,
+        ProcessEnvironment $processEnvironment,
+        $timeout = null,
+        $cwd = null
+    );
+
+    /**
+     * @return mixed
+     */
+    public function getInputLine();
+
+    /**
+     * @return CommandLine
+     */
+    public function getCommandLine();
+
+    /**
+     * The current Id of the processes.
+     *
+     * @return int
+     */
+    public function getIncrementalNumber();
+
+    /**
+     * The channel where the process is executed.
+     *
+     * @return Channel
+     */
+    public function getChannel();
+}