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

NAME

   shared_json.c - move data between in-core and JSON structures

DESCRIPTION

   This module uses the generic JSON parser to get data from JSON

representations to gps.h structures. These functions are used in both

the daemon and the client library.

PERMISSIONS

  Written by Eric S. Raymond, 2009

  This file is Copyright 2009 The GPSD project

  SPDX-License-Identifier: BSD-2-clause

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

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

#ifdef SOCKET_EXPORT_ENABLE

#include <math.h>

#include <stdbool.h>

#include "../include/gpsd.h"

#include "../include/gps_json.h"

#include "../include/strfuncs.h"

#include "../include/timespec.h"

int json_device_read(const char *buf,

                     struct devconfig_t *dev,

                     const char **endptr)

{

    // initialized to shut up clang

    double d_cycle = 0.0, d_mincycle = 0.0;

    // *INDENT-OFF*

    const struct json_attr_t json_attrs_device[] = {

        {"class",      t_check,      .dflt.check = "DEVICE"},

        {"path",       t_string,     .addr.string  = dev->path,

                                        .len = sizeof(dev->path)},

        // odd, device->gpsdata.online is sent, but put in dev->activated?

        {"activated",  t_time,       .addr.ts = &dev->activated,

                                        .dflt.ts = {0, 0}},

        {"flags",      t_integer,    .addr.integer = &dev->flags},

        {"driver",     t_string,     .addr.string  = dev->driver,

                                        .len = sizeof(dev->driver)},

        {"sernum",     t_string,     .addr.string  = dev->sernum,

                                        .len = sizeof(dev->sernum)},

        {"subtype",    t_string,     .addr.string  = dev->subtype,

                                        .len = sizeof(dev->subtype)},

        {"subtype1",   t_string,     .addr.string  = dev->subtype1,

                                        .len = sizeof(dev->subtype1)},

        {"hexdata",    t_string,     .addr.string  = dev->hexdata,

                                        .len = sizeof(dev->hexdata)},

        {"native",     t_integer,    .addr.integer = &dev->driver_mode,

                                        .dflt.integer = DEVDEFAULT_NATIVE},

        {"bps",        t_uinteger,   .addr.uinteger = &dev->baudrate,

                                        .dflt.uinteger = DEVDEFAULT_BPS},

        {"parity",     t_character,  .addr.character = &dev->parity,

                                        .dflt.character = DEVDEFAULT_PARITY},

        {"stopbits",   t_uinteger,   .addr.uinteger = &dev->stopbits,

                                        .dflt.uinteger = DEVDEFAULT_STOPBITS},

        {"cycle",      t_real,       .addr.real = &d_cycle,

                                        .dflt.real = NAN},

        {"mincycle",   t_real,       .addr.real = &d_mincycle,

                                        .dflt.real = NAN},

        // ignore unknown keys, for cross-version compatibility

        {"", t_ignore},

        {NULL},

    };

    // *INDENT-ON*

    int status;

    status = json_read_object(buf, json_attrs_device, endptr);

    if (0 != status) {

        return status;

    }

    if (0 == isfinite(d_cycle)) {

        dev->cycle.tv_sec = 0;

        dev->cycle.tv_nsec = 0;

    } else {

        DTOTS(&dev->cycle, d_cycle);

    }

    if (0 == isfinite(d_mincycle)) {

        dev->mincycle.tv_sec = 0;

        dev->mincycle.tv_nsec = 0;

    } else {

        DTOTS(&dev->mincycle, d_mincycle);

    }

    return 0;

}

int json_watch_read(const char *buf,

                    struct gps_policy_t *ccp,

                    const char **endptr)

{

    // *INDENT-OFF*

    struct json_attr_t chanconfig_attrs[] = {

        {"class",          t_check,    .dflt.check = "WATCH"},

        {"device",         t_string,   .addr.string = ccp->devpath,

                                          .len = sizeof(ccp->devpath)},

        {"enable",         t_boolean,  .addr.boolean = &ccp->watcher,

                                          .dflt.boolean = true},

        {"json",           t_boolean,  .addr.boolean = &ccp->json,

                                          .nodefault = true},

        {"nmea",           t_boolean,  .addr.boolean = &ccp->nmea,

                                          .nodefault = true},

        {"pps",            t_boolean,  .addr.boolean = &ccp->pps},

        {"raw",            t_integer,  .addr.integer = &ccp->raw,

                                          .nodefault = true},

        {"remote",         t_string,   .addr.string = ccp->remote,

                                          .len = sizeof(ccp->remote)},

        {"scaled",         t_boolean,  .addr.boolean = &ccp->scaled},

        {"split24",        t_boolean,  .addr.boolean = &ccp->split24},

        {"timing",         t_boolean,  .addr.boolean = &ccp->timing},

        // ignore unknown keys, for cross-version compatibility

        {"", t_ignore},

        {NULL},

    };

    // *INDENT-ON*

    int status;

    status = json_read_object(buf, chanconfig_attrs, endptr);

    return status;

}

/* Translate a gps_policy_t to a WATCH string (outbuf)

 * return outbuf

 */

char *json_policy_to_watch(struct gps_policy_t *ccp,

                           char *outbuf, size_t outbuf_len)

{

    char *str;

    snprintf(outbuf, outbuf_len, "?WATCH={\"device\":\"%s\"", ccp->devpath);

    str = ccp->watcher ? ",\"enable\":true" : ",\"enable\":false";

    (void)strlcat(outbuf, str, outbuf_len);

    str = ccp->json ? ",\"json\":true" : ",\"json\":false";

    (void)strlcat(outbuf, str, outbuf_len);

    str = ccp->nmea ? ",\"nmea\":true" : ",\"nmea\":false";

    (void)strlcat(outbuf, str, outbuf_len);

    str = ccp->pps ? ",\"pps\":true" : ",\"pps\":false";

    (void)strlcat(outbuf, str, outbuf_len);

    str_appendf(outbuf, outbuf_len, ",\"raw\":%u", ccp->raw);

    if ('\0' != ccp->remote[0]) {

        str_appendf(outbuf, outbuf_len, ",\"remote\":%s", ccp->remote);

    }

    str = ccp->scaled ? ",\"scaled\":true" : ",\"scaled\":false";

    (void)strlcat(outbuf, str, outbuf_len);

    str = ccp->split24 ? ",\"split24\":true" : ",\"split24\":false";

    (void)strlcat(outbuf, str, outbuf_len);

    str = ccp->timing ? ",\"timing\":true}\r\n" : ",\"timing\":false}\r\n";

    (void)strlcat(outbuf, str, outbuf_len);

    return outbuf;

}

#endif  // SOCKET_EXPORT_ENABLE

// vim: set expandtab shiftwidth=4