AdminApiController.php 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865
  1. <?php
  2. namespace App\Http\Controllers\Api;
  3. use App\AccountInterstitial;
  4. use App\Http\Controllers\Controller;
  5. use App\Http\Resources\AdminInstance;
  6. use App\Http\Resources\AdminUser;
  7. use App\Instance;
  8. use App\Jobs\DeletePipeline\DeleteAccountPipeline;
  9. use App\Jobs\DeletePipeline\DeleteRemoteProfilePipeline;
  10. use App\Jobs\StatusPipeline\StatusDelete;
  11. use App\Models\Conversation;
  12. use App\Models\RemoteReport;
  13. use App\Notification;
  14. use App\Profile;
  15. use App\Report;
  16. use App\Services\AccountService;
  17. use App\Services\AdminStatsService;
  18. use App\Services\ConfigCacheService;
  19. use App\Services\InstanceService;
  20. use App\Services\ModLogService;
  21. use App\Services\NetworkTimelineService;
  22. use App\Services\NotificationService;
  23. use App\Services\PublicTimelineService;
  24. use App\Services\SnowflakeService;
  25. use App\Services\StatusService;
  26. use App\Status;
  27. use App\User;
  28. use Cache;
  29. use DB;
  30. use Illuminate\Http\Request;
  31. class AdminApiController extends Controller
  32. {
  33. public function supported(Request $request)
  34. {
  35. abort_if(! $request->user() || ! $request->user()->token(), 404);
  36. abort_unless($request->user()->is_admin == 1, 404);
  37. abort_unless($request->user()->tokenCan('admin:read'), 404);
  38. return response()->json(['supported' => true]);
  39. }
  40. public function getStats(Request $request)
  41. {
  42. abort_if(! $request->user() || ! $request->user()->token(), 404);
  43. abort_unless($request->user()->is_admin == 1, 404);
  44. abort_unless($request->user()->tokenCan('admin:read'), 404);
  45. $res = AdminStatsService::summary();
  46. $res['autospam_count'] = AccountInterstitial::whereType('post.autospam')
  47. ->whereNull('appeal_handled_at')
  48. ->count();
  49. return $res;
  50. }
  51. public function autospam(Request $request)
  52. {
  53. abort_if(! $request->user() || ! $request->user()->token(), 404);
  54. abort_unless($request->user()->is_admin == 1, 404);
  55. abort_unless($request->user()->tokenCan('admin:read'), 404);
  56. $appeals = AccountInterstitial::whereType('post.autospam')
  57. ->whereNull('appeal_handled_at')
  58. ->latest()
  59. ->simplePaginate(6)
  60. ->map(function ($report) {
  61. $r = [
  62. 'id' => $report->id,
  63. 'type' => $report->type,
  64. 'item_id' => $report->item_id,
  65. 'item_type' => $report->item_type,
  66. 'created_at' => $report->created_at,
  67. ];
  68. if ($report->item_type === 'App\\Status') {
  69. $status = StatusService::get($report->item_id, false);
  70. if (! $status) {
  71. return;
  72. }
  73. $r['status'] = $status;
  74. if ($status['in_reply_to_id']) {
  75. $r['parent'] = StatusService::get($status['in_reply_to_id'], false);
  76. }
  77. }
  78. return $r;
  79. });
  80. return $appeals;
  81. }
  82. public function autospamHandle(Request $request)
  83. {
  84. abort_if(! $request->user() || ! $request->user()->token(), 404);
  85. abort_unless($request->user()->is_admin == 1, 404);
  86. abort_unless($request->user()->tokenCan('admin:write'), 404);
  87. $this->validate($request, [
  88. 'action' => 'required|in:dismiss,approve,dismiss-all,approve-all,delete-post,delete-account',
  89. 'id' => 'required',
  90. ]);
  91. $action = $request->input('action');
  92. $id = $request->input('id');
  93. $appeal = AccountInterstitial::whereType('post.autospam')
  94. ->whereNull('appeal_handled_at')
  95. ->findOrFail($id);
  96. $now = now();
  97. $res = ['status' => 'success'];
  98. $meta = json_decode($appeal->meta);
  99. $user = $appeal->user;
  100. $profile = $user->profile;
  101. if ($action == 'dismiss') {
  102. $appeal->is_spam = true;
  103. $appeal->appeal_handled_at = $now;
  104. $appeal->save();
  105. Cache::forget('pf:bouncer_v0:exemption_by_pid:'.$profile->id);
  106. Cache::forget('pf:bouncer_v0:recent_by_pid:'.$profile->id);
  107. Cache::forget('admin-dash:reports:spam-count');
  108. return $res;
  109. }
  110. if ($action == 'delete-post') {
  111. $appeal->appeal_handled_at = now();
  112. $appeal->is_spam = true;
  113. $appeal->save();
  114. ModLogService::boot()
  115. ->objectUid($profile->id)
  116. ->objectId($appeal->status->id)
  117. ->objectType('App\Status::class')
  118. ->user($request->user())
  119. ->action('admin.status.delete')
  120. ->accessLevel('admin')
  121. ->save();
  122. PublicTimelineService::deleteByProfileId($profile->id);
  123. StatusDelete::dispatch($appeal->status)->onQueue('high');
  124. Cache::forget('admin-dash:reports:spam-count');
  125. return $res;
  126. }
  127. if ($action == 'delete-account') {
  128. abort_if($user->is_admin, 400, 'Cannot delete an admin account.');
  129. $appeal->appeal_handled_at = now();
  130. $appeal->is_spam = true;
  131. $appeal->save();
  132. ModLogService::boot()
  133. ->objectUid($profile->id)
  134. ->objectId($profile->id)
  135. ->objectType('App\User::class')
  136. ->user($request->user())
  137. ->action('admin.user.delete')
  138. ->accessLevel('admin')
  139. ->save();
  140. PublicTimelineService::deleteByProfileId($profile->id);
  141. DeleteAccountPipeline::dispatch($appeal->user)->onQueue('high');
  142. Cache::forget('admin-dash:reports:spam-count');
  143. return $res;
  144. }
  145. if ($action == 'dismiss-all') {
  146. AccountInterstitial::whereType('post.autospam')
  147. ->whereItemType('App\Status')
  148. ->whereNull('appeal_handled_at')
  149. ->whereUserId($appeal->user_id)
  150. ->update(['appeal_handled_at' => $now, 'is_spam' => true]);
  151. Cache::forget('pf:bouncer_v0:exemption_by_pid:'.$appeal->user->profile_id);
  152. Cache::forget('pf:bouncer_v0:recent_by_pid:'.$appeal->user->profile_id);
  153. Cache::forget('admin-dash:reports:spam-count');
  154. return $res;
  155. }
  156. if ($action == 'approve') {
  157. $status = $appeal->status;
  158. $status->is_nsfw = $meta->is_nsfw;
  159. $status->scope = 'public';
  160. $status->visibility = 'public';
  161. $status->save();
  162. $appeal->is_spam = false;
  163. $appeal->appeal_handled_at = now();
  164. $appeal->save();
  165. StatusService::del($status->id);
  166. Notification::whereAction('autospam.warning')
  167. ->whereProfileId($appeal->user->profile_id)
  168. ->get()
  169. ->each(function ($n) use ($appeal) {
  170. NotificationService::del($appeal->user->profile_id, $n->id);
  171. $n->forceDelete();
  172. });
  173. Cache::forget('pf:bouncer_v0:exemption_by_pid:'.$appeal->user->profile_id);
  174. Cache::forget('pf:bouncer_v0:recent_by_pid:'.$appeal->user->profile_id);
  175. Cache::forget('admin-dash:reports:spam-count');
  176. return $res;
  177. }
  178. if ($action == 'approve-all') {
  179. AccountInterstitial::whereType('post.autospam')
  180. ->whereItemType('App\Status')
  181. ->whereNull('appeal_handled_at')
  182. ->whereUserId($appeal->user_id)
  183. ->get()
  184. ->each(function ($report) use ($meta) {
  185. $report->is_spam = false;
  186. $report->appeal_handled_at = now();
  187. $report->save();
  188. $status = Status::find($report->item_id);
  189. if ($status) {
  190. $status->is_nsfw = $meta->is_nsfw;
  191. $status->scope = 'public';
  192. $status->visibility = 'public';
  193. $status->save();
  194. StatusService::del($status->id, true);
  195. }
  196. Notification::whereAction('autospam.warning')
  197. ->whereProfileId($report->user->profile_id)
  198. ->get()
  199. ->each(function ($n) use ($report) {
  200. NotificationService::del($report->user->profile_id, $n->id);
  201. $n->forceDelete();
  202. });
  203. });
  204. Cache::forget('pf:bouncer_v0:exemption_by_pid:'.$appeal->user->profile_id);
  205. Cache::forget('pf:bouncer_v0:recent_by_pid:'.$appeal->user->profile_id);
  206. Cache::forget('admin-dash:reports:spam-count');
  207. return $res;
  208. }
  209. return $res;
  210. }
  211. public function modReports(Request $request)
  212. {
  213. abort_if(! $request->user() || ! $request->user()->token(), 404);
  214. abort_unless($request->user()->is_admin == 1, 404);
  215. abort_unless($request->user()->tokenCan('admin:read'), 404);
  216. $reports = Report::whereNull('admin_seen')
  217. ->orderBy('created_at', 'desc')
  218. ->paginate(6)
  219. ->map(function ($report) {
  220. $r = [
  221. 'id' => $report->id,
  222. 'type' => $report->type,
  223. 'message' => $report->message,
  224. 'object_id' => $report->object_id,
  225. 'object_type' => $report->object_type,
  226. 'created_at' => $report->created_at,
  227. ];
  228. if ($report->profile_id) {
  229. $r['reported_by_account'] = AccountService::get($report->profile_id, true);
  230. }
  231. if ($report->object_type === 'App\\Status') {
  232. $status = StatusService::get($report->object_id, false);
  233. if (! $status) {
  234. return;
  235. }
  236. $r['status'] = $status;
  237. if (isset($status['in_reply_to_id'])) {
  238. $r['parent'] = StatusService::get($status['in_reply_to_id'], false);
  239. }
  240. }
  241. if ($report->object_type === 'App\\Profile') {
  242. $acct = AccountService::get($report->object_id, true);
  243. if ($acct) {
  244. $r['account'] = $acct;
  245. }
  246. }
  247. return $r;
  248. })
  249. ->filter()
  250. ->values();
  251. return $reports;
  252. }
  253. public function modReportHandle(Request $request)
  254. {
  255. abort_if(! $request->user() || ! $request->user()->token(), 404);
  256. abort_unless($request->user()->is_admin == 1, 404);
  257. abort_unless($request->user()->tokenCan('admin:write'), 404);
  258. $this->validate($request, [
  259. 'action' => 'required|string',
  260. 'id' => 'required',
  261. ]);
  262. $action = $request->input('action');
  263. $id = $request->input('id');
  264. $actions = [
  265. 'ignore',
  266. 'cw',
  267. 'unlist',
  268. ];
  269. if (! in_array($action, $actions)) {
  270. return abort(403);
  271. }
  272. $report = Report::findOrFail($id);
  273. $item = $report->reported();
  274. $report->admin_seen = now();
  275. switch ($action) {
  276. case 'ignore':
  277. $report->not_interested = true;
  278. break;
  279. case 'cw':
  280. Cache::forget('status:thumb:'.$item->id);
  281. $item->is_nsfw = true;
  282. $item->save();
  283. $report->nsfw = true;
  284. StatusService::del($item->id, true);
  285. break;
  286. case 'unlist':
  287. $item->visibility = 'unlisted';
  288. $item->save();
  289. StatusService::del($item->id, true);
  290. break;
  291. default:
  292. $report->admin_seen = null;
  293. break;
  294. }
  295. $report->save();
  296. Cache::forget('admin-dash:reports:list-cache');
  297. Cache::forget('admin:dashboard:home:data:v0:15min');
  298. return ['success' => true];
  299. }
  300. public function getConfiguration(Request $request)
  301. {
  302. abort_if(! $request->user() || ! $request->user()->token(), 404);
  303. abort_unless($request->user()->is_admin == 1, 404);
  304. abort_unless($request->user()->tokenCan('admin:read'), 404);
  305. abort_unless(config('instance.enable_cc'), 400);
  306. return collect([
  307. [
  308. 'name' => 'ActivityPub Federation',
  309. 'description' => 'Enable activitypub federation support, compatible with Pixelfed, Mastodon and other platforms.',
  310. 'key' => 'federation.activitypub.enabled',
  311. ],
  312. [
  313. 'name' => 'Open Registration',
  314. 'description' => 'Allow new account registrations.',
  315. 'key' => 'pixelfed.open_registration',
  316. ],
  317. [
  318. 'name' => 'Stories',
  319. 'description' => 'Enable the ephemeral Stories feature.',
  320. 'key' => 'instance.stories.enabled',
  321. ],
  322. [
  323. 'name' => 'Require Email Verification',
  324. 'description' => 'Require new accounts to verify their email address.',
  325. 'key' => 'pixelfed.enforce_email_verification',
  326. ],
  327. [
  328. 'name' => 'AutoSpam Detection',
  329. 'description' => 'Detect and remove spam from public timelines.',
  330. 'key' => 'pixelfed.bouncer.enabled',
  331. ],
  332. ])
  333. ->map(function ($s) {
  334. $s['state'] = (bool) config_cache($s['key']);
  335. return $s;
  336. });
  337. }
  338. public function updateConfiguration(Request $request)
  339. {
  340. abort_if(! $request->user() || ! $request->user()->token(), 404);
  341. abort_unless($request->user()->is_admin == 1, 404);
  342. abort_unless($request->user()->tokenCan('admin:write'), 404);
  343. abort_unless(config('instance.enable_cc'), 400);
  344. $this->validate($request, [
  345. 'key' => 'required',
  346. 'value' => 'required',
  347. ]);
  348. $allowedKeys = [
  349. 'federation.activitypub.enabled',
  350. 'pixelfed.open_registration',
  351. 'instance.stories.enabled',
  352. 'pixelfed.enforce_email_verification',
  353. 'pixelfed.bouncer.enabled',
  354. ];
  355. $key = $request->input('key');
  356. $value = (bool) filter_var($request->input('value'), FILTER_VALIDATE_BOOLEAN);
  357. abort_if(! in_array($key, $allowedKeys), 400, 'Invalid cache key.');
  358. ConfigCacheService::put($key, $value);
  359. return collect([
  360. [
  361. 'name' => 'ActivityPub Federation',
  362. 'description' => 'Enable activitypub federation support, compatible with Pixelfed, Mastodon and other platforms.',
  363. 'key' => 'federation.activitypub.enabled',
  364. ],
  365. [
  366. 'name' => 'Open Registration',
  367. 'description' => 'Allow new account registrations.',
  368. 'key' => 'pixelfed.open_registration',
  369. ],
  370. [
  371. 'name' => 'Stories',
  372. 'description' => 'Enable the ephemeral Stories feature.',
  373. 'key' => 'instance.stories.enabled',
  374. ],
  375. [
  376. 'name' => 'Require Email Verification',
  377. 'description' => 'Require new accounts to verify their email address.',
  378. 'key' => 'pixelfed.enforce_email_verification',
  379. ],
  380. [
  381. 'name' => 'AutoSpam Detection',
  382. 'description' => 'Detect and remove spam from public timelines.',
  383. 'key' => 'pixelfed.bouncer.enabled',
  384. ],
  385. ])
  386. ->map(function ($s) {
  387. $s['state'] = (bool) config_cache($s['key']);
  388. return $s;
  389. });
  390. }
  391. public function getUsers(Request $request)
  392. {
  393. abort_if(! $request->user() || ! $request->user()->token(), 404);
  394. abort_unless($request->user()->is_admin == 1, 404);
  395. abort_unless($request->user()->tokenCan('admin:read'), 404);
  396. $this->validate($request, [
  397. 'sort' => 'sometimes|in:asc,desc',
  398. ]);
  399. $q = $request->input('q');
  400. $sort = $request->input('sort', 'desc') === 'asc' ? 'asc' : 'desc';
  401. $res = User::whereNull('status')
  402. ->when($q, function ($query, $q) {
  403. return $query->where('username', 'like', '%'.$q.'%');
  404. })
  405. ->orderBy('id', $sort)
  406. ->cursorPaginate(10);
  407. return AdminUser::collection($res);
  408. }
  409. public function getUser(Request $request)
  410. {
  411. abort_if(! $request->user() || ! $request->user()->token(), 404);
  412. abort_unless($request->user()->is_admin == 1, 404);
  413. abort_unless($request->user()->tokenCan('admin:read'), 404);
  414. $id = $request->input('user_id');
  415. $key = 'pf-admin-api:getUser:byId:'.$id;
  416. if ($request->has('refresh')) {
  417. Cache::forget($key);
  418. }
  419. return Cache::remember($key, 86400, function () use ($id) {
  420. $user = User::findOrFail($id);
  421. $profile = $user->profile;
  422. $account = AccountService::get($user->profile_id, true);
  423. $res = (new AdminUser($user))->additional(['meta' => [
  424. 'cached_at' => str_replace('+00:00', 'Z', now()->format(DATE_RFC3339_EXTENDED)),
  425. 'account' => $account,
  426. 'dms_sent' => Conversation::whereFromId($profile->id)->count(),
  427. 'report_count' => Report::where('object_id', $profile->id)->orWhere('reported_profile_id', $profile->id)->count(),
  428. 'remote_report_count' => RemoteReport::whereAccountId($profile->id)->count(),
  429. 'moderation' => [
  430. 'unlisted' => (bool) $profile->unlisted,
  431. 'cw' => (bool) $profile->cw,
  432. 'no_autolink' => (bool) $profile->no_autolink,
  433. ],
  434. ]]);
  435. return $res;
  436. });
  437. }
  438. public function userAdminAction(Request $request)
  439. {
  440. abort_if(! $request->user() || ! $request->user()->token(), 404);
  441. abort_unless($request->user()->is_admin == 1, 404);
  442. abort_unless($request->user()->tokenCan('admin:write'), 404);
  443. $this->validate($request, [
  444. 'id' => 'required',
  445. 'action' => 'required|in:unlisted,cw,no_autolink,refresh_stats,verify_email,delete',
  446. 'value' => 'sometimes',
  447. ]);
  448. $id = $request->input('id');
  449. $user = User::findOrFail($id);
  450. $profile = Profile::findOrFail($user->profile_id);
  451. $action = $request->input('action');
  452. abort_if($user->is_admin == true && $action !== 'refresh_stats', 400, 'Cannot moderate admin accounts');
  453. if ($action === 'delete') {
  454. if (config('pixelfed.account_deletion') == false) {
  455. abort(404);
  456. }
  457. abort_if($user->is_admin, 400, 'Cannot delete an admin account.');
  458. $ts = now()->addMonth();
  459. $user->status = 'delete';
  460. $user->delete_after = $ts;
  461. $user->save();
  462. $profile->status = 'delete';
  463. $profile->delete_after = $ts;
  464. $profile->save();
  465. ModLogService::boot()
  466. ->objectUid($profile->id)
  467. ->objectId($profile->id)
  468. ->objectType('App\Profile::class')
  469. ->user($request->user())
  470. ->action('admin.user.delete')
  471. ->accessLevel('admin')
  472. ->save();
  473. PublicTimelineService::deleteByProfileId($profile->id);
  474. NetworkTimelineService::deleteByProfileId($profile->id);
  475. if ($profile->user_id) {
  476. DB::table('oauth_access_tokens')->whereUserId($user->id)->delete();
  477. DB::table('oauth_auth_codes')->whereUserId($user->id)->delete();
  478. $user->email = $user->id;
  479. $user->password = '';
  480. $user->status = 'delete';
  481. $user->save();
  482. $profile->status = 'delete';
  483. $profile->delete_after = now()->addMonth();
  484. $profile->save();
  485. AccountService::del($profile->id);
  486. DeleteAccountPipeline::dispatch($user)->onQueue('high');
  487. } else {
  488. $profile->status = 'delete';
  489. $profile->delete_after = now()->addMonth();
  490. $profile->save();
  491. AccountService::del($profile->id);
  492. DeleteRemoteProfilePipeline::dispatch($profile)->onQueue('high');
  493. }
  494. return [
  495. 'status' => 200,
  496. 'msg' => 'deleted',
  497. ];
  498. } elseif ($action === 'refresh_stats') {
  499. $profile->following_count = DB::table('followers')->whereProfileId($user->profile_id)->count();
  500. $profile->followers_count = DB::table('followers')->whereFollowingId($user->profile_id)->count();
  501. $statusCount = Status::whereProfileId($user->profile_id)
  502. ->whereNull('in_reply_to_id')
  503. ->whereNull('reblog_of_id')
  504. ->whereIn('scope', ['public', 'unlisted', 'private'])
  505. ->count();
  506. $profile->status_count = $statusCount;
  507. $profile->save();
  508. } elseif ($action === 'verify_email') {
  509. $user->email_verified_at = now();
  510. $user->save();
  511. ModLogService::boot()
  512. ->objectUid($user->id)
  513. ->objectId($user->id)
  514. ->objectType('App\User::class')
  515. ->user($request->user())
  516. ->action('admin.user.moderate')
  517. ->metadata([
  518. 'action' => 'Manually verified email address',
  519. 'message' => 'Success!',
  520. ])
  521. ->accessLevel('admin')
  522. ->save();
  523. } elseif ($action === 'unlisted') {
  524. ModLogService::boot()
  525. ->objectUid($profile->id)
  526. ->objectId($profile->id)
  527. ->objectType('App\Profile::class')
  528. ->user($request->user())
  529. ->action('admin.user.moderate')
  530. ->metadata([
  531. 'action' => $action,
  532. 'message' => 'Success!',
  533. ])
  534. ->accessLevel('admin')
  535. ->save();
  536. $profile->unlisted = ! $profile->unlisted;
  537. $profile->save();
  538. } elseif ($action === 'cw') {
  539. ModLogService::boot()
  540. ->objectUid($profile->id)
  541. ->objectId($profile->id)
  542. ->objectType('App\Profile::class')
  543. ->user($request->user())
  544. ->action('admin.user.moderate')
  545. ->metadata([
  546. 'action' => $action,
  547. 'message' => 'Success!',
  548. ])
  549. ->accessLevel('admin')
  550. ->save();
  551. $profile->cw = ! $profile->cw;
  552. $profile->save();
  553. } elseif ($action === 'no_autolink') {
  554. ModLogService::boot()
  555. ->objectUid($profile->id)
  556. ->objectId($profile->id)
  557. ->objectType('App\Profile::class')
  558. ->user($request->user())
  559. ->action('admin.user.moderate')
  560. ->metadata([
  561. 'action' => $action,
  562. 'message' => 'Success!',
  563. ])
  564. ->accessLevel('admin')
  565. ->save();
  566. $profile->no_autolink = ! $profile->no_autolink;
  567. $profile->save();
  568. } else {
  569. $profile->{$action} = filter_var($request->input('value'), FILTER_VALIDATE_BOOLEAN);
  570. $profile->save();
  571. ModLogService::boot()
  572. ->objectUid($user->id)
  573. ->objectId($user->id)
  574. ->objectType('App\User::class')
  575. ->user($request->user())
  576. ->action('admin.user.moderate')
  577. ->metadata([
  578. 'action' => $action,
  579. 'message' => 'Success!',
  580. ])
  581. ->accessLevel('admin')
  582. ->save();
  583. }
  584. AccountService::del($user->profile_id);
  585. $account = AccountService::get($user->profile_id, true);
  586. return (new AdminUser($user))->additional(['meta' => [
  587. 'account' => $account,
  588. 'moderation' => [
  589. 'unlisted' => (bool) $profile->unlisted,
  590. 'cw' => (bool) $profile->cw,
  591. 'no_autolink' => (bool) $profile->no_autolink,
  592. ],
  593. ]]);
  594. }
  595. public function instances(Request $request)
  596. {
  597. abort_if(! $request->user() || ! $request->user()->token(), 404);
  598. abort_unless($request->user()->is_admin == 1, 404);
  599. abort_unless($request->user()->tokenCan('admin:write'), 404);
  600. $this->validate($request, [
  601. 'q' => 'sometimes',
  602. 'sort' => 'sometimes|in:asc,desc',
  603. 'sort_by' => 'sometimes|in:id,status_count,user_count,domain',
  604. 'filter' => 'sometimes|in:all,unlisted,auto_cw,banned',
  605. ]);
  606. $q = $request->input('q');
  607. $sort = $request->input('sort', 'desc') === 'asc' ? 'asc' : 'desc';
  608. $sortBy = $request->input('sort_by', 'id');
  609. $filter = $request->input('filter');
  610. $res = Instance::when($q, function ($query, $q) {
  611. return $query->where('domain', 'like', '%'.$q.'%');
  612. })
  613. ->when($filter, function ($query, $filter) {
  614. if ($filter === 'all') {
  615. return $query;
  616. } else {
  617. return $query->where($filter, true);
  618. }
  619. })
  620. ->when($sortBy, function ($query, $sortBy) use ($sort) {
  621. return $query->orderBy($sortBy, $sort);
  622. }, function ($query) {
  623. return $query->orderBy('id', 'desc');
  624. })
  625. ->cursorPaginate(10)
  626. ->withQueryString();
  627. return AdminInstance::collection($res);
  628. }
  629. public function getInstance(Request $request)
  630. {
  631. abort_if(! $request->user() || ! $request->user()->token(), 404);
  632. abort_unless($request->user()->is_admin == 1, 404);
  633. abort_unless($request->user()->tokenCan('admin:read'), 404);
  634. $id = $request->input('id');
  635. $res = Instance::findOrFail($id);
  636. return new AdminInstance($res);
  637. }
  638. public function moderateInstance(Request $request)
  639. {
  640. abort_if(! $request->user() || ! $request->user()->token(), 404);
  641. abort_unless($request->user()->is_admin == 1, 404);
  642. abort_unless($request->user()->tokenCan('admin:write'), 404);
  643. $this->validate($request, [
  644. 'id' => 'required',
  645. 'key' => 'required|in:unlisted,auto_cw,banned',
  646. 'value' => 'required',
  647. ]);
  648. $id = $request->input('id');
  649. $key = $request->input('key');
  650. $value = (bool) filter_var($request->input('value'), FILTER_VALIDATE_BOOLEAN);
  651. $res = Instance::findOrFail($id);
  652. $res->{$key} = $value;
  653. $res->save();
  654. InstanceService::refresh();
  655. NetworkTimelineService::warmCache(true);
  656. return new AdminInstance($res);
  657. }
  658. public function refreshInstanceStats(Request $request)
  659. {
  660. abort_if(! $request->user() || ! $request->user()->token(), 404);
  661. abort_unless($request->user()->is_admin == 1, 404);
  662. abort_unless($request->user()->tokenCan('admin:write'), 404);
  663. $this->validate($request, [
  664. 'id' => 'required',
  665. ]);
  666. $id = $request->input('id');
  667. $instance = Instance::findOrFail($id);
  668. $instance->user_count = Profile::whereDomain($instance->domain)->count();
  669. $instance->status_count = Profile::whereDomain($instance->domain)->leftJoin('statuses', 'profiles.id', '=', 'statuses.profile_id')->count();
  670. $instance->save();
  671. return new AdminInstance($instance);
  672. }
  673. public function getAllStats(Request $request)
  674. {
  675. abort_if(! $request->user() || ! $request->user()->token(), 404);
  676. abort_unless($request->user()->is_admin === 1, 404);
  677. abort_unless($request->user()->tokenCan('admin:read'), 404);
  678. if ($request->has('refresh')) {
  679. Cache::forget('admin-api:instance-all-stats-v1');
  680. }
  681. return Cache::remember('admin-api:instance-all-stats-v1', 1209600, function () {
  682. $days = range(1, 7);
  683. $res = [
  684. 'cached_at' => now()->format('c'),
  685. ];
  686. $minStatusId = SnowflakeService::byDate(now()->subDays(7));
  687. foreach ($days as $day) {
  688. $label = now()->subDays($day)->format('D');
  689. $labelShort = substr($label, 0, 1);
  690. $res['users']['days'][] = [
  691. 'date' => now()->subDays($day)->format('M j Y'),
  692. 'label_full' => $label,
  693. 'label' => $labelShort,
  694. 'count' => User::whereDate('created_at', now()->subDays($day))->count(),
  695. ];
  696. $res['posts']['days'][] = [
  697. 'date' => now()->subDays($day)->format('M j Y'),
  698. 'label_full' => $label,
  699. 'label' => $labelShort,
  700. 'count' => Status::whereNull('uri')->where('id', '>', $minStatusId)->whereDate('created_at', now()->subDays($day))->count(),
  701. ];
  702. $res['instances']['days'][] = [
  703. 'date' => now()->subDays($day)->format('M j Y'),
  704. 'label_full' => $label,
  705. 'label' => $labelShort,
  706. 'count' => Instance::whereDate('created_at', now()->subDays($day))->count(),
  707. ];
  708. }
  709. $res['users']['total'] = DB::table('users')->count();
  710. $res['users']['min'] = collect($res['users']['days'])->min('count');
  711. $res['users']['max'] = collect($res['users']['days'])->max('count');
  712. $res['users']['change'] = collect($res['users']['days'])->sum('count');
  713. $res['posts']['total'] = DB::table('statuses')->whereNull('uri')->count();
  714. $res['posts']['min'] = collect($res['posts']['days'])->min('count');
  715. $res['posts']['max'] = collect($res['posts']['days'])->max('count');
  716. $res['posts']['change'] = collect($res['posts']['days'])->sum('count');
  717. $res['instances']['total'] = DB::table('instances')->count();
  718. $res['instances']['min'] = collect($res['instances']['days'])->min('count');
  719. $res['instances']['max'] = collect($res['instances']['days'])->max('count');
  720. $res['instances']['change'] = collect($res['instances']['days'])->sum('count');
  721. return $res;
  722. });
  723. }
  724. }