tests/phpunit/includes/jobqueue/JobRunnerTest.php

   1 <?php
   2
   3 use MediaWiki\Page\DeletePage;
   4 use MediaWiki\Request\WebRequest;
   5 use MediaWiki\Title\Title;
   6
   7 /**
   8  * @group Database
   9  * @covers \JobRunner
  10  */
  11 class JobRunnerTest extends MediaWikiIntegrationTestCase {
  12
  13         /**
  14          * @var Title
  15          */
  16         private $page;
  17
  18         /**
  19          * @var JobRunner
  20          */
  21         private $jobRunner;
  22
  23         /**
  24          * @var DeletePageJob
  25          */
  26         private $deletePageJob;
  27
  28         protected function setUp(): void {
  29                 parent::setUp();
  30
  31                 $str = wfRandomString( 10 );
  32                 $this->page = $this->insertPage( $str )['title'];
  33
  34                 $this->assertTrue( $this->page->exists(), 'The created page exists' );
  35
  36                 $this->jobRunner = $this->getServiceContainer()->getJobRunner();
  37                 $jobParams = [
  38                         'namespace' => $this->page->getNamespace(),
  39                         'title' => $this->page->getDBkey(),
  40                         'wikiPageId' => $this->page->getArticleID(),
  41                         'requestId' => WebRequest::getRequestId(),
  42                         'reason' => 'Testing delete job',
  43                         'suppress' => false,
  44                         'userId' => $this->getTestUser()->getUser()->getId(),
  45                         'tags' => json_encode( [] ),
  46                         'logsubtype' => 'delete',
  47                         'pageRole' => DeletePage::PAGE_BASE,
  48                 ];
  49                 $this->deletePageJob = new DeletePageJob( $jobParams );
  50         }
  51
  52         /**
  53          * @dataProvider provideTestRun
  54          */
  55         public function testRun( $options, $expectedVal ) {
  56                 $this->getServiceContainer()->getJobQueueGroup()->push( $this->deletePageJob );
  57
  58                 $results = $this->jobRunner->run( $options );
  59
  60                 $this->assertEquals( $expectedVal, $results['reached'] );
  61         }
  62
  63         public static function provideTestRun() {
  64                 return [
  65                         [ [], 'none-ready' ],
  66                         [ [ 'type' => true ], 'none-possible' ],
  67                         [ [ 'maxJobs' => 1 ], 'job-limit' ],
  68                         [ [ 'maxTime' => -1 ], 'time-limit' ],
  69                         [ [ 'type' => 'deletePage', 'throttle' => false ], 'none-ready' ]
  70                 ];
  71         }
  72
  73         public function testExecuteJob() {
  74                 $results = $this->jobRunner->executeJob( $this->deletePageJob );
  75
  76                 $this->assertIsInt( $results['timeMs'] );
  77                 $this->assertTrue( $results['status'] );
  78                 $this->assertIsArray( $results['caught'] );
  79                 $this->assertNull( $results['error'] );
  80
  81                 $this->assertTrue( $this->page->hasDeletedEdits() );
  82         }
  83 }