out_stackdriver: check for proper http request key

Signed-off-by: Braydon Kains <[email protected]>

Author: braydonk

plugins/out_stackdriver/stackdriver.c

@@ -1980,8 +1980,10 @@ static int stackdriver_format(struct flb_config *config,
         /* Extract httpRequest */
         init_http_request(&http_request);
         http_request_extra_size = 0;
-        http_request_extracted = extract_http_request(&http_request, obj,
-                                                      &http_request_extra_size);
+        http_request_extracted = extract_http_request(&http_request, 
+                                                      ctx->http_request_key,
+                                                      ctx->http_request_key_size,
+                                                      obj, &http_request_extra_size);
         if (http_request_extracted == FLB_TRUE) {
             entry_size += 1;
         }

plugins/out_stackdriver/stackdriver_http_request.c

@@ -231,6 +231,8 @@ static void validate_latency(msgpack_object_str latency_in_payload,
 
 /* Return true if httpRequest extracted */
 int extract_http_request(struct http_request_field *http_request,
+                         flb_sds_t http_request_key,
+                         int http_request_key_size,
                          msgpack_object *obj, int *extra_subfields)
 {
     http_request_status op_status = NO_HTTPREQUEST;
@@ -249,8 +251,8 @@ int extract_http_request(struct http_request_field *http_request,
     for (; p < pend && op_status == NO_HTTPREQUEST; ++p) {
 
         if (p->val.type != MSGPACK_OBJECT_MAP
-            || !validate_key(p->key, HTTPREQUEST_FIELD_IN_JSON,
-                             HTTP_REQUEST_KEY_SIZE)) {
+            || !validate_key(p->key, http_request_key,
+                             http_request_key_size)) {
 
             continue;
         }

plugins/out_stackdriver/stackdriver_http_request.h

@@ -91,7 +91,9 @@ void add_http_request_field(struct http_request_field *http_request,
  *  If the httpRequest field exists, return TRUE and store the subfields.
  *  If there are extra subfields, count the number.
  */
-int extract_http_request(struct http_request_field *http_request, 
+int extract_http_request(struct http_request_field *http_request,
+                         flb_sds_t http_request_key,
+                         int http_request_key_size,
                          msgpack_object *obj, int *extra_subfields);
 
 /*