Merge pull request #148 from prooph/fix_date_interval_issue

Calculate seconds and initialize interval with it
prooph · Apr 30, 2018 · 9bd496e · 9bd496e
2 parents bce4c40 + dd0c300
commit 9bd496e
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 6 deletions.
diff --git a/src/Projection/PdoEventStoreProjector.php b/src/Projection/PdoEventStoreProjector.php
@@ -962,10 +962,12 @@ private function shouldUpdateLock(DateTimeImmutable $now): bool
             return true;
         }
 
-        //Create a 0 interval
-        $updateLockThreshold = new \DateInterval('PT0S');
+        $intervalSeconds = floor($this->updateLockThreshold / 1000);
+
+        //Create an interval based on seconds
+        $updateLockThreshold = new \DateInterval("PT{$intervalSeconds}S");
         //and manually add split seconds
-        $updateLockThreshold->f = $this->updateLockThreshold / 1000;
+        $updateLockThreshold->f = ($this->updateLockThreshold % 1000) / 1000;
 
         $threshold = $this->lastLockUpdate->add($updateLockThreshold);
 

diff --git a/src/Projection/PdoEventStoreReadModelProjector.php b/src/Projection/PdoEventStoreReadModelProjector.php
@@ -909,10 +909,12 @@ private function shouldUpdateLock(DateTimeImmutable $now): bool
             return true;
         }
 
-        //Create a 0 interval
-        $updateLockThreshold = new \DateInterval('PT0S');
+        $intervalSeconds = floor($this->updateLockThreshold / 1000);
+
+        //Create an interval based on seconds
+        $updateLockThreshold = new \DateInterval("PT{$intervalSeconds}S");
         //and manually add split seconds
-        $updateLockThreshold->f = $this->updateLockThreshold / 1000;
+        $updateLockThreshold->f = ($this->updateLockThreshold % 1000) / 1000;
 
         $threshold = $this->lastLockUpdate->add($updateLockThreshold);