DebaucheryLibrarian/traxxx-web
1
1
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

Including scene actor aliases in manticore.

Browse Source
This commit is contained in:
DebaucheryLibrarian
2026-06-29 00:37:18 +02:00
parent fb92b9c973
commit 4b39f787c9
2 changed files with 18 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/app.js
View File

@@ -1,10 +1,12 @@
import initServer from './web/server.js'; import initServer from './web/server.js';
import { initCaches } from './cache.js'; import { initCaches } from './cache.js';
import { initSyncCron } from './sync.js';
async function init() { async function init() {
await initCaches(); await initCaches();
initServer(); initServer();
initSyncCron();
} }
init(); init();

26
src/sync.js
View File

@@ -114,6 +114,7 @@ export async function syncManticoreScenes(sceneIds) {
studios.name as studio_name, studios.name as studio_name,
grandparents.id as parent_network_id, grandparents.id as parent_network_id,
COALESCE(JSON_AGG(DISTINCT (actors.id, actors.name)) FILTER (WHERE actors.id IS NOT NULL), '[]') as actors, COALESCE(JSON_AGG(DISTINCT (actors.id, actors.name)) FILTER (WHERE actors.id IS NOT NULL), '[]') as actors,
COALESCE(JSON_AGG(DISTINCT (actors_aliases.id, actors_aliases.name)) FILTER (WHERE actors_aliases.id IS NOT NULL), '[]') as actors_aliases,
COALESCE(JSON_AGG(DISTINCT (tags.id, tags.name, tags.priority, tags_aliases.name)) FILTER (WHERE tags.id IS NOT NULL), '[]') as tags, COALESCE(JSON_AGG(DISTINCT (tags.id, tags.name, tags.priority, tags_aliases.name)) FILTER (WHERE tags.id IS NOT NULL), '[]') as tags,
COALESCE(JSON_AGG(DISTINCT (movies.id, movies.title)) FILTER (WHERE movies.id IS NOT NULL), '[]') as movies, COALESCE(JSON_AGG(DISTINCT (movies.id, movies.title)) FILTER (WHERE movies.id IS NOT NULL), '[]') as movies,
COALESCE(JSON_AGG(DISTINCT (series.id, series.title)) FILTER (WHERE series.id IS NOT NULL), '[]') as series, COALESCE(JSON_AGG(DISTINCT (series.id, series.title)) FILTER (WHERE series.id IS NOT NULL), '[]') as series,
@@ -135,6 +136,7 @@ export async function syncManticoreScenes(sceneIds) {
LEFT JOIN releases_tags AS local_tags ON local_tags.release_id = releases.id LEFT JOIN releases_tags AS local_tags ON local_tags.release_id = releases.id
LEFT JOIN actors ON local_actors.actor_id = actors.id LEFT JOIN actors ON local_actors.actor_id = actors.id
LEFT JOIN actors AS directors ON local_directors.director_id = directors.id LEFT JOIN actors AS directors ON local_directors.director_id = directors.id
LEFT JOIN actors AS actors_aliases ON actors_aliases.id = local_actors.alias_id
LEFT JOIN tags ON local_tags.tag_id = tags.id LEFT JOIN tags ON local_tags.tag_id = tags.id
LEFT JOIN tags as tags_aliases ON local_tags.tag_id = tags_aliases.alias_for AND tags_aliases.secondary = true LEFT JOIN tags as tags_aliases ON local_tags.tag_id = tags_aliases.alias_for AND tags_aliases.secondary = true
LEFT JOIN movies_scenes ON movies_scenes.scene_id = releases.id LEFT JOIN movies_scenes ON movies_scenes.scene_id = releases.id
@@ -185,6 +187,8 @@ export async function syncManticoreScenes(sceneIds) {
const flatTags = scene.tags.filter((tag) => tag.f3 > 6).flatMap((tag) => [tag.f2].concat(tag.f4)).filter(Boolean); // only make top tags searchable to minimize cluttered results const flatTags = scene.tags.filter((tag) => tag.f3 > 6).flatMap((tag) => [tag.f2].concat(tag.f4)).filter(Boolean); // only make top tags searchable to minimize cluttered results
const filteredTitle = filterTitle(scene.title, [...flatActors, ...flatTags]); const filteredTitle = filterTitle(scene.title, [...flatActors, ...flatTags]);
// TODO: reconsider how direct vs indirect tags are stored and searched
return { return {
replace: { replace: {
index: 'scenes', index: 'scenes',
@@ -207,8 +211,8 @@ export async function syncManticoreScenes(sceneIds) {
studio_slug: scene.studio_slug || undefined, studio_slug: scene.studio_slug || undefined,
studio_name: scene.studio_name || undefined, studio_name: scene.studio_name || undefined,
entity_ids: [scene.channel_id, scene.network_id, scene.parent_network_id, scene.studio_id].filter(Boolean), // manticore does not support OR, this allows IN entity_ids: [scene.channel_id, scene.network_id, scene.parent_network_id, scene.studio_id].filter(Boolean), // manticore does not support OR, this allows IN
actor_ids: scene.actors.map((actor) => actor.f1), actor_ids: scene.actors.map((actor) => actor.f1), // don't include aliases in ID or they would show up in filters
actors: scene.actors.map((actor) => actor.f2).join(), actors: Array.from(new Set([...scene.actors.map((actor) => actor.f2), ...scene.actors_aliases.map((actor) => actor.f2)])).join(),
tag_ids: scene.tags.map((tag) => tag.f1), tag_ids: scene.tags.map((tag) => tag.f1),
tags: flatTags.join(' '), // only make top tags searchable to minimize cluttered results tags: flatTags.join(' '), // only make top tags searchable to minimize cluttered results
movie_ids: scene.movies.map((movie) => movie.f1), movie_ids: scene.movies.map((movie) => movie.f1),
@@ -470,11 +474,13 @@ export async function syncQueue() {
logger[process.tasks > 0 ? 'info' : 'verbose'](`Processed ${tasks.length} sync items`); logger[process.tasks > 0 ? 'info' : 'verbose'](`Processed ${tasks.length} sync items`);
} }
CronJob.from({ export function initSyncCron() {
cronTime: config.sync.crontab, CronJob.from({
async onTick() { cronTime: config.sync.crontab,
syncQueue(); async onTick() {
}, syncQueue();
start: config.sync.enabled, },
runOnInit: true, start: config.sync.enabled,
}); runOnInit: true,
});
}