/**
 * Tests for server/modlog.ts
 * Written by Annika
 */

'use strict';

const modlog = Config.usesqlite ? new (require('../../.server-dist/modlog')).Modlog('/dev/null', ':memory:') : null;
const assert = require('assert').strict;

Config.usesqlitemodlog = true;

const DATASET_A = [
	{action: 'ROOMBAN', userid: 'sometroll', ip: '127.0.0.1', loggedBy: 'annika', note: 'FIRST ENTRY', time: 1},
	{action: 'LOCK', userid: 'sometroll', ip: '127.0.0.1', loggedBy: 'annika', note: 'ENTRY 2', time: 2},
	{action: 'ROOMBAN', userid: 'sometroll', ip: '127.0.0.1', loggedBy: 'annika', note: 'ENTRY 3', time: 3},
	{action: 'WEEKLOCK', userid: 'sometroll', ip: '127.0.0.1', loggedBy: 'annika', note: 'this entry has many parts', time: 4},
	{action: 'ROOMBAN', userid: 'sometroll', ip: '127.0.0.1', loggedBy: 'annika', note: 'ENTRY 5', time: 5},
	{action: 'ROOMBAN', userid: 'sometroll', ip: '127.0.0.1', loggedBy: 'annika', note: 'ENTRY 6', time: 6},
	{action: 'MUTE', userid: 'sometroll', ip: '127.0.0.1', loggedBy: 'annika', note: 'ENTRY 7', time: 7},
	{action: 'ROOMBAN', userid: 'sometroll', ip: '127.0.0.1', loggedBy: 'annika', note: 'ENTRY 8', time: 8},
	{action: 'ROOMBAN', userid: 'sometroll', ip: '127.0.0.1', loggedBy: 'annika', note: 'LAST ENTRY', time: 9},
];

const DATASET_B = [
	{action: 'ROOMBAN', userid: 'sometroll', ip: '127.0.0.1', loggedBy: 'annika'},
	{action: 'ROOMBAN', userid: 'sometroll', ip: '127.0.0.1', loggedBy: 'annika'},
	{action: 'POLL', loggedBy: 'annika'},
	{action: 'ROOMBAN', userid: 'sometroll', ip: '127.0.0.1', loggedBy: 'annika'},
	{action: 'TOUR START', loggedBy: 'annika'},
];

function lastLine(database, roomid) {
	return database.prepare(
		`SELECT * FROM modlog WHERE roomid = ? ORDER BY modlog_id DESC LIMIT 1`
	).get(roomid);
}

