hiqdev\assetpackagist\repositories\PackageRepository

Complexity

Total Complexity

12

Size/Duplication

Total Lines	118
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

0%

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	save()	0	8	2
A	insert()	0	8	1
A	update()	0	6	1
A	markAvoided()	0	6	1
A	isAvoided()	0	8	1
A	getWhereCondition()	0	7	1
A	exists()	0	7	1
A	getExpiredForUpdate()	0	11	1
A	hydrate()	0	9	2

<?php
/**
 * Asset Packagist.
 *
 * @link      https://github.com/hiqdev/asset-packagist
 * @package   asset-packagist
 * @license   BSD-3-Clause
 * @copyright Copyright (c) 2016-2017, HiQDev (http://hiqdev.com/)
 */

namespace hiqdev\assetpackagist\repositories;

use hiqdev\assetpackagist\models\AssetPackage;
use yii\db\Connection;
use yii\db\Query;

class PackageRepository
{
    /**
     * @var Connection
     */
    protected $db;

    /**
     * PackageRepository constructor.
     * @param Connection $db
     */
    public function __construct(Connection $db)
    {
        $this->db = $db;
    }

    /**
     * @param AssetPackage $package
     * @return int
     */
    public function save(AssetPackage $package)
    {
        if ($this->exists($package)) {
            return $this->update($package);
        } else {
            return $this->insert($package);
        }
    }

    /**
     * @param AssetPackage $package
     * @return int
     */
    public function insert(AssetPackage $package)
    {
        return $this->db->createCommand()->insert('package', [
            'type' => $package->getType(),
            'name' => $package->getName(),
            'last_update' => $package->getUpdateTime(),
        ])->execute();
    }

    /**
     * @param AssetPackage $package
     * @return int
     */
    public function update(AssetPackage $package)
    {
        return $this->db->createCommand()->update('package', [
            'last_update' => $package->getUpdateTime(),
        ], $this->getWhereCondition($package))->execute();
    }

    public function markAvoided(AssetPackage $package)
    {
        $this->db->createCommand()->update('package', [
            'is_avoided' => true,
        ], $this->getWhereCondition($package))->execute();
    }

    public function isAvoided(AssetPackage $package)
    {
        return (new Query())
            ->select('is_avoided')
            ->from('package')
            ->where($this->getWhereCondition($package))
            ->scalar($this->db);
    }

    protected function getWhereCondition(AssetPackage $package)
    {
        return [
            'type' => $package->getType(),
            'name' => $package->getName(),
        ];
    }

    /**
     * @param AssetPackage $package
     * @return bool
     */
    public function exists(AssetPackage $package)
    {
        return (new Query())
            ->from('package')
            ->where($this->getWhereCondition($package))
            ->exists($this->db);
    }

    /**
     * @return \hiqdev\assetpackagist\models\AssetPackage[]
     */
    public function getExpiredForUpdate()
    {
        $rows = (new Query())
            ->from('package')
            ->where(['<', 'last_update', time() - 60 * 60 * 24 * 7]) // Older than 7 days
            ->andWhere(['not', ['last_update' => null]])
            ->andWhere(['is_avoided' => 0])
            ->all();

        return $this->hydrate($rows);
    }

    /**
     * @param array $rows
     * @return AssetPackage[]
     */
    public function hydrate($rows)
    {
        $result = [];
        foreach ($rows as $row) {
            $result[] = new AssetPackage($row['type'], $row['name']);
        }

        return $result;
    }
}