SiteStatsUpdateJob.php

<?php

namespace App\Jobs;

use App\Http\Curl\HttpRequest;
use App\Services\MediaWikiHostResolver;
use App\Wiki;
use Illuminate\Bus\Batchable;
use Illuminate\Support\Facades\Log;

/*
*
* Job that updates site_stats table in mediawiki by calling initSiteStats.php
*
* Example: php artisan job:dispatch SiteStatsUpdateJob
*/
class SiteStatsUpdateJob extends Job {
    use Batchable;

    private $wiki_id;

    public function __construct($wiki_id) {
        $this->wiki_id = $wiki_id;
    }

    public function handle(HttpRequest $request, MediaWikiHostResolver $mwHostResolver): void {
        $timeStart = microtime(true);

        $wiki = Wiki::where('id', $this->wiki_id)->first();
        if (!$wiki) {
            $this->fail(new \RuntimeException(" Could not find wiki with id: $this->wiki_id"));
        }

        Log::info(__METHOD__ . ": Updating stats for $wiki->domain");

        $request->setOptions([
            CURLOPT_URL => $mwHostResolver->getBackendHostForDomain($wiki->domain) . '/w/api.php?action=wbstackSiteStatsUpdate&format=json',
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_ENCODING => '',
            CURLOPT_TIMEOUT => 60 * 5,
            CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
            CURLOPT_CUSTOMREQUEST => 'POST',
            CURLOPT_HTTPHEADER => [
                'content-type: application/x-www-form-urlencoded',
                'host: ' . $wiki->domain,
            ],
        ]);

        $rawResponse = $request->execute();
        $err = $request->error();
        $request->close();

        if ($err) {
            Log::error(__METHOD__ . ": wbstackSiteStatsUpdate failed: $rawResponse");
            $this->fail(
                new \RuntimeException('curl error for ' . $wiki->domain . ': ' . $err)
            );

            return; // safegaurd
        }

        $response = json_decode($rawResponse, true);

        if (!is_array($response) || !array_key_exists('wbstackSiteStatsUpdate', $response)) {
            $this->fail(
                new \RuntimeException('wbstackSiteStatsUpdate call for ' . $wiki->domain . '. No wbstackSiteStatsUpdate key in response: ' . $rawResponse)
            );

            return; // safegaurd
        }

        if ($response['wbstackSiteStatsUpdate']['return'] !== 0) {
            $this->fail(
                new \RuntimeException('wbstackSiteStatsUpdate call for ' . $wiki->domain . ' was not successful: ' . $rawResponse)
            );

            return; // safegaurd
        }

        $timeEnd = microtime(true);
        $executionTime = ($timeEnd - $timeStart);

        Log::info(__METHOD__ . ": Finished in: $executionTime s");

    }
}