Merge pull request #16 from gyselroth/dev

Dev
gyselroth · Jan 28, 2019 · 3a13e39 · 3a13e39
2 parents 0ff5436 + 2fe7acb
commit 3a13e39
Show file tree

Hide file tree

Showing 26 changed files with 44 additions and 35 deletions.
diff --git a/.php_cs.dist b/.php_cs.dist
@@ -4,7 +4,7 @@ $header = <<<'EOF'
 TaskScheduler
 
 @author      Raffael Sahli <[email protected]>
-@copyright   Copryright (c) 2017-2018 gyselroth GmbH (https://gyselroth.com)
+@copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
 @license     MIT https://opensource.org/licenses/MIT
 EOF;
 

diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,3 +1,10 @@
+## 3.0.2
+**Maintainer**: Raffael Sahli <[email protected]>\
+**Date**: Mon Jan 28 12:18:34 CET 2018
+
+* [CHANGE] Set intial datetime (not 0), writer worker caught exception: 10003 Cannot change the size of a document in a capped collection #15
+
+
 ## 3.0.1
 **Maintainer**: Raffael Sahli <[email protected]>\
 **Date**: Thu Jan 25 17:29:34 CET 2018

diff --git a/src/AbstractJob.php b/src/AbstractJob.php
@@ -6,7 +6,7 @@
  * TaskScheduler
  *
  * @author      Raffael Sahli <[email protected]>
- * @copyright   Copryright (c) 2017-2018 gyselroth GmbH (https://gyselroth.com)
+ * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
  * @license     MIT https://opensource.org/licenses/MIT
  */
 

diff --git a/src/Exception/InternalQueueException.php b/src/Exception/InternalQueueException.php
@@ -6,7 +6,7 @@
  * TaskScheduler
  *
  * @author      Raffael Sahli <[email protected]>
- * @copyright   Copryright (c) 2017-2018 gyselroth GmbH (https://gyselroth.com)
+ * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
  * @license     MIT https://opensource.org/licenses/MIT
  */
 

diff --git a/src/Exception/InvalidArgumentException.php b/src/Exception/InvalidArgumentException.php
@@ -6,7 +6,7 @@
  * TaskScheduler
  *
  * @author      Raffael Sahli <[email protected]>
- * @copyright   Copryright (c) 2017-2018 gyselroth GmbH (https://gyselroth.com)
+ * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
  * @license     MIT https://opensource.org/licenses/MIT
  */
 

diff --git a/src/Exception/InvalidJobException.php b/src/Exception/InvalidJobException.php
@@ -6,7 +6,7 @@
  * TaskScheduler
  *
  * @author      Raffael Sahli <[email protected]>
- * @copyright   Copryright (c) 2017-2018 gyselroth GmbH (https://gyselroth.com)
+ * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
  * @license     MIT https://opensource.org/licenses/MIT
  */
 

diff --git a/src/Exception/JobNotFoundException.php b/src/Exception/JobNotFoundException.php
@@ -6,7 +6,7 @@
  * TaskScheduler
  *
  * @author      Raffael Sahli <[email protected]>
- * @copyright   Copryright (c) 2017-2018 gyselroth GmbH (https://gyselroth.com)
+ * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
  * @license     MIT https://opensource.org/licenses/MIT
  */
 

diff --git a/src/Exception/SpawnForkException.php b/src/Exception/SpawnForkException.php
@@ -6,7 +6,7 @@
  * TaskScheduler
  *
  * @author      Raffael Sahli <[email protected]>
- * @copyright   Copryright (c) 2017-2018 gyselroth GmbH (https://gyselroth.com)
+ * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
  * @license     MIT https://opensource.org/licenses/MIT
  */
 

diff --git a/src/InjectTrait.php b/src/InjectTrait.php
@@ -6,7 +6,7 @@
  * TaskScheduler
  *
  * @author      Raffael Sahli <[email protected]>
- * @copyright   Copryright (c) 2017-2018 gyselroth GmbH (https://gyselroth.com)
+ * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
  * @license     MIT https://opensource.org/licenses/MIT
  */
 

diff --git a/src/JobInterface.php b/src/JobInterface.php
@@ -6,7 +6,7 @@
  * TaskScheduler
  *
  * @author      Raffael Sahli <[email protected]>
- * @copyright   Copryright (c) 2017-2018 gyselroth GmbH (https://gyselroth.com)
+ * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
  * @license     MIT https://opensource.org/licenses/MIT
  */
 
@@ -36,7 +36,6 @@ interface JobInterface
         self::STATUS_TIMEOUT => 'timeout',
     ];
 
-
     /**
      * Get job data.
      */

diff --git a/src/MessageQueue.php b/src/MessageQueue.php
@@ -6,7 +6,7 @@
  * TaskScheduler
  *
  * @author      Raffael Sahli <[email protected]>
- * @copyright   Copryright (c) 2017-2018 gyselroth GmbH (https://gyselroth.com)
+ * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
  * @license     MIT https://opensource.org/licenses/MIT
  */
 

diff --git a/src/Process.php b/src/Process.php
@@ -6,7 +6,7 @@
  * TaskScheduler
  *
  * @author      Raffael Sahli <[email protected]>
- * @copyright   Copryright (c) 2017-2018 gyselroth GmbH (https://gyselroth.com)
+ * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
  * @license     MIT https://opensource.org/licenses/MIT
  */
 

diff --git a/src/Queue.php b/src/Queue.php
@@ -6,7 +6,7 @@
  * TaskScheduler
  *
  * @author      Raffael Sahli <[email protected]>
- * @copyright   Copryright (c) 2017-2018 gyselroth GmbH (https://gyselroth.com)
+ * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
  * @license     MIT https://opensource.org/licenses/MIT
  */
 
@@ -64,7 +64,7 @@ class Queue
     protected $manager_pid;
 
     /**
-     * Sysmfsg queue
+     * Sysmfsg queue.
      *
      * @var resource
      */
@@ -198,7 +198,7 @@ protected function main(): void
                 $this->main();
             });
 
-            if($event !== null) {
+            if (null !== $event) {
                 $this->handleEvent($event);
             }
 

diff --git a/src/Scheduler.php b/src/Scheduler.php
@@ -6,7 +6,7 @@
  * TaskScheduler
  *
  * @author      Raffael Sahli <[email protected]>
- * @copyright   Copryright (c) 2017-2018 gyselroth GmbH (https://gyselroth.com)
+ * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
  * @license     MIT https://opensource.org/licenses/MIT
  */
 
@@ -258,12 +258,13 @@ public function cancelJob(ObjectId $id): bool
     }
 
     /**
-     * Flush
+     * Flush.
      */
     public function flush(): Scheduler
     {
         $this->db->{$this->job_queue}->drop();
         $this->db->{$this->event_queue}->drop();
+
         return $this;
     }
 
@@ -448,8 +449,8 @@ protected function prepareInsert(string $class, $data, array &$options = []): ar
             'class' => $class,
             'status' => JobInterface::STATUS_WAITING,
             'created' => new UTCDateTime(),
-            'started' => new UTCDateTime(0),
-            'ended' => new UTCDateTime(0),
+            'started' => new UTCDateTime(),
+            'ended' => new UTCDateTime(),
             'worker' => new ObjectId(),
             'data' => $data,
         ];

diff --git a/src/SchedulerValidator.php b/src/SchedulerValidator.php
@@ -6,7 +6,7 @@
  * TaskScheduler
  *
  * @author      Raffael Sahli <[email protected]>
- * @copyright   Copryright (c) 2017-2018 gyselroth GmbH (https://gyselroth.com)
+ * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
  * @license     MIT https://opensource.org/licenses/MIT
  */
 

diff --git a/src/Worker.php b/src/Worker.php
@@ -6,7 +6,7 @@
  * TaskScheduler
  *
  * @author      Raffael Sahli <[email protected]>
- * @copyright   Copryright (c) 2017-2018 gyselroth GmbH (https://gyselroth.com)
+ * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
  * @license     MIT https://opensource.org/licenses/MIT
  */
 

diff --git a/src/WorkerFactoryInterface.php b/src/WorkerFactoryInterface.php
@@ -6,7 +6,7 @@
  * TaskScheduler
  *
  * @author      Raffael Sahli <[email protected]>
- * @copyright   Copryright (c) 2017-2018 gyselroth GmbH (https://gyselroth.com)
+ * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
  * @license     MIT https://opensource.org/licenses/MIT
  */
 

diff --git a/src/WorkerManager.php b/src/WorkerManager.php
@@ -6,7 +6,7 @@
  * TaskScheduler
  *
  * @author      Raffael Sahli <[email protected]>
- * @copyright   Copryright (c) 2017-2018 gyselroth GmbH (https://gyselroth.com)
+ * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
  * @license     MIT https://opensource.org/licenses/MIT
  */
 
@@ -113,7 +113,7 @@ class WorkerManager
     protected $onhold = [];
 
     /**
-     * Worker factory
+     * Worker factory.
      *
      * @var WorkerFactoryInterface
      */

diff --git a/tests/JobTest.php b/tests/JobTest.php
@@ -6,7 +6,7 @@
  * TaskScheduler
  *
  * @author      Raffael Sahli <[email protected]>
- * @copyright   Copryright (c) 2017-2018 gyselroth GmbH (https://gyselroth.com)
+ * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
  * @license     MIT https://opensource.org/licenses/MIT
  */
 

diff --git a/tests/MessageQueueTest.php b/tests/MessageQueueTest.php
@@ -6,7 +6,7 @@
  * TaskScheduler
  *
  * @author      Raffael Sahli <[email protected]>
- * @copyright   Copryright (c) 2017-2018 gyselroth GmbH (https://gyselroth.com)
+ * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
  * @license     MIT https://opensource.org/licenses/MIT
  */
 

diff --git a/tests/Mock/ErrorJobMock.php b/tests/Mock/ErrorJobMock.php
@@ -6,7 +6,7 @@
  * TaskScheduler
  *
  * @author      Raffael Sahli <[email protected]>
- * @copyright   Copryright (c) 2017-2018 gyselroth GmbH (https://gyselroth.com)
+ * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
  * @license     MIT https://opensource.org/licenses/MIT
  */
 

diff --git a/tests/Mock/SuccessJobMock.php b/tests/Mock/SuccessJobMock.php
@@ -6,7 +6,7 @@
  * TaskScheduler
  *
  * @author      Raffael Sahli <[email protected]>
- * @copyright   Copryright (c) 2017-2018 gyselroth GmbH (https://gyselroth.com)
+ * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
  * @license     MIT https://opensource.org/licenses/MIT
  */
 

diff --git a/tests/QueueTest.php b/tests/QueueTest.php
@@ -6,7 +6,7 @@
  * TaskScheduler
  *
  * @author      Raffael Sahli <[email protected]>
- * @copyright   Copryright (c) 2017-2018 gyselroth GmbH (https://gyselroth.com)
+ * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
  * @license     MIT https://opensource.org/licenses/MIT
  */
 

diff --git a/tests/SchedulerTest.php b/tests/SchedulerTest.php
@@ -6,7 +6,7 @@
  * TaskScheduler
  *
  * @author      Raffael Sahli <[email protected]>
- * @copyright   Copryright (c) 2017-2018 gyselroth GmbH (https://gyselroth.com)
+ * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
  * @license     MIT https://opensource.org/licenses/MIT
  */
 
@@ -21,6 +21,7 @@
 use TaskScheduler\JobInterface;
 use TaskScheduler\Process;
 use TaskScheduler\Scheduler;
+use MongoDB\BSON\UTCDateTime;
 
 class SchedulerTest extends TestCase
 {
@@ -89,10 +90,11 @@ public function testFlush()
 
     public function testNewJobTimestamps()
     {
+        $ts = new UTCDateTime();
         $job = $this->scheduler->addJob('test', ['foo' => 'bar'])->toArray();
-        $this->assertTrue((string) $job['created'] > '0');
-        $this->assertSame((string) $job['started'], '0');
-        $this->assertSame((string) $job['ended'], '0');
+        $this->assertTrue($job['created'] >= $ts);
+        $this->assertTrue($job['started'] >= $ts);
+        $this->assertTrue($job['ended'] >= $ts);
     }
 
     public function testGetJob()

diff --git a/tests/WorkerManagerTest.php b/tests/WorkerManagerTest.php
@@ -6,7 +6,7 @@
  * TaskScheduler
  *
  * @author      Raffael Sahli <[email protected]>
- * @copyright   Copryright (c) 2017-2018 gyselroth GmbH (https://gyselroth.com)
+ * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
  * @license     MIT https://opensource.org/licenses/MIT
  */
 

diff --git a/tests/WorkerTest.php b/tests/WorkerTest.php
@@ -6,7 +6,7 @@
  * TaskScheduler
  *
  * @author      Raffael Sahli <[email protected]>
- * @copyright   Copryright (c) 2017-2018 gyselroth GmbH (https://gyselroth.com)
+ * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
  * @license     MIT https://opensource.org/licenses/MIT
  */