EloquentEngine::connect() - Code Metrics - awssat/laravel-visits - Measure and Improve Code Quality continuously with Scrutinizer

EloquentEngine::connect() A
last analyzed 2021-02-03 01:23 UTC

↳ Parent: EloquentEngine
Complexity

Conditions	1
Paths	1
Size

Total Lines	3
Code Lines	1
Duplication

Lines	0
Ratio	0 %
Importance

Changes	1
Bugs	0	Features	1
Metric	Value
cc	1
eloc	1
nc	1
nop	1
dl	0
loc	3
rs	10
c	1
b	0
f	1
<?php
namespace Awssat\Visits\DataEngines;

use Awssat\Visits\Models\Visit as Model;

class EloquentEngine implements DataEngine
{
    private $model = null;
    private $prefix = null;

    public function __construct(Model $model)
    {
        $this->model = $model;
    }

    public function connect(string $connection): DataEngine
    {
        return $this;
    }

    public function setPrefix(string $prefix): DataEngine
    {
        $this->prefix = $prefix . ':';
        return $this;
    }

    public function increment(string $key, int $value, $member = null): bool
    {
        if (! empty($member) || is_numeric($member)) {
            $row = $this->model->firstOrNew(['primary_key' => $this->prefix.$key, 'secondary_key' => $member]);
        } else {
            $row = $this->model->firstOrNew(['primary_key' => $this->prefix.$key, 'secondary_key' => null]);
        }
   
        if($row->expired_at !== null && \Carbon\Carbon::now()->gt($row->expired_at)) {
            $row->score = $value;
            $row->expired_at = null;
        } else {
            $row->score += $value;
        }

        return $row->save();
    }

    public function decrement(string $key, int $value, $member = null): bool
    {
        return $this->increment($key, -$value, $member);
    }

    public function delete($key, $member = null): bool
    {
        if(is_array($key)) {
            array_walk($key, function($item) {
                $this->delete($item);
            });
            return true;
        }

        if(! empty($member) || is_numeric($member)) {
            return $this->model->where(['primary_key' => $this->prefix.$key, 'secondary_key' => $member])->delete();

        } else {
            return $this->model->where(['primary_key' => $this->prefix.$key])->delete();

        }
    }

    public function get(string $key, $member = null)
    {
        if(! empty($member) || is_numeric($member)) {
             return $this->model->where(['primary_key' => $this->prefix.$key, 'secondary_key' => $member])
            ->where(function($q) {
                return $q->where('expired_at', '>', \Carbon\Carbon::now())->orWhereNull('expired_at');
            })
            ->value('score');
        } else {
            return $this->model->where(['primary_key' => $this->prefix.$key, 'secondary_key' => null])
            ->where(function($q) {
                return $q->where('expired_at', '>', \Carbon\Carbon::now())->orWhereNull('expired_at');
            })
            ->value('score');
        }
    }

    public function set(string $key, $value, $member = null): bool
    {
        if(! empty($member) || is_numeric($member)) {
            return $this->model->updateOrCreate([
                'primary_key' => $this->prefix.$key, 
                'secondary_key' => $member,
                'score' => $value,
                'expired_at' => null,
                ]) instanceof Model;
        } else {
            return $this->model->updateOrCreate([
                'primary_key' => $this->prefix.$key, 
                'score' => $value,
                'expired_at' => null,
                ]) instanceof Model;
        }
    }

    public function search(string $word, bool $noPrefix = true): array
    {
        $results = [];

        if($word == '*') {
            $results = $this->model
                        ->where(function($q) {
                            return $q->where('expired_at', '>', \Carbon\Carbon::now())->orWhereNull('expired_at');
                        })
                        ->pluck('primary_key');
        } else {
            $results = $this->model->where('primary_key', 'like', $this->prefix.str_replace('*', '%', $word))
                                ->where(function($q) {
                                    return $q->where('expired_at', '>', \Carbon\Carbon::now())->orWhereNull('expired_at');
                                })
                                ->pluck('primary_key');
        }
    
        return array_map(
            function($item) use($noPrefix) {
                if ($noPrefix && substr($item, 0, strlen($this->prefix)) == $this->prefix) {
                    return substr($item, strlen($this->prefix));
                } 

                return $item;
            },
            $results->toArray() ?? []
        );
    }

    public function flatList(string $key, int $limit = -1): array
    {
        return array_slice(
            $this->model->where(['primary_key' => $this->prefix.$key, 'secondary_key' => null])
            /** @scrutinizer ignore-type */ $this->model->where(['primary_key' => $this->prefix.$key, 'secondary_key' => null])
                        ->where(function($q) {
                            return $q->where('expired_at', '>', \Carbon\Carbon::now())->orWhereNull('expired_at');
                        })
                        ->value('list') ?? [], 0, $limit
        );
    }

    public function addToFlatList(string $key, $value): bool
    {
        $row = $this->model->firstOrNew(['primary_key' => $this->prefix.$key, 'secondary_key' => null]);

        if($row->expired_at !== null && \Carbon\Carbon::now()->gt($row->expired_at)) {

            $row->list = (array) $value;

            $row->expired_at = null;
        } else {
            $row->list = array_merge($row->list ?? [], (array) $value);
        }

        $row->score =  $row->score ?? 0;

        return (bool) $row->save();
    }

    public function valueList(string $key, int $limit = -1, bool $orderByAsc = false, bool $withValues = false): array
    {
        $rows = $this->model->where('primary_key', $this->prefix.$key)
                            ->where(function($q) {
                                return $q->where('expired_at', '>', \Carbon\Carbon::now())->orWhereNull('expired_at');
                            })
                            ->whereNotNull('secondary_key')
                            ->orderBy('score', $orderByAsc ? 'asc' : 'desc')
                            ->when($limit > -1, function($q) use($limit) {
                                return $q->limit($limit+1);
                            })->pluck('score', 'secondary_key') ?? \Illuminate\Support\Collection::make();

        return $withValues ? $rows->toArray() : array_keys($rows->toArray());
    }

    public function exists(string $key): bool
    {
        return $this->model->where(['primary_key' => $this->prefix.$key, 'secondary_key' => null])

                            ->where(function($q) {
                                return $q->where('expired_at', '>', \Carbon\Carbon::now())->orWhereNull('expired_at');
                            })
                            ->exists();
    }

    public function timeLeft(string $key): int
    {
        $expired_at = $this->model->where(['primary_key' => $this->prefix.$key])->value('expired_at');

        if($expired_at === null) {
            return -2;
        }

        $ttl =  $expired_at->timestamp - \Carbon\Carbon::now()->timestamp;

        return $ttl <= 0 ? -1 : $ttl;

    }

    public function setExpiration(string $key, int $time): bool
    {
         return $this->model->where(['primary_key' => $this->prefix.$key])

                                ->where(function($q) {
                                    return $q->where('expired_at', '>', \Carbon\Carbon::now())->orWhereNull('expired_at');
                                })
                            ->update([
                                'expired_at' => \Carbon\Carbon::now()->addSeconds($time)
                            ]);
    }
}
awssat / laravel-visits

EloquentEngine::connect() A last analyzed 2021-02-03 01:23 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

EloquentEngine::connect() A
last analyzed 2021-02-03 01:23 UTC
