147 lines
3.8 KiB
JavaScript
147 lines
3.8 KiB
JavaScript
var request = require("request");
|
|
var notifier = require("./notifier");
|
|
|
|
var box_cover_queue = [];
|
|
var box_cover_requst_is_running = false;
|
|
|
|
var key = "3f3692d9c336994625a838a95b9a2ed0";
|
|
var poster_root = "https://image.tmdb.org/t/p/w500";
|
|
|
|
let options = {
|
|
headers: {
|
|
"User-Agent":
|
|
"WebPlay/0.1.0 (https://gitea.com/WebPlay)"
|
|
}
|
|
};
|
|
|
|
exports.find_box_cover = function (box) {
|
|
box_cover_queue.push(box);
|
|
process.stdout.write("TMDB Box: " + box.title + "\n");
|
|
run_box_cover_request();
|
|
};
|
|
|
|
async function run_box_cover_request() {
|
|
process.stdout.write("started request for box covers\n");
|
|
if (box_cover_requst_is_running) {
|
|
return;
|
|
}
|
|
box_cover_requst_is_running = true;
|
|
while (box_cover_queue && box_cover_queue.length > 0) {
|
|
await sleep(1500);
|
|
let box = box_cover_queue.shift();
|
|
process.stdout.write("SHIFT box: " + box.title + "\n");
|
|
|
|
let elements = check_for_season(box.title);
|
|
|
|
if (elements.season > 0) {
|
|
process.stdout.write("Has SEASONS: " + box.title)
|
|
cover_by_season_number(box, elements);
|
|
} else {
|
|
process.stdout.write("Has NO SEASONS: " + box.title)
|
|
cover_by_movie_title(box);
|
|
}
|
|
}
|
|
box_cover_requst_is_running = false;
|
|
}
|
|
|
|
function cover_by_movie_title(box) {
|
|
options.url = `https://api.themoviedb.org/3/search/movie?api_key=${key}&query=${box.title.replace(' ', '%20')}&page=1&include_adult=false`;
|
|
if (box.year > 0) {
|
|
options.url = `https://api.themoviedb.org/3/search/movie?api_key=${key}&query=${box.title}&page=1&primary_release_year=${box.year}&include_adult=false`;
|
|
}
|
|
|
|
process.stdout.write("\nSTART: " + options.url + "\n");
|
|
try {
|
|
request(options, (err, res, body) => {
|
|
if (err) {
|
|
console.log(err);
|
|
return;
|
|
}
|
|
if (res.statusCode != 200) {
|
|
return;
|
|
}
|
|
|
|
process.stdout.write("PARSE BODY FOR: " + box.title + "\n");
|
|
process.stdout.write(body);
|
|
process.stdout.write("\n\n");
|
|
|
|
let json = JSON.parse(body);
|
|
if (
|
|
json.results &&
|
|
json.results.length > 0 &&
|
|
json.results[0].poster_path
|
|
) {
|
|
box.tmdb = poster_root + json.results[0].poster_path;
|
|
notifier.emit("found_movie_db_box_cover", box);
|
|
}
|
|
|
|
});
|
|
} catch (err) {
|
|
console.log(err);
|
|
process.stdout.write("\nERROR: " + box.title + "\n");
|
|
process.stdout.write(options.url + "\n\n");
|
|
}
|
|
}
|
|
|
|
function cover_by_season_number(box, elements) {
|
|
options.url = `https://api.themoviedb.org/3/search/tv?api_key=${key}&query=${elements.title
|
|
}&page=1`;
|
|
|
|
request(options, (err, res, body) => {
|
|
if (err) {
|
|
console.log(err);
|
|
return;
|
|
}
|
|
if (res.statusCode != 200) {
|
|
return;
|
|
}
|
|
|
|
let json = JSON.parse(body);
|
|
|
|
if (json.results && json.results.length > 0) {
|
|
let id = json.results[0].id;
|
|
cover_by_tv_id(id, elements.season, box);
|
|
}
|
|
});
|
|
}
|
|
|
|
function cover_by_tv_id(id, season, box) {
|
|
options.url = `https://api.themoviedb.org/3/tv/${id}/season/${season}?api_key=${key}`;
|
|
|
|
request(options, (err, res, body) => {
|
|
if (err) {
|
|
console.log(err);
|
|
return;
|
|
}
|
|
if (res.statusCode != 200) {
|
|
return;
|
|
}
|
|
|
|
let json = JSON.parse(body);
|
|
if (json.poster_path) {
|
|
box.tmdb = poster_root + json.poster_path;
|
|
notifier.emit("found_movie_db_box_cover", box);
|
|
}
|
|
});
|
|
}
|
|
|
|
function check_for_season(title) {
|
|
let return_value = { title: title, season: 0 };
|
|
let regex_season = /\s*\-?\s*seasons?\s*\d+$/gi;
|
|
|
|
let result = regex_season.exec(title);
|
|
if (result) {
|
|
return_value.title = title.replace(result[0], "");
|
|
|
|
let regex_season_no = /\d*$/g;
|
|
result = regex_season_no.exec(title);
|
|
return_value.season = parseInt(result[0]);
|
|
}
|
|
|
|
return return_value;
|
|
}
|
|
|
|
function sleep(milliseconds) {
|
|
return new Promise(resolve => setTimeout(resolve, milliseconds));
|
|
}
|