Oppaitime's version of Gazelle
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

upload_handle.php 33KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898
  1. <?
  2. //****************************************************************************//
  3. //--------------- Take upload ------------------------------------------------//
  4. // This pages handles the backend of the torrent upload function. It checks //
  5. // the data, and if it all validates, it builds the torrent file, then writes //
  6. // the data to the database and the torrent to the disk. //
  7. //****************************************************************************//
  8. // Maximum allowed size for uploaded files.
  9. // http://php.net/upload-max-filesize
  10. ini_set('upload_max_filesize', 2097152); // 2 Mibibytes
  11. ini_set('max_file_uploads', 100);
  12. define('MAX_FILENAME_LENGTH', 180);
  13. include(SERVER_ROOT.'/classes/validate.class.php');
  14. include(SERVER_ROOT.'/classes/feed.class.php');
  15. include(SERVER_ROOT.'/sections/torrents/functions.php');
  16. include(SERVER_ROOT.'/classes/file_checker.class.php');
  17. enforce_login();
  18. authorize();
  19. $Validate = new VALIDATE;
  20. $Feed = new FEED;
  21. define('QUERY_EXCEPTION', true); // Shut up debugging
  22. //*****************************************************************************//
  23. //--------------- Set $Properties array ---------------------------------------//
  24. // This is used if the form doesn't validate, and when the time comes to enter //
  25. // it into the database. //
  26. // Haha wow god i'm trying to restrict the database to only have fields for //
  27. // movies and not add anything for other categories but this is fucking dumb //
  28. $Properties = [];
  29. $Type = $Categories[(int)$_POST['type']];
  30. $TypeID = $_POST['type'] + 1;
  31. $Properties['CategoryID'] = $TypeID;
  32. $Properties['CategoryName'] = $Type;
  33. $Properties['Title'] = $_POST['title'];
  34. $Properties['TitleRJ'] = $_POST['title_rj'];
  35. $Properties['TitleJP'] = $_POST['title_jp'];
  36. $Properties['Year'] = $_POST['year'];
  37. $Properties['Studio'] = isset($_POST['studio']) ? $_POST['studio'] : '';
  38. $Properties['Series'] = isset($_POST['series']) ? $_POST['series'] : '';
  39. $Properties['CatalogueNumber'] = isset($_POST['catalogue']) ? $_POST['catalogue'] : '';
  40. $Properties['Pages'] = isset($_POST['pages']) ? $_POST['pages'] : 0;
  41. $Properties['Container'] = isset($_POST['container']) ? $_POST['container'] : '';
  42. $Properties['Media'] = $_POST['media'];
  43. $Properties['Codec'] = isset($_POST['codec']) ? $_POST['codec'] : '';
  44. if (!($_POST['resolution'] ?? false)) $_POST['resolution'] = $_POST['ressel'] ?? '';
  45. $Properties['Resolution'] = $_POST['resolution'] ?? '';
  46. $Properties['AudioFormat'] = isset($_POST['audioformat']) ? $_POST['audioformat'] : '';
  47. $Properties['Subbing'] = isset($_POST['sub']) ? $_POST['sub'] : '';
  48. $Properties['Language'] = isset($_POST['lang']) ? $_POST['lang'] : '';
  49. $Properties['Subber'] = isset($_POST['subber']) ? $_POST['subber'] : '';
  50. $Properties['DLsiteID'] = (isset($_POST['dlsiteid'])) ? $_POST['dlsiteid'] : '';
  51. $Properties['Censored'] = (isset($_POST['censored'])) ? 1 : 0;
  52. $Properties['Archive'] = (isset($_POST['archive']) && $_POST['archive'] != '---') ? $_POST['archive'] : '';
  53. if (isset($_POST['library_image'])) $Properties['LibraryImage'] = $_POST['library_image'];
  54. if (isset($_POST['tags'])) $Properties['TagList'] = implode(',',array_unique(explode(',', str_replace(' ','',$_POST['tags']))));
  55. if (isset($_POST['image'])) $Properties['Image'] = $_POST['image'];
  56. if (isset($_POST['release'])) {
  57. $Properties['ReleaseGroup'] = $_POST['release'];
  58. }
  59. $Properties['GroupDescription'] = trim($_POST['album_desc']);
  60. $Properties['TorrentDescription'] = $_POST['release_desc'];
  61. $Properties['MediaInfo'] = $_POST['mediainfo'];
  62. $Properties['Screenshots'] = isset($_POST['screenshots']) ? $_POST['screenshots'] : "";
  63. if ($_POST['album_desc']) {
  64. $Properties['GroupDescription'] = trim($_POST['album_desc']);
  65. } elseif ($_POST['desc']) {
  66. $Properties['GroupDescription'] = trim($_POST['desc']);
  67. $Properties['MediaInfo'] = $_POST['mediainfo'];
  68. }
  69. if (isset($_POST['groupid'])) $Properties['GroupID'] = $_POST['groupid'];
  70. if (isset($Properties['GroupID'])) {
  71. $Properties['Artists'] = Artists::get_artist($Properties['GroupID']);
  72. }
  73. if ($Type == 'Movies' || $Type == 'Manga' || $Type == 'Anime' || $Type == 'Games' ) {
  74. if (empty($_POST['idols'])) {
  75. $Err = "You didn't enter any goils";
  76. } else {
  77. $Artists = $_POST['idols'];
  78. }
  79. }
  80. if (!empty($_POST['requestid'])) {
  81. $RequestID = $_POST['requestid'];
  82. $Properties['RequestID'] = $RequestID;
  83. }
  84. //******************************************************************************//
  85. //--------------- Validate data in upload form ---------------------------------//
  86. $Validate->SetFields('type', '1', 'inarray', 'Please select a valid type.', array('inarray' => array_keys($Categories)));
  87. switch ($Type) {
  88. case 'Movies':
  89. case 'Anime':
  90. $Validate->SetFields('codec',
  91. '1','inarray','Please select a valid codec.', array('inarray'=>$Codecs));
  92. $Validate->SetFields('resolution',
  93. '1','regex','Please set a valid resolution.', array('regex'=>'/^(SD)|([0-9]+(p|i))|([0-9]K)|([0-9]+x[0-9]+)$/'));
  94. $Validate->SetFields('audioformat',
  95. '1','inarray','Please select a valid audio format.', array('inarray'=>$AudioFormats));
  96. $Validate->SetFields('sub',
  97. '1','inarray','Please select a valid sub format.', array('inarray'=>$Subbing));
  98. $Validate->SetFields('censored', '1', 'inarray', 'Set valid censoring', array('inarray'=>array(0, 1)));
  99. case 'Games':
  100. $Validate->SetFields('container',
  101. '1','inarray','Please select a valid container.', array('inarray'=>array_merge($Containers, $ContainersGames)));
  102. case 'Manga':
  103. if (!isset($_POST['groupid']) || !$_POST['groupid']) {
  104. $Validate->SetFields('year',
  105. '1','number','The year of the original release must be entered.', array('maxlength'=>3000, 'minlength'=>1800));
  106. if ($Type == 'Manga') {
  107. $Validate->SetFields('pages',
  108. '1', 'number', 'That is not a valid page count', array('minlength'=>1));
  109. }
  110. }
  111. $Validate->SetFields('media',
  112. '1','inarray','Please select a valid media/platform.', array('inarray'=>array_merge($Media, $MediaManga, $Platform)));
  113. $Validate->SetFields('lang',
  114. '1','inarray','Please select a valid language.', array('inarray'=>$Languages));
  115. $Validate->SetFields('release_desc',
  116. '0','string','The release description has a minimum length of 10 characters.', array('maxlength'=>1000000, 'minlength'=>10));
  117. default:
  118. if (!isset($_POST['groupid']) || !$_POST['groupid']) {
  119. $Validate->SetFields('title',
  120. '0','string','Title must be between 1 and 300 characters.', array('maxlength'=>300, 'minlength'=>1));
  121. $Validate->SetFields('title_rj',
  122. '0','string', 'Romaji Title must be between 1 and 300 characters.', array('maxlength'=>300, 'minlength'=>1));
  123. $Validate->SetFields('title_jp',
  124. '0','string','Japanese Title must be between 1 and 512 bytes.', array('maxlength'=>512, 'minlength'=>1));
  125. $Validate->SetFields('tags',
  126. '1','string','You must enter at least five tag. Maximum length is 1500 characters.', array('maxlength'=>1500, 'minlength'=>2));
  127. $Validate->SetFields('image',
  128. '0','link','The image URL you entered was invalid.', array('maxlength'=>255, 'minlength'=>12));
  129. }
  130. $Validate->SetFields('album_desc',
  131. '1','string','The description has a minimum length of 10 characters.', array('maxlength'=>1000000, 'minlength'=>10));
  132. $Validate->SetFields('groupid', '0', 'number', 'Group ID was not numeric');
  133. }
  134. $Validate->SetFields('rules',
  135. '1','require','Your torrent must abide by the rules.');
  136. $Err = $Validate->ValidateForm($_POST); // Validate the form
  137. if (count(explode(',', $Properties['TagList'])) < 5) {
  138. $Err = 'You must enter at least 5 tags.';
  139. }
  140. if (!(isset($_POST['title']) || isset($_POST['title_rj']) || isset($_POST['title_jp']))) {
  141. $Err = 'You must enter at least one title.';
  142. }
  143. $File = $_FILES['file_input']; // This is our torrent file
  144. $TorrentName = $File['tmp_name'];
  145. if (!is_uploaded_file($TorrentName) || !filesize($TorrentName)) {
  146. $Err = 'No torrent file uploaded, or file is empty.';
  147. } elseif (substr(strtolower($File['name']), strlen($File['name']) - strlen('.torrent')) !== '.torrent') {
  148. $Err = "You seem to have put something other than a torrent file into the upload field. (".$File['name'].").";
  149. }
  150. //Multiple artists!
  151. $LogName = '';
  152. if (empty($Properties['GroupID']) && empty($ArtistForm) && ($Type == 'Movies' || $Type == 'Anime' || $Type == 'Manga' || $Type == 'Games')) {
  153. $ArtistNames = [];
  154. $ArtistForm = [];
  155. for ($i = 0; $i < count($Artists); $i++) {
  156. if (trim($Artists[$i]) != '') {
  157. if (!in_array($Artists[$i], $ArtistNames)) {
  158. $ArtistForm[$i] = array('name' => Artists::normalise_artist_name($Artists[$i]));
  159. array_push($ArtistNames, $ArtistForm[$i]['name']);
  160. }
  161. }
  162. }
  163. $LogName .= Artists::display_artists($ArtistForm, false, true, false);
  164. } elseif (($Type == 'Movies' || $Type == 'Anime' || $Type == 'Manga' || $Type == 'Games') && empty($ArtistForm)) {
  165. $DB->query("
  166. SELECT ta.ArtistID, ag.Name
  167. FROM torrents_artists AS ta
  168. JOIN artists_group AS ag ON ta.ArtistID = ag.ArtistID
  169. WHERE ta.GroupID = ".$Properties['GroupID']."
  170. ORDER BY ag.Name ASC;");
  171. $ArtistForm = [];
  172. while (list($ArtistID, $ArtistName) = $DB->next_record(MYSQLI_BOTH, false)) {
  173. array_push($ArtistForm, array('id' => $ArtistID, 'name' => display_str($ArtistName)));
  174. array_push($ArtistsUnescaped, array('name' => $ArtistName));
  175. }
  176. $LogName .= Artists::display_artists($ArtistsUnescaped, false, true, false);
  177. }
  178. if ($Err) { // Show the upload form, with the data the user entered
  179. $UploadForm = $Type;
  180. include(SERVER_ROOT.'/sections/upload/upload.php');
  181. die();
  182. }
  183. // Strip out Amazon's padding
  184. $AmazonReg = '/(http:\/\/ecx.images-amazon.com\/images\/.+)(\._.*_\.jpg)/i';
  185. $Matches = [];
  186. //What the fuck is $RegX what.cd devs?
  187. //if (preg_match($RegX, $Properties['Image'], $Matches)) {
  188. if (preg_match($AmazonReg, $Properties['Image'], $Matches)) {
  189. $Properties['Image'] = $Matches[1].'.jpg';
  190. }
  191. ImageTools::blacklisted($Properties['Image']);
  192. //******************************************************************************//
  193. //--------------- Make variables ready for database input ----------------------//
  194. // Shorten and escape $Properties for database input
  195. $T = [];
  196. foreach ($Properties as $Key => $Value) {
  197. $T[$Key] = "'".db_string(trim($Value))."'";
  198. if (!$T[$Key]) {
  199. $T[$Key] = null;
  200. }
  201. }
  202. $T['Censored'] = $Properties['Censored'];
  203. //******************************************************************************//
  204. //--------------- Generate torrent file ----------------------------------------//
  205. $Tor = new BencodeTorrent($TorrentName, true);
  206. $PublicTorrent = $Tor->make_private(); // The torrent is now private.
  207. $UnsourcedTorrent = $Tor->make_sourced(); // The torrent now has the source field set.
  208. $TorEnc = $Tor->encode();
  209. $InfoHash = pack('H*', $Tor->info_hash());
  210. $DB->query("
  211. SELECT ID
  212. FROM torrents
  213. WHERE info_hash = '".db_string($InfoHash)."'");
  214. if ($DB->has_results()) {
  215. list($ID) = $DB->next_record();
  216. if (file_exists(TORRENT_STORE.$ID.'.torrent')) {
  217. $Err = '<a href="torrents.php?torrentid='.$ID.'">The exact same torrent file already exists on the site!</a>';
  218. } else {
  219. // A lost torrent
  220. file_put_contents(TORRENT_STORE.$ID.'.torrent', $TorEnc);
  221. $Err = '<a href="torrents.php?torrentid='.$ID.'">Thank you for fixing this torrent</a>';
  222. }
  223. }
  224. if (isset($Tor->Dec['encrypted_files'])) {
  225. $Err = 'This torrent contains an encrypted file list which is not supported here.';
  226. }
  227. // File list and size
  228. list($TotalSize, $FileList) = $Tor->file_list();
  229. $NumFiles = count($FileList);
  230. $TmpFileList = [];
  231. $TooLongPaths = [];
  232. $DirName = (isset($Tor->Dec['info']['files']) ? Format::make_utf8($Tor->get_name()) : '');
  233. check_name($DirName); // check the folder name against the blacklist
  234. foreach ($FileList as $File) {
  235. list($Size, $Name) = $File;
  236. // Check file name and extension against blacklist/whitelist
  237. check_file($Type, $Name);
  238. // Make sure the filename is not too long
  239. if (mb_strlen($Name, 'UTF-8') + mb_strlen($DirName, 'UTF-8') + 1 > MAX_FILENAME_LENGTH) {
  240. $TooLongPaths[] = "$DirName/$Name";
  241. }
  242. // Add file info to array
  243. $TmpFileList[] = Torrents::filelist_format_file($File);
  244. }
  245. if (count($TooLongPaths) > 0) {
  246. $Names = implode(' <br />', $TooLongPaths);
  247. $Err = "The torrent contained one or more files with too long a name:<br /> $Names";
  248. }
  249. $FilePath = db_string($DirName);
  250. $FileString = db_string(implode("\n", $TmpFileList));
  251. $Debug->set_flag('upload: torrent decoded');
  252. /*if ($Type == 'Music') {
  253. include(SERVER_ROOT.'/sections/upload/generate_extra_torrents.php');
  254. }*/
  255. if (!empty($Err)) { // Show the upload form, with the data the user entered
  256. $UploadForm = $Type;
  257. include(SERVER_ROOT.'/sections/upload/upload.php');
  258. die();
  259. }
  260. //******************************************************************************//
  261. //--------------- Start database stuff -----------------------------------------//
  262. $Body = $Properties['GroupDescription'];
  263. // Trickery
  264. if (!preg_match('/^'.IMAGE_REGEX.'$/i', $Properties['Image'])) {
  265. $Properties['Image'] = '';
  266. $T['Image'] = "''";
  267. }
  268. if ($Type == 'Movies' || $Type == 'Anime' || $Type == 'Manga' || $Type == 'Games') {
  269. // Does it belong in a group?
  270. if ($Properties['GroupID']) {
  271. $DB->query("
  272. SELECT
  273. ID,
  274. WikiImage,
  275. WikiBody,
  276. RevisionID,
  277. Name,
  278. Year,
  279. TagList
  280. FROM torrents_group
  281. WHERE id = ".$Properties['GroupID']);
  282. if ($DB->has_results()) {
  283. // Don't escape tg.Name. It's written directly to the log table
  284. list($GroupID, $WikiImage, $WikiBody, $RevisionID, $Properties['Title'], $Properties['Year'], $Properties['TagList']) = $DB->next_record(MYSQLI_NUM, array(4));
  285. $Properties['TagList'] = str_replace(array(' ', '.', '_'), array(', ', '.', '.'), $Properties['TagList']);
  286. if (!$Properties['Image'] && $WikiImage) {
  287. $Properties['Image'] = $WikiImage;
  288. $T['Image'] = "'".db_string($WikiImage)."'";
  289. }
  290. if (strlen($WikiBody) > strlen($Body)) {
  291. $Body = $WikiBody;
  292. if (!$Properties['Image'] || $Properties['Image'] == $WikiImage) {
  293. $NoRevision = true;
  294. }
  295. }
  296. $Properties['Artist'] = Artists::display_artists(Artists::get_artist($GroupID), false, false);
  297. }
  298. }
  299. if (!isset($GroupID) || !$GroupID) {
  300. foreach ($ArtistForm as $Num => $Artist) {
  301. /*$DB->query("
  302. SELECT
  303. tg.id,
  304. tg.WikiImage,
  305. tg.WikiBody,
  306. tg.RevisionID
  307. FROM torrents_group AS tg
  308. LEFT JOIN torrents_artists AS ta ON ta.GroupID = tg.ID
  309. LEFT JOIN artists_group AS ag ON ta.ArtistID = ag.ArtistID
  310. WHERE ag.Name = '".db_string($Artist['name'])."'
  311. AND tg.Name = ".$T['Title']."
  312. AND tg.Year = ".$T['Year']);
  313. if ($DB->has_results()) {
  314. list($GroupID, $WikiImage, $WikiBody, $RevisionID) = $DB->next_record();
  315. if (!$Properties['Image'] && $WikiImage) {
  316. $Properties['Image'] = $WikiImage;
  317. $T['Image'] = "'".db_string($WikiImage)."'";
  318. }
  319. if (strlen($WikiBody) > strlen($Body)) {
  320. $Body = $WikiBody;
  321. if (!$Properties['Image'] || $Properties['Image'] == $WikiImage) {
  322. $NoRevision = true;
  323. }
  324. }
  325. $ArtistForm = Artists::get_artist($GroupID);
  326. //This torrent belongs in a group
  327. break;
  328. } else {*/
  329. // The album hasn't been uploaded. Try to get the artist IDs
  330. $DB->query("
  331. SELECT
  332. ArtistID,
  333. Name
  334. FROM artists_group
  335. WHERE Name = '".db_string($Artist['name'])."'");
  336. if ($DB->has_results()) {
  337. while (list($ArtistID, $Name) = $DB->next_record(MYSQLI_NUM, false)) {
  338. if (!strcasecmp($Artist['name'], $Name)) {
  339. $ArtistForm[$Num] = array('id' => $ArtistID, 'name' => $Name);
  340. break;
  341. }
  342. }
  343. }
  344. //}
  345. }
  346. }
  347. }
  348. //Needs to be here as it isn't set for add format until now
  349. $LogName .= $Properties['Title'];
  350. //For notifications--take note now whether it's a new group
  351. $IsNewGroup = !isset($GroupID) || !$GroupID;
  352. //----- Start inserts
  353. if ((!isset($GroupID) || !$GroupID) && ($Type != 'Other')) {
  354. //array to store which artists we have added already, to prevent adding an artist twice
  355. $ArtistsAdded = [];
  356. foreach ($ArtistForm as $Num => $Artist) {
  357. if (!isset($Artist['id']) || !$Artist['id']) {
  358. if (isset($ArtistsAdded[strtolower($Artist['name'])])) {
  359. $ArtistForm[$Num] = $ArtistsAdded[strtolower($Artist['name'])];
  360. } else {
  361. // Create artist
  362. $DB->query("
  363. INSERT INTO artists_group (Name)
  364. VALUES ('".db_string($Artist['name'])."')");
  365. $ArtistID = $DB->inserted_id();
  366. $Cache->increment('stats_artist_count');
  367. /*$DB->query("
  368. INSERT INTO artists_alias (ArtistID, Name)
  369. VALUES ($ArtistID, '".db_string($Artist['name'])."')");
  370. $AliasID = $DB->inserted_id();*/
  371. $ArtistForm[$Num] = array('id' => $ArtistID, 'name' => $Artist['name']);
  372. $ArtistsAdded[strtolower($Artist['name'])] = $ArtistForm[$Num];
  373. }
  374. }
  375. }
  376. unset($ArtistsAdded);
  377. }
  378. if (!isset($GroupID) || !$GroupID) {
  379. // Create torrent group
  380. $DB->query("
  381. INSERT INTO torrents_group
  382. (CategoryID, Name, NameRJ, NameJP, Year, Series, Studio, CatalogueNumber, Pages, Time, WikiBody, WikiImage, DLsiteID)
  383. VALUES
  384. ($TypeID, ".$T['Title'].", ".$T['TitleRJ'].", ".$T['TitleJP'].", ".$T['Year'].", ".$T['Series'].", ".$T['Studio'].", ".$T['CatalogueNumber'].", " . $T['Pages'] . ", '".sqltime()."', '".db_string($Body)."', ".$T['Image'].", ".$T['DLsiteID'].")");
  385. $GroupID = $DB->inserted_id();
  386. if ($Type == 'Movies' || $Type == 'Anime' || $Type == 'Manga' || $Type == 'Games') {
  387. foreach ($ArtistForm as $Num => $Artist) {
  388. $DB->query("
  389. INSERT IGNORE INTO torrents_artists (GroupID, ArtistID, UserID)
  390. VALUES ($GroupID, ".$Artist['id'].', '.$LoggedUser['ID'].")");
  391. $Cache->increment('stats_album_count');
  392. $Cache->delete_value('artist_groups_'.$Artist['id']);
  393. }
  394. }
  395. $Cache->increment('stats_group_count');
  396. // Add screenshots
  397. $Screenshots = array_slice(array_filter(array_map("db_string", array_map("trim", array_unique(explode("\n", $Properties['Screenshots'])))), function ($s) { return preg_match('/^'.IMAGE_REGEX.'$/i', $s); }), 0, 10);
  398. $values = [];
  399. foreach ($Screenshots as $s) {
  400. $values[] = "(" . $GroupID . ", " . $LoggedUser['ID'] . ", NOW(), '" . $s . "')";
  401. }
  402. if (!empty($values)) {
  403. $DB->query("
  404. INSERT INTO torrents_screenshots
  405. (GroupID, UserID, Time, Image)
  406. VALUES " . implode(", ", $values));
  407. }
  408. } else {
  409. $DB->query("
  410. UPDATE torrents_group
  411. SET Time = '".sqltime()."'
  412. WHERE ID = $GroupID");
  413. $Cache->delete_value("torrent_group_$GroupID");
  414. $Cache->delete_value("torrents_details_$GroupID");
  415. $Cache->delete_value("detail_files_$GroupID");
  416. }
  417. // Description
  418. if (!isset($NoRevision) || !$NoRevision) {
  419. $DB->query("
  420. INSERT INTO wiki_torrents
  421. (PageID, Body, UserID, Summary, Time, Image)
  422. VALUES
  423. ($GroupID, $T[GroupDescription], $LoggedUser[ID], 'Uploaded new torrent', '".sqltime()."', $T[Image])");
  424. $RevisionID = $DB->inserted_id();
  425. // Revision ID
  426. $DB->query("
  427. UPDATE torrents_group
  428. SET RevisionID = '$RevisionID'
  429. WHERE ID = $GroupID");
  430. }
  431. // Tags
  432. $Tags = explode(',', $Properties['TagList']);
  433. if (!$Properties['GroupID']) {
  434. foreach ($Tags as $Tag) {
  435. $Tag = Misc::sanitize_tag($Tag);
  436. if (!empty($Tag)) {
  437. $Tag = Misc::get_alias_tag($Tag);
  438. $DB->query("
  439. INSERT INTO tags
  440. (Name, UserID)
  441. VALUES
  442. ('$Tag', $LoggedUser[ID])
  443. ON DUPLICATE KEY UPDATE
  444. Uses = Uses + 1;
  445. ");
  446. $TagID = $DB->inserted_id();
  447. $DB->query("
  448. INSERT INTO torrents_tags
  449. (TagID, GroupID, UserID)
  450. VALUES
  451. ($TagID, $GroupID, $LoggedUser[ID])
  452. ON DUPLICATE KEY UPDATE TagID=TagID
  453. ");
  454. }
  455. }
  456. }
  457. // Use this section to control freeleeches
  458. $DB->query("
  459. SELECT Name, First, Second
  460. FROM misc
  461. WHERE Second = 'freeleech'");
  462. if ($DB->has_results()) {
  463. $FreeLeechTags = $DB->to_array('Name');
  464. foreach ($FreeLeechTags as $Tag => $Exp) {
  465. if ($Tag == 'global' || in_array($Tag, $Tags)) {
  466. $T['FreeTorrent'] = 1;
  467. $T['FreeLeechType'] = 3;
  468. break;
  469. }
  470. }
  471. } else {
  472. $T['FreeTorrent'] = 0;
  473. $T['FreeLeechType'] = 0;
  474. }
  475. // movie and anime ISOs are neutral leech, and receive a BP bounty
  476. if (($Type == "Movies" || $Type == "Anime") && ($T['Container'] == "'ISO'" || $T['Container'] == "'M2TS'" || $T['Container'] == "'VOB IFO'")) {
  477. $T['FreeTorrent'] = 2;
  478. $T['FreeLeechType'] = 2;
  479. }
  480. // Torrent
  481. $DB->query("
  482. INSERT INTO torrents
  483. (GroupID, UserID, Media, Container, Codec, Resolution, AudioFormat,
  484. Subbing, Language, Subber, Censored, Archive, info_hash, FileCount, FileList,
  485. FilePath, Size, Time, Description, MediaInfo, FreeTorrent, FreeLeechType)
  486. VALUES
  487. ($GroupID, $LoggedUser[ID], $T[Media], $T[Container], $T[Codec], $T[Resolution], $T[AudioFormat],
  488. $T[Subbing], $T[Language], $T[Subber], $T[Censored], $T[Archive],'".db_string($InfoHash)."', $NumFiles, '$FileString',
  489. '$FilePath', $TotalSize, '".sqltime()."', $T[TorrentDescription], $T[MediaInfo], '$T[FreeTorrent]', '$T[FreeLeechType]')");
  490. $Cache->increment('stats_torrent_count');
  491. $TorrentID = $DB->inserted_id();
  492. Tracker::update_tracker('add_torrent', array('id' => $TorrentID, 'info_hash' => rawurlencode($InfoHash), 'freetorrent' => $T['FreeTorrent']));
  493. $Debug->set_flag('upload: ocelot updated');
  494. // Prevent deletion of this torrent until the rest of the upload process is done
  495. // (expire the key after 10 minutes to prevent locking it for too long in case there's a fatal error below)
  496. $Cache->cache_value("torrent_{$TorrentID}_lock", true, 600);
  497. //give BP if necessary
  498. if (($Type == "Movies" || $Type == "Anime") && ($T['Container'] == "'ISO'" || $T['Container'] == "'M2TS'" || $T['Container'] == "'VOB IFO'")) {
  499. $BPAmt = (int) 2*($TotalSize / (1024*1024*1024))*1000;
  500. $DB->query("
  501. UPDATE users_main
  502. SET BonusPoints = BonusPoints + $BPAmt
  503. WHERE ID = $LoggedUser[ID]");
  504. $DB->query("
  505. UPDATE users_info
  506. SET AdminComment = CONCAT('".sqltime()." - Received $BPAmt ".BONUS_POINTS." for uploading a torrent $TorrentID\n\n', AdminComment)
  507. WHERE UserID = $LoggedUser[ID]");
  508. $Cache->delete_value('user_info_heavy_'.$LoggedUser['ID']);
  509. $Cache->delete_value('user_stats_'.$LoggedUser['ID']);
  510. }
  511. // Add to shop freeleeches if necessary
  512. if ($T['FreeLeechType'] == 3) {
  513. // Figure out which duration to use
  514. $Expiry = 0;
  515. foreach ($FreeLeechTags as $Tag => $Exp) {
  516. if ($Tag == 'global' || in_array($Tag, $Tags)) {
  517. if (((int) $FreeLeechTags[$Tag]['First']) > $Expiry)
  518. $Expiry = (int) $FreeLeechTags[$Tag]['First'];
  519. }
  520. }
  521. if ($Expiry > 0) {
  522. $DB->query("
  523. INSERT INTO shop_freeleeches
  524. (TorrentID, ExpiryTime)
  525. VALUES
  526. (" . $TorrentID . ", FROM_UNIXTIME(" . $Expiry . "))
  527. ON DUPLICATE KEY UPDATE
  528. ExpiryTime = FROM_UNIXTIME(UNIX_TIMESTAMP(ExpiryTime) + ($Expiry - FROM_UNIXTIME(NOW())))");
  529. } else {
  530. Torrents::freeleech_torrents($TorrentID, 0, 0);
  531. }
  532. }
  533. //******************************************************************************//
  534. //--------------- Write torrent file -------------------------------------------//
  535. file_put_contents(TORRENT_STORE.$TorrentID.'.torrent', $TorEnc);
  536. Misc::write_log("Torrent $TorrentID ($LogName) (".number_format($TotalSize / (1024 * 1024), 2).' MB) was uploaded by ' . $LoggedUser['Username']);
  537. Torrents::write_group_log($GroupID, $TorrentID, $LoggedUser['ID'], 'uploaded ('.number_format($TotalSize / (1024 * 1024), 2).' MB)', 0);
  538. Torrents::update_hash($GroupID);
  539. $Debug->set_flag('upload: sphinx updated');
  540. /*if ($Type == 'Music') {
  541. include(SERVER_ROOT.'/sections/upload/insert_extra_torrents.php');
  542. }*/
  543. //******************************************************************************//
  544. //---------------------- Recent Uploads ----------------------------------------//
  545. if (trim($Properties['Image']) != '') {
  546. $RecentUploads = $Cache->get_value("recent_uploads_$UserID");
  547. if (is_array($RecentUploads)) {
  548. do {
  549. foreach ($RecentUploads as $Item) {
  550. if ($Item['ID'] == $GroupID) {
  551. break 2;
  552. }
  553. }
  554. // Only reached if no matching GroupIDs in the cache already.
  555. if (count($RecentUploads) === 5) {
  556. array_pop($RecentUploads);
  557. }
  558. array_unshift($RecentUploads, array(
  559. 'ID' => $GroupID,
  560. 'Name' => trim($Properties['Title']),
  561. 'Artist' => Artists::display_artists($ArtistForm, false, true),
  562. 'WikiImage' => trim($Properties['Image'])));
  563. $Cache->cache_value("recent_uploads_$UserID", $RecentUploads, 0);
  564. } while (0);
  565. }
  566. }
  567. //******************************************************************************//
  568. //------------------------------- Post-processing ------------------------------//
  569. /* Because tracker updates and notifications can be slow, we're
  570. * redirecting the user to the destination page and flushing the buffers
  571. * to make it seem like the PHP process is working in the background.
  572. */
  573. if ($PublicTorrent) {
  574. View::show_header('Warning');
  575. ?>
  576. <h1>Warning</h1>
  577. <p><strong>Your torrent has been uploaded; however, you must download your torrent from <a href="torrents.php?id=<?=$GroupID?>">here</a> because you didn't make your torrent using the "private" option.</strong></p>
  578. <?
  579. View::show_footer();
  580. } elseif ($RequestID) {
  581. header("Location: requests.php?action=takefill&requestid=$RequestID&torrentid=$TorrentID&auth=".$LoggedUser['AuthKey']);
  582. } else {
  583. header("Location: torrents.php?id=$GroupID");
  584. }
  585. if (function_exists('fastcgi_finish_request')) {
  586. fastcgi_finish_request();
  587. } else {
  588. ignore_user_abort(true);
  589. ob_flush();
  590. flush();
  591. ob_start(); // So we don't keep sending data to the client
  592. }
  593. //******************************************************************************//
  594. //--------------------------- IRC announce and feeds ---------------------------//
  595. $Announce = '';
  596. if ($Type != 'Other') {
  597. $Announce .= Artists::display_artists($ArtistForm, false);
  598. }
  599. $Announce .= empty($Properties['Title']) ? (empty($Properties['TitleRJ']) ? trim($Properties['TitleJP']) : trim($Properties['TitleRJ'])) : trim($Properties['Title']);
  600. $Announce .= ' ';
  601. if ($Type != 'Other') {
  602. $Announce .= '['.Torrents::torrent_info($Properties, false, false, false).']';
  603. }
  604. $Title = '['.$Properties['CategoryName'].'] '.$Announce;
  605. $Announce = "$Title - ".site_url()."torrents.php?id=$GroupID / ".site_url()."torrents.php?action=download&id=$TorrentID";
  606. $Announce .= ' - '.trim($Properties['TagList']);
  607. // ENT_QUOTES is needed to decode single quotes/apostrophes
  608. send_irc('PRIVMSG '.BOT_ANNOUNCE_CHAN.' '.html_entity_decode($Announce, ENT_QUOTES));
  609. $Debug->set_flag('upload: announced on irc');
  610. // Manage notifications
  611. // For RSS
  612. $Item = $Feed->item($Title, Text::strip_bbcode($Body), 'torrents.php?action=download&amp;authkey=[[AUTHKEY]]&amp;torrent_pass=[[PASSKEY]]&amp;id='.$TorrentID, $LoggedUser['Username'], 'torrents.php?id='.$GroupID, trim($Properties['TagList']));
  613. //Notifications
  614. $SQL = "
  615. SELECT unf.ID, unf.UserID, torrent_pass
  616. FROM users_notify_filters AS unf
  617. JOIN users_main AS um ON um.ID = unf.UserID
  618. WHERE um.Enabled = '1'";
  619. if (empty($ArtistsUnescaped)) {
  620. $ArtistsUnescaped = $ArtistForm;
  621. }
  622. if (!empty($ArtistsUnescaped)) {
  623. $ArtistNameList = [];
  624. $GuestArtistNameList = [];
  625. foreach ($ArtistsUnescaped as $Importance => $Artists) {
  626. foreach ($Artists as $Artist) {
  627. if ($Importance == 1 || $Importance == 4 || $Importance == 5 || $Importance == 6) {
  628. $ArtistNameList[] = "Artists LIKE '%|".db_string(str_replace('\\', '\\\\', $Artist['name']), true)."|%'";
  629. } else {
  630. $GuestArtistNameList[] = "Artists LIKE '%|".db_string(str_replace('\\', '\\\\', $Artist['name']), true)."|%'";
  631. }
  632. }
  633. }
  634. // Don't add notification if >2 main artists or if tracked artist isn't a main artist
  635. if (count($ArtistNameList) > 2 || $Artist['name'] == 'Various Artists') {
  636. $SQL .= " AND (ExcludeVA = '0' AND (";
  637. $SQL .= implode(' OR ', array_merge($ArtistNameList, $GuestArtistNameList));
  638. $SQL .= " OR Artists = '')) AND (";
  639. } else {
  640. $SQL .= " AND (";
  641. if (!empty($GuestArtistNameList)) {
  642. $SQL .= "(ExcludeVA = '0' AND (";
  643. $SQL .= implode(' OR ', $GuestArtistNameList);
  644. $SQL .= ')) OR ';
  645. }
  646. if (count($ArtistNameList) > 0) {
  647. $SQL .= implode(' OR ', $ArtistNameList);
  648. $SQL .= " OR ";
  649. }
  650. $SQL .= "Artists = '') AND (";
  651. }
  652. } else {
  653. $SQL .= "AND (Artists = '') AND (";
  654. }
  655. reset($Tags);
  656. $TagSQL = [];
  657. $NotTagSQL = [];
  658. foreach ($Tags as $Tag) {
  659. $TagSQL[] = " Tags LIKE '%|".db_string(trim($Tag))."|%' ";
  660. $NotTagSQL[] = " NotTags LIKE '%|".db_string(trim($Tag))."|%' ";
  661. }
  662. $TagSQL[] = "Tags = ''";
  663. $SQL .= implode(' OR ', $TagSQL);
  664. $SQL .= ") AND !(".implode(' OR ', $NotTagSQL).')';
  665. $SQL .= " AND (Categories LIKE '%|".db_string(trim($Type))."|%' OR Categories = '') ";
  666. if ($Properties['ReleaseType']) {
  667. $SQL .= " AND (ReleaseTypes LIKE '%|".db_string(trim($ReleaseTypes[$Properties['ReleaseType']]))."|%' OR ReleaseTypes = '') ";
  668. } else {
  669. $SQL .= " AND (ReleaseTypes = '') ";
  670. }
  671. /*
  672. Notify based on the following:
  673. 1. The torrent must match the formatbitrate filter on the notification
  674. 2. If they set NewGroupsOnly to 1, it must also be the first torrent in the group to match the formatbitrate filter on the notification
  675. */
  676. if ($Properties['Format']) {
  677. $SQL .= " AND (Formats LIKE '%|".db_string(trim($Properties['Format']))."|%' OR Formats = '') ";
  678. } else {
  679. $SQL .= " AND (Formats = '') ";
  680. }
  681. if ($_POST['bitrate']) {
  682. $SQL .= " AND (Encodings LIKE '%|".db_string(trim($_POST['bitrate']))."|%' OR Encodings = '') ";
  683. } else {
  684. $SQL .= " AND (Encodings = '') ";
  685. }
  686. if ($Properties['Media']) {
  687. $SQL .= " AND (Media LIKE '%|".db_string(trim($Properties['Media']))."|%' OR Media = '') ";
  688. } else {
  689. $SQL .= " AND (Media = '') ";
  690. }
  691. // Either they aren't using NewGroupsOnly
  692. $SQL .= "AND ((NewGroupsOnly = '0' ";
  693. // Or this is the first torrent in the group to match the formatbitrate filter
  694. $SQL .= ") OR ( NewGroupsOnly = '1' ";
  695. // Test the filter doesn't match any previous formatbitrate in the group
  696. /*
  697. foreach ($UsedFormatBitrates as $UsedFormatBitrate) {
  698. $FormatReq = "(Formats LIKE '%|".db_string($UsedFormatBitrate['format'])."|%' OR Formats = '') ";
  699. $BitrateReq = "(Encodings LIKE '%|".db_string($UsedFormatBitrate['bitrate'])."|%' OR Encodings = '') ";
  700. $SQL .= "AND (NOT($FormatReq AND $BitrateReq)) ";
  701. }
  702. */
  703. $SQL .= '))';
  704. /*if ($Properties['Year'] && $Properties['RemasterYear']) {
  705. $SQL .= " AND (('".db_string(trim($Properties['Year']))."' BETWEEN FromYear AND ToYear)
  706. OR ('".db_string(trim($Properties['RemasterYear']))."' BETWEEN FromYear AND ToYear)
  707. OR (FromYear = 0 AND ToYear = 0)) ";
  708. } else*/
  709. if ($Properties['Year'] || $Properties['RemasterYear']) {
  710. //$SQL .= " AND (('".db_string(trim(Max($Properties['Year'],$Properties['RemasterYear'])))."' BETWEEN FromYear AND ToYear)
  711. $SQL .= " AND (('".db_string(trim($Properties['Year']))."' BETWEEN FromYear AND ToYear)
  712. OR (FromYear = 0 AND ToYear = 0)) ";
  713. } else {
  714. $SQL .= " AND (FromYear = 0 AND ToYear = 0) ";
  715. }
  716. $SQL .= " AND UserID != '".$LoggedUser['ID']."' ";
  717. $DB->query("
  718. SELECT Paranoia
  719. FROM users_main
  720. WHERE ID = $LoggedUser[ID]");
  721. list($Paranoia) = $DB->next_record();
  722. $Paranoia = unserialize($Paranoia);
  723. if (!is_array($Paranoia)) {
  724. $Paranoia = [];
  725. }
  726. if (!in_array('notifications', $Paranoia)) {
  727. $SQL .= " AND (Users LIKE '%|".$LoggedUser['ID']."|%' OR Users = '') ";
  728. }
  729. $SQL .= " AND UserID != '".$LoggedUser['ID']."' ";
  730. $DB->query($SQL);
  731. $Debug->set_flag('upload: notification query finished');
  732. if ($DB->has_results()) {
  733. $UserArray = $DB->to_array('UserID');
  734. $FilterArray = $DB->to_array('ID');
  735. $InsertSQL = '
  736. INSERT IGNORE INTO users_notify_torrents (UserID, GroupID, TorrentID, FilterID)
  737. VALUES ';
  738. $Rows = [];
  739. foreach ($UserArray as $User) {
  740. list($FilterID, $UserID, $Passkey) = $User;
  741. $Rows[] = "('$UserID', '$GroupID', '$TorrentID', '$FilterID')";
  742. $Feed->populate("torrents_notify_$Passkey", $Item);
  743. $Cache->delete_value("notifications_new_$UserID");
  744. }
  745. $InsertSQL .= implode(',', $Rows);
  746. $DB->query($InsertSQL);
  747. $Debug->set_flag('upload: notification inserts finished');
  748. foreach ($FilterArray as $Filter) {
  749. list($FilterID, $UserID, $Passkey) = $Filter;
  750. $Feed->populate("torrents_notify_{$FilterID}_$Passkey", $Item);
  751. }
  752. }
  753. // RSS for bookmarks
  754. $DB->query("
  755. SELECT u.ID, u.torrent_pass
  756. FROM users_main AS u
  757. JOIN bookmarks_torrents AS b ON b.UserID = u.ID
  758. WHERE b.GroupID = $GroupID");
  759. while (list($UserID, $Passkey) = $DB->next_record()) {
  760. $Feed->populate("torrents_bookmarks_t_$Passkey", $Item);
  761. }
  762. $Feed->populate('torrents_all', $Item);
  763. $Feed->populate('torrents_'.strtolower($Type), $Item);
  764. $Debug->set_flag('upload: notifications handled');
  765. // Clear cache
  766. $Cache->delete_value("torrents_details_$GroupID");
  767. $Cache->delete_value("contest_scores");
  768. // Allow deletion of this torrent now
  769. $Cache->delete_value("torrent_{$TorrentID}_lock");