File Coverage

amqp_url.c

Criterion	Covered	Total	%
statement	0	85	0.0
branch	0	52	0.0
condition			n/a
subroutine			n/a
pod			n/a
total	0	137	0.0

// 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;
}