Added interface for pausing features

detailnet · Feb 17, 2015 · 0e1b8b6 · 0e1b8b6
1 parent 4ea1576
commit 0e1b8b6
Show file tree

Hide file tree

Showing 3 changed files with 36 additions and 5 deletions.
diff --git a/src/Detail/FileConversion/Processing/Adapter/BlitlineAdapter.php b/src/Detail/FileConversion/Processing/Adapter/BlitlineAdapter.php
@@ -103,7 +103,7 @@ public function startProcessing(Task\TaskInterface $task)
             // if Blitline's having server side problems (in case of 5xx errors).
             // Either way, we need to fail...
             throw new Exception\ProcessingFailedException(
-                sprintf('Processing failed immediately after submitting the job: %s',$e->getMessage()),
+                sprintf('Processing failed immediately after submitting the job: %s', $e->getMessage()),
                 0,
                 $e
             );
@@ -145,7 +145,7 @@ public function checkProcessing(Task\TaskInterface $task)
             // if Blitline's having server side problems (in case of 5xx errors).
             // Either way, we need to fail...
             throw new Exception\ProcessingFailedException(
-                sprintf('Processing failed after polling for the completion of the job: %s',$e->getMessage()),
+                sprintf('Processing failed after polling for the completion of the job: %s', $e->getMessage()),
                 0,
                 $e
             );

diff --git a/src/Detail/FileConversion/Processing/PausableTaskProcessorInterface.php b/src/Detail/FileConversion/Processing/PausableTaskProcessorInterface.php
@@ -0,0 +1,29 @@
+<?php
+
+namespace Detail\FileConversion\Processing;
+
+use DateTime;
+
+interface PausableTaskProcessorInterface
+{
+    /**
+     * @param DateTime $until
+     * @return DateTime
+     */
+    public function pauseProcessing(DateTime $until = null);
+
+    /**
+     * @return void
+     */
+    public function resumeProcessing();
+
+    /**
+     * @return DateTime|boolean
+     */
+    public function getPausedUntil();
+
+    /**
+     * @return boolean
+     */
+    public function isPaused();
+}
diff --git a/src/Detail/FileConversion/Processing/TaskProcessor.php b/src/Detail/FileConversion/Processing/TaskProcessor.php
@@ -6,7 +6,8 @@
 use DateTime;
 
 class TaskProcessor implements
-    TaskProcessorInterface
+    TaskProcessorInterface,
+    PausableTaskProcessorInterface
 {
     /**
      * @var AdapterManagerInterface
@@ -96,7 +97,7 @@ public function setPauseOnIncident($pauseOnIncident)
     {
         if (is_string($pauseOnIncident)) {
             $pauseOnIncident = DateInterval::createFromDateString($pauseOnIncident);
-        } else if (!$pauseOnIncident instanceof DateInterval) {
+        } elseif (!$pauseOnIncident instanceof DateInterval) {
             throw new Exception\InvalidArgumentException(
                 '$pauseOnIncident must be a valid date string or DateInterval object'
             );
@@ -248,7 +249,8 @@ protected function getAdapter(Task\TaskInterface $task)
      */
     protected function callAdapter(
         Adapter\AdapterInterface $adapter,
-        $method, array $arguments = array(),
+        $method,
+        array $arguments = array(),
         $considerPaused = true
     ) {
         if ($considerPaused !== false && $this->isPaused()) {