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",
"version": "1.253.1",
"version": "1.253.2",
"lockfileVersion": 3,
"requires": true,
"packages": {
"": {
"name": "traxxx",
"version": "1.253.1",
"version": "1.253.2",
"license": "ISC",
"dependencies": {
"@aws-sdk/client-s3": "^3.458.0",

View File

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

View File

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

View File

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