ApiV1Dot1Controller.php 35 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008
  1. <?php
  2. namespace App\Http\Controllers\Api;
  3. use App\AccountLog;
  4. use App\EmailVerification;
  5. use App\Http\Controllers\Controller;
  6. use App\Http\Resources\StatusStateless;
  7. use App\Jobs\ReportPipeline\ReportNotifyAdminViaEmail;
  8. use App\Jobs\StatusPipeline\RemoteStatusDelete;
  9. use App\Jobs\StatusPipeline\StatusDelete;
  10. use App\Mail\ConfirmAppEmail;
  11. use App\Mail\PasswordChange;
  12. use App\Place;
  13. use App\Profile;
  14. use App\Report;
  15. use App\Services\AccountService;
  16. use App\Services\BouncerService;
  17. use App\Services\EmailService;
  18. use App\Services\FollowerService;
  19. use App\Services\NetworkTimelineService;
  20. use App\Services\ProfileStatusService;
  21. use App\Services\PublicTimelineService;
  22. use App\Services\StatusService;
  23. use App\Status;
  24. use App\StatusArchived;
  25. use App\User;
  26. use App\UserSetting;
  27. use App\Util\Lexer\RestrictedNames;
  28. use Cache;
  29. use DB;
  30. use Illuminate\Http\Request;
  31. use Illuminate\Support\Facades\Hash;
  32. use Illuminate\Support\Facades\RateLimiter;
  33. use Illuminate\Support\Str;
  34. use Jenssegers\Agent\Agent;
  35. use League\Fractal;
  36. use League\Fractal\Serializer\ArraySerializer;
  37. use Mail;
  38. class ApiV1Dot1Controller extends Controller
  39. {
  40. protected $fractal;
  41. public function __construct()
  42. {
  43. $this->fractal = new Fractal\Manager();
  44. $this->fractal->setSerializer(new ArraySerializer());
  45. }
  46. public function json($res, $code = 200, $headers = [])
  47. {
  48. return response()->json($res, $code, $headers, JSON_UNESCAPED_SLASHES);
  49. }
  50. public function error($msg, $code = 400, $extra = [], $headers = [])
  51. {
  52. $res = [
  53. 'msg' => $msg,
  54. 'code' => $code,
  55. ];
  56. return response()->json(array_merge($res, $extra), $code, $headers, JSON_UNESCAPED_SLASHES);
  57. }
  58. public function report(Request $request)
  59. {
  60. abort_if(! $request->user() || ! $request->user()->token(), 403);
  61. abort_unless($request->user()->tokenCan('write'), 403);
  62. $user = $request->user();
  63. abort_if($user->status != null, 403);
  64. if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
  65. abort_if(BouncerService::checkIp($request->ip()), 404);
  66. }
  67. $report_type = $request->input('report_type');
  68. $object_id = $request->input('object_id');
  69. $object_type = $request->input('object_type');
  70. $types = [
  71. 'spam',
  72. 'sensitive',
  73. 'abusive',
  74. 'underage',
  75. 'violence',
  76. 'copyright',
  77. 'impersonation',
  78. 'scam',
  79. 'terrorism',
  80. ];
  81. if (! $report_type || ! $object_id || ! $object_type) {
  82. return $this->error('Invalid or missing parameters', 400, ['error_code' => 'ERROR_INVALID_PARAMS']);
  83. }
  84. if (! in_array($report_type, $types)) {
  85. return $this->error('Invalid report type', 400, ['error_code' => 'ERROR_TYPE_INVALID']);
  86. }
  87. if ($object_type === 'user' && $object_id == $user->profile_id) {
  88. return $this->error('Cannot self report', 400, ['error_code' => 'ERROR_NO_SELF_REPORTS']);
  89. }
  90. $rpid = null;
  91. switch ($object_type) {
  92. case 'post':
  93. $object = Status::find($object_id);
  94. if (! $object) {
  95. return $this->error('Invalid object id', 400, ['error_code' => 'ERROR_INVALID_OBJECT_ID']);
  96. }
  97. $object_type = 'App\Status';
  98. $exists = Report::whereUserId($user->id)
  99. ->whereObjectId($object->id)
  100. ->whereObjectType('App\Status')
  101. ->count();
  102. $rpid = $object->profile_id;
  103. break;
  104. case 'user':
  105. $object = Profile::find($object_id);
  106. if (! $object) {
  107. return $this->error('Invalid object id', 400, ['error_code' => 'ERROR_INVALID_OBJECT_ID']);
  108. }
  109. $object_type = 'App\Profile';
  110. $exists = Report::whereUserId($user->id)
  111. ->whereObjectId($object->id)
  112. ->whereObjectType('App\Profile')
  113. ->count();
  114. $rpid = $object->id;
  115. break;
  116. default:
  117. return $this->error('Invalid report type', 400, ['error_code' => 'ERROR_REPORT_OBJECT_TYPE_INVALID']);
  118. break;
  119. }
  120. if ($exists !== 0) {
  121. return $this->error('Duplicate report', 400, ['error_code' => 'ERROR_REPORT_DUPLICATE']);
  122. }
  123. if ($object->profile_id == $user->profile_id) {
  124. return $this->error('Cannot self report', 400, ['error_code' => 'ERROR_NO_SELF_REPORTS']);
  125. }
  126. $report = new Report;
  127. $report->profile_id = $user->profile_id;
  128. $report->user_id = $user->id;
  129. $report->object_id = $object->id;
  130. $report->object_type = $object_type;
  131. $report->reported_profile_id = $rpid;
  132. $report->type = $report_type;
  133. $report->save();
  134. if (config('instance.reports.email.enabled')) {
  135. ReportNotifyAdminViaEmail::dispatch($report)->onQueue('default');
  136. }
  137. $res = [
  138. 'msg' => 'Successfully sent report',
  139. 'code' => 200,
  140. ];
  141. return $this->json($res);
  142. }
  143. /**
  144. * DELETE /api/v1.1/accounts/avatar
  145. *
  146. * @return \App\Transformer\Api\AccountTransformer
  147. */
  148. public function deleteAvatar(Request $request)
  149. {
  150. abort_if(! $request->user() || ! $request->user()->token(), 403);
  151. abort_unless($request->user()->tokenCan('write'), 403);
  152. $user = $request->user();
  153. abort_if($user->status != null, 403);
  154. if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
  155. abort_if(BouncerService::checkIp($request->ip()), 404);
  156. }
  157. $avatar = $user->profile->avatar;
  158. if ($avatar->media_path == 'public/avatars/default.png' ||
  159. $avatar->media_path == 'public/avatars/default.jpg'
  160. ) {
  161. return AccountService::get($user->profile_id);
  162. }
  163. if (is_file(storage_path('app/'.$avatar->media_path))) {
  164. @unlink(storage_path('app/'.$avatar->media_path));
  165. }
  166. $avatar->media_path = 'public/avatars/default.jpg';
  167. $avatar->change_count = $avatar->change_count + 1;
  168. $avatar->save();
  169. Cache::forget('avatar:'.$user->profile_id);
  170. Cache::forget("avatar:{$user->profile_id}");
  171. Cache::forget('user:account:id:'.$user->id);
  172. AccountService::del($user->profile_id);
  173. return AccountService::get($user->profile_id);
  174. }
  175. /**
  176. * GET /api/v1.1/accounts/{id}/posts
  177. *
  178. * @return \App\Transformer\Api\StatusTransformer
  179. */
  180. public function accountPosts(Request $request, $id)
  181. {
  182. abort_if(! $request->user() || ! $request->user()->token(), 403);
  183. abort_unless($request->user()->tokenCan('read'), 403);
  184. $user = $request->user();
  185. abort_if($user->status != null, 403);
  186. if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
  187. abort_if(BouncerService::checkIp($request->ip()), 404);
  188. }
  189. $account = AccountService::get($id);
  190. if (! $account || $account['username'] !== $request->input('username')) {
  191. return $this->json([]);
  192. }
  193. $posts = ProfileStatusService::get($id);
  194. if (! $posts) {
  195. return $this->json([]);
  196. }
  197. $res = collect($posts)
  198. ->map(function ($id) {
  199. return StatusService::get($id);
  200. })
  201. ->filter(function ($post) {
  202. return $post && isset($post['account']);
  203. })
  204. ->toArray();
  205. return $this->json($res);
  206. }
  207. /**
  208. * POST /api/v1.1/accounts/change-password
  209. *
  210. * @return \App\Transformer\Api\AccountTransformer
  211. */
  212. public function accountChangePassword(Request $request)
  213. {
  214. abort_if(! $request->user() || ! $request->user()->token(), 403);
  215. abort_unless($request->user()->tokenCan('write'), 403);
  216. $user = $request->user();
  217. abort_if($user->status != null, 403);
  218. if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
  219. abort_if(BouncerService::checkIp($request->ip()), 404);
  220. }
  221. $this->validate($request, [
  222. 'current_password' => 'bail|required|current_password',
  223. 'new_password' => 'required|min:'.config('pixelfed.min_password_length', 8),
  224. 'confirm_password' => 'required|same:new_password',
  225. ], [
  226. 'current_password' => 'The password you entered is incorrect',
  227. ]);
  228. $user->password = bcrypt($request->input('new_password'));
  229. $user->save();
  230. $log = new AccountLog;
  231. $log->user_id = $user->id;
  232. $log->item_id = $user->id;
  233. $log->item_type = 'App\User';
  234. $log->action = 'account.edit.password';
  235. $log->message = 'Password changed';
  236. $log->link = null;
  237. $log->ip_address = $request->ip();
  238. $log->user_agent = $request->userAgent();
  239. $log->save();
  240. Mail::to($request->user())->send(new PasswordChange($user));
  241. return $this->json(AccountService::get($user->profile_id));
  242. }
  243. /**
  244. * GET /api/v1.1/accounts/login-activity
  245. *
  246. * @return array
  247. */
  248. public function accountLoginActivity(Request $request)
  249. {
  250. abort_if(! $request->user() || ! $request->user()->token(), 403);
  251. abort_unless($request->user()->tokenCan('read'), 403);
  252. $user = $request->user();
  253. abort_if($user->status != null, 403);
  254. if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
  255. abort_if(BouncerService::checkIp($request->ip()), 404);
  256. }
  257. $agent = new Agent();
  258. $currentIp = $request->ip();
  259. $activity = AccountLog::whereUserId($user->id)
  260. ->whereAction('auth.login')
  261. ->orderBy('created_at', 'desc')
  262. ->groupBy('ip_address')
  263. ->limit(10)
  264. ->get()
  265. ->map(function ($item) use ($agent, $currentIp) {
  266. $agent->setUserAgent($item->user_agent);
  267. return [
  268. 'id' => $item->id,
  269. 'action' => $item->action,
  270. 'ip' => $item->ip_address,
  271. 'ip_current' => $item->ip_address === $currentIp,
  272. 'is_mobile' => $agent->isMobile(),
  273. 'device' => $agent->device(),
  274. 'browser' => $agent->browser(),
  275. 'platform' => $agent->platform(),
  276. 'created_at' => $item->created_at->format('c'),
  277. ];
  278. });
  279. return $this->json($activity);
  280. }
  281. /**
  282. * GET /api/v1.1/accounts/two-factor
  283. *
  284. * @return array
  285. */
  286. public function accountTwoFactor(Request $request)
  287. {
  288. abort_if(! $request->user() || ! $request->user()->token(), 403);
  289. abort_unless($request->user()->tokenCan('read'), 403);
  290. $user = $request->user();
  291. abort_if($user->status != null, 403);
  292. if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
  293. abort_if(BouncerService::checkIp($request->ip()), 404);
  294. }
  295. $res = [
  296. 'active' => (bool) $user->{'2fa_enabled'},
  297. 'setup_at' => $user->{'2fa_setup_at'},
  298. ];
  299. return $this->json($res);
  300. }
  301. /**
  302. * GET /api/v1.1/accounts/emails-from-pixelfed
  303. *
  304. * @return array
  305. */
  306. public function accountEmailsFromPixelfed(Request $request)
  307. {
  308. abort_if(! $request->user() || ! $request->user()->token(), 403);
  309. abort_unless($request->user()->tokenCan('read'), 403);
  310. $user = $request->user();
  311. abort_if($user->status != null, 403);
  312. if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
  313. abort_if(BouncerService::checkIp($request->ip()), 404);
  314. }
  315. $from = config('mail.from.address');
  316. $emailVerifications = EmailVerification::whereUserId($user->id)
  317. ->orderByDesc('id')
  318. ->where('created_at', '>', now()->subDays(14))
  319. ->limit(10)
  320. ->get()
  321. ->map(function ($mail) use ($user, $from) {
  322. return [
  323. 'type' => 'Email Verification',
  324. 'subject' => 'Confirm Email',
  325. 'to_address' => $user->email,
  326. 'from_address' => $from,
  327. 'created_at' => str_replace('@', 'at', $mail->created_at->format('M j, Y @ g:i:s A')),
  328. ];
  329. })
  330. ->toArray();
  331. $passwordResets = DB::table('password_resets')
  332. ->whereEmail($user->email)
  333. ->where('created_at', '>', now()->subDays(14))
  334. ->orderByDesc('created_at')
  335. ->limit(10)
  336. ->get()
  337. ->map(function ($mail) use ($user, $from) {
  338. return [
  339. 'type' => 'Password Reset',
  340. 'subject' => 'Reset Password Notification',
  341. 'to_address' => $user->email,
  342. 'from_address' => $from,
  343. 'created_at' => str_replace('@', 'at', now()->parse($mail->created_at)->format('M j, Y @ g:i:s A')),
  344. ];
  345. })
  346. ->toArray();
  347. $passwordChanges = AccountLog::whereUserId($user->id)
  348. ->whereAction('account.edit.password')
  349. ->where('created_at', '>', now()->subDays(14))
  350. ->orderByDesc('created_at')
  351. ->limit(10)
  352. ->get()
  353. ->map(function ($mail) use ($user, $from) {
  354. return [
  355. 'type' => 'Password Change',
  356. 'subject' => 'Password Change',
  357. 'to_address' => $user->email,
  358. 'from_address' => $from,
  359. 'created_at' => str_replace('@', 'at', now()->parse($mail->created_at)->format('M j, Y @ g:i:s A')),
  360. ];
  361. })
  362. ->toArray();
  363. $res = collect([])
  364. ->merge($emailVerifications)
  365. ->merge($passwordResets)
  366. ->merge($passwordChanges)
  367. ->sortByDesc('created_at')
  368. ->values();
  369. return $this->json($res);
  370. }
  371. /**
  372. * GET /api/v1.1/accounts/apps-and-applications
  373. *
  374. * @return array
  375. */
  376. public function accountApps(Request $request)
  377. {
  378. abort_if(! $request->user() || ! $request->user()->token(), 403);
  379. abort_unless($request->user()->tokenCan('read'), 403);
  380. $user = $request->user();
  381. abort_if($user->status != null, 403);
  382. if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
  383. abort_if(BouncerService::checkIp($request->ip()), 404);
  384. }
  385. $res = $user->tokens->sortByDesc('created_at')->take(10)->map(function ($token, $key) use ($request) {
  386. return [
  387. 'id' => $token->id,
  388. 'current_session' => $request->user()->token()->id == $token->id,
  389. 'name' => $token->client->name,
  390. 'scopes' => $token->scopes,
  391. 'revoked' => $token->revoked,
  392. 'created_at' => str_replace('@', 'at', now()->parse($token->created_at)->format('M j, Y @ g:i:s A')),
  393. 'expires_at' => str_replace('@', 'at', now()->parse($token->expires_at)->format('M j, Y @ g:i:s A')),
  394. ];
  395. });
  396. return $this->json($res);
  397. }
  398. public function inAppRegistrationPreFlightCheck(Request $request)
  399. {
  400. return [
  401. 'open' => (bool) config_cache('pixelfed.open_registration'),
  402. 'iara' => (bool) config_cache('pixelfed.allow_app_registration'),
  403. ];
  404. }
  405. public function inAppRegistration(Request $request)
  406. {
  407. abort_if($request->user(), 404);
  408. abort_unless((bool) config_cache('pixelfed.open_registration'), 404);
  409. abort_unless((bool) config_cache('pixelfed.allow_app_registration'), 404);
  410. abort_unless($request->hasHeader('X-PIXELFED-APP'), 403);
  411. if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
  412. abort_if(BouncerService::checkIp($request->ip()), 404);
  413. }
  414. $rl = RateLimiter::attempt('pf:apiv1.1:iar:'.$request->ip(), config('pixelfed.app_registration_rate_limit_attempts', 3), function () {
  415. }, config('pixelfed.app_registration_rate_limit_decay', 1800));
  416. abort_if(! $rl, 400, 'Too many requests');
  417. $this->validate($request, [
  418. 'email' => [
  419. 'required',
  420. 'string',
  421. 'email',
  422. 'max:255',
  423. 'unique:users',
  424. function ($attribute, $value, $fail) {
  425. $banned = EmailService::isBanned($value);
  426. if ($banned) {
  427. return $fail('Email is invalid.');
  428. }
  429. },
  430. ],
  431. 'username' => [
  432. 'required',
  433. 'min:2',
  434. 'max:15',
  435. 'unique:users',
  436. function ($attribute, $value, $fail) {
  437. $dash = substr_count($value, '-');
  438. $underscore = substr_count($value, '_');
  439. $period = substr_count($value, '.');
  440. if (ends_with($value, ['.php', '.js', '.css'])) {
  441. return $fail('Username is invalid.');
  442. }
  443. if (($dash + $underscore + $period) > 1) {
  444. return $fail('Username is invalid. Can only contain one dash (-), period (.) or underscore (_).');
  445. }
  446. if (! ctype_alnum($value[0])) {
  447. return $fail('Username is invalid. Must start with a letter or number.');
  448. }
  449. if (! ctype_alnum($value[strlen($value) - 1])) {
  450. return $fail('Username is invalid. Must end with a letter or number.');
  451. }
  452. $val = str_replace(['_', '.', '-'], '', $value);
  453. if (! ctype_alnum($val)) {
  454. return $fail('Username is invalid. Username must be alpha-numeric and may contain dashes (-), periods (.) and underscores (_).');
  455. }
  456. $restricted = RestrictedNames::get();
  457. if (in_array(strtolower($value), array_map('strtolower', $restricted))) {
  458. return $fail('Username cannot be used.');
  459. }
  460. },
  461. ],
  462. 'password' => 'required|string|min:8',
  463. ]);
  464. $email = $request->input('email');
  465. $username = $request->input('username');
  466. $password = $request->input('password');
  467. if (config('database.default') == 'pgsql') {
  468. $username = strtolower($username);
  469. $email = strtolower($email);
  470. }
  471. $user = new User;
  472. $user->name = $username;
  473. $user->username = $username;
  474. $user->email = $email;
  475. $user->password = Hash::make($password);
  476. $user->register_source = 'app';
  477. $user->app_register_ip = $request->ip();
  478. $user->app_register_token = Str::random(40);
  479. $user->save();
  480. $rtoken = Str::random(64);
  481. $verify = new EmailVerification();
  482. $verify->user_id = $user->id;
  483. $verify->email = $user->email;
  484. $verify->user_token = $user->app_register_token;
  485. $verify->random_token = $rtoken;
  486. $verify->save();
  487. $params = http_build_query([
  488. 'ut' => $user->app_register_token,
  489. 'rt' => $rtoken,
  490. 'ea' => base64_encode($user->email),
  491. ]);
  492. $appUrl = url('/api/v1.1/auth/iarer?'.$params);
  493. Mail::to($user->email)->send(new ConfirmAppEmail($verify, $appUrl));
  494. return response()->json([
  495. 'success' => true,
  496. ]);
  497. }
  498. public function inAppRegistrationEmailRedirect(Request $request)
  499. {
  500. $this->validate($request, [
  501. 'ut' => 'required',
  502. 'rt' => 'required',
  503. 'ea' => 'required',
  504. ]);
  505. $ut = $request->input('ut');
  506. $rt = $request->input('rt');
  507. $ea = $request->input('ea');
  508. $params = http_build_query([
  509. 'ut' => $ut,
  510. 'rt' => $rt,
  511. 'domain' => config('pixelfed.domain.app'),
  512. 'ea' => $ea,
  513. ]);
  514. $url = 'pixelfed://confirm-account/'.$ut.'?'.$params;
  515. return redirect()->away($url);
  516. }
  517. public function inAppRegistrationConfirm(Request $request)
  518. {
  519. abort_if($request->user(), 404);
  520. abort_unless((bool) config_cache('pixelfed.open_registration'), 404);
  521. abort_unless((bool) config_cache('pixelfed.allow_app_registration'), 404);
  522. abort_unless($request->hasHeader('X-PIXELFED-APP'), 403);
  523. if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
  524. abort_if(BouncerService::checkIp($request->ip()), 404);
  525. }
  526. $rl = RateLimiter::attempt('pf:apiv1.1:iarc:'.$request->ip(), config('pixelfed.app_registration_confirm_rate_limit_attempts', 20), function () {
  527. }, config('pixelfed.app_registration_confirm_rate_limit_decay', 1800));
  528. abort_if(! $rl, 429, 'Too many requests');
  529. $request->validate([
  530. 'user_token' => 'required',
  531. 'random_token' => 'required',
  532. 'email' => 'required',
  533. ]);
  534. $verify = EmailVerification::whereEmail($request->input('email'))
  535. ->whereUserToken($request->input('user_token'))
  536. ->whereRandomToken($request->input('random_token'))
  537. ->first();
  538. if (! $verify) {
  539. return response()->json(['error' => 'Invalid tokens'], 403);
  540. }
  541. if ($verify->created_at->lt(now()->subHours(24))) {
  542. $verify->delete();
  543. return response()->json(['error' => 'Invalid tokens'], 403);
  544. }
  545. $user = User::findOrFail($verify->user_id);
  546. $user->email_verified_at = now();
  547. $user->last_active_at = now();
  548. $user->save();
  549. $token = $user->createToken('Pixelfed', ['read', 'write', 'follow', 'admin:read', 'admin:write', 'push']);
  550. return response()->json([
  551. 'access_token' => $token->accessToken,
  552. ]);
  553. }
  554. public function archive(Request $request, $id)
  555. {
  556. abort_if(! $request->user() || ! $request->user()->token(), 403);
  557. abort_unless($request->user()->tokenCan('write'), 403);
  558. if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
  559. abort_if(BouncerService::checkIp($request->ip()), 404);
  560. }
  561. $status = Status::whereNull('in_reply_to_id')
  562. ->whereNull('reblog_of_id')
  563. ->whereProfileId($request->user()->profile_id)
  564. ->findOrFail($id);
  565. if ($status->scope === 'archived') {
  566. return [200];
  567. }
  568. $archive = new StatusArchived;
  569. $archive->status_id = $status->id;
  570. $archive->profile_id = $status->profile_id;
  571. $archive->original_scope = $status->scope;
  572. $archive->save();
  573. $status->scope = 'archived';
  574. $status->visibility = 'draft';
  575. $status->save();
  576. StatusService::del($status->id, true);
  577. AccountService::syncPostCount($status->profile_id);
  578. return [200];
  579. }
  580. public function unarchive(Request $request, $id)
  581. {
  582. abort_if(! $request->user() || ! $request->user()->token(), 403);
  583. abort_unless($request->user()->tokenCan('write'), 403);
  584. if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
  585. abort_if(BouncerService::checkIp($request->ip()), 404);
  586. }
  587. $status = Status::whereNull('in_reply_to_id')
  588. ->whereNull('reblog_of_id')
  589. ->whereProfileId($request->user()->profile_id)
  590. ->findOrFail($id);
  591. if ($status->scope !== 'archived') {
  592. return [200];
  593. }
  594. $archive = StatusArchived::whereStatusId($status->id)
  595. ->whereProfileId($status->profile_id)
  596. ->firstOrFail();
  597. $status->scope = $archive->original_scope;
  598. $status->visibility = $archive->original_scope;
  599. $status->save();
  600. $archive->delete();
  601. StatusService::del($status->id, true);
  602. AccountService::syncPostCount($status->profile_id);
  603. return [200];
  604. }
  605. public function archivedPosts(Request $request)
  606. {
  607. abort_if(! $request->user() || ! $request->user()->token(), 403);
  608. abort_unless($request->user()->tokenCan('read'), 403);
  609. if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
  610. abort_if(BouncerService::checkIp($request->ip()), 404);
  611. }
  612. $statuses = Status::whereProfileId($request->user()->profile_id)
  613. ->whereScope('archived')
  614. ->orderByDesc('id')
  615. ->cursorPaginate(10);
  616. return StatusStateless::collection($statuses);
  617. }
  618. public function placesById(Request $request, $id, $slug)
  619. {
  620. abort_if(! $request->user() || ! $request->user()->token(), 403);
  621. abort_unless($request->user()->tokenCan('read'), 403);
  622. if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
  623. abort_if(BouncerService::checkIp($request->ip()), 404);
  624. }
  625. $place = Place::whereSlug($slug)->findOrFail($id);
  626. $posts = Cache::remember('pf-api:v1.1:places-by-id:'.$place->id, 3600, function () use ($place) {
  627. return Status::wherePlaceId($place->id)
  628. ->whereNull('uri')
  629. ->whereScope('public')
  630. ->orderByDesc('created_at')
  631. ->limit(60)
  632. ->pluck('id');
  633. });
  634. $posts = $posts->map(function ($id) {
  635. return StatusService::get($id);
  636. })
  637. ->filter()
  638. ->values();
  639. return [
  640. 'place' => [
  641. 'id' => $place->id,
  642. 'name' => $place->name,
  643. 'slug' => $place->slug,
  644. 'country' => $place->country,
  645. 'lat' => $place->lat,
  646. 'long' => $place->long,
  647. ],
  648. 'posts' => $posts];
  649. }
  650. public function moderatePost(Request $request, $id)
  651. {
  652. abort_if(! $request->user() || ! $request->user()->token(), 403);
  653. abort_if($request->user()->is_admin != true, 403);
  654. abort_unless($request->user()->tokenCan('admin:write'), 403);
  655. if (config('pixelfed.bouncer.cloud_ips.ban_signups')) {
  656. abort_if(BouncerService::checkIp($request->ip()), 404);
  657. }
  658. $this->validate($request, [
  659. 'action' => 'required|in:cw,mark-public,mark-unlisted,mark-private,mark-spammer,delete',
  660. ]);
  661. $action = $request->input('action');
  662. $status = Status::find($id);
  663. if (! $status) {
  664. return response()->json(['error' => 'Cannot find status'], 400);
  665. }
  666. if ($status->uri == null) {
  667. if ($status->profile->user && $status->profile->user->is_admin) {
  668. return response()->json(['error' => 'Cannot moderate admin accounts'], 400);
  669. }
  670. }
  671. if ($action == 'mark-spammer') {
  672. $status->profile->update([
  673. 'unlisted' => true,
  674. 'cw' => true,
  675. 'no_autolink' => true,
  676. ]);
  677. Status::whereProfileId($status->profile_id)
  678. ->get()
  679. ->each(function ($s) {
  680. if (in_array($s->scope, ['public', 'unlisted'])) {
  681. $s->scope = 'private';
  682. $s->visibility = 'private';
  683. }
  684. $s->is_nsfw = true;
  685. $s->save();
  686. StatusService::del($s->id, true);
  687. });
  688. Cache::forget('pf:bouncer_v0:exemption_by_pid:'.$status->profile_id);
  689. Cache::forget('pf:bouncer_v0:recent_by_pid:'.$status->profile_id);
  690. Cache::forget('admin-dash:reports:spam-count');
  691. } elseif ($action == 'cw') {
  692. $state = $status->is_nsfw;
  693. $status->is_nsfw = ! $state;
  694. $status->save();
  695. StatusService::del($status->id);
  696. } elseif ($action == 'mark-public') {
  697. $state = $status->scope;
  698. $status->scope = 'public';
  699. $status->visibility = 'public';
  700. $status->save();
  701. StatusService::del($status->id, true);
  702. if ($state !== 'public') {
  703. if ($status->uri) {
  704. if ($status->in_reply_to_id == null && $status->reblog_of_id == null) {
  705. NetworkTimelineService::add($status->id);
  706. }
  707. } else {
  708. if ($status->in_reply_to_id == null && $status->reblog_of_id == null) {
  709. PublicTimelineService::add($status->id);
  710. }
  711. }
  712. }
  713. } elseif ($action == 'mark-unlisted') {
  714. $state = $status->scope;
  715. $status->scope = 'unlisted';
  716. $status->visibility = 'unlisted';
  717. $status->save();
  718. StatusService::del($status->id);
  719. if ($state == 'public') {
  720. PublicTimelineService::del($status->id);
  721. NetworkTimelineService::del($status->id);
  722. }
  723. } elseif ($action == 'mark-private') {
  724. $state = $status->scope;
  725. $status->scope = 'private';
  726. $status->visibility = 'private';
  727. $status->save();
  728. StatusService::del($status->id);
  729. if ($state == 'public') {
  730. PublicTimelineService::del($status->id);
  731. NetworkTimelineService::del($status->id);
  732. }
  733. } elseif ($action == 'delete') {
  734. PublicTimelineService::del($status->id);
  735. NetworkTimelineService::del($status->id);
  736. Cache::forget('_api:statuses:recent_9:'.$status->profile_id);
  737. Cache::forget('profile:status_count:'.$status->profile_id);
  738. Cache::forget('profile:embed:'.$status->profile_id);
  739. StatusService::del($status->id, true);
  740. Cache::forget('profile:status_count:'.$status->profile_id);
  741. $status->uri ? RemoteStatusDelete::dispatch($status) : StatusDelete::dispatch($status);
  742. return [];
  743. }
  744. Cache::forget('_api:statuses:recent_9:'.$status->profile_id);
  745. return StatusService::get($status->id, false);
  746. }
  747. public function getWebSettings(Request $request)
  748. {
  749. abort_if(! $request->user() || ! $request->user()->token(), 403);
  750. abort_unless($request->user()->tokenCan('read'), 403);
  751. $uid = $request->user()->id;
  752. $settings = UserSetting::firstOrCreate([
  753. 'user_id' => $uid,
  754. ]);
  755. if (! $settings->other) {
  756. return [];
  757. }
  758. return $settings->other;
  759. }
  760. public function setWebSettings(Request $request)
  761. {
  762. abort_if(! $request->user() || ! $request->user()->token(), 403);
  763. abort_unless($request->user()->tokenCan('write'), 403);
  764. $this->validate($request, [
  765. 'field' => 'required|in:enable_reblogs,hide_reblog_banner',
  766. 'value' => 'required',
  767. ]);
  768. $field = $request->input('field');
  769. $value = $request->input('value');
  770. $settings = UserSetting::firstOrCreate([
  771. 'user_id' => $request->user()->id,
  772. ]);
  773. if (! $settings->other) {
  774. $other = [];
  775. } else {
  776. $other = $settings->other;
  777. }
  778. $other[$field] = $value;
  779. $settings->other = $other;
  780. $settings->save();
  781. return [200];
  782. }
  783. public function getMutualAccounts(Request $request, $id)
  784. {
  785. abort_if(! $request->user() || ! $request->user()->token(), 403);
  786. abort_unless($request->user()->tokenCan('follows'), 403);
  787. $account = AccountService::get($id, true);
  788. if (! $account || ! isset($account['id'])) {
  789. return [];
  790. }
  791. $res = collect(FollowerService::mutualAccounts($request->user()->profile_id, $id))
  792. ->map(function ($accountId) {
  793. return AccountService::get($accountId, true);
  794. })
  795. ->filter()
  796. ->take(24)
  797. ->values();
  798. return $this->json($res);
  799. }
  800. public function accountUsernameToId(Request $request, $username)
  801. {
  802. abort_if(! $request->user() || ! $request->user()->token() || ! $username, 403);
  803. abort_unless($request->user()->tokenCan('read'), 403);
  804. $rateLimiting = (bool) config_cache('api.rate-limits.v1Dot1.accounts.usernameToId.enabled');
  805. $ipRateLimiting = (bool) config_cache('api.rate-limits.v1Dot1.accounts.usernameToId.ip_enabled');
  806. if ($ipRateLimiting) {
  807. $userLimit = (int) config_cache('api.rate-limits.v1Dot1.accounts.usernameToId.ip_limit');
  808. $userDecay = (int) config_cache('api.rate-limits.v1Dot1.accounts.usernameToId.ip_decay');
  809. $userKey = 'pf:apiv1.1:acctU2ID:byIp:'.$request->ip();
  810. if (RateLimiter::tooManyAttempts($userKey, $userLimit)) {
  811. $limits = [
  812. 'X-Rate-Limit-Limit' => $userLimit,
  813. 'X-Rate-Limit-Remaining' => RateLimiter::remaining($userKey, $userLimit),
  814. 'X-Rate-Limit-Reset' => RateLimiter::availableIn($userKey),
  815. ];
  816. return $this->json(['error' => 'Too many attempts!'], 429, $limits);
  817. }
  818. RateLimiter::increment($userKey, $userDecay);
  819. $limits = [
  820. 'X-Rate-Limit-Limit' => $userLimit,
  821. 'X-Rate-Limit-Remaining' => RateLimiter::remaining($userKey, $userLimit),
  822. 'X-Rate-Limit-Reset' => RateLimiter::availableIn($userKey),
  823. ];
  824. }
  825. if ($rateLimiting) {
  826. $userLimit = (int) config_cache('api.rate-limits.v1Dot1.accounts.usernameToId.limit');
  827. $userDecay = (int) config_cache('api.rate-limits.v1Dot1.accounts.usernameToId.decay');
  828. $userKey = 'pf:apiv1.1:acctU2ID:byUid:'.$request->user()->id;
  829. if (RateLimiter::tooManyAttempts($userKey, $userLimit)) {
  830. $limits = [
  831. 'X-Rate-Limit-Limit' => $userLimit,
  832. 'X-Rate-Limit-Remaining' => RateLimiter::remaining($userKey, $userLimit),
  833. 'X-Rate-Limit-Reset' => RateLimiter::availableIn($userKey),
  834. ];
  835. return $this->json(['error' => 'Too many attempts!'], 429, $limits);
  836. }
  837. RateLimiter::increment($userKey, $userDecay);
  838. $limits = [
  839. 'X-Rate-Limit-Limit' => $userLimit,
  840. 'X-Rate-Limit-Remaining' => RateLimiter::remaining($userKey, $userLimit),
  841. 'X-Rate-Limit-Reset' => RateLimiter::availableIn($userKey),
  842. ];
  843. }
  844. $accountId = AccountService::usernameToId($username, true);
  845. if (! $accountId) {
  846. return [];
  847. }
  848. $account = AccountService::get($accountId);
  849. return $this->json($account, 200, $rateLimiting ? $limits : []);
  850. }
  851. }