1 files changed, 57 insertions, 0 deletions

diff --git a/utils.c b/utils.c
index 5d54b8b..576b17c 100644
--- a/utils.c
+++ b/utils.c
@@ -912,3 +912,60 @@ void import_csv(snac *user)
     else
         snac_log(user, xs_fmt("Cannot open file %s", fn));
 }
+
+static const struct {
+    const char *proto;
+    unsigned short default_port;
+} FALLBACK_PORTS[] = {
+    /* caution: https > http, smpts > smtp */
+    {"https", 443},
+    {"http",  80},
+    {"smtps", 465},
+    {"smtp", 25}
+};
+
+int parse_port(const char *url, const char **errstr)
+{
+    const char *col, *rcol;
+    int tmp, ret = -1;
+
+    if (errstr)
+        *errstr = NULL;
+
+    if (!(col = strchr(url, ':'))) {
+        if (errstr)
+            *errstr = "bad url";
+
+        return -1;
+    }
+
+    for (size_t i = 0; i < sizeof(FALLBACK_PORTS) / sizeof(*FALLBACK_PORTS); ++i) {
+        if (memcmp(url, FALLBACK_PORTS[i].proto, strlen(FALLBACK_PORTS[i].proto)) == 0) {
+            ret = FALLBACK_PORTS[i].default_port;
+            break;
+        }
+    }
+
+    if (!(rcol = strchr(col + 1, ':')))
+        rcol = col;
+
+    if (rcol) {
+        tmp = atoi(rcol + 1);
+        if (tmp == 0) {
+            if (ret != -1)
+                return ret;
+
+            if (errstr)
+                *errstr = strerror(errno);
+
+            return -1;
+        }
+
+        return tmp;
+    }
+
+    if (errstr)
+        *errstr = "unknown protocol";
+
+    return -1;
+}