ICM: File strategy - initial.

Author: dmitry-ivanov

src/Mutex.php

@@ -3,16 +3,21 @@
 namespace Illuminated\Console;
 
 use Illuminate\Console\Command;
+use NinjaMutex\Lock\FlockLock;
+use NinjaMutex\Mutex as Ninja;
+use NinjaMutex\MutexException;
 
 class Mutex
 {
     private $command;
     private $strategy;
+    private $ninja;
 
     public function __construct(Command $command)
     {
         $this->command = $command;
         $this->strategy = $this->strategy();
+        $this->ninja = new Ninja('test', $this->strategy);
     }
 
     private function strategy()
@@ -23,11 +28,25 @@ private function strategy()
 
         switch ($this->command->getMutexStrategy()) {
             case 'mysql':
-                break;
+                throw new MutexException('Strategy `mysql` is not implemented yet.');
+
+            case 'redis':
+                throw new MutexException('Strategy `redis` is not implemented yet.');
+
+            case 'memcache':
+                throw new MutexException('Strategy `memcache` is not implemented yet.');
+
+            case 'memcached':
+                throw new MutexException('Strategy `memcached` is not implemented yet.');
 
             case 'file':
             default:
-                break;
+                return new FlockLock(storage_path('framework'));
         }
     }
+
+    public function __call($method, $parameters)
+    {
+        return call_user_func_array([$this->ninja, $method], $parameters);
+    }
 }

src/WithoutOverlapping.php

@@ -10,8 +10,15 @@ trait WithoutOverlapping
     protected function execute(InputInterface $input, OutputInterface $output)
     {
         $mutex = new Mutex($this);
+        if (!$mutex->acquireLock(0)) {
+            $this->info('Command already running!');
+            return;
+        }
 
-        return parent::execute($input, $output);
+        $code = parent::execute($input, $output);
+        $mutex->releaseLock();
+
+        return $code;
     }
 
     public function getMutexStrategy()