Coverage Report

Created: 2026-10-12 06:10

next uncovered line (L), next uncovered region (R), next uncovered branch (B)
/src/gpsd/gpsd-3.27.6~dev/libgps/libgps_json.c
Line
Count
Source
1
/****************************************************************************
2
3
NAME
4
   libgps_json.c - deserialize gpsd data coming from the server
5
6
DESCRIPTION
7
   This module uses the generic JSON parser to get data from JSON
8
representations to libgps structures.
9
10
PERMISSIONS
11
   Written by Eric S. Raymond, 2009
12
   This file is Copyright by the GPSD project
13
   SPDX-License-Identifier: BSD-2-clause
14
15
***************************************************************************/
16
17
/* isfinite() needs _POSIX_C_SOURCE >= 200112L
18
 * isnan(+Inf) is false, isfinite(+Inf) is false
19
 * use isfinite() to make sure a float or double is valid
20
 */
21
22
#include "../include/gpsd_config.h"   // must be before all includes
23
24
#include <assert.h>                  // for assert()  :-(
25
#include <math.h>
26
#include <stdbool.h>
27
#include <stddef.h>
28
#include <string.h>
29
30
#include "../include/gpsd.h"
31
#include "../include/strfuncs.h"
32
#include "../include/gps_json.h"
33
#include "../include/timespec.h"
34
35
static int json_tpv_read(const char *buf, struct gps_data_t *gpsdata,
36
                         const char **endptr)
37
0
{
38
0
    int ret;
39
40
0
    const struct json_attr_t json_attrs_1[] = {
41
        // *INDENT-OFF*
42
0
        {"class",  t_check,   .dflt.check = "TPV"},
43
0
        {"alt",    t_real,    .addr.real = &gpsdata->fix.altitude,
44
0
                                 .dflt.real = NAN}, // DEPRECATED, undefined
45
0
        {"altHAE", t_real,    .addr.real = &gpsdata->fix.altHAE,
46
0
                                 .dflt.real = NAN},
47
0
        {"altMSL", t_real,    .addr.real = &gpsdata->fix.altMSL,
48
0
                                 .dflt.real = NAN},
49
0
        {"ant",    t_integer, .addr.integer = &gpsdata->fix.ant_stat,
50
0
                                 .dflt.integer = 0},
51
0
        {"antPwr",    t_integer, .addr.integer = &gpsdata->fix.ant_power,
52
0
                                 .dflt.integer = 0},
53
0
        {"baseS",     t_integer,   .addr.integer = &gpsdata->fix.base.status,
54
0
         .dflt.integer = STATUS_UNK},     // aka zero
55
0
        {"baseE",     t_real,      .addr.real = &gpsdata->fix.base.east,
56
0
         .dflt.real = NAN},
57
0
        {"baseN",     t_real,      .addr.real = &gpsdata->fix.base.north,
58
0
         .dflt.real = NAN},
59
0
        {"baseU",     t_real,      .addr.real = &gpsdata->fix.base.up,
60
0
         .dflt.real = NAN},
61
0
        {"baseL",     t_real,      .addr.real = &gpsdata->fix.base.length,
62
0
         .dflt.real = NAN},
63
0
        {"baseC",     t_real,      .addr.real = &gpsdata->fix.base.course,
64
0
         .dflt.real = NAN},
65
0
        {"climb",     t_real,      .addr.real = &gpsdata->fix.climb,
66
0
                                   .dflt.real = NAN},
67
0
        {"clockbias", t_longint, .addr.longint = &gpsdata->fix.clockbias,
68
0
                                 .dflt.longint = 0},
69
0
        {"clockdrift", t_longint, .addr.longint = &gpsdata->fix.clockdrift,
70
0
                                 .dflt.longint = 0},
71
0
        {"datum",  t_string,  .addr.string = gpsdata->fix.datum,
72
0
                                 .len = sizeof(gpsdata->fix.datum)},
73
0
        {"device", t_string,  .addr.string = gpsdata->dev.path,
74
0
                                 .len = sizeof(gpsdata->dev.path)},
75
0
        {"depth", t_real,  .addr.real = &gpsdata->fix.depth,
76
0
                                 .dflt.real = NAN},
77
0
        {"dgpsAge", t_real, .addr.real = &gpsdata->fix.dgps_age,
78
0
                                 .dflt.real = NAN},
79
0
        {"dgpsRatio", t_real, .addr.real = &gpsdata->fix.base.ratio,
80
0
                                 .dflt.real = NAN},
81
0
        {"dgpsSta", t_integer, .addr.integer = &gpsdata->fix.dgps_station,
82
0
                                 .dflt.integer = -1},
83
0
        {"ecefx",  t_real,    .addr.real = &gpsdata->fix.ecef.x,
84
0
                                 .dflt.real = NAN},
85
0
        {"ecefy",  t_real,    .addr.real = &gpsdata->fix.ecef.y,
86
0
                                 .dflt.real = NAN},
87
0
        {"ecefz",  t_real,    .addr.real = &gpsdata->fix.ecef.z,
88
0
                                 .dflt.real = NAN},
89
0
        {"ecefvx", t_real,    .addr.real = &gpsdata->fix.ecef.vx,
90
0
                                 .dflt.real = NAN},
91
0
        {"ecefvy", t_real,    .addr.real = &gpsdata->fix.ecef.vy,
92
0
                                 .dflt.real = NAN},
93
0
        {"ecefvz", t_real,    .addr.real = &gpsdata->fix.ecef.vz,
94
0
                                 .dflt.real = NAN},
95
0
        {"ecefpAcc", t_real,  .addr.real = &gpsdata->fix.ecef.pAcc,
96
0
                                 .dflt.real = NAN},
97
0
        {"ecefvAcc", t_real,  .addr.real = &gpsdata->fix.ecef.vAcc,
98
0
                                 .dflt.real = NAN},
99
0
        {"epc",    t_real,    .addr.real = &gpsdata->fix.epc,
100
0
                                 .dflt.real = NAN},
101
0
        {"epd",    t_real,    .addr.real = &gpsdata->fix.epd,
102
0
                                 .dflt.real = NAN},
103
0
        {"eph",    t_real,    .addr.real = &gpsdata->fix.eph,
104
0
                                 .dflt.real = NAN},
105
0
        {"eps",    t_real,    .addr.real = &gpsdata->fix.eps,
106
0
                                 .dflt.real = NAN},
107
0
        {"ept",    t_real,    .addr.real = &gpsdata->fix.ept,
108
0
                                 .dflt.real = NAN},
109
0
        {"epx",    t_real,    .addr.real = &gpsdata->fix.epx,
110
0
                                 .dflt.real = NAN},
111
0
        {"epy",    t_real,    .addr.real = &gpsdata->fix.epy,
112
0
                                 .dflt.real = NAN},
113
0
        {"epv",    t_real,    .addr.real = &gpsdata->fix.epv,
114
0
                                 .dflt.real = NAN},
115
0
        {"geoidSep", t_real,  .addr.real = &gpsdata->fix.geoid_sep,
116
0
                                 .dflt.real = NAN},
117
0
        {"lat",    t_real,    .addr.real = &gpsdata->fix.latitude,
118
0
                                 .dflt.real = NAN},
119
0
        {"jam",    t_integer, .addr.integer = &gpsdata->fix.jam,
120
0
                                 .dflt.integer = -1},
121
0
        {"leapseconds",   t_integer, .addr.integer = &gpsdata->leap_seconds,
122
0
                                 .dflt.integer = 0},
123
0
        {"lon",    t_real,    .addr.real = &gpsdata->fix.longitude,
124
0
                                 .dflt.real = NAN},
125
0
        {"magdev",  t_real,   .addr.real = &gpsdata->fix.magnetic_dev,
126
0
                                 .dflt.real = NAN},
127
0
        {"magtrack",  t_real,    .addr.real = &gpsdata->fix.magnetic_track,
128
0
                                 .dflt.real = NAN},
129
0
        {"magvar",  t_real,   .addr.real = &gpsdata->fix.magnetic_var,
130
0
                                 .dflt.real = NAN},
131
0
        {"mode",   t_integer, .addr.integer = &gpsdata->fix.mode,
132
0
                                 .dflt.integer = MODE_NOT_SEEN},
133
0
        {"relD", t_real,  .addr.real = &gpsdata->fix.NED.relPosD,
134
0
                                 .dflt.real = NAN},
135
0
        {"relE", t_real,  .addr.real = &gpsdata->fix.NED.relPosE,
136
0
                                 .dflt.real = NAN},
137
0
        {"relN", t_real,  .addr.real = &gpsdata->fix.NED.relPosN,
138
0
                                 .dflt.real = NAN},
139
0
        {"relH", t_real,  .addr.real = &gpsdata->fix.NED.relPosH,
140
0
                                 .dflt.real = NAN},
141
0
        {"relL", t_real,  .addr.real = &gpsdata->fix.NED.relPosL,
142
0
                                 .dflt.real = NAN},
143
0
        {"temp",   t_real, .addr.real = &gpsdata->fix.temp,
144
0
                                 .dflt.real = NAN},
145
0
        {"time",   t_time,    .addr.ts = &gpsdata->fix.time,
146
0
                                 .dflt.ts = {0, 0}},
147
0
        {"track",  t_real,    .addr.real = &gpsdata->fix.track,
148
0
                                 .dflt.real = NAN},
149
0
        {"sep",    t_real,    .addr.real = &gpsdata->fix.sep,
150
0
                                 .dflt.real = NAN},
151
0
        {"speed",  t_real,    .addr.real = &gpsdata->fix.speed,
152
0
                                 .dflt.real = NAN},
153
0
        {"status", t_integer, .addr.integer = &gpsdata->fix.status,
154
0
                                 .dflt.integer = STATUS_UNK},
155
0
        {"velD", t_real,  .addr.real = &gpsdata->fix.NED.velD,
156
0
                                 .dflt.real = NAN},
157
0
        {"velE", t_real,  .addr.real = &gpsdata->fix.NED.velE,
158
0
                                 .dflt.real = NAN},
159
0
        {"velN", t_real,  .addr.real = &gpsdata->fix.NED.velN,
160
0
                                 .dflt.real = NAN},
161
0
        {"wanglem", t_real, .addr.real = &gpsdata->fix.wanglem,
162
0
                                 .dflt.real = NAN},
163
0
        {"wangler", t_real, .addr.real = &gpsdata->fix.wangler,
164
0
                                 .dflt.real = NAN},
165
0
        {"wanglet", t_real, .addr.real = &gpsdata->fix.wanglet,
166
0
                                 .dflt.real = NAN},
167
0
        {"wspeedr", t_real, .addr.real = &gpsdata->fix.wspeedr,
168
0
                                 .dflt.real = NAN},
169
0
        {"wspeedt", t_real, .addr.real = &gpsdata->fix.wspeedt,
170
0
                                 .dflt.real = NAN},
171
0
        {"wtemp", t_real, .addr.real = &gpsdata->fix.wtemp,
172
0
                                 .dflt.real = NAN},
173
        // ignore unknown keys, for cross-version compatibility
174
0
        {"", t_ignore},
175
176
0
        {NULL},
177
        // *INDENT-ON*
178
0
    };
179
180
0
    ret = json_read_object(buf, json_attrs_1, endptr);
181
0
    if (1 == isfinite(gpsdata->fix.magnetic_dev) ||
182
0
        1 == isfinite(gpsdata->fix.magnetic_track) ||
183
0
        1 == isfinite(gpsdata->fix.magnetic_var)) {
184
0
        gpsdata->set |= MAGNETIC_TRACK_SET;
185
0
    }
186
0
    if (1 == isfinite(gpsdata->fix.track)) {
187
0
        gpsdata->set |= TRACK_SET;
188
0
    }
189
0
    return ret;
190
0
}
191
192
static int json_noise_read(const char *buf, struct gps_data_t *gpsdata,
193
                           const char **endptr)
