mirror of
https://github.com/HDInnovations/UNIT3D-Community-Edition.git
synced 2026-01-25 13:29:24 -06:00
422 lines
19 KiB
PHP
422 lines
19 KiB
PHP
<?php
|
|
/**
|
|
* NOTICE OF LICENSE.
|
|
*
|
|
* UNIT3D Community Edition is open-sourced software licensed under the GNU Affero General Public License v3.0
|
|
* The details is bundled with this project in the file LICENSE.txt.
|
|
*
|
|
* @project UNIT3D Community Edition
|
|
*
|
|
* @author HDVinnie <hdinnovations@protonmail.com>
|
|
* @license https://www.gnu.org/licenses/agpl-3.0.en.html/ GNU Affero General Public License v3.0
|
|
*/
|
|
|
|
namespace App\Http\Controllers\API;
|
|
|
|
use App\Helpers\Bencode;
|
|
use App\Helpers\MediaInfo;
|
|
use App\Helpers\TorrentHelper;
|
|
use App\Helpers\TorrentTools;
|
|
use App\Http\Resources\TorrentResource;
|
|
use App\Http\Resources\TorrentsResource;
|
|
use App\Models\Category;
|
|
use App\Models\FeaturedTorrent;
|
|
use App\Models\Keyword;
|
|
use App\Models\PlaylistTorrent;
|
|
use App\Models\Torrent;
|
|
use App\Models\TorrentFile;
|
|
use App\Models\User;
|
|
use App\Repositories\ChatRepository;
|
|
use App\Services\Tmdb\TMDBScraper;
|
|
use Carbon\Carbon;
|
|
use Illuminate\Http\Request;
|
|
use Illuminate\Support\Facades\DB;
|
|
use Illuminate\Support\Facades\Storage;
|
|
use Illuminate\Support\Str;
|
|
|
|
/**
|
|
* @see \Tests\Todo\Feature\Http\Controllers\TorrentControllerTest
|
|
*/
|
|
class TorrentController extends BaseController
|
|
{
|
|
public int $perPage = 25;
|
|
|
|
public string $sortField = 'bumped_at';
|
|
|
|
public string $sortDirection = 'desc';
|
|
|
|
/**
|
|
* TorrentController Constructor.
|
|
*/
|
|
public function __construct(private readonly ChatRepository $chatRepository)
|
|
{
|
|
}
|
|
|
|
/**
|
|
* Display a listing of the resource.
|
|
*/
|
|
public function index(): TorrentsResource
|
|
{
|
|
return new TorrentsResource(Torrent::with(['category', 'type', 'resolution'])
|
|
->latest('sticky')
|
|
->latest('bumped_at')
|
|
->paginate(25));
|
|
}
|
|
|
|
/**
|
|
* Store a newly created resource in storage.
|
|
*
|
|
* @throws \Illuminate\Contracts\Container\BindingResolutionException
|
|
*/
|
|
public function store(Request $request): \Illuminate\Http\JsonResponse
|
|
{
|
|
$user = $request->user();
|
|
$requestFile = $request->file('torrent');
|
|
if (! $request->hasFile('torrent')) {
|
|
return $this->sendError('Validation Error.', 'You Must Provide A Torrent File For Upload!');
|
|
}
|
|
|
|
if ($requestFile->getError() !== 0 || $requestFile->getClientOriginalExtension() !== 'torrent') {
|
|
return $this->sendError('Validation Error.', 'You Must Provide A Valid Torrent File For Upload!');
|
|
}
|
|
|
|
// Deplace and decode the torrent temporarily
|
|
$decodedTorrent = TorrentTools::normalizeTorrent($requestFile);
|
|
$infohash = Bencode::get_infohash($decodedTorrent);
|
|
|
|
try {
|
|
$meta = Bencode::get_meta($decodedTorrent);
|
|
} catch (\Exception) {
|
|
return $this->sendError('Validation Error.', 'You Must Provide A Valid Torrent File For Upload!');
|
|
}
|
|
|
|
foreach (TorrentTools::getFilenameArray($decodedTorrent) as $name) {
|
|
if (! TorrentTools::isValidFilename($name)) {
|
|
return $this->sendError('Validation Error.', 'Invalid Filenames In Torrent Files!');
|
|
}
|
|
}
|
|
|
|
$fileName = \sprintf('%s.torrent', \uniqid('', true)); // Generate a unique name
|
|
Storage::disk('torrents')->put($fileName, Bencode::bencode($decodedTorrent));
|
|
|
|
// Find the right category
|
|
$category = Category::withCount('torrents')->findOrFail($request->input('category_id'));
|
|
|
|
// Create the torrent (DB)
|
|
$torrent = \app()->make(Torrent::class);
|
|
$torrent->name = $request->input('name');
|
|
$torrent->slug = Str::slug($torrent->name);
|
|
$torrent->description = $request->input('description');
|
|
$torrent->mediainfo = self::anonymizeMediainfo($request->input('mediainfo'));
|
|
$torrent->bdinfo = $request->input('bdinfo');
|
|
$torrent->info_hash = $infohash;
|
|
$torrent->file_name = $fileName;
|
|
$torrent->num_file = $meta['count'];
|
|
$torrent->announce = $decodedTorrent['announce'];
|
|
$torrent->size = $meta['size'];
|
|
$torrent->nfo = ($request->hasFile('nfo')) ? TorrentTools::getNfo($request->file('nfo')) : '';
|
|
$torrent->category_id = $category->id;
|
|
$torrent->type_id = $request->input('type_id');
|
|
$torrent->resolution_id = $request->input('resolution_id');
|
|
$torrent->region_id = $request->input('region_id');
|
|
$torrent->distributor_id = $request->input('distributor_id');
|
|
$torrent->user_id = $user->id;
|
|
$torrent->imdb = $request->input('imdb');
|
|
$torrent->tvdb = $request->input('tvdb');
|
|
$torrent->tmdb = $request->input('tmdb');
|
|
$torrent->mal = $request->input('mal');
|
|
$torrent->igdb = $request->input('igdb');
|
|
$torrent->season_number = $request->input('season_number');
|
|
$torrent->episode_number = $request->input('episode_number');
|
|
$torrent->anon = $request->input('anonymous');
|
|
$torrent->stream = $request->input('stream');
|
|
$torrent->sd = $request->input('sd');
|
|
$torrent->personal_release = $request->input('personal_release') ?? 0;
|
|
$torrent->internal = $user->group->is_modo || $user->group->is_internal ? $request->input('internal') : 0;
|
|
$torrent->featured = $user->group->is_modo || $user->group->is_internal ? $request->input('featured') : 0;
|
|
$torrent->doubleup = $user->group->is_modo || $user->group->is_internal ? $request->input('doubleup') : 0;
|
|
$du_until = $request->input('du_until');
|
|
if (($user->group->is_modo || $user->group->is_internal) && isset($du_until)) {
|
|
$torrent->du_until = Carbon::now()->addDays($request->input('du_until'));
|
|
}
|
|
$torrent->free = $user->group->is_modo || $user->group->is_internal ? $request->input('free') : 0;
|
|
$fl_until = $request->input('fl_until');
|
|
if (($user->group->is_modo || $user->group->is_internal) && isset($fl_until)) {
|
|
$torrent->fl_until = Carbon::now()->addDays($request->input('fl_until'));
|
|
}
|
|
$torrent->sticky = $user->group->is_modo || $user->group->is_internal ? $request->input('sticky') : 0;
|
|
$torrent->moderated_at = Carbon::now();
|
|
$torrent->moderated_by = User::where('username', 'System')->first()->id; //System ID
|
|
|
|
// Set freeleech and doubleup if featured
|
|
if ($torrent->featured == 1) {
|
|
$torrent->free = '100';
|
|
$torrent->doubleup = '1';
|
|
}
|
|
|
|
$resolutionRule = 'nullable|exists:resolutions,id';
|
|
if ($category->movie_meta || $category->tv_meta) {
|
|
$resolutionRule = 'required|exists:resolutions,id';
|
|
}
|
|
|
|
$episodeRule = 'nullable|numeric';
|
|
if ($category->tv_meta) {
|
|
$episodeRule = 'required|numeric';
|
|
}
|
|
|
|
$seasonRule = 'nullable|numeric';
|
|
if ($category->tv_meta) {
|
|
$seasonRule = 'required|numeric';
|
|
}
|
|
|
|
// Validation
|
|
$v = \validator($torrent->toArray(), [
|
|
'name' => 'required|unique:torrents',
|
|
'slug' => 'required',
|
|
'description' => 'required',
|
|
'info_hash' => 'required|unique:torrents',
|
|
'file_name' => 'required',
|
|
'num_file' => 'required|numeric',
|
|
'announce' => 'required',
|
|
'size' => 'required',
|
|
'category_id' => 'required|exists:categories,id',
|
|
'type_id' => 'required|exists:types,id',
|
|
'resolution_id' => $resolutionRule,
|
|
'region_id' => 'nullable|exists:regions,id',
|
|
'distributor_id' => 'nullable|exists:distributors,id',
|
|
'user_id' => 'required|exists:users,id',
|
|
'imdb' => 'required|numeric',
|
|
'tvdb' => 'required|numeric',
|
|
'tmdb' => 'required|numeric',
|
|
'mal' => 'required|numeric',
|
|
'igdb' => 'required|numeric',
|
|
'season_number' => $seasonRule,
|
|
'episode_number' => $episodeRule,
|
|
'anon' => 'required',
|
|
'stream' => 'required',
|
|
'sd' => 'required',
|
|
'personal_release' => 'nullable',
|
|
'internal' => 'required',
|
|
'featured' => 'required',
|
|
'free' => 'required|between:0,100',
|
|
'doubleup' => 'required',
|
|
'sticky' => 'required',
|
|
]);
|
|
|
|
if ($v->fails()) {
|
|
if (Storage::disk('torrents')->exists($fileName)) {
|
|
Storage::disk('torrents')->delete($fileName);
|
|
}
|
|
|
|
return $this->sendError('Validation Error.', $v->errors());
|
|
}
|
|
|
|
// Save The Torrent
|
|
$torrent->save();
|
|
// Set torrent to featured
|
|
if ($torrent->featured == 1) {
|
|
$featuredTorrent = new FeaturedTorrent();
|
|
$featuredTorrent->user_id = $user->id;
|
|
$featuredTorrent->torrent_id = $torrent->id;
|
|
$featuredTorrent->save();
|
|
}
|
|
|
|
// Count and save the torrent number in this category
|
|
$category->num_torrent = $category->torrents_count;
|
|
$category->save();
|
|
// Backup the files contained in the torrent
|
|
foreach (TorrentTools::getTorrentFiles($decodedTorrent) as $file) {
|
|
$torrentFile = new TorrentFile();
|
|
$torrentFile->name = $file['name'];
|
|
$torrentFile->size = $file['size'];
|
|
$torrentFile->torrent_id = $torrent->id;
|
|
$torrentFile->save();
|
|
unset($torrentFile);
|
|
}
|
|
|
|
$tmdbScraper = new TMDBScraper();
|
|
if ($torrent->category->tv_meta && ($torrent->tmdb || $torrent->tmdb != 0)) {
|
|
$tmdbScraper->tv($torrent->tmdb);
|
|
}
|
|
|
|
if ($torrent->category->movie_meta && ($torrent->tmdb || $torrent->tmdb != 0)) {
|
|
$tmdbScraper->movie($torrent->tmdb);
|
|
}
|
|
|
|
// Torrent Keywords System
|
|
foreach (self::parseKeywords($request->input('keywords')) as $keyword) {
|
|
$tag = new Keyword();
|
|
$tag->name = $keyword;
|
|
$tag->torrent_id = $torrent->id;
|
|
$tag->save();
|
|
}
|
|
|
|
// check for trusted user and update torrent
|
|
if ($user->group->is_trusted) {
|
|
$appurl = \config('app.url');
|
|
$user = $torrent->user;
|
|
$username = $user->username;
|
|
$anon = $torrent->anon;
|
|
$featured = $torrent->featured;
|
|
$free = $torrent->free;
|
|
$doubleup = $torrent->doubleup;
|
|
|
|
// Announce To Shoutbox
|
|
if ($anon == 0) {
|
|
$this->chatRepository->systemMessage(
|
|
\sprintf('User [url=%s/users/', $appurl).$username.']'.$username.\sprintf('[/url] has uploaded a new '.$torrent->category->name.'. [url=%s/torrents/', $appurl).$torrent->id.']'.$torrent->name.'[/url], grab it now! :slight_smile:'
|
|
);
|
|
} else {
|
|
$this->chatRepository->systemMessage(
|
|
\sprintf('An anonymous user has uploaded a new '.$torrent->category->name.'. [url=%s/torrents/', $appurl).$torrent->id.']'.$torrent->name.'[/url], grab it now! :slight_smile:'
|
|
);
|
|
}
|
|
|
|
if ($anon == 1 && $featured == 1) {
|
|
$this->chatRepository->systemMessage(
|
|
\sprintf('Ladies and Gents, [url=%s/torrents/', $appurl).$torrent->id.']'.$torrent->name.'[/url] has been added to the Featured Torrents Slider by an anonymous user! Grab It While You Can! :fire:'
|
|
);
|
|
} elseif ($anon == 0 && $featured == 1) {
|
|
$this->chatRepository->systemMessage(
|
|
\sprintf('Ladies and Gents, [url=%s/torrents/', $appurl).$torrent->id.']'.$torrent->name.\sprintf('[/url] has been added to the Featured Torrents Slider by [url=%s/users/', $appurl).$username.']'.$username.'[/url]! Grab It While You Can! :fire:'
|
|
);
|
|
}
|
|
|
|
if ($free >= 1 && $featured == 0) {
|
|
if ($torrent->fl_until === null) {
|
|
$this->chatRepository->systemMessage(
|
|
\sprintf('Ladies and Gents, [url=%s/torrents/',
|
|
$appurl).$torrent->id.']'.$torrent->name.'[/url] has been granted '.$free.'% FreeLeech! Grab It While You Can! :fire:'
|
|
);
|
|
} else {
|
|
$this->chatRepository->systemMessage(
|
|
\sprintf('Ladies and Gents, [url=%s/torrents/',
|
|
$appurl).$torrent->id.']'.$torrent->name.'[/url] has been granted '.$free.'% FreeLeech for '.$request->input('fl_until').' days. :stopwatch:'
|
|
);
|
|
}
|
|
}
|
|
|
|
if ($doubleup == 1 && $featured == 0) {
|
|
if ($torrent->du_until === null) {
|
|
$this->chatRepository->systemMessage(
|
|
\sprintf('Ladies and Gents, [url=%s/torrents/',
|
|
$appurl).$torrent->id.']'.$torrent->name.'[/url] has been granted Double Upload! Grab It While You Can! :fire:'
|
|
);
|
|
} else {
|
|
$this->chatRepository->systemMessage(
|
|
\sprintf('Ladies and Gents, [url=%s/torrents/',
|
|
$appurl).$torrent->id.']'.$torrent->name.'[/url] has been granted Double Upload for '.$request->input('du_until').' days. :stopwatch:'
|
|
);
|
|
}
|
|
}
|
|
|
|
TorrentHelper::approveHelper($torrent->id);
|
|
}
|
|
|
|
return $this->sendResponse(\route('torrent.download.rsskey', ['id' => $torrent->id, 'rsskey' => \auth('api')->user()->rsskey]), 'Torrent uploaded successfully.');
|
|
}
|
|
|
|
/**
|
|
* Display the specified resource.
|
|
*/
|
|
public function show(int $id): TorrentResource
|
|
{
|
|
$torrent = Torrent::findOrFail($id);
|
|
|
|
TorrentResource::withoutWrapping();
|
|
|
|
return new TorrentResource($torrent);
|
|
}
|
|
|
|
/**
|
|
* Uses Input's To Put Together A Search.
|
|
*/
|
|
public function filter(Request $request): TorrentsResource|\Illuminate\Http\JsonResponse
|
|
{
|
|
$torrents = Torrent::with(['user:id,username,group_id', 'category', 'type', 'resolution'])
|
|
->withCount(['thanks', 'comments'])
|
|
->when($request->has('name') , fn ($query) => $query->ofName($request->name))
|
|
->when($request->has('description') , fn ($query) => $query->ofDescription($request->description))
|
|
->when($request->has('mediainfo') , fn ($query) => $query->ofMediainfo($request->mediainfo))
|
|
->when($request->has('uploader') , fn ($query) => $query->ofUploader($request->uploader))
|
|
->when($request->has('keywords') , fn ($query) => $query->ofKeyword(\array_map('trim', explode(',', $request->keywords))))
|
|
->when($request->has('startYear') , fn ($query) => $query->releasedAfterOrIn($request->startYear))
|
|
->when($request->has('endYear') , fn ($query) => $query->releasedBeforeOrIn($request->endYear))
|
|
->when($request->has('categories') , fn ($query) => $query->ofCategory($request->categories))
|
|
->when($request->has('types') , fn ($query) => $query->ofType($request->types))
|
|
->when($request->has('resolutions') , fn ($query) => $query->ofResolution($request->resolutions))
|
|
->when($request->has('genres') , fn ($query) => $query->ofGenre($request->genres))
|
|
->when($request->has('tmdbId') , fn ($query) => $query->ofTmdb($request->tmdbId))
|
|
->when($request->has('imdbId') , fn ($query) => $query->ofImdb($request->imdbId))
|
|
->when($request->has('tvdbId') , fn ($query) => $query->ofTvdb($request->tvdbId))
|
|
->when($request->has('malId') , fn ($query) => $query->ofMal($request->malId))
|
|
->when($request->has('playlistId') , fn ($query) => $query->ofPlaylist($request->playlistId))
|
|
->when($request->has('collectionId') , fn ($query) => $query->ofCollection($request->collectionId))
|
|
->when($request->has('free') , fn ($query) => $query->ofFreeleech([25, 50, 75, 100]))
|
|
->when($request->has('doubleup') , fn ($query) => $query->doubleup())
|
|
->when($request->has('featured') , fn ($query) => $query->featured())
|
|
->when($request->has('stream') , fn ($query) => $query->streamOptimized())
|
|
->when($request->has('sd') , fn ($query) => $query->sd())
|
|
->when($request->has('highspeed') , fn ($query) => $query->highspeed())
|
|
->when($request->has('internal') , fn ($query) => $query->internal())
|
|
->when($request->has('personalRelease') , fn ($query) => $query->personalRelease())
|
|
->when($request->has('alive') , fn ($query) => $query->alive())
|
|
->when($request->has('dying') , fn ($query) => $query->dying())
|
|
->when($request->has('dead') , fn ($query) => $query->dead())
|
|
->when($request->has('file_name') , fn ($query) => $query->ofFilename($request->file_name))
|
|
->when($request->has('seasonNumber') , fn ($query) => $query->ofSeason($request->seasonNumber))
|
|
->when($request->has('episodeNumber') , fn ($query) => $query->ofEpisode($request->episodeNumber))
|
|
->latest('sticky')
|
|
->orderBy($request->input('sortField') ?? $this->sortField, $request->input('sortDirection') ?? $this->sortDirection)
|
|
->paginate($request->input('perPage') ?? $this->perPage);
|
|
|
|
if ($torrents !== null) {
|
|
return new TorrentsResource($torrents);
|
|
}
|
|
|
|
return $this->sendResponse('404', 'No Torrents Found');
|
|
}
|
|
|
|
/**
|
|
* Anonymize A Torrent Media Info.
|
|
*/
|
|
private static function anonymizeMediainfo(?string $mediainfo): array|string|null
|
|
{
|
|
if ($mediainfo === null) {
|
|
return null;
|
|
}
|
|
|
|
$completeNameI = \strpos($mediainfo, 'Complete name');
|
|
if ($completeNameI !== false) {
|
|
$pathI = \strpos($mediainfo, ': ', $completeNameI);
|
|
if ($pathI !== false) {
|
|
$pathI += 2;
|
|
$endI = \strpos($mediainfo, "\n", $pathI);
|
|
$path = \substr($mediainfo, $pathI, $endI - $pathI);
|
|
$newPath = MediaInfo::stripPath($path);
|
|
|
|
return \substr_replace($mediainfo, $newPath, $pathI, \strlen($path));
|
|
}
|
|
}
|
|
|
|
return $mediainfo;
|
|
}
|
|
|
|
/**
|
|
* Parse Torrent Keywords.
|
|
*/
|
|
private static function parseKeywords(?string $text): array
|
|
{
|
|
$parts = \explode(', ', (string) $text);
|
|
$result = [];
|
|
foreach ($parts as $part) {
|
|
$part = \trim($part);
|
|
if ($part !== '') {
|
|
$result[] = $part;
|
|
}
|
|
}
|
|
|
|
return array_unique($result);
|
|
}
|
|
}
|