(Config.usesqlite ? describe : describe.skip)('Modlog', () => {
	describe.skip('Modlog#prepareSQLSearch', () => {
		it('should respect the maxLines parameter', () => {
			const query = modlog.prepareSQLSearch(['lobby'], 1337, false, {});
			assert(query.statement.source.endsWith('LIMIT ?'));
			assert(query.args.includes(1337));

			const noMaxLines = modlog.prepareSQLSearch(['lobby'], 0, false, {}).statement;
			assert(!noMaxLines.source.toUpperCase().includes('LIMIT'));
		});

		it('should attempt to respect onlyPunishments', () => {
			const query = modlog.prepareSQLSearch(['lobby'], 0, true, {});
			assert(query.statement.source.includes('action IN ('));
			assert(query.args.includes('WEEKLOCK'));
		});
	});

	(Config.usesqlite ? describe : describe.skip)('Modlog#getSharedID', () => {
		it('should detect shared modlogs', () => {
			assert(modlog.getSharedID('battle-gen8randombattle-42'));
			assert(modlog.getSharedID('groupchat-annika-shitposting'));
			assert(modlog.getSharedID('help-mePleaseIAmTrappedInAUnitTestFactory'));

			assert(!modlog.getSharedID('1v1'));
			assert(!modlog.getSharedID('development'));
		});
	});

	(Config.usesqlite ? describe : describe.skip)('Modlog#write', () => {
		it('should write messages serially to the modlog', async () => {
			modlog.initialize('development');
			modlog.write('development', {note: 'This message is logged first', action: 'UNITTEST'});
			modlog.write('development', {note: 'This message is logged second', action: 'UNITTEST'});
			const lines = modlog.database.prepare(
				// Order by modlog_id since the writes most likely happen at the same second
				`SELECT * FROM modlog WHERE roomid = 'development' ORDER BY modlog_id DESC LIMIT 2`
			).all();

			assert.equal(lines.pop().note, 'This message is logged first');
			assert.equal(lines.pop().note, 'This message is logged second');
		});

		it('should throw an error when writing to a destroyed modlog stream', () => {
			modlog.initialize('somedeletedroom');
			assert.doesNotThrow(() => modlog.write('somedeletedroom', {action: 'ROOMBAN', userid: 'sometroll', ip: '127.0.0.1', staff: 'annika'}));
			modlog.destroy('somedeletedroom');
			assert.throws(() => modlog.write('somedeletedroom', {action: 'ROOMBAN', userid: 'sometroll', ip: '127.0.0.1', staff: 'annika'}));
		});

		it('should throw an error when writing to an uninitialized modlog stream', () => {
			assert.throws(() => modlog.write('lmaothisroomisntreal', {action: 'ROOMBAN', userid: 'sometroll', ip: '127.0.0.1', staff: 'annika'}));
			modlog.initialize('itsrealnow');
			assert.doesNotThrow(() => modlog.write('itsrealnow', {action: 'ROOMBAN', userid: 'sometroll', ip: '127.0.0.1', staff: 'annika'}));
		});


		it('should use overrideID if specified', async () => {
			modlog.initialize('battle-gen8randombattle-1337');
			modlog.write('battle-gen8randombattle-1337', {note: "I'm testing overrideID", action: 'UNITTEST'}, 'heyadora');
			const line = lastLine(modlog.database, 'battle-gen8randombattle-1337');
			assert.equal(line.note, "I'm testing overrideID");
			assert.equal(line.visual_roomid, 'heyadora');
		});
	});

	(Config.usesqlite ? describe : describe.skip)("Modlog#rename", () => {
		it('should rename modlogs', async () => {
			const entry = {note: 'This is in a modlog that will be renamed!', action: 'UNITTEST'};

			modlog.initialize('oldroom');
			modlog.write('oldroom', entry);
			await modlog.rename('oldroom', 'newroom');
			const line = lastLine(modlog.database, 'newroom');

			assert.equal(entry.action, line.action);
			assert.equal(entry.note, line.note);

			const newEntry = {note: 'This modlog has been renamed!', action: 'UNITTEST'};
			modlog.write('newroom', newEntry);

			const newLine = lastLine(modlog.database, 'newroom');

			assert.equal(newEntry.action, newLine.action);
			assert.equal(newEntry.note, newLine.note);
		});
	});

	// Skipped until SQL searching is properly implemented
	describe.skip('Modlog#search', () => {
		before(async () => {
			modlog.initialize('readingtest');
			modlog.initialize('readingtest2');
			for (const entry of DATASET_A) {
				modlog.write('readingtest', entry);
			}
			for (const entry of DATASET_B) {
				modlog.write('readingtest2', entry);
			}
		});

		it('should be capable of reading the entire modlog file', async () => {
			const results = await modlog.search('readingtest2', {}, 10000);
			assert.equal(results.results.length, DATASET_B.length);
		});

		it('user searches should be case-insensitive', async () => {
			const notExactUpper = await modlog.search('readingtest', {user: {search: 'sOmETRoll', isExact: false}});
			const notExactLower = await modlog.search('readingtest', {user: {search: 'sometroll', isExact: false}});
			const exactUpper = await modlog.search('readingtest', {user: {search: 'sOMEtroLL', isExact: true}});
			const exactLower = await modlog.search('readingtest', {user: {search: 'sometroll', isExact: true}});

			assert.deepEqual(notExactUpper.results, notExactLower.results);
			assert.deepEqual(exactUpper.results, exactLower.results);
		});

		it('note searches should respect isExact', async () => {
			const notExact = await modlog.search('readingtest', {note: {searches: ['has man'], isExact: false}});
			const exact = await modlog.search('readingtest', {note: {searches: ['has man'], isExact: true}});
			assert.equal(notExact.results.length, 0);
			assert(exact.results.length);
		});

		it.skip('should be LIFO (last-in, first-out)', async () => {
			modlog.initialize('lifotest');

			modlog.write('lifotest', {note: 'firstwrite', action: 'UNITTEST', timestamp: 1});
			modlog.write('lifotest', {note: 'secondwrite', action: 'UNITTEST', timestamp: 2});
			const search = await modlog.search('lifotest');
			assert.equal(search.results.length, 2);

			assert(search.results[0].note !== 'secondwrite');
			assert(search.results[0].note === 'firstwrite');

			assert(search.results[1].note !== 'firstwrite');
			assert(search.results[1].note === 'secondwrite');
		});

		it('should support limiting the number of responses', async () => {
			const unlimited = await modlog.search('readingtest');
			const limited = await modlog.search('readingtest', {}, 5);

			assert.equal(limited.results.length, 5);
			assert(unlimited.results.length > limited.results.length);

			assert(limited.results[0].note.includes('LAST ENTRY'));
			assert(unlimited.results[0].note.includes('LAST ENTRY'));

			const limitedLast = limited.results.pop().note;
			const unlimitedLast = unlimited.results.pop().note;

			assert(!limitedLast.includes('FIRST ENTRY'));
			assert(unlimitedLast.includes('FIRST ENTRY'));
		});

		it('should support filtering out non-punishment-related logs', async () => {
			const all = (await modlog.search('readingtest2', {}, 20, false)).results;
			const onlyPunishments = (await modlog.search('readingtest2', {}, 20, true)).results;

			assert(all.length > onlyPunishments.length);
			assert.equal(
				onlyPunishments.filter(result => result.action === 'ROOMBAN').length,
				onlyPunishments.length
			);
		});
	});
});