Vergil Cola
Fork of my original MQTTGateway
Diff: jsmn/RadioCfg.cpp
- Revision:
- 0:a1734fe1ec4b
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/jsmn/RadioCfg.cpp Sat Apr 08 14:43:14 2017 +0000
@@ -0,0 +1,157 @@
+#include "RadioCfg.h"
+#include <string.h>
+#include <stdlib.h>
+
+static char tempstr[100];
+
+static int jsoneq(const char * json, jsmntok_t * tok, const char * s)
+{
+ if (tok->type == JSMN_STRING && (int) strlen(s) == tok->end - tok->start &&
+ strncmp(json + tok->start, s, tok->end - tok->start) == 0) {
+ return 0;
+ }
+ return -1;
+}
+
+int parseradioconfig(const char * jsonstring, RadioCfg & radiocfg)
+{
+ int i, r;
+
+ jsmn_parser p;
+ jsmntok_t t[128];
+
+ jsmn_init(&p);
+ r = jsmn_parse(&p, jsonstring, strlen(jsonstring), t, sizeof(t)/sizeof(t[0]));
+ if ( r < 0 )
+ return -1;
+
+ /* Top level element is an object */
+ if (r < 1 || t[0].type != JSMN_OBJECT)
+ {
+ return -1;
+ }
+
+ /* Loop over all tokens */
+ for (i = 1; i < r; i++)
+ {
+ if (jsoneq(jsonstring, &t[i], "error") == 0)
+ {
+ // Query returned an error ...
+ return -1;
+ }
+ else if (jsoneq(jsonstring, &t[i], "id") == 0)
+ {
+ memset(&tempstr[0], 0, sizeof(tempstr));
+ strncpy(&tempstr[0], jsonstring + t[i+1].start, (t[i+1].end - t[i+1].start));
+ // Store the radio id ...
+ radiocfg.radioID = strtoull(tempstr, NULL, 0);
+ i++;
+ }
+ else if (jsoneq(jsonstring, &t[i], "name") == 0)
+ {
+ memset(&radiocfg.name[0], 0, RADIO_NAME_LEN);
+ strncpy(&radiocfg.name[0], jsonstring + t[i+1].start, (t[i+1].end - t[i+1].start));
+ i++;
+ }
+ else if (jsoneq(jsonstring, &t[i], "country") == 0)
+ {
+ memset(&radiocfg.country[0], 0, RADIO_NAME_LEN);
+ strncpy(&radiocfg.country[0], jsonstring + t[i+1].start, (t[i+1].end - t[i+1].start));
+ i++;
+ }
+ else if (jsoneq(jsonstring, &t[i], "utc_offset") == 0)
+ {
+ memset(&tempstr[0], 0, sizeof(tempstr));
+ strncpy(&tempstr[0], jsonstring + t[i+1].start, (t[i+1].end - t[i+1].start));
+ // Store the radio id ...
+ radiocfg.utc_offset = strtoul(&tempstr[0], NULL, 0);
+ i++;
+ }
+ else if (jsoneq(jsonstring, &t[i], "radios") == 0)
+ {
+ int j;
+ // Radios is an array of radio objects
+ if (t[i+1].type != JSMN_ARRAY){
+ continue;
+ }
+
+ int arrsize = t[i+1].size;
+ // Move to the start of the array
+ i += 2;
+ for (j = 0; j < arrsize; j++)
+ {
+ RadioSlave slv;
+ int r = t[i + j].size;
+ //jsmntok_t * g = &t[i + j];
+ //printf(" * %.*s\n", g->end - g->start, jsonstring + g->start);
+ // Enumerate objects within the array
+ for (int z = 0; z < r ; z++)
+ {
+
+ if (jsoneq(jsonstring, &t[i+j+(z*2)+1], "id") == 0)
+ {
+ jsmntok_t * o = &t[i+j+(z*2)+2];
+ memset(&tempstr[0], 0, sizeof(tempstr));
+ strncpy(&tempstr[0], jsonstring + o->start, o->end - o->start);
+ slv.radioID = strtoull(&tempstr[0], NULL, 0);
+ }
+ else if (jsoneq(jsonstring, &t[i+j+(z*2)+1], "name") == 0)
+ {
+ jsmntok_t * o = &t[i+j+(z*2)+2];
+ memset(&slv.name[0], 0, RADIO_NAME_LEN);
+ strncpy(&slv.name[0], jsonstring + o->start, o->end - o->start);
+ }
+ if (jsoneq(jsonstring, &t[i+j+(z*2)+1], "temp_pin") == 0)
+ {
+ jsmntok_t * o = &t[i+j+(z*2)+2];
+ memset(&tempstr[0], 0, sizeof(tempstr));
+ strncpy(&tempstr[0], jsonstring + o->start, o->end - o->start);
+ slv.temp_pin = strtoul(&tempstr[0], NULL, 0);
+ }
+ if (jsoneq(jsonstring, &t[i+j+(z*2)+1], "humid_pin") == 0)
+ {
+ jsmntok_t * o = &t[i+j+(z*2)+2];
+ memset(&tempstr[0], 0, sizeof(tempstr));
+ strncpy(&tempstr[0], jsonstring + o->start, o->end - o->start);
+ slv.humid_pin = strtoul(&tempstr[0], NULL, 0);
+ }
+ if (jsoneq(jsonstring, &t[i+j+(z*2)+1], "lumin_pin") == 0)
+ {
+ jsmntok_t * o = &t[i+j+(z*2)+2];
+ memset(&tempstr[0], 0, sizeof(tempstr));
+ strncpy(&tempstr[0], jsonstring + o->start, o->end - o->start);
+ slv.lumin_pin = strtoul(&tempstr[0], NULL, 0);
+ }
+ if (jsoneq(jsonstring, &t[i+j+(z*2)+1], "spinkler_pin") == 0)
+ {
+ jsmntok_t * o = &t[i+j+(z*2)+2];
+ memset(&tempstr[0], 0, sizeof(tempstr));
+ strncpy(&tempstr[0], jsonstring + o->start, o->end - o->start);
+ slv.sprinkler_pin = strtoul(&tempstr[0], NULL, 0);
+ }
+ if (jsoneq(jsonstring, &t[i+j+(z*2)+1], "hthreshold") == 0)
+ {
+ jsmntok_t * o = &t[i+j+(z*2)+2];
+ memset(&tempstr[0], 0, sizeof(tempstr));
+ strncpy(&tempstr[0], jsonstring + o->start, o->end - o->start);
+ slv.hthreshold = strtoul(&tempstr[0], NULL, 0);
+ }
+ else
+ {
+ // TODO:
+ }
+ }
+ // Add the radio slave to the vector
+ radiocfg.radios.push_back(slv);
+ i += (t[i+j].size) * 2;
+ }
+ // Move to the end of the object
+ i += 4;
+ }else
+ {
+
+ }
+ }
+
+ return 0;
+}