194
0
{
195
0
    int ret;
196
197
0
    const struct json_attr_t json_attrs_1[] = {
198
        // *INDENT-OFF*
199
0
        {"class",  t_check,   .dflt.check = "GST"},
200
0
        {"device", t_string,  .addr.string = gpsdata->dev.path,
201
0
                                 .len = sizeof(gpsdata->dev.path)},
202
0
        {"time",   t_time,    .addr.ts = &gpsdata->gst.utctime,
203
0
                                 .dflt.ts = {0, 0}},
204
0
        {"alt",    t_real,    .addr.real = &gpsdata->gst.alt_err_deviation,
205
0
                                 .dflt.real = NAN},
206
0
        {"lat",    t_real,    .addr.real = &gpsdata->gst.lat_err_deviation,
207
0
                                 .dflt.real = NAN},
208
0
        {"lon",    t_real,    .addr.real = &gpsdata->gst.lon_err_deviation,
209
0
                                 .dflt.real = NAN},
210
0
        {"major",  t_real,    .addr.real = &gpsdata->gst.smajor_deviation,
211
0
                                 .dflt.real = NAN},
212
0
        {"minor",  t_real,    .addr.real = &gpsdata->gst.sminor_deviation,
213
0
                                 .dflt.real = NAN},
214
0
        {"orient", t_real,    .addr.real = &gpsdata->gst.smajor_orientation,
215
0
                                 .dflt.real = NAN},
216
0
        {"rms",    t_real,    .addr.real = &gpsdata->gst.rms_deviation,
217
0
                                 .dflt.real = NAN},
218
0
        {"ve",     t_real,    .addr.real = &gpsdata->gst.ve_err_deviation,
219
0
                                 .dflt.real = NAN},
220
0
        {"vn",     t_real,    .addr.real = &gpsdata->gst.vn_err_deviation,
221
0
                                 .dflt.real = NAN},
222
0
        {"vu",     t_real,    .addr.real = &gpsdata->gst.vu_err_deviation,
223
0
                                 .dflt.real = NAN},
224
        // ignore unknown keys, for cross-version compatibility
225
0
        {"", t_ignore},
226
0
        {NULL},
227
        // *INDENT-ON*
228
0
    };
229
230
0
    ret = json_read_object(buf, json_attrs_1, endptr);
231
232
0
    return ret;
233
0
}
234
235
// decode a RAW messages into gpsdata.raw
236
static int json_raw_read(const char *buf, struct gps_data_t *gpsdata,
237
                         const char **endptr)
