Changed release media association existence check, added log for details.
This commit is contained in:
19
src/media.js
19
src/media.js
@@ -826,11 +826,12 @@ async function associateReleaseMedia(releases, type = 'release') {
|
||||
.reduce((acc, [releaseId, releaseBaseMedias]) => {
|
||||
releaseBaseMedias.forEach((baseMedia) => {
|
||||
const media = storedMediasById[baseMedia.id];
|
||||
const mediaId = media?.use || media?.entry?.id;
|
||||
|
||||
if (media) {
|
||||
if (mediaId) {
|
||||
acc.push({
|
||||
[`${type}_id`]: releaseId,
|
||||
media_id: media.use || media.entry.id,
|
||||
media_id: mediaId,
|
||||
});
|
||||
}
|
||||
});
|
||||
@@ -839,11 +840,19 @@ async function associateReleaseMedia(releases, type = 'release') {
|
||||
}, [])
|
||||
.filter(Boolean);
|
||||
|
||||
if (associations.length > 0) {
|
||||
await bulkInsert(`${type}s_${role}`, associations, false);
|
||||
try {
|
||||
if (associations.length > 0) {
|
||||
await bulkInsert(`${type}s_${role}`, associations, false);
|
||||
}
|
||||
} catch (error) {
|
||||
console.log(associations);
|
||||
throw error;
|
||||
}
|
||||
} catch (error) {
|
||||
logger.error(util.inspect(error.entries, null, null, { color: true }));
|
||||
if (error.entries) {
|
||||
logger.error(util.inspect(error.entries, null, null, { color: true }));
|
||||
}
|
||||
|
||||
logger.error(`Failed to store ${type} ${role}: ${error.message}`);
|
||||
}
|
||||
}, Promise.resolve());
|
||||
|
||||
Reference in New Issue
Block a user