Share telemetry parsing code in cc library.
[fw/altos] / ao-tools / lib / cc-telem.c
1 /*
2  * Copyright © 2009 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 #include "cc.h"
19 #include <string.h>
20 #include <stdlib.h>
21
22 static void
23 cc_parse_string(char *target, int len, char *source)
24 {
25         strncpy(target, source, len-1);
26         target[len-1] = '\0';
27 }
28
29 static void
30 cc_parse_int(int *target, char *source)
31 {
32         *target = strtol(source, NULL, 0);
33 }
34
35 static void
36 cc_parse_hex(int *target, char *source)
37 {
38         *target = strtol(source, NULL, 16);
39 }
40
41 static void
42 cc_parse_pos(double *target, char *source)
43 {
44         int     deg;
45         double  min;
46         char    dir;
47         double  r;
48
49         if (sscanf(source, "%d°%lf'%c", &deg, &min, &dir) != 3) {
50                 *target = 0;
51                 return;
52         }
53         r = deg + min / 60.0;
54         if (dir == 'S' || dir == 'W')
55                 r = -r;
56         *target = r;
57 }
58
59 #define PARSE_MAX_WORDS 512
60
61 int
62 cc_telem_parse(const char *input_line, struct cc_telem *telem)
63 {
64         char *saveptr;
65         char *raw_words[PARSE_MAX_WORDS];
66         char **words;
67         int version = 0;
68         int nword;
69         char line_buf[8192], *line;
70         int     tracking_pos;
71
72         /* avoid smashing our input parameter */
73         strncpy (line_buf, input_line, sizeof (line_buf)-1);
74         line_buf[sizeof(line_buf) - 1] = '\0';
75         line = line_buf;
76         for (nword = 0; nword < PARSE_MAX_WORDS; nword++) {
77                 raw_words[nword] = strtok_r(line, " \t\n", &saveptr);
78                 line = NULL;
79                 if (raw_words[nword] == NULL)
80                         break;
81         }
82         if (nword < 36)
83                 return FALSE;
84         words = raw_words;
85         if (strcmp(words[0], "VERSION") == 0) {
86                 cc_parse_int(&version, words[1]);
87                 words += 2;
88                 nword -= 2;
89         }
90
91         if (strcmp(words[0], "CALL") != 0)
92                 return FALSE;
93         cc_parse_string(telem->callsign, sizeof (telem->callsign), words[1]);
94         cc_parse_int(&telem->serial, words[3]);
95
96         cc_parse_int(&telem->rssi, words[5]);
97         cc_parse_string(telem->state, sizeof (telem->state), words[9]);
98         cc_parse_int(&telem->tick, words[10]);
99         cc_parse_int(&telem->accel, words[12]);
100         cc_parse_int(&telem->pres, words[14]);
101         cc_parse_int(&telem->temp, words[16]);
102         cc_parse_int(&telem->batt, words[18]);
103         cc_parse_int(&telem->drogue, words[20]);
104         cc_parse_int(&telem->main, words[22]);
105         cc_parse_int(&telem->flight_accel, words[24]);
106         cc_parse_int(&telem->ground_accel, words[26]);
107         cc_parse_int(&telem->flight_vel, words[28]);
108         cc_parse_int(&telem->flight_pres, words[30]);
109         cc_parse_int(&telem->ground_pres, words[32]);
110         if (version >= 1) {
111                 cc_parse_int(&telem->accel_plus_g, words[34]);
112                 cc_parse_int(&telem->accel_minus_g, words[36]);
113                 words += 4;
114                 nword -= 4;
115         } else {
116                 telem->accel_plus_g = telem->ground_accel;
117                 telem->accel_minus_g = telem->ground_accel + 530;
118         }
119         cc_parse_int(&telem->gps.nsat, words[34]);
120         if (strcmp (words[36], "unlocked") == 0) {
121                 telem->gps.gps_connected = 1;
122                 telem->gps.gps_locked = 0;
123                 telem->gps.gps_time.hour = telem->gps.gps_time.minute = telem->gps.gps_time.second = 0;
124                 telem->gps.lat = telem->gps.lon = 0;
125                 telem->gps.alt = 0;
126                 tracking_pos = 37;
127         } else if (nword >= 40) {
128                 telem->gps.gps_locked = 1;
129                 telem->gps.gps_connected = 1;
130                 sscanf(words[36], "%d:%d:%d", &telem->gps.gps_time.hour, &telem->gps.gps_time.minute, &telem->gps.gps_time.second);
131                 cc_parse_pos(&telem->gps.lat, words[37]);
132                 cc_parse_pos(&telem->gps.lon, words[38]);
133                 sscanf(words[39], "%dm", &telem->gps.alt);
134                 tracking_pos = 46;
135         } else {
136                 telem->gps.gps_connected = 0;
137                 telem->gps.gps_locked = 0;
138                 telem->gps.gps_time.hour = telem->gps.gps_time.minute = telem->gps.gps_time.second = 0;
139                 telem->gps.lat = telem->gps.lon = 0;
140                 telem->gps.alt = 0;
141                 tracking_pos = -1;
142         }
143         if (nword >= 46) {
144                 telem->gps.gps_extended = 1;
145                 sscanf(words[40], "%lfm/s", &telem->gps.ground_speed);
146                 sscanf(words[41], "%d", &telem->gps.course);
147                 sscanf(words[42], "%lfm/s", &telem->gps.climb_rate);
148                 sscanf(words[43], "%lf", &telem->gps.hdop);
149                 sscanf(words[44], "%d", &telem->gps.h_error);
150                 sscanf(words[45], "%d", &telem->gps.v_error);
151         } else {
152                 telem->gps.gps_extended = 0;
153                 telem->gps.ground_speed = 0;
154                 telem->gps.course = 0;
155                 telem->gps.climb_rate = 0;
156                 telem->gps.hdop = 0;
157                 telem->gps.h_error = 0;
158                 telem->gps.v_error = 0;
159         }
160         if (tracking_pos >= 0 && nword >= tracking_pos + 2 && strcmp(words[tracking_pos], "SAT") == 0) {
161                 int     c, n, pos;
162                 cc_parse_int(&n, words[tracking_pos + 1]);
163                 pos = tracking_pos + 2;
164                 if (nword >= pos + n * 3) {
165                         telem->gps_tracking.channels = n;
166                         for (c = 0; c < n; c++) {
167                                 cc_parse_int(&telem->gps_tracking.sats[c].svid,
168                                                  words[pos + 0]);
169                                 cc_parse_hex(&telem->gps_tracking.sats[c].state,
170                                                  words[pos + 1]);
171                                 cc_parse_int(&telem->gps_tracking.sats[c].c_n0,
172                                                  words[pos + 2]);
173                                 pos += 3;
174                         }
175                 } else {
176                         telem->gps_tracking.channels = 0;
177                 }
178         } else {
179                 telem->gps_tracking.channels = 0;
180         }
181         return TRUE;
182 }