gpsd/ais_json.c

/****************************************************************************

NAME
   ais_json.c - deserialize AIS JSON

DESCRIPTION
   This module uses the generic JSON parser to get data from AIS
representations to libgps structures.

This file is Copyright 2010 by the GPSD project
SPDX-License-Identifier: BSD-2-clause
***************************************************************************/

#include "gpsd_config.h"  /* must be before all includes */

#include <stdio.h>
#include <string.h>
#include <stdbool.h>
#include <stdlib.h>
#include <stddef.h>
#include <time.h>

#include "gps.h"
#include "json.h"
#ifdef SOCKET_EXPORT_ENABLE
#include "libgps.h"

/* kluge because we don't want to include gpsd.h here */
extern int gpsd_hexpack(const char *, char *, size_t);

static void lenhex_unpack(const char *from,
                          size_t * plen, char *to, size_t maxlen)
{
    char *colon = strchr(from, ':');

    *plen = (size_t) atoi(from);
    if (colon != NULL)
        (void)gpsd_hexpack(colon + 1, to, maxlen);
}


int json_ais_read(const char *buf,
                  char *path, size_t pathlen, struct ais_t *ais,
                  const char **endptr)
{
    /* collected but not actually used yet */
    bool scaled;

#define AIS_HEADER \
        {"class",          t_check,    .dflt.check = "AIS"}, \
        {"type",           t_uinteger, .addr.uinteger = &ais->type}, \
        {"device",         t_string,   .addr.string = path, \
                                          .len = pathlen}, \
        {"repeat",         t_uinteger, .addr.uinteger = &ais->repeat}, \
        {"scaled",         t_boolean,  .addr.boolean = &scaled, \
                                          .dflt.boolean = false}, \
        {"mmsi",           t_uinteger, .addr.uinteger = &ais->mmsi},

#define AIS_TYPE6 \
        {"seqno",         t_uinteger,  .addr.uinteger = &ais->type6.seqno,\
                                       .dflt.uinteger = 0},\
        {"dest_mmsi",     t_uinteger,  .addr.uinteger = &ais->type6.dest_mmsi,\
                                       .dflt.uinteger = 0},\
        {"retransmit",    t_boolean,   .addr.boolean = &ais->type6.retransmit,\
                                       .dflt.boolean = false},\
        {"dac",           t_uinteger,  .addr.uinteger = &ais->type6.dac,\
                                       .dflt.uinteger = 0},\
        {"fid",           t_uinteger,  .addr.uinteger = &ais->type6.fid,\
                                       .dflt.uinteger = 0},
#define AIS_TYPE8 \
        {"dac",           t_uinteger,  .addr.uinteger = &ais->type8.dac,\
                                       .dflt.uinteger = 0},\
        {"fid",           t_uinteger,  .addr.uinteger = &ais->type8.fid,\
                                       .dflt.uinteger = 0},

    int status;

#include "ais_json.i"           /* JSON parser template structures */

#undef AIS_HEADER

    memset(ais, '\0', sizeof(struct ais_t));

    if (strstr(buf, "\"type\":1,") != NULL
        || strstr(buf, "\"type\":2,") != NULL
        || strstr(buf, "\"type\":3,") != NULL) {
        status = json_read_object(buf, json_ais1, endptr);
    } else if (strstr(buf, "\"type\":4,") != NULL
               || strstr(buf, "\"type\":11,") != NULL) {
        status = json_read_object(buf, json_ais4, endptr);
        if (status == 0) {
            ais->type4.year = AIS_YEAR_NOT_AVAILABLE;
            ais->type4.month = AIS_MONTH_NOT_AVAILABLE;
            ais->type4.day = AIS_DAY_NOT_AVAILABLE;
            ais->type4.hour = AIS_HOUR_NOT_AVAILABLE;
            ais->type4.minute = AIS_MINUTE_NOT_AVAILABLE;
            ais->type4.second = AIS_SECOND_NOT_AVAILABLE;
            /* We use %09u for the date to allow for dodgy years (>9999)
             * to go through. */
            // cppcheck-suppress uninitvar
            (void)sscanf(timestamp, "%09u-%02u-%02uT%02u:%02u:%02uZ",
                         &ais->type4.year,
                         &ais->type4.month,
                         &ais->type4.day,
                         &ais->type4.hour,
                         &ais->type4.minute,
                         &ais->type4.second);
        }
    } else if (strstr(buf, "\"type\":5,") != NULL) {
        status = json_read_object(buf, json_ais5, endptr);
        if (status == 0) {
            ais->type5.month = AIS_MONTH_NOT_AVAILABLE;
            ais->type5.day = AIS_DAY_NOT_AVAILABLE;
            ais->type5.hour = AIS_HOUR_NOT_AVAILABLE;
            ais->type5.minute = AIS_MINUTE_NOT_AVAILABLE;
            // cppcheck-suppress uninitvar
            (void)sscanf(eta, "%02u-%02uT%02u:%02uZ",
                         &ais->type5.month,
                         &ais->type5.day,
                         &ais->type5.hour,
                         &ais->type5.minute);
        }
    } else if (strstr(buf, "\"type\":6,") != NULL) {
        bool structured = false;
        if (strstr(buf, "\"dac\":1,") != NULL) {
            if (strstr(buf, "\"fid\":12,") != NULL) {
                status = json_read_object(buf, json_ais6_fid12, endptr);
                if (status == 0) {
                    ais->type6.dac1fid12.lmonth = AIS_MONTH_NOT_AVAILABLE;
                    ais->type6.dac1fid12.lday = AIS_DAY_NOT_AVAILABLE;
                    ais->type6.dac1fid12.lhour = AIS_HOUR_NOT_AVAILABLE;
                    ais->type6.dac1fid12.lminute = AIS_MINUTE_NOT_AVAILABLE;
                    // cppcheck-suppress uninitvar
                    (void)sscanf(departure, "%02u-%02uT%02u:%02uZ",
                                 &ais->type6.dac1fid12.lmonth,
                                 &ais->type6.dac1fid12.lday,
                                 &ais->type6.dac1fid12.lhour,
                                 &ais->type6.dac1fid12.lminute);
                    ais->type6.dac1fid12.nmonth = AIS_MONTH_NOT_AVAILABLE;
                    ais->type6.dac1fid12.nday = AIS_DAY_NOT_AVAILABLE;
                    ais->type6.dac1fid12.nhour = AIS_HOUR_NOT_AVAILABLE;
                    ais->type6.dac1fid12.nminute = AIS_MINUTE_NOT_AVAILABLE;
                    // cppcheck-suppress uninitvar
                    (void)sscanf(eta, "%02u-%02uT%02u:%02uZ",
                                 &ais->type6.dac1fid12.nmonth,
                                 &ais->type6.dac1fid12.nday,
                                 &ais->type6.dac1fid12.nhour,
                                 &ais->type6.dac1fid12.nminute);
                }
                structured = true;
            }
            else if (strstr(buf, "\"fid\":15,") != NULL) {
                status = json_read_object(buf, json_ais6_fid15, endptr);
                structured = true;
            }
            else if (strstr(buf, "\"fid\":16,") != NULL) {
                status = json_read_object(buf, json_ais6_fid16, endptr);
                structured = true;
            }
            else if (strstr(buf, "\"fid\":18,") != NULL) {
                status = json_read_object(buf, json_ais6_fid18, endptr);
                if (status == 0) {
                    ais->type6.dac1fid18.day = AIS_DAY_NOT_AVAILABLE;
                    ais->type6.dac1fid18.hour = AIS_HOUR_NOT_AVAILABLE;
                    ais->type6.dac1fid18.minute = AIS_MINUTE_NOT_AVAILABLE;
                    // cppcheck-suppress uninitvar
                    (void)sscanf(arrival, "%02u-%02uT%02u:%02uZ",
                                 &ais->type6.dac1fid18.month,
                                 &ais->type6.dac1fid18.day,
                                 &ais->type6.dac1fid18.hour,
                                 &ais->type6.dac1fid18.minute);
                }
                structured = true;
            }
            else if (strstr(buf, "\"fid\":20,") != NULL) {
                status = json_read_object(buf, json_ais6_fid20, endptr);
                if (status == 0) {
                    ais->type6.dac1fid20.month = AIS_MONTH_NOT_AVAILABLE;
                    ais->type6.dac1fid20.day = AIS_DAY_NOT_AVAILABLE;
                    ais->type6.dac1fid20.hour = AIS_HOUR_NOT_AVAILABLE;
                    ais->type6.dac1fid20.minute = AIS_MINUTE_NOT_AVAILABLE;
                    // cppcheck-suppress uninitvar
                    (void)sscanf(arrival, "%02u-%02uT%02u:%02uZ",
                                 &ais->type6.dac1fid20.month,
                                 &ais->type6.dac1fid20.day,
                                 &ais->type6.dac1fid20.hour,
                                 &ais->type6.dac1fid20.minute);
                }
                structured = true;
            }
            else if (strstr(buf, "\"fid\":25,") != NULL) {
                status = json_read_object(buf, json_ais6_fid25, endptr);
                structured = true;
            }
            else if (strstr(buf, "\"fid\":28,") != NULL) {
                status = json_read_object(buf, json_ais6_fid28, endptr);
                if (status == 0) {
                    ais->type6.dac1fid28.month = AIS_MONTH_NOT_AVAILABLE;
                    ais->type6.dac1fid28.day = AIS_DAY_NOT_AVAILABLE;
                    ais->type6.dac1fid28.hour = AIS_HOUR_NOT_AVAILABLE;
                    ais->type6.dac1fid28.minute = AIS_MINUTE_NOT_AVAILABLE;
                    // cppcheck-suppress uninitvar
                    (void)sscanf(start, "%02u-%02uT%02u:%02uZ",
                                 &ais->type6.dac1fid28.month,
                                 &ais->type6.dac1fid28.day,
                                 &ais->type6.dac1fid28.hour,
                                 &ais->type6.dac1fid28.minute);
                }
                structured = true;
            }
            else if (strstr(buf, "\"fid\":30,") != NULL) {
                status = json_read_object(buf, json_ais6_fid30, endptr);
                structured = true;
            }
            else if (strstr(buf, "\"fid\":32,") != NULL ||
                     strstr(buf, "\"fid\":14,") != NULL) {
                status = json_read_object(buf, json_ais6_fid32, endptr);
                structured = true;
            }
        }
        else if (strstr(buf, "\"dac\":235,") != NULL ||
                 strstr(buf, "\"dac\":250,") != NULL) {
            if (strstr(buf, "\"fid\":10,") != NULL) {
                status = json_read_object(buf, json_ais6_fid10, endptr);
                structured = true;
            }
        }
        else if (strstr(buf, "\"dac\":200,") != NULL) {
            if (strstr(buf, "\"fid\":21,") != NULL) {
                status = json_read_object(buf, json_ais6_fid21, endptr);
                structured = true;
                if (status == 0) {
                    ais->type6.dac200fid21.month = AIS_MONTH_NOT_AVAILABLE;
                    ais->type6.dac200fid21.day = AIS_DAY_NOT_AVAILABLE;
                    ais->type6.dac200fid21.hour = AIS_HOUR_NOT_AVAILABLE;
                    ais->type6.dac200fid21.minute = AIS_MINUTE_NOT_AVAILABLE;
                    // cppcheck-suppress uninitvar
                    (void)sscanf(eta, "%02u-%02uT%02u:%02u",
                                 &ais->type6.dac200fid21.month,
                                 &ais->type6.dac200fid21.day,
                                 &ais->type6.dac200fid21.hour,
                                 &ais->type6.dac200fid21.minute);
                }
            }
            else if (strstr(buf, "\"fid\":22,") != NULL) {
                status = json_read_object(buf, json_ais6_fid22, endptr);
                structured = true;
                if (status == 0) {
                    ais->type6.dac200fid22.month = AIS_MONTH_NOT_AVAILABLE;
                    ais->type6.dac200fid22.day = AIS_DAY_NOT_AVAILABLE;
                    ais->type6.dac200fid22.hour = AIS_HOUR_NOT_AVAILABLE;
                    ais->type6.dac200fid22.minute = AIS_MINUTE_NOT_AVAILABLE;
                    // cppcheck-suppress uninitvar
                    (void)sscanf(rta, "%02u-%02uT%02u:%02u",
                                 &ais->type6.dac200fid22.month,
                                 &ais->type6.dac200fid22.day,
                                 &ais->type6.dac200fid22.hour,
                                 &ais->type6.dac200fid22.minute);
                }
            }
            else if (strstr(buf, "\"fid\":55,") != NULL) {
                status = json_read_object(buf, json_ais6_fid55, endptr);
                structured = true;
            }
        }
        if (!structured) {
            status = json_read_object(buf, json_ais6, endptr);
            if (status == 0)
                lenhex_unpack(data, &ais->type6.bitcount,
                              ais->type6.bitdata, sizeof(ais->type6.bitdata));
        }
        ais->type6.structured = structured;
    } else if (strstr(buf, "\"type\":7,") != NULL
               || strstr(buf, "\"type\":13,") != NULL) {
        status = json_read_object(buf, json_ais7, endptr);
    } else if (strstr(buf, "\"type\":8,") != NULL) {
        bool structured = false;
        if (strstr(buf, "\"dac\":1,") != NULL) {
            if (strstr(buf, "\"fid\":11,") != NULL) {
                status = json_read_object(buf, json_ais8_fid11, endptr);
                if (status == 0) {
                    ais->type8.dac1fid11.day = AIS_DAY_NOT_AVAILABLE;
                    ais->type8.dac1fid11.hour = AIS_HOUR_NOT_AVAILABLE;
                    ais->type8.dac1fid11.minute = AIS_MINUTE_NOT_AVAILABLE;
                    // cppcheck-suppress uninitvar
                    (void)sscanf(timestamp, "%02uT%02u:%02uZ",
                                 &ais->type8.dac1fid11.day,
                                 &ais->type8.dac1fid11.hour,
                                 &ais->type8.dac1fid11.minute);
                }
                structured = true;
            }
            else if (strstr(buf, "\"fid\":13,") != NULL) {
                status = json_read_object(buf, json_ais8_fid13, endptr);
                if (status == 0) {
                    ais->type8.dac1fid13.fmonth = AIS_MONTH_NOT_AVAILABLE;
                    ais->type8.dac1fid13.fday = AIS_DAY_NOT_AVAILABLE;
                    ais->type8.dac1fid13.fhour = AIS_HOUR_NOT_AVAILABLE;
                    ais->type8.dac1fid13.fminute = AIS_MINUTE_NOT_AVAILABLE;
                    // cppcheck-suppress uninitvar
                    (void)sscanf(departure, "%02u-%02uT%02u:%02uZ",
                                 &ais->type8.dac1fid13.fmonth,
                                 &ais->type8.dac1fid13.fday,
                                 &ais->type8.dac1fid13.fhour,
                                 &ais->type8.dac1fid13.fminute);
                    ais->type8.dac1fid13.tmonth = AIS_MONTH_NOT_AVAILABLE;
                    ais->type8.dac1fid13.tday = AIS_DAY_NOT_AVAILABLE;
                    ais->type8.dac1fid13.thour = AIS_HOUR_NOT_AVAILABLE;
                    ais->type8.dac1fid13.tminute = AIS_MINUTE_NOT_AVAILABLE;
                    // cppcheck-suppress uninitvar
                    (void)sscanf(eta, "%02u-%02uT%02u:%02uZ",
                                 &ais->type8.dac1fid13.tmonth,
                                 &ais->type8.dac1fid13.tday,
                                 &ais->type8.dac1fid13.thour,
                                 &ais->type8.dac1fid13.tminute);
                }
                structured = true;
            }
            else if (strstr(buf, "\"fid\":15,") != NULL) {
                status = json_read_object(buf, json_ais8_fid15, endptr);
                structured = true;
            }
            else if (strstr(buf, "\"fid\":16,") != NULL) {
                status = json_read_object(buf, json_ais8_fid16, endptr);
                if (status == 0) {
                        structured = true;
                }
            }
            else if (strstr(buf, "\"fid\":17,") != NULL) {
                status = json_read_object(buf, json_ais8_fid17, endptr);
                structured = true;
            }
            else if (strstr(buf, "\"fid\":19,") != NULL) {
                status = json_read_object(buf, json_ais8_fid19, endptr);
                structured = true;
            }
            else if (strstr(buf, "\"fid\":23,") != NULL) {
                status = json_read_object(buf, json_ais8_fid23, endptr);
                ais->type8.dac200fid23.start_year = AIS_YEAR_NOT_AVAILABLE;
                ais->type8.dac200fid23.start_month = AIS_MONTH_NOT_AVAILABLE;
                ais->type8.dac200fid23.start_day = AIS_DAY_NOT_AVAILABLE;
                ais->type8.dac200fid23.start_hour = AIS_HOUR_NOT_AVAILABLE;
                ais->type8.dac200fid23.start_minute = AIS_MINUTE_NOT_AVAILABLE;
                ais->type8.dac200fid23.end_year = AIS_YEAR_NOT_AVAILABLE;
                ais->type8.dac200fid23.end_month = AIS_MONTH_NOT_AVAILABLE;
                ais->type8.dac200fid23.end_day = AIS_DAY_NOT_AVAILABLE;
                ais->type8.dac200fid23.end_hour = AIS_HOUR_NOT_AVAILABLE;
                ais->type8.dac200fid23.end_minute = AIS_MINUTE_NOT_AVAILABLE;
                // cppcheck-suppress uninitvar
                (void)sscanf(start, "%09u-%02u-%02uT%02u:%02u",
                         &ais->type8.dac200fid23.start_year,
                         &ais->type8.dac200fid23.start_month,
                         &ais->type8.dac200fid23.start_day,
                         &ais->type8.dac200fid23.start_hour,
                         &ais->type8.dac200fid23.start_minute);
                // cppcheck-suppress uninitvar
                (void)sscanf(end, "%09u-%02u-%02uT%02u:%02u",
                         &ais->type8.dac200fid23.end_year,
                         &ais->type8.dac200fid23.end_month,
                         &ais->type8.dac200fid23.end_day,
                         &ais->type8.dac200fid23.end_hour,
                         &ais->type8.dac200fid23.end_minute);
                structured = true;
            }
            else if (strstr(buf, "\"fid\":24,") != NULL) {
                status = json_read_object(buf, json_ais8_fid24, endptr);
                structured = true;
            }
            else if (strstr(buf, "\"fid\":27,") != NULL) {
                status = json_read_object(buf, json_ais8_fid27, endptr);
                if (status == 0) {
                    ais->type8.dac1fid27.month = AIS_MONTH_NOT_AVAILABLE;
                    ais->type8.dac1fid27.day = AIS_DAY_NOT_AVAILABLE;
                    ais->type8.dac1fid27.hour = AIS_HOUR_NOT_AVAILABLE;
                    ais->type8.dac1fid27.minute = AIS_MINUTE_NOT_AVAILABLE;
                    // cppcheck-suppress uninitvar
                    (void)sscanf(start, "%02u-%02uT%02u:%02uZ",
                                 &ais->type8.dac1fid27.month,
                                 &ais->type8.dac1fid27.day,
                                 &ais->type8.dac1fid27.hour,
                                 &ais->type8.dac1fid27.minute);
                }
                structured = true;
            }
            else if (strstr(buf, "\"fid\":29,") != NULL) {
                status = json_read_object(buf, json_ais8_fid29, endptr);
                structured = true;
            }
            else if (strstr(buf, "\"fid\":31,") != NULL) {
                status = json_read_object(buf, json_ais8_fid31, endptr);
                if (status == 0) {
                    ais->type8.dac1fid31.day = AIS_DAY_NOT_AVAILABLE;
                    ais->type8.dac1fid31.hour = AIS_HOUR_NOT_AVAILABLE;
                    ais->type8.dac1fid31.minute = AIS_MINUTE_NOT_AVAILABLE;
                    // cppcheck-suppress uninitvar
                    (void)sscanf(timestamp, "%02uT%02u:%02uZ",
                                 &ais->type8.dac1fid31.day,
                                 &ais->type8.dac1fid31.hour,
                                 &ais->type8.dac1fid31.minute);
                }
                structured = true;
            }
        }
        else if (strstr(buf, "\"dac\":200,") != NULL &&
                 strstr(buf,"data")==NULL) {
            if (strstr(buf, "\"fid\":10,") != NULL) {
                status = json_read_object(buf, json_ais8_fid10, endptr);
                structured = true;
            }
            if (strstr(buf, "\"fid\":40,") != NULL) {
                status = json_read_object(buf, json_ais8_fid40, endptr);
                structured = true;
            }
        }
        if (!structured) {
            status = json_read_object(buf, json_ais8, endptr);
            if (status == 0)
                lenhex_unpack(data, &ais->type8.bitcount,
                              ais->type8.bitdata, sizeof(ais->type8.bitdata));
        }
        ais->type8.structured = structured;
    } else if (strstr(buf, "\"type\":9,") != NULL) {
        status = json_read_object(buf, json_ais9, endptr);
    } else if (strstr(buf, "\"type\":10,") != NULL) {
        status = json_read_object(buf, json_ais10, endptr);
    } else if (strstr(buf, "\"type\":12,") != NULL) {
        status = json_read_object(buf, json_ais12, endptr);
    } else if (strstr(buf, "\"type\":14,") != NULL) {
        status = json_read_object(buf, json_ais14, endptr);
    } else if (strstr(buf, "\"type\":15,") != NULL) {
        status = json_read_object(buf, json_ais15, endptr);
    } else if (strstr(buf, "\"type\":16,") != NULL) {
        status = json_read_object(buf, json_ais16, endptr);
    } else if (strstr(buf, "\"type\":17,") != NULL) {
        status = json_read_object(buf, json_ais17, endptr);
        if (status == 0)
            lenhex_unpack(data, &ais->type17.bitcount,
                          ais->type17.bitdata, sizeof(ais->type17.bitdata));
    } else if (strstr(buf, "\"type\":18,") != NULL) {
        status = json_read_object(buf, json_ais18, endptr);
    } else if (strstr(buf, "\"type\":19,") != NULL) {
        status = json_read_object(buf, json_ais19, endptr);
    } else if (strstr(buf, "\"type\":20,") != NULL) {
        status = json_read_object(buf, json_ais20, endptr);
    } else if (strstr(buf, "\"type\":21,") != NULL) {
        status = json_read_object(buf, json_ais21, endptr);
    } else if (strstr(buf, "\"type\":22,") != NULL) {
        status = json_read_object(buf, json_ais22, endptr);
    } else if (strstr(buf, "\"type\":23,") != NULL) {
        status = json_read_object(buf, json_ais23, endptr);
    } else if (strstr(buf, "\"type\":24,") != NULL) {
        status = json_read_object(buf, json_ais24, endptr);
    } else if (strstr(buf, "\"type\":25,") != NULL) {
        status = json_read_object(buf, json_ais25, endptr);
        if (status == 0)
            lenhex_unpack(data, &ais->type25.bitcount,
                          ais->type25.bitdata, sizeof(ais->type25.bitdata));
    } else if (strstr(buf, "\"type\":26,") != NULL) {
        status = json_read_object(buf, json_ais26, endptr);
        if (status == 0)
            lenhex_unpack(data, &ais->type26.bitcount,
                          ais->type26.bitdata, sizeof(ais->type26.bitdata));
    } else if (strstr(buf, "\"type\":27,") != NULL) {
        status = json_read_object(buf, json_ais27, endptr);
    } else {
        if (endptr != NULL)
            *endptr = NULL;
        return JSON_ERR_MISC;
    }
    return status;
}
#endif /* SOCKET_EXPORT_ENABLE */

/* ais_json.c ends here */
// vim: set expandtab shiftwidth=4