New Discover layout on Metro 2.0

app/Http/Controllers/DiscoverController.php

@@ -7,6 +7,8 @@ use App\{
 	Follower,
 	Hashtag,
 	HashtagFollow,
+	Instance,
+	Like,
 	Profile,
 	Status,
 	StatusHashtag,
@@ -14,13 +16,7 @@ use App\{
 };
 use Auth, DB, Cache;
 use Illuminate\Http\Request;
-use App\Transformer\Api\AccountTransformer;
+use App\Services\ConfigCacheService;
-use App\Transformer\Api\AccountWithStatusesTransformer;
-use App\Transformer\Api\StatusTransformer;
-use App\Transformer\Api\StatusStatelessTransformer;
-use League\Fractal;
-use League\Fractal\Serializer\ArraySerializer;
-use League\Fractal\Pagination\IlluminatePaginatorAdapter;
 use App\Services\StatusHashtagService;
 use App\Services\SnowflakeService;
 use App\Services\StatusService;
@@ -28,168 +24,322 @@ use App\Services\UserFilterService;
 
 class DiscoverController extends Controller
 {
-		protected $fractal;
+	public function home(Request $request)
+	{
+		abort_if(!Auth::check() && config('instance.discover.public') == false, 403);
+		return view('discover.home');
+	}
 
-		public function __construct()
+	public function showTags(Request $request, $hashtag)
-		{
+	{
-				$this->fractal = new Fractal\Manager();
+			abort_if(!config('instance.discover.tags.is_public') && !Auth::check(), 403);
-				$this->fractal->setSerializer(new ArraySerializer());
-		}
 
-		public function home(Request $request)
+			$tag = Hashtag::whereName($hashtag)
-		{
+				->orWhere('slug', $hashtag)
-				abort_if(!Auth::check() && config('instance.discover.public') == false, 403);
+				->firstOrFail();
-				return view('discover.home');
+			$tagCount = StatusHashtagService::count($tag->id);
-		}
+			return view('discover.tags.show', compact('tag', 'tagCount'));
+	}
 
-		public function showTags(Request $request, $hashtag)
+	public function showCategory(Request $request, $slug)
-		{
+	{
-				abort_if(!config('instance.discover.tags.is_public') && !Auth::check(), 403);
+		abort(404);
+	}
 
-				$tag = Hashtag::whereName($hashtag)
+	public function showLoops(Request $request)
-					->orWhere('slug', $hashtag)
+	{
-					->firstOrFail();
-				$tagCount = StatusHashtagService::count($tag->id);
-				return view('discover.tags.show', compact('tag', 'tagCount'));
-		}
-
-		public function showCategory(Request $request, $slug)
-		{
 			abort(404);
+	}
+
+	public function loopsApi(Request $request)
+	{
+			abort(404);
+	}
+
+	public function loopWatch(Request $request)
+	{
+			return response()->json(200);
+	}
+
+	public function getHashtags(Request $request)
+	{
+		$auth = Auth::check();
+		abort_if(!config('instance.discover.tags.is_public') && !$auth, 403);
+
+		$this->validate($request, [
+			'hashtag' => 'required|string|min:1|max:124',
+			'page' => 'nullable|integer|min:1|max:' . ($auth ? 29 : 10)
+		]);
+
+		$page = $request->input('page') ?? '1';
+		$end = $page > 1 ? $page * 9 : 0;
+		$tag = $request->input('hashtag');
+
+		$hashtag = Hashtag::whereName($tag)->firstOrFail();
+		if($page == 1) {
+			$res['follows'] = HashtagFollow::whereUserId(Auth::id())
+				->whereHashtagId($hashtag->id)
+				->exists();
 		}
+		$res['hashtag'] = [
+			'name' => $hashtag->name,
+			'url' => $hashtag->url()
+		];
+		$res['tags'] = StatusHashtagService::get($hashtag->id, $page, $end);
+		return $res;
+	}
 
-		public function showLoops(Request $request)
+	public function profilesDirectory(Request $request)
-		{
+	{
-				abort(404);
+		return redirect('/')->with('statusRedirect', 'The Profile Directory is unavailable at this time.');
-		}
+	}
 
-		public function loopsApi(Request $request)
+	public function profilesDirectoryApi(Request $request)
-		{
+	{
-				abort(404);
+		return ['error' => 'Temporarily unavailable.'];
-		}
+	}
 
-		public function loopWatch(Request $request)
+	public function trendingApi(Request $request)
-		{
+	{
-				return response()->json(200);
+		abort_if(config('instance.discover.public') == false && !Auth::check(), 403);
-		}
 
-		public function getHashtags(Request $request)
+		$this->validate($request, [
-		{
+			'range' => 'nullable|string|in:daily,monthly,yearly',
-			$auth = Auth::check();
+		]);
-			abort_if(!config('instance.discover.tags.is_public') && !$auth, 403);
 
-			$this->validate($request, [
+		$range = $request->input('range');
-				'hashtag' => 'required|string|min:1|max:124',
+		$days = $range == 'monthly' ? 31 : ($range == 'daily' ? 1 : 365);
-				'page' => 'nullable|integer|min:1|max:' . ($auth ? 29 : 10)
+		$ttls = [
-			]);
+			1 => 1500,
+			31 => 14400,
+			365 => 86400
+		];
+		$key = ':api:discover:trending:v2.12:range:' . $days;
 
-			$page = $request->input('page') ?? '1';
+		$ids = Cache::remember($key, $ttls[$days], function() use($days) {
-			$end = $page > 1 ? $page * 9 : 0;
+			$min_id = SnowflakeService::byDate(now()->subDays($days));
-			$tag = $request->input('hashtag');
+			return DB::table('statuses')
+				->select(
+					'id',
+					'scope',
+					'type',
+					'is_nsfw',
+					'likes_count',
+					'created_at'
+				)
+				->where('id', '>', $min_id)
+				->whereNull('uri')
+				->whereScope('public')
+				->whereIn('type', [
+					'photo',
+					'photo:album',
+					'video'
+				])
+				->whereIsNsfw(false)
+				->orderBy('likes_count','desc')
+				->take(30)
+				->pluck('id');
+		});
 
-			$hashtag = Hashtag::whereName($tag)->firstOrFail();
+		$filtered = Auth::check() ? UserFilterService::filters(Auth::user()->profile_id) : [];
-			if($page == 1) {
-				$res['follows'] = HashtagFollow::whereUserId(Auth::id())
-					->whereHashtagId($hashtag->id)
-					->exists();
-			}
-			$res['hashtag'] = [
-				'name' => $hashtag->name,
-				'url' => $hashtag->url()
-			];
-			$res['tags'] = StatusHashtagService::get($hashtag->id, $page, $end);
-			return $res;
-		}
 
-		public function profilesDirectory(Request $request)
+		$res = $ids->map(function($s) {
-		{
+			return StatusService::get($s);
-			return redirect('/')
+		})->filter(function($s) use($filtered) {
-				->with('statusRedirect', 'The Profile Directory is unavailable at this time.');
+			return
-		}
+				$s &&
+				!in_array($s['account']['id'], $filtered) &&
+				isset($s['account']);
+		})->values();
 
-		public function profilesDirectoryApi(Request $request)
+		return response()->json($res);
-		{
+	}
-			return ['error' => 'Temporarily unavailable.'];
-		}
 
-		public function trendingApi(Request $request)
+	public function trendingHashtags(Request $request)
-		{
+	{
-			abort_if(config('instance.discover.public') == false && !Auth::check(), 403);
+		$res = StatusHashtag::select('hashtag_id', \DB::raw('count(*) as total'))
-
+			->groupBy('hashtag_id')
-			$this->validate($request, [
+			->orderBy('total','desc')
-				'range' => 'nullable|string|in:daily,monthly,yearly',
+			->where('created_at', '>', now()->subDays(90))
-			]);
+			->take(9)
-
+			->get()
-			$range = $request->input('range');
+			->map(function($h) {
-			$days = $range == 'monthly' ? 31 : ($range == 'daily' ? 1 : 365);
+				$hashtag = $h->hashtag;
-			$ttls = [
+				return [
-				1 => 1500,
+					'id' => $hashtag->id,
-				31 => 14400,
+					'total' => $h->total,
-				365 => 86400
+					'name' => '#'.$hashtag->name,
-			];
+					'url' => $hashtag->url('?src=dsh1')
-			$key = ':api:discover:trending:v2.12:range:' . $days;
+				];
-
-			$ids = Cache::remember($key, $ttls[$days], function() use($days) {
-				$min_id = SnowflakeService::byDate(now()->subDays($days));
-				return DB::table('statuses')
-					->select(
-						'id',
-						'scope',
-						'type',
-						'is_nsfw',
-						'likes_count',
-						'created_at'
-					)
-					->where('id', '>', $min_id)
-					->whereNull('uri')
-					->whereScope('public')
-					->whereIn('type', [
-						'photo',
-						'photo:album',
-						'video'
-					])
-					->whereIsNsfw(false)
-					->orderBy('likes_count','desc')
-					->take(30)
-					->pluck('id');
 			});
+		return $res;
+	}
 
-			$filtered = Auth::check() ? UserFilterService::filters(Auth::user()->profile_id) : [];
+	public function trendingPlaces(Request $request)
+	{
+		return [];
+	}
 
-			$res = $ids->map(function($s) {
+	public function myMemories(Request $request)
-				return StatusService::get($s);
+	{
-			})->filter(function($s) use($filtered) {
+		abort_if(!$request->user(), 404);
-				return
+		$pid = $request->user()->profile_id;
-					$s &&
+		abort_if(!$this->config()['memories']['enabled'], 404);
-					!in_array($s['account']['id'], $filtered) &&
+		$type = $request->input('type') ?? 'posts';
-					isset($s['account']);
-			})->values();
 
-			return response()->json($res);
+		switch($type) {
+			case 'posts':
+				$res = Status::whereProfileId($pid)
+					->whereDay('created_at', date('d'))
+					->whereMonth('created_at', date('m'))
+					->whereYear('created_at', '!=', date('Y'))
+					->whereNull(['reblog_of_id', 'in_reply_to_id'])
+					->limit(20)
+					->pluck('id')
+					->map(function($id) {
+						return StatusService::get($id, false);
+					})
+					->filter(function($post) {
+						return $post && isset($post['account']);
+					})
+					->values();
+			break;
+
+			case 'liked':
+				$res = Like::whereProfileId($pid)
+					->whereDay('created_at', date('d'))
+					->whereMonth('created_at', date('m'))
+					->whereYear('created_at', '!=', date('Y'))
+					->orderByDesc('status_id')
+					->limit(20)
+					->pluck('status_id')
+					->map(function($id) {
+						return StatusService::get($id, false);
+					})
+					->filter(function($post) {
+						return $post && isset($post['account']);
+					})
+					->values();
+			break;
 		}
 
-		public function trendingHashtags(Request $request)
+		return $res;
-		{
+	}
-			$res = StatusHashtag::select('hashtag_id', \DB::raw('count(*) as total'))
-				->groupBy('hashtag_id')
-				->orderBy('total','desc')
-				->where('created_at', '>', now()->subDays(90))
-				->take(9)
-				->get()
-				->map(function($h) {
-					$hashtag = $h->hashtag;
-					return [
-						'id' => $hashtag->id,
-						'total' => $h->total,
-						'name' => '#'.$hashtag->name,
-						'url' => $hashtag->url('?src=dsh1')
-					];
-				});
-			return $res;
-		}
 
-		public function trendingPlaces(Request $request)
+	public function accountInsightsPopularPosts(Request $request)
-		{
+	{
-			return [];
+		abort_if(!$request->user(), 404);
+		$pid = $request->user()->profile_id;
+		abort_if(!$this->config()['insights']['enabled'], 404);
+		$posts = Cache::remember('pf:discover:metro2:accinsights:popular:' . $pid, 43200, function() use ($pid) {
+			return Status::whereProfileId($pid)
+			->whereNotNull('likes_count')
+			->orderByDesc('likes_count')
+			->limit(12)
+			->pluck('id')
+			->map(function($id) {
+				return StatusService::get($id, false);
+			})
+			->filter(function($post) {
+				return $post && isset($post['account']);
+			})
+			->values();
+		});
+
+		return $posts;
+	}
+
+	public function config()
+	{
+		$cc = ConfigCacheService::get('config.discover.features');
+		if($cc) {
+			return is_string($cc) ? json_decode($cc, true) : $cc;
 		}
+		return [
+			'hashtags' => [
+				'enabled' => false,
+			],
+			'memories' => [
+				'enabled' => false,
+			],
+			'insights' => [
+				'enabled' => false,
+			],
+			'friends' => [
+				'enabled' => false,
+			],
+			'server' => [
+				'enabled' => false,
+				'mode' => 'allowlist',
+				'domains' => []
+			]
+		];
+	}
+
+	public function serverTimeline(Request $request)
+	{
+		abort_if(!$request->user(), 404);
+		abort_if(!$this->config()['server']['enabled'], 404);
+		$pid = $request->user()->profile_id;
+		$domain = $request->input('domain');
+		$config = $this->config();
+		$domains = explode(',', $config['server']['domains']);
+		abort_unless(in_array($domain, $domains), 400);
+
+		$res = Status::whereNotNull('uri')
+			->where('uri', 'like', 'https://' . $domain . '%')
+			->whereNull(['in_reply_to_id', 'reblog_of_id'])
+			->orderByDesc('id')
+			->limit(12)
+			->pluck('id')
+			->map(function($id) {
+				return StatusService::get($id);
+			})
+			->filter(function($post) {
+				return $post && isset($post['account']);
+			})
+			->values();
+		return $res;
+	}
+
+	public function enabledFeatures(Request $request)
+	{
+		abort_if(!$request->user(), 404);
+		return $this->config();
+	}
+
+	public function updateFeatures(Request $request)
+	{
+		abort_if(!$request->user(), 404);
+		abort_if(!$request->user()->is_admin, 404);
+		$pid = $request->user()->profile_id;
+		$this->validate($request, [
+			'features.friends.enabled' => 'boolean',
+			'features.hashtags.enabled' => 'boolean',
+			'features.insights.enabled' => 'boolean',
+			'features.memories.enabled' => 'boolean',
+			'features.server.enabled' => 'boolean',
+		]);
+		$res = $request->input('features');
+		if($res['server'] && isset($res['server']['domains']) && !empty($res['server']['domains'])) {
+			$parts = explode(',', $res['server']['domains']);
+			$parts = array_filter($parts, function($v) {
+				$len = strlen($v);
+				$pos = strpos($v, '.');
+				$domain = trim($v);
+				if($pos == false || $pos == ($len + 1)) {
+					return false;
+				}
+				if(!Instance::whereDomain($domain)->exists()) {
+					return false;
+				}
+				return true;
+			});
+			$parts = array_slice($parts, 0, 10);
+			$d = implode(',', array_map('trim', $parts));
+			$res['server']['domains'] = $d;
+		}
+		ConfigCacheService::put('config.discover.features', json_encode($res));
+		return $res;
+	}
 }

routes/web.php

@@ -216,6 +216,11 @@ Route::domain(config('pixelfed.domain.app'))->middleware(['validemail', 'twofact
 				Route::post('status/{id}/archive', 'ApiController@archive');
 				Route::post('status/{id}/unarchive', 'ApiController@unarchive');
 				Route::get('statuses/archives', 'ApiController@archivedPosts');
+				Route::get('discover/memories', 'DiscoverController@myMemories');
+				Route::get('discover/account-insights', 'DiscoverController@accountInsightsPopularPosts');
+				Route::get('discover/server-timeline', 'DiscoverController@serverTimeline');
+				Route::get('discover/meta', 'DiscoverController@enabledFeatures');
+				Route::post('discover/admin/features', 'DiscoverController@updateFeatures');
 			});
 
 			Route::get('discover/accounts/popular', 'Api\ApiV1Controller@discoverAccountsPopular');