Awssat\Visits\Traits\Lists

Complexity

Total Complexity

15

Size/Duplication

Total Lines	128
Duplicated Lines	0 %

Importance

Changes	1
Bugs	1	Features	0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	languages()	0	3	1
A	getVisitsIds()	0	5	2
A	refs()	0	3	1
A	getSortedList()	0	3	1
A	freshList()	0	19	2
A	low()	0	3	1
A	operatingSystems()	0	3	1
A	countries()	0	3	1
A	top()	0	17	4
A	cachedList()	0	4	1

<?php

namespace Awssat\Visits\Traits;

use Illuminate\Support\Collection;

trait Lists
{
    /**
     * Fetch all time trending subjects.
     *
     * @param int $limit
     * @param array $constraints optional. filter models by attributes (where=[...])
     * @return \Illuminate\Support\Collection|array
     */
    public function top($limit = 5, $orderByAsc = false, $constraints = [])
    {
        if(is_array($orderByAsc)) {
            $constraints = $orderByAsc;
            $orderByAsc = false;
        }

        $cacheKey = $this->keys->cache($limit, $orderByAsc, $constraints);

        $cachedList = $this->cachedList($limit, $cacheKey);
        $visitsIds = $this->getVisitsIds($limit, $this->keys->visits, $orderByAsc);

        if($visitsIds === $cachedList->pluck($this->keys->primary)->toArray() && ! $this->fresh) {
            return $cachedList;
        }

        return $this->freshList($cacheKey, $visitsIds, $constraints);
    }


    /**
     * Top/low countries
     */
    public function countries($limit = -1, $orderByAsc = false)
    {
        return $this->getSortedList('countries', $limit, $orderByAsc, true);
    }

    /**
     * top/lows refs
     */
    public function refs($limit = -1, $orderByAsc = false)
    {
        return $this->getSortedList('referers', $limit, $orderByAsc, true);
    }

    /**
     * top/lows operating systems
     */
    public function operatingSystems($limit = -1, $orderByAsc = false)
    {
        return $this->getSortedList('OSes', $limit, $orderByAsc, true);
    }

    /**
     * top/lows languages
     */
    public function languages($limit = -1, $orderByAsc = false)
    {
        return $this->getSortedList('languages', $limit, $orderByAsc, true);
    }


    protected function getSortedList($name, $limit, $orderByAsc = false, $withValues = true)
    {
        return $this->connection->valueList($this->keys->visits . "_{$name}:{$this->keys->id}", $limit, $orderByAsc, $withValues);
    }

    /**
     * Fetch lowest subjects.
     *
     * @param int $limit
     * @param array $constraints optional
     * @return \Illuminate\Support\Collection|array
     */
    public function low($limit = 5, $constraints = [])
    {
        return $this->top($limit, true, $constraints);
    }


    /**
     * @param $limit
     * @param $visitsKey
     * @param bool $isLow
     * @return mixed
     */
    protected function getVisitsIds($limit, $visitsKey, $orderByAsc = false)
    {
        return array_map(function($item) {
            return is_numeric($item) ? intval($item) : $item;
        }, $this->connection->valueList($visitsKey, $limit - 1, $orderByAsc));
    }

    /**
     * @param $cacheKey
     * @param $visitsIds
     * @return mixed
     */
    protected function freshList($cacheKey, $visitsIds, $constraints = [])
    {
        if (count($visitsIds)) {

            $this->connection->delete($cacheKey);

            return ($this->subject)::whereIn($this->keys->primary, $visitsIds)
                ->when(count($constraints), function($query) use($constraints) {
                    return $query->where($constraints);
                })
                ->get()
                ->sortBy(function ($subject) use ($visitsIds) {
                    return array_search($subject->{$this->keys->primary}, $visitsIds);
                })->each(function ($subject) use ($cacheKey) {
                    $this->connection->addToFlatList($cacheKey, serialize($subject));
                });
        }

        return [];
    }

    /**
     * @param $limit
     * @param $cacheKey
     * @return \Illuminate\Support\Collection|array
     */
    protected function cachedList($limit, $cacheKey)
    {
        return Collection::make(
            array_map('unserialize', $this->connection->flatList($cacheKey, $limit))
        );
    }
}