/*
 * 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.util.*;
import java.io.*;
import java.util.concurrent.*;

public class AltosIgnite {
	AltosLink	link;
	boolean		remote;
	boolean		close_on_exit;
	boolean		link_started;
	boolean		has_pyro_info = false;
	boolean		has_standard = false;
	int		npyro;
	AltosConfigData	config_data;

	public final static String	None = null;
	public final static String	Apogee = "drogue";
	public final static String	Main = "main";

	public final static int	Unknown = 0;
	public final static int	Ready = 1;
	public final static int	Active = 2;
	public final static int	Open = 3;

	private void start_link() throws InterruptedException, TimeoutException {
		link_started = true;
		if (remote)
			link.start_remote();
	}

	private void stop_link() throws InterruptedException {
		if (!link_started)
			return;
		link_started = false;
		if (link == null)
			return;
		if (remote)
			link.stop_remote();
	}

	class string_ref {
		String	value;

		public String get() {
			return value;
		}
		public void set(String i) {
			value = i;
		}
		public string_ref() {
			value = null;
		}
	}

	/*
	private boolean get_string(String line, String label, string_ref s) {
		if (line.startsWith(label)) {
			String	quoted = line.substring(label.length()).trim();

			if (quoted.startsWith("\""))
				quoted = quoted.substring(1);
			if (quoted.endsWith("\""))
				quoted = quoted.substring(0,quoted.length()-1);
			s.set(quoted);
			return true;
		} else {
			return false;
		}
	}
	*/

	private int map_status(String status_name) {
		if (status_name.equals("unknown"))
			return Unknown;
		if (status_name.equals("ready"))
			return Ready;
		if (status_name.equals("active"))
			return Active;
		if (status_name.equals("open"))
			return Open;
		return Unknown;
	}

	private void get_npyro() throws InterruptedException, TimeoutException {
		if (config_data == null)
			config_data = new AltosConfigData(link);
		if (config_data != null && config_data.npyro != AltosLib.MISSING)
			npyro = config_data.npyro;
		else
			npyro = 0;
		if (config_data != null)
			has_standard = config_data.ignite_mode != AltosLib.MISSING;

		has_pyro_info = true;
	}

	public int npyro() throws InterruptedException, TimeoutException {
		if (!has_pyro_info) {
			start_link();
			get_npyro();
			stop_link();
		}
		return npyro;
	}

	public boolean has_standard() throws InterruptedException, TimeoutException {
		if (!has_pyro_info) {
			start_link();
			get_npyro();
			stop_link();
		}
		return has_standard;
	}

	public HashMap<String,Integer> status() throws InterruptedException, TimeoutException {
		HashMap<String,Integer> status = new HashMap<String,Integer>();

		if (link == null)
			return status;
		try {
			start_link();
			get_npyro();

			String last_igniter = Main;
			if (npyro > 0)
				last_igniter = String.format("%d", npyro - 1);

			link.printf("t\n");
			for (;;) {
				String line = link.get_reply(5000);
				if (line == null)
					throw new TimeoutException();
				String[] items = line.split("\\s+");

				if (items.length < 4)
					continue;

				if (!items[0].equals("Igniter:"))
					continue;

				if (!items[2].equals("Status:"))
					continue;

				status.put(items[1], map_status(items[3]));

				if (items[1].equals(last_igniter))
					break;
			}
		} finally {
			stop_link();
		}
		return status;
	}

	public static String status_string(int status) {
		switch (status) {
		case Unknown: return "Unknown";
		case Ready: return "Ready";
		case Active: return "Active";
		case Open: return "Open";
		default: return "Unknown";
		}
	}

	public void fire(String igniter) throws InterruptedException {
		if (link == null)
			return;
		try {
			start_link();
			link.printf("i DoIt %s\n", igniter);
			link.flush_output();
		} catch (TimeoutException te) {
		} finally {
			stop_link();
		}
	}

	public void close() throws InterruptedException {
		stop_link();
		if (close_on_exit)
			link.close();
		link = null;
	}

	public AltosIgnite(AltosLink in_link, boolean in_remote, boolean in_close_on_exit) {
		link = in_link;
		remote = in_remote;
		close_on_exit = in_close_on_exit;
	}

	public AltosIgnite(AltosLink in_link, boolean in_remote) {
		this(in_link, in_remote, true);
	}
}