Compare commits

...

2 Commits

Author SHA1 Message Date
DebaucheryLibrarian
2ef1ef80e4 1.253.2 2026-06-09 01:06:46 +02:00
DebaucheryLibrarian
5ed7c611e9 Syncing new actors to web. 2026-06-09 01:06:45 +02:00
4 changed files with 16 additions and 3 deletions

4
package-lock.json generated
View File

@@ -1,12 +1,12 @@
{ {
"name": "traxxx", "name": "traxxx",
"version": "1.253.1", "version": "1.253.2",
"lockfileVersion": 3, "lockfileVersion": 3,
"requires": true, "requires": true,
"packages": { "packages": {
"": { "": {
"name": "traxxx", "name": "traxxx",
"version": "1.253.1", "version": "1.253.2",
"license": "ISC", "license": "ISC",
"dependencies": { "dependencies": {
"@aws-sdk/client-s3": "^3.458.0", "@aws-sdk/client-s3": "^3.458.0",

View File

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

View File

@@ -30,6 +30,7 @@ const { toBaseReleases } = require('./deep');
const { associateAvatars, flushOrphanedMedia } = require('./media'); const { associateAvatars, flushOrphanedMedia } = require('./media');
const { fetchEntitiesBySlug } = require('./entities'); const { fetchEntitiesBySlug } = require('./entities');
const { deleteScenes } = require('./releases'); 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 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 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); await storeProfiles(newActorProfiles);
if (Array.isArray(newActors)) { if (Array.isArray(newActors)) {
await updateActorSearch(newActors.map((actor) => actor.id));
return newActors.concat(existingActors); return newActors.concat(existingActors);
} }

View File

@@ -6,6 +6,10 @@ const unprint = require('unprint');
const knex = require('./knex'); const knex = require('./knex');
async function syncWeb(domain, ids) { async function syncWeb(domain, ids) {
if (!ids || ids.length === 0) {
return;
}
await knex('sync').insert({ domain, item_ids: ids }); await knex('sync').insert({ domain, item_ids: ids });
if (config.webApi.enabled) { if (config.webApi.enabled) {
@@ -31,7 +35,14 @@ async function updateMovieSearch(releaseIds) {
await syncWeb('movie', releaseIds); await syncWeb('movie', releaseIds);
} }
async function updateActorSearch(actorIds) {
await knex.raw('REFRESH MATERIALIZED VIEW actors_meta;');
await syncWeb('actor', actorIds);
}
module.exports = { module.exports = {
updateSceneSearch, updateSceneSearch,
updateMovieSearch, updateMovieSearch,
updateActorSearch,
}; };