boiii/traxxx
1
0
Fork 0
forked from DebaucheryLibrarian/traxxx
Code Issues Pull Requests Projects Releases Wiki Activity

Enforcing profile ID in actors_avatars.

Browse Source
This commit is contained in:
DebaucheryLibrarian
2026-07-23 23:55:34 +02:00
parent 14ad2fd0f8
commit d7e0171b2f
2 changed files with 33 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
migrations/20260723120000_actors_avatars_profile_not_null.js Normal file
View File

@@ -0,0 +1,24 @@
exports.up = async function(knex) {
const orphanedAvatars = await knex('actors_avatars')
.whereNull('profile_id');
if (orphanedAvatars.length > 0) {
console.log(`Deleting ${orphanedAvatars.length} actors_avatars rows with no profile_id`);
}
await knex('actors_avatars')
.whereNull('profile_id')
.delete();
await knex.raw(`
DROP INDEX IF EXISTS unique_main_avatars;
ALTER TABLE actors_avatars ALTER COLUMN profile_id SET NOT NULL;
`);
};
exports.down = async function(knex) {
await knex.raw(`
ALTER TABLE actors_avatars ALTER COLUMN profile_id DROP NOT NULL;
CREATE UNIQUE INDEX unique_main_avatars ON actors_avatars (actor_id) WHERE (profile_id IS NULL);
`);
};

11
src/actors.js
View File

@@ -611,8 +611,15 @@ async function upsertProfiles(profiles) {
media_id: profile.avatarMediaId,
}));
if (avatars.length > 0) {
await batchInsert('actors_avatars', avatars, { conflict: false });
const resolvedAvatars = avatars.filter((avatar) => !!avatar.profile_id);
const unresolvedAvatars = avatars.filter((avatar) => !avatar.profile_id);
unresolvedAvatars.forEach((avatar) => {
logger.warn(`Skipping avatar for actor ${avatar.actor_id} (${avatar.media_id}), no profile could be resolved`);
});
if (resolvedAvatars.length > 0) {
await batchInsert('actors_avatars', resolvedAvatars, { conflict: false });
}
}
}