DiscoverController.php 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423
  1. <?php
  2. namespace App\Http\Controllers;
  3. use App\Hashtag;
  4. use App\Instance;
  5. use App\Like;
  6. use App\Services\AccountService;
  7. use App\Services\AdminShadowFilterService;
  8. use App\Services\BookmarkService;
  9. use App\Services\ConfigCacheService;
  10. use App\Services\FollowerService;
  11. use App\Services\HashtagService;
  12. use App\Services\LikeService;
  13. use App\Services\ReblogService;
  14. use App\Services\SnowflakeService;
  15. use App\Services\StatusHashtagService;
  16. use App\Services\StatusService;
  17. use App\Services\TrendingHashtagService;
  18. use App\Services\UserFilterService;
  19. use App\Status;
  20. use Auth;
  21. use Cache;
  22. use DB;
  23. use Illuminate\Http\Request;
  24. class DiscoverController extends Controller
  25. {
  26. public function home(Request $request)
  27. {
  28. abort_if(! Auth::check() && config('instance.discover.public') == false, 403);
  29. return view('discover.home');
  30. }
  31. public function showTags(Request $request, $hashtag)
  32. {
  33. if ($request->user()) {
  34. return redirect('/i/web/hashtag/'.$hashtag.'?src=pd');
  35. }
  36. abort_if(! config('instance.discover.tags.is_public') && ! Auth::check(), 403);
  37. $tag = Hashtag::whereName($hashtag)
  38. ->orWhere('slug', $hashtag)
  39. ->where('is_banned', '!=', true)
  40. ->firstOrFail();
  41. $tagCount = $tag->cached_count ?? 0;
  42. return view('discover.tags.show', compact('tag', 'tagCount'));
  43. }
  44. public function getHashtags(Request $request)
  45. {
  46. $user = $request->user();
  47. abort_if(! config('instance.discover.tags.is_public') && ! $user, 403);
  48. $this->validate($request, [
  49. 'hashtag' => 'required|string|min:1|max:124',
  50. 'page' => 'nullable|integer|min:1|max:'.($user ? 29 : 3),
  51. ]);
  52. $page = $request->input('page') ?? '1';
  53. $end = $page > 1 ? $page * 9 : 0;
  54. $tag = $request->input('hashtag');
  55. if (config('database.default') === 'pgsql') {
  56. $hashtag = Hashtag::where('name', 'ilike', $tag)->firstOrFail();
  57. } else {
  58. $hashtag = Hashtag::whereName($tag)->firstOrFail();
  59. }
  60. if ($hashtag->is_banned == true) {
  61. return [];
  62. }
  63. if ($user) {
  64. $res['follows'] = HashtagService::isFollowing($user->profile_id, $hashtag->id);
  65. }
  66. $res['hashtag'] = [
  67. 'name' => $hashtag->name,
  68. 'url' => $hashtag->url(),
  69. ];
  70. if ($user) {
  71. $tags = StatusHashtagService::get($hashtag->id, $page, $end);
  72. $res['tags'] = collect($tags)
  73. ->map(function ($tag) use ($user) {
  74. $tag['status']['favourited'] = (bool) LikeService::liked($user->profile_id, $tag['status']['id']);
  75. $tag['status']['reblogged'] = (bool) ReblogService::get($user->profile_id, $tag['status']['id']);
  76. $tag['status']['bookmarked'] = (bool) BookmarkService::get($user->profile_id, $tag['status']['id']);
  77. return $tag;
  78. })
  79. ->filter(function ($tag) {
  80. if (! StatusService::get($tag['status']['id'])) {
  81. return false;
  82. }
  83. return true;
  84. })
  85. ->values();
  86. } else {
  87. if ($page != 1) {
  88. $res['tags'] = [];
  89. return $res;
  90. }
  91. $key = 'discover:tags:public_feed:'.$hashtag->id.':page:'.$page;
  92. $tags = Cache::remember($key, 43200, function () use ($hashtag, $page, $end) {
  93. return collect(StatusHashtagService::get($hashtag->id, $page, $end))
  94. ->filter(function ($tag) {
  95. if (! $tag['status']['local']) {
  96. return false;
  97. }
  98. return true;
  99. })
  100. ->values();
  101. });
  102. $res['tags'] = collect($tags)
  103. ->filter(function ($tag) {
  104. if (! StatusService::get($tag['status']['id'])) {
  105. return false;
  106. }
  107. return true;
  108. })
  109. ->values();
  110. }
  111. return $res;
  112. }
  113. public function profilesDirectory(Request $request)
  114. {
  115. return redirect('/')->with('statusRedirect', 'The Profile Directory is unavailable at this time.');
  116. }
  117. public function profilesDirectoryApi(Request $request)
  118. {
  119. return ['error' => 'Temporarily unavailable.'];
  120. }
  121. public function trendingApi(Request $request)
  122. {
  123. abort_if(config('instance.discover.public') == false && ! $request->user(), 403);
  124. $this->validate($request, [
  125. 'range' => 'nullable|string|in:daily,monthly,yearly',
  126. ]);
  127. $range = $request->input('range');
  128. $days = $range == 'monthly' ? 31 : ($range == 'daily' ? 1 : 365);
  129. $ttls = [
  130. 1 => 1500,
  131. 31 => 14400,
  132. 365 => 86400,
  133. ];
  134. $key = ':api:discover:trending:v2.12:range:'.$days;
  135. $ids = Cache::remember($key, $ttls[$days], function () use ($days) {
  136. $min_id = SnowflakeService::byDate(now()->subDays($days));
  137. return DB::table('statuses')
  138. ->select(
  139. 'id',
  140. 'scope',
  141. 'type',
  142. 'is_nsfw',
  143. 'likes_count',
  144. 'created_at'
  145. )
  146. ->where('id', '>', $min_id)
  147. ->whereNull('uri')
  148. ->whereScope('public')
  149. ->whereIn('type', [
  150. 'photo',
  151. 'photo:album',
  152. 'video',
  153. ])
  154. ->whereIsNsfw(false)
  155. ->orderBy('likes_count', 'desc')
  156. ->take(30)
  157. ->pluck('id');
  158. });
  159. $filtered = Auth::check() ? UserFilterService::filters(Auth::user()->profile_id) : [];
  160. $res = $ids->map(function ($s) {
  161. return StatusService::get($s);
  162. })->filter(function ($s) use ($filtered) {
  163. return
  164. $s &&
  165. ! in_array($s['account']['id'], $filtered) &&
  166. isset($s['account']);
  167. })->values();
  168. return response()->json($res);
  169. }
  170. public function trendingHashtags(Request $request)
  171. {
  172. abort_if(! $request->user(), 403);
  173. $res = TrendingHashtagService::getTrending();
  174. return $res;
  175. }
  176. public function trendingPlaces(Request $request)
  177. {
  178. return [];
  179. }
  180. public function myMemories(Request $request)
  181. {
  182. abort_if(! $request->user(), 404);
  183. $pid = $request->user()->profile_id;
  184. abort_if(! $this->config()['memories']['enabled'], 404);
  185. $type = $request->input('type') ?? 'posts';
  186. switch ($type) {
  187. case 'posts':
  188. $res = Status::whereProfileId($pid)
  189. ->whereDay('created_at', date('d'))
  190. ->whereMonth('created_at', date('m'))
  191. ->whereYear('created_at', '!=', date('Y'))
  192. ->whereNull(['reblog_of_id', 'in_reply_to_id'])
  193. ->limit(20)
  194. ->pluck('id')
  195. ->map(function ($id) {
  196. return StatusService::get($id, false);
  197. })
  198. ->filter(function ($post) {
  199. return $post && isset($post['account']);
  200. })
  201. ->values();
  202. break;
  203. case 'liked':
  204. $res = Like::whereProfileId($pid)
  205. ->whereDay('created_at', date('d'))
  206. ->whereMonth('created_at', date('m'))
  207. ->whereYear('created_at', '!=', date('Y'))
  208. ->orderByDesc('status_id')
  209. ->limit(20)
  210. ->pluck('status_id')
  211. ->map(function ($id) {
  212. $status = StatusService::get($id, false);
  213. $status['favourited'] = true;
  214. return $status;
  215. })
  216. ->filter(function ($post) {
  217. return $post && isset($post['account']);
  218. })
  219. ->values();
  220. break;
  221. }
  222. return $res;
  223. }
  224. public function accountInsightsPopularPosts(Request $request)
  225. {
  226. abort_if(! $request->user(), 404);
  227. $pid = $request->user()->profile_id;
  228. abort_if(! $this->config()['insights']['enabled'], 404);
  229. $posts = Cache::remember('pf:discover:metro2:accinsights:popular:'.$pid, 43200, function () use ($pid) {
  230. return Status::whereProfileId($pid)
  231. ->whereNotNull('likes_count')
  232. ->orderByDesc('likes_count')
  233. ->limit(12)
  234. ->pluck('id')
  235. ->map(function ($id) {
  236. return StatusService::get($id, false);
  237. })
  238. ->filter(function ($post) {
  239. return $post && isset($post['account']);
  240. })
  241. ->values();
  242. });
  243. return $posts;
  244. }
  245. public function config()
  246. {
  247. $cc = ConfigCacheService::get('config.discover.features');
  248. if ($cc) {
  249. return is_string($cc) ? json_decode($cc, true) : $cc;
  250. }
  251. return [
  252. 'hashtags' => [
  253. 'enabled' => false,
  254. ],
  255. 'memories' => [
  256. 'enabled' => false,
  257. ],
  258. 'insights' => [
  259. 'enabled' => false,
  260. ],
  261. 'friends' => [
  262. 'enabled' => false,
  263. ],
  264. 'server' => [
  265. 'enabled' => false,
  266. 'mode' => 'allowlist',
  267. 'domains' => [],
  268. ],
  269. ];
  270. }
  271. public function serverTimeline(Request $request)
  272. {
  273. abort_if(! $request->user(), 404);
  274. abort_if(! $this->config()['server']['enabled'], 404);
  275. $pid = $request->user()->profile_id;
  276. $domain = $request->input('domain');
  277. $config = $this->config();
  278. $domains = explode(',', $config['server']['domains']);
  279. abort_unless(in_array($domain, $domains), 400);
  280. $res = Status::whereNotNull('uri')
  281. ->where('uri', 'like', 'https://'.$domain.'%')
  282. ->whereNull(['in_reply_to_id', 'reblog_of_id'])
  283. ->orderByDesc('id')
  284. ->limit(12)
  285. ->pluck('id')
  286. ->map(function ($id) {
  287. return StatusService::get($id);
  288. })
  289. ->filter(function ($post) {
  290. return $post && isset($post['account']);
  291. })
  292. ->values();
  293. return $res;
  294. }
  295. public function enabledFeatures(Request $request)
  296. {
  297. abort_if(! $request->user(), 404);
  298. return $this->config();
  299. }
  300. public function updateFeatures(Request $request)
  301. {
  302. abort_if(! $request->user(), 404);
  303. abort_if(! $request->user()->is_admin, 404);
  304. $pid = $request->user()->profile_id;
  305. $this->validate($request, [
  306. 'features.friends.enabled' => 'boolean',
  307. 'features.hashtags.enabled' => 'boolean',
  308. 'features.insights.enabled' => 'boolean',
  309. 'features.memories.enabled' => 'boolean',
  310. 'features.server.enabled' => 'boolean',
  311. ]);
  312. $res = $request->input('features');
  313. if ($res['server'] && isset($res['server']['domains']) && ! empty($res['server']['domains'])) {
  314. $parts = explode(',', $res['server']['domains']);
  315. $parts = array_filter($parts, function ($v) {
  316. $len = strlen($v);
  317. $pos = strpos($v, '.');
  318. $domain = trim($v);
  319. if ($pos == false || $pos == ($len + 1)) {
  320. return false;
  321. }
  322. if (! Instance::whereDomain($domain)->exists()) {
  323. return false;
  324. }
  325. return true;
  326. });
  327. $parts = array_slice($parts, 0, 10);
  328. $d = implode(',', array_map('trim', $parts));
  329. $res['server']['domains'] = $d;
  330. }
  331. ConfigCacheService::put('config.discover.features', json_encode($res));
  332. return $res;
  333. }
  334. public function discoverAccountsPopular(Request $request)
  335. {
  336. abort_if(! $request->user(), 403);
  337. $pid = $request->user()->profile_id;
  338. $ids = Cache::remember('api:v1.1:discover:accounts:popular', 14400, function () {
  339. return DB::table('profiles')
  340. ->where('is_private', false)
  341. ->whereNull('status')
  342. ->orderByDesc('profiles.followers_count')
  343. ->limit(30)
  344. ->get();
  345. });
  346. $filters = UserFilterService::filters($pid);
  347. $asf = AdminShadowFilterService::getHideFromPublicFeedsList();
  348. $ids = $ids->map(function ($profile) {
  349. return AccountService::get($profile->id, true);
  350. })
  351. ->filter(function ($profile) {
  352. return $profile && isset($profile['id'], $profile['locked']) && ! $profile['locked'];
  353. })
  354. ->filter(function ($profile) use ($pid) {
  355. return $profile['id'] != $pid;
  356. })
  357. ->filter(function ($profile) use ($pid) {
  358. return ! FollowerService::follows($pid, $profile['id'], true);
  359. })
  360. ->filter(function ($profile) use ($asf) {
  361. return ! in_array($profile['id'], $asf);
  362. })
  363. ->filter(function ($profile) use ($filters) {
  364. return ! in_array($profile['id'], $filters);
  365. })
  366. ->take(16)
  367. ->values();
  368. return response()->json($ids, 200, [], JSON_UNESCAPED_SLASHES);
  369. }
  370. }