altosui: Make Windows java test "smarter"
[fw/altos] / altosui / AltosConfig.java
index 1c42870f8d7ff61519a2df97b9eb88404cfab6cd..40f7ebecb4c4635809dfdec7ebc9d068edca3af5 100644 (file)
 
 package altosui;
 
-import java.awt.*;
 import java.awt.event.*;
 import javax.swing.*;
-import javax.swing.filechooser.FileNameExtensionFilter;
-import javax.swing.table.*;
 import java.io.*;
-import java.util.*;
-import java.text.*;
-import java.util.prefs.*;
 import java.util.concurrent.*;
+import java.text.*;
+import org.altusmetrum.altoslib_5.*;
+import org.altusmetrum.altosuilib_3.*;
 
-import libaltosJNI.*;
-
-public class AltosConfig implements Runnable, ActionListener {
+public class AltosConfig implements ActionListener {
 
        class int_ref {
                int     value;
@@ -64,153 +59,197 @@ public class AltosConfig implements Runnable, ActionListener {
        AltosDevice     device;
        AltosSerial     serial_line;
        boolean         remote;
-       Thread          config_thread;
-       int_ref         serial;
-       int_ref         main_deploy;
-       int_ref         apogee_delay;
-       int_ref         radio_channel;
-       int_ref         radio_calibration;
-       string_ref      version;
-       string_ref      product;
-       string_ref      callsign;
+
+       AltosConfigData data;
        AltosConfigUI   config_ui;
        boolean         serial_started;
+       boolean         made_visible;
 
-       boolean get_int(String line, String label, int_ref x) {
-               if (line.startsWith(label)) {
-                       try {
-                               String tail = line.substring(label.length()).trim();
-                               String[] tokens = tail.split("\\s+");
-                               if (tokens.length > 0) {
-                                       int     i = Integer.parseInt(tokens[0]);
-                                       x.set(i);
-                                       return true;
-                               }
-                       } catch (NumberFormatException ne) {
-                       }
-               }
-               return false;
-       }
-
-       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;
-               }
-       }
-
-       void start_serial() throws InterruptedException {
+       void start_serial() throws InterruptedException, TimeoutException {
                serial_started = true;
-               if (remote) {
-                       serial_line.set_radio();
-                       serial_line.printf("p\nE 0\n");
-                       serial_line.flush_input();
-               }
+               if (remote)
+                       serial_line.start_remote();
        }
 
        void stop_serial() throws InterruptedException {
                if (!serial_started)
                        return;
                serial_started = false;
-               if (remote) {
-                       serial_line.printf("~");
-                       serial_line.flush_output();
+               if (remote)
+                       serial_line.stop_remote();
+       }
+
+       void update_ui() {
+               data.set_values(config_ui);
+               config_ui.set_clean();
+               if (!made_visible) {
+                       made_visible = true;
+                       config_ui.make_visible();
                }
        }
 
-       void get_data() throws InterruptedException, TimeoutException {
-               try {
-                       start_serial();
-                       serial_line.printf("c s\nv\n");
-                       for (;;) {
-                               String line = serial_line.get_reply(5000);
-                               if (line == null)
-                                       throw new TimeoutException();
-                               get_int(line, "serial-number", serial);
-                               get_int(line, "Main deploy:", main_deploy);
-                               get_int(line, "Apogee delay:", apogee_delay);
-                               get_int(line, "Radio channel:", radio_channel);
-                               get_int(line, "Radio cal:", radio_calibration);
-                               get_string(line, "Callsign:", callsign);
-                               get_string(line,"software-version", version);
-                               get_string(line,"product", product);
-
-                               /* signals the end of the version info */
-                               if (line.startsWith("software-version"))
-                                       break;
+       int     pyro;
+
+       final static int        serial_mode_read = 0;
+       final static int        serial_mode_save = 1;
+       final static int        serial_mode_reboot = 2;
+
+       class SerialData implements Runnable {
+               AltosConfig     config;
+               int             serial_mode;
+
+               void callback(String in_cmd) {
+                       final String cmd = in_cmd;
+                       Runnable r = new Runnable() {
+                                       public void run() {
+                                               if (cmd.equals("abort")) {
+                                                       abort();
+                                               } else if (cmd.equals("all finished")) {
+                                                       if (serial_line != null)
+                                                               update_ui();
+                                               }
+                                       }
+                               };
+                       SwingUtilities.invokeLater(r);
+               }
+
+               void get_data() {
+                       data = null;
+                       try {
+                               start_serial();
+                               data = new AltosConfigData(config.serial_line);
+                       } catch (InterruptedException ie) {
+                       } catch (TimeoutException te) {
+                               try {
+                                       stop_serial();
+                                       callback("abort");
+                               } catch (InterruptedException ie) {
+                               }
+                       } finally {
+                               try {
+                                       stop_serial();
+                               } catch (InterruptedException ie) {
+                               }
+                       }
+                       callback("all finished");
+               }
+
+               void save_data() {
+                       try {
+                               start_serial();
+                               data.save(serial_line, remote);
+                               if (remote)
+                                       AltosUIPreferences.set_frequency(device.getSerial(),
+                                                                        data.frequency());
+                       } catch (InterruptedException ie) {
+                       } catch (TimeoutException te) {
+                       } finally {
+                               try {
+                                       stop_serial();
+                               } catch (InterruptedException ie) {
+                               }
+                       }
+               }
+
+               void reboot() {
+                       try {
+                               start_serial();
+                               serial_line.printf("r eboot\n");
+                               serial_line.flush_output();
+                       } catch (InterruptedException ie) {
+                       } catch (TimeoutException te) {
+                       } finally {
+                               try {
+                                       stop_serial();
+                                       serial_line.close();
+                               } catch (InterruptedException ie) {
+                               }
+                       }
+               }
+
+               public void run () {
+                       switch (serial_mode) {
+                       case serial_mode_save:
+                               save_data();
+                               /* fall through ... */
+                       case serial_mode_read:
+                               get_data();
+                               break;
+                       case serial_mode_reboot:
+                               reboot();
+                               break;
                        }
-               } finally {
-                       stop_serial();
+               }
+
+               public SerialData(AltosConfig in_config, int in_serial_mode) {
+                       config = in_config;
+                       serial_mode = in_serial_mode;
                }
        }
 
+       void run_serial_thread(int serial_mode) {
+               SerialData      sd = new SerialData(this, serial_mode);
+               Thread          st = new Thread(sd);
+               st.start();
+       }
+
        void init_ui () throws InterruptedException, TimeoutException {
                config_ui = new AltosConfigUI(owner, remote);
                config_ui.addActionListener(this);
+               serial_line.set_frame(owner);
                set_ui();
        }
 
        void abort() {
+               if (serial_line != null) {
+                       serial_line.close();
+                       serial_line = null;
+               }
                JOptionPane.showMessageDialog(owner,
                                              String.format("Connection to \"%s\" failed",
                                                            device.toShortString()),
                                              "Connection Failed",
                                              JOptionPane.ERROR_MESSAGE);
-               try {
-                       stop_serial();
-               } catch (InterruptedException ie) {
-               }
-               serial_line.close();
-               serial_line = null;
+               config_ui.setVisible(false);
        }
 
        void set_ui() throws InterruptedException, TimeoutException {
                if (serial_line != null)
-                       get_data();
-               config_ui.set_serial(serial.get());
-               config_ui.set_product(product.get());
-               config_ui.set_version(version.get());
-               config_ui.set_main_deploy(main_deploy.get());
-               config_ui.set_apogee_delay(apogee_delay.get());
-               config_ui.set_radio_channel(radio_channel.get());
-               config_ui.set_radio_calibration(radio_calibration.get());
-               config_ui.set_callsign(callsign.get());
-               config_ui.set_clean();
+                       run_serial_thread(serial_mode_read);
+               else
+                       update_ui();
        }
 
-       void run_dialog() {
+       double frequency() {
+               return AltosConvert.radio_to_frequency(data.radio_frequency,
+                                                      data.radio_setting,
+                                                      data.radio_calibration,
+                                                      data.radio_channel);
        }
 
        void save_data() {
-               main_deploy.set(config_ui.main_deploy());
-               apogee_delay.set(config_ui.apogee_delay());
-               radio_channel.set(config_ui.radio_channel());
-               radio_calibration.set(config_ui.radio_calibration());
-               callsign.set(config_ui.callsign());
+
                try {
-                       start_serial();
-                       serial_line.printf("c m %d\n", main_deploy.get());
-                       serial_line.printf("c d %d\n", apogee_delay.get());
-                       if (!remote) {
-                               serial_line.printf("c r %d\n", radio_channel.get());
-                               serial_line.printf("c f %d\n", radio_calibration.get());
-                       }
-                       serial_line.printf("c c %s\n", callsign.get());
-                       serial_line.printf("c w\n");
-               } catch (InterruptedException ie) {
-               } finally {
-                       try {
-                               stop_serial();
-                       } catch (InterruptedException ie) {
+                       /* bounds check stuff */
+                       if (config_ui.flight_log_max() > data.log_space() / 1024) {
+                               JOptionPane.showMessageDialog(owner,
+                                                             String.format("Requested flight log, %dk, is larger than the available space, %dk.\n",
+                                                                           config_ui.flight_log_max(),
+                                                                           data.log_space() / 1024),
+                                                             "Maximum Flight Log Too Large",
+                                                             JOptionPane.ERROR_MESSAGE);
+                               return;
                        }
+
+                       /* Pull data out of the UI and stuff back into our local data record */
+
+                       data.get_values(config_ui);
+                       run_serial_thread(serial_mode_save);
+               } catch (AltosConfigDataException ae) {
+                       JOptionPane.showMessageDialog(owner,
+                                                     ae.getMessage(),
+                                                     "Configuration Data Error",
+                                                     JOptionPane.ERROR_MESSAGE);
                }
        }
 
@@ -219,17 +258,11 @@ public class AltosConfig implements Runnable, ActionListener {
                try {
                        if (cmd.equals("Save")) {
                                save_data();
-                               set_ui();
                        } else if (cmd.equals("Reset")) {
                                set_ui();
                        } else if (cmd.equals("Reboot")) {
-                               if (serial_line != null) {
-                                       start_serial();
-                                       serial_line.printf("r eboot\n");
-                                       serial_line.flush_output();
-                                       stop_serial();
-                                       serial_line.close();
-                               }
+                               if (serial_line != null)
+                                       run_serial_thread(serial_mode_reboot);
                        } else if (cmd.equals("Close")) {
                                if (serial_line != null)
                                        serial_line.close();
@@ -241,41 +274,25 @@ public class AltosConfig implements Runnable, ActionListener {
                }
        }
 
-       public void run () {
-               try {
-                       init_ui();
-                       config_ui.make_visible();
-               } catch (InterruptedException ie) {
-                       abort();
-               } catch (TimeoutException te) {
-                       abort();
-               }
-       }
-
        public AltosConfig(JFrame given_owner) {
                owner = given_owner;
 
-               serial = new int_ref(0);
-               main_deploy = new int_ref(250);
-               apogee_delay = new int_ref(0);
-               radio_channel = new int_ref(0);
-               radio_calibration = new int_ref(1186611);
-               callsign = new string_ref("N0CALL");
-               version = new string_ref("unknown");
-               product = new string_ref("unknown");
-
-               device = AltosDeviceDialog.show(owner, AltosDevice.product_any);
+               device = AltosDeviceUIDialog.show(owner, Altos.product_any);
                if (device != null) {
                        try {
                                serial_line = new AltosSerial(device);
-                               if (!device.matchProduct(AltosDevice.product_telemetrum))
-                                       remote = true;
-                               config_thread = new Thread(this);
-                               config_thread.start();
+                               try {
+                                       if (device.matchProduct(Altos.product_basestation))
+                                               remote = true;
+                                       init_ui();
+                               } catch (InterruptedException ie) {
+                                       abort();
+                               } catch (TimeoutException te) {
+                                       abort();
+                               }
                        } catch (FileNotFoundException ee) {
                                JOptionPane.showMessageDialog(owner,
-                                                             String.format("Cannot open device \"%s\"",
-                                                                           device.toShortString()),
+                                                             ee.getMessage(),
                                                              "Cannot open target device",
                                                              JOptionPane.ERROR_MESSAGE);
                        } catch (AltosSerialInUseException si) {
@@ -284,12 +301,7 @@ public class AltosConfig implements Runnable, ActionListener {
                                                                            device.toShortString()),
                                                              "Device in use",
                                                              JOptionPane.ERROR_MESSAGE);
-                       } catch (IOException ee) {
-                               JOptionPane.showMessageDialog(owner,
-                                                             device.toShortString(),
-                                                             ee.getLocalizedMessage(),
-                                                             JOptionPane.ERROR_MESSAGE);
                        }
                }
        }
-}
\ No newline at end of file
+}