238
0
{
239
0
    unsigned measurements;
240
    // initialized to shut up clang
241
0
    double mtime_s = 0.0, mtime_ns = 0.0;
242
243
0
    const struct json_attr_t json_attrs_meas[] = {
244
        // *INDENT-OFF*
245
0
        {"gnssid",       t_ubyte,    STRUCTOBJECT(struct meas_t, gnssid)},
246
0
        {"svid",         t_ubyte,    STRUCTOBJECT(struct meas_t, svid)},
247
0
        {"sigid",        t_ubyte,    STRUCTOBJECT(struct meas_t, sigid),
248
0
                                     .dflt.ubyte = 0},
249
0
        {"snr",          t_ubyte,    STRUCTOBJECT(struct meas_t, snr)},
250
0
        {"freqid",       t_ubyte,    STRUCTOBJECT(struct meas_t, freqid),
251
0
                                     .dflt.ubyte = 0},
252
0
        {"obs",          t_string,   STRUCTOBJECT(struct meas_t, obs_code),
253
0
                                .len = sizeof(gpsdata->raw.meas[0].obs_code)},
254
0
        {"lli",          t_ubyte,    STRUCTOBJECT(struct meas_t, lli),
255
0
                                     .dflt.ubyte = 0},
256
0
        {"locktime",     t_uinteger, STRUCTOBJECT(struct meas_t, locktime),
257
0
                                     .dflt.uinteger = 0},
258
0
        {"carrierphase", t_real,     STRUCTOBJECT(struct meas_t, carrierphase),
259
0
                                     .dflt.real = NAN},
260
0
        {"pseudorange",  t_real,     STRUCTOBJECT(struct meas_t, pseudorange),
261
0
                                     .dflt.real = NAN},
262
0
        {"doppler",      t_real,     STRUCTOBJECT(struct meas_t, doppler),
263
0
                                     .dflt.real = NAN},
264
0
        {"c2c",          t_real,     STRUCTOBJECT(struct meas_t, c2c),
265
0
                                    .dflt.real = NAN},
266
0
        {"l2c",          t_real,     STRUCTOBJECT(struct meas_t, l2c),
267
0
                                    .dflt.real = NAN},
268
        // ignore unknown keys, for cross-version compatibility
269
0
        {"", t_ignore},
270
        // *INDENT-ON*
271
0
        {NULL},
272
0
    };
273
0
    const struct json_attr_t json_attrs_raw[] = {
274
        // *INDENT-OFF*
275
0
        {"class",      t_check,   .dflt.check = "RAW"},
276
0
        {"device",     t_string,  .addr.string  = gpsdata->dev.path,
277
0
                                    .len = sizeof(gpsdata->dev.path)},
278
0
        {"time",       t_real,    .addr.real = &mtime_s,
279
0
                                 .dflt.real = NAN},
280
0
        {"nsec",       t_real,    .addr.real = &mtime_ns,
281
0
                                 .dflt.real = NAN},
282
0
        {"rawdata",    t_array,   STRUCTARRAY(gpsdata->raw.meas,
283
0
                                     json_attrs_meas, &measurements)},
284
        // ignore unknown keys, for cross-version compatibility
285
0
        {"", t_ignore},
286
0
        {NULL},
287
        // *INDENT-ON*
288
0
    };
289
0
    int status;
290
291
0
    memset(&gpsdata->raw, 0, sizeof(gpsdata->raw));
292
293
0
    status = json_read_object(buf, json_attrs_raw, endptr);
294
0
    if (0 != status) {
295
0
        return status;
296
0
    }
297
0
    gpsdata->set |= RAW_SET;
298
0
    if (0 == isfinite(mtime_s) ||
299
0
        0 == isfinite(mtime_ns)) {
300
0
        return status;
301
0
    }
302
0
    gpsdata->raw.mtime.tv_sec = (time_t)mtime_s;
303
0
    gpsdata->raw.mtime.tv_nsec = (long)mtime_ns;
304
305
0
    return 0;
306
0
}
307
308
static int json_sky_read(const char *buf, struct gps_data_t *gpsdata,
309
                         const char **endptr)
310
0
{
311
312
0
    const struct json_attr_t json_attrs_satellites[] = {
313
        // *INDENT-OFF*
314
0
        {"PRN",    t_short,   STRUCTOBJECT(struct satellite_t, PRN)},
315
0
        {"az",     t_real,    STRUCTOBJECT(struct satellite_t, azimuth),
316
0
                              .dflt.real = NAN},
317
0
        {"el",     t_real,    STRUCTOBJECT(struct satellite_t, elevation),
318
0
                              .dflt.real = NAN},
319
0
        {"freqid", t_byte,    STRUCTOBJECT(struct satellite_t, freqid),
320
0
                              .dflt.byte = -1},
321
0
        {"gnssid", t_ubyte,   STRUCTOBJECT(struct satellite_t, gnssid)},
322
0
        {"health", t_ubyte,   STRUCTOBJECT(struct satellite_t, health),
323
0
                              .dflt.ubyte = SAT_HEALTH_UNK},
324
0
        {"pr",     t_real,    STRUCTOBJECT(struct satellite_t, pr),
325
0
                              .dflt.real = NAN},
326
0
        {"prRate", t_real,    STRUCTOBJECT(struct satellite_t, prRate),
327
0
                              .dflt.real = NAN},
328
0
        {"prRes",  t_real,    STRUCTOBJECT(struct satellite_t, prRes),
329
0
                              .dflt.real = NAN},
330
0
        {"ss",     t_real,    STRUCTOBJECT(struct satellite_t, ss),
331
0
                              .dflt.real = NAN},
332
0
        {"sigid",  t_ubyte,   STRUCTOBJECT(struct satellite_t, sigid)},
333
0
        {"svid",   t_ubyte,   STRUCTOBJECT(struct satellite_t, svid)},
334
0
        {"used",   t_boolean, STRUCTOBJECT(struct satellite_t, used)},
335
        // ignore unknown keys, for cross-version compatibility
336
0
        {"", t_ignore},
337
        // *INDENT-ON*
338
0
        {NULL},
339
0
    };
340
341
0
    int nSat = -1;  // Use nSat only to know if sats are in SKY
342
343
0
    const struct json_attr_t json_attrs_2[] = {
344
        // *INDENT-OFF*
345
0
        {"class",      t_check,   .dflt.check = "SKY"},
346
0
        {"device",     t_string,  .addr.string  = gpsdata->dev.path,
347
0
                                     .len = sizeof(gpsdata->dev.path)},
348
0
        {"gdop",       t_real,    .addr.real    = &gpsdata->dop.gdop,
349
0
                                     .dflt.real = NAN},
350
0
        {"hdop",       t_real,    .addr.real    = &gpsdata->dop.hdop,
351
0
                                     .dflt.real = NAN},
352
0
        {"nSat",       t_integer, .addr.integer = &nSat,
353
0
                                     .dflt.integer = -1},
354
0
        {"pdop",       t_real,    .addr.real    = &gpsdata->dop.pdop,
355
0
                                     .dflt.real = NAN},
356
0
        {"tdop",       t_real,    .addr.real    = &gpsdata->dop.tdop,
357
0
                                     .dflt.real = NAN},
358
0
        {"vdop",       t_real,    .addr.real    = &gpsdata->dop.vdop,
359
0
                                     .dflt.real = NAN},
360
0
        {"xdop",       t_real,    .addr.real    = &gpsdata->dop.xdop,
361
0
                                     .dflt.real = NAN},
362
0
        {"ydop",       t_real,    .addr.real    = &gpsdata->dop.ydop,
363
0
                                     .dflt.real = NAN},
364
0
        {"satellites", t_array,
365
0
                                   STRUCTARRAY(gpsdata->skyview,
366
0
                                         json_attrs_satellites,
367
0
                                         &gpsdata->satellites_visible)},
368
0
        {"time",       t_time,    .addr.ts = &gpsdata->skyview_time,
369
0
                                     .dflt.ts = {0, 0}},
370
0
        {"uSat",       t_integer, .addr.integer = &gpsdata->satellites_used,
371
0
                                     .dflt.integer = 0},
372
        // ignore unknown keys, for cross-version compatibility
373
0
        {"", t_ignore},
374
0
        {NULL},
375
        // *INDENT-ON*
376
0
    };
377
0
    int status, i;
378
379
0
    memset(&gpsdata->skyview, 0, sizeof(gpsdata->skyview));
380
381
0
    status = json_read_object(buf, json_attrs_2, endptr);
382
0
    if (0 != status) {
383
0
        return status;
384
0
    }
385
386
0
    if (1 == isfinite(gpsdata->dop.hdop) ||
387
0
        1 == isfinite(gpsdata->dop.xdop) ||
388
0
        1 == isfinite(gpsdata->dop.ydop) ||
389
0
        1 == isfinite(gpsdata->dop.vdop) ||
390
0
        1 == isfinite(gpsdata->dop.tdop) ||
391
0
        1 == isfinite(gpsdata->dop.pdop) ||
392
0
        1 == isfinite(gpsdata->dop.gdop)) {
393
        // got at least one DOP
394
0
        gpsdata->set |= DOP_SET;
395
0
    }
396
397
0
    gpsdata->satellites_visible = 0;
398
399
0
    if (-1 == nSat) {
400
        // no sats in the SKY, likely just dops.  Maybe uSat
401
0
        gpsdata->set &= ~SATELLITE_SET;
402
0
        return 0;
403
0
    }
404
0
    gpsdata->satellites_used = 0;
405
406
0
    gpsdata->set |= SATELLITE_SET;
407
    // recalculate used and visible, do not use nSat, uSat
408
0
    for (i = 0; i < MAXCHANNELS; i++) {
409
0
        if (0 < gpsdata->skyview[i].PRN) {
410
0
            gpsdata->satellites_visible++;
411
0
        }
412
0
        if (gpsdata->skyview[i].used) {
413
0
            gpsdata->satellites_used++;
414
0
        }
415
0
    }
416
417
0
    return 0;
418
0
}
419
420
// decode class ATT, almost the same as IMU
421
static int json_att_read(const char *buf, struct gps_data_t *gpsdata,
422
                         const char **endptr)
