forked from mirror/pixelfed
118 lines
3.6 KiB
PHP
118 lines
3.6 KiB
PHP
<?php
|
|
|
|
namespace App\Http\Controllers\Api\V1;
|
|
|
|
use Illuminate\Http\Request;
|
|
use App\Http\Controllers\Controller;
|
|
use App\Models\UserDomainBlock;
|
|
use App\Util\ActivityPub\Helpers;
|
|
use App\Services\UserFilterService;
|
|
use Illuminate\Bus\Batch;
|
|
use Illuminate\Support\Facades\Bus;
|
|
use Illuminate\Support\Facades\Cache;
|
|
use App\Jobs\HomeFeedPipeline\FeedRemoveDomainPipeline;
|
|
use App\Jobs\ProfilePipeline\ProfilePurgeNotificationsByDomain;
|
|
use App\Jobs\ProfilePipeline\ProfilePurgeFollowersByDomain;
|
|
|
|
class DomainBlockController extends Controller
|
|
{
|
|
public function json($res, $code = 200, $headers = [])
|
|
{
|
|
return response()->json($res, $code, $headers, JSON_UNESCAPED_SLASHES);
|
|
}
|
|
|
|
public function index(Request $request)
|
|
{
|
|
abort_unless($request->user(), 403);
|
|
$this->validate($request, [
|
|
'limit' => 'sometimes|integer|min:1|max:200'
|
|
]);
|
|
$limit = $request->input('limit', 100);
|
|
$id = $request->user()->profile_id;
|
|
$filters = UserDomainBlock::whereProfileId($id)->orderByDesc('id')->cursorPaginate($limit);
|
|
$links = null;
|
|
$headers = [];
|
|
|
|
if($filters->nextCursor()) {
|
|
$links .= '<'.$filters->nextPageUrl().'&limit='.$limit.'>; rel="next"';
|
|
}
|
|
|
|
if($filters->previousCursor()) {
|
|
if($links != null) {
|
|
$links .= ', ';
|
|
}
|
|
$links .= '<'.$filters->previousPageUrl().'&limit='.$limit.'>; rel="prev"';
|
|
}
|
|
|
|
if($links) {
|
|
$headers = ['Link' => $links];
|
|
}
|
|
return $this->json($filters->pluck('domain'), 200, $headers);
|
|
}
|
|
|
|
public function store(Request $request)
|
|
{
|
|
abort_unless($request->user(), 403);
|
|
|
|
$this->validate($request, [
|
|
'domain' => 'required|active_url|min:1|max:120'
|
|
]);
|
|
|
|
$pid = $request->user()->profile_id;
|
|
|
|
$domain = trim($request->input('domain'));
|
|
|
|
if(Helpers::validateUrl($domain) == false) {
|
|
return abort(500, 'Invalid domain or already blocked by server admins');
|
|
}
|
|
|
|
$domain = strtolower(parse_url($domain, PHP_URL_HOST));
|
|
|
|
abort_if(config_cache('pixelfed.domain.app') == $domain, 400, 'Cannot ban your own server');
|
|
|
|
$existingCount = UserDomainBlock::whereProfileId($pid)->count();
|
|
$maxLimit = config('instance.user_filters.max_domain_blocks');
|
|
$errorMsg = __('profile.block.domain.max', ['max' => $maxLimit]);
|
|
|
|
abort_if($existingCount >= $maxLimit, 400, $errorMsg);
|
|
|
|
$block = UserDomainBlock::updateOrCreate([
|
|
'profile_id' => $pid,
|
|
'domain' => $domain
|
|
]);
|
|
|
|
if($block->wasRecentlyCreated) {
|
|
Bus::batch([
|
|
[
|
|
new FeedRemoveDomainPipeline($pid, $domain),
|
|
new ProfilePurgeNotificationsByDomain($pid, $domain),
|
|
new ProfilePurgeFollowersByDomain($pid, $domain)
|
|
]
|
|
])->allowFailures()->onQueue('feed')->dispatch();
|
|
|
|
Cache::forget('profile:following:' . $pid);
|
|
UserFilterService::domainBlocks($pid, true);
|
|
}
|
|
|
|
return $this->json([]);
|
|
}
|
|
|
|
public function delete(Request $request)
|
|
{
|
|
abort_unless($request->user(), 403);
|
|
|
|
$this->validate($request, [
|
|
'domain' => 'required|min:1|max:120'
|
|
]);
|
|
|
|
$pid = $request->user()->profile_id;
|
|
|
|
$domain = strtolower(trim($request->input('domain')));
|
|
|
|
$filters = UserDomainBlock::whereProfileId($pid)->whereDomain($domain)->delete();
|
|
|
|
UserFilterService::domainBlocks($pid, true);
|
|
|
|
return $this->json([]);
|
|
}
|
|
}
|