MBED_DEMOS / SalesforceInterface

Salesforce.com interface to directly access Salesforce.com

Dependencies:   HTTPClient-SSL MbedJSONValue

Dependents:   df-2014-salesforce-hrm-k64f

Fork of SalesforceInterface by Doug Anson

SalesforceInterface.cpp@18:7dc9b949bbc3, 2014-09-24 (annotated)

Committer:
ansond
Date:
Wed Sep 24 04:13:17 2014 +0000
Revision:
18:7dc9b949bbc3
Parent:
17:6c774354b599
Child:
19:6a791e5449b3
updates for hrm

Who changed what in which revision?

UserRevisionLine numberNew contents of line
ansond 0:518b1ca956fc 1 /* Copyright C2014 ARM, MIT License
ansond 0:518b1ca956fc 2 *
ansond 9:a254fcd904be 3 * Author: Doug Anson (doug.anson@arm.com)
ansond 9:a254fcd904be 4 *
ansond 0:518b1ca956fc 5 * Permission is hereby granted, free of charge, to any person obtaining a copy of this software
ansond 0:518b1ca956fc 6 * and associated documentation files the "Software", to deal in the Software without restriction,
ansond 0:518b1ca956fc 7 * including without limitation the rights to use, copy, modify, merge, publish, distribute,
ansond 0:518b1ca956fc 8 * sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is
ansond 0:518b1ca956fc 9 * furnished to do so, subject to the following conditions:
ansond 0:518b1ca956fc 10 *
ansond 0:518b1ca956fc 11 * The above copyright notice and this permission notice shall be included in all copies or
ansond 0:518b1ca956fc 12 * substantial portions of the Software.
ansond 0:518b1ca956fc 13 *
ansond 16:3d160f224084 14 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING
ansond 0:518b1ca956fc 15 * BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
ansond 0:518b1ca956fc 16 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
ansond 0:518b1ca956fc 17 * DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
ansond 0:518b1ca956fc 18 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
ansond 0:518b1ca956fc 19 */
ansond 0:518b1ca956fc 20
ansond 0:518b1ca956fc 21 // Tuneables
ansond 0:518b1ca956fc 22 #define SF_OAUTH_TOKEN_URL "https://login.salesforce.com/services/oauth2/token"
ansond 0:518b1ca956fc 23 #define SF_OAUTH_REQUEST_BODY "grant_type=password&client_id=%s&client_secret=%s&username=%s&password=%s"
ansond 0:518b1ca956fc 24 #define SF_HTTP_AUTH_HEADER "Authorization: Bearer %s"
ansond 0:518b1ca956fc 25
ansond 15:89044c68ad36 26 // search tokens for URLS in salesforce token
ansond 8:47db53cd5884 27 #define SF_URLS_START_TOKEN "\"urls\":"
ansond 8:47db53cd5884 28 #define SF_URLS_STOP_TOKEN "},"
ansond 8:47db53cd5884 29
ansond 8:47db53cd5884 30 // salesforce QUERY specifier within URL
ansond 8:47db53cd5884 31 #define SF_QUERY_URL_SPECIFIER "q="
ansond 8:47db53cd5884 32
ansond 8:47db53cd5884 33 // salesforce URL API version token
ansond 8:47db53cd5884 34 #define SF_URL_API_VER_TOKEN "{version}"
ansond 8:47db53cd5884 35
ansond 17:6c774354b599 36 // HTTP response code to give for errored out conditions
ansond 17:6c774354b599 37 #define SF_GEN_ERR_HTTP_CODE 500
ansond 17:6c774354b599 38
ansond 0:518b1ca956fc 39 // include class definition
ansond 0:518b1ca956fc 40 #include "SalesforceInterface.h"
ansond 0:518b1ca956fc 41
ansond 0:518b1ca956fc 42 // Supported DataTypes for HTTPClient
ansond 0:518b1ca956fc 43 #include "HTTPMap.h"
ansond 0:518b1ca956fc 44 #include "HTTPJson.h"
ansond 0:518b1ca956fc 45
ansond 0:518b1ca956fc 46 // default constructor
ansond 0:518b1ca956fc 47 SalesforceInterface::SalesforceInterface(ErrorHandler *logger,HTTPClient *http) {
ansond 0:518b1ca956fc 48 this->m_logger = logger;
ansond 0:518b1ca956fc 49 this->m_http = http;
ansond 0:518b1ca956fc 50 this->m_username = NULL;
ansond 0:518b1ca956fc 51 this->m_password = NULL;
ansond 0:518b1ca956fc 52 this->m_client_id = NULL;
ansond 0:518b1ca956fc 53 this->m_client_secret = NULL;
ansond 0:518b1ca956fc 54 this->m_have_creds = false;
ansond 7:97ea5ef906f7 55 this->m_http_status = HTTP_OK;
ansond 7:97ea5ef906f7 56 this->m_http_response_code = -1;
ansond 7:97ea5ef906f7 57 RESET_BUFFER(this->m_http_redirection_url);
ansond 18:7dc9b949bbc3 58 RESET_SML_BUFFER(this->m_error_buffer);
ansond 8:47db53cd5884 59 memset(this->m_salesforce_api,0,SALESFORCE_API_VERSION_LENGTH);
ansond 8:47db53cd5884 60 strcpy(this->m_salesforce_api,SALESFORCE_API_VERSION);
ansond 14:3c8d11b48814 61 this->resetSalesforceToken();
ansond 0:518b1ca956fc 62 }
ansond 0:518b1ca956fc 63
ansond 0:518b1ca956fc 64 // destructor
ansond 0:518b1ca956fc 65 SalesforceInterface::~SalesforceInterface() {
ansond 0:518b1ca956fc 66 }
ansond 0:518b1ca956fc 67
ansond 0:518b1ca956fc 68 // set credentials
ansond 0:518b1ca956fc 69 void SalesforceInterface::setCredentials(char *username,char *password,char *client_id,char *client_secret) {
ansond 0:518b1ca956fc 70 this->m_username = NULL;
ansond 0:518b1ca956fc 71 this->m_password = NULL;
ansond 0:518b1ca956fc 72 this->m_client_id = NULL;
ansond 0:518b1ca956fc 73 this->m_client_secret = NULL;
ansond 0:518b1ca956fc 74 this->m_have_creds = false;
ansond 0:518b1ca956fc 75
ansond 0:518b1ca956fc 76 if (username != NULL) {
ansond 0:518b1ca956fc 77 this->m_username = username;
ansond 0:518b1ca956fc 78 if (password != NULL) {
ansond 0:518b1ca956fc 79 this->m_password = password;
ansond 0:518b1ca956fc 80 if (client_id != NULL) {
ansond 0:518b1ca956fc 81 this->m_client_id = client_id;
ansond 0:518b1ca956fc 82 if (client_secret != NULL) {
ansond 0:518b1ca956fc 83 this->m_client_secret = client_secret;
ansond 0:518b1ca956fc 84 this->m_have_creds = true;
ansond 0:518b1ca956fc 85 }
ansond 0:518b1ca956fc 86 }
ansond 0:518b1ca956fc 87 }
ansond 0:518b1ca956fc 88 }
ansond 0:518b1ca956fc 89 }
ansond 0:518b1ca956fc 90
ansond 0:518b1ca956fc 91 // convenience accessors
ansond 0:518b1ca956fc 92 ErrorHandler *SalesforceInterface::logger() { return this->m_logger; }
ansond 0:518b1ca956fc 93 HTTPClient *SalesforceInterface::http() { return this->m_http; }
ansond 7:97ea5ef906f7 94 OauthToken *SalesforceInterface::oauth() { return &this->m_oauth_token; }
ansond 0:518b1ca956fc 95 bool SalesforceInterface::haveCreds() { return this->m_have_creds; }
ansond 7:97ea5ef906f7 96 HTTPResult SalesforceInterface::httpStatus() { return this->m_http_status; }
ansond 7:97ea5ef906f7 97 int SalesforceInterface::httpResponseCode() { return this->m_http_response_code; }
ansond 8:47db53cd5884 98 void SalesforceInterface::setSalesforceAPIVersion(int version) { sprintf(this->m_salesforce_api,"%d",version); }
ansond 8:47db53cd5884 99 void SalesforceInterface::setSalesforceAPIVersion(char *version) { if (version != NULL && strlen(version) > 0 && strlen(version) < SALESFORCE_API_VERSION_LENGTH) strcpy(this->m_salesforce_api,version); }
ansond 8:47db53cd5884 100 char *SalesforceInterface::getSalesforceAPIVersion() { return this->m_salesforce_api; }
ansond 7:97ea5ef906f7 101
ansond 7:97ea5ef906f7 102 // reset our oauth token
ansond 7:97ea5ef906f7 103 void SalesforceInterface::resetOauthToken() {
ansond 9:a254fcd904be 104 DEBUG("resetting OAUTH token...");
ansond 7:97ea5ef906f7 105 this->m_oauth_token.valid = false;
ansond 7:97ea5ef906f7 106 this->m_oauth_token.id = "";
ansond 7:97ea5ef906f7 107 this->m_oauth_token.issued_at = "";
ansond 7:97ea5ef906f7 108 this->m_oauth_token.token_type = "";
ansond 7:97ea5ef906f7 109 this->m_oauth_token.instance_url = "";
ansond 7:97ea5ef906f7 110 this->m_oauth_token.signature = "";
ansond 7:97ea5ef906f7 111 this->m_oauth_token.access_token = "";
ansond 9:a254fcd904be 112 if (this->http() != NULL) this->http()->oauthToken(NULL);
ansond 7:97ea5ef906f7 113 }
ansond 7:97ea5ef906f7 114
ansond 7:97ea5ef906f7 115 // fill our oauth token
ansond 7:97ea5ef906f7 116 void SalesforceInterface::fillOauthToken(char *token) {
ansond 7:97ea5ef906f7 117 if (token != NULL && strlen(token) > 0) {
ansond 7:97ea5ef906f7 118 // parse JSON
ansond 7:97ea5ef906f7 119 MbedJSONValue parsed_token;
ansond 7:97ea5ef906f7 120 parse(parsed_token,token);
ansond 7:97ea5ef906f7 121
ansond 7:97ea5ef906f7 122 // fill our OAUTH token
ansond 7:97ea5ef906f7 123 this->m_oauth_token.id = parsed_token["id"].get<std::string>();
ansond 7:97ea5ef906f7 124 this->m_oauth_token.issued_at = parsed_token["issued_at"].get<std::string>();
ansond 7:97ea5ef906f7 125 this->m_oauth_token.token_type = parsed_token["token_type"].get<std::string>();
ansond 7:97ea5ef906f7 126 this->m_oauth_token.instance_url = parsed_token["instance_url"].get<std::string>();
ansond 7:97ea5ef906f7 127 this->m_oauth_token.signature = parsed_token["signature"].get<std::string>();
ansond 7:97ea5ef906f7 128 this->m_oauth_token.access_token = parsed_token["access_token"].get<std::string>();
ansond 7:97ea5ef906f7 129
ansond 7:97ea5ef906f7 130 // we have an OAUTH token now
ansond 7:97ea5ef906f7 131 this->m_oauth_token.valid = true;
ansond 7:97ea5ef906f7 132 DEBUG("valid OAUTH token acquired.");
ansond 7:97ea5ef906f7 133 return;
ansond 7:97ea5ef906f7 134 }
ansond 7:97ea5ef906f7 135 DEBUG("error: invalid or null OAUTH token fill attempt.");
ansond 7:97ea5ef906f7 136 }
ansond 7:97ea5ef906f7 137
ansond 7:97ea5ef906f7 138 // is our OAUTH token valid?
ansond 9:a254fcd904be 139 bool SalesforceInterface::validOauthToken(bool fetch) {
ansond 7:97ea5ef906f7 140 // make sure we have a valid OAUTH Token
ansond 9:a254fcd904be 141 this->checkAndGetOauthToken(fetch);
ansond 7:97ea5ef906f7 142 return this->m_oauth_token.valid;
ansond 8:47db53cd5884 143 }
ansond 9:a254fcd904be 144
ansond 15:89044c68ad36 145 // reset our salesforce token and OAUTH tokens
ansond 14:3c8d11b48814 146 void SalesforceInterface::resetSalesforceToken() {
ansond 9:a254fcd904be 147 this->resetOauthToken();
ansond 9:a254fcd904be 148 RESET_BUFFER(this->m_salesforce_id);
ansond 9:a254fcd904be 149 }
ansond 8:47db53cd5884 150
ansond 15:89044c68ad36 151 // do we have a valid salesforce.com token?
ansond 14:3c8d11b48814 152 bool SalesforceInterface::haveSalesforceToken(bool fetch) {
ansond 8:47db53cd5884 153 if (this->m_salesforce_id != NULL && strlen(this->m_salesforce_id) > 0) return true;
ansond 9:a254fcd904be 154 if (fetch) {
ansond 14:3c8d11b48814 155 this->logger()->log("No Salesforce Token found... fetching...");
ansond 14:3c8d11b48814 156 this->getSalesforceToken();
ansond 14:3c8d11b48814 157 return this->haveSalesforceToken(false);
ansond 9:a254fcd904be 158 }
ansond 8:47db53cd5884 159 return false;
ansond 8:47db53cd5884 160 }
ansond 7:97ea5ef906f7 161
ansond 7:97ea5ef906f7 162 // check and get our OAUTH token
ansond 9:a254fcd904be 163 void SalesforceInterface::checkAndGetOauthToken(bool fetch) {
ansond 7:97ea5ef906f7 164 DEBUG("checking for valid OAUTH token...");
ansond 9:a254fcd904be 165
ansond 9:a254fcd904be 166 // reset the token structure for sanity...
ansond 9:a254fcd904be 167 if (this->m_oauth_token.valid == false) this->resetOauthToken();
ansond 9:a254fcd904be 168
ansond 9:a254fcd904be 169 // should go fetch our token if we dont have one?
ansond 9:a254fcd904be 170 // just pass through if we already have a token
ansond 9:a254fcd904be 171 if (this->m_oauth_token.valid == true) {
ansond 9:a254fcd904be 172 DEBUG("valid OAUTH token found.");
ansond 9:a254fcd904be 173 }
ansond 9:a254fcd904be 174 else if (this->m_oauth_token.valid == false && fetch == true) {
ansond 9:a254fcd904be 175 // get our OAUTH token
ansond 9:a254fcd904be 176 DEBUG("No OAUTH token found. Acquiring OAUTH token...");
ansond 7:97ea5ef906f7 177 ALLOC_BUFFER(output_buffer);
ansond 7:97ea5ef906f7 178 char *token = this->getOauthToken(output_buffer,MAX_BUFFER_LENGTH);
ansond 9:a254fcd904be 179 if (token != NULL && strlen(token) > 0) {
ansond 9:a254fcd904be 180 // fill
ansond 9:a254fcd904be 181 DEBUG("Saving OAUTH token...");
ansond 9:a254fcd904be 182 this->fillOauthToken(token);
ansond 9:a254fcd904be 183 return;
ansond 9:a254fcd904be 184 }
ansond 9:a254fcd904be 185 else {
ansond 9:a254fcd904be 186 // unable to get the token (reset for sanity)
ansond 9:a254fcd904be 187 this->logger()->log("error in acquiring OAUTH token http_code=%d status=%d",this->httpResponseCode(),this->httpStatus());
ansond 9:a254fcd904be 188 this->resetOauthToken();
ansond 9:a254fcd904be 189 }
ansond 7:97ea5ef906f7 190 }
ansond 9:a254fcd904be 191
ansond 9:a254fcd904be 192 // else report that we dont have a token
ansond 9:a254fcd904be 193 else {
ansond 9:a254fcd904be 194 this->logger()->log("No OAUTH token found (fetch=false).");
ansond 9:a254fcd904be 195 }
ansond 9:a254fcd904be 196 }
ansond 0:518b1ca956fc 197
ansond 0:518b1ca956fc 198 //
ansond 0:518b1ca956fc 199 // get OAUTH2 Token - taken from here:
ansond 0:518b1ca956fc 200 // https://developer.salesforce.com/page/Digging_Deeper_into_OAuth_2.0_on_Force.com#Obtaining_a_Token_in_an_Autonomous_Client_.28Username_and_Password_Flow.29
ansond 0:518b1ca956fc 201 //
ansond 0:518b1ca956fc 202 char *SalesforceInterface::getOauthToken(char *output_buffer,int output_buffer_length) {
ansond 1:a7dca096e47d 203 if (this->haveCreds()) {
ansond 0:518b1ca956fc 204 // construct the OAUTH2 Token request body
ansond 0:518b1ca956fc 205 HTTPMap input;
ansond 0:518b1ca956fc 206
ansond 0:518b1ca956fc 207 //
ansond 0:518b1ca956fc 208 // FORMAT: Taken from URL above method signature:
ansond 0:518b1ca956fc 209 //
ansond 0:518b1ca956fc 210 // grant_type=password&client_id=<your_client_id>&client_secret=<your_client_secret>&username=<your_username>&password=<your_password>
ansond 0:518b1ca956fc 211 //
ansond 0:518b1ca956fc 212 // ContentType: application/x-www-form-urlencoded
ansond 0:518b1ca956fc 213 //
ansond 0:518b1ca956fc 214 input.put("grant_type","password");
ansond 0:518b1ca956fc 215 input.put("client_id",this->m_client_id);
ansond 0:518b1ca956fc 216 input.put("client_secret",this->m_client_secret);
ansond 0:518b1ca956fc 217 input.put("username",this->m_username);
ansond 0:518b1ca956fc 218 input.put("password",this->m_password);
ansond 1:a7dca096e47d 219
ansond 0:518b1ca956fc 220 // prepare the output buffer
ansond 0:518b1ca956fc 221 HTTPText output(output_buffer,output_buffer_length);
ansond 0:518b1ca956fc 222
ansond 0:518b1ca956fc 223 // HTTP POST call to gett he token
ansond 7:97ea5ef906f7 224 DEBUG("Getting OAUTH Token...");
ansond 7:97ea5ef906f7 225 this->m_http_status = this->http()->post(SF_OAUTH_TOKEN_URL,input,&output);
ansond 7:97ea5ef906f7 226
ansond 0:518b1ca956fc 227 // check the result and return the token
ansond 9:a254fcd904be 228 if (this->httpStatus() == HTTP_OK || this->httpResponseCode() == 200) return output_buffer;
ansond 9:a254fcd904be 229 this->logger()->log("acquire oauth FAILED. URL: %s http_code=%d status=%d",SF_OAUTH_TOKEN_URL,this->httpResponseCode(),this->httpStatus());
ansond 0:518b1ca956fc 230 }
ansond 0:518b1ca956fc 231 else {
ansond 0:518b1ca956fc 232 // no credentials
ansond 0:518b1ca956fc 233 this->logger()->log("no/incomplete salesforce.com credentials provided. Unable to acquire OAUTH2 token...");
ansond 0:518b1ca956fc 234 }
ansond 0:518b1ca956fc 235 return NULL;
ansond 0:518b1ca956fc 236 }
ansond 0:518b1ca956fc 237
ansond 15:89044c68ad36 238 // Salesforce.com: Get our token
ansond 14:3c8d11b48814 239 char *SalesforceInterface::getSalesforceToken(bool fetch) {
ansond 7:97ea5ef906f7 240 // proceed only if we have a valid OAUTH Token
ansond 9:a254fcd904be 241 if (this->validOauthToken(fetch) == true) {
ansond 15:89044c68ad36 242 // pull the token from salesforce
ansond 8:47db53cd5884 243 RESET_BUFFER(this->m_salesforce_id);
ansond 8:47db53cd5884 244 char *id = this->invoke(this->oauth()->id.c_str(),this->m_salesforce_id,MAX_BUFFER_LENGTH);
ansond 7:97ea5ef906f7 245
ansond 7:97ea5ef906f7 246 // log any error status and return what we have...
ansond 14:3c8d11b48814 247 if (this->httpStatus() != HTTP_OK) this->logger()->log("Unable to get Salesforce Token: status=%d httpCode=%d",this->httpStatus(),this->httpResponseCode());
ansond 7:97ea5ef906f7 248 return id;
ansond 7:97ea5ef906f7 249 }
ansond 7:97ea5ef906f7 250 else {
ansond 15:89044c68ad36 251 // unable to get token - no OAUTH token
ansond 14:3c8d11b48814 252 this->logger()->log("Unable to get Salesforce Token: no valid OAUTH token.");
ansond 7:97ea5ef906f7 253 }
ansond 7:97ea5ef906f7 254 return NULL;
ansond 7:97ea5ef906f7 255 }
ansond 7:97ea5ef906f7 256
ansond 8:47db53cd5884 257 // QUERY: Salesforce.com
ansond 8:47db53cd5884 258 char *SalesforceInterface::query(char *query_str,char *output_buffer,int output_buffer_length) {
ansond 15:89044c68ad36 259 // first we have to ensure that we have valid salesforce token
ansond 14:3c8d11b48814 260 if (this->haveSalesforceToken()) {
ansond 9:a254fcd904be 261 // get the query url
ansond 8:47db53cd5884 262 ALLOC_BUFFER(url);
ansond 8:47db53cd5884 263 char *sf_url = this->getSalesforceURL("query",url,MAX_BUFFER_LENGTH);
ansond 8:47db53cd5884 264 if (sf_url != NULL && strlen(sf_url) > 0) {
ansond 8:47db53cd5884 265 // make sure that the query string is ready to ship...
ansond 8:47db53cd5884 266 ALLOC_SML_BUFFER(tmp_query);
ansond 8:47db53cd5884 267
ansond 8:47db53cd5884 268 // replace all spaces in query with "+"
ansond 8:47db53cd5884 269 strcpy(tmp_query,query_str);
ansond 8:47db53cd5884 270 this->replace(tmp_query,' ','+'); // will modify tmp_query directly...
ansond 8:47db53cd5884 271
ansond 8:47db53cd5884 272 // customize the URL with our (formatted) query string
ansond 8:47db53cd5884 273 string str_url(sf_url);
ansond 8:47db53cd5884 274 str_url[str_url.length()-1] = '?'; // remove the slash and add a ?
ansond 8:47db53cd5884 275 str_url = str_url + SF_QUERY_URL_SPECIFIER + tmp_query; // add the query specifier
ansond 8:47db53cd5884 276
ansond 8:47db53cd5884 277 // DEBUG - show the query URL
ansond 8:47db53cd5884 278 DEBUG("query URL: %s",str_url.c_str());
ansond 8:47db53cd5884 279
ansond 8:47db53cd5884 280 // invoke with GET
ansond 8:47db53cd5884 281 return this->invoke((const char *)str_url.c_str(),output_buffer,output_buffer_length);
ansond 8:47db53cd5884 282 }
ansond 8:47db53cd5884 283 else {
ansond 8:47db53cd5884 284 // unable to find the query URL...
ansond 15:89044c68ad36 285 this->logger()->log("query: error - unable to find query URL in salesforce token...");
ansond 8:47db53cd5884 286 }
ansond 8:47db53cd5884 287 }
ansond 8:47db53cd5884 288 else {
ansond 15:89044c68ad36 289 // dont have a valid salesforce token
ansond 15:89044c68ad36 290 this->logger()->log("query: error - no valid salesforced token was found...");
ansond 8:47db53cd5884 291 }
ansond 8:47db53cd5884 292 return NULL;
ansond 8:47db53cd5884 293 }
ansond 8:47db53cd5884 294
ansond 14:3c8d11b48814 295 // CREATE: a record in Salesforce.com
ansond 14:3c8d11b48814 296 MbedJSONValue SalesforceInterface::createRecord(char *object_name,MbedJSONValue &record) {
ansond 9:a254fcd904be 297 ALLOC_BUFFER(output_buffer);
ansond 14:3c8d11b48814 298 char *reply = this->createRecord(object_name,(char *)record.serialize().c_str(),output_buffer,MAX_BUFFER_LENGTH);
ansond 9:a254fcd904be 299 MbedJSONValue response;
ansond 9:a254fcd904be 300 if (reply != NULL && strlen(reply) > 0) parse(response,reply);
ansond 9:a254fcd904be 301 return response;
ansond 9:a254fcd904be 302 }
ansond 9:a254fcd904be 303
ansond 14:3c8d11b48814 304 // READ: a specific record in Salesforce.com
ansond 16:3d160f224084 305 MbedJSONValue SalesforceInterface::readRecord(char *object_name,char *record_id,char *record_value) {
ansond 9:a254fcd904be 306 ALLOC_BUFFER(output_buffer);
ansond 16:3d160f224084 307 char *reply = this->readRecord(object_name,record_id,record_value,output_buffer,MAX_BUFFER_LENGTH);
ansond 9:a254fcd904be 308 MbedJSONValue response;
ansond 9:a254fcd904be 309 if (reply != NULL && strlen(reply) > 0) parse(response,reply);
ansond 9:a254fcd904be 310 return response;
ansond 9:a254fcd904be 311 }
ansond 9:a254fcd904be 312
ansond 14:3c8d11b48814 313 // UPDATE: a specific record in Salesforce.com
ansond 14:3c8d11b48814 314 bool SalesforceInterface::updateRecord(char *object_name,char *record_id,MbedJSONValue &record) {
ansond 18:7dc9b949bbc3 315 RESET_SML_BUFFER(this->m_error_buffer);
ansond 18:7dc9b949bbc3 316 return this->updateRecord(object_name,record_id,(char *)record.serialize().c_str(),this->m_error_buffer,MAX_SMALL_BUFFER_LENGTH);
ansond 9:a254fcd904be 317 }
ansond 9:a254fcd904be 318
ansond 16:3d160f224084 319 // UPSERT: update/insert an External ID record in Salesforce.com
ansond 16:3d160f224084 320 bool SalesforceInterface::upsertRecord(char *object_name,char *external_id_field_name,char *external_id_field_value,MbedJSONValue &record) {
ansond 18:7dc9b949bbc3 321 RESET_SML_BUFFER(this->m_error_buffer);
ansond 18:7dc9b949bbc3 322 return this->upsertRecord(object_name,external_id_field_name,external_id_field_value,(char *)record.serialize().c_str(),this->m_error_buffer,MAX_SMALL_BUFFER_LENGTH);
ansond 18:7dc9b949bbc3 323 }
ansond 18:7dc9b949bbc3 324
ansond 18:7dc9b949bbc3 325 // DELETE: a specific record in Salesforce.com
ansond 18:7dc9b949bbc3 326 bool SalesforceInterface::deleteRecord(char *object_name,char *record_id) {
ansond 18:7dc9b949bbc3 327 RESET_SML_BUFFER(this->m_error_buffer);
ansond 18:7dc9b949bbc3 328 return this->deleteRecord(object_name,record_id,this->m_error_buffer,MAX_SMALL_BUFFER_LENGTH);
ansond 18:7dc9b949bbc3 329 }
ansond 18:7dc9b949bbc3 330
ansond 18:7dc9b949bbc3 331 // ERROR: get last error result
ansond 18:7dc9b949bbc3 332 MbedJSONValue SalesforceInterface::getLastError() {
ansond 18:7dc9b949bbc3 333 MbedJSONValue error;
ansond 18:7dc9b949bbc3 334 if (strlen(this->m_error_buffer) > 0) parse(error,this->m_error_buffer);
ansond 18:7dc9b949bbc3 335 return error;
ansond 16:3d160f224084 336 }
ansond 16:3d160f224084 337
ansond 14:3c8d11b48814 338 // CREATE: a record in Salesforce.com
ansond 14:3c8d11b48814 339 char *SalesforceInterface::createRecord(char *object_name,char *json_data,char *output_buffer,int output_buffer_length) {
ansond 9:a254fcd904be 340 // parameter check
ansond 9:a254fcd904be 341 if (object_name != NULL && strlen(object_name) > 0 && json_data != NULL && strlen(json_data) > 0 && output_buffer != NULL && output_buffer_length > 0) {
ansond 15:89044c68ad36 342 // first we have to ensure that we have valid salesforce token
ansond 14:3c8d11b48814 343 if (this->haveSalesforceToken()) {
ansond 9:a254fcd904be 344 // get the sobjects url
ansond 9:a254fcd904be 345 ALLOC_BUFFER(url);
ansond 9:a254fcd904be 346 char *sf_url = this->getSalesforceURL("sobjects",url,MAX_BUFFER_LENGTH);
ansond 9:a254fcd904be 347 if (sf_url != NULL && strlen(sf_url) > 0) {
ansond 9:a254fcd904be 348 // convert to string
ansond 9:a254fcd904be 349 string str_url(sf_url);
ansond 9:a254fcd904be 350
ansond 14:3c8d11b48814 351 // add object name that we want to create a record in
ansond 9:a254fcd904be 352 str_url += object_name;
ansond 9:a254fcd904be 353
ansond 9:a254fcd904be 354 // DEBUG
ansond 14:3c8d11b48814 355 DEBUG("createRecord: URL: %s DATA: %s",str_url.c_str(),json_data);
ansond 9:a254fcd904be 356
ansond 9:a254fcd904be 357 // now invoke with POST with JSON data type
ansond 9:a254fcd904be 358 return this->invoke(str_url.c_str(),json_data,strlen(json_data)+1,output_buffer,output_buffer_length);
ansond 9:a254fcd904be 359 }
ansond 9:a254fcd904be 360 }
ansond 9:a254fcd904be 361 else {
ansond 15:89044c68ad36 362 // dont have a valid salesforce token
ansond 15:89044c68ad36 363 this->logger()->log("createRecord: error - no valid salesforced token was found...");
ansond 9:a254fcd904be 364 }
ansond 9:a254fcd904be 365 }
ansond 9:a254fcd904be 366 else {
ansond 9:a254fcd904be 367 // invalid or NULL parameters
ansond 14:3c8d11b48814 368 this->logger()->log("createRecord: error - invalid or NULL parameters...");
ansond 9:a254fcd904be 369 }
ansond 17:6c774354b599 370 this->m_http_response_code = SF_GEN_ERR_HTTP_CODE;
ansond 9:a254fcd904be 371 return NULL;
ansond 9:a254fcd904be 372 }
ansond 9:a254fcd904be 373
ansond 14:3c8d11b48814 374 // READ: a specific record in Salesforce.com
ansond 16:3d160f224084 375 char *SalesforceInterface::readRecord(char *object_name,char *record_id,char *record_value,char *output_buffer,int output_buffer_length) {
ansond 9:a254fcd904be 376 // parameter check
ansond 14:3c8d11b48814 377 if (object_name != NULL && strlen(object_name) > 0 && record_id != NULL && strlen(record_id) > 0 && output_buffer != NULL && output_buffer_length > 0) {
ansond 15:89044c68ad36 378 // first we have to ensure that we have valid salesforce token
ansond 14:3c8d11b48814 379 if (this->haveSalesforceToken()) {
ansond 9:a254fcd904be 380 // get the sobjects url
ansond 9:a254fcd904be 381 ALLOC_BUFFER(url);
ansond 9:a254fcd904be 382 char *sf_url = this->getSalesforceURL("sobjects",url,MAX_BUFFER_LENGTH);
ansond 9:a254fcd904be 383 if (sf_url != NULL && strlen(sf_url) > 0) {
ansond 9:a254fcd904be 384 // convert to string
ansond 9:a254fcd904be 385 string str_url(sf_url);
ansond 9:a254fcd904be 386
ansond 14:3c8d11b48814 387 // add object name that we want to create a record in
ansond 9:a254fcd904be 388 str_url += object_name;
ansond 9:a254fcd904be 389
ansond 15:89044c68ad36 390 // add the record token
ansond 9:a254fcd904be 391 str_url += "/";
ansond 14:3c8d11b48814 392 str_url += record_id;
ansond 9:a254fcd904be 393
ansond 16:3d160f224084 394 // add the record value (if present)
ansond 16:3d160f224084 395 if (record_value != NULL && strlen(record_value) > 0) {
ansond 16:3d160f224084 396 str_url += "/";
ansond 16:3d160f224084 397 str_url += record_value;
ansond 16:3d160f224084 398 }
ansond 16:3d160f224084 399
ansond 9:a254fcd904be 400 // DEBUG
ansond 14:3c8d11b48814 401 DEBUG("readRecord: URL: %s",str_url.c_str());
ansond 9:a254fcd904be 402
ansond 9:a254fcd904be 403 // now invoke with GET with JSON data type
ansond 9:a254fcd904be 404 return this->invoke(str_url.c_str(),output_buffer,output_buffer_length);
ansond 9:a254fcd904be 405 }
ansond 9:a254fcd904be 406 }
ansond 9:a254fcd904be 407 else {
ansond 15:89044c68ad36 408 // dont have a valid salesforce token
ansond 15:89044c68ad36 409 this->logger()->log("readRecord: error - no valid salesforced token was found...");
ansond 9:a254fcd904be 410 }
ansond 9:a254fcd904be 411 }
ansond 9:a254fcd904be 412 else {
ansond 9:a254fcd904be 413 // invalid or NULL parameters
ansond 14:3c8d11b48814 414 this->logger()->log("readRecord: error - invalid or NULL parameters...");
ansond 9:a254fcd904be 415 }
ansond 17:6c774354b599 416 this->m_http_response_code = SF_GEN_ERR_HTTP_CODE;
ansond 9:a254fcd904be 417 return NULL;
ansond 9:a254fcd904be 418 }
ansond 9:a254fcd904be 419
ansond 14:3c8d11b48814 420 // UPDATE: a specific record in Salesforce.com
ansond 18:7dc9b949bbc3 421 bool SalesforceInterface::updateRecord(char *object_name,char *record_id,char *json_data,char *output_buffer,int output_buffer_length) {
ansond 9:a254fcd904be 422 // parameter check
ansond 9:a254fcd904be 423 if (object_name != NULL && strlen(object_name) > 0 && json_data != NULL && strlen(json_data) > 0) {
ansond 15:89044c68ad36 424 // first we have to ensure that we have valid salesforce token
ansond 14:3c8d11b48814 425 if (this->haveSalesforceToken()) {
ansond 9:a254fcd904be 426 // get the sobjects url
ansond 9:a254fcd904be 427 ALLOC_BUFFER(url);
ansond 9:a254fcd904be 428 char *sf_url = this->getSalesforceURL("sobjects",url,MAX_BUFFER_LENGTH);
ansond 9:a254fcd904be 429 if (sf_url != NULL && strlen(sf_url) > 0) {
ansond 9:a254fcd904be 430 // convert to string
ansond 9:a254fcd904be 431 string str_url(sf_url);
ansond 9:a254fcd904be 432
ansond 14:3c8d11b48814 433 // add object name that we want to create a record in
ansond 9:a254fcd904be 434 str_url += object_name;
ansond 9:a254fcd904be 435
ansond 15:89044c68ad36 436 // add the record token
ansond 9:a254fcd904be 437 str_url += "/";
ansond 14:3c8d11b48814 438 str_url += record_id;
ansond 9:a254fcd904be 439
ansond 9:a254fcd904be 440 // HTTPClient does not support PATCH, so we have to use POST with a special added parameter
ansond 9:a254fcd904be 441 str_url += "?_HttpMethod=PATCH";
ansond 9:a254fcd904be 442
ansond 9:a254fcd904be 443 // DEBUG
ansond 14:3c8d11b48814 444 DEBUG("updateRecord: URL: %s DATA: %s",str_url.c_str(),json_data);
ansond 9:a254fcd904be 445
ansond 9:a254fcd904be 446 // now invoke with POST with JSON data type
ansond 18:7dc9b949bbc3 447 char *reply = this->invoke(str_url.c_str(),json_data,strlen(json_data)+1,output_buffer,output_buffer_length);
ansond 9:a254fcd904be 448
ansond 9:a254fcd904be 449 // DEBUG
ansond 14:3c8d11b48814 450 DEBUG("updateRecord: http status=%d",this->httpResponseCode());
ansond 9:a254fcd904be 451
ansond 9:a254fcd904be 452 // return our status
ansond 17:6c774354b599 453 if (this->httpResponseCodeInRange(200)) return true;
ansond 9:a254fcd904be 454 return false;
ansond 9:a254fcd904be 455 }
ansond 9:a254fcd904be 456 }
ansond 9:a254fcd904be 457 else {
ansond 15:89044c68ad36 458 // dont have a valid salesforce token
ansond 15:89044c68ad36 459 this->logger()->log("updateRecord: error - no valid salesforced token was found...");
ansond 9:a254fcd904be 460 }
ansond 9:a254fcd904be 461 }
ansond 9:a254fcd904be 462 else {
ansond 9:a254fcd904be 463 // invalid or NULL parameters
ansond 14:3c8d11b48814 464 this->logger()->log("updateRecord: error - invalid or NULL parameters...");
ansond 9:a254fcd904be 465 }
ansond 17:6c774354b599 466 this->m_http_response_code = SF_GEN_ERR_HTTP_CODE;
ansond 9:a254fcd904be 467 return false;
ansond 9:a254fcd904be 468 }
ansond 16:3d160f224084 469
ansond 16:3d160f224084 470 // UPSERT: update/insert a specific External record in Salesforce.com
ansond 18:7dc9b949bbc3 471 bool SalesforceInterface::upsertRecord(char *object_name,char *external_id_field_name,char *external_id_field_value,char *json_data,char *output_buffer,int output_buffer_length) {
ansond 16:3d160f224084 472 // parameter check
ansond 16:3d160f224084 473 if (object_name != NULL && strlen(object_name) > 0 && json_data != NULL && strlen(json_data) > 0) {
ansond 16:3d160f224084 474 // first we have to ensure that we have valid salesforce token
ansond 16:3d160f224084 475 if (this->haveSalesforceToken()) {
ansond 16:3d160f224084 476 // get the sobjects url
ansond 16:3d160f224084 477 ALLOC_BUFFER(url);
ansond 16:3d160f224084 478 char *sf_url = this->getSalesforceURL("sobjects",url,MAX_BUFFER_LENGTH);
ansond 16:3d160f224084 479 if (sf_url != NULL && strlen(sf_url) > 0) {
ansond 16:3d160f224084 480 // convert to string
ansond 16:3d160f224084 481 string str_url(sf_url);
ansond 16:3d160f224084 482
ansond 16:3d160f224084 483 // add object name that we want to create a record in
ansond 16:3d160f224084 484 str_url += object_name;
ansond 16:3d160f224084 485
ansond 16:3d160f224084 486 // add the external field name token
ansond 16:3d160f224084 487 str_url += "/";
ansond 16:3d160f224084 488 str_url += external_id_field_name;
ansond 16:3d160f224084 489
ansond 16:3d160f224084 490 // add the external field value token (if not NULL)
ansond 16:3d160f224084 491 if (external_id_field_value != NULL && strlen(external_id_field_value) > 0) {
ansond 16:3d160f224084 492 str_url += "/";
ansond 16:3d160f224084 493 str_url += external_id_field_value;
ansond 16:3d160f224084 494 }
ansond 16:3d160f224084 495
ansond 16:3d160f224084 496 // HTTPClient does not support PATCH, so we have to use POST with a special added parameter
ansond 16:3d160f224084 497 str_url += "?_HttpMethod=PATCH";
ansond 16:3d160f224084 498
ansond 16:3d160f224084 499 // DEBUG
ansond 16:3d160f224084 500 DEBUG("upsertRecord: URL: %s DATA: %s",str_url.c_str(),json_data);
ansond 16:3d160f224084 501
ansond 16:3d160f224084 502 // now invoke with POST with JSON data type
ansond 18:7dc9b949bbc3 503 char *reply = this->invoke(str_url.c_str(),json_data,strlen(json_data)+1,output_buffer,output_buffer_length);
ansond 16:3d160f224084 504
ansond 16:3d160f224084 505 // DEBUG
ansond 16:3d160f224084 506 DEBUG("upsertRecord: http status=%d",this->httpResponseCode());
ansond 16:3d160f224084 507
ansond 16:3d160f224084 508 // return our status
ansond 17:6c774354b599 509 if (this->httpResponseCodeInRange(200)) return true;
ansond 16:3d160f224084 510 return false;
ansond 16:3d160f224084 511 }
ansond 16:3d160f224084 512 }
ansond 16:3d160f224084 513 else {
ansond 16:3d160f224084 514 // dont have a valid salesforce token
ansond 16:3d160f224084 515 this->logger()->log("upsertRecord: error - no valid salesforced token was found...");
ansond 16:3d160f224084 516 }
ansond 16:3d160f224084 517 }
ansond 16:3d160f224084 518 else {
ansond 16:3d160f224084 519 // invalid or NULL parameters
ansond 16:3d160f224084 520 this->logger()->log("upsertRecord: error - invalid or NULL parameters...");
ansond 16:3d160f224084 521 }
ansond 17:6c774354b599 522 this->m_http_response_code = SF_GEN_ERR_HTTP_CODE;
ansond 16:3d160f224084 523 return false;
ansond 16:3d160f224084 524 }
ansond 9:a254fcd904be 525
ansond 14:3c8d11b48814 526 // DELETE: a specific record in Salesforce.com
ansond 18:7dc9b949bbc3 527 bool SalesforceInterface::deleteRecord(char *object_name,char *record_id,char *output_buffer,int output_buffer_length) {
ansond 9:a254fcd904be 528 // parameter check
ansond 14:3c8d11b48814 529 if (object_name != NULL && strlen(object_name) > 0 && record_id != NULL && strlen(record_id) > 0) {
ansond 15:89044c68ad36 530 // first we have to ensure that we have valid salesforce token
ansond 14:3c8d11b48814 531 if (this->haveSalesforceToken()) {
ansond 9:a254fcd904be 532 // get the sobjects url
ansond 9:a254fcd904be 533 ALLOC_BUFFER(url);
ansond 9:a254fcd904be 534 char *sf_url = this->getSalesforceURL("sobjects",url,MAX_BUFFER_LENGTH);
ansond 9:a254fcd904be 535 if (sf_url != NULL && strlen(sf_url) > 0) {
ansond 9:a254fcd904be 536 // convert to string
ansond 9:a254fcd904be 537 string str_url(sf_url);
ansond 9:a254fcd904be 538
ansond 14:3c8d11b48814 539 // add object name that we want to create a record in
ansond 9:a254fcd904be 540 str_url += object_name;
ansond 9:a254fcd904be 541
ansond 15:89044c68ad36 542 // add the record token
ansond 9:a254fcd904be 543 str_url += "/";
ansond 14:3c8d11b48814 544 str_url += record_id;
ansond 9:a254fcd904be 545
ansond 9:a254fcd904be 546 // DEBUG
ansond 14:3c8d11b48814 547 DEBUG("deleteRecord: URL: %s",str_url.c_str());
ansond 9:a254fcd904be 548
ansond 9:a254fcd904be 549 // now invoke with DELETE
ansond 9:a254fcd904be 550 ALLOC_SML_BUFFER(output_buffer);
ansond 18:7dc9b949bbc3 551 char *reply = this->invoke(str_url.c_str(),output_buffer,output_buffer_length,DELETE);
ansond 9:a254fcd904be 552
ansond 9:a254fcd904be 553 // DEBUG
ansond 14:3c8d11b48814 554 DEBUG("deleteRecord: http status=%d",this->httpResponseCode());
ansond 9:a254fcd904be 555
ansond 9:a254fcd904be 556 // return our status
ansond 17:6c774354b599 557 if (this->httpResponseCodeInRange(200)) return true;
ansond 9:a254fcd904be 558 return false;
ansond 9:a254fcd904be 559 }
ansond 9:a254fcd904be 560 }
ansond 9:a254fcd904be 561 else {
ansond 15:89044c68ad36 562 // dont have a valid salesforce token
ansond 15:89044c68ad36 563 this->logger()->log("deleteRecord: error - no valid salesforced token was found...");
ansond 9:a254fcd904be 564 }
ansond 9:a254fcd904be 565 }
ansond 9:a254fcd904be 566 else {
ansond 9:a254fcd904be 567 // invalid or NULL parameters
ansond 14:3c8d11b48814 568 this->logger()->log("deleteRecord: error - invalid or NULL parameters...");
ansond 9:a254fcd904be 569 }
ansond 17:6c774354b599 570 this->m_http_response_code = SF_GEN_ERR_HTTP_CODE;
ansond 9:a254fcd904be 571 return false;
ansond 9:a254fcd904be 572 }
ansond 9:a254fcd904be 573
ansond 0:518b1ca956fc 574 // Salesforce.com Invoke: defaults to GET
ansond 9:a254fcd904be 575 char *SalesforceInterface::invoke(const char *url,char *output_buffer,int output_buffer_length) {
ansond 9:a254fcd904be 576 return this->invoke(url,output_buffer,output_buffer_length,GET);
ansond 9:a254fcd904be 577 }
ansond 9:a254fcd904be 578
ansond 9:a254fcd904be 579 // Salesforce.com Invoke: GET or DELETE with simple output
ansond 9:a254fcd904be 580 char *SalesforceInterface::invoke(const char *url,char *output_buffer,int output_buffer_length,HttpVerb verb) {
ansond 9:a254fcd904be 581 char *response = NULL;
ansond 9:a254fcd904be 582 switch(verb) {
ansond 9:a254fcd904be 583 case GET:
ansond 9:a254fcd904be 584 case DELETE:
ansond 9:a254fcd904be 585 // GET and DELETE only require an output buffer...
ansond 9:a254fcd904be 586 response = this->invoke(url,NUM_TYPES,NULL,0,output_buffer,output_buffer_length,verb);
ansond 9:a254fcd904be 587 break;
ansond 9:a254fcd904be 588 default:
ansond 9:a254fcd904be 589 // wrong verb for this call interface...
ansond 9:a254fcd904be 590 this->logger()->log("invoke: invalid call: must be either GET or DELETE verb if only output buffer is provided");
ansond 9:a254fcd904be 591 break;
ansond 9:a254fcd904be 592 }
ansond 9:a254fcd904be 593 return response;
ansond 0:518b1ca956fc 594 }
ansond 0:518b1ca956fc 595
ansond 0:518b1ca956fc 596 // Salesforce.com Invoke: defaults to POST with JSON input data type
ansond 9:a254fcd904be 597 char *SalesforceInterface::invoke(const char *url,const char *input_data,const int input_data_len,char *output_buffer,int output_buffer_length) {
ansond 9:a254fcd904be 598 return this->invoke(url,JSON,input_data,input_data_len,output_buffer,output_buffer_length);
ansond 0:518b1ca956fc 599 }
ansond 0:518b1ca956fc 600
ansond 0:518b1ca956fc 601 // Salesforce.com Invoke: defaults to POST with variable input data type
ansond 9:a254fcd904be 602 char *SalesforceInterface::invoke(const char *url,const InputDataTypes input_type,const char *input_data,const int input_data_len,char *output_buffer,int output_buffer_length) {
ansond 9:a254fcd904be 603 return this->invoke(url,input_type,input_data,input_data_len,output_buffer,output_buffer_length,POST);
ansond 0:518b1ca956fc 604 }
ansond 0:518b1ca956fc 605
ansond 0:518b1ca956fc 606 // Salesforce.com Invoke: full fidelity method
ansond 9:a254fcd904be 607 char *SalesforceInterface::invoke(const char *url,const InputDataTypes input_type,const char *input_data,const int input_data_len,char *output_buffer,int output_buffer_length,const HttpVerb verb) {
ansond 7:97ea5ef906f7 608 // initialize our invocation status and response code
ansond 7:97ea5ef906f7 609 this->m_http_response_code = -1;
ansond 7:97ea5ef906f7 610 this->m_http_status = HTTP_ERROR;
ansond 7:97ea5ef906f7 611
ansond 7:97ea5ef906f7 612 // param check: make sure that we at least have an output buffer and URL
ansond 9:a254fcd904be 613 if (url != NULL && strlen(url) > 0 && output_buffer != NULL && output_buffer_length > 0) {
ansond 7:97ea5ef906f7 614 // proceed only if we have a valid OAUTH Token
ansond 7:97ea5ef906f7 615 if (this->validOauthToken() == true) {
ansond 7:97ea5ef906f7 616 // use OAUTH headers
ansond 7:97ea5ef906f7 617 this->http()->oauthToken(this->oauth()->access_token.c_str());
ansond 0:518b1ca956fc 618
ansond 7:97ea5ef906f7 619 // reset the redirection url buffer in case we get a redirect...
ansond 7:97ea5ef906f7 620 RESET_BUFFER(this->m_http_redirection_url);
ansond 7:97ea5ef906f7 621 this->http()->setLocationBuf((char *)this->m_http_redirection_url,MAX_BUFFER_LENGTH);
ansond 7:97ea5ef906f7 622
ansond 0:518b1ca956fc 623 // create our output/response buffer
ansond 9:a254fcd904be 624 HTTPText output(output_buffer,output_buffer_length);
ansond 0:518b1ca956fc 625
ansond 0:518b1ca956fc 626 // now make the HTTP(S) request
ansond 0:518b1ca956fc 627 switch(verb) {
ansond 0:518b1ca956fc 628 case GET:
ansond 9:a254fcd904be 629 DEBUG("invoke (GET) URL: %s...",url);
ansond 7:97ea5ef906f7 630 this->m_http_status = this->http()->get(url,&output);
ansond 7:97ea5ef906f7 631 this->m_http_response_code = this->http()->getHTTPResponseCode();
ansond 0:518b1ca956fc 632 break;
ansond 0:518b1ca956fc 633 case DELETE:
ansond 9:a254fcd904be 634 DEBUG("invoke (DEL) URL: %s...",url);
ansond 7:97ea5ef906f7 635 this->m_http_status = this->http()->del(url,&output);
ansond 7:97ea5ef906f7 636 this->m_http_response_code = this->http()->getHTTPResponseCode();
ansond 0:518b1ca956fc 637 break;
ansond 0:518b1ca956fc 638 case POST:
ansond 0:518b1ca956fc 639 if (input_data != NULL && input_data_len > 0) {
ansond 0:518b1ca956fc 640 if (input_type == JSON) {
ansond 9:a254fcd904be 641 DEBUG("invoke (POST-JSON) URL: %s...",url);
ansond 7:97ea5ef906f7 642 HTTPJson input_json((char *)input_data,(int)input_data_len);
ansond 7:97ea5ef906f7 643 this->m_http_status = this->http()->post(url,input_json,&output);
ansond 7:97ea5ef906f7 644 this->m_http_response_code = this->http()->getHTTPResponseCode();
ansond 0:518b1ca956fc 645 }
ansond 0:518b1ca956fc 646 else {
ansond 9:a254fcd904be 647 DEBUG("invoke (POST-TEXT) URL: %s...",url);
ansond 7:97ea5ef906f7 648 HTTPText input_text((char *)input_data,(int)input_data_len);
ansond 7:97ea5ef906f7 649 this->m_http_status = this->http()->post(url,input_text,&output);
ansond 7:97ea5ef906f7 650 this->m_http_response_code = this->http()->getHTTPResponseCode();
ansond 0:518b1ca956fc 651 }
ansond 0:518b1ca956fc 652 }
ansond 0:518b1ca956fc 653 else {
ansond 0:518b1ca956fc 654 // no input buffer!
ansond 0:518b1ca956fc 655 this->logger()->log("invoke: ERROR HTTP(POST) requested but no input data provided... returning NULL");
ansond 0:518b1ca956fc 656 }
ansond 0:518b1ca956fc 657 break;
ansond 0:518b1ca956fc 658 case PUT:
ansond 0:518b1ca956fc 659 if (input_data != NULL && input_data_len > 0) {
ansond 0:518b1ca956fc 660 if (input_type == JSON) {
ansond 9:a254fcd904be 661 DEBUG("invoke (PUT-JSON) URL: %s...",url);
ansond 7:97ea5ef906f7 662 HTTPJson input_json((char *)input_data,(int)input_data_len);
ansond 7:97ea5ef906f7 663 this->m_http_status = this->http()->put(url,input_json,&output);
ansond 7:97ea5ef906f7 664 this->m_http_response_code = this->http()->getHTTPResponseCode();
ansond 0:518b1ca956fc 665 }
ansond 0:518b1ca956fc 666 else {
ansond 9:a254fcd904be 667 DEBUG("invoke (PUT-TEXT) URL: %s...",url);
ansond 7:97ea5ef906f7 668 HTTPText input_text((char *)input_data,(int)input_data_len);
ansond 7:97ea5ef906f7 669 this->m_http_status = this->http()->put(url,input_text,&output);
ansond 7:97ea5ef906f7 670 this->m_http_response_code = this->http()->getHTTPResponseCode();
ansond 0:518b1ca956fc 671 }
ansond 0:518b1ca956fc 672 }
ansond 0:518b1ca956fc 673 else {
ansond 0:518b1ca956fc 674 // no input buffer!
ansond 0:518b1ca956fc 675 this->logger()->log("invoke: ERROR HTTP(PUT) requested but no input data provided... returning NULL");
ansond 0:518b1ca956fc 676 }
ansond 0:518b1ca956fc 677 break;
ansond 0:518b1ca956fc 678 default:
ansond 0:518b1ca956fc 679 // invalid HTTP verb
ansond 0:518b1ca956fc 680 this->logger()->log("invoke: ERROR invalid HTTP verb (%d) provided... returning NULL",verb);
ansond 0:518b1ca956fc 681 break;
ansond 0:518b1ca956fc 682 }
ansond 0:518b1ca956fc 683 }
ansond 7:97ea5ef906f7 684 else {
ansond 7:97ea5ef906f7 685 // no OAUTH Token
ansond 7:97ea5ef906f7 686 this->logger()->log("unable to acquire OAUTH token for credentials provided. Unable to invoke API...");
ansond 7:97ea5ef906f7 687 }
ansond 0:518b1ca956fc 688 }
ansond 0:518b1ca956fc 689 else {
ansond 0:518b1ca956fc 690 // no credentials
ansond 0:518b1ca956fc 691 this->logger()->log("no/incomplete salesforce.com credentials provided. Unable to invoke API...");
ansond 0:518b1ca956fc 692 }
ansond 0:518b1ca956fc 693
ansond 7:97ea5ef906f7 694 // process any return results that we have
ansond 7:97ea5ef906f7 695 if (this->httpStatus() == HTTP_OK || this->httpStatus() == HTTP_REDIRECT) {
ansond 7:97ea5ef906f7 696 // do we have any redirections?
ansond 17:6c774354b599 697 if (this->httpResponseCodeInRange(300) /* REDIRECT */ && strlen(this->m_http_redirection_url) > 0) {
ansond 7:97ea5ef906f7 698 // we have a redirect - so reset the output buffer
ansond 9:a254fcd904be 699 memset(output_buffer,0,output_buffer_length);
ansond 7:97ea5ef906f7 700
ansond 7:97ea5ef906f7 701 // we have to make a copy of the redirection URL - this is because the subsequent invoke() will wipe our current one clean
ansond 7:97ea5ef906f7 702 ALLOC_BUFFER(redirect_url);
ansond 7:97ea5ef906f7 703 strcpy(redirect_url,this->m_http_redirection_url);
ansond 7:97ea5ef906f7 704
ansond 7:97ea5ef906f7 705 // repeat with the redirection URL
ansond 7:97ea5ef906f7 706 DEBUG("invoke: redirecting to: %s",redirect_url);
ansond 9:a254fcd904be 707 return this->invoke((const char *)redirect_url,input_type,input_data,input_data_len,output_buffer,output_buffer_length,verb);
ansond 7:97ea5ef906f7 708 }
ansond 17:6c774354b599 709 else if (this->httpResponseCodeInRange(300) /* REDIRECT */) {
ansond 7:97ea5ef906f7 710 // error - got a redirect but have no URL
ansond 7:97ea5ef906f7 711 this->logger()->log("invoke error: received redirect but no URL...");
ansond 7:97ea5ef906f7 712 this->m_http_status = HTTP_ERROR;
ansond 7:97ea5ef906f7 713 }
ansond 7:97ea5ef906f7 714 }
ansond 7:97ea5ef906f7 715
ansond 0:518b1ca956fc 716 // return the response in the output buffer
ansond 9:a254fcd904be 717 if (this->httpStatus() == HTTP_OK || this->httpStatus() == HTTP_REDIRECT) return output_buffer;
ansond 7:97ea5ef906f7 718 else this->logger()->log("invocation failed with HTTP error code=%d status=%d",this->httpResponseCode(),this->httpStatus());
ansond 0:518b1ca956fc 719 return NULL;
ansond 0:518b1ca956fc 720 }
ansond 8:47db53cd5884 721
ansond 15:89044c68ad36 722 // find the specific URL in our salesforce token
ansond 8:47db53cd5884 723 char *SalesforceInterface::getSalesforceURL(char *key,char *url_buffer,int url_buffer_length) {
ansond 15:89044c68ad36 724 // due to MbedJSONValue limitations - we have to manually pull out the specific JSON from our salesforce token
ansond 8:47db53cd5884 725 int start = (int)strstr(this->m_salesforce_id,SF_URLS_START_TOKEN);
ansond 8:47db53cd5884 726 if (start >= 0) {
ansond 8:47db53cd5884 727 start += strlen(SF_URLS_START_TOKEN);
ansond 8:47db53cd5884 728 int stop = (int)strstr((char *)start,SF_URLS_STOP_TOKEN);
ansond 8:47db53cd5884 729 if (stop >= 0 && stop > start) {
ansond 8:47db53cd5884 730 // calculate the length
ansond 8:47db53cd5884 731 int length = stop - start + 1;
ansond 8:47db53cd5884 732
ansond 15:89044c68ad36 733 // copy over the "urls" json from the salesforce token
ansond 8:47db53cd5884 734 ALLOC_BUFFER(urls);
ansond 8:47db53cd5884 735 int start_index = (start - (int)this->m_salesforce_id);
ansond 8:47db53cd5884 736 for(int i=0;i<length;++i) urls[i] = this->m_salesforce_id[start_index+i];
ansond 8:47db53cd5884 737
ansond 8:47db53cd5884 738 // use MbedJSONValue to parse the "urls" json
ansond 8:47db53cd5884 739 MbedJSONValue parsed_urls;
ansond 8:47db53cd5884 740 parse(parsed_urls,urls);
ansond 8:47db53cd5884 741
ansond 8:47db53cd5884 742 // find the appropriate URL and copy it
ansond 8:47db53cd5884 743 string target_url = parsed_urls[key].get<std::string>();
ansond 8:47db53cd5884 744
ansond 8:47db53cd5884 745 // replace the version of the string with our selected salesforce API version
ansond 8:47db53cd5884 746 string sf_version(this->getSalesforceAPIVersion());
ansond 8:47db53cd5884 747 string version_tag(SF_URL_API_VER_TOKEN);
ansond 8:47db53cd5884 748 this->replace(target_url,version_tag,sf_version);
ansond 8:47db53cd5884 749
ansond 8:47db53cd5884 750 // copy the final URL to our putput
ansond 8:47db53cd5884 751 memset(url_buffer,0,url_buffer_length);
ansond 8:47db53cd5884 752 strcpy(url_buffer,target_url.c_str());
ansond 8:47db53cd5884 753
ansond 8:47db53cd5884 754 // return the URL
ansond 8:47db53cd5884 755 return url_buffer;
ansond 8:47db53cd5884 756 }
ansond 8:47db53cd5884 757 }
ansond 8:47db53cd5884 758 return NULL;
ansond 8:47db53cd5884 759 }
ansond 8:47db53cd5884 760
ansond 8:47db53cd5884 761 // simple char array replacement (modifies input string!)
ansond 8:47db53cd5884 762 void SalesforceInterface::replace(char *str,char orig_char,char new_char) {
ansond 8:47db53cd5884 763 int length = strlen(str);
ansond 8:47db53cd5884 764 for(int i=0;i<length;++i) if (str[i] == orig_char) str[i] = new_char;
ansond 8:47db53cd5884 765 }
ansond 8:47db53cd5884 766
ansond 8:47db53cd5884 767 //
ansond 8:47db53cd5884 768 // substring replacement
ansond 8:47db53cd5884 769 // Credit: http://stackoverflow.com/questions/4643512/replace-substring-with-another-substring-c
ansond 8:47db53cd5884 770 //
ansond 8:47db53cd5884 771 void SalesforceInterface::replace(string& line, string& oldString, string& newString) {
ansond 8:47db53cd5884 772 const size_t oldSize = oldString.length();
ansond 8:47db53cd5884 773
ansond 8:47db53cd5884 774 // do nothing if line is shorter than the string to find
ansond 8:47db53cd5884 775 if( oldSize > line.length() ) return;
ansond 8:47db53cd5884 776
ansond 8:47db53cd5884 777 const size_t newSize = newString.length();
ansond 8:47db53cd5884 778 for( size_t pos = 0; ; pos += newSize ) {
ansond 8:47db53cd5884 779
ansond 8:47db53cd5884 780 // Locate the substring to replace
ansond 8:47db53cd5884 781 pos = line.find( oldString, pos );
ansond 8:47db53cd5884 782 if( pos == string::npos ) return;
ansond 8:47db53cd5884 783 if( oldSize == newSize ) {
ansond 8:47db53cd5884 784
ansond 8:47db53cd5884 785 // if they're same size, use std::string::replace
ansond 8:47db53cd5884 786 line.replace( pos, oldSize, newString );
ansond 8:47db53cd5884 787 }
ansond 8:47db53cd5884 788 else {
ansond 8:47db53cd5884 789
ansond 8:47db53cd5884 790 // if not same size, replace by erasing and inserting
ansond 8:47db53cd5884 791 line.erase( pos, oldSize );
ansond 8:47db53cd5884 792 line.insert( pos, newString );
ansond 8:47db53cd5884 793 }
ansond 8:47db53cd5884 794 }
ansond 17:6c774354b599 795 }
ansond 17:6c774354b599 796
ansond 17:6c774354b599 797 // validate that a given HTTP result code is in the "n" range
ansond 17:6c774354b599 798 bool SalesforceInterface::httpResponseCodeInRange(int n) {
ansond 17:6c774354b599 799 int http_response = this->httpResponseCode();
ansond 17:6c774354b599 800 int diff = http_response - n;
ansond 17:6c774354b599 801 if (diff >= 0 && diff < 100) return true;
ansond 17:6c774354b599 802 return false;
ansond 9:a254fcd904be 803 }