423
0
{
424
0
    struct attitude_t *datap = &gpsdata->attitude;
425
426
0
    const struct json_attr_t json_attrs_1[] = {
427
        // *INDENT-OFF*
428
0
        {"class",     t_check,     .dflt.check = "ATT"},
429
0
        {"device",    t_string,    .addr.string = gpsdata->dev.path,
430
0
         .len = sizeof(gpsdata->dev.path)},
431
0
        {"acc_len",   t_real,      .addr.real = &datap->acc_len,
432
0
         .dflt.real = NAN},
433
0
        {"acc_x",     t_real,      .addr.real = &datap->acc_x,
434
0
         .dflt.real = NAN},
435
0
        {"acc_y",     t_real,      .addr.real = &datap->acc_y,
436
0
         .dflt.real = NAN},
437
0
        {"acc_z",     t_real,      .addr.real = &datap->acc_z,
438
0
         .dflt.real = NAN},
439
0
        {"baseS",     t_integer,   .addr.integer = &datap->base.status,
440
0
         .dflt.integer = STATUS_UNK},     // aka zero
441
0
        {"baseE",     t_real,      .addr.real = &datap->base.east,
442
0
         .dflt.real = NAN},
443
0
        {"baseN",     t_real,      .addr.real = &datap->base.north,
444
0
         .dflt.real = NAN},
445
0
        {"baseU",     t_real,      .addr.real = &datap->base.up,
446
0
         .dflt.real = NAN},
447
0
        {"baseL",     t_real,      .addr.real = &datap->base.length,
448
0
         .dflt.real = NAN},
449
0
        {"baseC",     t_real,      .addr.real = &datap->base.course,
450
0
         .dflt.real = NAN},
451
0
        {"dgpsRatio", t_real, .addr.real = &datap->base.ratio,
452
0
         .dflt.real = NAN},
453
0
        {"depth",     t_real,      .addr.real = &datap->depth,
454
0
         .dflt.real = NAN},
455
0
        {"dip",       t_real,      .addr.real = &datap->dip,
456
0
         .dflt.real = NAN},
457
0
        {"gyro_temp", t_real,      .addr.real = &datap->gyro_x,
458
0
         .dflt.real = NAN},
459
0
        {"gyro_x",    t_real,      .addr.real = &datap->gyro_x,
460
0
         .dflt.real = NAN},
461
0
        {"gyro_y",    t_real,      .addr.real = &datap->gyro_y,
462
0
         .dflt.real = NAN},
463
0
        {"gyro_z",    t_real,      .addr.real = &datap->gyro_z,
464
0
         .dflt.real = NAN},
465
0
        {"heading",   t_real,      .addr.real = &datap->heading,
466
0
         .dflt.real = NAN},
467
0
        {"mag_len",   t_real,      .addr.real = &datap->mag_len,
468
0
         .dflt.real = NAN},
469
0
        {"mag_st",    t_character, .addr.character = &datap->mag_st},
470
0
        {"mag_x",     t_real,      .addr.real = &datap->mag_x,
471
0
         .dflt.real = NAN},
472
0
        {"mag_y",     t_real,      .addr.real = &datap->mag_y,
473
0
         .dflt.real = NAN},
474
0
        {"mag_z",     t_real,      .addr.real = &datap->mag_z,
475
0
         .dflt.real = NAN},
476
0
        {"mheading",   t_real,     .addr.real = &datap->mheading,
477
0
         .dflt.real = NAN},
478
0
        {"msg",       t_string,    .addr.string = datap->msg,
479
0
         .len = sizeof(datap->msg)},
480
0
        {"pitch_st",  t_character, .addr.character = &datap->pitch_st},
481
0
        {"pitch",     t_real,      .addr.real = &datap->pitch,
482
0
         .dflt.real = NAN},
483
0
        {"roll_st",   t_character, .addr.character = &datap->roll_st},
484
0
        {"roll",      t_real,      .addr.real = &datap->roll,
485
0
         .dflt.real = NAN},
486
0
        {"temp",      t_real,      .addr.real = &datap->temp,
487
0
         .dflt.real = NAN},
488
0
        {"time",      t_time,      .addr.ts = &datap->mtime, .dflt.ts = {0, 0}},
489
0
        {"timeTag",   t_ulongint,  .addr.ulongint = &datap->timeTag,
490
0
         .dflt.ulongint = 0},
491
0
        {"yaw_st",    t_character, .addr.character = &datap->yaw_st},
492
0
        {"yaw",       t_real,      .addr.real = &datap->yaw, .dflt.real = NAN},
493
494
        // ignore unknown keys, for cross-version compatibility
495
0
        {"", t_ignore},
496
0
        {NULL},
497
        // *INDENT-ON*
498
0
    };
499
500
0
    return json_read_object(buf, json_attrs_1, endptr);
501
0
}
502
503
// decode class IMU, almost the ame as ATT
504
static int json_imu_read(const char *buf, struct gps_data_t *gpsdata,
505
                         const char **endptr)
