Merge pull request #14 from netlogix/feat/add-polling-configuration

Author: paxuclus

Classes/Controller/StatusController.php

@@ -7,6 +7,7 @@
 use Neos\Flow\Mvc\Controller\ActionController;
 use Netlogix\Neos\AsyncWorkspaceActions\Domain\Model\Job;
 use Netlogix\Neos\AsyncWorkspaceActions\Domain\Repository\JobRepository;
+use function usleep;
 
 class StatusController extends ActionController
 {
@@ -17,14 +18,25 @@ class StatusController extends ActionController
      */
     protected $jobRepository;
 
-    public function pollAction(Job $job): void
+    /**
+     * @var array
+     * @Flow\InjectConfiguration(path="polling")
+     */
+    protected array $pollingConfiguration = [];
+
+    public function pollAction(Job $job, int $count = 1): void
     {
         if ($job->getStatus() !== Job::STATUS_DONE) {
-            sleep(5);
-            $this->redirect('poll', null, null, ['job' => $job]);
+            $this->sleep($count);
+            $this->redirect('poll', null, null, [
+                'job' => $job,
+                'count' => ++$count
+            ]);
         }
 
-        $this->redirect('done', null, null, ['job' => $job]);
+        $this->redirect('done', null, null, [
+            'job' => $job
+        ]);
     }
 
     public function doneAction(Job $job): string
@@ -37,4 +49,16 @@ public function doneAction(Job $job): string
         return json_encode($feedback, JSON_PRETTY_PRINT);
     }
 
+    private function sleep(int $retry): void
+    {
+        $retryInterval = ($this->pollingConfiguration['retryInterval'] ?? 5);
+        if ($this->pollingConfiguration['exponentialBackoff'] ?? false) {
+            $backoff = ($this->pollingConfiguration['factor'] ?? 2) ** ($retry - 1) * $retryInterval;
+        } else {
+            $backoff = $retryInterval;
+        }
+        $sleeping = (int) ($backoff * 1000 * 1000);
+        usleep($sleeping);
+    }
+
 }

Configuration/Routes.yaml

@@ -17,3 +17,4 @@
     '@action':     'poll'
     '@format':     'json'
   httpMethods: ['GET']
+  appendExceedingArguments: true

Configuration/Settings.Threshold.yaml

@@ -0,0 +1,13 @@
+Netlogix:
+  Neos:
+    AsyncWorkspaceActions:
+      # Amount of nodes required to publish or discard asynchronously
+      nodeThreshold: 100
+
+      polling:
+        # Amount of seconds to wait between retries
+        retryInterval: 5
+        # Use exponential backoff
+        exponentialBackoff: false
+        # Exponential backoff factor
+        factor: 2