RepositoriesHandler::updateTableRepositories() - Code Metrics - ggoffy/wggithub - Measure and Improve Code Quality continuously with Scrutinizer

RepositoriesHandler::updateTableRepositories() F
last analyzed 2025-03-21 14:15 UTC

↳ Parent: RepositoriesHandler
Complexity

Conditions	19
Paths	624
Size

Total Lines	78
Code Lines	57
Duplication

Lines	0
Ratio	0 %
Importance

Changes	1
Bugs	0	Features	1
Metric	Value
cc	19
eloc	57
c	1
b	0
f	1
nc	624
nop	4
dl	0
loc	78
rs	0.8722
How to fix Long Method Complexity

<?php

namespace XoopsModules\Wggithub;

/*
 You may not change or alter any portion of this comment or credits
 of supporting developers from this source code or any supporting source code
 which is considered copyrighted (c) material of the original comment or credit authors.

 This program is distributed in the hope that it will be useful,
 but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
*/

/**
 * wgGitHub module for xoops
 *
 * @copyright      2020 XOOPS Project (https://xooops.org)
 * @license        GPL 2.0 or later
 * @package        wggithub
 * @since          1.0
 * @min_xoops      2.5.10
 * @author         Goffy - XOOPS Development Team - Email:<[email protected]> - Website:<https://wedega.com>
 */

use XoopsModules\Wggithub;


/**
 * Class Object Handler Repositories
 */
