@@ -111,7 +111,7 @@ discard block |
||
111 | 111 | { |
112 | 112 | $queueName = 'test'; |
113 | 113 | $queue = $this->getMockBuilder(MongoQueue::class)->disableOriginalConstructor() |
114 | - ->setMethods(['listing'])->getMock(); |
|
114 | + ->setMethods(['listing'])->getMock(); |
|
115 | 115 | $this->queueManager->expects($this->once())->method('get')->with($queueName)->willReturn($queue); |
116 | 116 | $params = $this->setupParamsMock([ |
117 | 117 | ['queue', null, $queueName], |
@@ -135,13 +135,13 @@ discard block |
||
135 | 135 | $date = new \DateTime(); |
136 | 136 | $date->setTimezone(new \DateTimeZone('UTC')); |
137 | 137 | $jobs = [ |
138 | - [ |
|
139 | - 'job' => $job, |
|
140 | - 'created' => new \MongoDb\BSON\UTCDateTime($date->getTimestamp() * 1000), |
|
141 | - 'executed' => new \MongoDb\BSON\UTCDateTime($date->getTimestamp() * 1000), |
|
142 | - 'scheduled' => new \MongoDb\BSON\UTCDateTime($date->getTimestamp() * 1000), |
|
143 | - 'tried' => 10, |
|
144 | - ], |
|
138 | + [ |
|
139 | + 'job' => $job, |
|
140 | + 'created' => new \MongoDb\BSON\UTCDateTime($date->getTimestamp() * 1000), |
|
141 | + 'executed' => new \MongoDb\BSON\UTCDateTime($date->getTimestamp() * 1000), |
|
142 | + 'scheduled' => new \MongoDb\BSON\UTCDateTime($date->getTimestamp() * 1000), |
|
143 | + 'tried' => 10, |
|
144 | + ], |
|
145 | 145 | ]; |
146 | 146 | |
147 | 147 | $queue->expects($this->once())->method('listing')->with(['limit' => 10, 'status' => 1])->willReturn($jobs); |
@@ -44,7 +44,7 @@ discard block |
||
44 | 44 | ], |
45 | 45 | ]; |
46 | 46 | |
47 | - private $inheritance = [ AbstractConsoleController::class ]; |
|
47 | + private $inheritance = [AbstractConsoleController::class]; |
|
48 | 48 | |
49 | 49 | private function injectConstructorDependencies() |
50 | 50 | { |
@@ -149,11 +149,11 @@ discard block |
||
149 | 149 | $lineTmpl = '%-20s %s'; |
150 | 150 | $console = $this->target->getConsole(); |
151 | 151 | $console->expects($this->exactly(7))->method('writeLine')->withConsecutive( |
152 | - [ get_class($job) . ' [ test ]' ], |
|
153 | - [ sprintf($lineTmpl, 'Created', $date->format('Y-m-d H:i:s')) ], |
|
154 | - [ sprintf($lineTmpl, 'Executed', $date->format('Y-m-d H:i:s')) ], |
|
155 | - [ sprintf($lineTmpl, 'Scheduled', $date->format('Y-m-d H:i:s')) ], |
|
156 | - [ sprintf($lineTmpl, 'Tries', $jobs[0]['tried']) ] |
|
152 | + [get_class($job).' [ test ]'], |
|
153 | + [sprintf($lineTmpl, 'Created', $date->format('Y-m-d H:i:s'))], |
|
154 | + [sprintf($lineTmpl, 'Executed', $date->format('Y-m-d H:i:s'))], |
|
155 | + [sprintf($lineTmpl, 'Scheduled', $date->format('Y-m-d H:i:s'))], |
|
156 | + [sprintf($lineTmpl, 'Tries', $jobs[0]['tried'])] |
|
157 | 157 | )->willReturn(null); |
158 | 158 | |
159 | 159 | $this->assertEmpty($this->target->listAction()); |
@@ -27,7 +27,7 @@ |
||
27 | 27 | |
28 | 28 | private $target = ProcessId::class; |
29 | 29 | |
30 | - private $inheritance = [ ProcessorInterface::class ]; |
|
30 | + private $inheritance = [ProcessorInterface::class]; |
|
31 | 31 | |
32 | 32 | public function testProcessAddsProcessIdToEventArray() |
33 | 33 | { |
@@ -76,25 +76,25 @@ |
||
76 | 76 | 'log' => array( |
77 | 77 | 'Core/Log' => array( |
78 | 78 | 'writers' => array( |
79 | - array( |
|
80 | - 'name' => 'stream', |
|
79 | + array( |
|
80 | + 'name' => 'stream', |
|
81 | 81 | 'priority' => 1000, |
82 | 82 | 'options' => array( |
83 | - 'stream' => getcwd().'/var/log/yawik.log', |
|
83 | + 'stream' => getcwd().'/var/log/yawik.log', |
|
84 | + ), |
|
84 | 85 | ), |
85 | - ), |
|
86 | 86 | ), |
87 | 87 | ), |
88 | 88 | 'Log/Core/Mail' => array( |
89 | 89 | 'writers' => array( |
90 | - array( |
|
91 | - 'name' => 'stream', |
|
90 | + array( |
|
91 | + 'name' => 'stream', |
|
92 | 92 | 'priority' => 1000, |
93 | 93 | 'options' => array( |
94 | - 'stream' => getcwd().'/var/log/mails.log', |
|
94 | + 'stream' => getcwd().'/var/log/mails.log', |
|
95 | 95 | ), |
96 | 96 | |
97 | - ), |
|
97 | + ), |
|
98 | 98 | ), |
99 | 99 | ), |
100 | 100 | 'Log/Core/Queue' => array( |
@@ -24,7 +24,7 @@ discard block |
||
24 | 24 | use Core\Service\Tracy; |
25 | 25 | use Laminas\I18n\Translator\Resources; |
26 | 26 | |
27 | -$doctrineConfig = include __DIR__ . '/doctrine.config.php'; |
|
27 | +$doctrineConfig = include __DIR__.'/doctrine.config.php'; |
|
28 | 28 | |
29 | 29 | |
30 | 30 | return array( |
@@ -76,7 +76,7 @@ discard block |
||
76 | 76 | ], |
77 | 77 | |
78 | 78 | 'options' => [ |
79 | - 'Core/MailServiceOptions' => [ 'class' => '\Core\Options\MailServiceOptions' ], |
|
79 | + 'Core/MailServiceOptions' => ['class' => '\Core\Options\MailServiceOptions'], |
|
80 | 80 | ], |
81 | 81 | |
82 | 82 | 'Core' => array( |
@@ -139,7 +139,7 @@ discard block |
||
139 | 139 | 'name' => 'stream', |
140 | 140 | 'priority' => 1000, |
141 | 141 | 'options' => [ |
142 | - 'stream' => getcwd() . '/var/log/mailqueue.log', |
|
142 | + 'stream' => getcwd().'/var/log/mailqueue.log', |
|
143 | 143 | 'formatter' => [ |
144 | 144 | 'name' => 'simple', |
145 | 145 | 'options' => [ |
@@ -375,19 +375,19 @@ discard block |
||
375 | 375 | 'modules/Core/jsonEntityHydrator' => 'Core\Entity\Hydrator\JsonEntityHydratorFactory', |
376 | 376 | 'Core/EntityHydrator' => 'Core\Entity\Hydrator\EntityHydratorFactory', |
377 | 377 | 'Core/Options' => 'Core\Factory\ModuleOptionsFactory', |
378 | - 'Core/DoctrineMongoODM/RepositoryEvents' => [\Core\Repository\DoctrineMongoODM\Event\RepositoryEventsSubscriber::class,'factory'], |
|
379 | - 'DefaultListeners' => ['Core\Listener\DefaultListener','factory'], |
|
380 | - 'templateProviderStrategy' => ['Core\Form\Hydrator\Strategy\TemplateProviderStrategy','factory'], |
|
381 | - 'Core/Listener/DeferredListenerAggregate' => [\Core\Listener\DeferredListenerAggregate::class,'factory'], |
|
378 | + 'Core/DoctrineMongoODM/RepositoryEvents' => [\Core\Repository\DoctrineMongoODM\Event\RepositoryEventsSubscriber::class, 'factory'], |
|
379 | + 'DefaultListeners' => ['Core\Listener\DefaultListener', 'factory'], |
|
380 | + 'templateProviderStrategy' => ['Core\Form\Hydrator\Strategy\TemplateProviderStrategy', 'factory'], |
|
381 | + 'Core/Listener/DeferredListenerAggregate' => [\Core\Listener\DeferredListenerAggregate::class, 'factory'], |
|
382 | 382 | 'Core/Listener/CreatePaginator' => 'Core\Listener\CreatePaginatorListener::factory', |
383 | 383 | 'Core/Locale' => 'Core\I18n\LocaleFactory', |
384 | 384 | \Core\Listener\AjaxRouteListener::class => \Core\Factory\Listener\AjaxRouteListenerFactory::class, |
385 | 385 | \Core\Listener\DeleteImageSetListener::class => \Core\Factory\Listener\DeleteImageSetListenerFactory::class, |
386 | 386 | 'Imagine' => \Core\Factory\Service\ImagineFactory::class, |
387 | - 'Core/Listener/Notification' => [\Core\Listener\NotificationListener::class,'factory'], |
|
388 | - 'Tracy' => [Tracy::class,'factory'], |
|
387 | + 'Core/Listener/Notification' => [\Core\Listener\NotificationListener::class, 'factory'], |
|
388 | + 'Tracy' => [Tracy::class, 'factory'], |
|
389 | 389 | Service\EntityEraser\DefaultEntityLoaderListener::class => Service\EntityEraser\DefaultEntityLoaderListenerFactory::class, |
390 | - ClearCacheService::class => [ClearCacheService::class,'factory'], |
|
390 | + ClearCacheService::class => [ClearCacheService::class, 'factory'], |
|
391 | 391 | Listener\ModuleVersionAdminWidgetProvider::class => Listener\ModuleVersionAdminWidgetProviderFactory::class, |
392 | 392 | Queue\Worker\MongoWorker::class => \SlmQueue\Factory\WorkerFactory::class, |
393 | 393 | 'Core/HtmlPurifier' => \Core\Factory\Service\HtmlPurifierFactory::class, |
@@ -415,7 +415,7 @@ discard block |
||
415 | 415 | 'translation_file_patterns' => array( |
416 | 416 | [ |
417 | 417 | 'type' => 'gettext', |
418 | - 'base_dir' => __DIR__ . '/../language', |
|
418 | + 'base_dir' => __DIR__.'/../language', |
|
419 | 419 | 'pattern' => '%s.mo', |
420 | 420 | ], |
421 | 421 | [ |
@@ -460,8 +460,8 @@ discard block |
||
460 | 460 | 'Core/File' => FileControllerFactory::class, |
461 | 461 | 'Core/Content' => LazyControllerFactory::class, |
462 | 462 | Controller\Console\PurgeController::class => Controller\Console\PurgeControllerFactory::class, |
463 | - AssetsInstallController::class => [AssetsInstallController::class,'factory'], |
|
464 | - ClearCacheController::class => [ClearCacheController::class,'factory'], |
|
463 | + AssetsInstallController::class => [AssetsInstallController::class, 'factory'], |
|
464 | + ClearCacheController::class => [ClearCacheController::class, 'factory'], |
|
465 | 465 | Queue\Controller\MongoQueueController::class => Queue\Controller\MongoQueueControllerFactory::class, |
466 | 466 | Queue\Controller\MongoQueueListController::class => Queue\Controller\MongoQueueListControllerFactory::class, |
467 | 467 | |
@@ -476,9 +476,9 @@ discard block |
||
476 | 476 | 'Core/SearchForm' => 'Core\Factory\Controller\Plugin\SearchFormFactory', |
477 | 477 | 'listquery' => 'Core\Controller\Plugin\ListQuery::factory', |
478 | 478 | 'mail' => 'Core\Controller\Plugin\Mail::factory', |
479 | - 'Core/Mailer' => ['Core\Controller\Plugin\Mailer','factory'], |
|
480 | - 'Core/CreatePaginator' => [\Core\Controller\Plugin\CreatePaginator::class,'factory'], |
|
481 | - 'Core/PaginatorService' => [\Core\Controller\Plugin\CreatePaginatorService::class,'factory'], |
|
479 | + 'Core/Mailer' => ['Core\Controller\Plugin\Mailer', 'factory'], |
|
480 | + 'Core/CreatePaginator' => [\Core\Controller\Plugin\CreatePaginator::class, 'factory'], |
|
481 | + 'Core/PaginatorService' => [\Core\Controller\Plugin\CreatePaginatorService::class, 'factory'], |
|
482 | 482 | Controller\Plugin\EntityEraser::class => Controller\Plugin\EntityEraserFactory::class, |
483 | 483 | ), |
484 | 484 | 'invokables' => array( |
@@ -509,32 +509,32 @@ discard block |
||
509 | 509 | 'exception_template' => 'error/index', |
510 | 510 | // Map template to files. Speeds up the lookup through the template stack. |
511 | 511 | 'template_map' => array( |
512 | - 'noscript-notice' => __DIR__ . '/../view/layout/_noscript-notice.phtml', |
|
513 | - 'layout/layout' => __DIR__ . '/../view/layout/layout.phtml', |
|
514 | - 'error/404' => __DIR__ . '/../view/error/404.phtml', |
|
515 | - 'error/403' => __DIR__ . '/../view/error/403.phtml', |
|
516 | - 'error/index' => __DIR__ . '/../view/error/index.phtml', |
|
517 | - 'main-navigation' => __DIR__ . '/../view/partial/main-navigation.phtml', |
|
518 | - 'pagination-control' => __DIR__ . '/../view/partial/pagination-control.phtml', |
|
519 | - 'core/loading-popup' => __DIR__ . '/../view/partial/loading-popup.phtml', |
|
520 | - 'core/notifications' => __DIR__ . '/../view/partial/notifications.phtml', |
|
521 | - 'form/core/buttons' => __DIR__ . '/../view/form/buttons.phtml', |
|
522 | - 'core/social-buttons' => __DIR__ . '/../view/partial/social-buttons.phtml', |
|
523 | - 'form/core/privacy' => __DIR__ . '/../view/form/privacy.phtml', |
|
524 | - 'core/form/permissions-fieldset' => __DIR__ . '/../view/form/permissions-fieldset.phtml', |
|
525 | - 'core/form/permissions-collection' => __DIR__ . '/../view/form/permissions-collection.phtml', |
|
526 | - 'core/form/container-view' => __DIR__ . '/../view/form/container.view.phtml', |
|
527 | - 'core/form/tree-manage.view' => __DIR__ . '/../view/form/tree-manage.view.phtml', |
|
528 | - 'core/form/tree-manage.form' => __DIR__ . '/../view/form/tree-manage.form.phtml', |
|
529 | - 'core/form/tree-add-item' => __DIR__ . '/../view/form/tree-add-item.phtml', |
|
530 | - 'mail/header' => __DIR__ . '/../view/mail/header.phtml', |
|
531 | - 'mail/footer' => __DIR__ . '/../view/mail/footer.phtml', |
|
532 | - 'mail/footer.en' => __DIR__ . '/../view/mail/footer.en.phtml', |
|
512 | + 'noscript-notice' => __DIR__.'/../view/layout/_noscript-notice.phtml', |
|
513 | + 'layout/layout' => __DIR__.'/../view/layout/layout.phtml', |
|
514 | + 'error/404' => __DIR__.'/../view/error/404.phtml', |
|
515 | + 'error/403' => __DIR__.'/../view/error/403.phtml', |
|
516 | + 'error/index' => __DIR__.'/../view/error/index.phtml', |
|
517 | + 'main-navigation' => __DIR__.'/../view/partial/main-navigation.phtml', |
|
518 | + 'pagination-control' => __DIR__.'/../view/partial/pagination-control.phtml', |
|
519 | + 'core/loading-popup' => __DIR__.'/../view/partial/loading-popup.phtml', |
|
520 | + 'core/notifications' => __DIR__.'/../view/partial/notifications.phtml', |
|
521 | + 'form/core/buttons' => __DIR__.'/../view/form/buttons.phtml', |
|
522 | + 'core/social-buttons' => __DIR__.'/../view/partial/social-buttons.phtml', |
|
523 | + 'form/core/privacy' => __DIR__.'/../view/form/privacy.phtml', |
|
524 | + 'core/form/permissions-fieldset' => __DIR__.'/../view/form/permissions-fieldset.phtml', |
|
525 | + 'core/form/permissions-collection' => __DIR__.'/../view/form/permissions-collection.phtml', |
|
526 | + 'core/form/container-view' => __DIR__.'/../view/form/container.view.phtml', |
|
527 | + 'core/form/tree-manage.view' => __DIR__.'/../view/form/tree-manage.view.phtml', |
|
528 | + 'core/form/tree-manage.form' => __DIR__.'/../view/form/tree-manage.form.phtml', |
|
529 | + 'core/form/tree-add-item' => __DIR__.'/../view/form/tree-add-item.phtml', |
|
530 | + 'mail/header' => __DIR__.'/../view/mail/header.phtml', |
|
531 | + 'mail/footer' => __DIR__.'/../view/mail/footer.phtml', |
|
532 | + 'mail/footer.en' => __DIR__.'/../view/mail/footer.en.phtml', |
|
533 | 533 | //'startpage' => __DIR__ . '/../view/layout/startpage.phtml', |
534 | 534 | ), |
535 | 535 | // Where to look for view templates not mapped above |
536 | 536 | 'template_path_stack' => array( |
537 | - __DIR__ . '/../view', |
|
537 | + __DIR__.'/../view', |
|
538 | 538 | ), |
539 | 539 | ), |
540 | 540 | 'view_helpers' => array( |
@@ -72,7 +72,7 @@ discard block |
||
72 | 72 | } |
73 | 73 | |
74 | 74 | if (!is_array($options)) { |
75 | - throw new \InvalidArgumentException('Options must be of type array or ' . LoggerInterface::class); |
|
75 | + throw new \InvalidArgumentException('Options must be of type array or '.LoggerInterface::class); |
|
76 | 76 | } |
77 | 77 | |
78 | 78 | parent::__construct($options); |
@@ -282,7 +282,7 @@ discard block |
||
282 | 282 | */ |
283 | 283 | private function formatJob(JobInterface $job) : string |
284 | 284 | { |
285 | - return get_class($job) . ' [ ' . $job->getId() . ' ] '; |
|
285 | + return get_class($job).' [ '.$job->getId().' ] '; |
|
286 | 286 | } |
287 | 287 | |
288 | 288 | } |
@@ -74,7 +74,7 @@ |
||
74 | 74 | |
75 | 75 | $lineTmpl = '%-20s %s'; |
76 | 76 | foreach ($jobs as $job) { |
77 | - $console->writeLine(get_class($job['job']) . ' [ ' . $job['job']->getId() . ' ]'); |
|
77 | + $console->writeLine(get_class($job['job']).' [ '.$job['job']->getId().' ]'); |
|
78 | 78 | |
79 | 79 | foreach (['created', 'executed', 'scheduled'] as $key) { |
80 | 80 | $console->writeLine(sprintf($lineTmpl, ucFirst($key), $job[$key]->toDateTime()->format('Y-m-d H:i:s'))); |
@@ -71,7 +71,7 @@ |
||
71 | 71 | $job = $options ? new $service(...$options) : new $service; |
72 | 72 | |
73 | 73 | } else { |
74 | - throw new FatalJobException('A job with name "' . $service . '" could not be created.'); |
|
74 | + throw new FatalJobException('A job with name "'.$service.'" could not be created.'); |
|
75 | 75 | } |
76 | 76 | |
77 | 77 | $job->setContent($this->getContent()); |
@@ -58,40 +58,40 @@ |
||
58 | 58 | $jobEntity = $this->repository->find($payload['jobId']); |
59 | 59 | |
60 | 60 | if (!$jobEntity) { |
61 | - return $this->failure('No job entity with the id ' . $payload['jobId'] . ' was found.'); |
|
61 | + return $this->failure('No job entity with the id '.$payload['jobId'].' was found.'); |
|
62 | 62 | } |
63 | 63 | |
64 | 64 | $uri = $jobEntity->getLogoRef(); |
65 | 65 | |
66 | 66 | if (0 !== strpos($uri, 'http')) { |
67 | - $logger->notice('logoRef seems not to be external: ' . $uri); |
|
67 | + $logger->notice('logoRef seems not to be external: '.$uri); |
|
68 | 68 | return $this->success('Skip fetching for this job.'); |
69 | 69 | } |
70 | 70 | |
71 | - $logger->debug('Trying to fetch image from ' . $uri); |
|
71 | + $logger->debug('Trying to fetch image from '.$uri); |
|
72 | 72 | |
73 | 73 | $client = new Client($uri); |
74 | 74 | $response = $client->send(); |
75 | 75 | |
76 | 76 | if (200 != $response->getStatusCode()) { |
77 | - $logger->err('Received status code ' . $response->getStatusCode() . ' when trying to fetch ' . $uri); |
|
77 | + $logger->err('Received status code '.$response->getStatusCode().' when trying to fetch '.$uri); |
|
78 | 78 | |
79 | - return $this->recoverable('Status code ' . $response->getStatusCode() . ' received.', ['delay' => '+5 minutes']); |
|
79 | + return $this->recoverable('Status code '.$response->getStatusCode().' received.', ['delay' => '+5 minutes']); |
|
80 | 80 | } |
81 | 81 | |
82 | 82 | $content = $response->getBody(); |
83 | 83 | $type = $response->getHeaders()->get('Content-Type')->getFieldValue(); |
84 | 84 | list(,$ext) = explode('/', $type, 2); |
85 | - $imageName = '/static/Jobs/logos/' . $jobEntity->getId() . '.' . $ext; |
|
85 | + $imageName = '/static/Jobs/logos/'.$jobEntity->getId().'.'.$ext; |
|
86 | 86 | |
87 | 87 | if (false === file_put_contents("public$imageName", $content, FILE_BINARY)) { |
88 | - return $this->failure('Writing image to "public' . $imageName . '" failed.'); |
|
88 | + return $this->failure('Writing image to "public'.$imageName.'" failed.'); |
|
89 | 89 | } |
90 | 90 | |
91 | - $logger->info('Saved job logo as ' . basename($imageName)); |
|
91 | + $logger->info('Saved job logo as '.basename($imageName)); |
|
92 | 92 | $jobEntity->setLogoRef($imageName); |
93 | 93 | $this->repository->store($jobEntity); |
94 | - $logger->info('Saved job logo as ' . basename($imageName)); |
|
94 | + $logger->info('Saved job logo as '.basename($imageName)); |
|
95 | 95 | |
96 | 96 | return $this->success(); |
97 | 97 | } |
@@ -74,8 +74,8 @@ discard block |
||
74 | 74 | foreach ($cursor->toArray() as $job) { |
75 | 75 | if (0 === strpos($job->getLogoRef(), 'http')) { |
76 | 76 | $queue->push(FetchExternalImageJob::create($job)); |
77 | - $logger->debug('Found external image uri: ' . $job->getLogoRef()); |
|
78 | - $logger->info('Pushed fetch image job for Job: ' . $job->getId()); |
|
77 | + $logger->debug('Found external image uri: '.$job->getLogoRef()); |
|
78 | + $logger->info('Pushed fetch image job for Job: '.$job->getId()); |
|
79 | 79 | } else { |
80 | 80 | $invalidJobs += 1; |
81 | 81 | } |
@@ -83,7 +83,7 @@ discard block |
||
83 | 83 | |
84 | 84 | $delay = 0 >= ($cursor->count() - $invalidJobs) ? '+2 hours' : '+5 minutes'; |
85 | 85 | $queue->push(self::create(), ['delay' => $delay]); |
86 | - $logger->info('Reinserted to fetch more jobs with delay: ' . $delay); |
|
86 | + $logger->info('Reinserted to fetch more jobs with delay: '.$delay); |
|
87 | 87 | |
88 | 88 | return $this->success(); |
89 | 89 | } |
@@ -211,7 +211,7 @@ discard block |
||
211 | 211 | $time = microtime(true); |
212 | 212 | $micro = sprintf("%06d", ($time - floor($time)) * 1000000); |
213 | 213 | $this->now = new \DateTime( |
214 | - date('Y-m-d H:i:s.' . $micro, $time), |
|
214 | + date('Y-m-d H:i:s.'.$micro, $time), |
|
215 | 215 | new \DateTimeZone(date_default_timezone_get()) |
216 | 216 | ); |
217 | 217 | $now = $this->dateTimeToUTCDateTime($this->now); |
@@ -250,12 +250,12 @@ discard block |
||
250 | 250 | */ |
251 | 251 | public function listing(array $options = []) |
252 | 252 | { |
253 | - $filter = [ 'queue' => $this->getName() ]; |
|
253 | + $filter = ['queue' => $this->getName()]; |
|
254 | 254 | if (isset($options['status'])) { |
255 | 255 | $filter['status'] = $options['status']; |
256 | 256 | } |
257 | 257 | |
258 | - $opt = [ 'sort' => [ 'scheduled' => 1, 'priority' => 1] ]; |
|
258 | + $opt = ['sort' => ['scheduled' => 1, 'priority' => 1]]; |
|
259 | 259 | if (isset($options['limit'])) { |
260 | 260 | $opt['limit'] = $options['limit']; |
261 | 261 | } |
@@ -336,7 +336,7 @@ discard block |
||
336 | 336 | { |
337 | 337 | $time = microtime(true); |
338 | 338 | $micro = sprintf("%06d", ($time - floor($time)) * 1000000); |
339 | - $this->now = new \DateTime(date('Y-m-d H:i:s.' . $micro, $time), new \DateTimeZone(date_default_timezone_get())); |
|
339 | + $this->now = new \DateTime(date('Y-m-d H:i:s.'.$micro, $time), new \DateTimeZone(date_default_timezone_get())); |
|
340 | 340 | $scheduled = isset($options['scheduled']) ? Utils::createDateTime($options['scheduled']) : clone ($this->now); |
341 | 341 | |
342 | 342 | if (isset($options['delay'])) { |