OutputPachube.cpp

00001 /** IoT Gateway Output definition for Pachube
00002  *
00003  * @author Andrew Lindsay
00004  *
00005  * @section LICENSE
00006  *
00007  * Copyright (c) 2012 Andrew Lindsay (andrew [at] thiseldo [dot] co [dot] uk)
00008  *
00009  * Permission is hereby granted, free of charge, to any person obtaining a copy
00010  * of this software and associated documentation files (the "Software"), to deal
00011  * in the Software without restriction, including without limitation the rights
00012  * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
00013  * copies of the Software, and to permit persons to whom the Software is
00014  * furnished to do so, subject to the following conditions:
00015 
00016  * The above copyright notice and this permission notice shall be included in
00017  * all copies or substantial portions of the Software.
00018  * 
00019  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
00020  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
00021  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
00022  * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
00023  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
00024  * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
00025  * THE SOFTWARE.
00026  * 
00027  * @section DESCRIPTION
00028  * 
00029  * 
00030  */
00031 
00032 #include "mbed.h"
00033 #include "OutputPachube.h"
00034 
00035 DigitalOut activityLED(p29, "activityLED");
00036 
00037 // Constructor
00038 OutputPachube::OutputPachube() {
00039     sendCount = 0;
00040 }
00041 
00042 /** Alternative Constructor
00043   */
00044 OutputPachube::OutputPachube( char *internalBufferStart, char *url, char *key ) {
00045     sendCount = 0;
00046     dataBuffer = internalBufferStart;
00047     apiUrl = url;
00048     apiKey = key;
00049     dbufPtr = dataBuffer;
00050     *dbufPtr = '\0';
00051 }
00052     
00053 
00054 void OutputPachube::init( ) {
00055     dbufPtr = dataBuffer;
00056     *dbufPtr = '\0';
00057 }
00058 
00059 void OutputPachube::addReading(char *dataFeed, char *dataStream, char *reading ) {
00060     char tmpBuf[20];
00061     int thisFeed = atoi( dataFeed );
00062 
00063     if ( thisFeed != currentFeed )
00064         send();
00065 
00066     currentFeed = thisFeed;
00067     snprintf(tmpBuf, DATABUF_SIZE, "%s,%s\n", dataStream, reading);
00068     strcat( dataBuffer, tmpBuf );
00069 }
00070 
00071 
00072 int OutputPachube::send( void ) {
00073     char urlBuf[API_URL_LENGTH];
00074     HTTPClient http;
00075 
00076     if ( strlen( dataBuffer ) > 1 ) {
00077         http.setRequestHeader("X-PachubeApiKey", apiKey);
00078 
00079         HTTPText csvContent("text/csv");
00080         // Get the string for Pachube
00081         csvContent.set(std::string(dataBuffer));
00082 
00083         // uri for post includes feed ID and datastream ID
00084         snprintf(urlBuf, API_URL_LENGTH, apiUrl, currentFeed );
00085 //        printf("URL: %s\n",urlBuf);
00086 
00087 
00088         activityLED = 1;
00089         // result should be 0 and response should be 200 for successful post
00090         sendCount++;
00091 //        printf("Pachube Send count %d\n", sendCount);
00092 
00093 /*        printf("\nHEAP STATS\n");
00094         __heapstats((__heapprt)fprintf,stderr);
00095         printf("\nHEAP CHECK\n");
00096         __heapvalid((__heapprt)fprintf,stderr, 0);
00097         printf("\nStackP: %ld\n",__current_sp());
00098         printf("---------------\n");
00099 */
00100         HTTPResult result = http.post(urlBuf, csvContent, NULL);
00101         int response = http.getHTTPResponseCode();
00102 //        printf("updateDataStream(%d)\n", response );
00103         activityLED = 0;
00104     }
00105 
00106     dbufPtr = dataBuffer;
00107     *dbufPtr = '\0';
00108     
00109     return 0;
00110 }
00111 
00112 
00113 int OutputPachube::getSendCount( void ) {
00114     return sendCount;
00115 }