class RepositoriesHandler extends \XoopsPersistableObjectHandler
filter:
    dependency_paths: ["lib/*"]
{
    /**
     * Constructor
     *
     * @param \XoopsDatabase $db
     */
    public function __construct(\XoopsDatabase $db)
filter:
    dependency_paths: ["lib/*"]
    {
        parent::__construct($db, 'wggithub_repositories', Repositories::class, 'repo_id', 'repo_name');
    }

    /**
     * @param bool $isNew
     *
     * @return object
     */
    public function create($isNew = true)
    {
        return parent::create($isNew);
    }

    /**
     * retrieve a field
     *
     * @param int $i field id
     * @param null fields
filter:
    dependency_paths: ["lib/*"]
     * @return mixed reference to the {@link Get} object
     */
    public function get($i = null, $fields = null)
    {
        return parent::get($i, $fields);
    }

    /**
     * get inserted id
     *
     * @param null
     * @return int reference to the {@link Get} object
     */
    public function getInsertId()
    {
        return $this->db->getInsertId();
    }

    /**
     * Get Count Repositories in the database
     * @param int    $start
     * @param int    $limit
     * @param string $sort
     * @param string $order
     * @return int
     */
    public function getCountRepositories($start = 0, $limit = 0, $sort = 'repo_id ASC, repo_name', $order = 'ASC')
    {
        $crCountRepositories = new \CriteriaCompo();
filter:
    dependency_paths: ["lib/*"]
        $crCountRepositories = $this->getRepositoriesCriteria($crCountRepositories, $start, $limit, $sort, $order);
        return $this->getCount($crCountRepositories);
    }

    /**
     * Get All Repositories in the database
     * @param int    $start
     * @param int    $limit
     * @param string $sort
     * @param string $order
     * @return array
     */
    public function getAllRepositories($start = 0, $limit = 0, $sort = 'repo_id ASC, repo_name', $order = 'ASC')
    {
        $crAllRepositories = new \CriteriaCompo();
        $crAllRepositories = $this->getRepositoriesCriteria($crAllRepositories, $start, $limit, $sort, $order);
        return $this->getAll($crAllRepositories);
    }

    /**
     * Get Criteria Repositories
     * @param        $crRepositories
     * @param int    $start
     * @param int    $limit
     * @param string $sort
     * @param string $order
     * @return int
     */
    private function getRepositoriesCriteria($crRepositories, $start, $limit, $sort, $order)
    {
        $crRepositories->setStart($start);
        $crRepositories->setLimit($limit);
        $crRepositories->setSort($sort);
        $crRepositories->setOrder($order);
        return $crRepositories;
    }

    /**
     * Update table repositories
     *
     * @param       $user
     * @param array $repos
     * @param bool  $updateAddtionals
     * @param int   $dirContent
     * @return int
     */
    public function updateTableRepositories($user, $repos = [], $updateAddtionals = true, $dirContent = 0)
    {
        $reposNb = 0;
        $helper = \XoopsModules\Wggithub\Helper::getInstance();
        $repositoriesHandler = $helper->getHandler('Repositories');

        $submitter = isset($GLOBALS['xoopsUser']) && \is_object($GLOBALS['xoopsUser']) ? $GLOBALS['xoopsUser']->getVar('uid') : 0;
        // add/update all items from table repositories
        foreach ($repos as $key => $repo) {
            $fork = (bool)$repo['fork'];
            if (Constants::DIRECTORY_CONTENT_ALL == $dirContent || false === $fork) {
                $crRepositories = new \CriteriaCompo();
                $crRepositories->add(new \Criteria('repo_nodeid', $repo['node_id']));
filter:
    dependency_paths: ["lib/*"]
                $repoId = 0;
                $status = 0;
                $updatedAtOld = 0;
                $updatedAtNew = 0;
                $repositoriesAll = $repositoriesHandler->getAll($crRepositories);
                foreach (\array_keys($repositoriesAll) as $i) {
                    $repoId = $repositoriesAll[$i]->getVar('repo_id');
                    $updatedAtOld = $repositoriesAll[$i]->getVar('repo_updatedat');
                    $status = $repositoriesAll[$i]->getVar('repo_status');
                    $repositoriesObj = $repositoriesAll[$i];
                }
                if ($repoId > 0) {
                    if (\is_string($repo['pushed_at'])) {
                        $updatedAtNew = \strtotime($repo['pushed_at']);
                    } elseif (\is_string($repo['updated_at'])) {
                        $updatedAtNew = \strtotime($repo['updated_at']);
                    }
                    if ($updatedAtOld != Constants::STATUS_OFFLINE && $updatedAtOld != $updatedAtNew) {
                        $status = Constants::STATUS_UPDATED;
                    }
                } else {
                    $repositoriesObj = $repositoriesHandler->create();
                    $updatedAtNew = \strtotime($repo['updated_at']);
                    $status = Constants::STATUS_NEW;
                }
                if (Constants::STATUS_UPTODATE !== $status) {
                    // Set Vars
                    $repositoriesObj->setVar('repo_nodeid', $repo['node_id']);

                    $repositoriesObj->setVar('repo_user', $user);
                    $repositoriesObj->setVar('repo_name', $repo['name']);
                    $repositoriesObj->setVar('repo_fullname', $repo['full_name']);
                    if (\is_string($repo['created_at'])) {
                        $createdAt = \strtotime($repo['created_at']);
                    }
                    $repositoriesObj->setVar('repo_createdat', $createdAt);

                    $repositoriesObj->setVar('repo_updatedat', $updatedAtNew);
                    $repositoriesObj->setVar('repo_htmlurl', $repo['html_url']);
                    $repositoriesObj->setVar('repo_status', $status);
                    $repositoriesObj->setVar('repo_datecreated', \time());
                    $repositoriesObj->setVar('repo_submitter', $submitter);
                    // Insert Data
                    if ($repositoriesHandler->insert($repositoriesObj)) {
                        $newRepoId = $repositoriesObj->getNewInsertedIdRepositories();
                        if (0 == $repoId) {
                            $repoId = $newRepoId;
                        }
                        $reposNb++;
                        if ($updateAddtionals && (Constants::STATUS_NEW == $status || Constants::STATUS_UPDATED == $status)) {
                            // add/update table readmes
                            $helper->getHandler('Readmes')->updateReadmes($repoId, $user, $repo['name']);
                            // add/update table release
                            $helper->getHandler('Releases')->updateReleases($repoId, $user, $repo['name']);
                            // change status to updated
                            $repositoriesObj = $repositoriesHandler->get($repoId);
                            $repositoriesObj->setVar('repo_status', Constants::STATUS_UPTODATE);
                            $repositoriesHandler->insert($repositoriesObj, true);
                        }
                    } else {
                        return false;

                    }
                }
            }
        }

        return $reposNb;
    }

    /**
     * @public function getForm
     * @param bool   $action
     * @param int    $start
     * @param int    $limit
     * @param string $filterValue
     * @param int    $filterStatus
     * @return \XoopsSimpleForm
     */
    public function getFormFilterRepos($action = false, $start = 0, $limit = 0, $filterValue = '', $filterStatus = 0)
    {
        if (!$action) {
            $action = $_SERVER['REQUEST_URI'];
        }
        // Get Theme Form
        \xoops_load('XoopsFormLoader');
        /** @scrutinizer ignore-call */ \xoops_load('XoopsFormLoader');
        $form = new \XoopsSimpleForm('', 'formFilterAdmin', $action, 'post', true);
filter:
    dependency_paths: ["lib/*"]
        $form->setExtra('enctype="multipart/form-data"');
        $filterTray = new \XoopsFormElementTray('', '&nbsp;');
filter:
    dependency_paths: ["lib/*"]
        // Form Select field
        $fieldSelect = new \XoopsFormSelect(\_AM_WGGITHUB_FILTER, 'filter_field', 'repo_name');
filter:
    dependency_paths: ["lib/*"]
        $fieldSelect->addOption('', ' ');
        $fieldSelect->addOption('repo_user', \_AM_WGGITHUB_REPOSITORY_USER);
        $fieldSelect->addOption('repo_name', \_AM_WGGITHUB_REPOSITORY_NAME);
        $fieldSelect->addOption('repo_fullname', \_AM_WGGITHUB_REPOSITORY_FULLNAME);
        $filterTray->addElement($fieldSelect, true);
        // Form Select operand
        $operandsSelect = new \XoopsFormSelect('', 'filter_operand', Constants::FILTER_OPERAND_LIKE);
        $operandsSelect->addOption(Constants::FILTER_OPERAND_EQUAL, \_AM_WGGITHUB_FILTER_OPERAND_EQUAL);
        $operandsSelect->addOption(Constants::FILTER_OPERAND_LIKE, \_AM_WGGITHUB_FILTER_OPERAND_LIKE);
        $filterTray->addElement($operandsSelect);
        // Form Text value
        $filterTray->addElement(new \XoopsFormText('', 'filter_value', 20, 255, $filterValue), true);
filter:
    dependency_paths: ["lib/*"]
        // Form Select Status repoStatus
        $repoStatusSelect = new \XoopsFormSelect(\_AM_WGGITHUB_REPOSITORY_STATUS, 'filter_status', $filterStatus);
        $repoStatusSelect->addOption(Constants::STATUS_NONE, ' ');
        $repoStatusSelect->addOption(Constants::STATUS_UPTODATE, \_AM_WGGITHUB_STATUS_UPTODATE);
        $repoStatusSelect->addOption(Constants::STATUS_UPDATED, \_AM_WGGITHUB_STATUS_UPDATED);
        $repoStatusSelect->addOption(Constants::STATUS_OFFLINE, \_AM_WGGITHUB_STATUS_OFFLINE);
        $filterTray->addElement($repoStatusSelect);
        // Form button
        $filterTray->addElement(new \XoopsFormButton('', 'confirm_submit', \_SUBMIT, 'submit'));
filter:
    dependency_paths: ["lib/*"]
        $form->addElement($filterTray);
        // To Save
        $form->addElement(new \XoopsFormHidden('op', 'filter'));
filter:
    dependency_paths: ["lib/*"]
        $form->addElement(new \XoopsFormHidden('start', $start));
        $form->addElement(new \XoopsFormHidden('limit', $limit));

        return $form;
    }
}

ggoffy / wggithub

RepositoriesHandler::updateTableRepositories() F last analyzed 2025-03-21 14:15 UTC

Complexity

Size

Duplication

Importance

How to fix Long Method Complexity

Long Method

Duplication Side-by-Side

Filter issues like

RepositoriesHandler::updateTableRepositories() F
last analyzed 2025-03-21 14:15 UTC
