import HttpClient from './HttpClient';
import Logger from '../utils/Logger';
import { IRegistryInfo } from '../models/IRegistryInfo';
import { ICaptainDefinition } from '../models/ICaptainDefinition';
import { IVersionInfo } from '../models/IVersionInfo';
import { IAppDef } from '../models/AppDef';
import * as fs from 'fs-extra';
import IBuildLogs from '../models/IBuildLogs';

export default class ApiManager {
	private static lastKnownPassword: string = process.env.REACT_APP_DEFAULT_PASSWORD
		? process.env.REACT_APP_DEFAULT_PASSWORD + ''
		: 'captain42';
	private static authToken: string = !!process.env.REACT_APP_IS_DEBUG
		? 'eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJkYXRhIjp7Im5hbWVzcGFjZSI6ImNhcHRhaW4iLCJ0b2tlblZlcnNpb24iOiI5NmRjM2U1MC00ZDk3LTRkNmItYTIzMS04MmNiZjY0ZTA2NTYifSwiaWF0IjoxNTQ1OTg0MDQwLCJleHAiOjE1ODE5ODQwNDB9.uGJyhb2JYsdw9toyMKX28bLVuB0PhnS2POwEjKpchww'
		: '';

	private http: HttpClient;

	constructor(baseUrl: string, private authTokenSaver: (authToken: string) => Promise<void>) {
		const self = this;

		this.http = new HttpClient(baseUrl, ApiManager.authToken, function() {
			return self.getAuthToken(ApiManager.lastKnownPassword);
		});
	}

	destroy() {
		this.http.destroy();
	}

	setAuthToken(authToken: string) {
		ApiManager.authToken = authToken;
		this.http.setAuthToken(authToken);
	}

	static isLoggedIn() {
		return !!ApiManager.authToken;
	}

	getAuthToken(password: string) {
		const http = this.http;
		ApiManager.lastKnownPassword = password;
		let authTokenFetched = '';

		const self = this;
		return Promise.resolve() //
			.then(http.fetch(http.POST, '/login', { password }))
			.then(function(data) {
				authTokenFetched = data.token;
				self.setAuthToken(authTokenFetched);
				return authTokenFetched;
			})
			.then(self.authTokenSaver)
			.then(function() {
				return authTokenFetched;
			});
	}

	getCaptainInfo() {
		const http = this.http;

		return Promise.resolve() //
			.then(http.fetch(http.GET, '/user/system/info', {}));
	}

	updateRootDomain(rootDomain: string) {
		const http = this.http;

		return Promise.resolve() //
			.then(http.fetch(http.POST, '/user/system/changerootdomain', { rootDomain }));
	}

	enableRootSsl(emailAddress: string) {
		const http = this.http;

		return Promise.resolve() //
			.then(http.fetch(http.POST, '/user/system/enablessl', { emailAddress }));
	}

	forceSsl(isEnabled: boolean) {
		const http = this.http;

		return Promise.resolve() //
			.then(http.fetch(http.POST, '/user/system/forcessl', { isEnabled }));
	}

	getAllApps() {
		const http = this.http;

		return Promise.resolve() //
			.then(http.fetch(http.GET, '/user/appDefinitions', {})); // TODO user/apps/appDefinitions
	}

	fetchBuildLogs(appName: string): Promise<IBuildLogs> {
		const http = this.http;

		return Promise.resolve() //
			.then(http.fetch(http.GET, '/user/appData/' + appName, {})); // TODO user/apps/appData
	}

	uploadAppData(appName: string, file: fs.ReadStream) {
		const http = this.http;
		return Promise.resolve() //
			.then(http.fetch(http.POST_DATA, '/user/appData/' + appName + '?detached=1', { sourceFile: file })); // TODO user/apps/appData
	}

	uploadCaptainDefinitionContent(
		appName: string,
		captainDefinition: ICaptainDefinition,
		gitHash: string,
		detached: boolean
	) {
		const http = this.http;

		return Promise.resolve() //
			.then(
				http.fetch(http.POST, '/user/apps/appData/' + appName + (detached ? '?detached=1' : ''), {
					captainDefinitionContent: JSON.stringify(captainDefinition),
					gitHash
				})
			);
	}

	updateConfigAndSave(appName: string, appDefinition: IAppDef) {
		var instanceCount = appDefinition.instanceCount;
		var envVars = appDefinition.envVars;
		var notExposeAsWebApp = appDefinition.notExposeAsWebApp;
		var forceSsl = appDefinition.forceSsl;
		var volumes = appDefinition.volumes;
		var ports = appDefinition.ports;
		var nodeId = appDefinition.nodeId;
		var appPushWebhook = appDefinition.appPushWebhook;
		var customNginxConfig = appDefinition.customNginxConfig;
		var preDeployFunction = appDefinition.preDeployFunction;
		const http = this.http;

		return Promise.resolve() //
			.then(
				http.fetch(http.POST, '/user/apps/appDefinitions/update', {
					appName: appName,
					instanceCount: instanceCount,
					notExposeAsWebApp: notExposeAsWebApp,
					forceSsl: forceSsl,
					volumes: volumes,
					ports: ports,
					customNginxConfig: customNginxConfig,
					appPushWebhook: appPushWebhook,
					nodeId: nodeId,
					preDeployFunction: preDeployFunction,
					envVars: envVars
				})
			);
	}

	registerNewApp(appName: string, hasPersistentData: boolean) {
		const http = this.http;

		return Promise.resolve() //
			.then(
				http.fetch(http.POST, '/user/apps/appDefinitions/register', {
					appName,
					hasPersistentData
				})
			);
	}

