/*
 * Copyright © 2010 Keith Packard <keithp@keithp.com>
 *
 * 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 2 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, write to the Free Software Foundation, Inc.,
 * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA.
 */

package org.altusmetrum.altoslib_14;

import java.io.*;
import java.util.concurrent.*;


public class AltosIdleMonitor extends Thread {
	AltosLink		link;
	AltosIdleMonitorListener	listener;

	AltosIdleFetch		fetch;

	boolean			remote;
	boolean			close_on_exit;
	double			frequency = AltosLib.MISSING;
	String			callsign;

	AltosState		state;
	AltosListenerState	listener_state;
	AltosConfigData		config_data;
	AltosGPS		gps;

	void start_link() throws InterruptedException, TimeoutException {
		if (remote) {
			link.set_radio_frequency(frequency);
			link.set_callsign(callsign);
			link.start_remote();
		} else
			link.flush_input();
	}

	boolean stop_link() throws InterruptedException, TimeoutException {
		if (remote)
			link.stop_remote();
		return link.reply_abort;
	}

	boolean provide_data() throws InterruptedException, TimeoutException, AltosUnknownProduct {
		boolean		worked = false;
		boolean		aborted = false;

		try {
			start_link();
			link.config_data();
			if (state == null)
				state = new AltosState(new AltosCalData(link.config_data()));
			fetch.provide_data(state);
			if (frequency != AltosLib.MISSING)
				state.set_frequency(frequency);
			if (!link.has_error && !link.reply_abort)
				worked = true;
		} finally {
			aborted = stop_link();
			if (worked) {
				if (remote)
					state.set_rssi(link.rssi(), 0);
				listener_state.battery = link.monitor_battery();
			}
		}
		return aborted;
	}

	public void set_frequency(double in_frequency) {
		frequency = in_frequency;
		link.abort_reply();
	}

	public void set_callsign(String in_callsign) {
		callsign = in_callsign;
		link.abort_reply();
	}

	public void abort() throws InterruptedException {
		while (isAlive()) {
			interrupt();
			link.abort_reply();
			Thread.sleep(100);
		}
		join();
	}

	public void run() {
		state = null;
		try {
			for (;;) {
				try {
					provide_data();
					listener.update(state, listener_state);
				} catch (TimeoutException te) {
				} catch (AltosUnknownProduct ae) {
					listener.error(String.format("Unknown product \"%s\"", ae.product));
				}
				if (link.has_error || link.reply_abort) {
					listener.failed();
					break;
				}
				Thread.sleep(1000);
			}
		} catch (InterruptedException ie) {
		}
		if (close_on_exit) {
			try {
				link.close();
			} catch (InterruptedException ie) {
			}
		}
	}

	public AltosIdleMonitor(AltosIdleMonitorListener in_listener, AltosLink in_link, boolean in_remote, boolean in_close_on_exit) {
		listener = in_listener;
		link = in_link;
		remote = in_remote;
		close_on_exit = in_close_on_exit;
		listener_state = new AltosListenerState();
		fetch = new AltosIdleFetch(link);
	}

	public AltosIdleMonitor(AltosIdleMonitorListener in_listener, AltosLink in_link, boolean in_remote) {
		this(in_listener, in_link, in_remote, true);
	}
}