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