altosui: Allow TM config connection to be canceled.
[fw/altos] / altosui / AltosConfig.java
1 /*
2  * Copyright © 2010 Keith Packard <keithp@keithp.com>
3  *
4  * This program is free software; you can redistribute it and/or modify
5  * it under the terms of the GNU General Public License as published by
6  * the Free Software Foundation; version 2 of the License.
7  *
8  * This program is distributed in the hope that it will be useful, but
9  * WITHOUT ANY WARRANTY; without even the implied warranty of
10  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
11  * General Public License for more details.
12  *
13  * You should have received a copy of the GNU General Public License along
14  * with this program; if not, write to the Free Software Foundation, Inc.,
15  * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA.
16  */
17
18 package altosui;
19
20 import java.awt.*;
21 import java.awt.event.*;
22 import javax.swing.*;
23 import javax.swing.filechooser.FileNameExtensionFilter;
24 import javax.swing.table.*;
25 import java.io.*;
26 import java.util.*;
27 import java.text.*;
28 import java.util.prefs.*;
29 import java.util.concurrent.*;
30
31 import libaltosJNI.*;
32
33 public class AltosConfig implements ActionListener {
34
35         class int_ref {
36                 int     value;
37
38                 public int get() {
39                         return value;
40                 }
41                 public void set(int i) {
42                         value = i;
43                 }
44                 public int_ref(int i) {
45                         value = i;
46                 }
47         }
48
49         class string_ref {
50                 String  value;
51
52                 public String get() {
53                         return value;
54                 }
55                 public void set(String i) {
56                         value = i;
57                 }
58                 public string_ref(String i) {
59                         value = i;
60                 }
61         }
62
63         JFrame          owner;
64         AltosDevice     device;
65         AltosSerial     serial_line;
66         boolean         remote;
67         int_ref         serial;
68         int_ref         main_deploy;
69         int_ref         apogee_delay;
70         int_ref         radio_channel;
71         int_ref         radio_calibration;
72         int_ref         flight_log_max;
73         string_ref      version;
74         string_ref      product;
75         string_ref      callsign;
76         AltosConfigUI   config_ui;
77         boolean         serial_started;
78
79         boolean get_int(String line, String label, int_ref x) {
80                 if (line.startsWith(label)) {
81                         try {
82                                 String tail = line.substring(label.length()).trim();
83                                 String[] tokens = tail.split("\\s+");
84                                 if (tokens.length > 0) {
85                                         int     i = Integer.parseInt(tokens[0]);
86                                         x.set(i);
87                                         return true;
88                                 }
89                         } catch (NumberFormatException ne) {
90                         }
91                 }
92                 return false;
93         }
94
95         boolean get_string(String line, String label, string_ref s) {
96                 if (line.startsWith(label)) {
97                         String  quoted = line.substring(label.length()).trim();
98
99                         if (quoted.startsWith("\""))
100                                 quoted = quoted.substring(1);
101                         if (quoted.endsWith("\""))
102                                 quoted = quoted.substring(0,quoted.length()-1);
103                         s.set(quoted);
104                         return true;
105                 } else {
106                         return false;
107                 }
108         }
109
110         void start_serial() throws InterruptedException {
111                 serial_started = true;
112                 if (remote)
113                         serial_line.start_remote();
114         }
115
116         void stop_serial() throws InterruptedException {
117                 if (!serial_started)
118                         return;
119                 serial_started = false;
120                 if (remote)
121                         serial_line.stop_remote();
122         }
123
124         void update_ui() {
125                 config_ui.set_serial(serial.get());
126                 config_ui.set_product(product.get());
127                 config_ui.set_version(version.get());
128                 config_ui.set_main_deploy(main_deploy.get());
129                 config_ui.set_apogee_delay(apogee_delay.get());
130                 config_ui.set_radio_channel(radio_channel.get());
131                 config_ui.set_radio_calibration(radio_calibration.get());
132                 config_ui.set_flight_log_max(flight_log_max.get());
133                 config_ui.set_callsign(callsign.get());
134                 config_ui.set_clean();
135                 config_ui.make_visible();
136         }
137
138         void process_line(String line) {
139                 if (line == null) {
140                         System.out.printf("timeout\n");
141                         abort();
142                         return;
143                 }
144                 if (line.equals("done")) {
145                         System.out.printf("done\n");
146                         if (serial_line != null)
147                                 update_ui();
148                         return;
149                 }
150                 get_int(line, "serial-number", serial);
151                 get_int(line, "Main deploy:", main_deploy);
152                 get_int(line, "Apogee delay:", apogee_delay);
153                 get_int(line, "Radio channel:", radio_channel);
154                 get_int(line, "Radio cal:", radio_calibration);
155                 get_int(line, "Max flight log:", flight_log_max);
156                 get_string(line, "Callsign:", callsign);
157                 get_string(line,"software-version", version);
158                 get_string(line,"product", product);
159         }
160
161         final static int        serial_mode_read = 0;
162         final static int        serial_mode_save = 1;
163         final static int        serial_mode_reboot = 2;
164
165         class SerialData implements Runnable {
166                 AltosConfig     config;
167                 int             serial_mode;
168
169                 void process_line(String line) {
170                         config.process_line(line);
171                 }
172                 void callback(String in_line) {
173                         final String line = in_line;
174                         Runnable r = new Runnable() {
175                                         public void run() {
176                                                 process_line(line);
177                                         }
178                                 };
179                         SwingUtilities.invokeLater(r);
180                 }
181
182                 void get_data() {
183                         try {
184                                 config.start_serial();
185                                 config.serial_line.printf("c s\nv\n");
186                                 for (;;) {
187                                         try {
188                                                 String line = config.serial_line.get_reply(5000);
189                                                 if (line == null)
190                                                         stop_serial();
191                                                 callback(line);
192                                                 if (line.startsWith("software-version"))
193                                                         break;
194                                         } catch (Exception e) {
195                                                 break;
196                                         }
197                                 }
198                         } catch (InterruptedException ie) {
199                         } finally {
200                                 try {
201                                         stop_serial();
202                                 } catch (InterruptedException ie) {
203                                 }
204                         }
205                         callback("done");
206                 }
207
208                 void save_data() {
209                         try {
210                                 start_serial();
211                                 serial_line.printf("c m %d\n", main_deploy.get());
212                                 serial_line.printf("c d %d\n", apogee_delay.get());
213                                 if (!remote) {
214                                         serial_line.printf("c r %d\n", radio_channel.get());
215                                         serial_line.printf("c f %d\n", radio_calibration.get());
216                                 }
217                                 serial_line.printf("c c %s\n", callsign.get());
218                                 if (flight_log_max.get() != 0)
219                                         serial_line.printf("c l %d\n", flight_log_max.get());
220                                 serial_line.printf("c w\n");
221                         } catch (InterruptedException ie) {
222                         } finally {
223                                 try {
224                                         stop_serial();
225                                 } catch (InterruptedException ie) {
226                                 }
227                         }
228                 }
229
230                 void reboot() {
231                         try {
232                                 start_serial();
233                                 serial_line.printf("r eboot\n");
234                                 serial_line.flush_output();
235                         } catch (InterruptedException ie) {
236                         } finally {
237                                 try {
238                                         stop_serial();
239                                 } catch (InterruptedException ie) {
240                                 }
241                                 serial_line.close();
242                         }
243                 }
244
245                 public void run () {
246                         switch (serial_mode) {
247                         case serial_mode_save:
248                                 save_data();
249                                 /* fall through ... */
250                         case serial_mode_read:
251                                 get_data();
252                                 break;
253                         case serial_mode_reboot:
254                                 reboot();
255                                 break;
256                         }
257                 }
258
259                 public SerialData(AltosConfig in_config, int in_serial_mode) {
260                         config = in_config;
261                         serial_mode = in_serial_mode;
262                 }
263         }
264
265         void run_serial_thread(int serial_mode) {
266                 SerialData      sd = new SerialData(this, serial_mode);
267                 Thread          st = new Thread(sd);
268                 st.start();
269         }
270
271         void init_ui () throws InterruptedException, TimeoutException {
272                 config_ui = new AltosConfigUI(owner, remote);
273                 config_ui.addActionListener(this);
274                 serial_line.set_frame(owner);
275                 set_ui();
276         }
277
278         void abort() {
279                 serial_line.close();
280                 serial_line = null;
281                 JOptionPane.showMessageDialog(owner,
282                                               String.format("Connection to \"%s\" failed",
283                                                             device.toShortString()),
284                                               "Connection Failed",
285                                               JOptionPane.ERROR_MESSAGE);
286                 config_ui.setVisible(false);
287         }
288
289         void set_ui() throws InterruptedException, TimeoutException {
290                 if (serial_line != null)
291                         run_serial_thread(serial_mode_read);
292                 else
293                         update_ui();
294         }
295
296         void save_data() {
297                 main_deploy.set(config_ui.main_deploy());
298                 apogee_delay.set(config_ui.apogee_delay());
299                 radio_channel.set(config_ui.radio_channel());
300                 radio_calibration.set(config_ui.radio_calibration());
301                 flight_log_max.set(config_ui.flight_log_max());
302                 callsign.set(config_ui.callsign());
303                 run_serial_thread(serial_mode_save);
304         }
305
306         public void actionPerformed(ActionEvent e) {
307                 String  cmd = e.getActionCommand();
308                 try {
309                         if (cmd.equals("Save")) {
310                                 save_data();
311                         } else if (cmd.equals("Reset")) {
312                                 set_ui();
313                         } else if (cmd.equals("Reboot")) {
314                                 if (serial_line != null)
315                                         run_serial_thread(serial_mode_reboot);
316                         } else if (cmd.equals("Close")) {
317                                 if (serial_line != null)
318                                         serial_line.close();
319                         }
320                 } catch (InterruptedException ie) {
321                         abort();
322                 } catch (TimeoutException te) {
323                         abort();
324                 }
325         }
326
327         public AltosConfig(JFrame given_owner) {
328                 owner = given_owner;
329
330                 serial = new int_ref(0);
331                 main_deploy = new int_ref(250);
332                 apogee_delay = new int_ref(0);
333                 radio_channel = new int_ref(0);
334                 radio_calibration = new int_ref(1186611);
335                 flight_log_max = new int_ref(0);
336                 callsign = new string_ref("N0CALL");
337                 version = new string_ref("unknown");
338                 product = new string_ref("unknown");
339
340                 device = AltosDeviceDialog.show(owner, AltosDevice.product_any);
341                 if (device != null) {
342                         try {
343                                 serial_line = new AltosSerial(device);
344                                 if (!device.matchProduct(AltosDevice.product_telemetrum))
345                                         remote = true;
346                                 try {
347                                         init_ui();
348                                 } catch (InterruptedException ie) {
349                                         abort();
350                                 } catch (TimeoutException te) {
351                                         abort();
352                                 }
353                         } catch (FileNotFoundException ee) {
354                                 JOptionPane.showMessageDialog(owner,
355                                                               String.format("Cannot open device \"%s\"",
356                                                                             device.toShortString()),
357                                                               "Cannot open target device",
358                                                               JOptionPane.ERROR_MESSAGE);
359                         } catch (AltosSerialInUseException si) {
360                                 JOptionPane.showMessageDialog(owner,
361                                                               String.format("Device \"%s\" already in use",
362                                                                             device.toShortString()),
363                                                               "Device in use",
364                                                               JOptionPane.ERROR_MESSAGE);
365                         } catch (IOException ee) {
366                                 JOptionPane.showMessageDialog(owner,
367                                                               device.toShortString(),
368                                                               ee.getLocalizedMessage(),
369                                                               JOptionPane.ERROR_MESSAGE);
370                         }
371                 }
372         }
373 }