let pageVisitedCollection;
let messageCollection;
let roomCollection;

const roomIdByToken = {};

const batchSize = 5000;

async function migrateHistory(total, current) {
	console.log(`Livechat history migration ${ current }/${ total }`);

	const items = await pageVisitedCollection.find({}).limit(batchSize).toArray();

	const tokens = items.filter((item) => item.token && !roomIdByToken[item.token]).map((item) => item.token);
	const rooms = await roomCollection.find({
		'v.token': {
			$in: tokens
		}
	}, {
		fields: {
			'v.token': 1
		}
	}).toArray();

	rooms.forEach((room) => {
		roomIdByToken[room.v.token] = room._id;
	});

	const actions = items.reduce((result, item) => {
		const msg = {
			t: 'livechat_navigation_history',
			rid: roomIdByToken[item.token] || null, // prevent from being `undefined`
			ts: item.ts,
			msg: `${ item.page.title } - ${ item.page.location.href }`,
			u: {
				_id : 'rocket.cat',
				username : 'rocket.cat'
			},
			groupable : false,
			navigation : {
				page: item.page,
				token: item.token
			}
		};
		if (!roomIdByToken[item.token] && item.expireAt) {
			msg.expireAt = item.expireAt;
		}
		result.insert.push(msg);
		result.remove.push(item._id);

		return result;
	}, { insert: [], remove: [] });

	const batch = Promise.all([
		messageCollection.insertMany(actions.insert),
		pageVisitedCollection.removeMany({ _id: { $in: actions.remove } })
	]);
	if (actions.remove.length === batchSize) {
		await batch;
		return migrateHistory(total, current + batchSize);
	}

	return batch;
}


RocketChat.Migrations.add({
	version: 123,
	up() {
		pageVisitedCollection = RocketChat.models.LivechatPageVisited.model.rawCollection();
		messageCollection = RocketChat.models.Messages.model.rawCollection();
		roomCollection = RocketChat.models.Rooms.model.rawCollection();

		/*
		 * Move visitor navigation history to messages
		 */
		Meteor.setTimeout(async() => {
			const pages = pageVisitedCollection.find({});
			const total = await pages.count();
			await pages.close();

			console.log('Migrating livechat visitors navigation history to livechat messages. This might take a long time ...');

			await migrateHistory(total, 0);

			console.log('Livechat visitors navigation history migration finished.');
		}, 1000);
	}
});