diff --git a/server/core/Reader/ReaderWorker.js b/server/core/Reader/ReaderWorker.js index ac2ea681..3b77f5b8 100644 --- a/server/core/Reader/ReaderWorker.js +++ b/server/core/Reader/ReaderWorker.js @@ -97,8 +97,7 @@ class ReaderWorker { wState.finish({path: `/tmp/${finishFilename}`}); } catch (e) { - if (this.config.branch == 'development') - console.error(e); + log(LM_ERR, e.stack); wState.set({state: 'error', error: (errMes ? errMes : e.message)}); } finally { //clean @@ -137,7 +136,6 @@ class ReaderWorker { async periodicCleanDir(dir, maxSize, timeout) { try { - log(`Start clean dir: ${dir}, maxSize=${maxSize}`); const list = await fs.readdir(dir); let size = 0; @@ -149,21 +147,20 @@ class ReaderWorker { files.push({name, stat}); } } - log(`found ${files.length} files in dir ${dir}`); + log(`clean dir ${dir}, maxSize=${maxSize}, found ${files.length} files`); files.sort((a, b) => a.stat.mtimeMs - b.stat.mtimeMs); let i = 0; while (i < files.length && size > maxSize) { const file = files[i]; - log(`rm ${dir}/${file.name}`); await fs.remove(`${dir}/${file.name}`); size -= file.stat.size; i++; } log(`removed ${i} files`); } catch(e) { - log(LM_ERR, e.message); + log(LM_ERR, e.stack); } finally { setTimeout(() => { this.periodicCleanDir(dir, maxSize, timeout);