DebaucheryLibrarian
/
traxxx
2
1
Fork 1
Code Issues 39 Pull Requests 1 Releases Wiki Activity

Compare commits

base: DebaucheryLibrarian:c9b774c4980465b563674f9abd001382043dc239
Branches Tags
DebaucheryLibrarian:master
DebaucheryLibrarian:old
DebaucheryLibrarian:experimental
...
compare: DebaucheryLibrarian:8aaf0609790e41dd09f3cf0e0600a33b32863fa8
Branches Tags
DebaucheryLibrarian:master
DebaucheryLibrarian:old
DebaucheryLibrarian:experimental

2 Commits
c9b774c498 ... 8aaf060979

Author SHA1 Message Date
DebaucheryLibrarian 8aaf060979 1.167.10 2021-02-05 03:37:10 +01:00
DebaucheryLibrarian 688863d16e Catching media storage errors to prevent full crash. 2021-02-05 03:37:04 +01:00
3 changed files with 25 additions and 21 deletions
Show Stats Expand all files Collapse all files

2
package-lock.json generated
View File

@ -1,6 +1,6 @@
{
"name": "traxxx",
"version": "1.167.9",
"version": "1.167.10",
"lockfileVersion": 1,
"requires": true,
"dependencies": {

2
package.json
View File

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

42
src/media.js
View File

@ -731,29 +731,33 @@ async function associateReleaseMedia(releases, type = 'release') {
return;
}
const storedMedias = await storeMedias(baseMedias);
const storedMediasById = itemsByKey(storedMedias, 'id');
try {
const storedMedias = await storeMedias(baseMedias);
const storedMediasById = itemsByKey(storedMedias, 'id');
const associations = Object
.entries(baseMediasByReleaseId)
.reduce((acc, [releaseId, releaseBaseMedias]) => {
releaseBaseMedias.forEach((baseMedia) => {
const media = storedMediasById[baseMedia.id];
const associations = Object
.entries(baseMediasByReleaseId)
.reduce((acc, [releaseId, releaseBaseMedias]) => {
releaseBaseMedias.forEach((baseMedia) => {
const media = storedMediasById[baseMedia.id];
if (media) {
acc.push({
[`${type}_id`]: releaseId,
media_id: media.use || media.entry.id,
});
}
});
if (media) {
acc.push({
[`${type}_id`]: releaseId,
media_id: media.use || media.entry.id,
});
}
});
return acc;
}, [])
.filter(Boolean);
return acc;
}, [])
.filter(Boolean);
if (associations.length > 0) {
await bulkInsert(`${type}s_${role}`, associations, false);
if (associations.length > 0) {
await bulkInsert(`${type}s_${role}`, associations, false);
}
} catch (error) {
logger.error(`Failed to store ${type} ${role}: ${error.message}`);
}
}, Promise.resolve());
}