forked from DebaucheryLibrarian/traxxx
Fixed pagination behavior for upcoming scenes.
This commit is contained in:
parent
7c052fedfc
commit
5f5c48ea05
|
@ -118,6 +118,11 @@ const { argv } = yargs
|
||||||
type: 'boolean',
|
type: 'boolean',
|
||||||
default: false,
|
default: false,
|
||||||
})
|
})
|
||||||
|
.option('paginate-upcoming', {
|
||||||
|
describe: 'Attempt \'next\' upcoming page, usually unavailable.',
|
||||||
|
type: 'boolean',
|
||||||
|
default: false,
|
||||||
|
})
|
||||||
.option('movies', {
|
.option('movies', {
|
||||||
describe: 'Scrape movies from channels',
|
describe: 'Scrape movies from channels',
|
||||||
type: 'boolean',
|
type: 'boolean',
|
||||||
|
|
|
@ -8,6 +8,7 @@ const { JSDOM } = require('jsdom');
|
||||||
const moment = require('moment');
|
const moment = require('moment');
|
||||||
|
|
||||||
const { get, geta, ctxa, parseDate } = require('../utils/q');
|
const { get, geta, ctxa, parseDate } = require('../utils/q');
|
||||||
|
const http = require('../utils/http');
|
||||||
const { heightToCm } = require('../utils/convert');
|
const { heightToCm } = require('../utils/convert');
|
||||||
const slugify = require('../utils/slugify');
|
const slugify = require('../utils/slugify');
|
||||||
|
|
||||||
|
@ -360,7 +361,7 @@ async function fetchUpcoming(site) {
|
||||||
if (site.parameters?.upcoming === false) return null;
|
if (site.parameters?.upcoming === false) return null;
|
||||||
|
|
||||||
const url = site.parameters?.upcoming ? util.format(site.parameters.upcoming) : `${site.url}/trial/index.php`;
|
const url = site.parameters?.upcoming ? util.format(site.parameters.upcoming) : `${site.url}/trial/index.php`;
|
||||||
const res = await bhttp.get(url);
|
const res = await http.get(url);
|
||||||
|
|
||||||
if (res.statusCode === 200) {
|
if (res.statusCode === 200) {
|
||||||
return scrapeUpcoming(res.body.toString(), site);
|
return scrapeUpcoming(res.body.toString(), site);
|
||||||
|
|
|
@ -37,7 +37,11 @@ async function filterUniqueReleases(latestReleases, accReleases) {
|
||||||
return uniqueReleases;
|
return uniqueReleases;
|
||||||
}
|
}
|
||||||
|
|
||||||
function needNextPage(releases, uniqueReleases, totalReleases, hasDates) {
|
function needNextPage(releases, uniqueReleases, totalReleases, hasDates, upcoming) {
|
||||||
|
if (upcoming && uniqueReleases.length > 0) {
|
||||||
|
return argv.paginateUpcoming;
|
||||||
|
}
|
||||||
|
|
||||||
if (argv.last) {
|
if (argv.last) {
|
||||||
return totalReleases + releases.length < argv.last;
|
return totalReleases + releases.length < argv.last;
|
||||||
}
|
}
|
||||||
|
@ -46,6 +50,10 @@ function needNextPage(releases, uniqueReleases, totalReleases, hasDates) {
|
||||||
return totalReleases + releases.length < argv.nullDateLimit;
|
return totalReleases + releases.length < argv.nullDateLimit;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (uniqueReleases.length === 0) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
const oldestReleaseOnPage = releases
|
const oldestReleaseOnPage = releases
|
||||||
.sort((releaseA, releaseB) => releaseB.date - releaseA.date)
|
.sort((releaseA, releaseB) => releaseB.date - releaseA.date)
|
||||||
.slice(-1)[0];
|
.slice(-1)[0];
|
||||||
|
@ -84,7 +92,7 @@ async function scrapeReleases(scraper, entity, preData, upcoming = false, page =
|
||||||
? limitedReleases
|
? limitedReleases
|
||||||
: await filterUniqueReleases(limitedReleases, accReleases);
|
: await filterUniqueReleases(limitedReleases, accReleases);
|
||||||
|
|
||||||
if (needNextPage(releases, uniqueReleases, totalReleases, hasDates)) {
|
if (needNextPage(releases, uniqueReleases, totalReleases, hasDates, upcoming)) {
|
||||||
return scrapeReleases(scraper, entity, preData, upcoming, page + 1, accReleases.concat(uniqueReleases), totalReleases + releases.length);
|
return scrapeReleases(scraper, entity, preData, upcoming, page + 1, accReleases.concat(uniqueReleases), totalReleases + releases.length);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue