App\Application\OuvrageEdit\OuvrageEditWorker

Complexity

Total Complexity

38

Size/Duplication

Total Lines	268
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	run()	0	8	2
A	checkArticleLabels()	0	19	5
A	printTitle()	0	3	1
A	printDebug()	0	6	1
B	pageProcess()	0	53	9
A	processOneCitation()	0	32	5
A	makeCitationsReplacements()	0	12	2
A	__construct()	0	10	1
B	updateDb()	0	22	7
A	editPage()	0	26	4
A	normalizeAndFixWikiTypo()	0	3	1

<?php

/*
 * This file is part of dispositif/wikibot application (@github)
 * 2019-2023 © Philippe M./Irønie  <dispositif@gmail.com>
 * For the full copyright and MIT license information, view the license file.
 */

declare(strict_types=1);

namespace App\Application\OuvrageEdit;

use App\Application\InfrastructurePorts\DbAdapterInterface;
use App\Application\InfrastructurePorts\MemoryInterface;
use App\Application\OuvrageEdit\Validators\CitationsNotEmptyValidator;
use App\Application\OuvrageEdit\Validators\CitationValidator;
use App\Application\OuvrageEdit\Validators\PageValidatorComposite;
use App\Application\OuvrageEdit\Validators\TalkStopValidator;
use App\Application\OuvrageEdit\Validators\WikiTextValidator;
use App\Application\WikiBotConfig;
use App\Application\WikiPageAction;
use App\Domain\Utils\WikiRefsFixer;
use App\Infrastructure\Monitor\NullLogger;
use App\Infrastructure\ServiceFactory;
use Codedungeon\PHPCliColors\Color;
use Exception;
use Mediawiki\Api\UsageException;
use Normalizer;
use Psr\Log\LoggerInterface;
use Throwable;

/**
 * Legacy class, to be refactored. Too big, too many responsibilities.
 * todo use PageOuvrageCollectionDTO.
 * todo chain of responsibility pattern + log decorator (+ events ?)
 */
class OuvrageEditWorker
{
    use OuvrageEditSummaryTrait, TalkPageEditTrait;

The trait App\Application\OuvrageEdit\TalkPageEditTrait requires the property $errorWarning which is not provided by App\Application\OuvrageEdit\OuvrageEditWorker.

The trait App\Application\OuvrageEdit\OuvrageEditSummaryTrait requires some properties which are not provided by App\Application\OuvrageEdit\OuvrageEditWorker: $importantSummary, $nbRows, $errorWarning

    final public const TASK_NAME = '📗 Amélioration bibliographique'; // 📖📔📘📗
    final public const LUCKY_MESSAGE = ' 🇺🇦'; // ☘️
    /**
     * poster ou pas le message en PD signalant les erreurs à résoudre
     */
    final public const EDIT_SIGNALEMENT = true;
    final public const CITATION_LIMIT = 150;
    final public const DELAY_BOTFLAG_SECONDS = 120;
    final public const DELAY_NO_BOTFLAG_SECONDS = 120;
    final public const ERROR_MSG_TEMPLATE = __DIR__ . '/templates/message_errors.wiki';
    protected const ALWAYS_NO_BOTFLAG_ON_BA = true;
    protected const ALWAYS_NO_BOTFLAG_ON_ADQ = true;

    /**
     * @var PageWorkStatus
     */
    protected $pageWorkStatus;

    /**
     * @var WikiPageAction
     */
    protected $wikiPageAction = null;

    protected $db;
    /**
     * @var WikiBotConfig
     */
    protected $bot;
    /**
     * @var MemoryInterface
     */
    protected $memory;
    /**
     * @var ImportantSummaryCreator
     */
    protected $summaryCreator;

    public function __construct(
        DbAdapterInterface $dbAdapter,
        WikiBotConfig      $bot,
        MemoryInterface    $memory,
        protected LoggerInterface   $log = new NullLogger()
    )
    {
        $this->db = $dbAdapter;
        $this->bot = $bot;
        $this->memory = $memory;
    }

