123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008 |
- <?php
- namespace App\Http\Controllers\Api;
- use App\AccountLog;
- use App\EmailVerification;
- use App\Http\Controllers\Controller;
- use App\Http\Resources\StatusStateless;
- use App\Jobs\ReportPipeline\ReportNotifyAdminViaEmail;
- use App\Jobs\StatusPipeline\RemoteStatusDelete;
- use App\Jobs\StatusPipeline\StatusDelete;
- use App\Mail\ConfirmAppEmail;
- use App\Mail\PasswordChange;
- use App\Place;
- use App\Profile;
- use App\Report;
- use App\Services\AccountService;
- use App\Services\BouncerService;
- use App\Services\EmailService;
- use App\Services\FollowerService;
- use App\Services\NetworkTimelineService;
- use App\Services\ProfileStatusService;
- use App\Services\PublicTimelineService;
- use App\Services\StatusService;
- use App\Status;
- use App\StatusArchived;
- use App\User;
- use App\UserSetting;
- use App\Util\Lexer\RestrictedNames;
- use Cache;
- use DB;
- use Illuminate\Http\Request;
- use Illuminate\Support\Facades\Hash;
- use Illuminate\Support\Facades\RateLimiter;
- use Illuminate\Support\Str;
- use Jenssegers\Agent\Agent;
- use League\Fractal;
- use League\Fractal\Serializer\ArraySerializer;
- use Mail;
- class ApiV1Dot1Controller extends Controller
- {
- protected $fractal;
- public function __construct()
- {
- $this->fractal = new Fractal\Manager();
- $this->fractal->setSerializer(new ArraySerializer());
- }
- public function json($res, $code = 200, $headers = [])
- {
- return response()->json($res, $code, $headers, JSON_UNESCAPED_SLASHES);
- }
- public function error($msg, $code = 400, $extra = [], $headers = [])
- {
- $res = [
- 'msg' => $msg,
- 'code' => $code,
- ];
- return response()->json(array_merge($res, $extra), $code, $headers, JSON_UNESCAPED_SLASHES);
- }
- public function report(Request $request)
- {
- abort_if(! $request->user() || ! $request->user()->token(), 403);
- abort_unless($request->user()->tokenCan('write'), 403);
- $user = $request->user();
- abort_if($user->status != null, 403);
- if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
- abort_if(BouncerService::checkIp($request->ip()), 404);
- }
- $report_type = $request->input('report_type');
- $object_id = $request->input('object_id');
- $object_type = $request->input('object_type');
- $types = [
- 'spam',
- 'sensitive',
- 'abusive',
- 'underage',
- 'violence',
- 'copyright',
- 'impersonation',
- 'scam',
- 'terrorism',
- ];
- if (! $report_type || ! $object_id || ! $object_type) {
- return $this->error('Invalid or missing parameters', 400, ['error_code' => 'ERROR_INVALID_PARAMS']);
- }
- if (! in_array($report_type, $types)) {
- return $this->error('Invalid report type', 400, ['error_code' => 'ERROR_TYPE_INVALID']);
- }
- if ($object_type === 'user' && $object_id == $user->profile_id) {
- return $this->error('Cannot self report', 400, ['error_code' => 'ERROR_NO_SELF_REPORTS']);
- }
- $rpid = null;
- switch ($object_type) {
- case 'post':
- $object = Status::find($object_id);
- if (! $object) {
- return $this->error('Invalid object id', 400, ['error_code' => 'ERROR_INVALID_OBJECT_ID']);
- }
- $object_type = 'App\Status';
- $exists = Report::whereUserId($user->id)
- ->whereObjectId($object->id)
- ->whereObjectType('App\Status')
- ->count();
- $rpid = $object->profile_id;
- break;
- case 'user':
- $object = Profile::find($object_id);
- if (! $object) {
- return $this->error('Invalid object id', 400, ['error_code' => 'ERROR_INVALID_OBJECT_ID']);
- }
- $object_type = 'App\Profile';
- $exists = Report::whereUserId($user->id)
- ->whereObjectId($object->id)
- ->whereObjectType('App\Profile')
- ->count();
- $rpid = $object->id;
- break;
- default:
- return $this->error('Invalid report type', 400, ['error_code' => 'ERROR_REPORT_OBJECT_TYPE_INVALID']);
- break;
- }
- if ($exists !== 0) {
- return $this->error('Duplicate report', 400, ['error_code' => 'ERROR_REPORT_DUPLICATE']);
- }
- if ($object->profile_id == $user->profile_id) {
- return $this->error('Cannot self report', 400, ['error_code' => 'ERROR_NO_SELF_REPORTS']);
- }
- $report = new Report;
- $report->profile_id = $user->profile_id;
- $report->user_id = $user->id;
- $report->object_id = $object->id;
- $report->object_type = $object_type;
- $report->reported_profile_id = $rpid;
- $report->type = $report_type;
- $report->save();
- if (config('instance.reports.email.enabled')) {
- ReportNotifyAdminViaEmail::dispatch($report)->onQueue('default');
- }
- $res = [
- 'msg' => 'Successfully sent report',
- 'code' => 200,
- ];
- return $this->json($res);
- }
- /**
- * DELETE /api/v1.1/accounts/avatar
- *
- * @return \App\Transformer\Api\AccountTransformer
- */
- public function deleteAvatar(Request $request)
- {
- abort_if(! $request->user() || ! $request->user()->token(), 403);
- abort_unless($request->user()->tokenCan('write'), 403);
- $user = $request->user();
- abort_if($user->status != null, 403);
- if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
- abort_if(BouncerService::checkIp($request->ip()), 404);
- }
- $avatar = $user->profile->avatar;
- if ($avatar->media_path == 'public/avatars/default.png' ||
- $avatar->media_path == 'public/avatars/default.jpg'
- ) {
- return AccountService::get($user->profile_id);
- }
- if (is_file(storage_path('app/'.$avatar->media_path))) {
- @unlink(storage_path('app/'.$avatar->media_path));
- }
- $avatar->media_path = 'public/avatars/default.jpg';
- $avatar->change_count = $avatar->change_count + 1;
- $avatar->save();
- Cache::forget('avatar:'.$user->profile_id);
- Cache::forget("avatar:{$user->profile_id}");
- Cache::forget('user:account:id:'.$user->id);
- AccountService::del($user->profile_id);
- return AccountService::get($user->profile_id);
- }
- /**
- * GET /api/v1.1/accounts/{id}/posts
- *
- * @return \App\Transformer\Api\StatusTransformer
- */
- public function accountPosts(Request $request, $id)
- {
- abort_if(! $request->user() || ! $request->user()->token(), 403);
- abort_unless($request->user()->tokenCan('read'), 403);
- $user = $request->user();
- abort_if($user->status != null, 403);
- if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
- abort_if(BouncerService::checkIp($request->ip()), 404);
- }
- $account = AccountService::get($id);
- if (! $account || $account['username'] !== $request->input('username')) {
- return $this->json([]);
- }
- $posts = ProfileStatusService::get($id);
- if (! $posts) {
- return $this->json([]);
- }
- $res = collect($posts)
- ->map(function ($id) {
- return StatusService::get($id);
- })
- ->filter(function ($post) {
- return $post && isset($post['account']);
- })
- ->toArray();
- return $this->json($res);
- }
- /**
- * POST /api/v1.1/accounts/change-password
- *
- * @return \App\Transformer\Api\AccountTransformer
- */
- public function accountChangePassword(Request $request)
- {
- abort_if(! $request->user() || ! $request->user()->token(), 403);
- abort_unless($request->user()->tokenCan('write'), 403);
- $user = $request->user();
- abort_if($user->status != null, 403);
- if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
- abort_if(BouncerService::checkIp($request->ip()), 404);
- }
- $this->validate($request, [
- 'current_password' => 'bail|required|current_password',
- 'new_password' => 'required|min:'.config('pixelfed.min_password_length', 8),
- 'confirm_password' => 'required|same:new_password',
- ], [
- 'current_password' => 'The password you entered is incorrect',
- ]);
- $user->password = bcrypt($request->input('new_password'));
- $user->save();
- $log = new AccountLog;
- $log->user_id = $user->id;
- $log->item_id = $user->id;
- $log->item_type = 'App\User';
- $log->action = 'account.edit.password';
- $log->message = 'Password changed';
- $log->link = null;
- $log->ip_address = $request->ip();
- $log->user_agent = $request->userAgent();
- $log->save();
- Mail::to($request->user())->send(new PasswordChange($user));
- return $this->json(AccountService::get($user->profile_id));
- }
- /**
- * GET /api/v1.1/accounts/login-activity
- *
- * @return array
- */
- public function accountLoginActivity(Request $request)
- {
- abort_if(! $request->user() || ! $request->user()->token(), 403);
- abort_unless($request->user()->tokenCan('read'), 403);
- $user = $request->user();
- abort_if($user->status != null, 403);
- if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
- abort_if(BouncerService::checkIp($request->ip()), 404);
- }
- $agent = new Agent();
- $currentIp = $request->ip();
- $activity = AccountLog::whereUserId($user->id)
- ->whereAction('auth.login')
- ->orderBy('created_at', 'desc')
- ->groupBy('ip_address')
- ->limit(10)
- ->get()
- ->map(function ($item) use ($agent, $currentIp) {
- $agent->setUserAgent($item->user_agent);
- return [
- 'id' => $item->id,
- 'action' => $item->action,
- 'ip' => $item->ip_address,
- 'ip_current' => $item->ip_address === $currentIp,
- 'is_mobile' => $agent->isMobile(),
- 'device' => $agent->device(),
- 'browser' => $agent->browser(),
- 'platform' => $agent->platform(),
- 'created_at' => $item->created_at->format('c'),
- ];
- });
- return $this->json($activity);
- }
- /**
- * GET /api/v1.1/accounts/two-factor
- *
- * @return array
- */
- public function accountTwoFactor(Request $request)
- {
- abort_if(! $request->user() || ! $request->user()->token(), 403);
- abort_unless($request->user()->tokenCan('read'), 403);
- $user = $request->user();
- abort_if($user->status != null, 403);
- if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
- abort_if(BouncerService::checkIp($request->ip()), 404);
- }
- $res = [
- 'active' => (bool) $user->{'2fa_enabled'},
- 'setup_at' => $user->{'2fa_setup_at'},
- ];
- return $this->json($res);
- }
- /**
- * GET /api/v1.1/accounts/emails-from-pixelfed
- *
- * @return array
- */
- public function accountEmailsFromPixelfed(Request $request)
- {
- abort_if(! $request->user() || ! $request->user()->token(), 403);
- abort_unless($request->user()->tokenCan('read'), 403);
- $user = $request->user();
- abort_if($user->status != null, 403);
- if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
- abort_if(BouncerService::checkIp($request->ip()), 404);
- }
- $from = config('mail.from.address');
- $emailVerifications = EmailVerification::whereUserId($user->id)
- ->orderByDesc('id')
- ->where('created_at', '>', now()->subDays(14))
- ->limit(10)
- ->get()
- ->map(function ($mail) use ($user, $from) {
- return [
- 'type' => 'Email Verification',
- 'subject' => 'Confirm Email',
- 'to_address' => $user->email,
- 'from_address' => $from,
- 'created_at' => str_replace('@', 'at', $mail->created_at->format('M j, Y @ g:i:s A')),
- ];
- })
- ->toArray();
- $passwordResets = DB::table('password_resets')
- ->whereEmail($user->email)
- ->where('created_at', '>', now()->subDays(14))
- ->orderByDesc('created_at')
- ->limit(10)
- ->get()
- ->map(function ($mail) use ($user, $from) {
- return [
- 'type' => 'Password Reset',
- 'subject' => 'Reset Password Notification',
- 'to_address' => $user->email,
- 'from_address' => $from,
- 'created_at' => str_replace('@', 'at', now()->parse($mail->created_at)->format('M j, Y @ g:i:s A')),
- ];
- })
- ->toArray();
- $passwordChanges = AccountLog::whereUserId($user->id)
- ->whereAction('account.edit.password')
- ->where('created_at', '>', now()->subDays(14))
- ->orderByDesc('created_at')
- ->limit(10)
- ->get()
- ->map(function ($mail) use ($user, $from) {
- return [
- 'type' => 'Password Change',
- 'subject' => 'Password Change',
- 'to_address' => $user->email,
- 'from_address' => $from,
- 'created_at' => str_replace('@', 'at', now()->parse($mail->created_at)->format('M j, Y @ g:i:s A')),
- ];
- })
- ->toArray();
- $res = collect([])
- ->merge($emailVerifications)
- ->merge($passwordResets)
- ->merge($passwordChanges)
- ->sortByDesc('created_at')
- ->values();
- return $this->json($res);
- }
- /**
- * GET /api/v1.1/accounts/apps-and-applications
- *
- * @return array
- */
- public function accountApps(Request $request)
- {
- abort_if(! $request->user() || ! $request->user()->token(), 403);
- abort_unless($request->user()->tokenCan('read'), 403);
- $user = $request->user();
- abort_if($user->status != null, 403);
- if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
- abort_if(BouncerService::checkIp($request->ip()), 404);
- }
- $res = $user->tokens->sortByDesc('created_at')->take(10)->map(function ($token, $key) use ($request) {
- return [
- 'id' => $token->id,
- 'current_session' => $request->user()->token()->id == $token->id,
- 'name' => $token->client->name,
- 'scopes' => $token->scopes,
- 'revoked' => $token->revoked,
- 'created_at' => str_replace('@', 'at', now()->parse($token->created_at)->format('M j, Y @ g:i:s A')),
- 'expires_at' => str_replace('@', 'at', now()->parse($token->expires_at)->format('M j, Y @ g:i:s A')),
- ];
- });
- return $this->json($res);
- }
- public function inAppRegistrationPreFlightCheck(Request $request)
- {
- return [
- 'open' => (bool) config_cache('pixelfed.open_registration'),
- 'iara' => (bool) config_cache('pixelfed.allow_app_registration'),
- ];
- }
- public function inAppRegistration(Request $request)
- {
- abort_if($request->user(), 404);
- abort_unless((bool) config_cache('pixelfed.open_registration'), 404);
- abort_unless((bool) config_cache('pixelfed.allow_app_registration'), 404);
- abort_unless($request->hasHeader('X-PIXELFED-APP'), 403);
- if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
- abort_if(BouncerService::checkIp($request->ip()), 404);
- }
- $rl = RateLimiter::attempt('pf:apiv1.1:iar:'.$request->ip(), config('pixelfed.app_registration_rate_limit_attempts', 3), function () {
- }, config('pixelfed.app_registration_rate_limit_decay', 1800));
- abort_if(! $rl, 400, 'Too many requests');
- $this->validate($request, [
- 'email' => [
- 'required',
- 'string',
- 'email',
- 'max:255',
- 'unique:users',
- function ($attribute, $value, $fail) {
- $banned = EmailService::isBanned($value);
- if ($banned) {
- return $fail('Email is invalid.');
- }
- },
- ],
- 'username' => [
- 'required',
- 'min:2',
- 'max:15',
- 'unique:users',
- function ($attribute, $value, $fail) {
- $dash = substr_count($value, '-');
- $underscore = substr_count($value, '_');
- $period = substr_count($value, '.');
- if (ends_with($value, ['.php', '.js', '.css'])) {
- return $fail('Username is invalid.');
- }
- if (($dash + $underscore + $period) > 1) {
- return $fail('Username is invalid. Can only contain one dash (-), period (.) or underscore (_).');
- }
- if (! ctype_alnum($value[0])) {
- return $fail('Username is invalid. Must start with a letter or number.');
- }
- if (! ctype_alnum($value[strlen($value) - 1])) {
- return $fail('Username is invalid. Must end with a letter or number.');
- }
- $val = str_replace(['_', '.', '-'], '', $value);
- if (! ctype_alnum($val)) {
- return $fail('Username is invalid. Username must be alpha-numeric and may contain dashes (-), periods (.) and underscores (_).');
- }
- $restricted = RestrictedNames::get();
- if (in_array(strtolower($value), array_map('strtolower', $restricted))) {
- return $fail('Username cannot be used.');
- }
- },
- ],
- 'password' => 'required|string|min:8',
- ]);
- $email = $request->input('email');
- $username = $request->input('username');
- $password = $request->input('password');
- if (config('database.default') == 'pgsql') {
- $username = strtolower($username);
- $email = strtolower($email);
- }
- $user = new User;
- $user->name = $username;
- $user->username = $username;
- $user->email = $email;
- $user->password = Hash::make($password);
- $user->register_source = 'app';
- $user->app_register_ip = $request->ip();
- $user->app_register_token = Str::random(40);
- $user->save();
- $rtoken = Str::random(64);
- $verify = new EmailVerification();
- $verify->user_id = $user->id;
- $verify->email = $user->email;
- $verify->user_token = $user->app_register_token;
- $verify->random_token = $rtoken;
- $verify->save();
- $params = http_build_query([
- 'ut' => $user->app_register_token,
- 'rt' => $rtoken,
- 'ea' => base64_encode($user->email),
- ]);
- $appUrl = url('/api/v1.1/auth/iarer?'.$params);
- Mail::to($user->email)->send(new ConfirmAppEmail($verify, $appUrl));
- return response()->json([
- 'success' => true,
- ]);
- }
- public function inAppRegistrationEmailRedirect(Request $request)
- {
- $this->validate($request, [
- 'ut' => 'required',
- 'rt' => 'required',
- 'ea' => 'required',
- ]);
- $ut = $request->input('ut');
- $rt = $request->input('rt');
- $ea = $request->input('ea');
- $params = http_build_query([
- 'ut' => $ut,
- 'rt' => $rt,
- 'domain' => config('pixelfed.domain.app'),
- 'ea' => $ea,
- ]);
- $url = 'pixelfed://confirm-account/'.$ut.'?'.$params;
- return redirect()->away($url);
- }
- public function inAppRegistrationConfirm(Request $request)
- {
- abort_if($request->user(), 404);
- abort_unless((bool) config_cache('pixelfed.open_registration'), 404);
- abort_unless((bool) config_cache('pixelfed.allow_app_registration'), 404);
- abort_unless($request->hasHeader('X-PIXELFED-APP'), 403);
- if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
- abort_if(BouncerService::checkIp($request->ip()), 404);
- }
- $rl = RateLimiter::attempt('pf:apiv1.1:iarc:'.$request->ip(), config('pixelfed.app_registration_confirm_rate_limit_attempts', 20), function () {
- }, config('pixelfed.app_registration_confirm_rate_limit_decay', 1800));
- abort_if(! $rl, 429, 'Too many requests');
- $request->validate([
- 'user_token' => 'required',
- 'random_token' => 'required',
- 'email' => 'required',
- ]);
- $verify = EmailVerification::whereEmail($request->input('email'))
- ->whereUserToken($request->input('user_token'))
- ->whereRandomToken($request->input('random_token'))
- ->first();
- if (! $verify) {
- return response()->json(['error' => 'Invalid tokens'], 403);
- }
- if ($verify->created_at->lt(now()->subHours(24))) {
- $verify->delete();
- return response()->json(['error' => 'Invalid tokens'], 403);
- }
- $user = User::findOrFail($verify->user_id);
- $user->email_verified_at = now();
- $user->last_active_at = now();
- $user->save();
- $token = $user->createToken('Pixelfed', ['read', 'write', 'follow', 'admin:read', 'admin:write', 'push']);
- return response()->json([
- 'access_token' => $token->accessToken,
- ]);
- }
- public function archive(Request $request, $id)
- {
- abort_if(! $request->user() || ! $request->user()->token(), 403);
- abort_unless($request->user()->tokenCan('write'), 403);
- if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
- abort_if(BouncerService::checkIp($request->ip()), 404);
- }
- $status = Status::whereNull('in_reply_to_id')
- ->whereNull('reblog_of_id')
- ->whereProfileId($request->user()->profile_id)
- ->findOrFail($id);
- if ($status->scope === 'archived') {
- return [200];
- }
- $archive = new StatusArchived;
- $archive->status_id = $status->id;
- $archive->profile_id = $status->profile_id;
- $archive->original_scope = $status->scope;
- $archive->save();
- $status->scope = 'archived';
- $status->visibility = 'draft';
- $status->save();
- StatusService::del($status->id, true);
- AccountService::syncPostCount($status->profile_id);
- return [200];
- }
- public function unarchive(Request $request, $id)
- {
- abort_if(! $request->user() || ! $request->user()->token(), 403);
- abort_unless($request->user()->tokenCan('write'), 403);
- if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
- abort_if(BouncerService::checkIp($request->ip()), 404);
- }
- $status = Status::whereNull('in_reply_to_id')
- ->whereNull('reblog_of_id')
- ->whereProfileId($request->user()->profile_id)
- ->findOrFail($id);
- if ($status->scope !== 'archived') {
- return [200];
- }
- $archive = StatusArchived::whereStatusId($status->id)
- ->whereProfileId($status->profile_id)
- ->firstOrFail();
- $status->scope = $archive->original_scope;
- $status->visibility = $archive->original_scope;
- $status->save();
- $archive->delete();
- StatusService::del($status->id, true);
- AccountService::syncPostCount($status->profile_id);
- return [200];
- }
- public function archivedPosts(Request $request)
- {
- abort_if(! $request->user() || ! $request->user()->token(), 403);
- abort_unless($request->user()->tokenCan('read'), 403);
- if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
- abort_if(BouncerService::checkIp($request->ip()), 404);
- }
- $statuses = Status::whereProfileId($request->user()->profile_id)
- ->whereScope('archived')
- ->orderByDesc('id')
- ->cursorPaginate(10);
- return StatusStateless::collection($statuses);
- }
- public function placesById(Request $request, $id, $slug)
- {
- abort_if(! $request->user() || ! $request->user()->token(), 403);
- abort_unless($request->user()->tokenCan('read'), 403);
- if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
- abort_if(BouncerService::checkIp($request->ip()), 404);
- }
- $place = Place::whereSlug($slug)->findOrFail($id);
- $posts = Cache::remember('pf-api:v1.1:places-by-id:'.$place->id, 3600, function () use ($place) {
- return Status::wherePlaceId($place->id)
- ->whereNull('uri')
- ->whereScope('public')
- ->orderByDesc('created_at')
- ->limit(60)
- ->pluck('id');
- });
- $posts = $posts->map(function ($id) {
- return StatusService::get($id);
- })
- ->filter()
- ->values();
- return [
- 'place' => [
- 'id' => $place->id,
- 'name' => $place->name,
- 'slug' => $place->slug,
- 'country' => $place->country,
- 'lat' => $place->lat,
- 'long' => $place->long,
- ],
- 'posts' => $posts];
- }
- public function moderatePost(Request $request, $id)
- {
- abort_if(! $request->user() || ! $request->user()->token(), 403);
- abort_if($request->user()->is_admin != true, 403);
- abort_unless($request->user()->tokenCan('admin:write'), 403);
- if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
- abort_if(BouncerService::checkIp($request->ip()), 404);
- }
- $this->validate($request, [
- 'action' => 'required|in:cw,mark-public,mark-unlisted,mark-private,mark-spammer,delete',
- ]);
- $action = $request->input('action');
- $status = Status::find($id);
- if (! $status) {
- return response()->json(['error' => 'Cannot find status'], 400);
- }
- if ($status->uri == null) {
- if ($status->profile->user && $status->profile->user->is_admin) {
- return response()->json(['error' => 'Cannot moderate admin accounts'], 400);
- }
- }
- if ($action == 'mark-spammer') {
- $status->profile->update([
- 'unlisted' => true,
- 'cw' => true,
- 'no_autolink' => true,
- ]);
- Status::whereProfileId($status->profile_id)
- ->get()
- ->each(function ($s) {
- if (in_array($s->scope, ['public', 'unlisted'])) {
- $s->scope = 'private';
- $s->visibility = 'private';
- }
- $s->is_nsfw = true;
- $s->save();
- StatusService::del($s->id, true);
- });
- Cache::forget('pf:bouncer_v0:exemption_by_pid:'.$status->profile_id);
- Cache::forget('pf:bouncer_v0:recent_by_pid:'.$status->profile_id);
- Cache::forget('admin-dash:reports:spam-count');
- } elseif ($action == 'cw') {
- $state = $status->is_nsfw;
- $status->is_nsfw = ! $state;
- $status->save();
- StatusService::del($status->id);
- } elseif ($action == 'mark-public') {
- $state = $status->scope;
- $status->scope = 'public';
- $status->visibility = 'public';
- $status->save();
- StatusService::del($status->id, true);
- if ($state !== 'public') {
- if ($status->uri) {
- if ($status->in_reply_to_id == null && $status->reblog_of_id == null) {
- NetworkTimelineService::add($status->id);
- }
- } else {
- if ($status->in_reply_to_id == null && $status->reblog_of_id == null) {
- PublicTimelineService::add($status->id);
- }
- }
- }
- } elseif ($action == 'mark-unlisted') {
- $state = $status->scope;
- $status->scope = 'unlisted';
- $status->visibility = 'unlisted';
- $status->save();
- StatusService::del($status->id);
- if ($state == 'public') {
- PublicTimelineService::del($status->id);
- NetworkTimelineService::del($status->id);
- }
- } elseif ($action == 'mark-private') {
- $state = $status->scope;
- $status->scope = 'private';
- $status->visibility = 'private';
- $status->save();
- StatusService::del($status->id);
- if ($state == 'public') {
- PublicTimelineService::del($status->id);
- NetworkTimelineService::del($status->id);
- }
- } elseif ($action == 'delete') {
- PublicTimelineService::del($status->id);
- NetworkTimelineService::del($status->id);
- Cache::forget('_api:statuses:recent_9:'.$status->profile_id);
- Cache::forget('profile:status_count:'.$status->profile_id);
- Cache::forget('profile:embed:'.$status->profile_id);
- StatusService::del($status->id, true);
- Cache::forget('profile:status_count:'.$status->profile_id);
- $status->uri ? RemoteStatusDelete::dispatch($status) : StatusDelete::dispatch($status);
- return [];
- }
- Cache::forget('_api:statuses:recent_9:'.$status->profile_id);
- return StatusService::get($status->id, false);
- }
- public function getWebSettings(Request $request)
- {
- abort_if(! $request->user() || ! $request->user()->token(), 403);
- abort_unless($request->user()->tokenCan('read'), 403);
- $uid = $request->user()->id;
- $settings = UserSetting::firstOrCreate([
- 'user_id' => $uid,
- ]);
- if (! $settings->other) {
- return [];
- }
- return $settings->other;
- }
- public function setWebSettings(Request $request)
- {
- abort_if(! $request->user() || ! $request->user()->token(), 403);
- abort_unless($request->user()->tokenCan('write'), 403);
- $this->validate($request, [
- 'field' => 'required|in:enable_reblogs,hide_reblog_banner',
- 'value' => 'required',
- ]);
- $field = $request->input('field');
- $value = $request->input('value');
- $settings = UserSetting::firstOrCreate([
- 'user_id' => $request->user()->id,
- ]);
- if (! $settings->other) {
- $other = [];
- } else {
- $other = $settings->other;
- }
- $other[$field] = $value;
- $settings->other = $other;
- $settings->save();
- return [200];
- }
- public function getMutualAccounts(Request $request, $id)
- {
- abort_if(! $request->user() || ! $request->user()->token(), 403);
- abort_unless($request->user()->tokenCan('follows'), 403);
- $account = AccountService::get($id, true);
- if (! $account || ! isset($account['id'])) {
- return [];
- }
- $res = collect(FollowerService::mutualAccounts($request->user()->profile_id, $id))
- ->map(function ($accountId) {
- return AccountService::get($accountId, true);
- })
- ->filter()
- ->take(24)
- ->values();
- return $this->json($res);
- }
- public function accountUsernameToId(Request $request, $username)
- {
- abort_if(! $request->user() || ! $request->user()->token() || ! $username, 403);
- abort_unless($request->user()->tokenCan('read'), 403);
- $rateLimiting = (bool) config_cache('api.rate-limits.v1Dot1.accounts.usernameToId.enabled');
- $ipRateLimiting = (bool) config_cache('api.rate-limits.v1Dot1.accounts.usernameToId.ip_enabled');
- if ($ipRateLimiting) {
- $userLimit = (int) config_cache('api.rate-limits.v1Dot1.accounts.usernameToId.ip_limit');
- $userDecay = (int) config_cache('api.rate-limits.v1Dot1.accounts.usernameToId.ip_decay');
- $userKey = 'pf:apiv1.1:acctU2ID:byIp:'.$request->ip();
- if (RateLimiter::tooManyAttempts($userKey, $userLimit)) {
- $limits = [
- 'X-Rate-Limit-Limit' => $userLimit,
- 'X-Rate-Limit-Remaining' => RateLimiter::remaining($userKey, $userLimit),
- 'X-Rate-Limit-Reset' => RateLimiter::availableIn($userKey),
- ];
- return $this->json(['error' => 'Too many attempts!'], 429, $limits);
- }
- RateLimiter::increment($userKey, $userDecay);
- $limits = [
- 'X-Rate-Limit-Limit' => $userLimit,
- 'X-Rate-Limit-Remaining' => RateLimiter::remaining($userKey, $userLimit),
- 'X-Rate-Limit-Reset' => RateLimiter::availableIn($userKey),
- ];
- }
- if ($rateLimiting) {
- $userLimit = (int) config_cache('api.rate-limits.v1Dot1.accounts.usernameToId.limit');
- $userDecay = (int) config_cache('api.rate-limits.v1Dot1.accounts.usernameToId.decay');
- $userKey = 'pf:apiv1.1:acctU2ID:byUid:'.$request->user()->id;
- if (RateLimiter::tooManyAttempts($userKey, $userLimit)) {
- $limits = [
- 'X-Rate-Limit-Limit' => $userLimit,
- 'X-Rate-Limit-Remaining' => RateLimiter::remaining($userKey, $userLimit),
- 'X-Rate-Limit-Reset' => RateLimiter::availableIn($userKey),
- ];
- return $this->json(['error' => 'Too many attempts!'], 429, $limits);
- }
- RateLimiter::increment($userKey, $userDecay);
- $limits = [
- 'X-Rate-Limit-Limit' => $userLimit,
- 'X-Rate-Limit-Remaining' => RateLimiter::remaining($userKey, $userLimit),
- 'X-Rate-Limit-Reset' => RateLimiter::availableIn($userKey),
- ];
- }
- $accountId = AccountService::usernameToId($username, true);
- if (! $accountId) {
- return [];
- }
- $account = AccountService::get($accountId);
- return $this->json($account, 200, $rateLimiting ? $limits : []);
- }
- }
|