-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
fix: lack of auto-cleaning mechanism for logs (janhq#2003)
- Loading branch information
Showing
2 changed files
with
69 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,67 @@ | ||
import { getJanDataFolderPath } from '@janhq/core/node' | ||
import * as fs from 'fs' | ||
import * as path from 'path' | ||
|
||
export function cleanLogs( | ||
maxFileSizeBytes?: number | undefined, | ||
daysToKeep?: number | undefined, | ||
delayMs?: number | undefined | ||
): void { | ||
const size = maxFileSizeBytes ?? 1 * 1024 * 1024 // 1 MB | ||
const days = daysToKeep ?? 7 // 7 days | ||
const delays = delayMs ?? 10000 // 10 seconds | ||
const logDirectory = path.join(getJanDataFolderPath(), 'logs') | ||
|
||
// Perform log cleaning | ||
const currentDate = new Date() | ||
fs.readdir(logDirectory, (err, files) => { | ||
if (err) { | ||
console.error('Error reading log directory:', err) | ||
return | ||
} | ||
|
||
files.forEach((file) => { | ||
const filePath = path.join(logDirectory, file) | ||
fs.stat(filePath, (err, stats) => { | ||
if (err) { | ||
console.error('Error getting file stats:', err) | ||
return | ||
} | ||
|
||
// Check size | ||
if (stats.size > size) { | ||
fs.unlink(filePath, (err) => { | ||
if (err) { | ||
console.error('Error deleting log file:', err) | ||
return | ||
} | ||
console.log( | ||
`Deleted log file due to exceeding size limit: ${filePath}` | ||
) | ||
}) | ||
} else { | ||
// Check age | ||
const creationDate = new Date(stats.ctime) | ||
const daysDifference = Math.floor( | ||
(currentDate.getTime() - creationDate.getTime()) / | ||
(1000 * 3600 * 24) | ||
) | ||
if (daysDifference > days) { | ||
fs.unlink(filePath, (err) => { | ||
if (err) { | ||
console.error('Error deleting log file:', err) | ||
return | ||
} | ||
console.log(`Deleted old log file: ${filePath}`) | ||
}) | ||
} | ||
} | ||
}) | ||
}) | ||
}) | ||
|
||
// Schedule the next execution with doubled delays | ||
setTimeout(() => { | ||
cleanLogs(maxFileSizeBytes, daysToKeep, delays * 2) | ||
}, delays) | ||
} |