    /**
     * @throws Exception
     */
    public function run(): void
    {
        while (true) {
            echo "\n-------------------------------------\n\n";
            echo date("Y-m-d H:i:s") . " ";
            $this->log->info($this->memory->getMemory(true));
            $this->pageProcess();
            sleep(2); // précaution boucle infinie
        }
    }

    /**
     * @throws UsageException
     * @throws Exception
     */
    protected function pageProcess(): bool
    {
        if (!(new TalkStopValidator($this->bot))->validate()) { // move up ?
            return false;
        }

        // get a random queue line
        $json = $this->db->getAllRowsOfOneTitleToEdit(self::CITATION_LIMIT);
        $pageCitationCollection = $json ? json_decode((string) $json, true, 512, JSON_THROW_ON_ERROR) : [];

        if (!(new CitationsNotEmptyValidator($pageCitationCollection, $this->log))->validate()) {
            return false;
        }

        $this->pageWorkStatus = new PageWorkStatus($pageCitationCollection[0]['page']);
        $this->printTitle($this->pageWorkStatus->getTitle());

        // Find on wikipedia the page to edit
        try {
            $this->wikiPageAction = ServiceFactory::wikiPageAction($this->pageWorkStatus->getTitle()); // , true ?
        } catch (Exception) {
            $this->log->warning("*** WikiPageAction error : " . $this->pageWorkStatus->getTitle() . " \n");
            sleep(20);

            return false;
        }
        $pageValidator = new PageValidatorComposite(
            $this->bot, $pageCitationCollection, $this->db, $this->wikiPageAction
        );
        if (!$pageValidator->validate()) {
            return false;
        }

        $this->pageWorkStatus->wikiText = $this->wikiPageAction->getText();
        $this->checkArticleLabels($this->pageWorkStatus->getTitle());
        // or do that at the end of ArticleValidForEditValidator if PageWorkStatus injected ?

        // print total number of rows completed in db
        $rowNumber = is_countable($pageCitationCollection) ? count($pageCitationCollection) : 0;
        $this->log->info(sprintf("%s rows to process\n", $rowNumber));

        // Make citations replacements
        if (!$this->makeCitationsReplacements($pageCitationCollection)) {
            return false;
        }

        if ($this->editPage()) {
            $this->updateDb($pageCitationCollection);

            return true;
        }

        return false;
    }

    protected function printTitle(string $title): void
    {
        echo Color::BG_CYAN . $title . Color::NORMAL . " \n";
    }

    protected function checkArticleLabels($title): void
    {
        // Featured/Good article (AdQ/BA) todo event listener
        if (preg_match('#{{ ?En-tête label ?\| ?AdQ#i', (string) $this->pageWorkStatus->wikiText)) {
            $this->db->setLabel($title, 2);

The method setLabel() does not exist on App\Application\InfrastructurePorts\DbAdapterInterface. Since it exists in all sub-types, consider adding an abstract or default implementation to App\Application\InfrastructurePorts\DbAdapterInterface.

            $this->log->warning("Article de Qualité !\n");
            if (self::ALWAYS_NO_BOTFLAG_ON_ADQ) {
                $this->pageWorkStatus->botFlag = false;
            }
            $this->pageWorkStatus->featured_article = true; // to add star in edit summary
        }
        if (preg_match('#{{ ?En-tête label ?\| ?BA#i', (string) $this->pageWorkStatus->wikiText)) {
            $this->db->setLabel($title, 1);
            if (self::ALWAYS_NO_BOTFLAG_ON_BA) {
                $this->pageWorkStatus->botFlag = false;
            }
            $this->pageWorkStatus->botFlag = false;
            $this->pageWorkStatus->featured_article = true; // to add star in edit summary
            $this->log->warning("Bon article !!\n");
        }
    }

    protected function makeCitationsReplacements(array $pageCitationCollection): bool
    {
        $oldText = $this->pageWorkStatus->wikiText;
        $this->summaryCreator = new ImportantSummaryCreator($this->pageWorkStatus);
        foreach ($pageCitationCollection as $dat) {
            $this->processOneCitation($dat); // that modify PageWorkStatus->wikiText
        }
        $newWikiTextValidator = new WikiTextValidator(
            $this->pageWorkStatus->wikiText, $oldText, $this->log, $this->pageWorkStatus->getTitle(), $this->db
        );

        return $newWikiTextValidator->validate();
    }

