1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165
|
/**
* Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
* SPDX-License-Identifier: Apache-2.0.
*/
#include <aws/auth/signable.h>
#include <aws/common/string.h>
void aws_signable_destroy(struct aws_signable *signable) {
if (signable == NULL) {
return;
}
if (signable->vtable != NULL) {
signable->vtable->destroy(signable);
}
}
int aws_signable_get_property(
const struct aws_signable *signable,
const struct aws_string *name,
struct aws_byte_cursor *out_value) {
AWS_ASSERT(signable && signable->vtable && signable->vtable->get_property);
return signable->vtable->get_property(signable, name, out_value);
}
int aws_signable_get_property_list(
const struct aws_signable *signable,
const struct aws_string *name,
struct aws_array_list **out_property_list) {
AWS_ASSERT(signable && signable->vtable && signable->vtable->get_property_list);
return signable->vtable->get_property_list(signable, name, out_property_list);
}
int aws_signable_get_payload_stream(const struct aws_signable *signable, struct aws_input_stream **out_input_stream) {
AWS_ASSERT(signable && signable->vtable && signable->vtable->get_payload_stream);
return signable->vtable->get_payload_stream(signable, out_input_stream);
}
AWS_STRING_FROM_LITERAL(g_aws_http_headers_property_list_name, "headers");
AWS_STRING_FROM_LITERAL(g_aws_http_query_params_property_list_name, "params");
AWS_STRING_FROM_LITERAL(g_aws_http_method_property_name, "method");
AWS_STRING_FROM_LITERAL(g_aws_http_uri_property_name, "uri");
AWS_STRING_FROM_LITERAL(g_aws_signature_property_name, "signature");
AWS_STRING_FROM_LITERAL(g_aws_previous_signature_property_name, "previous-signature");
AWS_STRING_FROM_LITERAL(g_aws_canonical_request_property_name, "canonical-request");
/*
* This is a simple aws_signable wrapper implementation for AWS's canonical representation of an http request
*/
struct aws_signable_canonical_request_impl {
struct aws_string *canonical_request;
};
static int s_aws_signable_canonical_request_get_property(
const struct aws_signable *signable,
const struct aws_string *name,
struct aws_byte_cursor *out_value) {
struct aws_signable_canonical_request_impl *impl = signable->impl;
AWS_ZERO_STRUCT(*out_value);
/*
* uri and method can be queried directly from the wrapper request
*/
if (aws_string_eq(name, g_aws_canonical_request_property_name)) {
*out_value = aws_byte_cursor_from_string(impl->canonical_request);
} else {
return aws_raise_error(AWS_ERROR_INVALID_ARGUMENT);
}
return AWS_OP_SUCCESS;
}
static int s_aws_signable_canonical_request_get_property_list(
const struct aws_signable *signable,
const struct aws_string *name,
struct aws_array_list **out_list) {
(void)signable;
(void)name;
(void)out_list;
*out_list = NULL;
return aws_raise_error(AWS_ERROR_UNSUPPORTED_OPERATION);
}
static int s_aws_signable_canonical_request_get_payload_stream(
const struct aws_signable *signable,
struct aws_input_stream **out_input_stream) {
(void)signable;
*out_input_stream = NULL;
return AWS_OP_SUCCESS;
}
static void s_aws_signable_canonical_request_destroy(struct aws_signable *signable) {
if (signable == NULL) {
return;
}
struct aws_signable_canonical_request_impl *impl = signable->impl;
if (impl == NULL) {
return;
}
aws_string_destroy(impl->canonical_request);
aws_mem_release(signable->allocator, signable);
}
static struct aws_signable_vtable s_signable_canonical_request_vtable = {
.get_property = s_aws_signable_canonical_request_get_property,
.get_property_list = s_aws_signable_canonical_request_get_property_list,
.get_payload_stream = s_aws_signable_canonical_request_get_payload_stream,
.destroy = s_aws_signable_canonical_request_destroy,
};
struct aws_signable *aws_signable_new_canonical_request(
struct aws_allocator *allocator,
struct aws_byte_cursor canonical_request) {
struct aws_signable *signable = NULL;
struct aws_signable_canonical_request_impl *impl = NULL;
aws_mem_acquire_many(
allocator,
2,
&signable,
sizeof(struct aws_signable),
&impl,
sizeof(struct aws_signable_canonical_request_impl));
if (signable == NULL || impl == NULL) {
return NULL;
}
AWS_ZERO_STRUCT(*signable);
AWS_ZERO_STRUCT(*impl);
signable->allocator = allocator;
signable->vtable = &s_signable_canonical_request_vtable;
signable->impl = impl;
impl->canonical_request = aws_string_new_from_array(allocator, canonical_request.ptr, canonical_request.len);
if (impl->canonical_request == NULL) {
goto on_error;
}
return signable;
on_error:
aws_signable_destroy(signable);
return NULL;
}
|