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@16:3d160f224084, 2014-09-23 (annotated)

Committer:
ansond
Date:
Tue Sep 23 20:26:24 2014 +0000
Revision:
16:3d160f224084
Parent:
15:89044c68ad36
Child:
17:6c774354b599
added external ID support

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