506
0
{
507
    // the client only uses the first slot.
508
0
    struct attitude_t *datap = &gpsdata->imu[0];
509
510
0
    const struct json_attr_t json_attrs_1[] = {
511
        // *INDENT-OFF*
512
0
        {"class",     t_check,     .dflt.check = "IMU"},
513
0
        {"device",    t_string,    .addr.string = gpsdata->dev.path,
514
0
         .len = sizeof(gpsdata->dev.path)},
515
0
        {"acc_len",   t_real,      .addr.real = &datap->acc_len,
516
0
         .dflt.real = NAN},
517
0
        {"acc_x",     t_real,      .addr.real = &datap->acc_x,
518
0
         .dflt.real = NAN},
519
0
        {"acc_y",     t_real,      .addr.real = &datap->acc_y,
520
0
         .dflt.real = NAN},
521
0
        {"acc_z",     t_real,      .addr.real = &datap->acc_z,
522
0
         .dflt.real = NAN},
523
0
        {"depth",     t_real,      .addr.real = &datap->depth,
524
0
         .dflt.real = NAN},
525
0
        {"dip",       t_real,      .addr.real = &datap->dip,
526
0
         .dflt.real = NAN},
527
0
        {"gyro_temp", t_real,      .addr.real = &datap->gyro_temp,
528
0
         .dflt.real = NAN},
529
0
        {"gyro_x",    t_real,      .addr.real = &datap->gyro_x,
530
0
         .dflt.real = NAN},
531
0
        {"gyro_y",    t_real,      .addr.real = &datap->gyro_y,
532
0
         .dflt.real = NAN},
533
0
        {"gyro_z",    t_real,      .addr.real = &datap->gyro_z,
534
0
         .dflt.real = NAN},
535
0
        {"heading",   t_real,      .addr.real = &datap->heading,
536
0
         .dflt.real = NAN},
537
0
        {"mag_len",   t_real,      .addr.real = &datap->mag_len,
538
0
         .dflt.real = NAN},
539
0
        {"mag_st",    t_character, .addr.character = &datap->mag_st},
540
0
        {"mag_x",     t_real,      .addr.real = &datap->mag_x,
541
0
         .dflt.real = NAN},
542
0
        {"mag_y",     t_real,      .addr.real = &datap->mag_y,
543
0
         .dflt.real = NAN},
544
0
        {"mag_z",     t_real,      .addr.real = &datap->mag_z,
545
0
         .dflt.real = NAN},
546
0
        {"msg",       t_string,    .addr.string = datap->msg,
547
0
         .len = sizeof(datap->msg)},
548
0
        {"pitch_st",  t_character, .addr.character = &datap->pitch_st},
549
0
        {"pitch",     t_real,      .addr.real = &datap->pitch,
550
0
         .dflt.real = NAN},
551
0
        {"roll_st",   t_character, .addr.character = &datap->roll_st},
552
0
        {"roll",      t_real,      .addr.real = &datap->roll,
553
0
         .dflt.real = NAN},
554
0
        {"temp",      t_real,      .addr.real = &datap->temp,
555
0
         .dflt.real = NAN},
556
0
        {"time",      t_time,      .addr.ts = &datap->mtime, .dflt.ts = {0, 0}},
557
0
        {"timeTag",   t_ulongint,  .addr.ulongint = &datap->timeTag,
558
0
         .dflt.ulongint = 0},
559
0
        {"yaw_st",    t_character, .addr.character = &datap->yaw_st},
560
0
        {"yaw",       t_real,      .addr.real = &datap->yaw, .dflt.real = NAN},
561
562
        // ignore unknown keys, for cross-version compatibility
563
0
        {"", t_ignore},
564
0
        {NULL},
565
        // *INDENT-ON*
566
0
    };
567
568
0
    return json_read_object(buf, json_attrs_1, endptr);
569
0
}
570
571
static int json_devicelist_read(const char *buf, struct gps_data_t *gpsdata,
572
                                const char **endptr)
573
0
{
574
0
    const struct json_attr_t json_attrs_subdevices[] = {
575
        // *INDENT-OFF*
576
0
        {"class",      t_check,      .dflt.check = "DEVICE"},
577
0
        {"path",       t_string,     STRUCTOBJECT(struct devconfig_t, path),
578
0
         .len = sizeof(gpsdata->devices.list[0].path)},
579
0
        {"activated",  t_time,
580
0
         STRUCTOBJECT(struct devconfig_t, activated)},
581
0
        {"flags",      t_integer,    STRUCTOBJECT(struct devconfig_t, flags)},
582
0
        {"driver",     t_string,     STRUCTOBJECT(struct devconfig_t, driver),
583
0
         .len = sizeof(gpsdata->devices.list[0].driver)},
584
0
        {"hexdata",    t_string,     STRUCTOBJECT(struct devconfig_t, hexdata),
585
0
         .len = sizeof(gpsdata->devices.list[0].hexdata)},
586
0
        {"sernum",     t_string,     STRUCTOBJECT(struct devconfig_t, sernum),
587
0
                            .len = sizeof(gpsdata->devices.list[0].sernum)},
588
0
        {"subtype",    t_string,     STRUCTOBJECT(struct devconfig_t, subtype),
589
0
                            .len = sizeof(gpsdata->devices.list[0].subtype)},
590
0
        {"subtype1",   t_string,     STRUCTOBJECT(struct devconfig_t, subtype1),
591
0
                            .len = sizeof(gpsdata->devices.list[0].subtype1)},
592
0
        {"native",     t_integer, STRUCTOBJECT(struct devconfig_t, driver_mode),
593
0
                                        .dflt.integer = -1},
594
0
        {"bps",        t_uinteger,   STRUCTOBJECT(struct devconfig_t, baudrate),
595
0
                                        .dflt.uinteger = DEVDEFAULT_BPS},
596
0
        {"parity",     t_character,  STRUCTOBJECT(struct devconfig_t, parity),
597
0
                                        .dflt.character = DEVDEFAULT_PARITY},
598
0
        {"stopbits",   t_uinteger,   STRUCTOBJECT(struct devconfig_t, stopbits),
599
0
                                        .dflt.integer = DEVDEFAULT_STOPBITS},
600
0
        {"cycle",      t_timespec,   STRUCTOBJECT(struct devconfig_t, cycle),
601
0
                                        .dflt.ts = {0,0}},
602
0
        {"mincycle",   t_timespec,   STRUCTOBJECT(struct devconfig_t, mincycle),
603
0
                                        .dflt.ts = {0,0}},
604
        // ignore unknown keys, for cross-version compatibility
605
0
        {"", t_ignore},
606
0
        {NULL},
607
        // *INDENT-ON*
608
0
    };
609
0
    const struct json_attr_t json_attrs_devices[] = {
610
0
        {"class", t_check,.dflt.check = "DEVICES"},
611
0
        {"devices", t_array, STRUCTARRAY(gpsdata->devices.list,
612
0
                                         json_attrs_subdevices,
613
0
                                         &gpsdata->devices.ndevices)},
614
        // ignore unknown keys, for cross-version compatibility
615
0
        {"", t_ignore},
616
0
        {NULL},
617
0
    };
618
0
    int status;
619
620
0
    memset(&gpsdata->devices, 0, sizeof(gpsdata->devices));
621
0
    status = json_read_object(buf, json_attrs_devices, endptr);
622
0
    if (status != 0) {
623
0
        return status;
624
0
    }
625
626
    // json.c should ensure this never happens
627
0
    assert(MAXUSERDEVS >= gpsdata->devices.ndevices);
628
629
0
    (void)clock_gettime(CLOCK_REALTIME, &gpsdata->devices.time);
630
0
    return 0;
631
0
}
632
633
static int json_version_read(const char *buf, struct gps_data_t *gpsdata,
634
                             const char **endptr)
