123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885 |
- /***************************************************************************
- * _ _ ____ _
- * Project ___| | | | _ \| |
- * / __| | | | |_) | |
- * | (__| |_| | _ <| |___
- * \___|\___/|_| \_\_____|
- *
- * Copyright (C) Daniel Stenberg, <daniel@haxx.se>, et al.
- *
- * This software is licensed as described in the file COPYING, which
- * you should have received as part of this distribution. The terms
- * are also available at https://curl.haxx.se/docs/copyright.html.
- *
- * You may opt to use, copy, modify, merge, publish, distribute and/or sell
- * copies of the Software, and permit persons to whom the Software is
- * furnished to do so, under the terms of the COPYING file.
- *
- * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
- * KIND, either express or implied.
- *
- * SPDX-License-Identifier: curl
- *
- ***************************************************************************/
- #include "curl_setup.h"
- #if !defined(CURL_DISABLE_HTTP) && !defined(CURL_DISABLE_AWS)
- #include "urldata.h"
- #include "strcase.h"
- #include "strdup.h"
- #include "http_aws_sigv4.h"
- #include "curl_sha256.h"
- #include "transfer.h"
- #include "parsedate.h"
- #include "sendf.h"
- #include "escape.h"
- #include "strparse.h"
- #include <time.h>
- /* The last 3 #include files should be in this order */
- #include "curl_printf.h"
- #include "curl_memory.h"
- #include "memdebug.h"
- #include "slist.h"
- #define HMAC_SHA256(k, kl, d, dl, o) \
- do { \
- result = Curl_hmacit(&Curl_HMAC_SHA256, \
- (unsigned char *)k, \
- kl, \
- (unsigned char *)d, \
- dl, o); \
- if(result) { \
- goto fail; \
- } \
- } while(0)
- #define TIMESTAMP_SIZE 17
- /* hex-encoded with trailing null */
- #define SHA256_HEX_LENGTH (2 * CURL_SHA256_DIGEST_LENGTH + 1)
- static void sha256_to_hex(char *dst, unsigned char *sha)
- {
- Curl_hexencode(sha, CURL_SHA256_DIGEST_LENGTH,
- (unsigned char *)dst, SHA256_HEX_LENGTH);
- }
- static char *find_date_hdr(struct Curl_easy *data, const char *sig_hdr)
- {
- char *tmp = Curl_checkheaders(data, sig_hdr, strlen(sig_hdr));
- if(tmp)
- return tmp;
- return Curl_checkheaders(data, STRCONST("Date"));
- }
- /* remove whitespace, and lowercase all headers */
- static void trim_headers(struct curl_slist *head)
- {
- struct curl_slist *l;
- for(l = head; l; l = l->next) {
- char *value; /* to read from */
- char *store;
- size_t colon = strcspn(l->data, ":");
- Curl_strntolower(l->data, l->data, colon);
- value = &l->data[colon];
- if(!*value)
- continue;
- ++value;
- store = value;
- /* skip leading whitespace */
- while(*value && ISBLANK(*value))
- value++;
- while(*value) {
- int space = 0;
- while(*value && ISBLANK(*value)) {
- value++;
- space++;
- }
- if(space) {
- /* replace any number of consecutive whitespace with a single space,
- unless at the end of the string, then nothing */
- if(*value)
- *store++ = ' ';
- }
- else
- *store++ = *value++;
- }
- *store = 0; /* null terminate */
- }
- }
- /* maximum length for the aws sivg4 parts */
- #define MAX_SIGV4_LEN 64
- #define DATE_HDR_KEY_LEN (MAX_SIGV4_LEN + sizeof("X--Date"))
- /* string been x-PROVIDER-date:TIMESTAMP, I need +1 for ':' */
- #define DATE_FULL_HDR_LEN (DATE_HDR_KEY_LEN + TIMESTAMP_SIZE + 1)
- /* alphabetically compare two headers by their name, expecting
- headers to use ':' at this point */
- static int compare_header_names(const char *a, const char *b)
- {
- const char *colon_a;
- const char *colon_b;
- size_t len_a;
- size_t len_b;
- size_t min_len;
- int cmp;
- colon_a = strchr(a, ':');
- colon_b = strchr(b, ':');
- DEBUGASSERT(colon_a);
- DEBUGASSERT(colon_b);
- len_a = colon_a ? (size_t)(colon_a - a) : strlen(a);
- len_b = colon_b ? (size_t)(colon_b - b) : strlen(b);
- min_len = (len_a < len_b) ? len_a : len_b;
- cmp = strncmp(a, b, min_len);
- /* return the shorter of the two if one is shorter */
- if(!cmp)
- return (int)(len_a - len_b);
- return cmp;
- }
- /* timestamp should point to a buffer of at last TIMESTAMP_SIZE bytes */
- static CURLcode make_headers(struct Curl_easy *data,
- const char *hostname,
- char *timestamp,
- const char *provider1,
- size_t plen, /* length of provider1 */
- char **date_header,
- char *content_sha256_header,
- struct dynbuf *canonical_headers,
- struct dynbuf *signed_headers)
- {
- char date_hdr_key[DATE_HDR_KEY_LEN];
- char date_full_hdr[DATE_FULL_HDR_LEN];
- struct curl_slist *head = NULL;
- struct curl_slist *tmp_head = NULL;
- CURLcode ret = CURLE_OUT_OF_MEMORY;
- struct curl_slist *l;
- bool again = TRUE;
- msnprintf(date_hdr_key, DATE_HDR_KEY_LEN, "X-%.*s-Date",
- (int)plen, provider1);
- /* provider1 ucfirst */
- Curl_strntolower(&date_hdr_key[2], provider1, plen);
- date_hdr_key[2] = Curl_raw_toupper(provider1[0]);
- msnprintf(date_full_hdr, DATE_FULL_HDR_LEN,
- "x-%.*s-date:%s", (int)plen, provider1, timestamp);
- /* provider1 lowercase */
- Curl_strntolower(&date_full_hdr[2], provider1, plen);
- if(!Curl_checkheaders(data, STRCONST("Host"))) {
- char *fullhost;
- if(data->state.aptr.host) {
- /* remove /r/n as the separator for canonical request must be '\n' */
- size_t pos = strcspn(data->state.aptr.host, "\n\r");
- fullhost = Curl_memdup0(data->state.aptr.host, pos);
- }
- else
- fullhost = aprintf("host:%s", hostname);
- if(fullhost)
- head = Curl_slist_append_nodup(NULL, fullhost);
- if(!head) {
- free(fullhost);
- goto fail;
- }
- }
- if(*content_sha256_header) {
- tmp_head = curl_slist_append(head, content_sha256_header);
- if(!tmp_head)
- goto fail;
- head = tmp_head;
- }
- /* copy user headers to our header list. the logic is based on how http.c
- handles user headers.
- user headers in format 'name:' with no value are used to signal that an
- internal header of that name should be removed. those user headers are not
- added to this list.
- user headers in format 'name;' with no value are used to signal that a
- header of that name with no value should be sent. those user headers are
- added to this list but in the format that they will be sent, ie the
- semi-colon is changed to a colon for format 'name:'.
- user headers with a value of whitespace only, or without a colon or
- semi-colon, are not added to this list.
- */
- for(l = data->set.headers; l; l = l->next) {
- char *dupdata, *ptr;
- char *sep = strchr(l->data, ':');
- if(!sep)
- sep = strchr(l->data, ';');
- if(!sep || (*sep == ':' && !*(sep + 1)))
- continue;
- for(ptr = sep + 1; ISSPACE(*ptr); ++ptr)
- ;
- if(!*ptr && ptr != sep + 1) /* a value of whitespace only */
- continue;
- dupdata = strdup(l->data);
- if(!dupdata)
- goto fail;
- dupdata[sep - l->data] = ':';
- tmp_head = Curl_slist_append_nodup(head, dupdata);
- if(!tmp_head) {
- free(dupdata);
- goto fail;
- }
- head = tmp_head;
- }
- trim_headers(head);
- *date_header = find_date_hdr(data, date_hdr_key);
- if(!*date_header) {
- tmp_head = curl_slist_append(head, date_full_hdr);
- if(!tmp_head)
- goto fail;
- head = tmp_head;
- *date_header = aprintf("%s: %s\r\n", date_hdr_key, timestamp);
- }
- else {
- char *value;
- char *endp;
- value = strchr(*date_header, ':');
- if(!value) {
- *date_header = NULL;
- goto fail;
- }
- ++value;
- while(ISBLANK(*value))
- ++value;
- endp = value;
- while(*endp && ISALNUM(*endp))
- ++endp;
- /* 16 bytes => "19700101T000000Z" */
- if((endp - value) == TIMESTAMP_SIZE - 1) {
- memcpy(timestamp, value, TIMESTAMP_SIZE - 1);
- timestamp[TIMESTAMP_SIZE - 1] = 0;
- }
- else
- /* bad timestamp length */
- timestamp[0] = 0;
- *date_header = NULL;
- }
- /* alpha-sort by header name in a case sensitive manner */
- do {
- again = FALSE;
- for(l = head; l; l = l->next) {
- struct curl_slist *next = l->next;
- if(next && compare_header_names(l->data, next->data) > 0) {
- char *tmp = l->data;
- l->data = next->data;
- next->data = tmp;
- again = TRUE;
- }
- }
- } while(again);
- for(l = head; l; l = l->next) {
- char *tmp;
- if(Curl_dyn_add(canonical_headers, l->data))
- goto fail;
- if(Curl_dyn_add(canonical_headers, "\n"))
- goto fail;
- tmp = strchr(l->data, ':');
- if(tmp)
- *tmp = 0;
- if(l != head) {
- if(Curl_dyn_add(signed_headers, ";"))
- goto fail;
- }
- if(Curl_dyn_add(signed_headers, l->data))
- goto fail;
- }
- ret = CURLE_OK;
- fail:
- curl_slist_free_all(head);
- return ret;
- }
- #define CONTENT_SHA256_KEY_LEN (MAX_SIGV4_LEN + sizeof("X--Content-Sha256"))
- /* add 2 for ": " between header name and value */
- #define CONTENT_SHA256_HDR_LEN (CONTENT_SHA256_KEY_LEN + 2 + \
- SHA256_HEX_LENGTH)
- /* try to parse a payload hash from the content-sha256 header */
- static char *parse_content_sha_hdr(struct Curl_easy *data,
- const char *provider1,
- size_t plen,
- size_t *value_len)
- {
- char key[CONTENT_SHA256_KEY_LEN];
- size_t key_len;
- char *value;
- size_t len;
- key_len = msnprintf(key, sizeof(key), "x-%.*s-content-sha256",
- (int)plen, provider1);
- value = Curl_checkheaders(data, key, key_len);
- if(!value)
- return NULL;
- value = strchr(value, ':');
- if(!value)
- return NULL;
- ++value;
- while(*value && ISBLANK(*value))
- ++value;
- len = strlen(value);
- while(len > 0 && ISBLANK(value[len-1]))
- --len;
- *value_len = len;
- return value;
- }
- static CURLcode calc_payload_hash(struct Curl_easy *data,
- unsigned char *sha_hash, char *sha_hex)
- {
- const char *post_data = data->set.postfields;
- size_t post_data_len = 0;
- CURLcode result;
- if(post_data) {
- if(data->set.postfieldsize < 0)
- post_data_len = strlen(post_data);
- else
- post_data_len = (size_t)data->set.postfieldsize;
- }
- result = Curl_sha256it(sha_hash, (const unsigned char *) post_data,
- post_data_len);
- if(!result)
- sha256_to_hex(sha_hex, sha_hash);
- return result;
- }
- #define S3_UNSIGNED_PAYLOAD "UNSIGNED-PAYLOAD"
- static CURLcode calc_s3_payload_hash(struct Curl_easy *data,
- Curl_HttpReq httpreq, char *provider1,
- size_t plen,
- unsigned char *sha_hash,
- char *sha_hex, char *header)
- {
- bool empty_method = (httpreq == HTTPREQ_GET || httpreq == HTTPREQ_HEAD);
- /* The request method or filesize indicate no request payload */
- bool empty_payload = (empty_method || data->set.filesize == 0);
- /* The POST payload is in memory */
- bool post_payload = (httpreq == HTTPREQ_POST && data->set.postfields);
- CURLcode ret = CURLE_OUT_OF_MEMORY;
- if(empty_payload || post_payload) {
- /* Calculate a real hash when we know the request payload */
- ret = calc_payload_hash(data, sha_hash, sha_hex);
- if(ret)
- goto fail;
- }
- else {
- /* Fall back to s3's UNSIGNED-PAYLOAD */
- size_t len = sizeof(S3_UNSIGNED_PAYLOAD) - 1;
- DEBUGASSERT(len < SHA256_HEX_LENGTH); /* 16 < 65 */
- memcpy(sha_hex, S3_UNSIGNED_PAYLOAD, len);
- sha_hex[len] = 0;
- }
- /* format the required content-sha256 header */
- msnprintf(header, CONTENT_SHA256_HDR_LEN,
- "x-%.*s-content-sha256: %s", (int)plen, provider1, sha_hex);
- ret = CURLE_OK;
- fail:
- return ret;
- }
- struct pair {
- const char *p;
- size_t len;
- };
- static int compare_func(const void *a, const void *b)
- {
- const struct pair *aa = a;
- const struct pair *bb = b;
- /* If one element is empty, the other is always sorted higher */
- if(aa->len == 0)
- return -1;
- if(bb->len == 0)
- return 1;
- return strncmp(aa->p, bb->p, aa->len < bb->len ? aa->len : bb->len);
- }
- #define MAX_QUERYPAIRS 64
- /**
- * found_equals have a double meaning,
- * detect if an equal have been found when called from canon_query,
- * and mark that this function is called to compute the path,
- * if found_equals is NULL.
- */
- static CURLcode canon_string(const char *q, size_t len,
- struct dynbuf *dq, bool *found_equals)
- {
- CURLcode result = CURLE_OK;
- for(; len && !result; q++, len--) {
- if(ISALNUM(*q))
- result = Curl_dyn_addn(dq, q, 1);
- else {
- switch(*q) {
- case '-':
- case '.':
- case '_':
- case '~':
- /* allowed as-is */
- result = Curl_dyn_addn(dq, q, 1);
- break;
- case '%':
- /* uppercase the following if hexadecimal */
- if(ISXDIGIT(q[1]) && ISXDIGIT(q[2])) {
- char tmp[3]="%";
- tmp[1] = Curl_raw_toupper(q[1]);
- tmp[2] = Curl_raw_toupper(q[2]);
- result = Curl_dyn_addn(dq, tmp, 3);
- q += 2;
- len -= 2;
- }
- else
- /* '%' without a following two-digit hex, encode it */
- result = Curl_dyn_addn(dq, "%25", 3);
- break;
- default: {
- const char hex[] = "0123456789ABCDEF";
- char out[3]={'%'};
- if(!found_equals) {
- /* if found_equals is NULL assuming, been in path */
- if(*q == '/') {
- /* allowed as if */
- result = Curl_dyn_addn(dq, q, 1);
- break;
- }
- }
- else {
- /* allowed as-is */
- if(*q == '=') {
- result = Curl_dyn_addn(dq, q, 1);
- *found_equals = TRUE;
- break;
- }
- }
- /* URL encode */
- out[1] = hex[((unsigned char)*q) >> 4];
- out[2] = hex[*q & 0xf];
- result = Curl_dyn_addn(dq, out, 3);
- break;
- }
- }
- }
- }
- return result;
- }
- static CURLcode canon_query(struct Curl_easy *data,
- const char *query, struct dynbuf *dq)
- {
- CURLcode result = CURLE_OK;
- int entry = 0;
- int i;
- const char *p = query;
- struct pair array[MAX_QUERYPAIRS];
- struct pair *ap = &array[0];
- if(!query)
- return result;
- /* sort the name=value pairs first */
- do {
- char *amp;
- entry++;
- ap->p = p;
- amp = strchr(p, '&');
- if(amp)
- ap->len = amp - p; /* excluding the ampersand */
- else {
- ap->len = strlen(p);
- break;
- }
- ap++;
- p = amp + 1;
- } while(entry < MAX_QUERYPAIRS);
- if(entry == MAX_QUERYPAIRS) {
- /* too many query pairs for us */
- failf(data, "aws-sigv4: too many query pairs in URL");
- return CURLE_URL_MALFORMAT;
- }
- qsort(&array[0], entry, sizeof(struct pair), compare_func);
- ap = &array[0];
- for(i = 0; !result && (i < entry); i++, ap++) {
- const char *q = ap->p;
- bool found_equals = FALSE;
- if(!ap->len)
- continue;
- result = canon_string(q, ap->len, dq, &found_equals);
- if(!result && !found_equals) {
- /* queries without value still need an equals */
- result = Curl_dyn_addn(dq, "=", 1);
- }
- if(!result && i < entry - 1) {
- /* insert ampersands between query pairs */
- result = Curl_dyn_addn(dq, "&", 1);
- }
- }
- return result;
- }
- CURLcode Curl_output_aws_sigv4(struct Curl_easy *data, bool proxy)
- {
- CURLcode result = CURLE_OUT_OF_MEMORY;
- struct connectdata *conn = data->conn;
- size_t len;
- char *line;
- struct Curl_str provider0;
- struct Curl_str provider1;
- struct Curl_str region = { NULL, 0};
- struct Curl_str service = { NULL, 0};
- const char *hostname = conn->host.name;
- time_t clock;
- struct tm tm;
- char timestamp[TIMESTAMP_SIZE];
- char date[9];
- struct dynbuf canonical_headers;
- struct dynbuf signed_headers;
- struct dynbuf canonical_query;
- struct dynbuf canonical_path;
- char *date_header = NULL;
- Curl_HttpReq httpreq;
- const char *method = NULL;
- char *payload_hash = NULL;
- size_t payload_hash_len = 0;
- unsigned char sha_hash[CURL_SHA256_DIGEST_LENGTH];
- char sha_hex[SHA256_HEX_LENGTH];
- char content_sha256_hdr[CONTENT_SHA256_HDR_LEN + 2] = ""; /* add \r\n */
- char *canonical_request = NULL;
- char *request_type = NULL;
- char *credential_scope = NULL;
- char *str_to_sign = NULL;
- const char *user = data->state.aptr.user ? data->state.aptr.user : "";
- char *secret = NULL;
- unsigned char sign0[CURL_SHA256_DIGEST_LENGTH] = {0};
- unsigned char sign1[CURL_SHA256_DIGEST_LENGTH] = {0};
- char *auth_headers = NULL;
- DEBUGASSERT(!proxy);
- (void)proxy;
- if(Curl_checkheaders(data, STRCONST("Authorization"))) {
- /* Authorization already present, Bailing out */
- return CURLE_OK;
- }
- /* we init those buffers here, so goto fail will free initialized dynbuf */
- Curl_dyn_init(&canonical_headers, CURL_MAX_HTTP_HEADER);
- Curl_dyn_init(&canonical_query, CURL_MAX_HTTP_HEADER);
- Curl_dyn_init(&signed_headers, CURL_MAX_HTTP_HEADER);
- Curl_dyn_init(&canonical_path, CURL_MAX_HTTP_HEADER);
- /*
- * Parameters parsing
- * Google and Outscale use the same OSC or GOOG,
- * but Amazon uses AWS and AMZ for header arguments.
- * AWS is the default because most of non-amazon providers
- * are still using aws:amz as a prefix.
- */
- line = data->set.str[STRING_AWS_SIGV4] ?
- data->set.str[STRING_AWS_SIGV4] : (char *)"aws:amz";
- /* provider0[:provider1[:region[:service]]]
- No string can be longer than N bytes of non-whitespace
- */
- if(Curl_str_until(&line, &provider0, MAX_SIGV4_LEN, ':')) {
- failf(data, "first aws-sigv4 provider cannot be empty");
- result = CURLE_BAD_FUNCTION_ARGUMENT;
- goto fail;
- }
- if(Curl_str_single(&line, ':') ||
- Curl_str_until(&line, &provider1, MAX_SIGV4_LEN, ':')) {
- provider1.str = provider0.str;
- provider1.len = provider0.len;
- }
- else if(Curl_str_single(&line, ':') ||
- Curl_str_until(&line, ®ion, MAX_SIGV4_LEN, ':') ||
- Curl_str_single(&line, ':') ||
- Curl_str_until(&line, &service, MAX_SIGV4_LEN, ':')) {
- /* nothing to do */
- }
- if(!service.len) {
- char *hostdot = strchr(hostname, '.');
- if(!hostdot) {
- failf(data, "aws-sigv4: service missing in parameters and hostname");
- result = CURLE_URL_MALFORMAT;
- goto fail;
- }
- len = hostdot - hostname;
- if(len > MAX_SIGV4_LEN) {
- failf(data, "aws-sigv4: service too long in hostname");
- result = CURLE_URL_MALFORMAT;
- goto fail;
- }
- service.str = (char *)hostname;
- service.len = len;
- infof(data, "aws_sigv4: picked service %.*s from host",
- (int)service.len, service.str);
- if(!region.len) {
- const char *reg = hostdot + 1;
- const char *hostreg = strchr(reg, '.');
- if(!hostreg) {
- failf(data, "aws-sigv4: region missing in parameters and hostname");
- result = CURLE_URL_MALFORMAT;
- goto fail;
- }
- len = hostreg - reg;
- if(len > MAX_SIGV4_LEN) {
- failf(data, "aws-sigv4: region too long in hostname");
- result = CURLE_URL_MALFORMAT;
- goto fail;
- }
- region.str = (char *)reg;
- region.len = len;
- infof(data, "aws_sigv4: picked region %.*s from host",
- (int)region.len, region.str);
- }
- }
- Curl_http_method(data, conn, &method, &httpreq);
- payload_hash = parse_content_sha_hdr(data, provider1.str, provider1.len,
- &payload_hash_len);
- if(!payload_hash) {
- /* AWS S3 requires a x-amz-content-sha256 header, and supports special
- * values like UNSIGNED-PAYLOAD */
- bool sign_as_s3 = ((provider0.len == 3) &&
- strncasecompare(provider0.str, "aws", 3)) &&
- ((service.len == 2) && strncasecompare(service.str, "s3", 2));
- if(sign_as_s3)
- result = calc_s3_payload_hash(data, httpreq,
- provider1.str, provider1.len,
- sha_hash, sha_hex, content_sha256_hdr);
- else
- result = calc_payload_hash(data, sha_hash, sha_hex);
- if(result)
- goto fail;
- payload_hash = sha_hex;
- /* may be shorter than SHA256_HEX_LENGTH, like S3_UNSIGNED_PAYLOAD */
- payload_hash_len = strlen(sha_hex);
- }
- #ifdef DEBUGBUILD
- {
- char *force_timestamp = getenv("CURL_FORCETIME");
- if(force_timestamp)
- clock = 0;
- else
- clock = time(NULL);
- }
- #else
- clock = time(NULL);
- #endif
- result = Curl_gmtime(clock, &tm);
- if(result) {
- goto fail;
- }
- if(!strftime(timestamp, sizeof(timestamp), "%Y%m%dT%H%M%SZ", &tm)) {
- result = CURLE_OUT_OF_MEMORY;
- goto fail;
- }
- result = make_headers(data, hostname, timestamp,
- provider1.str, provider1.len,
- &date_header, content_sha256_hdr,
- &canonical_headers, &signed_headers);
- if(result)
- goto fail;
- if(*content_sha256_hdr) {
- /* make_headers() needed this without the \r\n for canonicalization */
- size_t hdrlen = strlen(content_sha256_hdr);
- DEBUGASSERT(hdrlen + 3 < sizeof(content_sha256_hdr));
- memcpy(content_sha256_hdr + hdrlen, "\r\n", 3);
- }
- memcpy(date, timestamp, sizeof(date));
- date[sizeof(date) - 1] = 0;
- result = canon_query(data, data->state.up.query, &canonical_query);
- if(result)
- goto fail;
- result = canon_string(data->state.up.path, strlen(data->state.up.path),
- &canonical_path, NULL);
- if(result)
- goto fail;
- result = CURLE_OUT_OF_MEMORY;
- canonical_request =
- aprintf("%s\n" /* HTTPRequestMethod */
- "%s\n" /* CanonicalURI */
- "%s\n" /* CanonicalQueryString */
- "%s\n" /* CanonicalHeaders */
- "%s\n" /* SignedHeaders */
- "%.*s", /* HashedRequestPayload in hex */
- method,
- Curl_dyn_ptr(&canonical_path),
- Curl_dyn_ptr(&canonical_query) ?
- Curl_dyn_ptr(&canonical_query) : "",
- Curl_dyn_ptr(&canonical_headers),
- Curl_dyn_ptr(&signed_headers),
- (int)payload_hash_len, payload_hash);
- if(!canonical_request)
- goto fail;
- DEBUGF(infof(data, "Canonical request: %s", canonical_request));
- request_type = aprintf("%.*s4_request", (int)provider0.len, provider0.str);
- if(!request_type)
- goto fail;
- /* provider0 is lowercased *after* aprintf() so that the buffer can be
- written to */
- Curl_strntolower(request_type, request_type, provider0.len);
- credential_scope = aprintf("%s/%.*s/%.*s/%s",
- date, (int)region.len, region.str,
- (int)service.len, service.str,
- request_type);
- if(!credential_scope)
- goto fail;
- if(Curl_sha256it(sha_hash, (unsigned char *) canonical_request,
- strlen(canonical_request)))
- goto fail;
- sha256_to_hex(sha_hex, sha_hash);
- /*
- * Google allows using RSA key instead of HMAC, so this code might change
- * in the future. For now we only support HMAC.
- */
- str_to_sign = aprintf("%.*s4-HMAC-SHA256\n" /* Algorithm */
- "%s\n" /* RequestDateTime */
- "%s\n" /* CredentialScope */
- "%s", /* HashedCanonicalRequest in hex */
- (int)provider0.len, provider0.str,
- timestamp,
- credential_scope,
- sha_hex);
- if(!str_to_sign)
- goto fail;
- /* make provider0 part done uppercase */
- Curl_strntoupper(str_to_sign, provider0.str, provider0.len);
- secret = aprintf("%.*s4%s", (int)provider0.len, provider0.str,
- data->state.aptr.passwd ?
- data->state.aptr.passwd : "");
- if(!secret)
- goto fail;
- /* make provider0 part done uppercase */
- Curl_strntoupper(secret, provider0.str, provider0.len);
- HMAC_SHA256(secret, strlen(secret), date, strlen(date), sign0);
- HMAC_SHA256(sign0, sizeof(sign0), region.str, region.len, sign1);
- HMAC_SHA256(sign1, sizeof(sign1), service.str, service.len, sign0);
- HMAC_SHA256(sign0, sizeof(sign0), request_type, strlen(request_type), sign1);
- HMAC_SHA256(sign1, sizeof(sign1), str_to_sign, strlen(str_to_sign), sign0);
- sha256_to_hex(sha_hex, sign0);
- auth_headers = aprintf("Authorization: %.*s4-HMAC-SHA256 "
- "Credential=%s/%s, "
- "SignedHeaders=%s, "
- "Signature=%s\r\n"
- /*
- * date_header is added here, only if it was not
- * user-specified (using CURLOPT_HTTPHEADER).
- * date_header includes \r\n
- */
- "%s"
- "%s", /* optional sha256 header includes \r\n */
- (int)provider0.len, provider0.str,
- user,
- credential_scope,
- Curl_dyn_ptr(&signed_headers),
- sha_hex,
- date_header ? date_header : "",
- content_sha256_hdr);
- if(!auth_headers) {
- goto fail;
- }
- /* provider 0 uppercase */
- Curl_strntoupper(&auth_headers[sizeof("Authorization: ") - 1],
- provider0.str, provider0.len);
- Curl_safefree(data->state.aptr.userpwd);
- data->state.aptr.userpwd = auth_headers;
- data->state.authhost.done = TRUE;
- result = CURLE_OK;
- fail:
- Curl_dyn_free(&canonical_query);
- Curl_dyn_free(&canonical_path);
- Curl_dyn_free(&canonical_headers);
- Curl_dyn_free(&signed_headers);
- free(canonical_request);
- free(request_type);
- free(credential_scope);
- free(str_to_sign);
- free(secret);
- free(date_header);
- return result;
- }
- #endif /* !defined(CURL_DISABLE_HTTP) && !defined(CURL_DISABLE_AWS) */
|