From 5ed7c611e9cac18fcde6751292a2d8d5fca6427f Mon Sep 17 00:00:00 2001 From: DebaucheryLibrarian Date: Tue, 9 Jun 2026 01:06:45 +0200 Subject: [PATCH] Syncing new actors to web. --- src/actors.js | 2 ++ src/update-search.js | 11 +++++++++++ 2 files changed, 13 insertions(+) diff --git a/src/actors.js b/src/actors.js index 6619ed1b..7a1d274f 100755 --- a/src/actors.js +++ b/src/actors.js @@ -30,6 +30,7 @@ const { toBaseReleases } = require('./deep'); const { associateAvatars, flushOrphanedMedia } = require('./media'); const { fetchEntitiesBySlug } = require('./entities'); const { deleteScenes } = require('./releases'); +const { updateActorSearch } = require('./update-search'); const actorsCommon = import('../common/actors.mjs'); // eslint-disable-line import/extensions, import/no-relative-packages const geoCommon = import('../common/geo.mjs'); // eslint-disable-line import/extensions, import/no-relative-packages @@ -981,6 +982,7 @@ async function getOrCreateActors(baseActors, batchId) { await storeProfiles(newActorProfiles); if (Array.isArray(newActors)) { + await updateActorSearch(newActors.map((actor) => actor.id)); return newActors.concat(existingActors); } diff --git a/src/update-search.js b/src/update-search.js index 18b3b389..bb098ff1 100644 --- a/src/update-search.js +++ b/src/update-search.js @@ -6,6 +6,10 @@ const unprint = require('unprint'); const knex = require('./knex'); async function syncWeb(domain, ids) { + if (!ids || ids.length === 0) { + return; + } + await knex('sync').insert({ domain, item_ids: ids }); if (config.webApi.enabled) { @@ -31,7 +35,14 @@ async function updateMovieSearch(releaseIds) { await syncWeb('movie', releaseIds); } +async function updateActorSearch(actorIds) { + await knex.raw('REFRESH MATERIALIZED VIEW actors_meta;'); + + await syncWeb('actor', actorIds); +} + module.exports = { updateSceneSearch, updateMovieSearch, + updateActorSearch, };