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@7:9409a72ab6c0, 2014-07-29 (annotated)
- Committer:
- AndyA
- Date:
- Tue Jul 29 13:30:31 2014 +0000
- Revision:
- 7:9409a72ab6c0
- Parent:
- 5:fc8eefeb301b
- Parent:
- 6:e57d6e9313f4
- Child:
- 8:d4f705ba2ea5
Mid merge;
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 | 3:967be3d46701 | 4 | #define plotlyURL "plot.ly" |
AndyA | 0:96532c59670f | 5 | #define dataURL "arduino.plot.ly" |
AndyA | 0:96532c59670f | 6 | |
AndyA | 7:9409a72ab6c0 | 7 | plotly::plotly(const char *username, const char *api_key, const char** stream_tokens, const char *filename, int nTraces) |
AndyA | 0:96532c59670f | 8 | { |
AndyA | 4:33006c37c633 | 9 | log_level = 3; // 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 | 7:9409a72ab6c0 | 13 | stream_tokens = stream_tokens; |
AndyA | 0:96532c59670f | 14 | filename_ = filename; |
AndyA | 0:96532c59670f | 15 | maxpoints = 30; |
AndyA | 0:96532c59670f | 16 | world_readable = true; |
AndyA | 6:e57d6e9313f4 | 17 | convertTimestamp = false; |
AndyA | 0:96532c59670f | 18 | timezone = "America/Montreal"; |
AndyA | 0:96532c59670f | 19 | fileopt = "overwrite"; |
AndyA | 1:d532e96fca12 | 20 | |
AndyA | 7:9409a72ab6c0 | 21 | nTraces_ = nTraces; |
AndyA | 4:33006c37c633 | 22 | |
AndyA | 7:9409a72ab6c0 | 23 | sockets = (TCPSocketConnection **)malloc(sizeof(TCPSocketConnection *) * nTraces_); |
AndyA | 7:9409a72ab6c0 | 24 | for (int i = 0; i< nTraces_; i++) { |
AndyA | 6:e57d6e9313f4 | 25 | *(sockets+i) = NULL; |
AndyA | 6:e57d6e9313f4 | 26 | } |
AndyA | 1:d532e96fca12 | 27 | initalised = false; |
AndyA | 7:9409a72ab6c0 | 28 | |
AndyA | 0:96532c59670f | 29 | } |
AndyA | 0:96532c59670f | 30 | |
AndyA | 0:96532c59670f | 31 | |
AndyA | 1:d532e96fca12 | 32 | plotly::~plotly() |
AndyA | 1:d532e96fca12 | 33 | { |
AndyA | 6:e57d6e9313f4 | 34 | closeStreams(); |
AndyA | 6:e57d6e9313f4 | 35 | if (sockets) |
AndyA | 6:e57d6e9313f4 | 36 | free(sockets); |
AndyA | 1:d532e96fca12 | 37 | } |
AndyA | 0:96532c59670f | 38 | |
AndyA | 4:33006c37c633 | 39 | |
AndyA | 0:96532c59670f | 40 | bool plotly::init() |
AndyA | 0:96532c59670f | 41 | { |
AndyA | 0:96532c59670f | 42 | |
AndyA | 7:9409a72ab6c0 | 43 | fprintf(stderr,"%d tokens\n",nTraces_); |
AndyA | 7:9409a72ab6c0 | 44 | wait(1); |
AndyA | 7:9409a72ab6c0 | 45 | for (int i = 0; i<nTraces_; i++) { |
AndyA | 7:9409a72ab6c0 | 46 | fprintf(stderr,"%s\n",*(stream_tokens_+i)); |
AndyA | 7:9409a72ab6c0 | 47 | wait(1); |
AndyA | 7:9409a72ab6c0 | 48 | } |
AndyA | 7:9409a72ab6c0 | 49 | |
AndyA | 0:96532c59670f | 50 | // |
AndyA | 4:33006c37c633 | 51 | // Create plot with a REST post to plotly |
AndyA | 4:33006c37c633 | 52 | // See the clientresp section of https://plot.ly/rest/ for details |
AndyA | 0:96532c59670f | 53 | // |
AndyA | 0:96532c59670f | 54 | if(dry_run && log_level < 3) { |
AndyA | 0:96532c59670f | 55 | fprintf(stderr,"... This is a dry run, we are not connecting to plotly's servers...\n"); |
AndyA | 0:96532c59670f | 56 | } else if(log_level < 3) { |
AndyA | 0:96532c59670f | 57 | fprintf(stderr,"... Attempting to connect to plotly's REST servers\n"); |
AndyA | 0:96532c59670f | 58 | } |
AndyA | 0:96532c59670f | 59 | |
AndyA | 2:d53d74ed68ac | 60 | if (!dry_run) { |
AndyA | 4:33006c37c633 | 61 | int pause = 1; |
AndyA | 6:e57d6e9313f4 | 62 | *sockets = new TCPSocketConnection(); |
AndyA | 6:e57d6e9313f4 | 63 | if (!*sockets) |
AndyA | 6:e57d6e9313f4 | 64 | return false; |
AndyA | 6:e57d6e9313f4 | 65 | while ((*sockets)->connect(plotlyURL, 80) < 0) { |
AndyA | 4:33006c37c633 | 66 | if (pause > 30) { |
AndyA | 4:33006c37c633 | 67 | fprintf(stderr,"Failed to connect. :-(\n"); |
AndyA | 7:9409a72ab6c0 | 68 | delete (*sockets); |
AndyA | 4:33006c37c633 | 69 | return false; |
AndyA | 4:33006c37c633 | 70 | } |
AndyA | 0:96532c59670f | 71 | fprintf(stderr,"... Couldn\'t connect to plotly's REST servers... trying again!\n"); |
AndyA | 4:33006c37c633 | 72 | wait(pause); |
AndyA | 4:33006c37c633 | 73 | pause *= 2; |
AndyA | 0:96532c59670f | 74 | } |
AndyA | 2:d53d74ed68ac | 75 | } |
AndyA | 1:d532e96fca12 | 76 | |
AndyA | 1:d532e96fca12 | 77 | if(log_level < 3) fprintf(stderr,"... Connected to plotly's REST servers\n"); |
AndyA | 2:d53d74ed68ac | 78 | |
AndyA | 1:d532e96fca12 | 79 | if(log_level < 3) fprintf(stderr,"... Sending HTTP Post to plotly\n"); |
AndyA | 2:d53d74ed68ac | 80 | |
AndyA | 0:96532c59670f | 81 | print_("POST /clientresp HTTP/1.1\r\n"); |
AndyA | 0:96532c59670f | 82 | print_("Host: 107.21.214.199\r\n"); |
AndyA | 3:967be3d46701 | 83 | print_("User-Agent: Arduino/0.5.1\r\n"); |
AndyA | 2:d53d74ed68ac | 84 | print_("plotly-streamtoken: "); |
AndyA | 6:e57d6e9313f4 | 85 | for (int i = 0; i<nTraces_; i++) { |
AndyA | 6:e57d6e9313f4 | 86 | print_(stream_tokens_[i]); |
AndyA | 6:e57d6e9313f4 | 87 | if ( i < (nTraces_-1) ) |
AndyA | 6:e57d6e9313f4 | 88 | print_(","); |
AndyA | 6:e57d6e9313f4 | 89 | } |
AndyA | 4:33006c37c633 | 90 | printNetTerminator_(); |
AndyA | 0:96532c59670f | 91 | |
AndyA | 0:96532c59670f | 92 | print_("Content-Length: "); |
AndyA | 2:d53d74ed68ac | 93 | |
AndyA | 7:9409a72ab6c0 | 94 | unsigned long lineLen = snprintf(buffer,k_bufferSize,"version=2.3&origin=plot&platform=arduino&un=%s&key=%s&args=[",username_,api_key_); |
AndyA | 2:d53d74ed68ac | 95 | for(int i=0; i<nTraces_; i++) { |
AndyA | 2:d53d74ed68ac | 96 | 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 | 97 | } |
AndyA | 2:d53d74ed68ac | 98 | lineLen += snprintf((buffer+lineLen),k_bufferSize-lineLen,"]&kwargs={\"fileopt\": \"%s\", \"filename\": \"%s\", \"world_readable\": %s}",fileopt,filename_,world_readable?"true":"false"); |
AndyA | 2:d53d74ed68ac | 99 | |
AndyA | 2:d53d74ed68ac | 100 | print_(lineLen); |
AndyA | 4:33006c37c633 | 101 | printNetTerminator_(); |
AndyA | 4:33006c37c633 | 102 | printNetTerminator_(); |
AndyA | 6:e57d6e9313f4 | 103 | |
AndyA | 2:d53d74ed68ac | 104 | sendFormatedText(buffer,lineLen); |
AndyA | 6:e57d6e9313f4 | 105 | |
AndyA | 4:33006c37c633 | 106 | printNetTerminator_(); |
AndyA | 0:96532c59670f | 107 | |
AndyA | 0:96532c59670f | 108 | // |
AndyA | 0:96532c59670f | 109 | // Wait for a response |
AndyA | 0:96532c59670f | 110 | // Parse the response for the "All Streams Go!" and proceed to streaming |
AndyA | 0:96532c59670f | 111 | // if we find it |
AndyA | 0:96532c59670f | 112 | // |
AndyA | 2:d53d74ed68ac | 113 | |
AndyA | 0:96532c59670f | 114 | char allStreamsGo[] = "All Streams Go!"; |
AndyA | 0:96532c59670f | 115 | int asgCnt = 0; // asg stands for All Streams Go |
AndyA | 0:96532c59670f | 116 | char url[] = "\"url\": \"http://107.21.214.199/~"; |
AndyA | 0:96532c59670f | 117 | char fid[4]; |
AndyA | 0:96532c59670f | 118 | int fidCnt = 0; |
AndyA | 0:96532c59670f | 119 | int urlCnt = 0; |
AndyA | 0:96532c59670f | 120 | int usernameCnt = 0; |
AndyA | 0:96532c59670f | 121 | bool proceed = false; |
AndyA | 0:96532c59670f | 122 | bool fidMatched = false; |
AndyA | 0:96532c59670f | 123 | char c; |
AndyA | 0:96532c59670f | 124 | |
AndyA | 0:96532c59670f | 125 | if(log_level < 2) { |
AndyA | 0:96532c59670f | 126 | fprintf(stderr,"... Sent message, waiting for plotly's response...\n"); |
AndyA | 0:96532c59670f | 127 | } |
AndyA | 0:96532c59670f | 128 | |
AndyA | 0:96532c59670f | 129 | if(!dry_run) { |
AndyA | 0:96532c59670f | 130 | while(!proceed) { |
AndyA | 6:e57d6e9313f4 | 131 | int32_t dataIn = (*sockets)->receive(buffer,k_bufferSize -1); |
AndyA | 1:d532e96fca12 | 132 | if (dataIn < 0) { |
AndyA | 1:d532e96fca12 | 133 | if(log_level < 3) fprintf(stderr,"error reading network socket\n"); |
AndyA | 1:d532e96fca12 | 134 | break; |
AndyA | 1:d532e96fca12 | 135 | } |
AndyA | 0:96532c59670f | 136 | if(dataIn > 0) { |
AndyA | 2:d53d74ed68ac | 137 | buffer[dataIn]=0; |
AndyA | 0:96532c59670f | 138 | |
AndyA | 2:d53d74ed68ac | 139 | if(log_level < 2) fprintf(stderr,buffer); |
AndyA | 0:96532c59670f | 140 | |
AndyA | 0:96532c59670f | 141 | for (int i = 0; i<dataIn; i++) { |
AndyA | 2:d53d74ed68ac | 142 | c = buffer[i]; |
AndyA | 0:96532c59670f | 143 | // |
AndyA | 0:96532c59670f | 144 | // Attempt to read the "All streams go" msg if it exists |
AndyA | 0:96532c59670f | 145 | // by comparing characters as they roll in |
AndyA | 0:96532c59670f | 146 | // |
AndyA | 0:96532c59670f | 147 | |
AndyA | 6:e57d6e9313f4 | 148 | if(asgCnt == strlen(allStreamsGo) && !proceed) { |
AndyA | 0:96532c59670f | 149 | proceed = true; |
AndyA | 0:96532c59670f | 150 | } else if(allStreamsGo[asgCnt]==c) { |
AndyA | 0:96532c59670f | 151 | asgCnt += 1; |
AndyA | 0:96532c59670f | 152 | } else if(asgCnt > 0) { |
AndyA | 0:96532c59670f | 153 | // reset counter |
AndyA | 0:96532c59670f | 154 | asgCnt = 0; |
AndyA | 0:96532c59670f | 155 | } |
AndyA | 0:96532c59670f | 156 | |
AndyA | 0:96532c59670f | 157 | // |
AndyA | 0:96532c59670f | 158 | // Extract the last bit of the URL from the response |
AndyA | 0:96532c59670f | 159 | // The url is in the form http://107.21.214.199/~USERNAME/FID |
AndyA | 0:96532c59670f | 160 | // We'll character-count up through char url[] and through username_, then start |
AndyA | 0:96532c59670f | 161 | // filling in characters into fid |
AndyA | 0:96532c59670f | 162 | // |
AndyA | 0:96532c59670f | 163 | |
AndyA | 0:96532c59670f | 164 | if(log_level < 3) { |
AndyA | 6:e57d6e9313f4 | 165 | if(url[urlCnt]==c && urlCnt < strlen(url)) { |
AndyA | 0:96532c59670f | 166 | urlCnt += 1; |
AndyA | 6:e57d6e9313f4 | 167 | } else if(urlCnt > 0 && urlCnt < strlen(url)) { |
AndyA | 0:96532c59670f | 168 | // Reset counter |
AndyA | 0:96532c59670f | 169 | urlCnt = 0; |
AndyA | 0:96532c59670f | 170 | } |
AndyA | 6:e57d6e9313f4 | 171 | if(urlCnt == strlen(url) && fidCnt < 4 && !fidMatched) { |
AndyA | 0:96532c59670f | 172 | // We've counted through the url, start counting through the username |
AndyA | 6:e57d6e9313f4 | 173 | if(usernameCnt < strlen(username_)+2) { |
AndyA | 0:96532c59670f | 174 | usernameCnt += 1; |
AndyA | 0:96532c59670f | 175 | } else { |
AndyA | 0:96532c59670f | 176 | // the url ends with " |
AndyA | 0:96532c59670f | 177 | if(c != '"') { |
AndyA | 0:96532c59670f | 178 | fid[fidCnt] = c; |
AndyA | 0:96532c59670f | 179 | fidCnt += 1; |
AndyA | 0:96532c59670f | 180 | } else if(fidCnt>0) { |
AndyA | 0:96532c59670f | 181 | fidMatched = true; |
AndyA | 0:96532c59670f | 182 | } |
AndyA | 0:96532c59670f | 183 | |
AndyA | 0:96532c59670f | 184 | } |
AndyA | 0:96532c59670f | 185 | } |
AndyA | 0:96532c59670f | 186 | } |
AndyA | 0:96532c59670f | 187 | } |
AndyA | 0:96532c59670f | 188 | } |
AndyA | 0:96532c59670f | 189 | wait(0.1); |
AndyA | 0:96532c59670f | 190 | } |
AndyA | 0:96532c59670f | 191 | } |
AndyA | 0:96532c59670f | 192 | |
AndyA | 0:96532c59670f | 193 | if(!dry_run && !proceed && log_level < 4) { |
AndyA | 7:9409a72ab6c0 | 194 | fprintf(stderr,"... Error initializing stream, aborting.\n"); |
AndyA | 0:96532c59670f | 195 | } |
AndyA | 0:96532c59670f | 196 | |
AndyA | 0:96532c59670f | 197 | if(!dry_run && proceed && log_level < 3) { |
AndyA | 0:96532c59670f | 198 | fprintf(stderr,"... A-ok from plotly, All Streams Go!\n"); |
AndyA | 0:96532c59670f | 199 | if(fidMatched) { |
AndyA | 0:96532c59670f | 200 | fprintf(stderr,"... View your streaming plot here: https://plot.ly/~"); |
AndyA | 0:96532c59670f | 201 | fprintf(stderr,username_); |
AndyA | 0:96532c59670f | 202 | fprintf(stderr,"/"); |
AndyA | 0:96532c59670f | 203 | for(int i=0; i<fidCnt; i++) { |
AndyA | 4:33006c37c633 | 204 | fprintf(stderr,"%c",fid[i]); |
AndyA | 0:96532c59670f | 205 | } |
AndyA | 0:96532c59670f | 206 | fprintf(stderr,"\n"); |
AndyA | 0:96532c59670f | 207 | } |
AndyA | 0:96532c59670f | 208 | } |
AndyA | 2:d53d74ed68ac | 209 | |
AndyA | 2:d53d74ed68ac | 210 | if (proceed || dry_run) { |
AndyA | 6:e57d6e9313f4 | 211 | initalised = true; |
AndyA | 2:d53d74ed68ac | 212 | } |
AndyA | 6:e57d6e9313f4 | 213 | if (*sockets) { |
AndyA | 6:e57d6e9313f4 | 214 | delete *sockets; |
AndyA | 6:e57d6e9313f4 | 215 | *sockets=NULL; |
AndyA | 6:e57d6e9313f4 | 216 | } |
AndyA | 2:d53d74ed68ac | 217 | return initalised; |
AndyA | 0:96532c59670f | 218 | } |
AndyA | 0:96532c59670f | 219 | |
AndyA | 6:e57d6e9313f4 | 220 | void plotly::openStreams() |
AndyA | 6:e57d6e9313f4 | 221 | { |
AndyA | 6:e57d6e9313f4 | 222 | for (int i = 0; i< nTraces_; i++) { |
AndyA | 6:e57d6e9313f4 | 223 | openStream(i); |
AndyA | 6:e57d6e9313f4 | 224 | } |
AndyA | 6:e57d6e9313f4 | 225 | } |
AndyA | 6:e57d6e9313f4 | 226 | |
AndyA | 6:e57d6e9313f4 | 227 | void plotly::closeStreams() |
AndyA | 0:96532c59670f | 228 | { |
AndyA | 6:e57d6e9313f4 | 229 | for (int i = 0; i< nTraces_; i++) { |
AndyA | 6:e57d6e9313f4 | 230 | closeStream(i); |
AndyA | 6:e57d6e9313f4 | 231 | } |
AndyA | 6:e57d6e9313f4 | 232 | } |
AndyA | 6:e57d6e9313f4 | 233 | |
AndyA | 6:e57d6e9313f4 | 234 | |
AndyA | 7:9409a72ab6c0 | 235 | bool plotly::openStream(int stream) |
AndyA | 6:e57d6e9313f4 | 236 | { |
AndyA | 6:e57d6e9313f4 | 237 | |
AndyA | 6:e57d6e9313f4 | 238 | if (stream >= nTraces_) |
AndyA | 7:9409a72ab6c0 | 239 | return false; |
AndyA | 1:d532e96fca12 | 240 | |
AndyA | 1:d532e96fca12 | 241 | if (!initalised) |
AndyA | 4:33006c37c633 | 242 | return false; |
AndyA | 4:33006c37c633 | 243 | |
AndyA | 0:96532c59670f | 244 | // |
AndyA | 0:96532c59670f | 245 | // Start request to stream servers |
AndyA | 0:96532c59670f | 246 | // |
AndyA | 2:d53d74ed68ac | 247 | |
AndyA | 6:e57d6e9313f4 | 248 | if (*(sockets+stream) != NULL) { |
AndyA | 6:e57d6e9313f4 | 249 | delete *(sockets+stream); |
AndyA | 6:e57d6e9313f4 | 250 | *(sockets+stream) = NULL; |
AndyA | 6:e57d6e9313f4 | 251 | } |
AndyA | 2:d53d74ed68ac | 252 | |
AndyA | 2:d53d74ed68ac | 253 | if(log_level < 3) fprintf(stderr,"... Connecting to plotly's streaming servers...\n"); |
AndyA | 2:d53d74ed68ac | 254 | |
AndyA | 6:e57d6e9313f4 | 255 | if (!dry_run) { |
AndyA | 4:33006c37c633 | 256 | int pause = 1; |
AndyA | 6:e57d6e9313f4 | 257 | *(sockets + stream) = new TCPSocketConnection(); |
AndyA | 6:e57d6e9313f4 | 258 | while ((*(sockets + stream))->connect(dataURL, 80) < 0) { |
AndyA | 4:33006c37c633 | 259 | if (pause > 30) { |
AndyA | 4:33006c37c633 | 260 | fprintf(stderr,"Failed to connect. :-(\n"); |
AndyA | 7:9409a72ab6c0 | 261 | delete *(sockets + stream); |
AndyA | 4:33006c37c633 | 262 | return false; |
AndyA | 4:33006c37c633 | 263 | } |
AndyA | 4:33006c37c633 | 264 | fprintf(stderr,"... Couldn\'t connect to plotly's REST servers... trying again!\n"); |
AndyA | 4:33006c37c633 | 265 | wait(pause); |
AndyA | 4:33006c37c633 | 266 | pause *= 2; |
AndyA | 2:d53d74ed68ac | 267 | } |
AndyA | 0:96532c59670f | 268 | } |
AndyA | 2:d53d74ed68ac | 269 | |
AndyA | 4:33006c37c633 | 270 | |
AndyA | 6:e57d6e9313f4 | 271 | if(log_level < 3) fprintf(stderr,"... Connected to plotly's streaming servers\n... Initializing stream %d\n",stream); |
AndyA | 0:96532c59670f | 272 | |
AndyA | 6:e57d6e9313f4 | 273 | print_("POST / HTTP/1.1\r\n",stream); |
AndyA | 6:e57d6e9313f4 | 274 | print_("Host: arduino.plot.ly\r\n",stream); |
AndyA | 6:e57d6e9313f4 | 275 | print_("User-Agent: Python\r\n",stream); |
AndyA | 6:e57d6e9313f4 | 276 | print_("Transfer-Encoding: chunked\r\n",stream); |
AndyA | 6:e57d6e9313f4 | 277 | print_("Connection: close\r\n",stream); |
AndyA | 6:e57d6e9313f4 | 278 | print_("plotly-streamtoken: ",stream); |
AndyA | 6:e57d6e9313f4 | 279 | print_(stream_tokens_[stream],stream); |
AndyA | 7:9409a72ab6c0 | 280 | printNetTerminator_(stream); |
AndyA | 6:e57d6e9313f4 | 281 | if(convertTimestamp) { |
AndyA | 7:9409a72ab6c0 | 282 | print_("plotly-convertTimestamp: \"",stream); |
AndyA | 7:9409a72ab6c0 | 283 | print_(timezone,stream); |
AndyA | 7:9409a72ab6c0 | 284 | print_("\"",stream); |
AndyA | 7:9409a72ab6c0 | 285 | printNetTerminator_(stream); |
AndyA | 6:e57d6e9313f4 | 286 | } |
AndyA | 7:9409a72ab6c0 | 287 | printNetTerminator_(stream); |
AndyA | 0:96532c59670f | 288 | |
AndyA | 1:d532e96fca12 | 289 | if(log_level < 3) fprintf(stderr,"... Done initializing, ready to stream!\n"); |
AndyA | 4:33006c37c633 | 290 | return true; |
AndyA | 0:96532c59670f | 291 | } |
AndyA | 0:96532c59670f | 292 | |
AndyA | 6:e57d6e9313f4 | 293 | void plotly::closeStream( int stream) |
AndyA | 0:96532c59670f | 294 | { |
AndyA | 6:e57d6e9313f4 | 295 | if (stream >= nTraces_) |
AndyA | 6:e57d6e9313f4 | 296 | return; |
AndyA | 6:e57d6e9313f4 | 297 | |
AndyA | 6:e57d6e9313f4 | 298 | if (*(sockets+stream) != NULL) { |
AndyA | 6:e57d6e9313f4 | 299 | if ((*(sockets+stream))->is_connected()) { |
AndyA | 6:e57d6e9313f4 | 300 | print_("0\r\n\r\n",stream); |
AndyA | 6:e57d6e9313f4 | 301 | (*(sockets+stream))->close(); |
AndyA | 2:d53d74ed68ac | 302 | } |
AndyA | 6:e57d6e9313f4 | 303 | delete *(sockets+stream); |
AndyA | 6:e57d6e9313f4 | 304 | *(sockets+stream)=NULL; |
AndyA | 0:96532c59670f | 305 | } |
AndyA | 0:96532c59670f | 306 | } |
AndyA | 2:d53d74ed68ac | 307 | |
AndyA | 6:e57d6e9313f4 | 308 | void plotly::reconnectStream(int number) |
AndyA | 0:96532c59670f | 309 | { |
AndyA | 6:e57d6e9313f4 | 310 | while(!dry_run && (!(*(sockets+number)) || !(*(sockets+number))->is_connected())) { |
AndyA | 6:e57d6e9313f4 | 311 | if(log_level<4) fprintf(stderr,"... Disconnected from streaming servers\n"); |
AndyA | 6:e57d6e9313f4 | 312 | closeStream(number); |
AndyA | 6:e57d6e9313f4 | 313 | openStream(number); |
AndyA | 6:e57d6e9313f4 | 314 | } |
AndyA | 0:96532c59670f | 315 | } |
AndyA | 0:96532c59670f | 316 | |
AndyA | 6:e57d6e9313f4 | 317 | |
AndyA | 6:e57d6e9313f4 | 318 | void plotly::plot(unsigned long x, int y, int stream) |
AndyA | 0:96532c59670f | 319 | { |
AndyA | 6:e57d6e9313f4 | 320 | if (!initalised) |
AndyA | 6:e57d6e9313f4 | 321 | return; |
AndyA | 6:e57d6e9313f4 | 322 | |
AndyA | 6:e57d6e9313f4 | 323 | reconnectStream(stream); |
AndyA | 6:e57d6e9313f4 | 324 | |
AndyA | 4:33006c37c633 | 325 | // need to prefix with the length so print it once to get the content lenght and then a second time with the prefix. |
AndyA | 6:e57d6e9313f4 | 326 | int len = snprintf(buffer,k_bufferSize,"{\"x\": %lu, \"y\": %d}\n", x,y); |
AndyA | 6:e57d6e9313f4 | 327 | len = snprintf(buffer,k_bufferSize,"%x\r\n{\"x\": %lu, \"y\": %d}\n\r\n",len, x,y); |
AndyA | 6:e57d6e9313f4 | 328 | sendFormatedText(buffer,len,stream); |
AndyA | 0:96532c59670f | 329 | } |
AndyA | 6:e57d6e9313f4 | 330 | |
AndyA | 6:e57d6e9313f4 | 331 | void plotly::plot(unsigned long x, float y, int stream) |
AndyA | 0:96532c59670f | 332 | { |
AndyA | 2:d53d74ed68ac | 333 | if (!initalised) |
AndyA | 2:d53d74ed68ac | 334 | return; |
AndyA | 2:d53d74ed68ac | 335 | |
AndyA | 6:e57d6e9313f4 | 336 | reconnectStream(stream); |
AndyA | 2:d53d74ed68ac | 337 | |
AndyA | 4:33006c37c633 | 338 | // need to prefix with the length so print it once to get the content lenght and then a second time with the prefix. |
AndyA | 6:e57d6e9313f4 | 339 | int len = snprintf(buffer,k_bufferSize,"{\"x\": %lu, \"y\": %.3f}\n", x,y); |
AndyA | 6:e57d6e9313f4 | 340 | len = snprintf(buffer,k_bufferSize,"%x\r\n{\"x\": %lu, \"y\": %.3f}\n\r\n",len, x,y); |
AndyA | 6:e57d6e9313f4 | 341 | sendFormatedText(buffer,len,stream); |
AndyA | 0:96532c59670f | 342 | } |
AndyA | 0:96532c59670f | 343 | |
AndyA | 6:e57d6e9313f4 | 344 | void plotly::plot(float x, float y, int stream) |
AndyA | 0:96532c59670f | 345 | { |
AndyA | 2:d53d74ed68ac | 346 | if (!initalised) |
AndyA | 2:d53d74ed68ac | 347 | return; |
AndyA | 2:d53d74ed68ac | 348 | |
AndyA | 6:e57d6e9313f4 | 349 | reconnectStream(stream); |
AndyA | 5:fc8eefeb301b | 350 | // need to prefix with the length so print it once to get the content lenght and then a second time with the prefix. |
AndyA | 6:e57d6e9313f4 | 351 | int len = snprintf(buffer,k_bufferSize,"{\"x\": %.3f, \"y\": %.3f}\n", x,y); |
AndyA | 6:e57d6e9313f4 | 352 | len = snprintf(buffer,k_bufferSize,"%x\r\n{\"x\": %.3f, \"y\": %.3f}\n\r\n",len, x,y); |
AndyA | 6:e57d6e9313f4 | 353 | sendFormatedText(buffer,len,stream); |
AndyA | 0:96532c59670f | 354 | } |
AndyA | 0:96532c59670f | 355 | |
AndyA | 6:e57d6e9313f4 | 356 | |
AndyA | 6:e57d6e9313f4 | 357 | bool plotly::print_(int d, int stream) |
AndyA | 0:96532c59670f | 358 | { |
AndyA | 4:33006c37c633 | 359 | char smallBuffer[10]; |
AndyA | 4:33006c37c633 | 360 | int32_t len = snprintf(smallBuffer,10,"%d",d); |
AndyA | 7:9409a72ab6c0 | 361 | return sendFormatedText(smallBuffer,len,stream); |
AndyA | 2:d53d74ed68ac | 362 | } |
AndyA | 1:d532e96fca12 | 363 | |
AndyA | 6:e57d6e9313f4 | 364 | bool plotly::print_(unsigned long d, int stream) |
AndyA | 0:96532c59670f | 365 | { |
AndyA | 4:33006c37c633 | 366 | char smallBuffer[12]; |
AndyA | 4:33006c37c633 | 367 | int32_t len = snprintf(smallBuffer,12,"%lu",d); |
AndyA | 7:9409a72ab6c0 | 368 | return sendFormatedText(smallBuffer,len,stream); |
AndyA | 2:d53d74ed68ac | 369 | } |
AndyA | 2:d53d74ed68ac | 370 | |
AndyA | 6:e57d6e9313f4 | 371 | bool plotly::print_(float d, int stream) |
AndyA | 2:d53d74ed68ac | 372 | { |
AndyA | 4:33006c37c633 | 373 | char smallBuffer[12]; |
AndyA | 4:33006c37c633 | 374 | int32_t len = snprintf(smallBuffer,12,"%f",d); |
AndyA | 7:9409a72ab6c0 | 375 | return sendFormatedText(smallBuffer,len,stream); |
AndyA | 2:d53d74ed68ac | 376 | } |
AndyA | 2:d53d74ed68ac | 377 | |
AndyA | 7:9409a72ab6c0 | 378 | bool plotly::printNetTerminator_(int stream) |
AndyA | 4:33006c37c633 | 379 | { |
AndyA | 7:9409a72ab6c0 | 380 | return sendFormatedText("\r\n",2,stream); |
AndyA | 4:33006c37c633 | 381 | } |
AndyA | 4:33006c37c633 | 382 | |
AndyA | 4:33006c37c633 | 383 | |
AndyA | 7:9409a72ab6c0 | 384 | |
AndyA | 7:9409a72ab6c0 | 385 | bool plotly::print_(const char *d, int stream)// strings could be long, use the big buffer |
AndyA | 2:d53d74ed68ac | 386 | { |
AndyA | 2:d53d74ed68ac | 387 | int32_t len = snprintf(buffer,k_bufferSize,"%s",d); |
AndyA | 6:e57d6e9313f4 | 388 | return sendFormatedText(buffer,len,stream); |
AndyA | 2:d53d74ed68ac | 389 | } |
AndyA | 2:d53d74ed68ac | 390 | |
AndyA | 6:e57d6e9313f4 | 391 | bool plotly::printHex_(uint16_t d, int stream) |
AndyA | 2:d53d74ed68ac | 392 | { |
AndyA | 2:d53d74ed68ac | 393 | int32_t len = snprintf(buffer,k_bufferSize,"%X",d); |
AndyA | 6:e57d6e9313f4 | 394 | return sendFormatedText(buffer,len,stream); |
AndyA | 2:d53d74ed68ac | 395 | } |
AndyA | 2:d53d74ed68ac | 396 | |
AndyA | 6:e57d6e9313f4 | 397 | bool plotly::sendFormatedText(char* data, int size, int stream) |
AndyA | 2:d53d74ed68ac | 398 | { |
AndyA | 2:d53d74ed68ac | 399 | if(log_level < 2) { |
AndyA | 2:d53d74ed68ac | 400 | fprintf(stderr,"%s",data); |
AndyA | 2:d53d74ed68ac | 401 | } |
AndyA | 1:d532e96fca12 | 402 | if(!dry_run) { |
AndyA | 6:e57d6e9313f4 | 403 | if (!*(sockets+stream)) { |
AndyA | 2:d53d74ed68ac | 404 | fprintf(stderr,"\nTX failed, No network socket exists\n"); |
AndyA | 2:d53d74ed68ac | 405 | return false; |
AndyA | 6:e57d6e9313f4 | 406 | } |
AndyA | 6:e57d6e9313f4 | 407 | if (!((*(sockets+stream))->is_connected())) { |
AndyA | 2:d53d74ed68ac | 408 | fprintf(stderr,"\nTX failed, Network socket not connected\n"); |
AndyA | 6:e57d6e9313f4 | 409 | return false; |
AndyA | 6:e57d6e9313f4 | 410 | } |
AndyA | 6:e57d6e9313f4 | 411 | |
AndyA | 6:e57d6e9313f4 | 412 | int32_t sent = (*(sockets+stream))->send_all(data,size); |
AndyA | 2:d53d74ed68ac | 413 | if (sent == size) |
AndyA | 1:d532e96fca12 | 414 | return true; |
AndyA | 1:d532e96fca12 | 415 | else { |
AndyA | 2:d53d74ed68ac | 416 | fprintf(stderr,"\nTX failed to send _%s_ Sent %d of %d bytes\n",data,sent,size); |
AndyA | 1:d532e96fca12 | 417 | return false; |
AndyA | 1:d532e96fca12 | 418 | } |
AndyA | 1:d532e96fca12 | 419 | } else |
AndyA | 1:d532e96fca12 | 420 | return true; |
AndyA | 0:96532c59670f | 421 | } |
AndyA | 0:96532c59670f | 422 |