pixelfed/app/Http/Controllers/InternalApiController.php

437 lines
15 KiB
PHP
Raw Normal View History

2018-10-21 05:15:12 +00:00
<?php
namespace App\Http\Controllers;
use Illuminate\Http\Request;
use App\{
AccountInterstitial,
2018-11-17 19:57:58 +00:00
DirectMessage,
2019-02-07 19:01:01 +00:00
DiscoverCategory,
2018-11-05 00:17:21 +00:00
Hashtag,
2018-11-20 02:43:31 +00:00
Follower,
2018-10-21 05:15:12 +00:00
Like,
Media,
MediaTag,
2018-11-05 00:17:21 +00:00
Notification,
2018-10-21 05:15:12 +00:00
Profile,
2018-11-05 00:17:21 +00:00
StatusHashtag,
2018-10-21 05:15:12 +00:00
Status,
2018-11-20 02:43:31 +00:00
UserFilter,
2018-10-21 05:15:12 +00:00
};
use Auth,Cache;
2018-11-05 00:17:21 +00:00
use Carbon\Carbon;
2018-10-21 05:15:12 +00:00
use League\Fractal;
use App\Transformer\Api\{
AccountTransformer,
StatusTransformer,
// StatusMediaContainerTransformer,
2018-10-21 05:15:12 +00:00
};
2019-03-08 08:52:54 +00:00
use App\Util\Media\Filter;
2018-10-21 05:15:12 +00:00
use App\Jobs\StatusPipeline\NewStatusPipeline;
use League\Fractal\Serializer\ArraySerializer;
use League\Fractal\Pagination\IlluminatePaginatorAdapter;
2019-02-10 23:52:00 +00:00
use Illuminate\Validation\Rule;
2019-04-05 05:33:53 +00:00
use Illuminate\Support\Str;
use App\Services\MediaTagService;
use App\Services\ModLogService;
use App\Services\PublicTimelineService;
use App\Services\SnowflakeService;
use App\Services\StatusService;
2018-10-21 05:15:12 +00:00
class InternalApiController extends Controller
{
protected $fractal;
public function __construct()
{
$this->middleware('auth');
$this->fractal = new Fractal\Manager();
$this->fractal->setSerializer(new ArraySerializer());
}
2019-03-25 19:27:02 +00:00
// deprecated v2 compose api
2018-10-21 05:15:12 +00:00
public function compose(Request $request)
{
2019-03-26 02:49:27 +00:00
return redirect('/');
2018-10-21 05:15:12 +00:00
}
2018-11-05 00:17:21 +00:00
2018-11-27 09:17:27 +00:00
// deprecated
2018-11-05 00:17:21 +00:00
public function discover(Request $request)
{
2019-07-11 05:10:00 +00:00
return;
2018-11-05 00:17:21 +00:00
}
2018-11-27 09:17:27 +00:00
public function discoverPosts(Request $request)
{
$profile = Auth::user()->profile;
$pid = $profile->id;
2019-02-25 18:56:24 +00:00
$following = Cache::remember('feature:discover:following:'.$pid, now()->addMinutes(15), function() use ($pid) {
2018-11-27 09:17:27 +00:00
return Follower::whereProfileId($pid)->pluck('following_id')->toArray();
});
2019-02-25 18:56:24 +00:00
$filters = Cache::remember("user:filter:list:$pid", now()->addMinutes(15), function() use($pid) {
2019-02-10 23:52:00 +00:00
$private = Profile::whereIsPrivate(true)
->orWhere('unlisted', true)
->orWhere('status', '!=', null)
->pluck('id')
->toArray();
$filters = UserFilter::whereUserId($pid)
->whereFilterableType('App\Profile')
->whereIn('filter_type', ['mute', 'block'])
->pluck('filterable_id')
->toArray();
return array_merge($private, $filters);
2018-11-27 09:17:27 +00:00
});
$following = array_merge($following, $filters);
2020-11-22 02:56:25 +00:00
$sql = config('database.default') !== 'pgsql';
$min_id = SnowflakeService::byDate(now()->subMonths(3));
2019-05-28 05:06:20 +00:00
$posts = Status::select(
'id',
2020-11-22 02:56:25 +00:00
'is_nsfw',
2019-05-28 05:06:20 +00:00
'profile_id',
2020-11-22 02:56:25 +00:00
'type',
'uri',
2019-05-28 05:06:20 +00:00
)
2019-02-12 00:37:29 +00:00
->whereNull('uri')
2019-06-05 03:46:53 +00:00
->whereIn('type', ['photo','photo:album', 'video'])
2018-11-27 09:17:27 +00:00
->whereIsNsfw(false)
->whereVisibility('public')
->whereNotIn('profile_id', $following)
->where('id', '>', $min_id)
2019-06-05 04:00:05 +00:00
->inRandomOrder()
->take(39)
->pluck('id');
2018-11-27 09:17:27 +00:00
$res = [
'posts' => $posts->map(function($post) {
return StatusService::get($post);
2018-11-27 09:17:27 +00:00
})
];
return response()->json($res);
}
2018-11-17 19:57:58 +00:00
public function directMessage(Request $request, $profileId, $threadId)
{
$profile = Auth::user()->profile;
if($profileId != $profile->id) {
abort(403);
}
$msg = DirectMessage::whereToId($profile->id)
->orWhere('from_id',$profile->id)
->findOrFail($threadId);
$thread = DirectMessage::with('status')->whereIn('to_id', [$profile->id, $msg->from_id])
->whereIn('from_id', [$profile->id,$msg->from_id])
->orderBy('created_at', 'asc')
->paginate(30);
return response()->json(compact('msg', 'profile', 'thread'), 200, [], JSON_PRETTY_PRINT);
}
2018-12-09 23:02:32 +00:00
public function statusReplies(Request $request, int $id)
{
2021-03-01 05:41:07 +00:00
$this->validate($request, [
'limit' => 'nullable|int|min:1|max:6'
]);
2019-07-11 05:10:00 +00:00
$parent = Status::whereScope('public')->findOrFail($id);
2021-03-01 05:41:07 +00:00
$limit = $request->input('limit') ?? 3;
2018-12-09 23:02:32 +00:00
$children = Status::whereInReplyToId($parent->id)
->orderBy('created_at', 'desc')
2021-03-01 05:41:07 +00:00
->take($limit)
2018-12-09 23:02:32 +00:00
->get();
$resource = new Fractal\Resource\Collection($children, new StatusTransformer());
$res = $this->fractal->createData($resource)->toArray();
return response()->json($res);
}
2019-01-31 20:27:20 +00:00
public function stories(Request $request)
{
}
2019-02-07 19:01:01 +00:00
public function discoverCategories(Request $request)
{
$categories = DiscoverCategory::whereActive(true)->orderBy('order')->take(10)->get();
$res = $categories->map(function($item) {
return [
'name' => $item->name,
'url' => $item->url(),
'thumb' => $item->thumb()
];
});
return response()->json($res);
}
2019-02-10 23:52:00 +00:00
public function modAction(Request $request)
{
abort_unless(Auth::user()->is_admin, 400);
2019-02-10 23:52:00 +00:00
$this->validate($request, [
'action' => [
'required',
'string',
Rule::in([
'addcw',
'remcw',
'unlist'
2019-02-10 23:52:00 +00:00
])
],
'item_id' => 'required|integer|min:1',
'item_type' => [
'required',
'string',
Rule::in(['profile', 'status'])
2019-02-10 23:52:00 +00:00
]
]);
$action = $request->input('action');
$item_id = $request->input('item_id');
$item_type = $request->input('item_type');
switch($action) {
case 'addcw':
$status = Status::findOrFail($item_id);
$status->is_nsfw = true;
$status->save();
ModLogService::boot()
->user(Auth::user())
->objectUid($status->profile->user_id)
->objectId($status->id)
->objectType('App\Status::class')
->action('admin.status.moderate')
->metadata([
'action' => 'cw',
'message' => 'Success!'
])
->accessLevel('admin')
->save();
if($status->uri == null) {
$media = $status->media;
$ai = new AccountInterstitial;
$ai->user_id = $status->profile->user_id;
$ai->type = 'post.cw';
$ai->view = 'account.moderation.post.cw';
$ai->item_type = 'App\Status';
$ai->item_id = $status->id;
$ai->has_media = (bool) $media->count();
$ai->blurhash = $media->count() ? $media->first()->blurhash : null;
$ai->meta = json_encode([
'caption' => $status->caption,
'created_at' => $status->created_at,
'type' => $status->type,
'url' => $status->url(),
'is_nsfw' => $status->is_nsfw,
'scope' => $status->scope,
'reblog' => $status->reblog_of_id,
'likes_count' => $status->likes_count,
'reblogs_count' => $status->reblogs_count,
]);
$ai->save();
$u = $status->profile->user;
$u->has_interstitial = true;
$u->save();
}
2019-02-10 23:52:00 +00:00
break;
case 'remcw':
$status = Status::findOrFail($item_id);
$status->is_nsfw = false;
$status->save();
ModLogService::boot()
->user(Auth::user())
->objectUid($status->profile->user_id)
->objectId($status->id)
->objectType('App\Status::class')
->action('admin.status.moderate')
->metadata([
'action' => 'remove_cw',
'message' => 'Success!'
])
->accessLevel('admin')
->save();
if($status->uri == null) {
$ai = AccountInterstitial::whereUserId($status->profile->user_id)
->whereType('post.cw')
->whereItemId($status->id)
->whereItemType('App\Status')
->first();
$ai->delete();
}
2019-02-10 23:52:00 +00:00
break;
case 'unlist':
$status = Status::whereScope('public')->findOrFail($item_id);
$status->scope = $status->visibility = 'unlisted';
$status->save();
PublicTimelineService::del($status->id);
ModLogService::boot()
->user(Auth::user())
->objectUid($status->profile->user_id)
->objectId($status->id)
->objectType('App\Status::class')
->action('admin.status.moderate')
->metadata([
'action' => 'unlist',
'message' => 'Success!'
])
->accessLevel('admin')
->save();
if($status->uri == null) {
$media = $status->media;
$ai = new AccountInterstitial;
$ai->user_id = $status->profile->user_id;
$ai->type = 'post.unlist';
$ai->view = 'account.moderation.post.unlist';
$ai->item_type = 'App\Status';
$ai->item_id = $status->id;
$ai->has_media = (bool) $media->count();
$ai->blurhash = $media->count() ? $media->first()->blurhash : null;
$ai->meta = json_encode([
'caption' => $status->caption,
'created_at' => $status->created_at,
'type' => $status->type,
'url' => $status->url(),
'is_nsfw' => $status->is_nsfw,
'scope' => $status->scope,
'reblog' => $status->reblog_of_id,
'likes_count' => $status->likes_count,
'reblogs_count' => $status->reblogs_count,
]);
$ai->save();
$u = $status->profile->user;
$u->has_interstitial = true;
$u->save();
}
2019-02-10 23:52:00 +00:00
break;
}
return ['msg' => 200];
}
2019-03-25 19:27:02 +00:00
public function composePost(Request $request)
{
abort(400, 'Endpoint deprecated');
2019-03-25 19:27:02 +00:00
}
public function bookmarks(Request $request)
{
$statuses = Auth::user()->profile
->bookmarks()
->withCount(['likes','comments'])
->orderBy('created_at', 'desc')
->simplePaginate(10);
$resource = new Fractal\Resource\Collection($statuses, new StatusTransformer());
$res = $this->fractal->createData($resource)->toArray();
return response()->json($res);
}
public function accountStatuses(Request $request, $id)
{
$this->validate($request, [
'only_media' => 'nullable',
'pinned' => 'nullable',
'exclude_replies' => 'nullable',
'max_id' => 'nullable|integer|min:0|max:' . PHP_INT_MAX,
'since_id' => 'nullable|integer|min:0|max:' . PHP_INT_MAX,
'min_id' => 'nullable|integer|min:0|max:' . PHP_INT_MAX,
'limit' => 'nullable|integer|min:1|max:24'
]);
$profile = Profile::whereNull('status')->findOrFail($id);
$limit = $request->limit ?? 9;
$max_id = $request->max_id;
$min_id = $request->min_id;
$scope = $request->only_media == true ?
['photo', 'photo:album', 'video', 'video:album'] :
['photo', 'photo:album', 'video', 'video:album', 'share', 'reply'];
if($profile->is_private) {
if(!Auth::check()) {
return response()->json([]);
}
$pid = Auth::user()->profile->id;
$following = Cache::remember('profile:following:'.$pid, now()->addMinutes(1440), function() use($pid) {
$following = Follower::whereProfileId($pid)->pluck('following_id');
return $following->push($pid)->toArray();
});
$visibility = true == in_array($profile->id, $following) ? ['public', 'unlisted', 'private'] : [];
} else {
if(Auth::check()) {
$pid = Auth::user()->profile->id;
$following = Cache::remember('profile:following:'.$pid, now()->addMinutes(1440), function() use($pid) {
$following = Follower::whereProfileId($pid)->pluck('following_id');
return $following->push($pid)->toArray();
});
$visibility = true == in_array($profile->id, $following) ? ['public', 'unlisted', 'private'] : ['public', 'unlisted'];
} else {
$visibility = ['public', 'unlisted'];
}
}
$dir = $min_id ? '>' : '<';
$id = $min_id ?? $max_id;
$timeline = Status::select(
'id',
'uri',
'caption',
'rendered',
'profile_id',
'type',
'in_reply_to_id',
'reblog_of_id',
'is_nsfw',
'likes_count',
'reblogs_count',
'scope',
'local',
'created_at',
'updated_at'
)->whereProfileId($profile->id)
->whereIn('type', $scope)
->where('id', $dir, $id)
->whereIn('visibility', $visibility)
->latest()
->limit($limit)
->get();
$resource = new Fractal\Resource\Collection($timeline, new StatusTransformer());
$res = $this->fractal->createData($resource)->toArray();
return response()->json($res);
}
2020-04-09 03:34:31 +00:00
public function remoteProfile(Request $request, $id)
{
$profile = Profile::whereNull('status')
->whereNotNull('domain')
2020-04-09 03:34:31 +00:00
->findOrFail($id);
$user = Auth::user();
return view('profile.remote', compact('profile', 'user'));
}
public function remoteStatus(Request $request, $profileId, $statusId)
{
$user = Profile::whereNull('status')
->whereNotNull('domain')
->findOrFail($profileId);
$status = Status::whereProfileId($user->id)
->whereNull('reblog_of_id')
->whereIn('visibility', ['public', 'unlisted'])
->findOrFail($statusId);
2020-04-09 03:34:31 +00:00
$template = $status->in_reply_to_id ? 'status.reply' : 'status.remote';
return view($template, compact('user', 'status'));
}
2018-10-21 05:15:12 +00:00
}