utils: validate sds port

Signed-off-by: Eduardo Silva <[email protected]>

Author: edsiper

src/flb_utils.c

@@ -1256,6 +1256,7 @@ int flb_utils_url_split(const char *in_url, char **out_protocol,
 int flb_utils_url_split_sds(const flb_sds_t in_url, flb_sds_t *out_protocol,
                             flb_sds_t *out_host, flb_sds_t *out_port, flb_sds_t *out_uri)
 {
+    int i;
     flb_sds_t protocol = NULL;
     flb_sds_t host = NULL;
     flb_sds_t port = NULL;
@@ -1337,10 +1338,21 @@ int flb_utils_url_split_sds(const flb_sds_t in_url, flb_sds_t *out_protocol,
         flb_errno();
         goto error;
     }
+
     if (!port) {
         flb_errno();
         goto error;
     }
+    else {
+        /* check that port is a number */
+        for (i = 0; i < flb_sds_len(port); i++) {
+            if (!isdigit(port[i])) {
+                goto error;
+            }
+        }
+
+    }
+
     if (!uri) {
         flb_errno();
         goto error;
@@ -1355,7 +1367,16 @@ int flb_utils_url_split_sds(const flb_sds_t in_url, flb_sds_t *out_protocol,
 
  error:
     if (protocol) {
-        flb_free(protocol);
+        flb_sds_destroy(protocol);
+    }
+    if (host) {
+        flb_sds_destroy(host);
+    }
+    if (port) {
+        flb_sds_destroy(port);
+    }
+    if (uri) {
+        flb_sds_destroy(uri);
     }
 
     return -1;