// Copyright 2007 - 2021, Alan Antonuk and the rabbitmq-c contributors. // SPDX-License-Identifier: mit #ifdef HAVE_CONFIG_H #include "config.h" #endif #ifdef _MSC_VER #define _CRT_SECURE_NO_WARNINGS #endif #include "amqp_private.h" #include #include #include #include #include void amqp_default_connection_info(struct amqp_connection_info *ci) { /* Apply defaults */ ci->user = "guest"; ci->password = "guest"; ci->host = "localhost"; ci->port = 5672; ci->vhost = "/"; ci->ssl = 0; } /* Scan for the next delimiter, handling percent-encodings on the way. */ static char find_delim(char **pp, int colon_and_at_sign_are_delims) { char *from = *pp; char *to = from; for (;;) { char ch = *from++; switch (ch) { case ':': case '@': if (!colon_and_at_sign_are_delims) { *to++ = ch; break; } /* fall through */ case 0: case '/': case '?': case '#': case '[': case ']': *to = 0; *pp = from; return ch; case '%': { unsigned int val; int chars; int res = sscanf(from, "%2x%n", &val, &chars); if (res == EOF || res < 1 || chars != 2 || val > CHAR_MAX) /* Return a surprising delimiter to force an error. */ { return '%'; } *to++ = (char)val; from += 2; break; } default: *to++ = ch; break; } } } /* Parse an AMQP URL into its component parts. */ int amqp_parse_url(char *url, struct amqp_connection_info *parsed) { int res = AMQP_STATUS_BAD_URL; char delim; char *start; char *host; char *port = NULL; amqp_default_connection_info(parsed); /* check the prefix */ if (!strncmp(url, "amqp://", 7)) { /* do nothing */ } else if (!strncmp(url, "amqps://", 8)) { parsed->port = 5671; parsed->ssl = 1; } else { goto out; } host = start = url += (parsed->ssl ? 8 : 7); delim = find_delim(&url, 1); if (delim == ':') { /* The colon could be introducing the port or the password part of the userinfo. We don't know yet, so stash the preceding component. */ port = start = url; delim = find_delim(&url, 1); } if (delim == '@') { /* What might have been the host and port were in fact the username and password */ parsed->user = host; if (port) { parsed->password = port; } port = NULL; host = start = url; delim = find_delim(&url, 1); } if (delim == '[') { /* IPv6 address. The bracket should be the first character in the host. */ if (host != start || *host != 0) { goto out; } start = url; delim = find_delim(&url, 0); if (delim != ']') { goto out; } parsed->host = start; start = url; delim = find_delim(&url, 1); /* Closing bracket should be the last character in the host. */ if (*start != 0) { goto out; } } else { /* If we haven't seen the host yet, this is it. */ if (*host != 0) { parsed->host = host; } } if (delim == ':') { port = url; delim = find_delim(&url, 1); } if (port) { char *end; long portnum = strtol(port, &end, 10); if (port == end || *end != 0 || portnum < 0 || portnum > 65535) { goto out; } parsed->port = portnum; } if (delim == '/') { start = url; delim = find_delim(&url, 1); if (delim != 0) { goto out; } parsed->vhost = start; res = AMQP_STATUS_OK; } else if (delim == 0) { res = AMQP_STATUS_OK; } /* Any other delimiter is bad, and we will return AMQP_STATUS_BAD_AMQP_URL. */ out: return res; }