run($query); } protected function run($query) { $this->query = $query; $q = urldecode($query->input('q')); if($query->has('resolve') && ( Str::startsWith($q, 'https://') || Str::substrCount($q, '@') >= 1) ) { return $this->resolveQuery(); } if($query->has('type')) { switch ($query->input('type')) { case 'accounts': return [ 'accounts' => $this->accounts(), 'hashtags' => [], 'statuses' => [] ]; break; case 'hashtags': return [ 'accounts' => [], 'hashtags' => $this->hashtags(), 'statuses' => [] ]; break; case 'statuses': return [ 'accounts' => [], 'hashtags' => [], 'statuses' => $this->statuses() ]; break; } } if($query->has('account_id')) { return [ 'accounts' => [], 'hashtags' => [], 'statuses' => $this->statusesById() ]; } return [ 'accounts' => $this->accounts(), 'hashtags' => $this->hashtags(), 'statuses' => $this->statuses() ]; } protected function accounts($initalQuery = false) { $mastodonMode = self::$mastodonMode; $user = request()->user(); $limit = $this->query->input('limit') ?? 20; $offset = $this->query->input('offset') ?? 0; $rawQuery = $initalQuery ? $initalQuery : $this->query->input('q'); $query = '%' . $rawQuery . '%'; if(Str::substrCount($rawQuery, '@') >= 1 && Str::contains($rawQuery, config('pixelfed.domain.app'))) { $deliminatorCount = Str::substrCount($rawQuery, '@'); $query = explode('@', $rawQuery)[$deliminatorCount == 1 ? 0 : 1]; } if(Str::substrCount($rawQuery, '@') == 1 && substr($rawQuery, 0, 1) == '@') { $query = substr($rawQuery, 1) . '%'; } $banned = InstanceService::getBannedDomains(); $results = Profile::select('username', 'id', 'followers_count', 'domain') ->where('username', 'like', $query) ->orderByDesc('profiles.followers_count') ->offset($offset) ->limit($limit) ->get() ->filter(function($profile) use ($banned) { return in_array($profile->domain, $banned) == false; }) ->map(function($res) use($mastodonMode) { return $mastodonMode ? AccountService::getMastodon($res['id']) : AccountService::get($res['id']); }) ->filter(function($account) { return $account && isset($account['id']); }) ->values(); return $results; } protected function hashtags() { $mastodonMode = self::$mastodonMode; $limit = $this->query->input('limit') ?? 20; $offset = $this->query->input('offset') ?? 0; $query = '%' . $this->query->input('q') . '%'; return Hashtag::where('can_search', true) ->where('name', 'like', $query) ->offset($offset) ->limit($limit) ->get() ->map(function($tag) use($mastodonMode) { $res = [ 'name' => $tag->name, 'url' => $tag->url() ]; if(!$mastodonMode) { $res['history'] = []; $res['count'] = HashtagService::count($tag->id); } return $res; }); } protected function statuses() { // Removed until we provide more relevent sorting/results return []; } protected function statusesById() { $mastodonMode = self::$mastodonMode; $accountId = $this->query->input('account_id'); $limit = $this->query->input('limit', 20); $query = '%' . $this->query->input('q') . '%'; $results = Status::where('caption', 'like', $query) ->whereProfileId($accountId) ->limit($limit) ->get() ->map(function($status) use($mastodonMode) { return $mastodonMode ? StatusService::getMastodon($status->id) : StatusService::get($status->id); }) ->filter(function($status) { return $status && isset($status['account']); }); return $results; } protected function resolveQuery() { $default = [ 'accounts' => [], 'hashtags' => [], 'statuses' => [], ]; $mastodonMode = self::$mastodonMode; $query = urldecode($this->query->input('q')); if(substr($query, 0, 1) === '@' && !Str::contains($query, '.')) { $default['accounts'] = $this->accounts(substr($query, 1)); return $default; } if(Helpers::validateLocalUrl($query)) { if(Str::contains($query, '/p/')) { return $this->resolveLocalStatus(); } else { return $this->resolveLocalProfile(); } } else { if(!Helpers::validateUrl($query) && strpos($query, '@') == -1) { return $default; } if(!Str::startsWith($query, 'http') && Str::substrCount($query, '@') == 1 && strpos($query, '@') !== 0) { try { $res = WebfingerService::lookup('@' . $query, $mastodonMode); } catch (\Exception $e) { return $default; } if($res && isset($res['id'])) { $default['accounts'][] = $res; return $default; } else { return $default; } } if(Str::substrCount($query, '@') == 2) { try { $res = WebfingerService::lookup($query, $mastodonMode); } catch (\Exception $e) { return $default; } if($res && isset($res['id'])) { $default['accounts'][] = $res; return $default; } else { return $default; } } try { $res = ActivityPubFetchService::get($query); $banned = InstanceService::getBannedDomains(); if($res) { $json = json_decode($res, true); if(!$json || !isset($json['@context']) || !isset($json['type']) || !in_array($json['type'], ['Note', 'Person'])) { return [ 'accounts' => [], 'hashtags' => [], 'statuses' => [], ]; } switch($json['type']) { case 'Note': $obj = Helpers::statusFetch($query); if(!$obj || !isset($obj['id'])) { return $default; } $note = $mastodonMode ? StatusService::getMastodon($obj['id']) : StatusService::get($obj['id']); if(!$note) { return $default; } $default['statuses'][] = $note; return $default; break; case 'Person': $obj = Helpers::profileFetch($query); if(!$obj) { return $default; } if(in_array($obj['domain'], $banned)) { return $default; } $default['accounts'][] = $mastodonMode ? AccountService::getMastodon($obj['id']) : AccountService::get($obj['id']); return $default; break; default: return [ 'accounts' => [], 'hashtags' => [], 'statuses' => [], ]; break; } } } catch (\Exception $e) { return [ 'accounts' => [], 'hashtags' => [], 'statuses' => [], ]; } return $default; } } protected function resolveLocalStatus() { $query = urldecode($this->query->input('q')); $query = last(explode('/', $query)); $status = StatusService::getMastodon($query); if(!$status) { return [ 'accounts' => [], 'hashtags' => [], 'statuses' => [] ]; } $res = [ 'accounts' => [], 'hashtags' => [], 'statuses' => [$status] ]; return $res; } protected function resolveLocalProfile() { $query = urldecode($this->query->input('q')); $query = last(explode('/', $query)); $profile = Profile::whereNull('status') ->whereNull('domain') ->whereUsername($query) ->first(); if(!$profile) { return [ 'accounts' => [], 'hashtags' => [], 'statuses' => [] ]; } $fractal = new Fractal\Manager(); $fractal->setSerializer(new ArraySerializer()); $resource = new Fractal\Resource\Item($profile, new AccountTransformer()); return [ 'accounts' => $fractal->createData($resource)->toArray(), 'hashtags' => [], 'statuses' => [] ]; } }