/*
 Copyright (C) 2021 - 2024 3NSoft Inc.
 
 This program is free software: you can redistribute it and/or modify it under
 the terms of the GNU General Public License as published by the Free Software
 Foundation, either version 3 of the License, or (at your option) any later
 version.
 
 This program is distributed in the hope that it will be useful, but
 WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
 See the GNU General Public License for more details.
 
 You should have received a copy of the GNU General Public License along with
 this program. If not, see <http://www.gnu.org/licenses/>.
*/

import { NsisUpdater, AppImageUpdater, MacUpdater, AppUpdater, ProgressInfo, UpdateDownloadedEvent, UpdateInfo } from "electron-updater";
import { Subject } from "rxjs";
import { makeRuntimeException } from "../../lib-common/exceptions/runtime";
import { toRxObserver } from "../../lib-common/utils-for-observables";
import { PLATFORM_BUNDLE_URL } from "../../bundle-confs";
import { findPackInfo } from "../../confs";

type PlatformDownloadProgress = web3n.apps.PlatformDownloadProgress;
type Observer<T> = web3n.Observer<T>;

export interface Updater {
	checkForUpdateAndApply(
		observer: Observer<PlatformDownloadProgress>
	): () => void;
}

export async function makeUpdater(channel: string): Promise<Updater|undefined> {
	const packInfo = findPackInfo();
	if (!packInfo) {
		return;
	}
	if (packInfo.variant === 'AppImage') {
		return wrapElectronBuilderUpdater(new AppImageUpdater({
			provider: 'generic',
			url: `${PLATFORM_BUNDLE_URL}${channel}/linux/`
		}));			
	} else if (packInfo.variant === 'nsis') {
		return wrapElectronBuilderUpdater(new NsisUpdater({
			provider: 'generic',
			url: `${PLATFORM_BUNDLE_URL}${channel}/windows/`
		}));			
	} else if (packInfo.variant === 'dmg') {
		return wrapElectronBuilderUpdater(new MacUpdater({
			provider: 'generic',
			url: `${PLATFORM_BUNDLE_URL}${channel}/mac/`
		}));			
	} else {
		return;
	}
}

function wrapElectronBuilderUpdater(updater: AppUpdater): Updater {
	updater.on('checking-for-update', () => {
		next({ event: 'checking-for-update' });
	});
	updater.on('update-available', (info: UpdateInfo) => {
		next({
			event: 'update-available',
			totalSizeMBs: Math.round(info.files[0].size!/1024/1024)
		});
	});
	updater.on('update-not-available', info => {
		signalErr(makeRuntimeException('platform-download', {
			message: `Update unexpectedly not available`,
			cause: info
		}, {}));
	});
	updater.on('download-progress', (progress: ProgressInfo) => {
		next({
			event: 'download-progress',
			percent: progress.percent
		});
	});
	updater.on('update-downloaded', (info: UpdateDownloadedEvent) => {
		next({ event: 'download-progress', percent: 100 });
	});
	updater.on('error', err => signalErr(err));

	let proc: Promise<any>|undefined = undefined;
	let sinks: Subject<PlatformDownloadProgress>[] = [];
	const next = (p: PlatformDownloadProgress) => sinks.forEach(s => s.next(p));
	const signalErr = (err: any) => {
		sinks.forEach(s => s.error(err));
		sinks = [];
		proc = undefined;
	}
	const signalCompletion = () => {
		sinks.forEach(s => s.complete());
		sinks = [];
		proc = undefined;
	};

	return {
		checkForUpdateAndApply: observer => {
			const sink = new Subject<PlatformDownloadProgress>();
			sinks.push(sink);
			const sub = sink.asObservable()
			.subscribe(toRxObserver(observer));
			if (!proc) {
				proc = updater.checkForUpdatesAndNotify()
				.then(signalCompletion, signalErr);
			}
			return () => sub.unsubscribe();
		}
	};
}


Object.freeze(exports);