BulkIndexerTest::testSingleDocumentBeingQueuedForBulkIndexing()

Complexity

Conditions	3
Paths	4

Size

Total Lines	61
Code Lines	34

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	0	Features	0

<?php declare(strict_types = 1);
    public function testSingleDocumentBeingQueuedForBulkIndexing(): void
    {
        BulkIndexer::resetIndexedPayload();

        // only one job is created per index when there are dirty objects to index.  This is dealt with within the
        // queued jobs module, in that the job parameters are identical.  One job will already be present from
        // loading of the fixtures.  As such, clear the queue
        DB::query('DELETE FROM "QueuedJobDescriptor"');

        $before = QueuedJobDescriptor::get()->count();

        $page = $this->objFromFixture(SiteTree::class, 'sitetree_10');
        $page->Title = 'This is a new title';
        $page->write();

        $after = QueuedJobDescriptor::get()->count();

        // assert that 1 job has been created, then inspect the contents
        $this->assertEquals(1, $after - $before);

        // check the contents of the job queue
        $jobDescriptor = QueuedJobDescriptor::get()->first();
        $this->assertEquals('Bulk Index Dirty DataObjects', $jobDescriptor->JobTitle);
        $this->assertEquals(
            'O:8:"stdClass":1:{s:9:"indexName";s:8:"sitetree";}',
            $jobDescriptor->SavedJobData
        );

        // create the job class
        $impl = $jobDescriptor->Implementation;
        /** @var \Suilven\FreeTextSearch\Tests\Factory\BulkIndexDirtyJob $job */
        $job = Injector::inst()->create($impl);

        // populate data - taken from QueuedJobService
        $jobData = null;

The assignment to $jobData is dead and can be removed.

        $messages = null;

The assignment to $messages is dead and can be removed.

        // switching to php's serialize methods... not sure why this wasn't done from the start!
        $jobData = @\unserialize($jobDescriptor->SavedJobData);
        $messages = @\unserialize($jobDescriptor->SavedJobMessages);

        // try decoding as json if null
        $jobData = $jobData
            ? $jobData
            : \json_decode($jobDescriptor->SavedJobData);
        $messages = $messages
            ? $messages
            : \json_decode($jobDescriptor->SavedJobMessages);

        $job->setJobData(
            $jobDescriptor->TotalSteps,
            $jobDescriptor->StepsProcessed,
            $jobDescriptor->JobStatus === QueuedJob::STATUS_COMPLETE,
            $jobData,
            $messages
        );

        $job->setup();
        $job->process();

        $this->checkBulkIndexedPayload();
    }