mirror of
https://github.com/pixelfed/pixelfed.git
synced 2024-12-29 08:23:17 +00:00
368 lines
13 KiB
PHP
368 lines
13 KiB
PHP
<?php
|
|
|
|
namespace App\Http\Controllers;
|
|
|
|
use App\Hashtag;
|
|
use App\Place;
|
|
use App\Profile;
|
|
use App\Services\WebfingerService;
|
|
use App\Status;
|
|
use App\Util\ActivityPub\Helpers;
|
|
use Auth;
|
|
use Illuminate\Http\Request;
|
|
use Illuminate\Support\Facades\Cache;
|
|
use Illuminate\Support\Str;
|
|
|
|
class SearchController extends Controller
|
|
{
|
|
public $tokens = [];
|
|
|
|
public $term = '';
|
|
|
|
public $hash = '';
|
|
|
|
public $cacheKey = 'api:search:tag:';
|
|
|
|
public function __construct()
|
|
{
|
|
$this->middleware('auth');
|
|
}
|
|
|
|
public function searchAPI(Request $request)
|
|
{
|
|
$this->validate($request, [
|
|
'q' => 'required|string|min:3|max:120',
|
|
'src' => 'required|string|in:metro',
|
|
'v' => 'required|integer|in:2',
|
|
'scope' => 'required|in:all,hashtag,profile,remote,webfinger',
|
|
]);
|
|
|
|
$scope = $request->input('scope') ?? 'all';
|
|
$this->term = e(urldecode($request->input('q')));
|
|
$this->hash = hash('sha256', $this->term);
|
|
|
|
switch ($scope) {
|
|
case 'all':
|
|
$this->getHashtags();
|
|
$this->getPosts();
|
|
$this->getProfiles();
|
|
// $this->getPlaces();
|
|
break;
|
|
|
|
case 'hashtag':
|
|
$this->getHashtags();
|
|
break;
|
|
|
|
case 'profile':
|
|
$this->getProfiles();
|
|
break;
|
|
|
|
case 'webfinger':
|
|
$this->webfingerSearch();
|
|
break;
|
|
|
|
case 'remote':
|
|
$this->remoteLookupSearch();
|
|
break;
|
|
|
|
case 'place':
|
|
$this->getPlaces();
|
|
break;
|
|
|
|
default:
|
|
break;
|
|
}
|
|
|
|
return response()->json($this->tokens, 200, [], JSON_PRETTY_PRINT);
|
|
}
|
|
|
|
protected function getPosts()
|
|
{
|
|
$tag = $this->term;
|
|
$hash = hash('sha256', $tag);
|
|
if (Helpers::validateUrl($tag) != false &&
|
|
Helpers::validateLocalUrl($tag) != true &&
|
|
(bool) config_cache('federation.activitypub.enabled') == true &&
|
|
config('federation.activitypub.remoteFollow') == true
|
|
) {
|
|
$remote = Helpers::fetchFromUrl($tag);
|
|
if (isset($remote['type']) &&
|
|
in_array($remote['type'], ['Note', 'Question'])
|
|
) {
|
|
$item = Helpers::statusFetch($tag);
|
|
$this->tokens['posts'] = [[
|
|
'count' => 0,
|
|
'url' => $item->url(),
|
|
'type' => 'status',
|
|
'value' => "by {$item->profile->username} <span class='float-right'>{$item->created_at->diffForHumans(null, true, true)}</span>",
|
|
'tokens' => [$item->caption],
|
|
'name' => $item->caption,
|
|
'thumb' => $item->thumb(),
|
|
]];
|
|
}
|
|
} else {
|
|
$posts = Status::select('id', 'profile_id', 'caption', 'created_at')
|
|
->whereHas('media')
|
|
->whereNull('in_reply_to_id')
|
|
->whereNull('reblog_of_id')
|
|
->whereProfileId(Auth::user()->profile_id)
|
|
->where('caption', 'like', '%'.$tag.'%')
|
|
->latest()
|
|
->limit(10)
|
|
->get();
|
|
|
|
if ($posts->count() > 0) {
|
|
$posts = $posts->map(function ($item, $key) {
|
|
return [
|
|
'count' => 0,
|
|
'url' => $item->url(),
|
|
'type' => 'status',
|
|
'value' => "by {$item->profile->username} <span class='float-right'>{$item->created_at->diffForHumans(null, true, true)}</span>",
|
|
'tokens' => [$item->caption],
|
|
'name' => $item->caption,
|
|
'thumb' => $item->thumb(),
|
|
'filter' => $item->firstMedia()->filter_class,
|
|
];
|
|
});
|
|
$this->tokens['posts'] = $posts;
|
|
}
|
|
}
|
|
}
|
|
|
|
protected function getHashtags()
|
|
{
|
|
$tag = $this->term;
|
|
$key = $this->cacheKey.'hashtags:'.$this->hash;
|
|
$ttl = now()->addMinutes(1);
|
|
$tokens = Cache::remember($key, $ttl, function () use ($tag) {
|
|
$htag = Str::startsWith($tag, '#') == true ? mb_substr($tag, 1) : $tag;
|
|
$hashtags = Hashtag::select('id', 'name', 'slug')
|
|
->where('slug', 'like', '%'.$htag.'%')
|
|
->whereHas('posts')
|
|
->limit(20)
|
|
->get();
|
|
if ($hashtags->count() > 0) {
|
|
$tags = $hashtags->map(function ($item, $key) {
|
|
return [
|
|
'count' => $item->posts()->count(),
|
|
'url' => $item->url(),
|
|
'type' => 'hashtag',
|
|
'value' => $item->name,
|
|
'tokens' => '',
|
|
'name' => null,
|
|
];
|
|
});
|
|
|
|
return $tags;
|
|
}
|
|
});
|
|
$this->tokens['hashtags'] = $tokens;
|
|
}
|
|
|
|
protected function getPlaces()
|
|
{
|
|
$tag = $this->term;
|
|
// $key = $this->cacheKey . 'places:' . $this->hash;
|
|
// $ttl = now()->addHours(12);
|
|
// $tokens = Cache::remember($key, $ttl, function() use($tag) {
|
|
$htag = Str::contains($tag, ',') == true ? explode(',', $tag) : [$tag];
|
|
$hashtags = Place::select('id', 'name', 'slug', 'country')
|
|
->where('name', 'like', '%'.$htag[0].'%')
|
|
->paginate(20);
|
|
$tags = [];
|
|
if ($hashtags->count() > 0) {
|
|
$tags = $hashtags->map(function ($item, $key) {
|
|
return [
|
|
'count' => null,
|
|
'url' => $item->url(),
|
|
'type' => 'place',
|
|
'value' => $item->name.', '.$item->country,
|
|
'tokens' => '',
|
|
'name' => null,
|
|
'city' => $item->name,
|
|
'country' => $item->country,
|
|
];
|
|
});
|
|
// return $tags;
|
|
}
|
|
// });
|
|
$this->tokens['places'] = $tags;
|
|
$this->tokens['placesPagination'] = [
|
|
'total' => $hashtags->total(),
|
|
'current_page' => $hashtags->currentPage(),
|
|
'last_page' => $hashtags->lastPage(),
|
|
];
|
|
}
|
|
|
|
protected function getProfiles()
|
|
{
|
|
$tag = $this->term;
|
|
$remoteKey = $this->cacheKey.'profiles:remote:'.$this->hash;
|
|
$key = $this->cacheKey.'profiles:'.$this->hash;
|
|
$remoteTtl = now()->addMinutes(15);
|
|
$ttl = now()->addHours(2);
|
|
if (Helpers::validateUrl($tag) != false &&
|
|
Helpers::validateLocalUrl($tag) != true &&
|
|
(bool) config_cache('federation.activitypub.enabled') == true &&
|
|
config('federation.activitypub.remoteFollow') == true
|
|
) {
|
|
$remote = Helpers::fetchFromUrl($tag);
|
|
if (isset($remote['type']) &&
|
|
$remote['type'] == 'Person'
|
|
) {
|
|
$this->tokens['profiles'] = Cache::remember($remoteKey, $remoteTtl, function () use ($tag) {
|
|
$item = Helpers::profileFirstOrNew($tag);
|
|
$tokens = [[
|
|
'count' => 1,
|
|
'url' => $item->url(),
|
|
'type' => 'profile',
|
|
'value' => $item->username,
|
|
'tokens' => [$item->username],
|
|
'name' => $item->name,
|
|
'entity' => [
|
|
'id' => (string) $item->id,
|
|
'following' => $item->followedBy(Auth::user()->profile),
|
|
'follow_request' => $item->hasFollowRequestById(Auth::user()->profile_id),
|
|
'thumb' => $item->avatarUrl(),
|
|
'local' => (bool) ! $item->domain,
|
|
'post_count' => $item->statuses()->count(),
|
|
],
|
|
]];
|
|
|
|
return $tokens;
|
|
});
|
|
}
|
|
} else {
|
|
$this->tokens['profiles'] = Cache::remember($key, $ttl, function () use ($tag) {
|
|
if (Str::startsWith($tag, '@')) {
|
|
$tag = substr($tag, 1);
|
|
}
|
|
$users = Profile::select('status', 'domain', 'username', 'name', 'id')
|
|
->whereNull('status')
|
|
->where('username', 'like', '%'.$tag.'%')
|
|
->limit(20)
|
|
->orderBy('domain')
|
|
->get();
|
|
|
|
if ($users->count() > 0) {
|
|
return $users->map(function ($item, $key) {
|
|
return [
|
|
'count' => 0,
|
|
'url' => $item->url(),
|
|
'type' => 'profile',
|
|
'value' => $item->username,
|
|
'tokens' => [$item->username],
|
|
'name' => $item->name,
|
|
'avatar' => $item->avatarUrl(),
|
|
'id' => (string) $item->id,
|
|
'entity' => [
|
|
'id' => (string) $item->id,
|
|
'following' => $item->followedBy(Auth::user()->profile),
|
|
'follow_request' => $item->hasFollowRequestById(Auth::user()->profile_id),
|
|
'thumb' => $item->avatarUrl(),
|
|
'local' => (bool) ! $item->domain,
|
|
'post_count' => $item->statuses()->count(),
|
|
],
|
|
];
|
|
});
|
|
}
|
|
});
|
|
}
|
|
}
|
|
|
|
public function results(Request $request)
|
|
{
|
|
$this->validate($request, [
|
|
'q' => 'required|string|min:1',
|
|
]);
|
|
|
|
return view('search.results');
|
|
}
|
|
|
|
protected function webfingerSearch()
|
|
{
|
|
$wfs = WebfingerService::lookup($this->term);
|
|
|
|
if (empty($wfs)) {
|
|
return;
|
|
}
|
|
|
|
$this->tokens['profiles'] = [
|
|
[
|
|
'count' => 1,
|
|
'url' => $wfs['url'],
|
|
'type' => 'profile',
|
|
'value' => $wfs['username'],
|
|
'tokens' => [$wfs['username']],
|
|
'name' => $wfs['display_name'],
|
|
'entity' => [
|
|
'id' => (string) $wfs['id'],
|
|
'following' => null,
|
|
'follow_request' => null,
|
|
'thumb' => $wfs['avatar'],
|
|
'local' => (bool) $wfs['local'],
|
|
],
|
|
],
|
|
];
|
|
|
|
}
|
|
|
|
protected function remotePostLookup()
|
|
{
|
|
$tag = $this->term;
|
|
$hash = hash('sha256', $tag);
|
|
$local = Helpers::validateLocalUrl($tag);
|
|
$valid = Helpers::validateUrl($tag);
|
|
|
|
if ($valid == false || $local == true) {
|
|
return;
|
|
}
|
|
|
|
if (Status::whereUri($tag)->whereLocal(false)->exists()) {
|
|
$item = Status::whereUri($tag)->first();
|
|
$media = $item->firstMedia();
|
|
$url = null;
|
|
if ($media) {
|
|
$url = $media->remote_url;
|
|
}
|
|
$this->tokens['posts'] = [[
|
|
'count' => 0,
|
|
'url' => "/i/web/post/_/$item->profile_id/$item->id",
|
|
'type' => 'status',
|
|
'username' => $item->profile->username,
|
|
'caption' => $item->rendered ?? $item->caption,
|
|
'thumb' => $url,
|
|
'timestamp' => $item->created_at->diffForHumans(),
|
|
]];
|
|
}
|
|
|
|
$remote = Helpers::fetchFromUrl($tag);
|
|
|
|
if (isset($remote['type']) && $remote['type'] == 'Note') {
|
|
$item = Helpers::statusFetch($tag);
|
|
$media = $item->firstMedia();
|
|
$url = null;
|
|
if ($media) {
|
|
$url = $media->remote_url;
|
|
}
|
|
$this->tokens['posts'] = [[
|
|
'count' => 0,
|
|
'url' => "/i/web/post/_/$item->profile_id/$item->id",
|
|
'type' => 'status',
|
|
'username' => $item->profile->username,
|
|
'caption' => $item->rendered ?? $item->caption,
|
|
'thumb' => $url,
|
|
'timestamp' => $item->created_at->diffForHumans(),
|
|
]];
|
|
}
|
|
}
|
|
|
|
protected function remoteLookupSearch()
|
|
{
|
|
if (! Helpers::validateUrl($this->term)) {
|
|
return;
|
|
}
|
|
$this->getProfiles();
|
|
$this->remotePostLookup();
|
|
}
|
|
}
|