635
0
{
636
0
    const struct json_attr_t json_attrs_version[] = {
637
        // *INDENT-OFF*
638
0
        {"class",     t_check,   .dflt.check = "VERSION"},
639
0
        {"release",   t_string,  .addr.string  = gpsdata->version.release,
640
0
                                    .len = sizeof(gpsdata->version.release)},
641
0
        {"rev",       t_string,  .addr.string  = gpsdata->version.rev,
642
0
                                    .len = sizeof(gpsdata->version.rev)},
643
0
        {"proto_major", t_integer,
644
0
         .addr.integer = &gpsdata->version.proto_major},
645
0
        {"proto_minor", t_integer,
646
0
         .addr.integer = &gpsdata->version.proto_minor},
647
0
        {"remote",    t_string,  .addr.string  = gpsdata->version.remote,
648
0
                                    .len = sizeof(gpsdata->version.remote)},
649
        // ignore unknown keys, for cross-version compatibility
650
0
        {"", t_ignore},
651
0
        {NULL},
652
        // *INDENT-ON*
653
0
    };
654
0
    int status;
655
656
0
    memset(&gpsdata->version, 0, sizeof(gpsdata->version));
657
0
    status = json_read_object(buf, json_attrs_version, endptr);
658
659
0
    return status;
660
0
}
661
662
static int json_error_read(const char *buf, struct gps_data_t *gpsdata,
663
                           const char **endptr)
664
0
{
665
0
    const struct json_attr_t json_attrs_error[] = {
666
        // *INDENT-OFF*
667
0
        {"class",     t_check,   .dflt.check = "ERROR"},
668
0
        {"message",   t_string,  .addr.string  = gpsdata->error,
669
0
                                    .len = sizeof(gpsdata->error)},
670
        // ignore unknown keys, for cross-version compatibility
671
0
        {"", t_ignore},
672
0
        {NULL},
673
        // *INDENT-ON*
674
0
    };
675
0
    int status;
676
677
0
    memset(&gpsdata->error, 0, sizeof(gpsdata->error));
678
0
    status = json_read_object(buf, json_attrs_error, endptr);
679
0
    if (status != 0)
680
0
        return status;
681
682
0
    return status;
683
0
}
684
685
int json_toff_read(const char *buf, struct gps_data_t *gpsdata,
686
                           const char **endptr)
687
0
{
688
0
    int real_sec = 0, real_nsec = 0, clock_sec = 0, clock_nsec = 0;
689
0
    const struct json_attr_t json_attrs_toff[] = {
690
        // *INDENT-OFF*
691
0
        {"class",     t_check,   .dflt.check = "TOFF"},
692
0
        {"device",    t_string,  .addr.string = gpsdata->dev.path,
693
0
                                 .len = sizeof(gpsdata->dev.path)},
694
0
        {"real_sec",  t_integer, .addr.integer = &real_sec,
695
0
                                 .dflt.integer = 0},
696
0
        {"real_nsec", t_integer, .addr.integer = &real_nsec,
697
0
                                 .dflt.integer = 0},
698
0
        {"clock_sec", t_integer, .addr.integer = &clock_sec,
699
0
                                 .dflt.integer = 0},
700
0
        {"clock_nsec",t_integer, .addr.integer = &clock_nsec,
701
0
                                 .dflt.integer = 0},
702
        // ignore unknown keys, for cross-version compatibility
703
0
        {"", t_ignore},
704
0
        {NULL},
705
        // *INDENT-ON*
706
0
    };
707
0
    int status;
708
709
0
    memset(&gpsdata->toff, 0, sizeof(gpsdata->toff));
710
0
    status = json_read_object(buf, json_attrs_toff, endptr);
711
0
    gpsdata->toff.real.tv_sec = (time_t)real_sec;
712
0
    gpsdata->toff.real.tv_nsec = (long)real_nsec;
713
0
    gpsdata->toff.clock.tv_sec = (time_t)clock_sec;
714
0
    gpsdata->toff.clock.tv_nsec = (long)clock_nsec;
715
0
    if (status != 0)
716
0
        return status;
717
718
0
    return status;
719
0
}
720
721
int json_pps_read(const char *buf, struct gps_data_t *gpsdata,
722
                  const char **endptr)
723
0
{
724
0
    int real_sec = 0, real_nsec = 0, clock_sec = 0, clock_nsec = 0, precision=0;
725
0
    int qErr = 0;
726
727
0
    const struct json_attr_t json_attrs_pps[] = {
728
        // *INDENT-OFF*
729
0
        {"class",     t_check,   .dflt.check = "PPS"},
730
0
        {"device",    t_string,  .addr.string = gpsdata->dev.path,
731
0
                                 .len = sizeof(gpsdata->dev.path)},
732
0
        {"real_sec",  t_integer, .addr.integer = &real_sec,
733
0
                                 .dflt.integer = 0},
734
0
        {"real_nsec", t_integer, .addr.integer = &real_nsec,
735
0
                                 .dflt.integer = 0},
736
0
        {"clock_sec", t_integer, .addr.integer = &clock_sec,
737
0
                                 .dflt.integer = 0},
738
0
        {"clock_nsec",t_integer, .addr.integer = &clock_nsec,
739
0
                                 .dflt.integer = 0},
740
0
        {"precision", t_integer, .addr.integer = &precision,
741
0
                                 .dflt.integer = 0},
742
0
        {"qErr", t_integer, .addr.integer = &qErr,
743
0
                                 .dflt.integer = 0},
744
        // ignore unknown keys, for cross-version compatibility
745
0
        {"", t_ignore},
746
0
        {NULL},
747
        // *INDENT-ON*
748
0
    };
749
0
    int status;
750
751
0
    memset(&gpsdata->pps, 0, sizeof(gpsdata->pps));
752
0
    status = json_read_object(buf, json_attrs_pps, endptr);
753
754
    // This is good until GPS are more than nanosec accurate
755
0
    gpsdata->pps.real.tv_sec = (time_t)real_sec;
756
0
    gpsdata->pps.real.tv_nsec = (long)real_nsec;
757
0
    gpsdata->pps.clock.tv_sec = (time_t)clock_sec;
758
0
    gpsdata->pps.clock.tv_nsec = (long)clock_nsec;
759
    // hope qErr fits in int
760
0
    gpsdata->qErr = (long)qErr;
761
762
    // FIXME: precision is currently parsed but discarded
763
0
    return status;
764
0
}
765
766
int json_oscillator_read(const char *buf, struct gps_data_t *gpsdata,
767
                         const char **endptr)