	deleteApp(appName: string) {
		const http = this.http;

		return Promise.resolve() //
			.then(
				http.fetch(http.POST, '/user/apps/appDefinitions/delete', {
					appName
				})
			);
	}

	enableSslForBaseDomain(appName: string) {
		const http = this.http;

		return Promise.resolve() //
			.then(
				http.fetch(http.POST, '/user/apps/appDefinitions/enablebasedomainssl', {
					appName
				})
			);
	}

	attachNewCustomDomainToApp(appName: string, customDomain: string) {
		const http = this.http;

		return Promise.resolve() //
			.then(
				http.fetch(http.POST, '/user/apps/appDefinitions/customdomain', {
					appName,
					customDomain
				})
			);
	}

	enableSslForCustomDomain(appName: string, customDomain: string) {
		const http = this.http;

		return Promise.resolve() //
			.then(
				http.fetch(http.POST, '/user/apps/appDefinitions/enablecustomdomainssl', {
					appName,
					customDomain
				})
			);
	}

	removeCustomDomain(appName: string, customDomain: string) {
		const http = this.http;

		return Promise.resolve() //
			.then(
				http.fetch(http.POST, '/user/apps/appDefinitions/removecustomdomain', {
					appName,
					customDomain
				})
			);
	}

	getLoadBalancerInfo() {
		const http = this.http;

		return Promise.resolve() //
			.then(http.fetch(http.GET, '/user/system/loadbalancerinfo', {}));
	}

	getNetDataInfo() {
		const http = this.http;

		return Promise.resolve() //
			.then(http.fetch(http.GET, '/user/system/netdata', {}));
	}

	updateNetDataInfo(netDataInfo: any) {
		const http = this.http;

		return Promise.resolve() //
			.then(http.fetch(http.POST, '/user/system/netdata', { netDataInfo }));
	}

	changePass(oldPassword: string, newPassword: string) {
		const http = this.http;

		return Promise.resolve() //
			.then(
				http.fetch(http.POST, '/user/changepassword', {
					oldPassword,
					newPassword
				})
			);
	}

	getVersionInfo(): Promise<IVersionInfo> {
		const http = this.http;

		return Promise.resolve() //
			.then(http.fetch(http.GET, '/user/system/versioninfo', {}));
	}

	performUpdate(latestVersion: string) {
		const http = this.http;

		return Promise.resolve() //
			.then(http.fetch(http.POST, '/user/system/versioninfo', { latestVersion }));
	}

	getNginxConfig() {
		const http = this.http;

		return Promise.resolve() //
			.then(http.fetch(http.GET, '/user/system/nginxconfig', {}));
	}

	setNginxConfig(customBase: string, customCaptain: string) {
		const http = this.http;

		return Promise.resolve() //
			.then(
				http.fetch(http.POST, '/user/system/nginxconfig', {
					baseConfig: { customValue: customBase },
					captainConfig: { customValue: customCaptain }
				})
			);
	}

	getUnusedImages(mostRecentLimit: number) {
		const http = this.http;
		return Promise.resolve() //
			.then(
				http.fetch(http.GET, '/user/apps/appDefinitions/unusedImages', {
					mostRecentLimit: mostRecentLimit + ''
				})
			);
	}

	deleteImages(imageIds: string[]) {
		const http = this.http;

		return Promise.resolve() //
			.then(
				http.fetch(http.POST, '/user/apps/appDefinitions/deleteImages', {
					imageIds
				})
			);
	}

	getDockerRegistries() {
		const http = this.http;

		return Promise.resolve() //
			.then(http.fetch(http.GET, '/user/registries', {}));
	}

	enableSelfHostedDockerRegistry() {
		const http = this.http;

		return Promise.resolve() //
			.then(http.fetch(http.POST, '/user/system/selfhostregistry/enableregistry', {}));
	}

	disableSelfHostedDockerRegistry() {
		const http = this.http;

		return Promise.resolve() //
			.then(http.fetch(http.POST, '/user/system/selfhostregistry/disableregistry', {}));
	}

	addDockerRegistry(dockerRegistry: IRegistryInfo) {
		const http = this.http;

		return Promise.resolve() //
			.then(http.fetch(http.POST, '/user/registries/insert', { ...dockerRegistry }));
	}

	updateDockerRegistry(dockerRegistry: IRegistryInfo) {
		const http = this.http;

		return Promise.resolve() //
			.then(http.fetch(http.POST, '/user/registries/update', { ...dockerRegistry }));
	}

	deleteDockerRegistry(registryId: string) {
		const http = this.http;

		return Promise.resolve() //
			.then(
				http.fetch(http.POST, '/user/registries/delete', {
					registryId
				})
			);
	}

	setDefaultPushDockerRegistry(registryId: string) {
		const http = this.http;

		return Promise.resolve() //
			.then(
				http.fetch(http.POST, '/user/registries/setpush', {
					registryId
				})
			);
	}

	getAllNodes() {
		const http = this.http;

		return Promise.resolve() //
			.then(http.fetch(http.GET, '/user/system/nodes', {}));
	}

	addDockerNode(nodeType: string, privateKey: string, remoteNodeIpAddress: string, captainIpAddress: string) {
		const http = this.http;

		return Promise.resolve() //
			.then(
				http.fetch(http.POST, '/user/system/nodes', {
					nodeType,
					privateKey,
					remoteNodeIpAddress,
					captainIpAddress
				})
			);
	}
}