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@17:6c774354b599, 2014-09-23 (annotated)

Committer:
ansond
Date:
Tue Sep 23 22:01:43 2014 +0000
Revision:
17:6c774354b599
Parent:
16:3d160f224084
Child:
18:7dc9b949bbc3
updates for external id usage and sanity checking of http codes

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