import { InteractionManager } from 'react-native';
import { sanitizedRaw } from '@nozbe/watermelondb/RawRecord';
import { Q } from '@nozbe/watermelondb';

import RocketChat from '../rocketchat';
import reduxStore from '../createStore';
import * as actions from '../../actions';
import settings from '../../constants/settings';
import log from '../../utils/log';
import database from '../database';
import protectedFunction from './helpers/protectedFunction';
import fetch from '../../utils/fetch';

const serverInfoKeys = ['Site_Name', 'UI_Use_Real_Name', 'FileUpload_MediaTypeWhiteList', 'FileUpload_MaxFileSize'];

const serverInfoUpdate = async(serverInfo, iconSetting) => {
	const serversDB = database.servers;
	const serverId = reduxStore.getState().server.server;

	let info = serverInfo.reduce((allSettings, setting) => {
		if (setting._id === 'Site_Name') {
			return { ...allSettings, name: setting.valueAsString };
		}
		if (setting._id === 'UI_Use_Real_Name') {
			return { ...allSettings, useRealName: setting.valueAsBoolean };
		}
		if (setting._id === 'FileUpload_MediaTypeWhiteList') {
			return { ...allSettings, FileUpload_MediaTypeWhiteList: setting.valueAsString };
		}
		if (setting._id === 'FileUpload_MaxFileSize') {
			return { ...allSettings, FileUpload_MaxFileSize: setting.valueAsNumber };
		}
		return allSettings;
	}, {});

	if (iconSetting) {
		const iconURL = `${ serverId }/${ iconSetting.value.url || iconSetting.value.defaultUrl }`;
		info = { ...info, iconURL };
	}

	await serversDB.action(async() => {
		try {
			const serversCollection = serversDB.collections.get('servers');
			const server = await serversCollection.find(serverId);

			await server.update((record) => {
				Object.assign(record, info);
			});
		} catch (e) {
			log(e);
		}
	});
};

export function getSetting({ server, setting }) {
	return new Promise(async(resolve, reject) => {
		try {
			const result = await fetch(`${ server }/api/v1/settings.public?query={"_id":{"$in":["${ setting }"]}}`).then(response => response.json());

			if (result.success && result.settings.length) {
				const [{ value }] = result.settings;
				return resolve(value);
			}
		} catch (e) {
			log(e);
		}

		return reject();
	});
}

export async function setSettings() {
	const db = database.active;
	const settingsCollection = db.collections.get('settings');
	const settingsRecords = await settingsCollection.query().fetch();
	const parsed = Object.values(settingsRecords).map(item => ({
		_id: item.id,
		valueAsString: item.valueAsString,
		valueAsBoolean: item.valueAsBoolean,
		valueAsNumber: item.valueAsNumber,
		_updatedAt: item._updatedAt
	}));
	reduxStore.dispatch(actions.setAllSettings(RocketChat.parseSettings(parsed.slice(0, parsed.length))));
}

export default async function() {
	try {
		const db = database.active;
		const settingsParams = JSON.stringify(Object.keys(settings));
		// RC 0.60.0
		const result = await fetch(`${ this.sdk.client.host }/api/v1/settings.public?query={"_id":{"$in":${ settingsParams }}}`).then(response => response.json());

		if (!result.success) {
			return;
		}
		const data = result.settings || [];
		const filteredSettings = this._prepareSettings(data.filter(item => item._id !== 'Assets_favicon_512'));
		const filteredSettingsIds = filteredSettings.map(s => s._id);

		reduxStore.dispatch(actions.addSettings(this.parseSettings(filteredSettings)));
		InteractionManager.runAfterInteractions(async() => {
			// filter server info
			const serverInfo = filteredSettings.filter(i1 => serverInfoKeys.includes(i1._id));
			const iconSetting = data.find(item => item._id === 'Assets_favicon_512');
			await serverInfoUpdate(serverInfo, iconSetting);

			await db.action(async() => {
				const settingsCollection = db.collections.get('settings');
				const allSettingsRecords = await settingsCollection
					.query(Q.where('id', Q.oneOf(filteredSettingsIds)))
					.fetch();

				// filter settings
				let settingsToCreate = filteredSettings.filter(i1 => !allSettingsRecords.find(i2 => i1._id === i2.id));
				let settingsToUpdate = allSettingsRecords.filter(i1 => filteredSettings.find(i2 => i1.id === i2._id));

				// Create
				settingsToCreate = settingsToCreate.map(setting => settingsCollection.prepareCreate(protectedFunction((s) => {
					s._raw = sanitizedRaw({ id: setting._id }, settingsCollection.schema);
					Object.assign(s, setting);
				})));

				// Update
				settingsToUpdate = settingsToUpdate.map((setting) => {
					const newSetting = filteredSettings.find(s => s._id === setting.id);
					return setting.prepareUpdate(protectedFunction((s) => {
						Object.assign(s, newSetting);
					}));
				});

				const allRecords = [
					...settingsToCreate,
					...settingsToUpdate
				];

				try {
					await db.batch(...allRecords);
				} catch (e) {
					log(e);
				}
				return allRecords.length;
			});
		});
	} catch (e) {
		log(e);
	}
}