Adding a really basic example implementation

Finally have the (extremely) basic version working
justinrainbow · Jul 22, 2012 · 5c2ffca · 5c2ffca
1 parent b482871
commit 5c2ffca
Show file tree

Hide file tree

Showing 5 changed files with 88 additions and 8 deletions.
diff --git a/example/Presque/Example/SimpleJob.php b/example/Presque/Example/SimpleJob.php
@@ -0,0 +1,15 @@
+<?php
+
+namespace Presque\Example;
+
+class SimpleJob
+{
+    public function perform($path)
+    {
+        file_put_contents(
+            $path,
+            sprintf('Run at %s!', date('Y-m-d H:i:s')) . PHP_EOL,
+            FILE_APPEND
+        );
+    }
+}
diff --git a/example/cli.php b/example/cli.php
@@ -0,0 +1,20 @@
+#!/usr/bin/env php
+<?php
+
+$loader = require_once __DIR__.'/../vendor/autoload.php';
+$loader->add('Presque\\Example', __DIR__);
+
+$connection = new Predis\Client('tcp://maureen.local:6379');
+
+$storage = new Presque\Storage\PredisStorage($connection, 'presque');
+
+$queue = new Presque\Queue('example', $storage);
+
+$worker = new Presque\Worker();
+$worker->addQueue($queue);
+
+if (count($argv) > 1) {
+	$queue->enqueue(Presque\Job::create('Presque\Example\SimpleJob', array($argv[1])));
+} else {
+	$worker->start();
+}
diff --git a/src/Presque/Storage/PredisStorage.php b/src/Presque/Storage/PredisStorage.php
@@ -32,6 +32,10 @@ public function push($listName, $payload)
     public function pop($listName, $waitTimeout = null)
     {
         if ($payload = $this->connection->blpop($this->getKey($listName), $waitTimeout)) {
+            if (is_array($payload)) {
+                return json_decode($payload[1], true);
+            }
+
             return json_decode($payload, true);
         }
 

diff --git a/src/Presque/Worker.php b/src/Presque/Worker.php
@@ -17,8 +17,9 @@ class Worker implements WorkerInterface
 {
     private $id;
     private $queues;
+    private $status;
 
-    public function __construct($id)
+    public function __construct($id = null)
     {
         $this->id = $id;
     }
@@ -45,6 +46,31 @@ public function getQueues()
         return $this->queues;
     }
 
+    public function setEventDispatcher(EventDispatcherInterface $eventDispatcher = null)
+    {
+        $this->eventDispatcher = $eventDispatcher;
+    }
+
+    public function getEventDispatcher()
+    {
+        return $this->eventDispatcher;
+    }
+
+    public function hasEventDispatcher()
+    {
+        return null !== $this->eventDispatcher;
+    }
+
+    public function setStatus($status)
+    {
+        $this->status = $status;
+    }
+
+    public function getStatus()
+    {
+        return $this->status;
+    }
+
     public function isRunning()
     {
         return $this->getStatus() === StatusInterface::RUNNING;
@@ -55,6 +81,13 @@ public function isDying()
         return $this->getStatus() === StatusInterface::DYING;
     }
 
+    public function start()
+    {
+        $this->setStatus(StatusInterface::RUNNING);
+
+        $this->run();
+    }
+
     public function run()
     {
         while ($this->isRunning()) {
@@ -70,6 +103,20 @@ public function run()
 
     protected function process(QueueInterface $queue)
     {
+        $job = $queue->reserve();
 
+        if (!$job instanceof JobInterface) {
+            return;
+        }
+
+        $job->perform();
+
+        if ($job->isSuccessful()) {
+            return;
+        }
+
+        if ($job->isError()) {
+
+        }
     }
 }
diff --git a/src/Presque/WorkerInterface.php b/src/Presque/WorkerInterface.php
@@ -25,11 +25,5 @@ function isRunning();
 
 	function isDying();
 
-    function start();
-
-    function pause();
-
-    function stop();
-
-    function abort();
+	function run();
 }