From 01e69dc0de8729888ff8662f8ed4287151f382c2 Mon Sep 17 00:00:00 2001
From: Kris Wallsmith <kris.wallsmith@gmail.com>
Date: Mon, 18 May 2015 12:15:58 -0700
Subject: [PATCH] added factory

---
 src/Spork/Factory.php        | 59 ++++++++++++++++++++++++++++++++++++
 src/Spork/ProcessManager.php | 13 ++++----
 2 files changed, 66 insertions(+), 6 deletions(-)
 create mode 100644 src/Spork/Factory.php

diff --git a/src/Spork/Factory.php b/src/Spork/Factory.php
new file mode 100644
index 0000000..f951022
--- /dev/null
+++ b/src/Spork/Factory.php
@@ -0,0 +1,59 @@
+<?php
+
+/*
+ * This file is part of Spork, an OpenSky project.
+ *
+ * (c) OpenSky Project Inc
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Spork;
+
+use Spork\Batch\BatchJob;
+use Spork\Batch\Strategy\StrategyInterface;
+
+class Factory
+{
+    /**
+     * Creates a new batch job instance.
+     *
+     * @param ProcessManager    $manager  The process manager
+     * @param null              $data     Data for the batch job
+     * @param StrategyInterface $strategy The strategy
+     *
+     * @return BatchJob A new batch job instance
+     */
+    public function createBatchJob(ProcessManager $manager, $data = null, StrategyInterface $strategy = null)
+    {
+        return new BatchJob($manager, $data, $strategy);
+    }
+
+    /**
+     * Creates a new shared memory instance.
+     *
+     * @param integer $pid    The child process id or null if this is the child
+     * @param integer $signal The signal to send after writing to shared memory
+     *
+     * @return SharedMemory A new shared memory instance
+     */
+    public function createSharedMemory($pid = null, $signal = null)
+    {
+        return new SharedMemory($pid, $signal);
+    }
+
+    /**
+     * Creates a new fork instance.
+     *
+     * @param int          $pid   Process id
+     * @param SharedMemory $shm   Shared memory
+     * @param bool         $debug Debug mode
+     *
+     * @return Fork A new fork instance
+     */
+    public function createFork($pid, SharedMemory $shm, $debug = false)
+    {
+        return new Fork($pid, $shm, $debug);
+    }
+}
diff --git a/src/Spork/ProcessManager.php b/src/Spork/ProcessManager.php
index 6bf8143..663c5a8 100644
--- a/src/Spork/ProcessManager.php
+++ b/src/Spork/ProcessManager.php
@@ -11,7 +11,6 @@
 
 namespace Spork;
 
-use Spork\Batch\BatchJob;
 use Spork\Batch\Strategy\StrategyInterface;
 use Spork\EventDispatcher\EventDispatcher;
 use Spork\EventDispatcher\EventDispatcherInterface;
@@ -24,6 +23,7 @@
 class ProcessManager
 {
     private $dispatcher;
+    private $factory;
     private $debug;
     private $zombieOkay;
     private $signal;
@@ -31,9 +31,10 @@ class ProcessManager
     /** @var Fork[] */
     private $forks;
 
-    public function __construct(EventDispatcherInterface $dispatcher = null, $debug = false)
+    public function __construct(EventDispatcherInterface $dispatcher = null, Factory $factory = null, $debug = false)
     {
         $this->dispatcher = $dispatcher ?: new EventDispatcher();
+        $this->factory = $factory ?: new Factory();
         $this->debug = $debug;
         $this->zombieOkay = false;
         $this->forks = array();
@@ -72,7 +73,7 @@ public function zombieOkay($zombieOkay = true)
 
     public function createBatchJob($data = null, StrategyInterface $strategy = null)
     {
-        return new BatchJob($this, $data, $strategy);
+        return $this->factory->createBatchJob($this, $data, $strategy);
     }
 
     public function process($data, $callable, StrategyInterface $strategy = null)
@@ -101,7 +102,7 @@ public function fork($callable)
             $this->forks = array();
 
             // setup the shared memory
-            $shm = new SharedMemory(null, $this->signal);
+            $shm = $this->factory->createSharedMemory(null, $this->signal);
             $message = new ExitMessage();
 
             // phone home on shutdown
@@ -146,9 +147,9 @@ public function fork($callable)
         }
 
         // connect to shared memory
-        $shm = new SharedMemory($pid);
+        $shm = $this->factory->createSharedMemory($pid);
 
-        return $this->forks[$pid] = new Fork($pid, $shm, $this->debug);
+        return $this->forks[$pid] = $this->factory->createFork($pid, $shm, $this->debug);
     }
 
     public function monitor($signal = SIGUSR1)