Added try-catch
gitea/salix/pipeline/head Something is wrong with the build of this commit
Details
gitea/salix/pipeline/head Something is wrong with the build of this commit
Details
This commit is contained in:
parent
4ef540c8f3
commit
ea4f561bcf
|
@ -19,6 +19,7 @@ module.exports = Self => {
|
|||
Self.downloadImages = async() => {
|
||||
const models = Self.app.models;
|
||||
|
||||
let image;
|
||||
try {
|
||||
const tempPath = path.join('/tmp/salix-image');
|
||||
|
||||
|
@ -26,7 +27,7 @@ module.exports = Self => {
|
|||
await fs.mkdir(tempPath, {recursive: true});
|
||||
|
||||
const timer = setInterval(async() => {
|
||||
const image = await Self.findOne({where: {error: null}});
|
||||
image = await Self.findOne({where: {error: null}});
|
||||
|
||||
// Exit loop
|
||||
if (!image) return clearInterval(timer);
|
||||
|
@ -61,17 +62,25 @@ module.exports = Self => {
|
|||
await errorHandler(image.itemFk, error, filePath);
|
||||
}
|
||||
});
|
||||
}, 1000);
|
||||
}, 1500);
|
||||
} catch (error) {
|
||||
await errorHandler(image.itemFk, error);
|
||||
}
|
||||
|
||||
async function errorHandler(rowId, error, filePath) {
|
||||
const row = await Self.findById(rowId);
|
||||
await row.updateAttribute('error', error);
|
||||
try {
|
||||
const row = await Self.findById(rowId);
|
||||
|
||||
if (filePath)
|
||||
await fs.unlink(filePath);
|
||||
if (!row)
|
||||
throw new Error(`Could not update due error ${error}`);
|
||||
|
||||
await row.updateAttribute('error', error);
|
||||
|
||||
if (filePath)
|
||||
await fs.unlink(filePath);
|
||||
} catch (error) {
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
};
|
||||
};
|
||||
|
|
Loading…
Reference in New Issue