Separate the tests to each part os the public api of the RotatingLogs.

packages/lib/BaseApplication.ts

@@ -59,6 +59,8 @@ import Resource from './models/Resource';
 import { ProfileConfig } from './services/profileConfig/types';
 import initProfile from './services/profileConfig/initProfile';
 
+import RotatingLogs from './RotatingLogs';
+
 const appLogger: LoggerWrapper = Logger.create('App');
 
 // const ntpClient = require('./vendor/ntp-client');
@@ -85,6 +87,8 @@ export default class BaseApplication {
 
 	protected store_: Store<any> = null;
 
+	private rotatingLogs: RotatingLogs;
+
 	public constructor() {
 		this.eventEmitter_ = new EventEmitter();
 		this.decryptionWorker_resourceMetadataButNotBlobDecrypted = this.decryptionWorker_resourceMetadataButNotBlobDecrypted.bind(this);
@@ -927,6 +931,18 @@ export default class BaseApplication {
 
 		await MigrationService.instance().run();
 
+		this.rotatingLogs = new RotatingLogs(profileDir);
+		const processLogs = async () => {
+			try {
+				await this.rotatingLogs.cleanActiveLogFile();
+				await this.rotatingLogs.deleteNonActiveLogFiles();
+			} catch (error) {
+				appLogger.error(error);
+			}
+		};
+		shim.setTimeout(() => { void processLogs(); }, 60000);
+		shim.setInterval(() => { void processLogs(); }, 24 * 60 * 60 * 1000);
+
 		return argv;
 	}
 }

packages/lib/RotatingLogs.test.ts

@@ -0,0 +1,45 @@
+import { writeFile, readdir, remove } from 'fs-extra';
+import { createTempDir, msleep } from './testing/test-utils';
+import RotatingLogs from './RotatingLogs';
+
+const createTestLogFile = async (dir: string) => {
+	await writeFile(`${dir}/log.txt`, 'some content');
+};
+
+describe('RotatingLogs', () => {
+	test('should rename log.txt to log-TIMESTAMP.txt', async () => {
+		let dir: string;
+		try {
+			dir = await createTempDir();
+			await createTestLogFile(dir);
+			let files: string[] = await readdir(dir);
+			expect(files.find(file => file.match(/^log.txt$/gi))).toBeTruthy();
+			expect(files.length).toBe(1);
+			const rotatingLogs: RotatingLogs = new RotatingLogs(dir, 1, 1);
+			await rotatingLogs.cleanActiveLogFile();
+			files = await readdir(dir);
+			expect(files.find(file => file.match(/^log.txt$/gi))).toBeFalsy();
+			expect(files.find(file => file.match(/^log-[0-9]+.txt$/gi))).toBeTruthy();
+			expect(files.length).toBe(1);
+		} finally {
+			await remove(dir);
+		}
+	});
+
+	test('should delete inative log file after 1ms', async () => {
+		let dir: string;
+		try {
+			dir = await createTempDir();
+			await createTestLogFile(dir);
+			const rotatingLogs: RotatingLogs = new RotatingLogs(dir, 1, 1);
+			await rotatingLogs.cleanActiveLogFile();
+			await msleep(1);
+			await rotatingLogs.deleteNonActiveLogFiles();
+			const files = await readdir(dir);
+			expect(files.find(file => file.match(/^log-[0-9]+.txt$/gi))).toBeFalsy();
+			expect(files.length).toBe(0);
+		} finally {
+			await remove(dir);
+		}
+	});
+});

packages/lib/RotatingLogs.ts

@@ -0,0 +1,46 @@
+import shim from './shim';
+import { Stat } from './fs-driver-base';
+
+export default class RotatingLogs {
+
+	private logFilesDir: string;
+	private maxFileSize: number = 1024 * 1024 * 100;
+	private inactiveMaxAge: number = 90 * 24 * 60 * 60 * 1000;
+
+	public constructor(logFilesDir: string, maxFileSize: number = null, inactiveMaxAge: number = null) {
+		this.logFilesDir = logFilesDir;
+		if (maxFileSize) this.maxFileSize = maxFileSize;
+		if (inactiveMaxAge) this.inactiveMaxAge = inactiveMaxAge;
+	}
+
+	public async cleanActiveLogFile() {
+		const stats: Stat = await this.fsDriver().stat(this.logFileFullpath());
+		if (stats.size >= this.maxFileSize) {
+			const newLogFile: string = this.logFileFullpath(this.getNameToNonActiveLogFile());
+			await this.fsDriver().move(this.logFileFullpath(), newLogFile);
+		}
+	}
+
+	private getNameToNonActiveLogFile(): string {
+		return `log-${Date.now()}.txt`;
+	}
+
+	public async deleteNonActiveLogFiles() {
+		const files: Stat[] = await this.fsDriver().readDirStats(this.logFilesDir);
+		for (const file of files) {
+			if (!file.path.match(/^log-[0-9]+.txt$/gi)) continue;
+			const ageOfTheFile: number = Date.now() - file.birthtime;
+			if (ageOfTheFile >= this.inactiveMaxAge) {
+				await this.fsDriver().remove(this.logFileFullpath(file.path));
+			}
+		}
+	}
+
+	private logFileFullpath(fileName = 'log.txt'): string {
+		return `${this.logFilesDir}/${fileName}`;
+	}
+
+	private fsDriver() {
+		return shim.fsDriver();
+	}
+}