Coverage Report

Created: 2025-10-12 07:12

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