Initial Commit

- Adding initial version of the Job library

Signed-off-by: RJ Garcia <rj@bighead.net>

.gitignore

@@ -0,0 +1 @@
+/vendor/

LICENSE

@@ -0,0 +1,20 @@
+The MIT License (MIT)
+
+Copyright (c) 2016 Bighead Technology
+
+Permission is hereby granted, free of charge, to any person obtaining a copy of
+this software and associated documentation files (the "Software"), to deal in
+the Software without restriction, including without limitation the rights to
+use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
+the Software, and to permit persons to whom the Software is furnished to do so,
+subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
+IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
+CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

README.md

@@ -0,0 +1,3 @@
+# Jobs
+
+Simple yet powerful implementation of Queued Jobs built on the krak/mw library.

composer.json

@@ -0,0 +1,24 @@
+{
+    "name": "krak/job",
+    "description": "Simple and Powerful Queued Jobs",
+    "type": "library",
+    "license": "MIT",
+    "authors": [
+        {
+            "name": "RJ Garcia",
+            "email": "rj@bighead.net"
+        }
+    ],
+    "autoload": {
+        "psr-4": {
+            "Krak\\Job\\": "src"
+        },
+        "files": ["src/inc.php"]
+    },
+    "require": {
+        "krak/mw": "^0.1.0",
+        "nikic/iter": "^1.4",
+        "psr/log": "^1.0",
+        "symfony/process": "^2.8"
+    }
+}

src/AbstractPipeline.php

@@ -0,0 +1,32 @@
+<?php
+
+namespace Krak\Job;
+
+use function Krak\Mw\composeMwSet;
+
+/** manages a stack of consumers to form a pipeline. Consumers at the end will be executed first */
+abstract class AbstractPipeline
+{
+    private $middleware;
+
+    public function __construct(array $middleware = []) {
+        $this->middleware = $middleware;
+    }
+    public function push(callable $mw) {
+        array_push($this->middleware, $mw);
+        return $this;
+    }
+    public function unshift(callable $mw) {
+        array_unshift($this->middleware, $mw);
+        return $this;
+    }
+    public function pop() {
+        return array_pop($this->middleware);
+    }
+    public function shift() {
+        return array_shift($this->middleware);
+    }
+    public function compose() {
+        return composeMwSet($this->middleware);
+    }
+}