Syncing new actors to web.

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);
 	}
 

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,
 };