Compare commits

..

8 Commits

Author SHA1 Message Date
DebaucheryLibrarian cefd91a7b9 1.137.4 2020-10-20 15:29:51 +02:00
DebaucheryLibrarian ecdd6d8fb0 Added logo path to entity API. 2020-10-20 15:28:58 +02:00
DebaucheryLibrarian 60eb599416 Added alias to entity search query. 2020-10-20 00:25:32 +02:00
DebaucheryLibrarian 8e7b944b52 1.137.3 2020-10-20 00:21:25 +02:00
DebaucheryLibrarian 6b17f9d1f2 Allowing entity to be fetched by alias. 2020-10-20 00:21:15 +02:00
DebaucheryLibrarian cb459d4cc7 1.137.2 2020-10-20 00:08:24 +02:00
DebaucheryLibrarian d795266114 Removed no-date-limit as argument due yargs conflict. 2020-10-20 00:08:14 +02:00
DebaucheryLibrarian 3e303e4b10 1.137.1 2020-10-20 00:05:34 +02:00
5 changed files with 18 additions and 8 deletions

2
package-lock.json generated
View File

@ -1,6 +1,6 @@
{
"name": "traxxx",
"version": "1.137.0",
"version": "1.137.4",
"lockfileVersion": 1,
"requires": true,
"dependencies": {

View File

@ -1,6 +1,6 @@
{
"name": "traxxx",
"version": "1.137.0",
"version": "1.137.4",
"description": "All the latest porn releases in one place",
"main": "src/app.js",
"scripts": {

View File

@ -6,6 +6,7 @@ const parentNetworks = [
slug: 'gamma',
name: 'Gamma Entertainment',
url: 'https://www.gammaentertainment.com',
alias: ['gammaentertainment'],
},
{
slug: 'hush',

View File

@ -146,7 +146,7 @@ const { argv } = yargs
describe: 'Limit amount of scenes when dates are missing.',
type: 'number',
default: config.noDateLimit,
alias: ['no-date-limit', 'null-date-limit', 'limit'],
alias: ['null-date-limit', 'limit'],
})
.option('page', {
describe: 'Page to start scraping at',

View File

@ -13,6 +13,11 @@ function curateEntity(entity, includeParameters = false) {
return null;
}
const logo = (entity.has_logo
&& (((entity.independent || entity.type === 'network') && `${entity.slug}/network.png`)
|| (entity.parent && `${entity.parent.slug}/${entity.slug}.png`)))
|| null;
const curatedEntity = entity.id ? {
id: entity.id,
name: entity.name,
@ -20,6 +25,9 @@ function curateEntity(entity, includeParameters = false) {
description: entity.description,
slug: entity.slug,
type: entity.type,
independent: !!entity.independent,
aliases: entity.alias,
logo,
parent: curateEntity(entity.parent, includeParameters),
} : {};
@ -132,8 +140,9 @@ async function fetchEntity(entityId, type) {
if (type) {
queryBuilder
.where('entities.type', type)
.where('entities.slug', entityId)
.where('entities.type', type);
.orWhere(knex.raw(':entityId = ANY(entities.alias)', { entityId }));
return;
}
@ -172,9 +181,9 @@ async function fetchEntities(type, limit) {
}
async function searchEntities(query, type, limit) {
const entities = knex
const entities = await knex
.select(knex.raw(`
entities.id, entities.name, entities.slug, entities.type, entities.url, entities.description,
entities.id, entities.name, entities.slug, entities.type, entities.url, entities.description, entities.alias, entities.has_logo,
COALESCE(json_agg(tags) FILTER (WHERE tags.id IS NOT NULL), '[]') as tags,
row_to_json(parents) as parent
`))
@ -187,10 +196,10 @@ async function searchEntities(query, type, limit) {
.leftJoin('entities as parents', 'parents.id', 'entities.parent_id')
.leftJoin('entities_tags', 'entities_tags.entity_id', 'entities.id')
.leftJoin('tags', 'tags.id', 'entities_tags.tag_id')
.groupBy('entities.id', 'entities.name', 'entities.slug', 'entities.type', 'entities.url', 'entities.description', 'parents.id')
.groupBy('entities.id', 'entities.name', 'entities.slug', 'entities.type', 'entities.url', 'entities.description', 'entities.alias', 'entities.has_logo', 'parents.id')
.limit(limit || 100);
return curateEntities(await entities);
return curateEntities(entities);
}
async function flushEntities(networkSlugs = [], channelSlugs = []) {