require('dotenv').config(); const Bottleneck = require('bottleneck'); const { parse } = require('parse-torrent-title'); const repository = require('../lib/repository'); const { parseTorrentFiles } = require('../lib/torrentFiles'); const { Type } = require('../lib/types'); const limiter = new Bottleneck({ maxConcurrent: 40 }); async function addMissingEpisodes() { const torrent = { infoHash: '0ec780c2c7f8d5b38e61827f0b53c77c3d22f955' }; const torrentFiles = await require('../lib/torrent').torrentFiles(torrent); const storedFiles = await repository.getFiles(torrent) .then((files) => files.reduce((map, next) => (map[next.fileIndex] = next, map), {})); const imdbId = Object.values(storedFiles)[0].imdbId; torrentFiles .filter((file) => !storedFiles[file.fileIndex]) .map((file) => ({ infoHash: torrent.infoHash, fileIndex: file.fileIndex, title: file.name, size: file.size, imdbId: imdbId, imdbSeason: parse(file.name).season, imdbEpisode: parse(file.name).episode, // imdbSeason: parseInt(file.name.match(/(\d+)[ .]?-[ .]?\d+/)[1], 10), // imdbEpisode: parseInt(file.name.match(/\d+[ .]?-[ .]?(\d+)/)[1], 10), })) .forEach((file) => repository.createFile(file)); } async function updateMovieCollections() { const collectionFiles = await repository.getFilesBasedOnTitle('logy') .then(files => files.filter(file => file.fileIndex === null)) .then(files => files.filter(file => parse(file.title).complete)); collectionFiles.map(original => repository.getTorrent({ infoHash: original.infoHash }) .then(torrent => parseTorrentFiles({ ...torrent, imdbId: original.imdbId })) .then(files => Promise.all(files.map(file => { console.log(file); return repository.createFile(file) }))) .then(createdFiled => { if (createdFiled && createdFiled.length) { console.log(`Updated movie collection ${original.title}`); repository.deleteFile(original) } else { console.log(`Failed updating movie collection ${original.title}`); } })); } async function reapplySeriesSeasonsSavedAsMovies() { return repository.getTorrentsBasedOnTitle('(?:[^a-zA-Z0-9]|^)[Ss][012]?[0-9](?:[^0-9]|$)', Type.MOVIE) .then(torrents => Promise.all(torrents .filter(torrent => parse(torrent.title).seasons) .map(torrent => limiter.schedule(() => reapplyEpisodeDecomposing(torrent.infoHash, false) .then(() => { torrent.type = Type.SERIES; return torrent.save(); }))))) .then(() => console.log('Finished updating multiple torrents')); } async function reapplyEpisodeDecomposing(infoHash, includeSourceFiles = true) { const torrent = await repository.getTorrent({ infoHash }); const storedFiles = await repository.getFiles({ infoHash }); const fileIndexMap = storedFiles .reduce((map, next) => (map[next.fileIndex] = (map[next.fileIndex] || []).concat(next), map), {}); const files = includeSourceFiles && Object.values(fileIndexMap) .map(sameIndexFiles => sameIndexFiles[0]) .map(file => ({ fileIndex: file.fileIndex, name: file.title.replace(/.*\//, ''), path: file.title, size: file.size })); const imdbId = storedFiles[0].imdbId; return parseTorrentFiles({ ...torrent, imdbId, files }) .then(newFiles => newFiles.map(file => { if (fileIndexMap[file.fileIndex]) { const originalFile = fileIndexMap[file.fileIndex].shift(); if (originalFile) { originalFile.imdbSeason = file.imdbSeason; originalFile.imdbEpisode = file.imdbEpisode; originalFile.kitsuId = file.kitsuId; originalFile.kitsuEpisode = file.kitsuEpisode; return originalFile; } } return file; })) .then(updatedFiles => Promise.all(updatedFiles .map(file => file.id ? file.save() : repository.createFile(file)))) .then(() => console.log(`Updated files for ${torrent.title}`)); } async function findAllFiles() { /* Test cases */ /* Anime Season and absolute episodes */ const torrent = { infoHash: '6b95e5cfde9aaa71970a14f6bb6b9de19e2cbfa1', title: '[OMDA] Bleach + Filmes + Ovas (480p-720p x264 AAC-MP3) [rich_jc]', type: Type.SERIES, imdbId: 'tt0434665' }; /* Season and concat episodes */ // const torrent = { // infoHash: '235e8ed73b6cc9679b0842c39e17223c47b51f68', // title: 'Daria - The Complete Animated Series [2010] DVDRip', // type: Type.SERIES, // imdbId: 'tt0118298' // }; /* Series Season and absolute episodes */ // const torrent = { // infoHash: '16b4560beb05397c0eeb35487a997caf789243ea', // title: 'Seinfeld - Complete Collection', // type: Type.SERIES, // imdbId: 'tt0098904' // }; /* Series Season and episodes */ // const torrent = { // infoHash: 'd0f120c1bbfb988eb35b648e1c78ca3e5d45ef39', // title: 'Seinfeld Complete Series-720p WEBrip EN-SUB x264-[MULVAcoded]', // type: Type.SERIES, // imdbId: 'tt0098904' // }; /* Anime single absolute episode */ // const torrent = { // infoHash: 'e81e12880980086c476aa8bfdd22bed9d41b1dfe', // title: '[Vision] Naruto Shippuuden - 451 (1080p x264 AAC) [rich_jc].mp4', // size: 467361138, // type: Type.SERIES, // imdbId: 'tt0988824' // }; /* Date based episode */ // const torrent = { // infoHash: '5a8e9e64fa04e3541236f049cb6b0d35e4ca12cc', // title: 'Jimmy.Fallon.2020.02.14.Steve.Buscemi.WEB.x264-XLF[TGx]', // size: 618637331, // type: Type.SERIES, // imdbId: 'tt3444938' // }; /* Not all seasons available so Date based episode */ // const torrent = { // infoHash: 'DCD5ACF85F4203FE14428A890528B2EDBD07B092', // title: 'The Young And The Restless - S43 E10986 - 2016-08-12', // size: 989777743, // type: Type.SERIES, // imdbId: 'tt0069658' // }; // const torrent = { // infoHash: 'C75FBDCD62EB882746A0E58B19BADD60DE14526B', // title: 'Jimmy.Kimmel.2016.08.03.Hugh.Grant.480p.x264-mSD', // size: 618637331, // type: Type.SERIES, // imdbId: 'tt0320037' // }; /* With extras exceeding season episode count */ // const torrent = { // infoHash: '2af56a80357b61d839328b986d1165ea8395bbc0', // title: 'Tim and Eric - Complete', // type: Type.SERIES, // imdbId: 'tt0912343' // }; return parseTorrentFiles(torrent) .then((files) => console.log(files)); } //addMissingEpisodes().then(() => console.log('Finished')); //findAllFiles().then(() => console.log('Finished')); //updateMovieCollections().then(() => console.log('Finished')); reapplyEpisodeDecomposing('d71c4fd1cb9bb9c5365a570b903a3a58774f61a5', true).then(() => console.log('Finished')); //reapplySeriesSeasonsSavedAsMovies().then(() => console.log('Finished'));