altoslib: Create data file open helper in AltosLib
[fw/altos] / altoslib / AltosTelemetryFile.java
1 /*
2  * Copyright © 2013 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; either version 2 of the License, or
7  * (at your option) any later version.
8  *
9  * This program is distributed in the hope that it will be useful, but
10  * WITHOUT ANY WARRANTY; without even the implied warranty of
11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
12  * General Public License for more details.
13  *
14  * You should have received a copy of the GNU General Public License along
15  * with this program; if not, write to the Free Software Foundation, Inc.,
16  * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA.
17  */
18
19 package org.altusmetrum.altoslib_11;
20
21 import java.io.*;
22 import java.util.*;
23 import java.text.*;
24
25 class AltosTelemetryNullListener extends AltosDataListener {
26         public void set_rssi(int rssi, int status) { }
27         public void set_received_time(long received_time) { }
28
29         public void set_acceleration(double accel) { }
30         public void set_pressure(double pa) { }
31         public void set_thrust(double N) { }
32
33         public void set_kalman(double height, double speed, double accel) { }
34
35         public void set_temperature(double deg_c) { }
36         public void set_battery_voltage(double volts) { }
37
38         public void set_apogee_voltage(double volts) { }
39         public void set_main_voltage(double volts) { }
40
41         public void set_gps(AltosGPS gps) { }
42
43         public void set_orient(double orient) { }
44         public void set_gyro(double roll, double pitch, double yaw) { }
45         public void set_accel_ground(double along, double across, double through) { }
46         public void set_accel(double along, double across, double through) { }
47         public void set_mag(double along, double across, double through) { }
48         public void set_pyro_voltage(double volts) { }
49         public void set_igniter_voltage(double[] voltage) { }
50         public void set_pyro_fired(int pyro_mask) { }
51         public void set_companion(AltosCompanion companion) { }
52
53         public boolean cal_data_complete() {
54                 /* All telemetry packets */
55                 if (cal_data.serial == AltosLib.MISSING)
56                         return false;
57
58                 if (cal_data.boost_tick == AltosLib.MISSING)
59                         return false;
60
61                 /*
62                  * TelemetryConfiguration:
63                  *
64                  * device_type, flight, config version, log max,
65                  * flight params, callsign and version
66                  */
67                 if (cal_data.device_type == AltosLib.MISSING)
68                         return false;
69
70                 /*
71                  * TelemetrySensor or TelemetryMegaData:
72                  *
73                  * ground_accel, accel+/-, ground pressure
74                  */
75                 if (cal_data.ground_pressure == AltosLib.MISSING)
76                         return false;
77
78                 /*
79                  * TelemetryLocation
80                  */
81                 if (AltosLib.has_gps(cal_data.device_type) && cal_data.gps_pad == null)
82                         return false;
83
84                 return true;
85         }
86
87         public AltosTelemetryNullListener(AltosCalData cal_data) {
88                 super(cal_data);
89         }
90 }
91
92 public class AltosTelemetryFile implements AltosRecordSet {
93
94         AltosTelemetryIterable  telems;
95         AltosCalData            cal_data;
96
97         public void write_comments(PrintStream out) {
98         }
99
100         public void write(PrintStream out) {
101         }
102
103         /* Construct cal data by walking through the telemetry data until we've found everything available */
104         public AltosCalData cal_data() {
105                 if (cal_data == null) {
106                         cal_data = new AltosCalData();
107                         AltosTelemetryNullListener l = new AltosTelemetryNullListener(cal_data);
108
109                         for (AltosTelemetry telem : telems) {
110                                 telem.provide_data(l, cal_data);
111                                 if (l.cal_data_complete())
112                                         break;
113                         }
114                 }
115                 return cal_data;
116         }
117
118         public void capture_series(AltosDataListener listener) {
119                 AltosCalData    cal_data = cal_data();
120
121                 for (AltosTelemetry telem : telems) {
122                         int tick = telem.tick();
123                         cal_data.set_tick(tick);
124                         if (cal_data.time() >= -1)
125                                 telem.provide_data(listener, cal_data);
126                         if (listener.state == AltosLib.ao_flight_landed)
127                                 break;
128                 }
129                 listener.finish();
130         }
131
132         public AltosTelemetryFile(FileInputStream input) throws IOException {
133                 telems = new AltosTelemetryIterable(input);
134         }
135 }