hiqdev\assetpackagist\repositories\PackageRepository

Complexity

Total Complexity

9

Size/Duplication

Total Lines	94
Duplicated Lines	17.02 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	save()	0	8	2
A	insert()	7	7	1
A	update()	9	9	1
A	exists()	0	7	1
A	getExpired()	0	9	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) {

This method seems to be duplicated in your project.

        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)

This method seems to be duplicated in your project.

    {
        return $this->db->createCommand()->update('package', [
            'last_update' => $package->getUpdateTime()
        ], [
            'type' => $package->getType(),
            'name' => $package->getName(),
        ])->execute();
    }

    /**
     * @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 getExpired()
    {
        $rows = (new Query())
            ->from('package')
            ->where(['<', 'last_update', time() - 60 * 60 * 24 * 7]) // Older than 7 days
            ->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;
    }
}