cross-solution / YAWIK

module/Core/test/CoreTest/Queue/Strategy/IdleSleepStrategyTest.php

Indentation +2 added lines, -2 removed lines

@@ -46,8 +46,8 @@
     {
         $events = $this->prophesize(EventManagerInterface::class);
         $events->attach(AbstractWorkerEvent::EVENT_PROCESS_IDLE, [$this->target, 'onIdle'], 1)
-               ->willReturn('handle')
-               ->shouldBeCalled();
+                ->willReturn('handle')
+                ->shouldBeCalled();
 
         $this->target->attach($events->reveal());
 

module/Core/test/CoreTest/Queue/MongoQueueTest.php

Indentation +44 added lines, -44 removed lines

@@ -152,12 +152,12 @@ 
             'delay' => 100,
         ];
         $resultMock = $this->getMockBuilder(\MongoDB\InsertOneResult::class)->disableOriginalConstructor()
-                           ->setMethods(['getInsertedId'])->getMock();
+                            ->setMethods(['getInsertedId'])->getMock();
         $resultMock->expects($this->once())->method('getInsertedId')->willReturn('ID');
         $this->mongoCollectionMock->expects($this->once())->method('insertOne')
-                                  ->with($this->callback(function($value) use ($options) {
+                                    ->with($this->callback(function($value) use ($options) {
 
-                                      return isset($value['queue']) && $value['queue'] == $this->queueName
+                                        return isset($value['queue']) && $value['queue'] == $this->queueName
                                              && isset($value['status']) && $value['status'] == MongoQueue::STATUS_PENDING
                                              && !isset($value['tried'])
                                              && !isset($value['message']) && !isset($value['trace'])
@@ -166,9 +166,9 @@ 
                                              && $value['created'] instanceOf \MongoDB\BSON\UTCDateTime
                                              && (int) ((string) $value['scheduled']) - (int) ((string)$value['created']) == $options['delay'] * 1000
                                              && isset($value['priority']) && $value['priority'] == $options['priority']
-                                          ;
-                                  }))
-                                  ->willReturn($resultMock);
+                                            ;
+                                    }))
+                                    ->willReturn($resultMock);
 
         $this->target->push($job, $options);
 
@@ -184,17 +184,17 @@ 
 
 
         $this->mongoCollectionMock->expects($this->once())->method('findOneAndUpdate')
-                                  ->with(
-                                      $this->equalTo(['_id' => new \MongoDB\BSON\ObjectID($job->getId())]),
-                                      $this->callback(function($value) {
-                                          if (!array_key_exists('$set', $value)) { return false;}
-                                          $value = $value['$set'];
+                                    ->with(
+                                        $this->equalTo(['_id' => new \MongoDB\BSON\ObjectID($job->getId())]),
+                                        $this->callback(function($value) {
+                                            if (!array_key_exists('$set', $value)) { return false;}
+                                            $value = $value['$set'];
                                         return isset($value['tried']) && $value['tried'] == 10
                                                 && !array_key_exists('created', $value)
                                         ;
-                                      }
-                                  ))
-                                  ->willReturn(null);
+                                        }
+                                    ))
+                                    ->willReturn(null);
 
         $this->target->retry($job);
     }
@@ -211,31 +211,31 @@ 
 
         $this->jobManagerMock->expects($this->once())->method('get')->with(get_class($job))->willReturn(new $this->testJobClass());
         $this->mongoCollectionMock->expects($this->once())->method('findOneAndUpdate')
-                                  ->with(
-                                      $this->callback(function($value) {
-                                          return
+                                    ->with(
+                                        $this->callback(function($value) {
+                                            return
                                                     isset($value['queue']) && $value['queue'] == $this->queueName
                                                     && isset($value['status']) && $value['status'] == MongoQueue::STATUS_PENDING
                                                     && isset($value['scheduled']['$lte']) && $value['scheduled']['$lte'] instanceOf \MongoDB\BSON\UTCDateTime
-                                              ;
-                                      }),
+                                                ;
+                                        }),
 
-                                      $this->callback(function($value) {
-                                          if (!array_key_exists('$set', $value)) { return false;}
-                                          $value = $value['$set'];
-                                          return isset($value['status']) && $value['status'] == MongoQueue::STATUS_RUNNING
+                                        $this->callback(function($value) {
+                                            if (!array_key_exists('$set', $value)) { return false;}
+                                            $value = $value['$set'];
+                                            return isset($value['status']) && $value['status'] == MongoQueue::STATUS_RUNNING
                                                  && array_key_exists('executed', $value)
-                                              ;
-                                      }
-                                      ),
+                                                ;
+                                        }
+                                        ),
 
-                                      $this->callback(function($value) {
-                                          return
+                                        $this->callback(function($value) {
+                                            return
                                             isset($value['sort']) && $value['sort'] == ['priority' => 1, 'scheduled' => 1]
                                               && isset($value['returnDocument'])&&$value['returnDocument'] = \MongoDB\Operation\FindOneAndUpdate::RETURN_DOCUMENT_AFTER
-                                              ;
-                                      }))
-                                  ->willReturn($envelope);
+                                                ;
+                                        }))
+                                    ->willReturn($envelope);
 
         $actualJob = $this->target->pop();
 