768
0
{
769
0
    bool running = false, reference = false, disciplined = false;
770
0
    int delta = 0;
771
0
    const struct json_attr_t json_attrs_osc[] = {
772
        // *INDENT-OFF*
773
0
        {"class",       t_check,   .dflt.check = "OSC"},
774
0
        {"device",      t_string,  .addr.string = gpsdata->dev.path,
775
0
                                   .len = sizeof(gpsdata->dev.path)},
776
0
        {"running",     t_boolean, .addr.boolean = &running,
777
0
                                   .dflt.boolean = false},
778
0
        {"reference",   t_boolean, .addr.boolean = &reference,
779
0
                                   .dflt.boolean = false},
780
0
        {"disciplined", t_boolean, .addr.boolean = &disciplined,
781
0
                                   .dflt.boolean = false},
782
0
        {"delta",       t_integer, .addr.integer = &delta,
783
0
                                   .dflt.integer = 0},
784
        // ignore unknown keys, for cross-version compatibility
785
0
        {"", t_ignore},
786
0
        {NULL},
787
        // *INDENT-ON*
788
0
    };
789
0
    int status;
790
791
0
    memset(&gpsdata->osc, 0, sizeof(gpsdata->osc));
792
0
    status = json_read_object(buf, json_attrs_osc, endptr);
793
794
0
    gpsdata->osc.running = running;
795
0
    gpsdata->osc.reference = reference;
796
0
    gpsdata->osc.disciplined = disciplined;
797
0
    gpsdata->osc.delta = delta;
798
799
0
    return status;
800
0
}
801
802
/* Test for JSON read status values that should be treated as a go-ahead
803
 * for further processing.  JSON_BADATTR - to allow JSON attributes unknown
804
 * to this version of the library, for forward compatibility, is an obvious
805
 * thing to go here.
806
 * Until microjson is fixed to allow t_array as t_ignore, mask that too.
807
 */
808
0
#define FILTER(n) (((n) == JSON_ERR_BADATTR ||   \
809
0
                    (n) == JSON_ERR_NOARRAY) ? 0 : n)
810
0
#define PASS(n) (0 == FILTER(n))
811
812
/* the only entry point - unpack a JSON object into gpsdata_t substructures
813
 *
814
 * Returns: 0 if OK
815
 *          -1 on unknown
816
 *         JSON_ERR_xx code
817
 */
818
int libgps_json_unpack(const char *buf,
819
                       struct gps_data_t *gpsdata, const char **end)
