Update StatusHashtagService, use more efficient cached count

pull/4989/head
Daniel Supernault 2024-03-07 02:37:35 -07:00
rodzic e68fe64ffc
commit 592c84125c
Nie znaleziono w bazie danych klucza dla tego podpisu
ID klucza GPG: 23740873EE6F76A1
1 zmienionych plików z 78 dodań i 77 usunięć

Wyświetl plik

@ -2,96 +2,97 @@
namespace App\Services; namespace App\Services;
use Cache; use App\Hashtag;
use Illuminate\Support\Facades\Redis; use App\Status;
use App\{Status, StatusHashtag}; use App\StatusHashtag;
use App\Transformer\Api\StatusHashtagTransformer;
use App\Transformer\Api\HashtagTransformer; use App\Transformer\Api\HashtagTransformer;
use League\Fractal; use League\Fractal;
use League\Fractal\Serializer\ArraySerializer; use League\Fractal\Serializer\ArraySerializer;
use League\Fractal\Pagination\IlluminatePaginatorAdapter;
class StatusHashtagService { class StatusHashtagService
{
const CACHE_KEY = 'pf:services:status-hashtag:collection:';
const CACHE_KEY = 'pf:services:status-hashtag:collection:'; public static function get($id, $page = 1, $stop = 9)
{
if ($page > 20) {
return [];
}
public static function get($id, $page = 1, $stop = 9) $pid = request()->user() ? request()->user()->profile_id : false;
{ $filtered = $pid ? UserFilterService::filters($pid) : [];
if($page > 20) {
return [];
}
$pid = request()->user() ? request()->user()->profile_id : false; return StatusHashtag::whereHashtagId($id)
$filtered = $pid ? UserFilterService::filters($pid) : []; ->whereStatusVisibility('public')
->skip($stop)
->latest()
->take(9)
->pluck('status_id')
->map(function ($i, $k) use ($id) {
return self::getStatus($i, $id);
})
->filter(function ($i) use ($filtered) {
return isset($i['status']) &&
! empty($i['status']) && ! in_array($i['status']['account']['id'], $filtered) &&
isset($i['status']['media_attachments']) &&
! empty($i['status']['media_attachments']);
})
->values();
}
return StatusHashtag::whereHashtagId($id) public static function coldGet($id, $start = 0, $stop = 2000)
->whereStatusVisibility('public') {
->skip($stop) $stop = $stop > 2000 ? 2000 : $stop;
->latest() $ids = StatusHashtag::whereHashtagId($id)
->take(9) ->whereStatusVisibility('public')
->pluck('status_id') ->whereHas('media')
->map(function ($i, $k) use ($id) { ->latest()
return self::getStatus($i, $id); ->skip($start)
}) ->take($stop)
->filter(function ($i) use($filtered) { ->pluck('status_id');
return isset($i['status']) && foreach ($ids as $key) {
!empty($i['status']) && !in_array($i['status']['account']['id'], $filtered) && self::set($id, $key);
isset($i['status']['media_attachments']) && }
!empty($i['status']['media_attachments']);
})
->values();
}
public static function coldGet($id, $start = 0, $stop = 2000) return $ids;
{ }
$stop = $stop > 2000 ? 2000 : $stop;
$ids = StatusHashtag::whereHashtagId($id)
->whereStatusVisibility('public')
->whereHas('media')
->latest()
->skip($start)
->take($stop)
->pluck('status_id');
foreach($ids as $key) {
self::set($id, $key);
}
return $ids;
}
public static function set($key, $val) public static function set($key, $val)
{ {
return 1; return 1;
} }
public static function del($key) public static function del($key)
{ {
return 1; return 1;
} }
public static function count($id) public static function count($id)
{ {
$key = 'pf:services:status-hashtag:count:' . $id; $cc = Hashtag::find($id);
$ttl = now()->addMinutes(5); if (! $cc) {
return Cache::remember($key, $ttl, function() use($id) { return 0;
return StatusHashtag::whereHashtagId($id)->has('media')->count(); }
});
}
public static function getStatus($statusId, $hashtagId) return $cc->cached_count ?? 0;
{ }
return ['status' => StatusService::get($statusId)];
}
public static function statusTags($statusId) public static function getStatus($statusId, $hashtagId)
{ {
$status = Status::with('hashtags')->find($statusId); return ['status' => StatusService::get($statusId)];
if(!$status) { }
return [];
}
$fractal = new Fractal\Manager(); public static function statusTags($statusId)
$fractal->setSerializer(new ArraySerializer()); {
$resource = new Fractal\Resource\Collection($status->hashtags, new HashtagTransformer()); $status = Status::with('hashtags')->find($statusId);
return $fractal->createData($resource)->toArray(); if (! $status) {
} return [];
}
$fractal = new Fractal\Manager();
$fractal->setSerializer(new ArraySerializer());
$resource = new Fractal\Resource\Collection($status->hashtags, new HashtagTransformer());
return $fractal->createData($resource)->toArray();
}
} }