    /**
     * @throws Exception
     */
    protected function processOneCitation(array $ouvrageData): bool
    {
        $origin = $ouvrageData['raw'];
        $completed = $ouvrageData['opti'];
        $this->printDebug($ouvrageData);

        $citationValidator = new CitationValidator(
            $ouvrageData,
            $this->pageWorkStatus->wikiText,
            $this->log,
            $this->db
        );
        if (!$citationValidator->validate()) {
            return false;
        }

        // Replace text
        $newText = WikiPageAction::replaceTemplateInText($this->pageWorkStatus->wikiText, $origin, $completed);

        if (empty($newText) || $newText === $this->pageWorkStatus->wikiText) {
            $this->log->warning("newText error");

            return false;
        }
        $this->summaryCreator->processPageOuvrage($ouvrageData);
        $this->pageWorkStatus->wikiText = $newText;
        $this->pageWorkStatus->minorFlag = ('1' === $ouvrageData['major']) ? false : $this->pageWorkStatus->minorFlag;
        $this->pageWorkStatus->citationVersion = $ouvrageData['version']; // todo gérer versions différentes
        $this->pageWorkStatus->citationSummary[] = $ouvrageData['modifs'];
        $this->pageWorkStatus->nbRows++;

        return true;
    }

    protected function printDebug(array $data)
    {
        $this->log->debug('origin: ' . $data['raw']);
        $this->log->debug('completed: ' . $data['opti']);
        $this->log->debug('modifs: ' . $data['modifs']);
        $this->log->debug('version: ' . $data['version']);
    }

    protected function editPage(): bool
    {
        $miniSummary = $this->generateFinalSummary();

        $this->log->debug("sleep 2...");
        sleep(2); // todo ???

        try {
            $editInfo = ServiceFactory::editInfo($miniSummary, $this->pageWorkStatus->minorFlag, $this->pageWorkStatus->botFlag);
            $cleanWikiText = $this->normalizeAndFixWikiTypo($this->pageWorkStatus->wikiText);
            $success = $this->wikiPageAction->editPage($cleanWikiText, $editInfo);
        } catch (Throwable $e) {
            // Invalid CSRF token.
            if (str_contains($e->getMessage(), 'Invalid CSRF token')) {
                $this->log->alert("*** Invalid CSRF token \n");
                throw new Exception('Invalid CSRF token', $e->getCode(), $e);
            } else {
                $this->log->warning('Exception in editPage() ' . $e->getMessage());
                sleep(10);

                return false;
            }
        }
        $this->log->info($success ? "Edition Ok\n" : "***** Edition KO !\n");

        return $success;
    }

    protected function updateDb(array $pageOuvrageCollection)
    {
        $title = $pageOuvrageCollection[0]['page'];
        foreach ($pageOuvrageCollection as $ouvrageData) {
            $this->db->sendEditedData(['id' => $ouvrageData['id']]);

The method sendEditedData() does not exist on App\Application\InfrastructurePorts\DbAdapterInterface. Since it exists in all sub-types, consider adding an abstract or default implementation to App\Application\InfrastructurePorts\DbAdapterInterface.

        }
        try {
            if (self::EDIT_SIGNALEMENT && !empty($this->pageWorkStatus->errorWarning[$title])) {
                $this->sendOuvrageErrorsOnTalkPage($pageOuvrageCollection, $this->log);
            }
        } catch (Throwable $e) {
            $this->log->warning('Exception in editPage() ' . $e->getMessage());
            unset($e);
        }

        if (!$this->pageWorkStatus->botFlag) {
            $this->log->debug("sleep " . self::DELAY_NO_BOTFLAG_SECONDS);
            sleep(self::DELAY_NO_BOTFLAG_SECONDS);
        }
        if ($this->pageWorkStatus->botFlag) {
            $this->log->debug("sleep " . self::DELAY_BOTFLAG_SECONDS);
            sleep(self::DELAY_BOTFLAG_SECONDS);
        }
    }

    protected function normalizeAndFixWikiTypo(string $newText): string
    {
        return Normalizer::normalize(WikiRefsFixer::fixRefWikiSyntax($newText));
    }
}