820
0
{
821
0
    int status;
822
0
    const char *classtag = strstr(buf, "\"class\":");
823
824
0
    if (NULL == classtag) {
825
0
        return -1;
826
0
    }
827
828
0
    if (str_starts_with(classtag, "\"class\":\"TPV\"")) {
829
0
        status = json_tpv_read(buf, gpsdata, end);
830
0
        gpsdata->set = STATUS_SET;
831
0
        if (0 != gpsdata->fix.time.tv_sec) {
832
0
            gpsdata->set |= TIME_SET;
833
0
        }
834
0
        if (0 != isfinite(gpsdata->fix.ept)) {
835
0
            gpsdata->set |= TIMERR_SET;
836
0
        }
837
0
        if (0 != isfinite(gpsdata->fix.longitude)) {
838
0
            gpsdata->set |= LATLON_SET;
839
0
        }
840
0
        if (0 != isfinite(gpsdata->fix.altitude) ||
841
0
            0 != isfinite(gpsdata->fix.altHAE) ||
842
0
            0 != isfinite(gpsdata->fix.depth) ||
843
0
            0 != isfinite(gpsdata->fix.altMSL)) {
844
0
            gpsdata->set |= ALTITUDE_SET;
845
0
        }
846
0
        if (0 != isfinite(gpsdata->fix.epx) &&
847
0
            0 != isfinite(gpsdata->fix.epy)) {
848
0
            gpsdata->set |= HERR_SET;
849
0
        }
850
0
        if (0 != isfinite(gpsdata->fix.epv)) {
851
0
            gpsdata->set |= VERR_SET;
852
0
        }
853
0
        if (0 != isfinite(gpsdata->fix.track)) {
854
0
            gpsdata->set |= TRACK_SET;
855
0
        }
856
0
        if (0 != isfinite(gpsdata->fix.magnetic_track) ||
857
0
            0 != isfinite(gpsdata->fix.magnetic_var)) {
858
0
            gpsdata->set |= MAGNETIC_TRACK_SET;
859
0
        }
860
0
        if (0 != isfinite(gpsdata->fix.speed)) {
861
0
            gpsdata->set |= SPEED_SET;
862
0
        }
863
0
        if (0 != isfinite(gpsdata->fix.climb)) {
864
0
            gpsdata->set |= CLIMB_SET;
865
0
        }
866
0
        if (0 != isfinite(gpsdata->fix.epd)) {
867
0
            gpsdata->set |= TRACKERR_SET;
868
0
        }
869
0
        if (0 != isfinite(gpsdata->fix.eps)) {
870
0
            gpsdata->set |= SPEEDERR_SET;
871
0
        }
872
0
        if (0 != isfinite(gpsdata->fix.epc)) {
873
0
            gpsdata->set |= CLIMBERR_SET;
874
0
        }
875
0
        if (MODE_NOT_SEEN != gpsdata->fix.mode) {
876
0
            gpsdata->set |= MODE_SET;
877
0
        }
878
0
        if (0 != isfinite(gpsdata->fix.wanglem) ||
879
0
            0 != isfinite(gpsdata->fix.wangler) ||
880
0
            0 != isfinite(gpsdata->fix.wanglet) ||
881
0
            0 != isfinite(gpsdata->fix.wspeedr) ||
882
0
            0 != isfinite(gpsdata->fix.wspeedt)) {
883
0
            gpsdata->set |= NAVDATA_SET;
884
0
        }
885
0
        if (0 != isfinite(gpsdata->fix.NED.relPosN) ||
886
0
            0 != isfinite(gpsdata->fix.NED.relPosE) ||
887
0
            0 != isfinite(gpsdata->fix.NED.relPosD) ||
888
0
            0 != isfinite(gpsdata->fix.NED.relPosH) ||
889
0
            0 != isfinite(gpsdata->fix.NED.relPosL) ||
890
0
            0 != isfinite(gpsdata->fix.NED.velN) ||
891
0
            0 != isfinite(gpsdata->fix.NED.velE) ||
892
0
            0 != isfinite(gpsdata->fix.NED.velD)) {
893
0
            gpsdata->set |= NED_SET;
894
0
        }
895
0
        if ((0 != isfinite(gpsdata->fix.ecef.x)) &&
896
0
            (0 != isfinite(gpsdata->fix.ecef.y)) &&
897
0
            (0 != isfinite(gpsdata->fix.ecef.z))) {
898
            // All, or none.  Clients can just do their own isfinite()s
899
0
            gpsdata->set |= ECEF_SET;
900
0
        }
901
0
        if ((0 != isfinite(gpsdata->fix.ecef.vx)) &&
902
0
            (0 != isfinite(gpsdata->fix.ecef.vy)) &&
903
0
            (0 != isfinite(gpsdata->fix.ecef.vz))) {
904
            // All, or none.  Clients can just do their own isfinite()s
905
0
            gpsdata->set |= VECEF_SET;
906
0
        }
907
0
        return FILTER(status);
908
0
    }
909
0
    if (str_starts_with(classtag, "\"class\":\"GST\"")) {
910
0
        status = json_noise_read(buf, gpsdata, end);
911
0
        if (PASS(status)) {
912
0
            gpsdata->set &= ~UNION_SET;
913
0
            gpsdata->set |= GST_SET;
914
0
        }
915
0
        return FILTER(status);
916
0
    }
917
0
    if (str_starts_with(classtag, "\"class\":\"SKY\"")) {
918
0
        status = json_sky_read(buf, gpsdata, end);
919
0
        return FILTER(status);
920
0
    }
921
0
    if (str_starts_with(classtag, "\"class\":\"ATT\"")) {
922
0
        status = json_att_read(buf, gpsdata, end);
923
0
        if (PASS(status)) {
924
0
            gpsdata->set |= ATTITUDE_SET;
925
0
        }
926
0
        return FILTER(status);
927
0
    }
928
0
    if (str_starts_with(classtag, "\"class\":\"IMU\"")) {
929
0
        status = json_imu_read(buf, gpsdata, end);
930
0
        if (PASS(status)) {
931
0
            gpsdata->set |= IMU_SET;
932
0
        }
933
0
        return FILTER(status);
934
0
    }
935
0
    if (str_starts_with(classtag, "\"class\":\"DEVICES\"")) {
936
0
        status = json_devicelist_read(buf, gpsdata, end);
937
0
        if (PASS(status)) {
938
0
            gpsdata->set &= ~UNION_SET;
939
0
            gpsdata->set |= DEVICELIST_SET;
940
0
        }
941
0
        return FILTER(status);
942
0
    }
943
0
    if (str_starts_with(classtag, "\"class\":\"DEVICE\"")) {
944
0
        status = json_device_read(buf, &gpsdata->dev, end);
945
0
        if (PASS(status))
946
0
            gpsdata->set |= DEVICE_SET;
947
0
        return FILTER(status);
948
0
    }
949
0
    if (str_starts_with(classtag, "\"class\":\"WATCH\"")) {
950
0
        status = json_watch_read(buf, &gpsdata->policy, end);
951
0
        if (PASS(status)) {
952
0
            gpsdata->set &= ~UNION_SET;
953
0
            gpsdata->set |= POLICY_SET;
954
0
        }
955
0
        return FILTER(status);
956
0
    }
957
0
    if (str_starts_with(classtag, "\"class\":\"VERSION\"")) {
958
0
        status = json_version_read(buf, gpsdata, end);
959
0
        if (status ==  0) {
960
0
            gpsdata->set &= ~UNION_SET;
961
0
            gpsdata->set |= VERSION_SET;
962
0
        }
963
0
        return FILTER(status);
964
0
    }
965
0
    if (str_starts_with(classtag, "\"class\":\"RTCM2\"")) {
966
0
        status = json_rtcm2_read(buf,
967
0
                                 gpsdata->dev.path, sizeof(gpsdata->dev.path),
968
0
                                 &gpsdata->rtcm2, end);
969
0
        if (PASS(status)) {
970
0
            gpsdata->set &= ~UNION_SET;
971
0
            gpsdata->set |= RTCM2_SET;
972
0
        }
973
0
        return FILTER(status);
974
0
    }
975
0
    if (str_starts_with(classtag, "\"class\":\"RTCM3\"")) {
976
0
        status = json_rtcm3_read(buf,
977
0
                                 gpsdata->dev.path, sizeof(gpsdata->dev.path),
978
0
                                 &gpsdata->rtcm3, end);
979
0
        if (PASS(status)) {
980
0
            gpsdata->set &= ~UNION_SET;
981
0
            gpsdata->set |= RTCM3_SET;
982
0
        }
983
0
        return FILTER(status);
984
0
    }
985
0
#ifdef AIVDM_ENABLE
986
0
    if (str_starts_with(classtag, "\"class\":\"AIS\"")) {
987
0
        status = json_ais_read(buf,
988
0
                               gpsdata->dev.path, sizeof(gpsdata->dev.path),
989
0
                               &gpsdata->ais, end);
990
0
        if (PASS(status)) {
991
0
            gpsdata->set &= ~UNION_SET;
992
0
            gpsdata->set |= AIS_SET;
993
0
        }
994
0
        return FILTER(status);
995
0
    }
996
0
#endif  // AIVDM_ENABLE
997
0
    if (str_starts_with(classtag, "\"class\":\"ERROR\"")) {
998
0
        status = json_error_read(buf, gpsdata, end);
999
0
        if (PASS(status)) {
1000
0
            gpsdata->set &= ~UNION_SET;
1001
0
            gpsdata->set |= ERROR_SET;
1002
0
        }
1003
0
        return FILTER(status);
1004
0
    }
1005
0
    if (str_starts_with(classtag, "\"class\":\"TOFF\"")) {
1006
0
        status = json_toff_read(buf, gpsdata, end);
1007
0
        if (PASS(status)) {
1008
0
            gpsdata->set &= ~UNION_SET;
1009
0
            gpsdata->set |= TOFF_SET;
1010
0
        }
1011
0
        return FILTER(status);
1012
0
    }
1013
0
    if (str_starts_with(classtag, "\"class\":\"PPS\"")) {
1014
0
        status = json_pps_read(buf, gpsdata, end);
1015
0
        if (PASS(status)) {
1016
0
            gpsdata->set &= ~UNION_SET;
1017
0
            gpsdata->set |= PPS_SET;
1018
0
        }
1019
0
        return FILTER(status);
1020
0
    }
1021
0
    if (str_starts_with(classtag, "\"class\":\"OSC\"")) {
1022
0
        status = json_oscillator_read(buf, gpsdata, end);
1023
0
        if (PASS(status)) {
1024
0
            gpsdata->set &= ~UNION_SET;
1025
0
            gpsdata->set |= OSCILLATOR_SET;
1026
0
        }
1027
0
        return FILTER(status);
1028
0
    }
1029
0
    if (str_starts_with(classtag, "\"class\":\"RAW\"")) {
1030
0
        status = json_raw_read(buf, gpsdata, end);
1031
0
        if (PASS(status)) {
1032
0
            gpsdata->set &= ~UNION_SET;
1033
0
            gpsdata->set |= RAW_SET;
1034
0
        }
1035
0
        return FILTER(status);
1036
0
    }
1037
    // else, unknown class type
1038
0
    return -1;
1039
0
}
1040
1041
1042
1043
// vim: set expandtab shiftwidth=4