Merge pull request CoderKungfu#29 from miccheng/master

Add Daemon class as part of the core framework.

Author: miccheng

composer.json

@@ -19,10 +19,10 @@
     ],
     "require": {
         "php": ">=5.3.0",
-        "monolog/monolog": "~1.3"
+        "monolog/monolog": "~1.3",
+        "clio/clio": "@stable"
     },
     "require-dev": {
-        "clio/clio": "@stable",
         "mrpoundsign/pheanstalk-5.3": "dev-master",
         "aws/aws-sdk-php": "dev-master",
         "amazonwebservices/aws-sdk-for-php": "dev-master",

src/PHPQueue/Daemon.php

@@ -0,0 +1,108 @@
+<?php
+namespace PHPQueue;
+
+use Clio\Console;
+use Clio\Daemon as D;
+
+abstract class Daemon
+{
+    public $queue_name = null;
+    public $pid_file;
+    public $log_root;
+    public $stdout = '/tmp/stdout.log';
+    public $stderr = '/tmp/stderr.log';
+
+    /**
+     * @param string $pid_file
+     * @param string $log_root
+     */
+    public function __construct($pid_file, $log_root)
+    {
+        $this->pid_file = $pid_file;
+        $this->log_root = $log_root;
+    }
+
+    public function run()
+    {
+        global $argv;
+        if (empty($argv[1]))
+        {
+            Console::output("Unknown action.");
+            die();
+        }
+        if (empty($this->queue_name))
+        {
+            Console::output("Queue is not set.");
+            die();
+        }
+        switch($argv[1])
+        {
+            case 'start':
+                $this->start();
+                break;
+            case 'stop':
+                $this->stop();
+                break;
+            case 'restart':
+                $this->restart();
+                break;
+            default:
+                Console::output("Unknown action.");
+                break;
+        }
+    }
+
+    protected function start()
+    {
+        Console::stdout('Starting... ');
+        try
+        {
+            if (D::isRunning($this->pid_file)) {
+                Console::output('%y[Already Running]%n');
+            } else {
+                $queue = $this->queue_name;
+                $log_path = $this->log_root;
+                D::work(array(
+                          'pid' => $this->pid_file
+                        , 'stdout' => $this->stdout
+                        , 'stderr' => $this->stderr
+                    ),
+                    function($stdin, $stdout, $sterr) use ($queue, $log_path)
+                    {
+                        $runner = new Runner($queue, array('logPath'=>$log_path));
+                        $runner->run();
+                    }
+                );
+                Console::output('%g[OK]%n');
+            }
+        }
+        catch (\Exception $ex)
+        {
+            Console::output('%r[FAILED]%n');
+        }
+    }
+
+    protected function stop()
+    {
+        Console::stdout('Stopping... ');
+        try
+        {
+            if (!D::isRunning($this->pid_file)) {
+                Console::output('%y[Daemon not running]%n');
+            } else {
+                D::kill($this->pid_file, true);
+                Console::output('%g[OK]%n');
+            }
+        }
+        catch (\Exception $ex)
+        {
+            Console::output('%r[FAILED]%n');
+        }
+    }
+
+    protected function restart()
+    {
+        $this->stop();
+        $this->start();
+    }
+} 

src/PHPQueue/Runner.php

@@ -3,7 +3,7 @@
 
 use PHPQueue\Exception\Exception;
 
-abstract class Runner
+class Runner
 {
     const RUN_USLEEP = 1000000;
     /**