M2XStreamClient-JMF - Added function deleteLocations to delete the loca…

Users » JMF » Code » M2XStreamClient-JMF

Added function deleteLocations to delete the location history.

Dependents: WNCInterface_M2Xdemo ATT_WNCInterface_Info WNCInterface_HTTP_example Public_IoT_M2X_Cellular_Demo

Fork of M2XStreamClient by AT&T M2X Team

M2XStreamClient.h@25:67079c11d1ea, 2016-09-18 (annotated)

Committer:: JMF
Date:: Sun Sep 18 14:45:31 2016 +0000
Revision:: 25:67079c11d1ea
Parent:: 24:6a5ba4cfa19a

Changed HTTP/1.0 references to HTTP/1.1  because the server apparently answeres 1.0 requests incorrectly which causes the library to hang.

Who changed what in which revision?

User	Revision	Line number	New contents of line
jb8414	0:f479e4f4db0e	1	#ifndef M2XStreamClient_h
jb8414	0:f479e4f4db0e	2	#define M2XStreamClient_h
jb8414	0:f479e4f4db0e	3
defmacro	22:4d895e732765	4	#if (!defined(ARDUINO_PLATFORM)) && (!defined(ESP8266_PLATFORM)) && (!defined(MBED_PLATFORM))
defmacro	22:4d895e732765	5	#error "Platform definition is missing!"
jb8414	0:f479e4f4db0e	6	#endif
jb8414	0:f479e4f4db0e	7
defmacro	22:4d895e732765	8	#define M2X_VERSION "2.2.0"
jb8414	0:f479e4f4db0e	9
jb8414	0:f479e4f4db0e	10	#ifdef ARDUINO_PLATFORM
defmacro	22:4d895e732765	11	#include "m2x-arduino.h"
defmacro	22:4d895e732765	12	#endif /* ARDUINO_PLATFORM */
defmacro	22:4d895e732765	13
defmacro	22:4d895e732765	14	#ifdef ESP8266_PLATFORM
defmacro	22:4d895e732765	15	#include "m2x-esp8266.h"
defmacro	22:4d895e732765	16	#endif /* ESP8266_PLATFORM */
jb8414	0:f479e4f4db0e	17
jb8414	0:f479e4f4db0e	18	#ifdef MBED_PLATFORM
defmacro	22:4d895e732765	19	#include "m2x-mbed.h"
defmacro	22:4d895e732765	20	#endif /* MBED_PLATFORM */
defmacro	22:4d895e732765	21
defmacro	22:4d895e732765	22	/* If we don't have DBG defined, provide dump implementation */
defmacro	22:4d895e732765	23	#ifndef DBG
jb8414	0:f479e4f4db0e	24	#define DBG(fmt_, data_)
jb8414	0:f479e4f4db0e	25	#define DBGLN(fmt_, data_)
jb8414	0:f479e4f4db0e	26	#define DBGLNEND
defmacro	22:4d895e732765	27	#endif /* DBG */
jb8414	0:f479e4f4db0e	28
defmacro	22:4d895e732765	29	#define MIN(a, b) (((a) > (b))?(b):(a))
defmacro	22:4d895e732765	30	#define TO_HEX(t_) ((char) (((t_) > 9) ? ((t_) - 10 + 'A') : ((t_) + '0')))
jb8414	0:f479e4f4db0e	31	#define MAX_DOUBLE_DIGITS 7
jb8414	0:f479e4f4db0e	32
defmacro	22:4d895e732765	33	/* For tolower */
defmacro	22:4d895e732765	34	#include <ctype.h>
defmacro	22:4d895e732765	35
jb8414	0:f479e4f4db0e	36	static const int E_OK = 0;
jb8414	0:f479e4f4db0e	37	static const int E_NOCONNECTION = -1;
jb8414	0:f479e4f4db0e	38	static const int E_DISCONNECTED = -2;
jb8414	0:f479e4f4db0e	39	static const int E_NOTREACHABLE = -3;
jb8414	0:f479e4f4db0e	40	static const int E_INVALID = -4;
jb8414	0:f479e4f4db0e	41	static const int E_JSON_INVALID = -5;
citrusbyte	16:7903152de19f	42	static const int E_BUFFER_TOO_SMALL = -6;
citrusbyte	16:7903152de19f	43	static const int E_TIMESTAMP_ERROR = -8;
citrusbyte	16:7903152de19f	44
defmacro	22:4d895e732765	45	static const char* DEFAULT_M2X_HOST = "api-m2x.att.com";
defmacro	22:4d895e732765	46	static const int DEFAULT_M2X_PORT = 80;
defmacro	22:4d895e732765	47
citrusbyte	16:7903152de19f	48	static inline bool m2x_status_is_success(int status) {
citrusbyte	16:7903152de19f	49	return (status == E_OK) \|\| (status >= 200 && status <= 299);
citrusbyte	16:7903152de19f	50	}
citrusbyte	16:7903152de19f	51
citrusbyte	16:7903152de19f	52	static inline bool m2x_status_is_client_error(int status) {
citrusbyte	16:7903152de19f	53	return status >= 400 && status <= 499;
citrusbyte	16:7903152de19f	54	}
citrusbyte	16:7903152de19f	55
citrusbyte	16:7903152de19f	56	static inline bool m2x_status_is_server_error(int status) {
citrusbyte	16:7903152de19f	57	return status >= 500 && status <= 599;
citrusbyte	16:7903152de19f	58	}
citrusbyte	16:7903152de19f	59
citrusbyte	16:7903152de19f	60	static inline bool m2x_status_is_error(int status) {
citrusbyte	16:7903152de19f	61	return m2x_status_is_client_error(status) \|\|
citrusbyte	16:7903152de19f	62	m2x_status_is_server_error(status);
citrusbyte	16:7903152de19f	63	}
jb8414	0:f479e4f4db0e	64
defmacro	22:4d895e732765	65	// Null Print class used to calculate length to print
defmacro	22:4d895e732765	66	class NullPrint : public Print {
defmacro	22:4d895e732765	67	public:
defmacro	22:4d895e732765	68	size_t counter;
defmacro	22:4d895e732765	69
defmacro	22:4d895e732765	70	virtual size_t write(uint8_t b) {
defmacro	22:4d895e732765	71	counter++;
defmacro	22:4d895e732765	72	return 1;
defmacro	22:4d895e732765	73	}
defmacro	22:4d895e732765	74
defmacro	22:4d895e732765	75	virtual size_t write(const uint8_t* buf, size_t size) {
defmacro	22:4d895e732765	76	counter += size;
defmacro	22:4d895e732765	77	return size;
defmacro	22:4d895e732765	78	}
defmacro	22:4d895e732765	79	};
defmacro	22:4d895e732765	80
defmacro	22:4d895e732765	81	// Encodes and prints string using Percent-encoding specified
defmacro	22:4d895e732765	82	// in RFC 1738, Section 2.2
defmacro	22:4d895e732765	83	static inline int print_encoded_string(Print* print, const char* str) {
defmacro	22:4d895e732765	84	int bytes = 0;
defmacro	22:4d895e732765	85	for (int i = 0; str[i] != 0; i++) {
defmacro	22:4d895e732765	86	if (((str[i] >= 'A') && (str[i] <= 'Z')) \|\|
defmacro	22:4d895e732765	87	((str[i] >= 'a') && (str[i] <= 'z')) \|\|
defmacro	22:4d895e732765	88	((str[i] >= '0') && (str[i] <= '9')) \|\|
defmacro	22:4d895e732765	89	(str[i] == '-') \|\| (str[i] == '_') \|\|
defmacro	22:4d895e732765	90	(str[i] == '.') \|\| (str[i] == '~')) {
defmacro	22:4d895e732765	91	bytes += print->print(str[i]);
defmacro	22:4d895e732765	92	} else {
defmacro	22:4d895e732765	93	// Encode all other characters
defmacro	22:4d895e732765	94	bytes += print->print('%');
defmacro	22:4d895e732765	95	bytes += print->print(TO_HEX(str[i] / 16));
defmacro	22:4d895e732765	96	bytes += print->print(TO_HEX(str[i] % 16));
defmacro	22:4d895e732765	97	}
defmacro	22:4d895e732765	98	}
defmacro	22:4d895e732765	99	return bytes;
defmacro	22:4d895e732765	100	}
defmacro	22:4d895e732765	101
defmacro	22:4d895e732765	102	#ifdef M2X_ENABLE_READER
citrusbyte	10:4ce9eba38dbe	103	/*
citrusbyte	10:4ce9eba38dbe	104	* +type+ indicates the value type: 1 for string, 2 for number
citrusbyte	10:4ce9eba38dbe	105	* NOTE that the value type here only contains a hint on how
citrusbyte	10:4ce9eba38dbe	106	* you can use the value. Even though 2 is returned, the value
citrusbyte	10:4ce9eba38dbe	107	* is still stored in (const char *), and atoi/atof is needed to
citrusbyte	10:4ce9eba38dbe	108	* get the actual value
citrusbyte	10:4ce9eba38dbe	109	*/
jb8414	0:f479e4f4db0e	110	typedef void (stream_value_read_callback)(const char at,
jb8414	0:f479e4f4db0e	111	const char* value,
jb8414	0:f479e4f4db0e	112	int index,
citrusbyte	10:4ce9eba38dbe	113	void* context,
citrusbyte	10:4ce9eba38dbe	114	int type);
jb8414	0:f479e4f4db0e	115
jb8414	0:f479e4f4db0e	116	typedef void (location_read_callback)(const char name,
jb8414	0:f479e4f4db0e	117	double latitude,
jb8414	0:f479e4f4db0e	118	double longitude,
jb8414	0:f479e4f4db0e	119	double elevation,
jb8414	0:f479e4f4db0e	120	const char* timestamp,
jb8414	0:f479e4f4db0e	121	int index,
jb8414	0:f479e4f4db0e	122	void* context);
JMF	23:f32837239193	123
defmacro	22:4d895e732765	124	typedef void (m2x_command_read_callback)(const char id,
defmacro	22:4d895e732765	125	const char* name,
defmacro	22:4d895e732765	126	int index,
defmacro	22:4d895e732765	127	void *context);
defmacro	22:4d895e732765	128	#endif /* M2X_ENABLE_READER */
defmacro	22:4d895e732765	129
defmacro	22:4d895e732765	130	typedef void (m2x_fill_data_callback)(Print print, void *context);
defmacro	22:4d895e732765	131
jb8414	0:f479e4f4db0e	132	class M2XStreamClient {
jb8414	0:f479e4f4db0e	133	public:
jb8414	0:f479e4f4db0e	134	M2XStreamClient(Client* client,
jb8414	0:f479e4f4db0e	135	const char* key,
defmacro	22:4d895e732765	136	void (* idlefunc)(void) = NULL,
jb8414	0:f479e4f4db0e	137	int case_insensitive = 1,
defmacro	22:4d895e732765	138	const char* host = DEFAULT_M2X_HOST,
defmacro	22:4d895e732765	139	int port = DEFAULT_M2X_PORT,
NetArc	14:205076b587fe	140	const char* path_prefix = NULL);
jb8414	0:f479e4f4db0e	141
citrusbyte	10:4ce9eba38dbe	142	// Push data stream value using PUT request, returns the HTTP status code
defmacro	22:4d895e732765	143	// NOTE: if you want to update by a serial, use "serial/<serial ID>" as
defmacro	22:4d895e732765	144	// the device ID here.
jb8414	0:f479e4f4db0e	145	template <class T>
citrusbyte	13:0d574742208f	146	int updateStreamValue(const char* deviceId, const char* streamName, T value);
jb8414	0:f479e4f4db0e	147
jb8414	0:f479e4f4db0e	148	// Post multiple values to M2X all at once.
citrusbyte	13:0d574742208f	149	// +deviceId+ - id of the device to post values
jb8414	0:f479e4f4db0e	150	// +streamNum+ - Number of streams to post
jb8414	0:f479e4f4db0e	151	// +names+ - Array of stream names, the length of the array should
jb8414	0:f479e4f4db0e	152	// be exactly +streamNum+
jb8414	0:f479e4f4db0e	153	// +counts+ - Array of +streamNum+ length, each item in this array
jb8414	0:f479e4f4db0e	154	// containing the number of values we want to post for each stream
jb8414	0:f479e4f4db0e	155	// +ats+ - Timestamps for each value, the length of this array should
jb8414	0:f479e4f4db0e	156	// be the some of all values in +counts+, for the first +counts[0]+
jb8414	0:f479e4f4db0e	157	// items, the values belong to the first stream, for the following
jb8414	0:f479e4f4db0e	158	// +counts[1]+ number of items, the values belong to the second stream,
citrusbyte	10:4ce9eba38dbe	159	// etc. Notice that timestamps are required here: you must provide
citrusbyte	10:4ce9eba38dbe	160	// a timestamp for each value posted.
jb8414	0:f479e4f4db0e	161	// +values+ - Values to post. This works the same way as +ats+, the
jb8414	0:f479e4f4db0e	162	// first +counts[0]+ number of items contain values to post to the first
jb8414	0:f479e4f4db0e	163	// stream, the succeeding +counts[1]+ number of items contain values
jb8414	0:f479e4f4db0e	164	// for the second stream, etc. The length of this array should be
jb8414	0:f479e4f4db0e	165	// the sum of all values in +counts+ array.
defmacro	22:4d895e732765	166	// NOTE: if you want to update by a serial, use "serial/<serial ID>" as
defmacro	22:4d895e732765	167	// the device ID here.
jb8414	0:f479e4f4db0e	168	template <class T>
citrusbyte	13:0d574742208f	169	int postDeviceUpdates(const char* deviceId, int streamNum,
citrusbyte	13:0d574742208f	170	const char* names[], const int counts[],
citrusbyte	13:0d574742208f	171	const char* ats[], T values[]);
jb8414	0:f479e4f4db0e	172
citrusbyte	19:4dfa28d37b8f	173	// Post multiple values of a single device at once.
citrusbyte	19:4dfa28d37b8f	174	// +deviceId+ - id of the device to post values
citrusbyte	19:4dfa28d37b8f	175	// +streamNum+ - Number of streams to post
citrusbyte	19:4dfa28d37b8f	176	// +names+ - Array of stream names, the length of the array should
citrusbyte	19:4dfa28d37b8f	177	// be exactly +streamNum+
citrusbyte	19:4dfa28d37b8f	178	// +values+ - Array of values to post, the length of the array should
citrusbyte	19:4dfa28d37b8f	179	// be exactly +streamNum+. Notice that the array of +values+ should
citrusbyte	19:4dfa28d37b8f	180	// match the array of +names+, and that the ith value in +values+ is
citrusbyte	19:4dfa28d37b8f	181	// exactly the value to post for the ith stream name in +names+
defmacro	22:4d895e732765	182	// NOTE: if you want to update by a serial, use "serial/<serial ID>" as
defmacro	22:4d895e732765	183	// the device ID here.
citrusbyte	19:4dfa28d37b8f	184	template <class T>
defmacro	22:4d895e732765	185	int postDeviceUpdate(const char* deviceId, int streamNum,
defmacro	22:4d895e732765	186	const char* names[], T values[],
defmacro	22:4d895e732765	187	const char* at = NULL);
citrusbyte	19:4dfa28d37b8f	188
defmacro	22:4d895e732765	189	#ifdef M2X_ENABLE_READER
jb8414	0:f479e4f4db0e	190	// Fetch values for a particular data stream. Since memory is
jb8414	0:f479e4f4db0e	191	// very limited on an Arduino, we cannot parse and get all the
jb8414	0:f479e4f4db0e	192	// data points in memory. Instead, we use callbacks here: whenever
jb8414	0:f479e4f4db0e	193	// a new data point is parsed, we call the callback using the values,
jb8414	0:f479e4f4db0e	194	// after that, the values will be thrown away to make space for new
jb8414	0:f479e4f4db0e	195	// values.
jb8414	0:f479e4f4db0e	196	// Note that you can also pass in a user-specified context in this
jb8414	0:f479e4f4db0e	197	// function, this context will be passed to the callback function
jb8414	0:f479e4f4db0e	198	// each time we get a data point.
jb8414	0:f479e4f4db0e	199	// For each data point, the callback will be called once. The HTTP
jb8414	0:f479e4f4db0e	200	// status code will be returned. And the content is only parsed when
jb8414	0:f479e4f4db0e	201	// the status code is 200.
citrusbyte	13:0d574742208f	202	int listStreamValues(const char* deviceId, const char* streamName,
citrusbyte	13:0d574742208f	203	stream_value_read_callback callback, void* context,
citrusbyte	13:0d574742208f	204	const char* query = NULL);
defmacro	22:4d895e732765	205	#endif /* M2X_ENABLE_READER */
jb8414	0:f479e4f4db0e	206
jb8414	0:f479e4f4db0e	207	// Update datasource location
jb8414	0:f479e4f4db0e	208	// NOTE: On an Arduino Uno and other ATMEGA based boards, double has
jb8414	0:f479e4f4db0e	209	// 4-byte (32 bits) precision, which is the same as float. So there's
jb8414	0:f479e4f4db0e	210	// no natural double-precision floating number on these boards. With
jb8414	0:f479e4f4db0e	211	// a float value, we have a precision of roughly 7 digits, that means
jb8414	0:f479e4f4db0e	212	// either 5 or 6 digits after the floating point. According to wikipedia,
jb8414	0:f479e4f4db0e	213	// a difference of 0.00001 will give us ~1.1132m distance. If this
jb8414	0:f479e4f4db0e	214	// precision is good for you, you can use the double-version we provided
jb8414	0:f479e4f4db0e	215	// here. Otherwise, you may need to use the string-version and do the
jb8414	0:f479e4f4db0e	216	// actual conversion by yourselves.
jb8414	0:f479e4f4db0e	217	// However, with an Arduino Due board, double has 8-bytes (64 bits)
jb8414	0:f479e4f4db0e	218	// precision, which means you are free to use the double-version only
jb8414	0:f479e4f4db0e	219	// without any precision problems.
jb8414	0:f479e4f4db0e	220	// Returned value is the http status code.
defmacro	22:4d895e732765	221	// NOTE: if you want to update by a serial, use "serial/<serial ID>" as
defmacro	22:4d895e732765	222	// the device ID here.
jb8414	0:f479e4f4db0e	223	template <class T>
citrusbyte	13:0d574742208f	224	int updateLocation(const char* deviceId, const char* name,
jb8414	0:f479e4f4db0e	225	T latitude, T longitude, T elevation);
jb8414	0:f479e4f4db0e	226
defmacro	22:4d895e732765	227	#ifdef M2X_ENABLE_READER
citrusbyte	13:0d574742208f	228	// Read location information for a device. Also used callback to process
jb8414	0:f479e4f4db0e	229	// data points for memory reasons. The HTTP status code is returned,
jb8414	0:f479e4f4db0e	230	// response is only parsed when the HTTP status code is 200
citrusbyte	13:0d574742208f	231	int readLocation(const char* deviceId, location_read_callback callback,
jb8414	0:f479e4f4db0e	232	void* context);
JMF	23:f32837239193	233
JMF	23:f32837239193	234	// Delete location information for a device. The HTTP status code is
JMF	23:f32837239193	235	// returned,response is only parsed when the HTTP status code is 200
JMF	24:6a5ba4cfa19a	236	int deleteLocations(const char* deviceId,
JMF	23:f32837239193	237	const char* from, const char* end);
JMF	23:f32837239193	238
defmacro	22:4d895e732765	239	#endif /* M2X_ENABLE_READER */
citrusbyte	10:4ce9eba38dbe	240
citrusbyte	10:4ce9eba38dbe	241	// Delete values from a data stream
citrusbyte	10:4ce9eba38dbe	242	// You will need to provide from and end date/time strings in the ISO8601
citrusbyte	10:4ce9eba38dbe	243	// format "yyyy-mm-ddTHH:MM:SS.SSSZ" where
citrusbyte	10:4ce9eba38dbe	244	// yyyy: the year
citrusbyte	10:4ce9eba38dbe	245	// mm: the month
citrusbyte	10:4ce9eba38dbe	246	// dd: the day
citrusbyte	10:4ce9eba38dbe	247	// HH: the hour (24 hour format)
citrusbyte	10:4ce9eba38dbe	248	// MM: the minute
citrusbyte	10:4ce9eba38dbe	249	// SS.SSS: the seconds (to the millisecond)
citrusbyte	10:4ce9eba38dbe	250	// NOTE: the time is given in Zulu (GMT)
citrusbyte	10:4ce9eba38dbe	251	// M2X will delete all values within the from to end date/time range.
citrusbyte	10:4ce9eba38dbe	252	// The status code is 204 on success and 400 on a bad request (e.g. the
citrusbyte	10:4ce9eba38dbe	253	// timestamp is not in ISO8601 format or the from timestamp is not less than
citrusbyte	10:4ce9eba38dbe	254	// or equal to the end timestamp.
citrusbyte	13:0d574742208f	255	int deleteValues(const char* deviceId, const char* streamName,
citrusbyte	10:4ce9eba38dbe	256	const char* from, const char* end);
citrusbyte	16:7903152de19f	257
defmacro	22:4d895e732765	258	#ifdef M2X_ENABLE_READER
defmacro	22:4d895e732765	259	// Fetch commands available for this device, notice that for memory constraints,
defmacro	22:4d895e732765	260	// we only keep ID and name of the command received here.
defmacro	22:4d895e732765	261	// You can tweak the command receiving via the query parameter.
defmacro	22:4d895e732765	262	int listCommands(const char* deviceId,
defmacro	22:4d895e732765	263	m2x_command_read_callback callback, void* context,
defmacro	22:4d895e732765	264	const char* query = NULL);
defmacro	22:4d895e732765	265	#endif /* M2X_ENABLE_READER */
defmacro	22:4d895e732765	266
defmacro	22:4d895e732765	267	// Mark a command as processed.
defmacro	22:4d895e732765	268	// Link: https://m2x.att.com/developer/documentation/v2/commands#Device-Marks-a-Command-as-Processed
defmacro	22:4d895e732765	269	// To make sure the minimal amount of memory is needed, this API works with
defmacro	22:4d895e732765	270	// a callback function. The callback function is then used to fill the request
defmacro	22:4d895e732765	271	// data, note that in order to correctly set the content length in HTTP header,
defmacro	22:4d895e732765	272	// the callback function will be called twice, the caller must make sure both
defmacro	22:4d895e732765	273	// calls fill the Print object with exactly the same data.
defmacro	22:4d895e732765	274	// If you have a pre-allocated buffer filled with the data to post, you can
defmacro	22:4d895e732765	275	// use markCommandProcessedWithData API below.
defmacro	22:4d895e732765	276	int markCommandProcessed(const char* deviceId, const char* commandId,
defmacro	22:4d895e732765	277	m2x_fill_data_callback callback, void *context);
defmacro	22:4d895e732765	278
defmacro	22:4d895e732765	279	// Mark a command as processed with a data buffer
defmacro	22:4d895e732765	280	// Link: https://m2x.att.com/developer/documentation/v2/commands#Device-Marks-a-Command-as-Processed
defmacro	22:4d895e732765	281	// This is exactly like markCommandProcessed, except that a buffer is use to
defmacro	22:4d895e732765	282	// contain the data to post as the request body.
defmacro	22:4d895e732765	283	int markCommandProcessedWithData(const char* deviceId, const char* commandId,
defmacro	22:4d895e732765	284	const char* data);
defmacro	22:4d895e732765	285
defmacro	22:4d895e732765	286	// Mark a command as rejected.
defmacro	22:4d895e732765	287	// Link: https://m2x.att.com/developer/documentation/v2/commands#Device-Marks-a-Command-as-Rejected
defmacro	22:4d895e732765	288	// To make sure the minimal amount of memory is needed, this API works with
defmacro	22:4d895e732765	289	// a callback function. The callback function is then used to fill the request
defmacro	22:4d895e732765	290	// data, note that in order to correctly set the content length in HTTP header,
defmacro	22:4d895e732765	291	// the callback function will be called twice, the caller must make sure both
defmacro	22:4d895e732765	292	// calls fill the Print object with exactly the same data.
defmacro	22:4d895e732765	293	// If you have a pre-allocated buffer filled with the data to post, you can
defmacro	22:4d895e732765	294	// use markCommandRejectedWithData API below.
defmacro	22:4d895e732765	295	int markCommandRejected(const char* deviceId, const char* commandId,
defmacro	22:4d895e732765	296	m2x_fill_data_callback callback, void *context);
defmacro	22:4d895e732765	297
defmacro	22:4d895e732765	298	// Mark a command as rejected with a data buffer
defmacro	22:4d895e732765	299	// Link: https://m2x.att.com/developer/documentation/v2/commands#Device-Marks-a-Command-as-Rejected
defmacro	22:4d895e732765	300	// This is exactly like markCommandRejected, except that a buffer is use to
defmacro	22:4d895e732765	301	// contain the data to post as the request body.
defmacro	22:4d895e732765	302	int markCommandRejectedWithData(const char* deviceId, const char* commandId,
defmacro	22:4d895e732765	303	const char* data);
defmacro	22:4d895e732765	304
citrusbyte	16:7903152de19f	305	// Fetches current timestamp in seconds from M2X server. Since we
citrusbyte	16:7903152de19f	306	// are using signed 32-bit integer as return value, this will only
citrusbyte	16:7903152de19f	307	// return valid results before 03:14:07 UTC on 19 January 2038. If
citrusbyte	16:7903152de19f	308	// the device is supposed to work after that, this function should
citrusbyte	16:7903152de19f	309	// not be used.
citrusbyte	16:7903152de19f	310	//
citrusbyte	16:7903152de19f	311	// The returned value will contain the status code(positive values)
citrusbyte	16:7903152de19f	312	// or the error code(negative values).
citrusbyte	16:7903152de19f	313	// In case of success, the current timestamp will be filled in the
citrusbyte	16:7903152de19f	314	// +ts+ pointer passed in as argument.
citrusbyte	16:7903152de19f	315	//
citrusbyte	16:7903152de19f	316	// NOTE: although returning uint32_t can give us a larger space,
citrusbyte	16:7903152de19f	317	// we prefer to cope with the unix convention here.
citrusbyte	16:7903152de19f	318	int getTimestamp32(int32_t* ts);
citrusbyte	16:7903152de19f	319
citrusbyte	16:7903152de19f	320	// Fetches current timestamp in seconds from M2X server.
citrusbyte	16:7903152de19f	321	// This function will return the timestamp as an integer literal
citrusbyte	16:7903152de19f	322	// in the provided buffer. Hence there's no problem working after
citrusbyte	16:7903152de19f	323	// 03:14:07 UTC on 19 January 2038. The drawback part here, is that
citrusbyte	16:7903152de19f	324	// you will have to work with 64-bit integer, which is not available
citrusbyte	16:7903152de19f	325	// on certain platform(such as Arduino), a bignum library or alike
citrusbyte	16:7903152de19f	326	// is needed in this case.
citrusbyte	16:7903152de19f	327	//
citrusbyte	16:7903152de19f	328	// Notice +bufferLength+ is supposed to contain the length of the
citrusbyte	16:7903152de19f	329	// buffer when calling this function. It is also the caller's
citrusbyte	16:7903152de19f	330	// responsibility to ensure the buffer is big enough, otherwise
citrusbyte	16:7903152de19f	331	// the library will return an error indicating the buffer is too
citrusbyte	16:7903152de19f	332	// small.
citrusbyte	16:7903152de19f	333	// While this is not accurate all the time, one trick here is to
citrusbyte	16:7903152de19f	334	// pass in 0 as the bufferLength, in which case we will always return
citrusbyte	16:7903152de19f	335	// the buffer-too-small error. However, the correct buffer length
citrusbyte	16:7903152de19f	336	// can be found this way so a secound execution is most likely to work
citrusbyte	16:7903152de19f	337	// (unless we are at the edge of the buffer length increasing, for
citrusbyte	16:7903152de19f	338	// example, when the timestamp jumps from 9999999999 to 10000000000,
citrusbyte	16:7903152de19f	339	// which is highly unlikely to happend). However, given that the
citrusbyte	16:7903152de19f	340	// maximum 64-bit integer can be stored in 19 bytes, there's not
citrusbyte	16:7903152de19f	341	// much need to use this trick.)
citrusbyte	16:7903152de19f	342	//
citrusbyte	16:7903152de19f	343	// The returned value will contain the status code(positive values)
citrusbyte	16:7903152de19f	344	// or the error code(negative values).
citrusbyte	16:7903152de19f	345	// In case of success, the current timestamp will be filled in the
citrusbyte	16:7903152de19f	346	// passed +buffer+ pointer, and the actual used buffer length will
citrusbyte	16:7903152de19f	347	// be returned in +bufferLength+ pointer.
citrusbyte	16:7903152de19f	348	// NOTE: as long as we can read the returned buffer length, it will
citrusbyte	16:7903152de19f	349	// be used to fill in the +bufferLength+ variable even though other
citrusbyte	16:7903152de19f	350	// errors occur(buffer is not enough, network is shutdown before
citrusbyte	16:7903152de19f	351	// reading the whole buffer, etc.)
citrusbyte	16:7903152de19f	352	int getTimestamp(char* buffer, int* bufferLength);
jb8414	0:f479e4f4db0e	353	private:
jb8414	0:f479e4f4db0e	354	Client* _client;
jb8414	0:f479e4f4db0e	355	const char* _key;
jb8414	0:f479e4f4db0e	356	int _case_insensitive;
jb8414	0:f479e4f4db0e	357	const char* _host;
jb8414	0:f479e4f4db0e	358	int _port;
defmacro	22:4d895e732765	359	void (* _idlefunc)(void);
NetArc	14:205076b587fe	360	const char* _path_prefix;
jb8414	0:f479e4f4db0e	361	NullPrint _null_print;
jb8414	0:f479e4f4db0e	362
jb8414	0:f479e4f4db0e	363	// Writes the HTTP header part for updating a stream value
citrusbyte	13:0d574742208f	364	void writePutHeader(const char* deviceId,
citrusbyte	10:4ce9eba38dbe	365	const char* streamName,
citrusbyte	10:4ce9eba38dbe	366	int contentLength);
citrusbyte	10:4ce9eba38dbe	367	// Writes the HTTP header part for deleting stream values
citrusbyte	13:0d574742208f	368	void writeDeleteHeader(const char* deviceId,
citrusbyte	10:4ce9eba38dbe	369	const char* streamName,
citrusbyte	10:4ce9eba38dbe	370	int contentLength);
JMF	23:f32837239193	371	void writeDeleteLocationHeader(const char* deviceId,
JMF	23:f32837239193	372	int contentLength);
JMF	23:f32837239193	373
jb8414	0:f479e4f4db0e	374	// Writes HTTP header lines including M2X API Key, host, content
jb8414	0:f479e4f4db0e	375	// type and content length(if the body exists)
jb8414	0:f479e4f4db0e	376	void writeHttpHeader(int contentLength);
jb8414	0:f479e4f4db0e	377	// Parses HTTP response header and return the content length.
jb8414	0:f479e4f4db0e	378	// Note that this function does not parse all http headers, as long
jb8414	0:f479e4f4db0e	379	// as the content length is found, this function will return
jb8414	0:f479e4f4db0e	380	int readContentLength();
jb8414	0:f479e4f4db0e	381	// Skips all HTTP response header part. Return minus value in case
jb8414	0:f479e4f4db0e	382	// the connection is closed before we got all headers
jb8414	0:f479e4f4db0e	383	int skipHttpHeader();
jb8414	0:f479e4f4db0e	384	// Parses and returns the HTTP status code, note this function will
jb8414	0:f479e4f4db0e	385	// return immediately once it gets the status code
jb8414	0:f479e4f4db0e	386	int readStatusCode(bool closeClient);
jb8414	0:f479e4f4db0e	387	// Waits for a certain string pattern in the HTTP header, and returns
jb8414	0:f479e4f4db0e	388	// once the pattern is found. In the pattern, you can use '*' to denote
jb8414	0:f479e4f4db0e	389	// any character
jb8414	0:f479e4f4db0e	390	int waitForString(const char* str);
jb8414	0:f479e4f4db0e	391	// Closes the connection
jb8414	0:f479e4f4db0e	392	void close();
defmacro	22:4d895e732765	393
defmacro	22:4d895e732765	394	#ifdef M2X_ENABLE_READER
jb8414	0:f479e4f4db0e	395	// Parses JSON response of stream value API, and calls callback function
jb8414	0:f479e4f4db0e	396	// once we get a data point
jb8414	0:f479e4f4db0e	397	int readStreamValue(stream_value_read_callback callback, void* context);
jb8414	0:f479e4f4db0e	398	// Parses JSON response of location API, and calls callback function once
jb8414	0:f479e4f4db0e	399	// we get a data point
jb8414	0:f479e4f4db0e	400	int readLocation(location_read_callback callback, void* context);
defmacro	22:4d895e732765	401	// Parses JSON response of command API, and calls callback function once
defmacro	22:4d895e732765	402	// we get a data point
defmacro	22:4d895e732765	403	int readCommand(m2x_command_read_callback callback, void* context);
defmacro	22:4d895e732765	404	#endif /* M2X_ENABLE_READER */
defmacro	22:4d895e732765	405	};
defmacro	22:4d895e732765	406
defmacro	22:4d895e732765	407
defmacro	22:4d895e732765	408	// A ISO8601 timestamp generation service for M2X.
defmacro	22:4d895e732765	409	// It uses the Time API provided by the M2X server to initialize
defmacro	22:4d895e732765	410	// clock, then uses millis() function provided by Arduino to calculate
defmacro	22:4d895e732765	411	// time advancements so as to reduce API query times.
defmacro	22:4d895e732765	412	//
defmacro	22:4d895e732765	413	// Right now, this service only works with 32-bit timestamp, meaning that
defmacro	22:4d895e732765	414	// this service won't work after 03:14:07 UTC on 19 January 2038. However,
defmacro	22:4d895e732765	415	// a similar service that uses 64-bit timestamp can be implemented following
defmacro	22:4d895e732765	416	// the logic here.
defmacro	22:4d895e732765	417	class TimeService {
defmacro	22:4d895e732765	418	public:
defmacro	22:4d895e732765	419	TimeService(M2XStreamClient* client);
defmacro	22:4d895e732765	420
defmacro	22:4d895e732765	421	// Initialize the time service. Notice the TimeService instance is only
defmacro	22:4d895e732765	422	// working after calling this function successfully.
defmacro	22:4d895e732765	423	int init();
defmacro	22:4d895e732765	424
defmacro	22:4d895e732765	425	// Reset the internal recorded time by calling M2X Time API again. Normally,
defmacro	22:4d895e732765	426	// you don't need to call this manually. TimeService will handle Arduino clock
defmacro	22:4d895e732765	427	// overflow automatically
defmacro	22:4d895e732765	428	int reset();
defmacro	22:4d895e732765	429
defmacro	22:4d895e732765	430	// Fills ISO8601 formatted timestamp into the buffer provided. +length+ should
defmacro	22:4d895e732765	431	// contains the maximum supported length of the buffer when calling. For now,
defmacro	22:4d895e732765	432	// the buffer should be able to store 25 characters for a full ISO8601 formatted
defmacro	22:4d895e732765	433	// timestamp, otherwise, an error will be returned.
defmacro	22:4d895e732765	434	int getTimestamp(char* buffer, int* length);
defmacro	22:4d895e732765	435	private:
defmacro	22:4d895e732765	436	M2XStreamClient* _client;
defmacro	22:4d895e732765	437	int32_t _server_timestamp;
defmacro	22:4d895e732765	438	uint32_t _local_last_milli;
defmacro	22:4d895e732765	439	M2XTimer _timer;
jb8414	0:f479e4f4db0e	440	};
jb8414	0:f479e4f4db0e	441
defmacro	22:4d895e732765	442
defmacro	22:4d895e732765	443	// Implementations
defmacro	22:4d895e732765	444	M2XStreamClient::M2XStreamClient(Client* client,
defmacro	22:4d895e732765	445	const char* key,
defmacro	22:4d895e732765	446	void (* idlefunc)(void),
defmacro	22:4d895e732765	447	int case_insensitive,
defmacro	22:4d895e732765	448	const char* host,
defmacro	22:4d895e732765	449	int port,
defmacro	22:4d895e732765	450	const char* path_prefix) : _client(client),
defmacro	22:4d895e732765	451	_key(key),
defmacro	22:4d895e732765	452	_idlefunc(idlefunc),
defmacro	22:4d895e732765	453	_case_insensitive(case_insensitive),
defmacro	22:4d895e732765	454	_host(host),
defmacro	22:4d895e732765	455	_port(port),
defmacro	22:4d895e732765	456	_path_prefix(path_prefix),
defmacro	22:4d895e732765	457	_null_print() {
defmacro	22:4d895e732765	458	}
defmacro	22:4d895e732765	459
defmacro	22:4d895e732765	460	template <class T>
defmacro	22:4d895e732765	461	int M2XStreamClient::updateStreamValue(const char* deviceId, const char* streamName, T value) {
defmacro	22:4d895e732765	462	if (_client->connect(_host, _port)) {
defmacro	22:4d895e732765	463	DBGLN("%s", "Connected to M2X server!");
defmacro	22:4d895e732765	464	writePutHeader(deviceId, streamName,
defmacro	22:4d895e732765	465	// for {"value": and }
defmacro	22:4d895e732765	466	_null_print.print(value) + 12);
defmacro	22:4d895e732765	467	_client->print("{\"value\":\"");
defmacro	22:4d895e732765	468	_client->print(value);
defmacro	22:4d895e732765	469	_client->print("\"}");
defmacro	22:4d895e732765	470	} else {
defmacro	22:4d895e732765	471	DBGLN("%s", "ERROR: Cannot connect to M2X server!");
defmacro	22:4d895e732765	472	return E_NOCONNECTION;
defmacro	22:4d895e732765	473	}
defmacro	22:4d895e732765	474
defmacro	22:4d895e732765	475	return readStatusCode(true);
defmacro	22:4d895e732765	476	}
defmacro	22:4d895e732765	477
defmacro	22:4d895e732765	478	template <class T>
defmacro	22:4d895e732765	479	inline int write_multiple_values(Print* print, int streamNum,
defmacro	22:4d895e732765	480	const char* names[], const int counts[],
defmacro	22:4d895e732765	481	const char* ats[], T values[]) {
defmacro	22:4d895e732765	482	int bytes = 0, value_index = 0;
defmacro	22:4d895e732765	483	bytes += print->print("{\"values\":{");
defmacro	22:4d895e732765	484	for (int i = 0; i < streamNum; i++) {
defmacro	22:4d895e732765	485	bytes += print->print("\"");
defmacro	22:4d895e732765	486	bytes += print->print(names[i]);
defmacro	22:4d895e732765	487	bytes += print->print("\":[");
defmacro	22:4d895e732765	488	for (int j = 0; j < counts[i]; j++) {
defmacro	22:4d895e732765	489	bytes += print->print("{\"timestamp\": \"");
defmacro	22:4d895e732765	490	bytes += print->print(ats[value_index]);
defmacro	22:4d895e732765	491	bytes += print->print("\",\"value\": \"");
defmacro	22:4d895e732765	492	bytes += print->print(values[value_index]);
defmacro	22:4d895e732765	493	bytes += print->print("\"}");
defmacro	22:4d895e732765	494	if (j < counts[i] - 1) { bytes += print->print(","); }
defmacro	22:4d895e732765	495	value_index++;
defmacro	22:4d895e732765	496	}
defmacro	22:4d895e732765	497	bytes += print->print("]");
defmacro	22:4d895e732765	498	if (i < streamNum - 1) { bytes += print->print(","); }
defmacro	22:4d895e732765	499	}
defmacro	22:4d895e732765	500	bytes += print->print("}}");
defmacro	22:4d895e732765	501	return bytes;
defmacro	22:4d895e732765	502	}
defmacro	22:4d895e732765	503
defmacro	22:4d895e732765	504	template <class T>
defmacro	22:4d895e732765	505	int M2XStreamClient::postDeviceUpdates(const char* deviceId, int streamNum,
defmacro	22:4d895e732765	506	const char* names[], const int counts[],
defmacro	22:4d895e732765	507	const char* ats[], T values[]) {
defmacro	22:4d895e732765	508	if (_client->connect(_host, _port)) {
defmacro	22:4d895e732765	509	DBGLN("%s", "Connected to M2X server!");
defmacro	22:4d895e732765	510	int length = write_multiple_values(&_null_print, streamNum, names,
defmacro	22:4d895e732765	511	counts, ats, values);
defmacro	22:4d895e732765	512	_client->print("POST ");
defmacro	22:4d895e732765	513	if (_path_prefix) { _client->print(_path_prefix); }
defmacro	22:4d895e732765	514	_client->print("/v2/devices/");
defmacro	22:4d895e732765	515	_client->print(deviceId);
JMF	25:67079c11d1ea	516	_client->println("/updates HTTP/1.1");
defmacro	22:4d895e732765	517	writeHttpHeader(length);
defmacro	22:4d895e732765	518	write_multiple_values(_client, streamNum, names, counts, ats, values);
defmacro	22:4d895e732765	519	} else {
defmacro	22:4d895e732765	520	DBGLN("%s", "ERROR: Cannot connect to M2X server!");
defmacro	22:4d895e732765	521	return E_NOCONNECTION;
defmacro	22:4d895e732765	522	}
defmacro	22:4d895e732765	523	return readStatusCode(true);
defmacro	22:4d895e732765	524	}
defmacro	22:4d895e732765	525
defmacro	22:4d895e732765	526	template <class T>
defmacro	22:4d895e732765	527	inline int write_single_device_values(Print* print, int streamNum,
defmacro	22:4d895e732765	528	const char* names[], T values[],
defmacro	22:4d895e732765	529	const char* at) {
defmacro	22:4d895e732765	530	int bytes = 0;
defmacro	22:4d895e732765	531	bytes += print->print("{\"values\":{");
defmacro	22:4d895e732765	532	for (int i = 0; i < streamNum; i++) {
defmacro	22:4d895e732765	533	bytes += print->print("\"");
defmacro	22:4d895e732765	534	bytes += print->print(names[i]);
defmacro	22:4d895e732765	535	bytes += print->print("\": \"");
defmacro	22:4d895e732765	536	bytes += print->print(values[i]);
defmacro	22:4d895e732765	537	bytes += print->print("\"");
defmacro	22:4d895e732765	538	if (i < streamNum - 1) { bytes += print->print(","); }
defmacro	22:4d895e732765	539	}
defmacro	22:4d895e732765	540	bytes += print->print("}");
defmacro	22:4d895e732765	541	if (at != NULL) {
defmacro	22:4d895e732765	542	bytes += print->print(",\"timestamp\":\"");
defmacro	22:4d895e732765	543	bytes += print->print(at);
defmacro	22:4d895e732765	544	bytes += print->print("\"");
defmacro	22:4d895e732765	545	}
defmacro	22:4d895e732765	546	bytes += print->print("}");
defmacro	22:4d895e732765	547	return bytes;
defmacro	22:4d895e732765	548	}
defmacro	22:4d895e732765	549
defmacro	22:4d895e732765	550	template <class T>
defmacro	22:4d895e732765	551	int M2XStreamClient::postDeviceUpdate(const char* deviceId, int streamNum,
defmacro	22:4d895e732765	552	const char* names[], T values[],
defmacro	22:4d895e732765	553	const char* at) {
defmacro	22:4d895e732765	554	if (_client->connect(_host, _port)) {
defmacro	22:4d895e732765	555	DBGLN("%s", "Connected to M2X server!");
defmacro	22:4d895e732765	556	int length = write_single_device_values(&_null_print, streamNum, names,
defmacro	22:4d895e732765	557	values, at);
defmacro	22:4d895e732765	558	_client->print("POST ");
defmacro	22:4d895e732765	559	if (_path_prefix) { _client->print(_path_prefix); }
defmacro	22:4d895e732765	560	_client->print("/v2/devices/");
defmacro	22:4d895e732765	561	_client->print(deviceId);
JMF	25:67079c11d1ea	562	_client->println("/update HTTP/1.1");
defmacro	22:4d895e732765	563	writeHttpHeader(length);
defmacro	22:4d895e732765	564	write_single_device_values(_client, streamNum, names, values, at);
defmacro	22:4d895e732765	565	} else {
defmacro	22:4d895e732765	566	DBGLN("%s", "ERROR: Cannot connect to M2X server!");
defmacro	22:4d895e732765	567	return E_NOCONNECTION;
defmacro	22:4d895e732765	568	}
defmacro	22:4d895e732765	569	return readStatusCode(true);
defmacro	22:4d895e732765	570	}
defmacro	22:4d895e732765	571
defmacro	22:4d895e732765	572	template <class T>
defmacro	22:4d895e732765	573	static int write_location_data(Print* print, const char* name,
defmacro	22:4d895e732765	574	T latitude, T longitude,
defmacro	22:4d895e732765	575	T elevation) {
defmacro	22:4d895e732765	576	int bytes = 0;
defmacro	22:4d895e732765	577	bytes += print->print("{\"name\":\"");
defmacro	22:4d895e732765	578	bytes += print->print(name);
defmacro	22:4d895e732765	579	bytes += print->print("\",\"latitude\":\"");
defmacro	22:4d895e732765	580	bytes += print->print(latitude);
defmacro	22:4d895e732765	581	bytes += print->print("\",\"longitude\":\"");
defmacro	22:4d895e732765	582	bytes += print->print(longitude);
defmacro	22:4d895e732765	583	bytes += print->print("\",\"elevation\":\"");
defmacro	22:4d895e732765	584	bytes += print->print(elevation);
defmacro	22:4d895e732765	585	bytes += print->print("\"}");
defmacro	22:4d895e732765	586	return bytes;
defmacro	22:4d895e732765	587	}
defmacro	22:4d895e732765	588
defmacro	22:4d895e732765	589	static int write_location_data(Print* print, const char* name,
defmacro	22:4d895e732765	590	double latitude, double longitude,
defmacro	22:4d895e732765	591	double elevation) {
defmacro	22:4d895e732765	592	int bytes = 0;
defmacro	22:4d895e732765	593	bytes += print->print("{\"name\":\"");
defmacro	22:4d895e732765	594	bytes += print->print(name);
defmacro	22:4d895e732765	595	bytes += print->print("\",\"latitude\":\"");
defmacro	22:4d895e732765	596	bytes += print->print(latitude, MAX_DOUBLE_DIGITS);
defmacro	22:4d895e732765	597	bytes += print->print("\",\"longitude\":\"");
defmacro	22:4d895e732765	598	bytes += print->print(longitude, MAX_DOUBLE_DIGITS);
defmacro	22:4d895e732765	599	bytes += print->print("\",\"elevation\":\"");
defmacro	22:4d895e732765	600	bytes += print->print(elevation);
defmacro	22:4d895e732765	601	bytes += print->print("\"}");
defmacro	22:4d895e732765	602	return bytes;
defmacro	22:4d895e732765	603	}
defmacro	22:4d895e732765	604
defmacro	22:4d895e732765	605	template <class T>
defmacro	22:4d895e732765	606	int M2XStreamClient::updateLocation(const char* deviceId,
defmacro	22:4d895e732765	607	const char* name,
defmacro	22:4d895e732765	608	T latitude,
defmacro	22:4d895e732765	609	T longitude,
defmacro	22:4d895e732765	610	T elevation) {
defmacro	22:4d895e732765	611	if (_client->connect(_host, _port)) {
defmacro	22:4d895e732765	612	DBGLN("%s", "Connected to M2X server!");
defmacro	22:4d895e732765	613
defmacro	22:4d895e732765	614	int length = write_location_data(&_null_print, name, latitude, longitude,
defmacro	22:4d895e732765	615	elevation);
defmacro	22:4d895e732765	616	_client->print("PUT ");
defmacro	22:4d895e732765	617	if (_path_prefix) { _client->print(_path_prefix); }
defmacro	22:4d895e732765	618	_client->print("/v2/devices/");
defmacro	22:4d895e732765	619	_client->print(deviceId);
JMF	25:67079c11d1ea	620	_client->println("/location HTTP/1.1");
defmacro	22:4d895e732765	621
defmacro	22:4d895e732765	622	writeHttpHeader(length);
defmacro	22:4d895e732765	623	write_location_data(_client, name, latitude, longitude, elevation);
defmacro	22:4d895e732765	624	} else {
defmacro	22:4d895e732765	625	DBGLN("%s", "ERROR: Cannot connect to M2X server!");
defmacro	22:4d895e732765	626	return E_NOCONNECTION;
defmacro	22:4d895e732765	627	}
defmacro	22:4d895e732765	628	return readStatusCode(true);
defmacro	22:4d895e732765	629	}
defmacro	22:4d895e732765	630
defmacro	22:4d895e732765	631	static inline int write_delete_values(Print* print, const char* from,
defmacro	22:4d895e732765	632	const char* end) {
defmacro	22:4d895e732765	633	int bytes = 0;
defmacro	22:4d895e732765	634	bytes += print->print("{\"from\":\"");
defmacro	22:4d895e732765	635	bytes += print->print(from);
defmacro	22:4d895e732765	636	bytes += print->print("\",\"end\":\"");
defmacro	22:4d895e732765	637	bytes += print->print(end);
defmacro	22:4d895e732765	638	bytes += print->print("\"}");
defmacro	22:4d895e732765	639	return bytes;
defmacro	22:4d895e732765	640	}
defmacro	22:4d895e732765	641
defmacro	22:4d895e732765	642	int M2XStreamClient::deleteValues(const char* deviceId, const char* streamName,
defmacro	22:4d895e732765	643	const char* from, const char* end) {
defmacro	22:4d895e732765	644	if (_client->connect(_host, _port)) {
defmacro	22:4d895e732765	645	DBGLN("%s", "Connected to M2X server!");
defmacro	22:4d895e732765	646	int length = write_delete_values(&_null_print, from, end);
defmacro	22:4d895e732765	647	writeDeleteHeader(deviceId, streamName, length);
defmacro	22:4d895e732765	648	write_delete_values(_client, from, end);
defmacro	22:4d895e732765	649	} else {
defmacro	22:4d895e732765	650	DBGLN("%s", "ERROR: Cannot connect to M2X server!");
defmacro	22:4d895e732765	651	return E_NOCONNECTION;
defmacro	22:4d895e732765	652	}
defmacro	22:4d895e732765	653
defmacro	22:4d895e732765	654	return readStatusCode(true);
defmacro	22:4d895e732765	655	}
defmacro	22:4d895e732765	656
defmacro	22:4d895e732765	657	int M2XStreamClient::markCommandProcessed(const char* deviceId,
defmacro	22:4d895e732765	658	const char* commandId,
defmacro	22:4d895e732765	659	m2x_fill_data_callback callback,
defmacro	22:4d895e732765	660	void *context) {
defmacro	22:4d895e732765	661	if (_client->connect(_host, _port)) {
defmacro	22:4d895e732765	662	DBGLN("%s", "Connected to M2X server!");
defmacro	22:4d895e732765	663	_null_print.counter = 0;
defmacro	22:4d895e732765	664	callback(&_null_print, context);
defmacro	22:4d895e732765	665	int length = _null_print.counter;
defmacro	22:4d895e732765	666	_client->print("POST ");
defmacro	22:4d895e732765	667	if (_path_prefix) { _client->print(_path_prefix); }
defmacro	22:4d895e732765	668	_client->print("/v2/devices/");
defmacro	22:4d895e732765	669	_client->print(deviceId);
defmacro	22:4d895e732765	670	_client->print("/commands/");
defmacro	22:4d895e732765	671	_client->print(commandId);
defmacro	22:4d895e732765	672	_client->print("/process");
JMF	25:67079c11d1ea	673	_client->println(" HTTP/1.1");
defmacro	22:4d895e732765	674	writeHttpHeader(length);
defmacro	22:4d895e732765	675	callback(_client, context);
defmacro	22:4d895e732765	676	} else {
defmacro	22:4d895e732765	677	DBGLN("%s", "ERROR: Cannot connect to M2X server!");
defmacro	22:4d895e732765	678	return E_NOCONNECTION;
defmacro	22:4d895e732765	679	}
defmacro	22:4d895e732765	680	return readStatusCode(true);
defmacro	22:4d895e732765	681	}
defmacro	22:4d895e732765	682
defmacro	22:4d895e732765	683	static void m2x_fixed_buffer_filling_callback(Print print, void context) {
defmacro	22:4d895e732765	684	if (context) {
defmacro	22:4d895e732765	685	print->print((const char *) context);
defmacro	22:4d895e732765	686	}
defmacro	22:4d895e732765	687	}
defmacro	22:4d895e732765	688
defmacro	22:4d895e732765	689	int M2XStreamClient::markCommandProcessedWithData(const char* deviceId,
defmacro	22:4d895e732765	690	const char* commandId,
defmacro	22:4d895e732765	691	const char* data) {
defmacro	22:4d895e732765	692	return markCommandProcessed(deviceId, commandId,
defmacro	22:4d895e732765	693	m2x_fixed_buffer_filling_callback, (void *) data);
defmacro	22:4d895e732765	694	}
defmacro	22:4d895e732765	695
defmacro	22:4d895e732765	696	int M2XStreamClient::markCommandRejected(const char* deviceId,
defmacro	22:4d895e732765	697	const char* commandId,
defmacro	22:4d895e732765	698	m2x_fill_data_callback callback,
defmacro	22:4d895e732765	699	void *context) {
defmacro	22:4d895e732765	700	if (_client->connect(_host, _port)) {
defmacro	22:4d895e732765	701	DBGLN("%s", "Connected to M2X server!");
defmacro	22:4d895e732765	702	_null_print.counter = 0;
defmacro	22:4d895e732765	703	callback(&_null_print, context);
defmacro	22:4d895e732765	704	int length = _null_print.counter;
defmacro	22:4d895e732765	705	_client->print("POST ");
defmacro	22:4d895e732765	706	if (_path_prefix) { _client->print(_path_prefix); }
defmacro	22:4d895e732765	707	_client->print("/v2/devices/");
defmacro	22:4d895e732765	708	_client->print(deviceId);
defmacro	22:4d895e732765	709	_client->print("/commands/");
defmacro	22:4d895e732765	710	_client->print(commandId);
defmacro	22:4d895e732765	711	_client->print("/reject");
JMF	25:67079c11d1ea	712	_client->println(" HTTP/1.1");
defmacro	22:4d895e732765	713	writeHttpHeader(length);
defmacro	22:4d895e732765	714	callback(_client, context);
defmacro	22:4d895e732765	715	} else {
defmacro	22:4d895e732765	716	DBGLN("%s", "ERROR: Cannot connect to M2X server!");
defmacro	22:4d895e732765	717	return E_NOCONNECTION;
defmacro	22:4d895e732765	718	}
defmacro	22:4d895e732765	719	return readStatusCode(true);
defmacro	22:4d895e732765	720	}
defmacro	22:4d895e732765	721
defmacro	22:4d895e732765	722	int M2XStreamClient::markCommandRejectedWithData(const char* deviceId,
defmacro	22:4d895e732765	723	const char* commandId,
defmacro	22:4d895e732765	724	const char* data) {
defmacro	22:4d895e732765	725	return markCommandRejected(deviceId, commandId,
defmacro	22:4d895e732765	726	m2x_fixed_buffer_filling_callback, (void *) data);
defmacro	22:4d895e732765	727	}
defmacro	22:4d895e732765	728
defmacro	22:4d895e732765	729	int M2XStreamClient::getTimestamp32(int32_t *ts) {
defmacro	22:4d895e732765	730	// The maximum value of signed 64-bit integer is 0x7fffffffffffffff,
defmacro	22:4d895e732765	731	// which is 9223372036854775807. It consists of 19 characters, so a
defmacro	22:4d895e732765	732	// buffer of 20 is definitely enough here
defmacro	22:4d895e732765	733	int length = 20;
defmacro	22:4d895e732765	734	char buffer[20];
defmacro	22:4d895e732765	735	int status = getTimestamp(buffer, &length);
defmacro	22:4d895e732765	736	if (status == 200) {
defmacro	22:4d895e732765	737	int32_t result = 0;
defmacro	22:4d895e732765	738	for (int i = 0; i < length; i++) {
defmacro	22:4d895e732765	739	result = result * 10 + (buffer[i] - '0');
defmacro	22:4d895e732765	740	}
defmacro	22:4d895e732765	741	if (ts != NULL) { *ts = result; }
defmacro	22:4d895e732765	742	}
defmacro	22:4d895e732765	743	return status;
defmacro	22:4d895e732765	744	}
defmacro	22:4d895e732765	745
defmacro	22:4d895e732765	746	int M2XStreamClient::getTimestamp(char* buffer, int *bufferLength) {
defmacro	22:4d895e732765	747	if (bufferLength == NULL) { return E_INVALID; }
defmacro	22:4d895e732765	748	if (_client->connect(_host, _port)) {
defmacro	22:4d895e732765	749	DBGLN("%s", "Connected to M2X server!");
defmacro	22:4d895e732765	750	_client->print("GET ");
defmacro	22:4d895e732765	751	if (_path_prefix) { _client->print(_path_prefix); }
JMF	25:67079c11d1ea	752	_client->println("/v2/time/seconds HTTP/1.1");
defmacro	22:4d895e732765	753
defmacro	22:4d895e732765	754	writeHttpHeader(-1);
defmacro	22:4d895e732765	755	} else {
defmacro	22:4d895e732765	756	DBGLN("%s", "ERROR: Cannot connect to M2X server!");
defmacro	22:4d895e732765	757	return E_NOCONNECTION;
defmacro	22:4d895e732765	758	}
defmacro	22:4d895e732765	759	int status = readStatusCode(false);
defmacro	22:4d895e732765	760	if (status == 200) {
defmacro	22:4d895e732765	761	int length = readContentLength();
defmacro	22:4d895e732765	762	if (length < 0) {
defmacro	22:4d895e732765	763	close();
defmacro	22:4d895e732765	764	return length;
defmacro	22:4d895e732765	765	}
defmacro	22:4d895e732765	766	if (*bufferLength < length) {
defmacro	22:4d895e732765	767	*bufferLength = length;
defmacro	22:4d895e732765	768	return E_BUFFER_TOO_SMALL;
defmacro	22:4d895e732765	769	}
defmacro	22:4d895e732765	770	*bufferLength = length;
defmacro	22:4d895e732765	771	int index = skipHttpHeader();
defmacro	22:4d895e732765	772	if (index != E_OK) {
defmacro	22:4d895e732765	773	close();
defmacro	22:4d895e732765	774	return index;
defmacro	22:4d895e732765	775	}
defmacro	22:4d895e732765	776	index = 0;
defmacro	22:4d895e732765	777	while (index < length) {
defmacro	22:4d895e732765	778	DBG("%s", "Received Data: ");
defmacro	22:4d895e732765	779	while ((index < length) && _client->available()) {
defmacro	22:4d895e732765	780	buffer[index++] = _client->read();
defmacro	22:4d895e732765	781	DBG("%c", buffer[index - 1]);
defmacro	22:4d895e732765	782	}
defmacro	22:4d895e732765	783	DBGLNEND;
defmacro	22:4d895e732765	784
defmacro	22:4d895e732765	785	if ((!_client->connected()) &&
defmacro	22:4d895e732765	786	(index < length)) {
defmacro	22:4d895e732765	787	close();
defmacro	22:4d895e732765	788	return E_NOCONNECTION;
defmacro	22:4d895e732765	789	}
defmacro	22:4d895e732765	790
defmacro	22:4d895e732765	791	if (_idlefunc!=NULL) {
defmacro	22:4d895e732765	792	_idlefunc();
defmacro	22:4d895e732765	793	} else {
defmacro	22:4d895e732765	794	delay(200);
defmacro	22:4d895e732765	795	}
defmacro	22:4d895e732765	796	}
defmacro	22:4d895e732765	797	}
defmacro	22:4d895e732765	798	close();
defmacro	22:4d895e732765	799	return status;
defmacro	22:4d895e732765	800	}
defmacro	22:4d895e732765	801
defmacro	22:4d895e732765	802
defmacro	22:4d895e732765	803	void M2XStreamClient::writePutHeader(const char* deviceId,
defmacro	22:4d895e732765	804	const char* streamName,
defmacro	22:4d895e732765	805	int contentLength) {
defmacro	22:4d895e732765	806	_client->print("PUT ");
defmacro	22:4d895e732765	807	if (_path_prefix) { _client->print(_path_prefix); }
defmacro	22:4d895e732765	808	_client->print("/v2/devices/");
defmacro	22:4d895e732765	809	_client->print(deviceId);
defmacro	22:4d895e732765	810	_client->print("/streams/");
defmacro	22:4d895e732765	811	print_encoded_string(_client, streamName);
JMF	25:67079c11d1ea	812	_client->println("/value HTTP/1.1");
defmacro	22:4d895e732765	813
defmacro	22:4d895e732765	814	writeHttpHeader(contentLength);
defmacro	22:4d895e732765	815	}
defmacro	22:4d895e732765	816
defmacro	22:4d895e732765	817	void M2XStreamClient::writeDeleteHeader(const char* deviceId,
defmacro	22:4d895e732765	818	const char* streamName,
defmacro	22:4d895e732765	819	int contentLength) {
defmacro	22:4d895e732765	820	_client->print("DELETE ");
defmacro	22:4d895e732765	821	if (_path_prefix) { _client->print(_path_prefix); }
defmacro	22:4d895e732765	822	_client->print("/v2/devices/");
defmacro	22:4d895e732765	823	_client->print(deviceId);
defmacro	22:4d895e732765	824	_client->print("/streams/");
defmacro	22:4d895e732765	825	print_encoded_string(_client, streamName);
defmacro	22:4d895e732765	826	_client->print("/values");
JMF	25:67079c11d1ea	827	_client->println(" HTTP/1.1");
defmacro	22:4d895e732765	828
defmacro	22:4d895e732765	829	writeHttpHeader(contentLength);
defmacro	22:4d895e732765	830	}
defmacro	22:4d895e732765	831
JMF	23:f32837239193	832	void M2XStreamClient::writeDeleteLocationHeader(const char* deviceId,
JMF	23:f32837239193	833	int contentLength) {
JMF	23:f32837239193	834	_client->print("DELETE ");
JMF	23:f32837239193	835	if (_path_prefix) { _client->print(_path_prefix); }
JMF	23:f32837239193	836	_client->print("/v2/devices/");
JMF	23:f32837239193	837	_client->print(deviceId);
JMF	23:f32837239193	838	_client->print("/location/waypoints/");
JMF	25:67079c11d1ea	839	_client->println(" HTTP/1.1");
JMF	23:f32837239193	840
JMF	23:f32837239193	841	writeHttpHeader(contentLength);
JMF	23:f32837239193	842	}
JMF	23:f32837239193	843
JMF	23:f32837239193	844
defmacro	22:4d895e732765	845	void M2XStreamClient::writeHttpHeader(int contentLength) {
defmacro	22:4d895e732765	846	_client->println(USER_AGENT);
defmacro	22:4d895e732765	847	_client->print("X-M2X-KEY: ");
defmacro	22:4d895e732765	848	_client->println(_key);
defmacro	22:4d895e732765	849
defmacro	22:4d895e732765	850	_client->print("Host: ");
defmacro	22:4d895e732765	851	print_encoded_string(_client, _host);
defmacro	22:4d895e732765	852	if (_port != DEFAULT_M2X_PORT) {
defmacro	22:4d895e732765	853	_client->print(":");
defmacro	22:4d895e732765	854	// port is an integer, does not need encoding
defmacro	22:4d895e732765	855	_client->print(_port);
defmacro	22:4d895e732765	856	}
defmacro	22:4d895e732765	857	_client->println();
defmacro	22:4d895e732765	858
defmacro	22:4d895e732765	859	if (contentLength > 0) {
defmacro	22:4d895e732765	860	_client->println("Content-Type: application/json");
defmacro	22:4d895e732765	861	DBG("%s", "Content Length: ");
defmacro	22:4d895e732765	862	DBGLN("%d", contentLength);
defmacro	22:4d895e732765	863
defmacro	22:4d895e732765	864	_client->print("Content-Length: ");
defmacro	22:4d895e732765	865	_client->println(contentLength);
defmacro	22:4d895e732765	866	}
defmacro	22:4d895e732765	867	_client->println();
defmacro	22:4d895e732765	868	}
defmacro	22:4d895e732765	869
defmacro	22:4d895e732765	870	int M2XStreamClient::waitForString(const char* str) {
defmacro	22:4d895e732765	871	int currentIndex = 0;
defmacro	22:4d895e732765	872	if (str[currentIndex] == '\0') return E_OK;
defmacro	22:4d895e732765	873
defmacro	22:4d895e732765	874	while (true) {
defmacro	22:4d895e732765	875	while (_client->available()) {
defmacro	22:4d895e732765	876	char c = _client->read();
defmacro	22:4d895e732765	877	DBG("%c", c);
defmacro	22:4d895e732765	878
defmacro	22:4d895e732765	879	int cmp;
defmacro	22:4d895e732765	880	if (_case_insensitive) {
defmacro	22:4d895e732765	881	cmp = tolower(c) - tolower(str[currentIndex]);
defmacro	22:4d895e732765	882	} else {
defmacro	22:4d895e732765	883	cmp = c - str[currentIndex];
defmacro	22:4d895e732765	884	}
defmacro	22:4d895e732765	885
defmacro	22:4d895e732765	886	if ((str[currentIndex] == '*') \|\| (cmp == 0)) {
defmacro	22:4d895e732765	887	currentIndex++;
defmacro	22:4d895e732765	888	if (str[currentIndex] == '\0') {
defmacro	22:4d895e732765	889	return E_OK;
defmacro	22:4d895e732765	890	}
defmacro	22:4d895e732765	891	} else {
defmacro	22:4d895e732765	892	// start from the beginning
defmacro	22:4d895e732765	893	currentIndex = 0;
defmacro	22:4d895e732765	894	}
defmacro	22:4d895e732765	895	}
defmacro	22:4d895e732765	896
defmacro	22:4d895e732765	897	if (!_client->connected()) {
defmacro	22:4d895e732765	898	DBGLN("%s", "ERROR: The client is disconnected from the server!");
defmacro	22:4d895e732765	899
defmacro	22:4d895e732765	900	close();
defmacro	22:4d895e732765	901	return E_DISCONNECTED;
defmacro	22:4d895e732765	902	}
defmacro	22:4d895e732765	903	if (_idlefunc!=NULL)
defmacro	22:4d895e732765	904	_idlefunc();
defmacro	22:4d895e732765	905	else
defmacro	22:4d895e732765	906	delay(200);
defmacro	22:4d895e732765	907	}
defmacro	22:4d895e732765	908	// never reached here
defmacro	22:4d895e732765	909	return E_NOTREACHABLE;
defmacro	22:4d895e732765	910	}
defmacro	22:4d895e732765	911
defmacro	22:4d895e732765	912	int M2XStreamClient::readStatusCode(bool closeClient) {
defmacro	22:4d895e732765	913	int responseCode = 0;
defmacro	22:4d895e732765	914	int ret = waitForString("HTTP/. ");
defmacro	22:4d895e732765	915	if (ret != E_OK) {
defmacro	22:4d895e732765	916	if (closeClient) close();
defmacro	22:4d895e732765	917	return ret;
defmacro	22:4d895e732765	918	}
defmacro	22:4d895e732765	919
defmacro	22:4d895e732765	920	// ret is not needed from here(since it must be E_OK), so we can use it
defmacro	22:4d895e732765	921	// as a regular variable now.
defmacro	22:4d895e732765	922	ret = 0;
defmacro	22:4d895e732765	923	while (true) {
defmacro	22:4d895e732765	924	while (_client->available()) {
defmacro	22:4d895e732765	925	char c = _client->read();
defmacro	22:4d895e732765	926	DBG("%c", c);
defmacro	22:4d895e732765	927
defmacro	22:4d895e732765	928	responseCode = responseCode * 10 + (c - '0');
defmacro	22:4d895e732765	929	ret++;
defmacro	22:4d895e732765	930	if (ret == 3) {
defmacro	22:4d895e732765	931	if (closeClient) close();
defmacro	22:4d895e732765	932	return responseCode;
defmacro	22:4d895e732765	933	}
defmacro	22:4d895e732765	934	}
defmacro	22:4d895e732765	935
defmacro	22:4d895e732765	936	if (!_client->connected()) {
defmacro	22:4d895e732765	937	DBGLN("%s", "ERROR: The client is disconnected from the server!");
defmacro	22:4d895e732765	938
defmacro	22:4d895e732765	939	if (closeClient) close();
defmacro	22:4d895e732765	940	return E_DISCONNECTED;
defmacro	22:4d895e732765	941	}
defmacro	22:4d895e732765	942	if (_idlefunc!=NULL)
defmacro	22:4d895e732765	943	_idlefunc();
defmacro	22:4d895e732765	944	else
defmacro	22:4d895e732765	945	delay(200);
defmacro	22:4d895e732765	946	}
defmacro	22:4d895e732765	947
defmacro	22:4d895e732765	948	// never reached here
defmacro	22:4d895e732765	949	return E_NOTREACHABLE;
defmacro	22:4d895e732765	950	}
defmacro	22:4d895e732765	951
defmacro	22:4d895e732765	952	int M2XStreamClient::readContentLength() {
defmacro	22:4d895e732765	953	int ret = waitForString("Content-Length: ");
defmacro	22:4d895e732765	954	if (ret != E_OK) {
defmacro	22:4d895e732765	955	return ret;
defmacro	22:4d895e732765	956	}
defmacro	22:4d895e732765	957
defmacro	22:4d895e732765	958	// From now on, ret is not needed, we can use it
defmacro	22:4d895e732765	959	// to keep the final result
defmacro	22:4d895e732765	960	ret = 0;
defmacro	22:4d895e732765	961	while (true) {
defmacro	22:4d895e732765	962	while (_client->available()) {
defmacro	22:4d895e732765	963	char c = _client->read();
defmacro	22:4d895e732765	964	DBG("%c", c);
defmacro	22:4d895e732765	965
defmacro	22:4d895e732765	966	if ((c == '\r') \|\| (c == '\n')) {
defmacro	22:4d895e732765	967	return (ret == 0) ? (E_INVALID) : (ret);
defmacro	22:4d895e732765	968	} else {
defmacro	22:4d895e732765	969	ret = ret * 10 + (c - '0');
defmacro	22:4d895e732765	970	}
defmacro	22:4d895e732765	971	}
defmacro	22:4d895e732765	972
defmacro	22:4d895e732765	973	if (!_client->connected()) {
defmacro	22:4d895e732765	974	DBGLN("%s", "ERROR: The client is disconnected from the server!");
defmacro	22:4d895e732765	975
defmacro	22:4d895e732765	976	return E_DISCONNECTED;
defmacro	22:4d895e732765	977	}
defmacro	22:4d895e732765	978	if (_idlefunc!=NULL)
defmacro	22:4d895e732765	979	_idlefunc();
defmacro	22:4d895e732765	980	else
defmacro	22:4d895e732765	981	delay(200);
defmacro	22:4d895e732765	982	}
defmacro	22:4d895e732765	983
defmacro	22:4d895e732765	984	// never reached here
defmacro	22:4d895e732765	985	return E_NOTREACHABLE;
defmacro	22:4d895e732765	986	}
defmacro	22:4d895e732765	987
defmacro	22:4d895e732765	988	int M2XStreamClient::skipHttpHeader() {
defmacro	22:4d895e732765	989	return waitForString("\n\r\n");
defmacro	22:4d895e732765	990	}
defmacro	22:4d895e732765	991
defmacro	22:4d895e732765	992	void M2XStreamClient::close() {
defmacro	22:4d895e732765	993	// Eats up buffered data before closing
defmacro	22:4d895e732765	994	_client->flush();
defmacro	22:4d895e732765	995	_client->stop();
defmacro	22:4d895e732765	996	}
defmacro	22:4d895e732765	997
defmacro	22:4d895e732765	998	static inline int fill_iso8601_timestamp(int32_t seconds, int32_t milli,
defmacro	22:4d895e732765	999	char* buffer, int* length);
defmacro	22:4d895e732765	1000
defmacro	22:4d895e732765	1001	TimeService::TimeService(M2XStreamClient* client) : _client(client) {
defmacro	22:4d895e732765	1002	}
defmacro	22:4d895e732765	1003
defmacro	22:4d895e732765	1004	int TimeService::init() {
defmacro	22:4d895e732765	1005	_timer.start();
defmacro	22:4d895e732765	1006	return reset();
defmacro	22:4d895e732765	1007	}
defmacro	22:4d895e732765	1008
defmacro	22:4d895e732765	1009	int TimeService::reset() {
defmacro	22:4d895e732765	1010	int32_t ts;
defmacro	22:4d895e732765	1011	int status = _client->getTimestamp32(&ts);
defmacro	22:4d895e732765	1012
defmacro	22:4d895e732765	1013	if (m2x_status_is_success(status)) {
defmacro	22:4d895e732765	1014	_server_timestamp = ts;
defmacro	22:4d895e732765	1015	_local_last_milli = _timer.read_ms();
defmacro	22:4d895e732765	1016	}
defmacro	22:4d895e732765	1017
defmacro	22:4d895e732765	1018	return status;
defmacro	22:4d895e732765	1019	}
defmacro	22:4d895e732765	1020
defmacro	22:4d895e732765	1021	int TimeService::getTimestamp(char* buffer, int* length) {
defmacro	22:4d895e732765	1022	uint32_t now = _timer.read_ms();
defmacro	22:4d895e732765	1023	if (now < _local_last_milli) {
defmacro	22:4d895e732765	1024	// In case of a timestamp overflow(happens once every 50 days on
defmacro	22:4d895e732765	1025	// Arduino), we reset the server timestamp recorded.
defmacro	22:4d895e732765	1026	// NOTE: while on an Arduino this might be okay, the situation is worse
defmacro	22:4d895e732765	1027	// on mbed, see the notes in m2x-mbed.h for details
defmacro	22:4d895e732765	1028	int status = reset();
defmacro	22:4d895e732765	1029	if (!m2x_status_is_success(status)) { return status; }
defmacro	22:4d895e732765	1030	now = _timer.read_ms();
defmacro	22:4d895e732765	1031	}
defmacro	22:4d895e732765	1032	if (now < _local_last_milli) {
defmacro	22:4d895e732765	1033	// We have already reseted the timestamp, so this cannot happen
defmacro	22:4d895e732765	1034	// (an HTTP request can take longer than 50 days to finished? You
defmacro	22:4d895e732765	1035	// must be kidding here). Something else must be wrong here
defmacro	22:4d895e732765	1036	return E_TIMESTAMP_ERROR;
defmacro	22:4d895e732765	1037	}
defmacro	22:4d895e732765	1038	uint32_t diff = now - _local_last_milli;
defmacro	22:4d895e732765	1039	_local_last_milli = now;
defmacro	22:4d895e732765	1040	_server_timestamp += (int32_t) (diff / 1000); // Milliseconds to seconds
defmacro	22:4d895e732765	1041	return fill_iso8601_timestamp(_server_timestamp, (int32_t) (diff % 1000),
defmacro	22:4d895e732765	1042	buffer, length);
defmacro	22:4d895e732765	1043	}
defmacro	22:4d895e732765	1044
defmacro	22:4d895e732765	1045	#define SIZE_ISO_8601 25
defmacro	22:4d895e732765	1046	static inline bool is_leap_year(int16_t y) {
defmacro	22:4d895e732765	1047	return ((1970 + y) > 0) &&
defmacro	22:4d895e732765	1048	!((1970 + y) % 4) &&
defmacro	22:4d895e732765	1049	(((1970 + y) % 100) \|\| !((1970 + y) % 400));
defmacro	22:4d895e732765	1050	}
defmacro	22:4d895e732765	1051	static inline int32_t days_in_year(int16_t y) {
defmacro	22:4d895e732765	1052	return is_leap_year(y) ? 366 : 365;
defmacro	22:4d895e732765	1053	}
defmacro	22:4d895e732765	1054	static const uint8_t MONTH_DAYS[]={31,28,31,30,31,30,31,31,30,31,30,31};
defmacro	22:4d895e732765	1055
defmacro	22:4d895e732765	1056	static inline int fill_iso8601_timestamp(int32_t timestamp, int32_t milli,
defmacro	22:4d895e732765	1057	char* buffer, int* length) {
defmacro	22:4d895e732765	1058	int16_t year;
defmacro	22:4d895e732765	1059	int8_t month, month_length;
defmacro	22:4d895e732765	1060	int32_t day;
defmacro	22:4d895e732765	1061	int8_t hour, minute, second;
defmacro	22:4d895e732765	1062
defmacro	22:4d895e732765	1063	if (*length < SIZE_ISO_8601) {
defmacro	22:4d895e732765	1064	*length = SIZE_ISO_8601;
defmacro	22:4d895e732765	1065	return E_BUFFER_TOO_SMALL;
defmacro	22:4d895e732765	1066	}
defmacro	22:4d895e732765	1067
defmacro	22:4d895e732765	1068	second = timestamp % 60;
defmacro	22:4d895e732765	1069	timestamp /= 60; // now it is minutes
defmacro	22:4d895e732765	1070
defmacro	22:4d895e732765	1071	minute = timestamp % 60;
defmacro	22:4d895e732765	1072	timestamp /= 60; // now it is hours
defmacro	22:4d895e732765	1073
defmacro	22:4d895e732765	1074	hour = timestamp % 24;
defmacro	22:4d895e732765	1075	timestamp /= 24; // now it is days
defmacro	22:4d895e732765	1076
defmacro	22:4d895e732765	1077	year = 0;
defmacro	22:4d895e732765	1078	day = 0;
defmacro	22:4d895e732765	1079	while ((day += days_in_year(year)) <= timestamp) {
defmacro	22:4d895e732765	1080	year++;
defmacro	22:4d895e732765	1081	}
defmacro	22:4d895e732765	1082	day -= days_in_year(year);
defmacro	22:4d895e732765	1083	timestamp -= day; // now it is days in this year, starting at 0
defmacro	22:4d895e732765	1084
defmacro	22:4d895e732765	1085	day = 0;
defmacro	22:4d895e732765	1086	month_length = 0;
defmacro	22:4d895e732765	1087	for (month = 0; month < 12; month++) {
defmacro	22:4d895e732765	1088	if (month == 1) {
defmacro	22:4d895e732765	1089	// February
defmacro	22:4d895e732765	1090	month_length = is_leap_year(year) ? 29 : 28;
defmacro	22:4d895e732765	1091	} else {
defmacro	22:4d895e732765	1092	month_length = MONTH_DAYS[month];
defmacro	22:4d895e732765	1093	}
defmacro	22:4d895e732765	1094
defmacro	22:4d895e732765	1095	if (timestamp >= month_length) {
defmacro	22:4d895e732765	1096	timestamp -= month_length;
defmacro	22:4d895e732765	1097	} else {
defmacro	22:4d895e732765	1098	break;
defmacro	22:4d895e732765	1099	}
defmacro	22:4d895e732765	1100	}
defmacro	22:4d895e732765	1101	year = 1970 + year;
defmacro	22:4d895e732765	1102	month++; // offset by 1
defmacro	22:4d895e732765	1103	day = timestamp + 1;
defmacro	22:4d895e732765	1104
defmacro	22:4d895e732765	1105	int i = 0, j = 0;
defmacro	22:4d895e732765	1106
defmacro	22:4d895e732765	1107	// NOTE: It seems the snprintf implementation in Arduino has bugs,
defmacro	22:4d895e732765	1108	// we have to manually piece the string together here.
defmacro	22:4d895e732765	1109	#define INT_TO_STR(v_, width_) \
defmacro	22:4d895e732765	1110	for (j = 0; j < (width_); j++) { \
defmacro	22:4d895e732765	1111	buffer[i + (width_) - 1 - j] = '0' + ((v_) % 10); \
defmacro	22:4d895e732765	1112	(v_) /= 10; \
defmacro	22:4d895e732765	1113	} \
defmacro	22:4d895e732765	1114	i += (width_)
defmacro	22:4d895e732765	1115
defmacro	22:4d895e732765	1116	INT_TO_STR(year, 4);
defmacro	22:4d895e732765	1117	buffer[i++] = '-';
defmacro	22:4d895e732765	1118	INT_TO_STR(month, 2);
defmacro	22:4d895e732765	1119	buffer[i++] = '-';
defmacro	22:4d895e732765	1120	INT_TO_STR(day, 2);
defmacro	22:4d895e732765	1121	buffer[i++] = 'T';
defmacro	22:4d895e732765	1122	INT_TO_STR(hour, 2);
defmacro	22:4d895e732765	1123	buffer[i++] = ':';
defmacro	22:4d895e732765	1124	INT_TO_STR(minute, 2);
defmacro	22:4d895e732765	1125	buffer[i++] = ':';
defmacro	22:4d895e732765	1126	INT_TO_STR(second, 2);
defmacro	22:4d895e732765	1127	buffer[i++] = '.';
defmacro	22:4d895e732765	1128	INT_TO_STR(milli, 3);
defmacro	22:4d895e732765	1129	buffer[i++] = 'Z';
defmacro	22:4d895e732765	1130	buffer[i++] = '\0';
defmacro	22:4d895e732765	1131
defmacro	22:4d895e732765	1132	#undef INT_TO_STR
defmacro	22:4d895e732765	1133
defmacro	22:4d895e732765	1134	*length = i;
defmacro	22:4d895e732765	1135	return E_OK;
defmacro	22:4d895e732765	1136	}
defmacro	22:4d895e732765	1137
defmacro	22:4d895e732765	1138	/* Reader functions */
defmacro	22:4d895e732765	1139	#ifdef M2X_ENABLE_READER
defmacro	22:4d895e732765	1140
defmacro	22:4d895e732765	1141	// Data structures and functions used to parse stream values
defmacro	22:4d895e732765	1142
defmacro	22:4d895e732765	1143	#define STREAM_BUF_LEN 32
defmacro	22:4d895e732765	1144
defmacro	22:4d895e732765	1145	typedef struct {
defmacro	22:4d895e732765	1146	uint8_t state;
defmacro	22:4d895e732765	1147	char at_str[STREAM_BUF_LEN + 1];
defmacro	22:4d895e732765	1148	char value_str[STREAM_BUF_LEN + 1];
defmacro	22:4d895e732765	1149	int index;
defmacro	22:4d895e732765	1150
defmacro	22:4d895e732765	1151	stream_value_read_callback callback;
defmacro	22:4d895e732765	1152	void* context;
defmacro	22:4d895e732765	1153	} stream_parsing_context_state;
defmacro	22:4d895e732765	1154
defmacro	22:4d895e732765	1155	#define WAITING_AT 0x1
defmacro	22:4d895e732765	1156	#define GOT_AT 0x2
defmacro	22:4d895e732765	1157	#define WAITING_VALUE 0x4
defmacro	22:4d895e732765	1158	#define GOT_VALUE 0x8
defmacro	22:4d895e732765	1159
defmacro	22:4d895e732765	1160	#define GOT_STREAM (GOT_AT \| GOT_VALUE)
defmacro	22:4d895e732765	1161	#define TEST_GOT_STREAM(state_) (((state_) & GOT_STREAM) == GOT_STREAM)
defmacro	22:4d895e732765	1162
defmacro	22:4d895e732765	1163	#define TEST_IS_AT(state_) (((state_) & (WAITING_AT \| GOT_AT)) == WAITING_AT)
defmacro	22:4d895e732765	1164	#define TEST_IS_VALUE(state_) (((state_) & (WAITING_VALUE \| GOT_VALUE)) == \
defmacro	22:4d895e732765	1165	WAITING_VALUE)
defmacro	22:4d895e732765	1166
defmacro	22:4d895e732765	1167	static void on_stream_key_found(jsonlite_callback_context* context,
defmacro	22:4d895e732765	1168	jsonlite_token* token)
defmacro	22:4d895e732765	1169	{
defmacro	22:4d895e732765	1170	stream_parsing_context_state* state =
defmacro	22:4d895e732765	1171	(stream_parsing_context_state*) context->client_state;
defmacro	22:4d895e732765	1172	if (strncmp((const char*) token->start, "timestamp", 9) == 0) {
defmacro	22:4d895e732765	1173	state->state \|= WAITING_AT;
defmacro	22:4d895e732765	1174	} else if ((strncmp((const char*) token->start, "value", 5) == 0) &&
defmacro	22:4d895e732765	1175	(token->start[5] != 's')) { // get rid of "values"
defmacro	22:4d895e732765	1176	state->state \|= WAITING_VALUE;
defmacro	22:4d895e732765	1177	}
defmacro	22:4d895e732765	1178	}
defmacro	22:4d895e732765	1179
defmacro	22:4d895e732765	1180	static void on_stream_value_found(jsonlite_callback_context* context,
defmacro	22:4d895e732765	1181	jsonlite_token* token,
defmacro	22:4d895e732765	1182	int type)
defmacro	22:4d895e732765	1183	{
defmacro	22:4d895e732765	1184	stream_parsing_context_state* state =
defmacro	22:4d895e732765	1185	(stream_parsing_context_state*) context->client_state;
defmacro	22:4d895e732765	1186
defmacro	22:4d895e732765	1187	if (TEST_IS_AT(state->state)) {
defmacro	22:4d895e732765	1188	strncpy(state->at_str, (const char*) token->start,
defmacro	22:4d895e732765	1189	MIN(token->end - token->start, STREAM_BUF_LEN));
defmacro	22:4d895e732765	1190	state->at_str[MIN(token->end - token->start, STREAM_BUF_LEN)] = '\0';
defmacro	22:4d895e732765	1191	state->state \|= GOT_AT;
defmacro	22:4d895e732765	1192	} else if (TEST_IS_VALUE(state->state)) {
defmacro	22:4d895e732765	1193	strncpy(state->value_str, (const char*) token->start,
defmacro	22:4d895e732765	1194	MIN(token->end - token->start, STREAM_BUF_LEN));
defmacro	22:4d895e732765	1195	state->value_str[MIN(token->end - token->start, STREAM_BUF_LEN)] = '\0';
defmacro	22:4d895e732765	1196	state->state \|= GOT_VALUE;
defmacro	22:4d895e732765	1197	}
defmacro	22:4d895e732765	1198
defmacro	22:4d895e732765	1199	if (TEST_GOT_STREAM(state->state)) {
defmacro	22:4d895e732765	1200	state->callback(state->at_str, state->value_str,
defmacro	22:4d895e732765	1201	state->index++, state->context, type);
defmacro	22:4d895e732765	1202	state->state = 0;
defmacro	22:4d895e732765	1203	}
defmacro	22:4d895e732765	1204	}
defmacro	22:4d895e732765	1205
defmacro	22:4d895e732765	1206	static void on_stream_string_found(jsonlite_callback_context* context,
defmacro	22:4d895e732765	1207	jsonlite_token* token)
defmacro	22:4d895e732765	1208	{
defmacro	22:4d895e732765	1209	on_stream_value_found(context, token, 1);
defmacro	22:4d895e732765	1210	}
defmacro	22:4d895e732765	1211
defmacro	22:4d895e732765	1212	static void on_stream_number_found(jsonlite_callback_context* context,
defmacro	22:4d895e732765	1213	jsonlite_token* token)
defmacro	22:4d895e732765	1214	{
defmacro	22:4d895e732765	1215	on_stream_value_found(context, token, 2);
defmacro	22:4d895e732765	1216	}
defmacro	22:4d895e732765	1217
defmacro	22:4d895e732765	1218	// Data structures and functions used to parse locations
defmacro	22:4d895e732765	1219
defmacro	22:4d895e732765	1220	#define LOCATION_BUF_LEN 20
defmacro	22:4d895e732765	1221
defmacro	22:4d895e732765	1222	typedef struct {
defmacro	22:4d895e732765	1223	uint16_t state;
defmacro	22:4d895e732765	1224	char name_str[LOCATION_BUF_LEN + 1];
defmacro	22:4d895e732765	1225	double latitude;
defmacro	22:4d895e732765	1226	double longitude;
defmacro	22:4d895e732765	1227	double elevation;
defmacro	22:4d895e732765	1228	char timestamp_str[LOCATION_BUF_LEN + 1];
defmacro	22:4d895e732765	1229	int index;
defmacro	22:4d895e732765	1230
defmacro	22:4d895e732765	1231	location_read_callback callback;
defmacro	22:4d895e732765	1232	void* context;
defmacro	22:4d895e732765	1233	} location_parsing_context_state;
defmacro	22:4d895e732765	1234
defmacro	22:4d895e732765	1235	#define WAITING_NAME 0x1
defmacro	22:4d895e732765	1236	#define WAITING_LATITUDE 0x2
defmacro	22:4d895e732765	1237	#define WAITING_LONGITUDE 0x4
defmacro	22:4d895e732765	1238	#define WAITING_ELEVATION 0x8
defmacro	22:4d895e732765	1239	#define WAITING_TIMESTAMP 0x10
defmacro	22:4d895e732765	1240
defmacro	22:4d895e732765	1241	#define GOT_NAME 0x20
defmacro	22:4d895e732765	1242	#define GOT_LATITUDE 0x40
defmacro	22:4d895e732765	1243	#define GOT_LONGITUDE 0x80
defmacro	22:4d895e732765	1244	#define GOT_ELEVATION 0x100
defmacro	22:4d895e732765	1245	#define GOT_TIMESTAMP 0x200
defmacro	22:4d895e732765	1246
defmacro	22:4d895e732765	1247	#define GOT_LOCATION (GOT_NAME \| GOT_LATITUDE \| GOT_LONGITUDE \| GOT_ELEVATION \| GOT_TIMESTAMP)
defmacro	22:4d895e732765	1248	#define TEST_GOT_LOCATION(state_) (((state_) & GOT_LOCATION) == GOT_LOCATION)
defmacro	22:4d895e732765	1249
defmacro	22:4d895e732765	1250	#define TEST_IS_NAME(state_) (((state_) & (WAITING_NAME \| GOT_NAME)) == WAITING_NAME)
defmacro	22:4d895e732765	1251	#define TEST_IS_LATITUDE(state_) (((state_) & (WAITING_LATITUDE \| GOT_LATITUDE)) \
defmacro	22:4d895e732765	1252	== WAITING_LATITUDE)
defmacro	22:4d895e732765	1253	#define TEST_IS_LONGITUDE(state_) (((state_) & (WAITING_LONGITUDE \| GOT_LONGITUDE)) \
defmacro	22:4d895e732765	1254	== WAITING_LONGITUDE)
defmacro	22:4d895e732765	1255	#define TEST_IS_ELEVATION(state_) (((state_) & (WAITING_ELEVATION \| GOT_ELEVATION)) \
defmacro	22:4d895e732765	1256	== WAITING_ELEVATION)
defmacro	22:4d895e732765	1257	#define TEST_IS_TIMESTAMP(state_) (((state_) & (WAITING_TIMESTAMP \| GOT_TIMESTAMP)) \
defmacro	22:4d895e732765	1258	== WAITING_TIMESTAMP)
defmacro	22:4d895e732765	1259
defmacro	22:4d895e732765	1260	static void on_location_key_found(jsonlite_callback_context* context,
defmacro	22:4d895e732765	1261	jsonlite_token* token) {
defmacro	22:4d895e732765	1262	location_parsing_context_state* state =
defmacro	22:4d895e732765	1263	(location_parsing_context_state*) context->client_state;
defmacro	22:4d895e732765	1264	if (strncmp((const char*) token->start, "waypoints", 9) == 0) {
defmacro	22:4d895e732765	1265	// only parses those locations in waypoints, skip the outer one
defmacro	22:4d895e732765	1266	state->state = 0;
defmacro	22:4d895e732765	1267	} else if (strncmp((const char*) token->start, "name", 4) == 0) {
defmacro	22:4d895e732765	1268	state->state \|= WAITING_NAME;
defmacro	22:4d895e732765	1269	} else if (strncmp((const char*) token->start, "latitude", 8) == 0) {
defmacro	22:4d895e732765	1270	state->state \|= WAITING_LATITUDE;
defmacro	22:4d895e732765	1271	} else if (strncmp((const char*) token->start, "longitude", 9) == 0) {
defmacro	22:4d895e732765	1272	state->state \|= WAITING_LONGITUDE;
defmacro	22:4d895e732765	1273	} else if (strncmp((const char*) token->start, "elevation", 9) == 0) {
defmacro	22:4d895e732765	1274	state->state \|= WAITING_ELEVATION;
defmacro	22:4d895e732765	1275	} else if (strncmp((const char*) token->start, "timestamp", 9) == 0) {
defmacro	22:4d895e732765	1276	state->state \|= WAITING_TIMESTAMP;
defmacro	22:4d895e732765	1277	}
defmacro	22:4d895e732765	1278	}
defmacro	22:4d895e732765	1279
defmacro	22:4d895e732765	1280	static void on_location_string_found(jsonlite_callback_context* context,
defmacro	22:4d895e732765	1281	jsonlite_token* token) {
defmacro	22:4d895e732765	1282	location_parsing_context_state* state =
defmacro	22:4d895e732765	1283	(location_parsing_context_state*) context->client_state;
defmacro	22:4d895e732765	1284
defmacro	22:4d895e732765	1285	if (TEST_IS_NAME(state->state)) {
defmacro	22:4d895e732765	1286	strncpy(state->name_str, (const char*) token->start,
defmacro	22:4d895e732765	1287	MIN(token->end - token->start, LOCATION_BUF_LEN));
defmacro	22:4d895e732765	1288	state->name_str[MIN(token->end - token->start, LOCATION_BUF_LEN)] = '\0';
defmacro	22:4d895e732765	1289	state->state \|= GOT_NAME;
defmacro	22:4d895e732765	1290	} else if (TEST_IS_LATITUDE(state->state)) {
defmacro	22:4d895e732765	1291	state->latitude = atof((const char*) token->start);
defmacro	22:4d895e732765	1292	state->state \|= GOT_LATITUDE;
defmacro	22:4d895e732765	1293	} else if (TEST_IS_LONGITUDE(state->state)) {
defmacro	22:4d895e732765	1294	state->longitude = atof((const char*) token->start);
defmacro	22:4d895e732765	1295	state->state \|= GOT_LONGITUDE;
defmacro	22:4d895e732765	1296	} else if (TEST_IS_ELEVATION(state->state)) {
defmacro	22:4d895e732765	1297	state->elevation = atof((const char*) token->start);
defmacro	22:4d895e732765	1298	state->state \|= GOT_ELEVATION;
defmacro	22:4d895e732765	1299	} else if (TEST_IS_TIMESTAMP(state->state)) {
defmacro	22:4d895e732765	1300	strncpy(state->timestamp_str, (const char*) token->start,
defmacro	22:4d895e732765	1301	MIN(token->end - token->start, LOCATION_BUF_LEN));
defmacro	22:4d895e732765	1302	state->timestamp_str[MIN(token->end - token->start, LOCATION_BUF_LEN)] = '\0';
defmacro	22:4d895e732765	1303	state->state \|= GOT_TIMESTAMP;
defmacro	22:4d895e732765	1304	}
defmacro	22:4d895e732765	1305
defmacro	22:4d895e732765	1306	if (TEST_GOT_LOCATION(state->state)) {
defmacro	22:4d895e732765	1307	state->callback(state->name_str, state->latitude, state->longitude,
defmacro	22:4d895e732765	1308	state->elevation, state->timestamp_str, state->index++,
defmacro	22:4d895e732765	1309	state->context);
defmacro	22:4d895e732765	1310	state->state = 0;
defmacro	22:4d895e732765	1311	}
defmacro	22:4d895e732765	1312	}
defmacro	22:4d895e732765	1313
defmacro	22:4d895e732765	1314	#ifndef M2X_COMMAND_BUF_LEN
defmacro	22:4d895e732765	1315	#define M2X_COMMAND_BUF_LEN 40
defmacro	22:4d895e732765	1316	#endif /* M2X_COMMAND_BUF_LEN */
defmacro	22:4d895e732765	1317
defmacro	22:4d895e732765	1318	typedef struct {
defmacro	22:4d895e732765	1319	uint8_t state;
defmacro	22:4d895e732765	1320	char id_str[M2X_COMMAND_BUF_LEN + 1];
defmacro	22:4d895e732765	1321	char name_str[M2X_COMMAND_BUF_LEN + 1];
defmacro	22:4d895e732765	1322	int index;
defmacro	22:4d895e732765	1323
defmacro	22:4d895e732765	1324	m2x_command_read_callback callback;
defmacro	22:4d895e732765	1325	void* context;
defmacro	22:4d895e732765	1326	} m2x_command_parsing_context_state;
defmacro	22:4d895e732765	1327
defmacro	22:4d895e732765	1328	#define M2X_COMMAND_WAITING_ID 0x1
defmacro	22:4d895e732765	1329	#define M2X_COMMAND_GOT_ID 0x2
defmacro	22:4d895e732765	1330	#define M2X_COMMAND_WAITING_NAME 0x4
defmacro	22:4d895e732765	1331	#define M2X_COMMAND_GOT_NAME 0x8
defmacro	22:4d895e732765	1332
defmacro	22:4d895e732765	1333	#define M2X_COMMAND_GOT_COMMAND (M2X_COMMAND_GOT_ID \| M2X_COMMAND_GOT_NAME)
defmacro	22:4d895e732765	1334	#define M2X_COMMAND_TEST_GOT_COMMAND(state_) \
defmacro	22:4d895e732765	1335	(((state_) & M2X_COMMAND_GOT_COMMAND) == M2X_COMMAND_GOT_COMMAND)
defmacro	22:4d895e732765	1336
defmacro	22:4d895e732765	1337	#define M2X_COMMAND_TEST_IS_ID(state_) \
defmacro	22:4d895e732765	1338	(((state_) & (M2X_COMMAND_WAITING_ID \| M2X_COMMAND_GOT_ID)) == \
defmacro	22:4d895e732765	1339	M2X_COMMAND_WAITING_ID)
defmacro	22:4d895e732765	1340	#define M2X_COMMAND_TEST_IS_NAME(state_) \
defmacro	22:4d895e732765	1341	(((state_) & (M2X_COMMAND_WAITING_NAME \| M2X_COMMAND_GOT_NAME)) == \
defmacro	22:4d895e732765	1342	M2X_COMMAND_WAITING_NAME)
defmacro	22:4d895e732765	1343
defmacro	22:4d895e732765	1344	static void m2x_on_command_key_found(jsonlite_callback_context* context,
defmacro	22:4d895e732765	1345	jsonlite_token* token)
defmacro	22:4d895e732765	1346	{
defmacro	22:4d895e732765	1347	m2x_command_parsing_context_state* state =
defmacro	22:4d895e732765	1348	(m2x_command_parsing_context_state*) context->client_state;
defmacro	22:4d895e732765	1349	if (strncmp((const char*) token->start, "id", 2) == 0) {
defmacro	22:4d895e732765	1350	state->state \|= M2X_COMMAND_WAITING_ID;
defmacro	22:4d895e732765	1351	} else if (strncmp((const char*) token->start, "name", 4) == 0) {
defmacro	22:4d895e732765	1352	state->state \|= M2X_COMMAND_WAITING_NAME;
defmacro	22:4d895e732765	1353	}
defmacro	22:4d895e732765	1354	}
defmacro	22:4d895e732765	1355
defmacro	22:4d895e732765	1356	static void m2x_on_command_value_found(jsonlite_callback_context* context,
defmacro	22:4d895e732765	1357	jsonlite_token* token)
defmacro	22:4d895e732765	1358	{
defmacro	22:4d895e732765	1359	m2x_command_parsing_context_state* state =
defmacro	22:4d895e732765	1360	(m2x_command_parsing_context_state*) context->client_state;
defmacro	22:4d895e732765	1361	if (M2X_COMMAND_TEST_IS_ID(state->state)) {
defmacro	22:4d895e732765	1362	strncpy(state->id_str, (const char*) token->start,
defmacro	22:4d895e732765	1363	MIN(token->end - token->start, M2X_COMMAND_BUF_LEN));
defmacro	22:4d895e732765	1364	state->id_str[MIN(token->end - token->start, M2X_COMMAND_BUF_LEN)] = '\0';
defmacro	22:4d895e732765	1365	state->state \|= M2X_COMMAND_GOT_ID;
defmacro	22:4d895e732765	1366	} else if (M2X_COMMAND_TEST_IS_NAME(state->state)) {
defmacro	22:4d895e732765	1367	strncpy(state->name_str, (const char*) token->start,
defmacro	22:4d895e732765	1368	MIN(token->end - token->start, M2X_COMMAND_BUF_LEN));
defmacro	22:4d895e732765	1369	state->name_str[MIN(token->end - token->start, M2X_COMMAND_BUF_LEN)] = '\0';
defmacro	22:4d895e732765	1370	state->state \|= M2X_COMMAND_GOT_NAME;
defmacro	22:4d895e732765	1371	}
defmacro	22:4d895e732765	1372
defmacro	22:4d895e732765	1373	if (M2X_COMMAND_TEST_GOT_COMMAND(state->state)) {
defmacro	22:4d895e732765	1374	state->callback(state->id_str, state->name_str,
defmacro	22:4d895e732765	1375	state->index++, state->context);
defmacro	22:4d895e732765	1376	state->state = 0;
defmacro	22:4d895e732765	1377	}
defmacro	22:4d895e732765	1378	}
defmacro	22:4d895e732765	1379
defmacro	22:4d895e732765	1380	int M2XStreamClient::listStreamValues(const char* deviceId, const char* streamName,
defmacro	22:4d895e732765	1381	stream_value_read_callback callback, void* context,
defmacro	22:4d895e732765	1382	const char* query) {
defmacro	22:4d895e732765	1383	if (_client->connect(_host, _port)) {
defmacro	22:4d895e732765	1384	DBGLN("%s", "Connected to M2X server!");
defmacro	22:4d895e732765	1385	_client->print("GET ");
defmacro	22:4d895e732765	1386	if (_path_prefix) { _client->print(_path_prefix); }
defmacro	22:4d895e732765	1387	_client->print("/v2/devices/");
defmacro	22:4d895e732765	1388	_client->print(deviceId);
defmacro	22:4d895e732765	1389	_client->print("/streams/");
defmacro	22:4d895e732765	1390	print_encoded_string(_client, streamName);
defmacro	22:4d895e732765	1391	_client->print("/values");
defmacro	22:4d895e732765	1392
defmacro	22:4d895e732765	1393	if (query) {
defmacro	22:4d895e732765	1394	if (query[0] != '?') {
defmacro	22:4d895e732765	1395	_client->print('?');
defmacro	22:4d895e732765	1396	}
defmacro	22:4d895e732765	1397	_client->print(query);
defmacro	22:4d895e732765	1398	}
defmacro	22:4d895e732765	1399
JMF	25:67079c11d1ea	1400	_client->println(" HTTP/1.1");
defmacro	22:4d895e732765	1401	writeHttpHeader(-1);
defmacro	22:4d895e732765	1402	} else {
defmacro	22:4d895e732765	1403	DBGLN("%s", "ERROR: Cannot connect to M2X server!");
defmacro	22:4d895e732765	1404	return E_NOCONNECTION;
defmacro	22:4d895e732765	1405	}
defmacro	22:4d895e732765	1406	int status = readStatusCode(false);
defmacro	22:4d895e732765	1407	if (status == 200) {
defmacro	22:4d895e732765	1408	readStreamValue(callback, context);
defmacro	22:4d895e732765	1409	}
defmacro	22:4d895e732765	1410
defmacro	22:4d895e732765	1411	close();
defmacro	22:4d895e732765	1412	return status;
defmacro	22:4d895e732765	1413	}
defmacro	22:4d895e732765	1414
defmacro	22:4d895e732765	1415	int M2XStreamClient::readLocation(const char* deviceId,
defmacro	22:4d895e732765	1416	location_read_callback callback,
defmacro	22:4d895e732765	1417	void* context) {
defmacro	22:4d895e732765	1418	if (_client->connect(_host, _port)) {
defmacro	22:4d895e732765	1419	DBGLN("%s", "Connected to M2X server!");
defmacro	22:4d895e732765	1420	_client->print("GET ");
defmacro	22:4d895e732765	1421	if (_path_prefix) { _client->print(_path_prefix); }
defmacro	22:4d895e732765	1422	_client->print("/v2/devices/");
defmacro	22:4d895e732765	1423	_client->print(deviceId);
JMF	25:67079c11d1ea	1424	_client->println("/location HTTP/1.1");
defmacro	22:4d895e732765	1425
defmacro	22:4d895e732765	1426	writeHttpHeader(-1);
defmacro	22:4d895e732765	1427	} else {
defmacro	22:4d895e732765	1428	DBGLN("%s", "ERROR: Cannot connect to M2X server!");
defmacro	22:4d895e732765	1429	return E_NOCONNECTION;
defmacro	22:4d895e732765	1430	}
defmacro	22:4d895e732765	1431	int status = readStatusCode(false);
defmacro	22:4d895e732765	1432	if (status == 200) {
defmacro	22:4d895e732765	1433	readLocation(callback, context);
defmacro	22:4d895e732765	1434	}
defmacro	22:4d895e732765	1435
defmacro	22:4d895e732765	1436	close();
defmacro	22:4d895e732765	1437	return status;
defmacro	22:4d895e732765	1438	}
defmacro	22:4d895e732765	1439
JMF	23:f32837239193	1440	int M2XStreamClient::deleteLocations(const char* deviceId,
JMF	23:f32837239193	1441	const char* from, const char* end) {
JMF	23:f32837239193	1442	if (_client->connect(_host, _port)) {
JMF	23:f32837239193	1443	DBGLN("%s", "Connected to M2X server!");
JMF	23:f32837239193	1444	int length = write_delete_values(&_null_print, from, end);
JMF	23:f32837239193	1445	writeDeleteLocationHeader(deviceId, length);
JMF	23:f32837239193	1446	write_delete_values(_client, from, end);
JMF	23:f32837239193	1447	} else {
JMF	23:f32837239193	1448	DBGLN("%s", "ERROR: Cannot connect to M2X server!");
JMF	23:f32837239193	1449	return E_NOCONNECTION;
JMF	23:f32837239193	1450	}
JMF	23:f32837239193	1451
JMF	23:f32837239193	1452	return readStatusCode(true);
JMF	23:f32837239193	1453	}
JMF	23:f32837239193	1454
defmacro	22:4d895e732765	1455	int M2XStreamClient::listCommands(const char* deviceId,
defmacro	22:4d895e732765	1456	m2x_command_read_callback callback,
defmacro	22:4d895e732765	1457	void* context,
defmacro	22:4d895e732765	1458	const char* query) {
defmacro	22:4d895e732765	1459	if (_client->connect(_host, _port)) {
defmacro	22:4d895e732765	1460	DBGLN("%s", "Connected to M2X server!");
defmacro	22:4d895e732765	1461	_client->print("GET ");
defmacro	22:4d895e732765	1462	if (_path_prefix) { _client->print(_path_prefix); }
defmacro	22:4d895e732765	1463	_client->print("/v2/devices/");
defmacro	22:4d895e732765	1464	_client->print(deviceId);
defmacro	22:4d895e732765	1465	_client->print("/commands");
defmacro	22:4d895e732765	1466
defmacro	22:4d895e732765	1467	if (query) {
defmacro	22:4d895e732765	1468	if (query[0] != '?') {
defmacro	22:4d895e732765	1469	_client->print('?');
defmacro	22:4d895e732765	1470	}
defmacro	22:4d895e732765	1471	_client->print(query);
defmacro	22:4d895e732765	1472	}
defmacro	22:4d895e732765	1473
JMF	25:67079c11d1ea	1474	_client->println(" HTTP/1.1");
defmacro	22:4d895e732765	1475	writeHttpHeader(-1);
defmacro	22:4d895e732765	1476	} else {
defmacro	22:4d895e732765	1477	DBGLN("%s", "ERROR: Cannot connect to M2X server!");
defmacro	22:4d895e732765	1478	return E_NOCONNECTION;
defmacro	22:4d895e732765	1479	}
defmacro	22:4d895e732765	1480	int status = readStatusCode(false);
defmacro	22:4d895e732765	1481	if (status == 200) {
defmacro	22:4d895e732765	1482	readCommand(callback, context);
defmacro	22:4d895e732765	1483	}
defmacro	22:4d895e732765	1484
defmacro	22:4d895e732765	1485	close();
defmacro	22:4d895e732765	1486	return status;
defmacro	22:4d895e732765	1487	}
defmacro	22:4d895e732765	1488
defmacro	22:4d895e732765	1489
defmacro	22:4d895e732765	1490	int M2XStreamClient::readStreamValue(stream_value_read_callback callback,
defmacro	22:4d895e732765	1491	void* context) {
defmacro	22:4d895e732765	1492	const int BUF_LEN = 64;
defmacro	22:4d895e732765	1493	char buf[BUF_LEN];
defmacro	22:4d895e732765	1494
defmacro	22:4d895e732765	1495	int length = readContentLength();
defmacro	22:4d895e732765	1496	if (length < 0) {
defmacro	22:4d895e732765	1497	close();
defmacro	22:4d895e732765	1498	return length;
defmacro	22:4d895e732765	1499	}
defmacro	22:4d895e732765	1500
defmacro	22:4d895e732765	1501	int index = skipHttpHeader();
defmacro	22:4d895e732765	1502	if (index != E_OK) {
defmacro	22:4d895e732765	1503	close();
defmacro	22:4d895e732765	1504	return index;
defmacro	22:4d895e732765	1505	}
defmacro	22:4d895e732765	1506	index = 0;
defmacro	22:4d895e732765	1507
defmacro	22:4d895e732765	1508	stream_parsing_context_state state;
defmacro	22:4d895e732765	1509	state.state = state.index = 0;
defmacro	22:4d895e732765	1510	state.callback = callback;
defmacro	22:4d895e732765	1511	state.context = context;
defmacro	22:4d895e732765	1512
defmacro	22:4d895e732765	1513	jsonlite_parser_callbacks cbs = jsonlite_default_callbacks;
defmacro	22:4d895e732765	1514	cbs.key_found = on_stream_key_found;
defmacro	22:4d895e732765	1515	cbs.number_found = on_stream_number_found;
defmacro	22:4d895e732765	1516	cbs.string_found = on_stream_string_found;
defmacro	22:4d895e732765	1517	cbs.context.client_state = &state;
defmacro	22:4d895e732765	1518
defmacro	22:4d895e732765	1519	jsonlite_parser p = jsonlite_parser_init(jsonlite_parser_estimate_size(5));
defmacro	22:4d895e732765	1520	jsonlite_parser_set_callback(p, &cbs);
defmacro	22:4d895e732765	1521
defmacro	22:4d895e732765	1522	jsonlite_result result = jsonlite_result_unknown;
defmacro	22:4d895e732765	1523	while (index < length) {
defmacro	22:4d895e732765	1524	int i = 0;
defmacro	22:4d895e732765	1525
defmacro	22:4d895e732765	1526	DBG("%s", "Received Data: ");
defmacro	22:4d895e732765	1527	while ((i < BUF_LEN) && _client->available()) {
defmacro	22:4d895e732765	1528	buf[i++] = _client->read();
defmacro	22:4d895e732765	1529	DBG("%c", buf[i - 1]);
defmacro	22:4d895e732765	1530	}
defmacro	22:4d895e732765	1531	DBGLNEND;
defmacro	22:4d895e732765	1532
defmacro	22:4d895e732765	1533	if ((!_client->connected()) &&
defmacro	22:4d895e732765	1534	(!_client->available()) &&
defmacro	22:4d895e732765	1535	((index + i) < length)) {
defmacro	22:4d895e732765	1536	jsonlite_parser_release(p);
defmacro	22:4d895e732765	1537	close();
defmacro	22:4d895e732765	1538	return E_NOCONNECTION;
defmacro	22:4d895e732765	1539	}
defmacro	22:4d895e732765	1540
defmacro	22:4d895e732765	1541	result = jsonlite_parser_tokenize(p, buf, i);
defmacro	22:4d895e732765	1542	if ((result != jsonlite_result_ok) &&
defmacro	22:4d895e732765	1543	(result != jsonlite_result_end_of_stream)) {
defmacro	22:4d895e732765	1544	jsonlite_parser_release(p);
defmacro	22:4d895e732765	1545	close();
defmacro	22:4d895e732765	1546	return E_JSON_INVALID;
defmacro	22:4d895e732765	1547	}
defmacro	22:4d895e732765	1548
defmacro	22:4d895e732765	1549	index += i;
defmacro	22:4d895e732765	1550	}
defmacro	22:4d895e732765	1551
defmacro	22:4d895e732765	1552	jsonlite_parser_release(p);
defmacro	22:4d895e732765	1553	close();
defmacro	22:4d895e732765	1554	return (result == jsonlite_result_ok) ? (E_OK) : (E_JSON_INVALID);
defmacro	22:4d895e732765	1555	}
defmacro	22:4d895e732765	1556
defmacro	22:4d895e732765	1557	int M2XStreamClient::readLocation(location_read_callback callback,
defmacro	22:4d895e732765	1558	void* context) {
defmacro	22:4d895e732765	1559	const int BUF_LEN = 40;
defmacro	22:4d895e732765	1560	char buf[BUF_LEN];
defmacro	22:4d895e732765	1561
defmacro	22:4d895e732765	1562	int length = readContentLength();
defmacro	22:4d895e732765	1563	if (length < 0) {
defmacro	22:4d895e732765	1564	close();
defmacro	22:4d895e732765	1565	return length;
defmacro	22:4d895e732765	1566	}
defmacro	22:4d895e732765	1567
defmacro	22:4d895e732765	1568	int index = skipHttpHeader();
defmacro	22:4d895e732765	1569	if (index != E_OK) {
defmacro	22:4d895e732765	1570	close();
defmacro	22:4d895e732765	1571	return index;
defmacro	22:4d895e732765	1572	}
defmacro	22:4d895e732765	1573	index = 0;
defmacro	22:4d895e732765	1574
defmacro	22:4d895e732765	1575	location_parsing_context_state state;
defmacro	22:4d895e732765	1576	state.state = state.index = 0;
defmacro	22:4d895e732765	1577	state.callback = callback;
defmacro	22:4d895e732765	1578	state.context = context;
defmacro	22:4d895e732765	1579
defmacro	22:4d895e732765	1580	jsonlite_parser_callbacks cbs = jsonlite_default_callbacks;
defmacro	22:4d895e732765	1581	cbs.key_found = on_location_key_found;
defmacro	22:4d895e732765	1582	cbs.string_found = on_location_string_found;
defmacro	22:4d895e732765	1583	cbs.context.client_state = &state;
defmacro	22:4d895e732765	1584
defmacro	22:4d895e732765	1585	jsonlite_parser p = jsonlite_parser_init(jsonlite_parser_estimate_size(5));
defmacro	22:4d895e732765	1586	jsonlite_parser_set_callback(p, &cbs);
defmacro	22:4d895e732765	1587
defmacro	22:4d895e732765	1588	jsonlite_result result = jsonlite_result_unknown;
defmacro	22:4d895e732765	1589	while (index < length) {
defmacro	22:4d895e732765	1590	int i = 0;
defmacro	22:4d895e732765	1591
defmacro	22:4d895e732765	1592	DBG("%s", "Received Data: ");
defmacro	22:4d895e732765	1593	while ((i < BUF_LEN) && _client->available()) {
defmacro	22:4d895e732765	1594	buf[i++] = _client->read();
defmacro	22:4d895e732765	1595	DBG("%c", buf[i - 1]);
defmacro	22:4d895e732765	1596	}
defmacro	22:4d895e732765	1597	DBGLNEND;
defmacro	22:4d895e732765	1598
defmacro	22:4d895e732765	1599	if ((!_client->connected()) &&
defmacro	22:4d895e732765	1600	(!_client->available()) &&
defmacro	22:4d895e732765	1601	((index + i) < length)) {
defmacro	22:4d895e732765	1602	jsonlite_parser_release(p);
defmacro	22:4d895e732765	1603	close();
defmacro	22:4d895e732765	1604	return E_NOCONNECTION;
defmacro	22:4d895e732765	1605	}
defmacro	22:4d895e732765	1606
defmacro	22:4d895e732765	1607	result = jsonlite_parser_tokenize(p, buf, i);
defmacro	22:4d895e732765	1608	if ((result != jsonlite_result_ok) &&
defmacro	22:4d895e732765	1609	(result != jsonlite_result_end_of_stream)) {
defmacro	22:4d895e732765	1610	jsonlite_parser_release(p);
defmacro	22:4d895e732765	1611	close();
defmacro	22:4d895e732765	1612	return E_JSON_INVALID;
defmacro	22:4d895e732765	1613	}
defmacro	22:4d895e732765	1614
defmacro	22:4d895e732765	1615	index += i;
defmacro	22:4d895e732765	1616	}
defmacro	22:4d895e732765	1617
defmacro	22:4d895e732765	1618	jsonlite_parser_release(p);
defmacro	22:4d895e732765	1619	close();
defmacro	22:4d895e732765	1620	return (result == jsonlite_result_ok) ? (E_OK) : (E_JSON_INVALID);
defmacro	22:4d895e732765	1621	}
defmacro	22:4d895e732765	1622
defmacro	22:4d895e732765	1623	int M2XStreamClient::readCommand(m2x_command_read_callback callback,
defmacro	22:4d895e732765	1624	void* context) {
defmacro	22:4d895e732765	1625	const int BUF_LEN = 60;
defmacro	22:4d895e732765	1626	char buf[BUF_LEN];
defmacro	22:4d895e732765	1627
defmacro	22:4d895e732765	1628	int length = readContentLength();
defmacro	22:4d895e732765	1629	if (length < 0) {
defmacro	22:4d895e732765	1630	close();
defmacro	22:4d895e732765	1631	return length;
defmacro	22:4d895e732765	1632	}
defmacro	22:4d895e732765	1633
defmacro	22:4d895e732765	1634	int index = skipHttpHeader();
defmacro	22:4d895e732765	1635	if (index != E_OK) {
defmacro	22:4d895e732765	1636	close();
defmacro	22:4d895e732765	1637	return index;
defmacro	22:4d895e732765	1638	}
defmacro	22:4d895e732765	1639	index = 0;
defmacro	22:4d895e732765	1640
defmacro	22:4d895e732765	1641	m2x_command_parsing_context_state state;
defmacro	22:4d895e732765	1642	state.state = 0;
defmacro	22:4d895e732765	1643	state.index = 0;
defmacro	22:4d895e732765	1644	state.callback = callback;
defmacro	22:4d895e732765	1645	state.context = context;
defmacro	22:4d895e732765	1646
defmacro	22:4d895e732765	1647	jsonlite_parser_callbacks cbs = jsonlite_default_callbacks;
defmacro	22:4d895e732765	1648	cbs.key_found = m2x_on_command_key_found;
defmacro	22:4d895e732765	1649	cbs.string_found = m2x_on_command_value_found;
defmacro	22:4d895e732765	1650	cbs.context.client_state = &state;
defmacro	22:4d895e732765	1651
defmacro	22:4d895e732765	1652	jsonlite_parser p = jsonlite_parser_init(jsonlite_parser_estimate_size(5));
defmacro	22:4d895e732765	1653	jsonlite_parser_set_callback(p, &cbs);
defmacro	22:4d895e732765	1654
defmacro	22:4d895e732765	1655	jsonlite_result result = jsonlite_result_unknown;
defmacro	22:4d895e732765	1656	while (index < length) {
defmacro	22:4d895e732765	1657	int i = 0;
defmacro	22:4d895e732765	1658
defmacro	22:4d895e732765	1659	DBG("%s", "Received Data: ");
defmacro	22:4d895e732765	1660	while ((i < BUF_LEN) && _client->available()) {
defmacro	22:4d895e732765	1661	buf[i++] = _client->read();
defmacro	22:4d895e732765	1662	DBG("%c", buf[i - 1]);
defmacro	22:4d895e732765	1663	}
defmacro	22:4d895e732765	1664	DBGLNEND;
defmacro	22:4d895e732765	1665
defmacro	22:4d895e732765	1666	if ((!_client->connected()) &&
defmacro	22:4d895e732765	1667	(!_client->available()) &&
defmacro	22:4d895e732765	1668	((index + i) < length)) {
defmacro	22:4d895e732765	1669	jsonlite_parser_release(p);
defmacro	22:4d895e732765	1670	close();
defmacro	22:4d895e732765	1671	return E_NOCONNECTION;
defmacro	22:4d895e732765	1672	}
defmacro	22:4d895e732765	1673
defmacro	22:4d895e732765	1674	result = jsonlite_parser_tokenize(p, buf, i);
defmacro	22:4d895e732765	1675	if ((result != jsonlite_result_ok) &&
defmacro	22:4d895e732765	1676	(result != jsonlite_result_end_of_stream)) {
defmacro	22:4d895e732765	1677	jsonlite_parser_release(p);
defmacro	22:4d895e732765	1678	close();
defmacro	22:4d895e732765	1679	return E_JSON_INVALID;
defmacro	22:4d895e732765	1680	}
defmacro	22:4d895e732765	1681
defmacro	22:4d895e732765	1682	index += i;
defmacro	22:4d895e732765	1683	}
defmacro	22:4d895e732765	1684
defmacro	22:4d895e732765	1685	jsonlite_parser_release(p);
defmacro	22:4d895e732765	1686	close();
defmacro	22:4d895e732765	1687	return (result == jsonlite_result_ok) ? (E_OK) : (E_JSON_INVALID);
defmacro	22:4d895e732765	1688	}
defmacro	22:4d895e732765	1689
defmacro	22:4d895e732765	1690	#endif /* M2X_ENABLE_READER */
jb8414	0:f479e4f4db0e	1691
jb8414	0:f479e4f4db0e	1692	#endif /* M2XStreamClient_h */

Repository toolbox

Export to desktop IDE

Repository details

Type:	Library
Created:	11 Sep 2016
Imports:	16
Forks:	1
Commits:	26
Dependents:	4
Dependencies:	0
Followers:	1

The code in this repository is Apache licensed.

M2XStreamClient.h@25:67079c11d1ea, 2016-09-18 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Important Information for this Arm website

Access Warning