@@ -245,7 +245,7 @@ 
     public function testPopEmptyQueue()
     {
         $this->mongoCollectionMock->expects($this->once())->method('findOneAndUpdate')
-                                  ->willReturn(null);
+                                    ->willReturn(null);
 
         $actualJob = $this->target->pop();
 
@@ -319,8 +319,8 @@ 
         };
 
         $this->mongoCollectionMock->expects($this->once())->method('find')
-                                  ->with($filter, $opt)
-                                  ->willReturn($cursor);
+                                    ->with($filter, $opt)
+                                    ->willReturn($cursor);
 
         $this->target->listing($options);
 
@@ -334,19 +334,19 @@ 
         $job->setId(new \MongoDB\BSON\ObjectID());
         $options = ['message' => 'test failure message'];
         $this->mongoCollectionMock->expects($this->once())->method('findOneAndUpdate')
-                                  ->with(
-                                      $this->equalTo(['_id' => new \MongoDB\BSON\ObjectID($job->getId())]),
-                                      $this->callback(function($value) use ($options) {
-                                          if (!array_key_exists('$set', $value)) { return false;}
-                                          $value = $value['$set'];
-                                          return isset($value['status']) && $value['status'] == MongoQueue::STATUS_FAILED
+                                    ->with(
+                                        $this->equalTo(['_id' => new \MongoDB\BSON\ObjectID($job->getId())]),
+                                        $this->callback(function($value) use ($options) {
+                                            if (!array_key_exists('$set', $value)) { return false;}
+                                            $value = $value['$set'];
+                                            return isset($value['status']) && $value['status'] == MongoQueue::STATUS_FAILED
                                                  && !array_key_exists('created', $value)
                                                 && !array_key_exists('scheduled', $value)
                                               && isset($value['message']) && $value['message'] == $options['message']
-                                              ;
-                                      }
-                                      ))
-                                  ->willReturn(null);
+                                                ;
+                                        }
+                                        ))
+                                    ->willReturn(null);
 
         $this->target->fail($job, $options);
     }

module/Core/test/CoreTest/Queue/Worker/MongoWorkerTest.php

Indentation +2 added lines, -2 removed lines

@@ -71,7 +71,7 @@ 
 
     public function testDoesDeleteJobIfProcessedSuccessfully()
     {
-         /* @var AbstractJob $jobMock */
+            /* @var AbstractJob $jobMock */
         $job = $this->prophesize(AbstractJob::class);
         $job->execute()->willReturn(ProcessJobEvent::JOB_STATUS_SUCCESS);
         $jobMock = $job->reveal();
@@ -90,7 +90,7 @@ 
     {
         $options = ['delay' => 10];
 
-         /* @var AbstractJob $jobMock */
+            /* @var AbstractJob $jobMock */
         $job = $this->prophesize(AbstractJob::class);
         $job->execute()->willThrow(new RecoverableJobException('test recoverable', $options));
         $jobMock = $job->reveal();

module/Core/test/CoreTest/Queue/Controller/MongoQueueListControllerTest.php

Indentation +8 added lines, -8 removed lines

@@ -111,7 +111,7 @@ 
     {
         $queueName = 'test';
         $queue = $this->getMockBuilder(MongoQueue::class)->disableOriginalConstructor()
-                      ->setMethods(['listing'])->getMock();
+                        ->setMethods(['listing'])->getMock();
         $this->queueManager->expects($this->once())->method('get')->with($queueName)->willReturn($queue);
         $params = $this->setupParamsMock([
             ['queue', null, $queueName],
@@ -135,13 +135,13 @@ 
         $date = new \DateTime();
         $date->setTimezone(new \DateTimeZone('UTC'));
         $jobs = [
-           [
-               'job' => $job,
-               'created' => new \MongoDb\BSON\UTCDateTime($date->getTimestamp() * 1000),
-               'executed' => new \MongoDb\BSON\UTCDateTime($date->getTimestamp() * 1000),
-               'scheduled' => new \MongoDb\BSON\UTCDateTime($date->getTimestamp() * 1000),
-               'tried' => 10,
-           ],
+            [
+                'job' => $job,
+                'created' => new \MongoDb\BSON\UTCDateTime($date->getTimestamp() * 1000),
+                'executed' => new \MongoDb\BSON\UTCDateTime($date->getTimestamp() * 1000),
+                'scheduled' => new \MongoDb\BSON\UTCDateTime($date->getTimestamp() * 1000),
+                'tried' => 10,
+            ],
         ];
 
         $queue->expects($this->once())->method('listing')->with(['limit' => 10, 'status' => 1])->willReturn($jobs);

module/Core/config/module.config.php

Indentation +8 added lines, -8 removed lines

@@ -76,25 +76,25 @@
     'log' => array(
         'Core/Log' => array(
             'writers' => array(
-                 array(
-                     'name' => 'stream',
+                    array(
+                        'name' => 'stream',
                     'priority' => 1000,
                     'options' => array(
-                         'stream' => getcwd().'/var/log/yawik.log',
+                            'stream' => getcwd().'/var/log/yawik.log',
+                    ),
                     ),
-                 ),
             ),
         ),
         'Log/Core/Mail' => array(
             'writers' => array(
-                 array(
-                     'name' => 'stream',
+                    array(
+                        'name' => 'stream',
                     'priority' => 1000,
                     'options' => array(
-                         'stream' => getcwd().'/var/log/mails.log',
+                            'stream' => getcwd().'/var/log/mails.log',
                     ),
 
-                 ),
+                    ),
             ),
         ),
         'Log/Core/Queue' => array(