hiqdev\assetpackagist\repositories\PackageRepository

Complexity

Total Complexity

11

Size/Duplication

Total Lines	108
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes	3
Bugs	0	Features	0

9 Methods

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

<?php

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();
    }

    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(['type' => $package->getType(), 'name' => $package->getName()])
            ->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' => null])
            ->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;
    }
}