|
@@ -23,109 +23,7 @@ class FollowerController extends Controller
|
|
|
|
|
|
public function store(Request $request)
|
|
public function store(Request $request)
|
|
{
|
|
{
|
|
- $this->validate($request, [
|
|
|
|
- 'item' => 'required|string',
|
|
|
|
- 'force' => 'nullable|boolean',
|
|
|
|
- ]);
|
|
|
|
- $force = (bool) $request->input('force', true);
|
|
|
|
- $item = (int) $request->input('item');
|
|
|
|
- $url = $this->handleFollowRequest($item, $force);
|
|
|
|
- if($request->wantsJson() == true) {
|
|
|
|
- return response()->json(200);
|
|
|
|
- } else {
|
|
|
|
- return redirect($url);
|
|
|
|
- }
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- protected function handleFollowRequest($item, $force)
|
|
|
|
- {
|
|
|
|
- $user = Auth::user()->profile;
|
|
|
|
-
|
|
|
|
- $target = Profile::where('id', '!=', $user->id)->whereNull('status')->findOrFail($item);
|
|
|
|
- $private = (bool) $target->is_private;
|
|
|
|
- $remote = (bool) $target->domain;
|
|
|
|
- $blocked = UserFilter::whereUserId($target->id)
|
|
|
|
- ->whereFilterType('block')
|
|
|
|
- ->whereFilterableId($user->id)
|
|
|
|
- ->whereFilterableType('App\Profile')
|
|
|
|
- ->exists();
|
|
|
|
-
|
|
|
|
- if($blocked == true) {
|
|
|
|
- abort(400, 'You cannot follow this user.');
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- $isFollowing = Follower::whereProfileId($user->id)->whereFollowingId($target->id)->exists();
|
|
|
|
-
|
|
|
|
- if($private == true && $isFollowing == 0) {
|
|
|
|
- if($user->following()->count() >= Follower::MAX_FOLLOWING) {
|
|
|
|
- abort(400, 'You cannot follow more than ' . Follower::MAX_FOLLOWING . ' accounts');
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- if($user->following()->where('followers.created_at', '>', now()->subHour())->count() >= Follower::FOLLOW_PER_HOUR) {
|
|
|
|
- abort(400, 'You can only follow ' . Follower::FOLLOW_PER_HOUR . ' users per hour');
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- $follow = FollowRequest::firstOrCreate([
|
|
|
|
- 'follower_id' => $user->id,
|
|
|
|
- 'following_id' => $target->id
|
|
|
|
- ]);
|
|
|
|
- if($remote == true && config('federation.activitypub.remoteFollow') == true) {
|
|
|
|
- $this->sendFollow($user, $target);
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- FollowerService::add($user->id, $target->id);
|
|
|
|
- } elseif ($private == false && $isFollowing == 0) {
|
|
|
|
- if($user->following()->count() >= Follower::MAX_FOLLOWING) {
|
|
|
|
- abort(400, 'You cannot follow more than ' . Follower::MAX_FOLLOWING . ' accounts');
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- if($user->following()->where('followers.created_at', '>', now()->subHour())->count() >= Follower::FOLLOW_PER_HOUR) {
|
|
|
|
- abort(400, 'You can only follow ' . Follower::FOLLOW_PER_HOUR . ' users per hour');
|
|
|
|
- }
|
|
|
|
- $follower = new Follower();
|
|
|
|
- $follower->profile_id = $user->id;
|
|
|
|
- $follower->following_id = $target->id;
|
|
|
|
- $follower->save();
|
|
|
|
-
|
|
|
|
- if($remote == true && config('federation.activitypub.remoteFollow') == true) {
|
|
|
|
- $this->sendFollow($user, $target);
|
|
|
|
- }
|
|
|
|
- FollowerService::add($user->id, $target->id);
|
|
|
|
- FollowPipeline::dispatch($follower);
|
|
|
|
- } else {
|
|
|
|
- if($force == true) {
|
|
|
|
- $request = FollowRequest::whereFollowerId($user->id)->whereFollowingId($target->id)->exists();
|
|
|
|
- $follower = Follower::whereProfileId($user->id)->whereFollowingId($target->id)->exists();
|
|
|
|
- if($remote == true && $request && !$follower) {
|
|
|
|
- $this->sendFollow($user, $target);
|
|
|
|
- }
|
|
|
|
- if($remote == true && $follower) {
|
|
|
|
- $this->sendUndoFollow($user, $target);
|
|
|
|
- }
|
|
|
|
- Follower::whereProfileId($user->id)
|
|
|
|
- ->whereFollowingId($target->id)
|
|
|
|
- ->delete();
|
|
|
|
- FollowerService::remove($user->id, $target->id);
|
|
|
|
- }
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- Cache::forget('profile:following:'.$target->id);
|
|
|
|
- Cache::forget('profile:followers:'.$target->id);
|
|
|
|
- Cache::forget('profile:following:'.$user->id);
|
|
|
|
- Cache::forget('profile:followers:'.$user->id);
|
|
|
|
- Cache::forget('api:local:exp:rec:'.$user->id);
|
|
|
|
- Cache::forget('user:account:id:'.$target->user_id);
|
|
|
|
- Cache::forget('user:account:id:'.$user->user_id);
|
|
|
|
- Cache::forget('px:profile:followers-v1.3:'.$user->id);
|
|
|
|
- Cache::forget('px:profile:followers-v1.3:'.$target->id);
|
|
|
|
- Cache::forget('px:profile:following-v1.3:'.$user->id);
|
|
|
|
- Cache::forget('px:profile:following-v1.3:'.$target->id);
|
|
|
|
- Cache::forget('profile:follower_count:'.$target->id);
|
|
|
|
- Cache::forget('profile:follower_count:'.$user->id);
|
|
|
|
- Cache::forget('profile:following_count:'.$target->id);
|
|
|
|
- Cache::forget('profile:following_count:'.$user->id);
|
|
|
|
-
|
|
|
|
- return $target->url();
|
|
|
|
|
|
+ abort(422, 'Deprecated API Endpoint, use /api/v1/accounts/{id}/follow or /api/v1/accounts/{id}/unfollow instead.');
|
|
}
|
|
}
|
|
|
|
|
|
public function sendFollow($user, $target)
|
|
public function sendFollow($user, $target)
|