Andy A / plotly

plotly interface based on ardunio sample code

Dependents:   Plotly_HelloWorld

Library for plotting a simple x/y scatter chart on the plot.ly website.

See plotly_HelloWorld for sample usage.

plotly.cpp@3:967be3d46701, 2014-07-11 (annotated)

Committer:
AndyA
Date:
Fri Jul 11 08:08:06 2014 +0000
Revision:
3:967be3d46701
Parent:
2:d53d74ed68ac
Child:
4:33006c37c633
Child:
6:e57d6e9313f4
Update to match current API documentation

Who changed what in which revision?

UserRevisionLine numberNew contents of line
AndyA 0:96532c59670f 1 #include "plotly.h"
AndyA 0:96532c59670f 2 #include "mbed.h"
AndyA 0:96532c59670f 3
AndyA 3:967be3d46701 4 #define plotlyURL "plot.ly"
AndyA 0:96532c59670f 5 #define dataURL "arduino.plot.ly"
AndyA 0:96532c59670f 6
AndyA 0:96532c59670f 7 plotly::plotly(char *username, char *api_key, char* stream_tokens[], char *filename, int nTraces)
AndyA 0:96532c59670f 8 {
AndyA 0:96532c59670f 9 log_level = 0; // 0 = Debugging, 1 = Informational, 2 = Status, 3 = Errors, 4 = Quiet (// Serial Off)
AndyA 0:96532c59670f 10 dry_run = false;
AndyA 0:96532c59670f 11 username_ = username;
AndyA 0:96532c59670f 12 api_key_ = api_key;
AndyA 0:96532c59670f 13 stream_tokens_ = stream_tokens;
AndyA 0:96532c59670f 14 filename_ = filename;
AndyA 0:96532c59670f 15 nTraces_ = nTraces;
AndyA 0:96532c59670f 16 maxpoints = 30;
AndyA 0:96532c59670f 17 fibonacci_ = 1;
AndyA 0:96532c59670f 18 world_readable = true;
AndyA 0:96532c59670f 19 convertTimestamp = true;
AndyA 0:96532c59670f 20 timezone = "America/Montreal";
AndyA 0:96532c59670f 21 fileopt = "overwrite";
AndyA 1:d532e96fca12 22
AndyA 2:d53d74ed68ac 23 socket = NULL;
AndyA 1:d532e96fca12 24 initalised = false;
AndyA 0:96532c59670f 25 }
AndyA 0:96532c59670f 26
AndyA 0:96532c59670f 27
AndyA 1:d532e96fca12 28 plotly::~plotly()
AndyA 1:d532e96fca12 29 {
AndyA 1:d532e96fca12 30 closeStream();
AndyA 1:d532e96fca12 31 }
AndyA 0:96532c59670f 32
AndyA 0:96532c59670f 33 bool plotly::init()
AndyA 0:96532c59670f 34 {
AndyA 0:96532c59670f 35
AndyA 0:96532c59670f 36 //
AndyA 0:96532c59670f 37 // Validate a stream with a REST post to plotly
AndyA 0:96532c59670f 38 //
AndyA 0:96532c59670f 39 if(dry_run && log_level < 3) {
AndyA 0:96532c59670f 40 fprintf(stderr,"... This is a dry run, we are not connecting to plotly's servers...\n");
AndyA 0:96532c59670f 41 } else if(log_level < 3) {
AndyA 0:96532c59670f 42 fprintf(stderr,"... Attempting to connect to plotly's REST servers\n");
AndyA 0:96532c59670f 43 }
AndyA 0:96532c59670f 44
AndyA 2:d53d74ed68ac 45 // socket.set_blocking(false);
AndyA 1:d532e96fca12 46
AndyA 2:d53d74ed68ac 47 if (!dry_run) {
AndyA 2:d53d74ed68ac 48 socket = new TCPSocketConnection();
AndyA 2:d53d74ed68ac 49 while (socket->connect(plotlyURL, 80) < 0) {
AndyA 0:96532c59670f 50 fprintf(stderr,"... Couldn\'t connect to plotly's REST servers... trying again!\n");
AndyA 2:d53d74ed68ac 51 wait(1);
AndyA 0:96532c59670f 52 }
AndyA 2:d53d74ed68ac 53 }
AndyA 1:d532e96fca12 54
AndyA 1:d532e96fca12 55 if(log_level < 3) fprintf(stderr,"... Connected to plotly's REST servers\n");
AndyA 2:d53d74ed68ac 56
AndyA 1:d532e96fca12 57 if(log_level < 3) fprintf(stderr,"... Sending HTTP Post to plotly\n");
AndyA 2:d53d74ed68ac 58
AndyA 0:96532c59670f 59 print_("POST /clientresp HTTP/1.1\r\n");
AndyA 0:96532c59670f 60 print_("Host: 107.21.214.199\r\n");
AndyA 3:967be3d46701 61 print_("User-Agent: Arduino/0.5.1\r\n");
AndyA 2:d53d74ed68ac 62 print_("plotly-streamtoken: ");
AndyA 2:d53d74ed68ac 63 print_(stream_tokens_[0]);
AndyA 2:d53d74ed68ac 64 print_("\r\n");
AndyA 0:96532c59670f 65
AndyA 0:96532c59670f 66 print_("Content-Length: ");
AndyA 0:96532c59670f 67 int contentLength = 126 + len_(username_) + len_(fileopt) + nTraces_*(87+len_(maxpoints)) + (nTraces_-1)*2 + len_(filename_);
AndyA 0:96532c59670f 68 if(world_readable) {
AndyA 0:96532c59670f 69 contentLength += 4;
AndyA 0:96532c59670f 70 } else {
AndyA 0:96532c59670f 71 contentLength += 5;
AndyA 0:96532c59670f 72 }
AndyA 0:96532c59670f 73 // contentLength =
AndyA 0:96532c59670f 74 // 44 // first part of querystring below
AndyA 0:96532c59670f 75 // + len_(username) // upper bound on username length
AndyA 0:96532c59670f 76 // + 5 // &key=
AndyA 0:96532c59670f 77 // + 10 // api_key length
AndyA 0:96532c59670f 78 // + 7 // &args=[...
AndyA 0:96532c59670f 79 // + nTraces*(87+len(maxpoints)) // len({\"y\": [], \"x\": [], \"type\": \"scatter\", \"stream\": {\"token\": \") + 10 + len(\", "maxpoints": )+len(maxpoints)+len(}})
AndyA 0:96532c59670f 80 // + (nTraces-1)*2 // ", " in between trace objects
AndyA 0:96532c59670f 81 // + 22 // ]&kwargs={\"fileopt\": \"
AndyA 0:96532c59670f 82 // + len_(fileopt)
AndyA 0:96532c59670f 83 // + 16 // \", \"filename\": \"
AndyA 0:96532c59670f 84 // + len_(filename)
AndyA 0:96532c59670f 85 // + 21 // ", "world_readable":
AndyA 0:96532c59670f 86 // + 4 if world_readable, 5 otherwise
AndyA 0:96532c59670f 87 // + 1 // closing }
AndyA 0:96532c59670f 88 //------
AndyA 0:96532c59670f 89 // 126 + len_(username) + len_(fileopt) + nTraces*(86+len(maxpoints)) + (nTraces-1)*2 + len_(filename)
AndyA 0:96532c59670f 90 //
AndyA 0:96532c59670f 91 // Terminate headers with new lines
AndyA 2:d53d74ed68ac 92
AndyA 2:d53d74ed68ac 93
AndyA 2:d53d74ed68ac 94 // big buffer method to generate the string so that length can be measured directly.
AndyA 2:d53d74ed68ac 95
AndyA 2:d53d74ed68ac 96
AndyA 2:d53d74ed68ac 97 // fprintf(stderr,"AutoVersion:\n");
AndyA 3:967be3d46701 98 int lineLen = snprintf(buffer,k_bufferSize,"version=2.3&origin=plot&platform=arduino&un=%s&key=%s&args=[",username_,api_key_);
AndyA 2:d53d74ed68ac 99 for(int i=0; i<nTraces_; i++) {
AndyA 2:d53d74ed68ac 100 lineLen += snprintf((buffer+lineLen),k_bufferSize-lineLen,"{\"y\": [], \"x\": [], \"type\": \"scatter\", \"stream\": {\"token\": \"%s\", \"maxpoints\": %d}}%s",stream_tokens_[i],maxpoints,((nTraces_ > 1) && (i != nTraces_-1))?", ":"");
AndyA 2:d53d74ed68ac 101 }
AndyA 2:d53d74ed68ac 102 lineLen += snprintf((buffer+lineLen),k_bufferSize-lineLen,"]&kwargs={\"fileopt\": \"%s\", \"filename\": \"%s\", \"world_readable\": %s}",fileopt,filename_,world_readable?"true":"false");
AndyA 2:d53d74ed68ac 103
AndyA 2:d53d74ed68ac 104 // fprintf(stderr,buffer);
AndyA 2:d53d74ed68ac 105 // fprintf(stderr,"\nLen = %d",lineLen);
AndyA 2:d53d74ed68ac 106
AndyA 2:d53d74ed68ac 107 print_(lineLen);
AndyA 0:96532c59670f 108 print_("\r\n\r\n");
AndyA 2:d53d74ed68ac 109
AndyA 3:967be3d46701 110 lineLen = snprintf(buffer,k_bufferSize,"version=2.3&origin=plot&platform=arduino&un=%s&key=%s&args=[",username_,api_key_);
AndyA 2:d53d74ed68ac 111 for(int i=0; i<nTraces_; i++) {
AndyA 2:d53d74ed68ac 112 lineLen += snprintf((buffer+lineLen),k_bufferSize-lineLen,"{\"y\": [], \"x\": [], \"type\": \"scatter\", \"stream\": {\"token\": \"%s\", \"maxpoints\": %d}}%s",stream_tokens_[i],maxpoints,((nTraces_ > 1) && (i != nTraces_-1))?", ":"");
AndyA 2:d53d74ed68ac 113 }
AndyA 2:d53d74ed68ac 114 lineLen += snprintf((buffer+lineLen),k_bufferSize-lineLen,"]&kwargs={\"fileopt\": \"%s\", \"filename\": \"%s\", \"world_readable\": %s}",fileopt,filename_,world_readable?"true":"false");
AndyA 2:d53d74ed68ac 115 sendFormatedText(buffer,lineLen);
AndyA 2:d53d74ed68ac 116
AndyA 2:d53d74ed68ac 117 print_("\r\n");
AndyA 2:d53d74ed68ac 118 /*
AndyA 0:96532c59670f 119 // Start printing querystring body
AndyA 0:96532c59670f 120 print_("version=2.2&origin=plot&platform=arduino&un=");
AndyA 0:96532c59670f 121 print_(username_);
AndyA 0:96532c59670f 122 print_("&key=");
AndyA 0:96532c59670f 123 print_(api_key_);
AndyA 0:96532c59670f 124 print_("&args=[");
AndyA 0:96532c59670f 125 // print a trace for each token supplied
AndyA 0:96532c59670f 126 for(int i=0; i<nTraces_; i++) {
AndyA 0:96532c59670f 127 print_("{\"y\": [], \"x\": [], \"type\": \"scatter\", \"stream\": {\"token\": \"");
AndyA 0:96532c59670f 128 print_(stream_tokens_[i]);
AndyA 0:96532c59670f 129 print_("\", \"maxpoints\": ");
AndyA 0:96532c59670f 130 print_(maxpoints);
AndyA 0:96532c59670f 131 print_("}}");
AndyA 0:96532c59670f 132 if(nTraces_ > 1 && i != nTraces_-1) {
AndyA 0:96532c59670f 133 print_(", ");
AndyA 0:96532c59670f 134 }
AndyA 0:96532c59670f 135 }
AndyA 0:96532c59670f 136 print_("]&kwargs={\"fileopt\": \"");
AndyA 0:96532c59670f 137 print_(fileopt);
AndyA 0:96532c59670f 138 print_("\", \"filename\": \"");
AndyA 0:96532c59670f 139 print_(filename_);
AndyA 0:96532c59670f 140 print_("\", \"world_readable\": ");
AndyA 0:96532c59670f 141 if(world_readable) {
AndyA 0:96532c59670f 142 print_("true");
AndyA 0:96532c59670f 143 } else {
AndyA 0:96532c59670f 144 print_("false");
AndyA 0:96532c59670f 145 }
AndyA 0:96532c59670f 146 print_("}");
AndyA 0:96532c59670f 147 // final newline to terminate the POST
AndyA 0:96532c59670f 148 print_("\r\n");
AndyA 2:d53d74ed68ac 149 */
AndyA 0:96532c59670f 150
AndyA 0:96532c59670f 151 //
AndyA 0:96532c59670f 152 // Wait for a response
AndyA 0:96532c59670f 153 // Parse the response for the "All Streams Go!" and proceed to streaming
AndyA 0:96532c59670f 154 // if we find it
AndyA 0:96532c59670f 155 //
AndyA 2:d53d74ed68ac 156
AndyA 0:96532c59670f 157 char allStreamsGo[] = "All Streams Go!";
AndyA 0:96532c59670f 158 int asgCnt = 0; // asg stands for All Streams Go
AndyA 0:96532c59670f 159 char url[] = "\"url\": \"http://107.21.214.199/~";
AndyA 0:96532c59670f 160 char fid[4];
AndyA 0:96532c59670f 161 int fidCnt = 0;
AndyA 0:96532c59670f 162 int urlCnt = 0;
AndyA 0:96532c59670f 163 int usernameCnt = 0;
AndyA 0:96532c59670f 164 bool proceed = false;
AndyA 0:96532c59670f 165 bool fidMatched = false;
AndyA 0:96532c59670f 166 char c;
AndyA 0:96532c59670f 167
AndyA 0:96532c59670f 168 if(log_level < 2) {
AndyA 0:96532c59670f 169 fprintf(stderr,"... Sent message, waiting for plotly's response...\n");
AndyA 0:96532c59670f 170 }
AndyA 0:96532c59670f 171
AndyA 0:96532c59670f 172 if(!dry_run) {
AndyA 0:96532c59670f 173 while(!proceed) {
AndyA 2:d53d74ed68ac 174 int32_t dataIn = socket->receive(buffer,k_bufferSize -1);
AndyA 1:d532e96fca12 175 if (dataIn < 0) {
AndyA 1:d532e96fca12 176 if(log_level < 3) fprintf(stderr,"error reading network socket\n");
AndyA 1:d532e96fca12 177 break;
AndyA 1:d532e96fca12 178 }
AndyA 0:96532c59670f 179 if(dataIn > 0) {
AndyA 2:d53d74ed68ac 180 buffer[dataIn]=0;
AndyA 0:96532c59670f 181
AndyA 2:d53d74ed68ac 182 if(log_level < 2) fprintf(stderr,buffer);
AndyA 0:96532c59670f 183
AndyA 0:96532c59670f 184 for (int i = 0; i<dataIn; i++) {
AndyA 2:d53d74ed68ac 185 c = buffer[i];
AndyA 0:96532c59670f 186 //
AndyA 0:96532c59670f 187 // Attempt to read the "All streams go" msg if it exists
AndyA 0:96532c59670f 188 // by comparing characters as they roll in
AndyA 0:96532c59670f 189 //
AndyA 0:96532c59670f 190
AndyA 0:96532c59670f 191 if(asgCnt == len_(allStreamsGo) && !proceed) {
AndyA 0:96532c59670f 192 proceed = true;
AndyA 0:96532c59670f 193 } else if(allStreamsGo[asgCnt]==c) {
AndyA 0:96532c59670f 194 asgCnt += 1;
AndyA 0:96532c59670f 195 } else if(asgCnt > 0) {
AndyA 0:96532c59670f 196 // reset counter
AndyA 0:96532c59670f 197 asgCnt = 0;
AndyA 0:96532c59670f 198 }
AndyA 0:96532c59670f 199
AndyA 0:96532c59670f 200 //
AndyA 0:96532c59670f 201 // Extract the last bit of the URL from the response
AndyA 0:96532c59670f 202 // The url is in the form http://107.21.214.199/~USERNAME/FID
AndyA 0:96532c59670f 203 // We'll character-count up through char url[] and through username_, then start
AndyA 0:96532c59670f 204 // filling in characters into fid
AndyA 0:96532c59670f 205 //
AndyA 0:96532c59670f 206
AndyA 0:96532c59670f 207 if(log_level < 3) {
AndyA 0:96532c59670f 208 if(url[urlCnt]==c && urlCnt < len_(url)) {
AndyA 0:96532c59670f 209 urlCnt += 1;
AndyA 0:96532c59670f 210 } else if(urlCnt > 0 && urlCnt < len_(url)) {
AndyA 0:96532c59670f 211 // Reset counter
AndyA 0:96532c59670f 212 urlCnt = 0;
AndyA 0:96532c59670f 213 }
AndyA 0:96532c59670f 214 if(urlCnt == len_(url) && fidCnt < 4 && !fidMatched) {
AndyA 0:96532c59670f 215 // We've counted through the url, start counting through the username
AndyA 0:96532c59670f 216 if(usernameCnt < len_(username_)+2) {
AndyA 0:96532c59670f 217 usernameCnt += 1;
AndyA 0:96532c59670f 218 } else {
AndyA 0:96532c59670f 219 // the url ends with "
AndyA 0:96532c59670f 220 if(c != '"') {
AndyA 0:96532c59670f 221 fid[fidCnt] = c;
AndyA 0:96532c59670f 222 fidCnt += 1;
AndyA 0:96532c59670f 223 } else if(fidCnt>0) {
AndyA 0:96532c59670f 224 fidMatched = true;
AndyA 0:96532c59670f 225 }
AndyA 0:96532c59670f 226
AndyA 0:96532c59670f 227 }
AndyA 0:96532c59670f 228 }
AndyA 0:96532c59670f 229 }
AndyA 0:96532c59670f 230 }
AndyA 0:96532c59670f 231 }
AndyA 0:96532c59670f 232 wait(0.1);
AndyA 0:96532c59670f 233 }
AndyA 0:96532c59670f 234 }
AndyA 0:96532c59670f 235
AndyA 0:96532c59670f 236 if(!dry_run && !proceed && log_level < 4) {
AndyA 0:96532c59670f 237 fprintf(stderr,"... Error initializing stream, aborting. Try again or get in touch with Chris at chris@plot.ly\n");
AndyA 0:96532c59670f 238 }
AndyA 0:96532c59670f 239
AndyA 0:96532c59670f 240 if(!dry_run && proceed && log_level < 3) {
AndyA 0:96532c59670f 241 fprintf(stderr,"... A-ok from plotly, All Streams Go!\n");
AndyA 0:96532c59670f 242 if(fidMatched) {
AndyA 0:96532c59670f 243 fprintf(stderr,"... View your streaming plot here: https://plot.ly/~");
AndyA 0:96532c59670f 244 fprintf(stderr,username_);
AndyA 0:96532c59670f 245 fprintf(stderr,"/");
AndyA 0:96532c59670f 246 for(int i=0; i<fidCnt; i++) {
AndyA 0:96532c59670f 247 fprintf(stderr,"%d ",fid[i]);
AndyA 0:96532c59670f 248 }
AndyA 0:96532c59670f 249 fprintf(stderr,"\n");
AndyA 0:96532c59670f 250 }
AndyA 0:96532c59670f 251 }
AndyA 2:d53d74ed68ac 252
AndyA 2:d53d74ed68ac 253 if (proceed || dry_run) {
AndyA 2:d53d74ed68ac 254 initalised = true;
AndyA 2:d53d74ed68ac 255 }
AndyA 2:d53d74ed68ac 256 if (socket) {
AndyA 2:d53d74ed68ac 257 delete socket;
AndyA 2:d53d74ed68ac 258 socket=NULL;
AndyA 2:d53d74ed68ac 259 }
AndyA 2:d53d74ed68ac 260 return initalised;
AndyA 0:96532c59670f 261 }
AndyA 0:96532c59670f 262
AndyA 0:96532c59670f 263 void plotly::openStream()
AndyA 0:96532c59670f 264 {
AndyA 1:d532e96fca12 265
AndyA 1:d532e96fca12 266 if (!initalised)
AndyA 1:d532e96fca12 267 return;
AndyA 0:96532c59670f 268 //
AndyA 0:96532c59670f 269 // Start request to stream servers
AndyA 0:96532c59670f 270 //
AndyA 2:d53d74ed68ac 271
AndyA 2:d53d74ed68ac 272 if (socket) {
AndyA 2:d53d74ed68ac 273 delete socket;
AndyA 2:d53d74ed68ac 274 socket = NULL;
AndyA 2:d53d74ed68ac 275 }
AndyA 2:d53d74ed68ac 276
AndyA 2:d53d74ed68ac 277
AndyA 2:d53d74ed68ac 278 if(log_level < 3) fprintf(stderr,"... Connecting to plotly's streaming servers...\n");
AndyA 2:d53d74ed68ac 279
AndyA 2:d53d74ed68ac 280
AndyA 2:d53d74ed68ac 281 if (!dry_run && !socket) {
AndyA 2:d53d74ed68ac 282 socket = new TCPSocketConnection();
AndyA 2:d53d74ed68ac 283 while (socket->connect(dataURL, 80) < 0) {
AndyA 2:d53d74ed68ac 284 fprintf(stderr,"... Couldn\'t connect to servers... trying again!\n");
AndyA 2:d53d74ed68ac 285 wait(10);
AndyA 2:d53d74ed68ac 286 }
AndyA 0:96532c59670f 287 }
AndyA 2:d53d74ed68ac 288
AndyA 2:d53d74ed68ac 289 if(log_level < 3) fprintf(stderr,"... Connected to plotly's streaming servers\n... Initializing stream\n");
AndyA 0:96532c59670f 290
AndyA 0:96532c59670f 291 print_("POST / HTTP/1.1\r\n");
AndyA 3:967be3d46701 292 print_("Host: arduino.plot.ly\r\n");
AndyA 3:967be3d46701 293 print_("User-Agent: Python\r\n");
AndyA 0:96532c59670f 294 print_("Transfer-Encoding: chunked\r\n");
AndyA 3:967be3d46701 295 print_("Connection: close\r\n");
AndyA 2:d53d74ed68ac 296 print_("plotly-streamtoken: ");
AndyA 2:d53d74ed68ac 297 print_(stream_tokens_[0]);
AndyA 2:d53d74ed68ac 298 print_("\r\n");
AndyA 2:d53d74ed68ac 299 // if(convertTimestamp) {
AndyA 2:d53d74ed68ac 300 // print_("plotly-convertTimestamp: \"");
AndyA 2:d53d74ed68ac 301 // print_(timezone);
AndyA 2:d53d74ed68ac 302 // print_("\"");
AndyA 2:d53d74ed68ac 303 // print_("\r\n");
AndyA 2:d53d74ed68ac 304 // }
AndyA 2:d53d74ed68ac 305 print_("\r\n");
AndyA 0:96532c59670f 306
AndyA 1:d532e96fca12 307 if(log_level < 3) fprintf(stderr,"... Done initializing, ready to stream!\n");
AndyA 0:96532c59670f 308 }
AndyA 0:96532c59670f 309
AndyA 0:96532c59670f 310 void plotly::closeStream()
AndyA 0:96532c59670f 311 {
AndyA 2:d53d74ed68ac 312 if (socket) {
AndyA 2:d53d74ed68ac 313 if (socket->is_connected()) {
AndyA 2:d53d74ed68ac 314 print_("0\r\n\r\n");
AndyA 2:d53d74ed68ac 315 socket->close();
AndyA 2:d53d74ed68ac 316 }
AndyA 2:d53d74ed68ac 317 delete socket;
AndyA 2:d53d74ed68ac 318 socket=NULL;
AndyA 2:d53d74ed68ac 319 }
AndyA 0:96532c59670f 320 }
AndyA 1:d532e96fca12 321
AndyA 0:96532c59670f 322 void plotly::reconnectStream()
AndyA 0:96532c59670f 323 {
AndyA 2:d53d74ed68ac 324 while(!dry_run && (!socket || !socket->is_connected())) {
AndyA 0:96532c59670f 325 if(log_level<4) fprintf(stderr,"... Disconnected from streaming servers\n");
AndyA 0:96532c59670f 326 closeStream();
AndyA 0:96532c59670f 327 openStream();
AndyA 0:96532c59670f 328 }
AndyA 0:96532c59670f 329 }
AndyA 2:d53d74ed68ac 330
AndyA 0:96532c59670f 331 void plotly::jsonStart(int i)
AndyA 0:96532c59670f 332 {
AndyA 0:96532c59670f 333 // Print the length of the message in hex:
AndyA 0:96532c59670f 334 // 15 char for the json that wraps the data: {"x": , "y": }\n
AndyA 0:96532c59670f 335 // + 23 char for the token: , "token": "abcdefghij"
AndyA 0:96532c59670f 336 // = 38
AndyA 2:d53d74ed68ac 337 printHex_(i+38);
AndyA 0:96532c59670f 338 print_("\r\n{\"x\": ");
AndyA 0:96532c59670f 339 }
AndyA 0:96532c59670f 340 void plotly::jsonMiddle()
AndyA 0:96532c59670f 341 {
AndyA 0:96532c59670f 342 print_(", \"y\": ");
AndyA 0:96532c59670f 343 }
AndyA 0:96532c59670f 344 void plotly::jsonEnd(char *token)
AndyA 0:96532c59670f 345 {
AndyA 0:96532c59670f 346 print_(", \"streamtoken\": \"");
AndyA 0:96532c59670f 347 print_(token);
AndyA 2:d53d74ed68ac 348 print_("\"");
AndyA 2:d53d74ed68ac 349 print_("}\n\r\n");
AndyA 0:96532c59670f 350 }
AndyA 0:96532c59670f 351
AndyA 0:96532c59670f 352 int plotly::len_(int i)
AndyA 0:96532c59670f 353 {
AndyA 0:96532c59670f 354 // int range: -32,768 to 32,767
AndyA 0:96532c59670f 355 if(i > 9999) return 5;
AndyA 0:96532c59670f 356 else if(i > 999) return 4;
AndyA 0:96532c59670f 357 else if(i > 99) return 3;
AndyA 0:96532c59670f 358 else if(i > 9) return 2;
AndyA 0:96532c59670f 359 else if(i > -1) return 1;
AndyA 0:96532c59670f 360 else if(i > -10) return 2;
AndyA 0:96532c59670f 361 else if(i > -100) return 3;
AndyA 0:96532c59670f 362 else if(i > -1000) return 4;
AndyA 0:96532c59670f 363 else if(i > -10000) return 5;
AndyA 0:96532c59670f 364 else return 6;
AndyA 0:96532c59670f 365 }
AndyA 0:96532c59670f 366 int plotly::len_(unsigned long i)
AndyA 0:96532c59670f 367 {
AndyA 0:96532c59670f 368 // max length of unsigned long: 4294967295
AndyA 0:96532c59670f 369 if(i > 999999999) return 10;
AndyA 0:96532c59670f 370 else if(i > 99999999) return 9;
AndyA 0:96532c59670f 371 else if(i > 9999999) return 8;
AndyA 0:96532c59670f 372 else if(i > 999999) return 7;
AndyA 0:96532c59670f 373 else if(i > 99999) return 6;
AndyA 0:96532c59670f 374 else if(i > 9999) return 5;
AndyA 0:96532c59670f 375 else if(i > 999) return 4;
AndyA 0:96532c59670f 376 else if(i > 99) return 3;
AndyA 0:96532c59670f 377 else if(i > 9) return 2;
AndyA 0:96532c59670f 378 else return 1;
AndyA 0:96532c59670f 379 }
AndyA 0:96532c59670f 380 int plotly::len_(char *i)
AndyA 0:96532c59670f 381 {
AndyA 0:96532c59670f 382 return strlen(i);
AndyA 0:96532c59670f 383 }
AndyA 0:96532c59670f 384 void plotly::plot(unsigned long x, int y, char *token)
AndyA 0:96532c59670f 385 {
AndyA 2:d53d74ed68ac 386 if (!initalised)
AndyA 2:d53d74ed68ac 387 return;
AndyA 2:d53d74ed68ac 388
AndyA 0:96532c59670f 389 reconnectStream();
AndyA 2:d53d74ed68ac 390
AndyA 2:d53d74ed68ac 391 // int len = snprintf(buffer,k_bufferSize,"{\"x\": %lu, \"y\": %d, \"streamtoken\": \"%s\"}\n", x,y,token);
AndyA 2:d53d74ed68ac 392 // len = snprintf(buffer,k_bufferSize,"%X\r\n{\"x\": %lu, \"y\": %d, \"streamtoken\": \"%s\"}\n\r\n",len, x,y,token);
AndyA 2:d53d74ed68ac 393 int len = snprintf(buffer,k_bufferSize,"{\"x\": %lu, \"y\": %d}\n", x,y);
AndyA 2:d53d74ed68ac 394 len = snprintf(buffer,k_bufferSize,"%x\r\n{\"x\": %lu, \"y\": %d}\n\r\n",len, x,y);
AndyA 2:d53d74ed68ac 395 sendFormatedText(buffer,len);
AndyA 0:96532c59670f 396 }
AndyA 0:96532c59670f 397
AndyA 0:96532c59670f 398 void plotly::plot(unsigned long x, float y, char *token)
AndyA 0:96532c59670f 399 {
AndyA 2:d53d74ed68ac 400 if (!initalised)
AndyA 2:d53d74ed68ac 401 return;
AndyA 2:d53d74ed68ac 402
AndyA 0:96532c59670f 403 reconnectStream();
AndyA 0:96532c59670f 404
AndyA 2:d53d74ed68ac 405 int len = snprintf(buffer,k_bufferSize,"{\"x\": %lu, \"y\": %.3f}\n", x,y);
AndyA 2:d53d74ed68ac 406 len = snprintf(buffer,k_bufferSize,"%x\r\n{\"x\": %lu, \"y\": %.3f}\n\r\n",len, x,y);
AndyA 2:d53d74ed68ac 407 // int len = snprintf(buffer,k_bufferSize,"{\"x\": %lu, \"y\": %.3f, \"streamtoken\": \"%s\"}\n", x,y,token);
AndyA 2:d53d74ed68ac 408 // len = snprintf(buffer,k_bufferSize,"%X\r\n{\"x\": %lu, \"y\": %.3f, \"streamtoken\": \"%s\"}\n\r\n",len, x,y,token);
AndyA 2:d53d74ed68ac 409 sendFormatedText(buffer,len);
AndyA 0:96532c59670f 410 }
AndyA 0:96532c59670f 411
AndyA 1:d532e96fca12 412 bool plotly::print_(int d)
AndyA 0:96532c59670f 413 {
AndyA 2:d53d74ed68ac 414 int32_t len = snprintf(buffer,k_bufferSize,"%d",d);
AndyA 2:d53d74ed68ac 415 return sendFormatedText(buffer,len);
AndyA 2:d53d74ed68ac 416 }
AndyA 1:d532e96fca12 417
AndyA 1:d532e96fca12 418 bool plotly::print_(unsigned long d)
AndyA 0:96532c59670f 419 {
AndyA 2:d53d74ed68ac 420 int32_t len = snprintf(buffer,k_bufferSize,"%lu",d);
AndyA 2:d53d74ed68ac 421 return sendFormatedText(buffer,len);
AndyA 2:d53d74ed68ac 422 }
AndyA 2:d53d74ed68ac 423
AndyA 2:d53d74ed68ac 424 bool plotly::print_(float d)
AndyA 2:d53d74ed68ac 425 {
AndyA 2:d53d74ed68ac 426 int32_t len = snprintf(buffer,k_bufferSize,"%f",d);
AndyA 2:d53d74ed68ac 427 return sendFormatedText(buffer,len);
AndyA 2:d53d74ed68ac 428 }
AndyA 2:d53d74ed68ac 429
AndyA 2:d53d74ed68ac 430 bool plotly::print_(char *d)
AndyA 2:d53d74ed68ac 431 {
AndyA 2:d53d74ed68ac 432 int32_t len = snprintf(buffer,k_bufferSize,"%s",d);
AndyA 2:d53d74ed68ac 433 return sendFormatedText(buffer,len);
AndyA 2:d53d74ed68ac 434 }
AndyA 2:d53d74ed68ac 435
AndyA 2:d53d74ed68ac 436 bool plotly::printHex_(uint16_t d)
AndyA 2:d53d74ed68ac 437 {
AndyA 2:d53d74ed68ac 438 int32_t len = snprintf(buffer,k_bufferSize,"%X",d);
AndyA 2:d53d74ed68ac 439 return sendFormatedText(buffer,len);
AndyA 2:d53d74ed68ac 440 }
AndyA 2:d53d74ed68ac 441
AndyA 2:d53d74ed68ac 442 bool plotly::sendFormatedText(char* data, int size)
AndyA 2:d53d74ed68ac 443 {
AndyA 2:d53d74ed68ac 444 if(log_level < 2) {
AndyA 2:d53d74ed68ac 445 fprintf(stderr,"%s",data);
AndyA 2:d53d74ed68ac 446 }
AndyA 1:d532e96fca12 447 if(!dry_run) {
AndyA 2:d53d74ed68ac 448 if (!socket) {
AndyA 2:d53d74ed68ac 449 fprintf(stderr,"\nTX failed, No network socket exists\n");
AndyA 2:d53d74ed68ac 450 return false;
AndyA 2:d53d74ed68ac 451 }
AndyA 2:d53d74ed68ac 452 if (!(socket->is_connected())) {
AndyA 2:d53d74ed68ac 453 fprintf(stderr,"\nTX failed, Network socket not connected\n");
AndyA 2:d53d74ed68ac 454 return false;
AndyA 2:d53d74ed68ac 455 }
AndyA 2:d53d74ed68ac 456
AndyA 2:d53d74ed68ac 457 int32_t sent = socket->send_all(data,size);
AndyA 2:d53d74ed68ac 458 if (sent == size)
AndyA 1:d532e96fca12 459 return true;
AndyA 1:d532e96fca12 460 else {
AndyA 2:d53d74ed68ac 461 fprintf(stderr,"\nTX failed to send _%s_ Sent %d of %d bytes\n",data,sent,size);
AndyA 2:d53d74ed68ac 462 echoRxData();
AndyA 1:d532e96fca12 463 return false;
AndyA 1:d532e96fca12 464 }
AndyA 1:d532e96fca12 465 } else
AndyA 1:d532e96fca12 466 return true;
AndyA 0:96532c59670f 467 }
AndyA 0:96532c59670f 468
AndyA 2:d53d74ed68ac 469 void plotly::echoRxData()
AndyA 0:96532c59670f 470 {
AndyA 2:d53d74ed68ac 471
AndyA 2:d53d74ed68ac 472 int32_t dataIn = socket->receive(buffer,k_bufferSize -1);
AndyA 2:d53d74ed68ac 473 if (dataIn < 0) {
AndyA 2:d53d74ed68ac 474 if (socket->is_connected()) {
AndyA 2:d53d74ed68ac 475 fprintf(stderr,"error reading network socket. Closing it\n");
AndyA 2:d53d74ed68ac 476 socket->close();
AndyA 2:d53d74ed68ac 477 delete socket;
AndyA 2:d53d74ed68ac 478 socket = NULL;
AndyA 2:d53d74ed68ac 479 }
AndyA 1:d532e96fca12 480 else {
AndyA 2:d53d74ed68ac 481 fprintf(stderr,"error reading network socket, socket isn't connected\n");
AndyA 2:d53d74ed68ac 482 delete socket;
AndyA 2:d53d74ed68ac 483 socket = NULL;
AndyA 2:d53d74ed68ac 484 }
AndyA 2:d53d74ed68ac 485 }
AndyA 2:d53d74ed68ac 486 if(dataIn > 0) {
AndyA 2:d53d74ed68ac 487 buffer[dataIn]=0;
AndyA 2:d53d74ed68ac 488 fprintf(stderr,"Rx Data __");
AndyA 2:d53d74ed68ac 489 fprintf(stderr,buffer);
AndyA 2:d53d74ed68ac 490 fprintf(stderr,"__\n");
AndyA 2:d53d74ed68ac 491 }
AndyA 2:d53d74ed68ac 492
AndyA 2:d53d74ed68ac 493 }