X-Git-Url: http://git.madism.org/?p=apps%2Fmadmutt.git;a=blobdiff_plain;f=lib-mx%2Fpop-new.c;h=4978f8f3797315aec0145967bb1772c511ba45ab;hp=a7e135d50361b8afdc977d8034bd9e526c430121;hb=6d838d9aef36d95fa439b3f7cc06d4e81c8581bd;hpb=a833478d0bab31dd0016520da5049bdf45b29736

diff --git a/lib-mx/pop-new.c b/lib-mx/pop-new.c
index a7e135d..4978f8f 100644
--- a/lib-mx/pop-new.c
+++ b/lib-mx/pop-new.c
@@ -23,14 +23,22 @@
 #include "pop.h"
 #include "account.h"
 
+#define POP3_PORT         110
+#define POP3S_PORT        995
+
+enum pop_state {
+    POP_NEW,
+    POP_READY,
+};
+
 typedef struct pop_data_t {
     int refcnt;
-    job_t *w;
+    enum pop_state state;
 
-    ACCOUNT account;
+    volatile job_t *w;
+
+    ACCOUNT act;
 } pop_data_t;
-DO_INIT(pop_data_t, pop_data);
-DO_WIPE(pop_data_t, pop_data);
 static void pop_data_delete(pop_data_t **tp);
 DO_ARRAY_TYPE(pop_data_t, pop_data);
 DO_ARRAY_FUNCS(pop_data_t, pop_data, pop_data_delete);
@@ -41,17 +49,25 @@ DO_ARRAY_FUNCS(pop_data_t, pop_data, pop_data_delete);
 
 static pop_data_array conns;
 
-static inline pop_data_t *pop_data_new(void) {
-    pop_data_t *res = pop_data_init(p_new(pop_data_t, 1));
+static inline pop_data_t *pop_data_new(void)
+{
+    pop_data_t *res = p_new(pop_data_t, 1);
     res->refcnt = 1;
     pop_data_array_append(&conns, res);
     return res;
 }
-static inline pop_data_t *pop_data_dup(pop_data_t *t) {
+static inline pop_data_t *pop_data_dup(pop_data_t *t)
+{
     t->refcnt++;
     return t;
 }
-static void pop_data_delete(pop_data_t **tp) {
+static void pop_data_wipe(pop_data_t *pd)
+{
+    if (pd->w)
+        IGNORE(el_job_release((job_t *)pd->w, EL_KILLED));
+}
+static void pop_data_delete(pop_data_t **tp)
+{
     if (!*tp)
         return;
     if (--(*tp)->refcnt > 0) {
@@ -83,7 +99,7 @@ static __fini void pop_shutdown(void)
 
 static int pop_setup(job_t *w, void *cfg)
 {
-    w->ptr = cfg;
+    w->ptr = pop_data_dup(cfg);
     /* FIXME */ return el_job_release(w, EL_ERROR);
     return 0;
 }
@@ -103,6 +119,85 @@ static machine_t const pop_machine = {
 /* pop3 mx driver                                                           */
 /****************************************************************************/
 
+static int pop_parse_path(const char *path, ACCOUNT *act)
+{
+    ciss_url_t url;
+    char s[BUFSIZ];
+
+    /* Defaults */
+    act->flags = 0;
+    act->port  = POP3_PORT;
+    act->type  = M_ACCT_TYPE_POP;
+    m_strcpy(s, sizeof(s), path);
+    url_parse_ciss(&url, s);
+
+    if (url.scheme == U_POP || url.scheme == U_POPS) {
+        if (url.scheme == U_POPS) {
+            act->has_ssl = 1;
+            act->port    = POP3S_PORT;
+        }
+
+        if (m_strisempty(url.path) && !mutt_account_fromurl(act, &url))
+            return 0;
+    }
+
+    return -1;
+}
+
+static pop_data_t *pop_find_conn(ACCOUNT *act)
+{
+    pop_data_t *pd = NULL;
+
+    el_lock();
+    for (int i = 0; i < conns.len; i++) {
+        if (mutt_account_match(act, &conns.arr[i]->act)) {
+            pd = pop_data_dup(conns.arr[i]);
+            break;
+        }
+    }
+    if (!pd) {
+        pd = pop_data_new();
+        pd->act = *act;
+    }
+    if (!pd->w) {
+        pd->w = el_job_start(&pop_machine, pd);
+    }
+    while (pd->w && pd->state != POP_READY) {
+        el_wait(pd->w);
+    }
+    if (!pd->w)
+        pop_data_delete(&pd);
+
+    el_unlock();
+    return pd;
+}
+
+static int pop_open_mailbox(CONTEXT *ctx)
+{
+    char buf[BUFSIZ];
+    ACCOUNT act;
+    ciss_url_t url;
+    pop_data_t *pd = NULL;
+
+    if (pop_parse_path(ctx->path, &act)) {
+        mutt_error(_("%s is an invalid POP path"), ctx->path);
+        mutt_sleep(2);
+        return -1;
+    }
+
+    p_clear(&url, 1);
+    mutt_account_tourl(&act, &url);
+
+    pd = pop_find_conn(&act);
+    if (pd) {
+        ctx->data = pd;
+        url_ciss_tostring(&url, buf, sizeof (buf), 0);
+        m_strreplace(&ctx->path, buf);
+    }
+    return 0;
+}
+
 mx_t const pop_mx_ng = {
-    .type = M_POP,
+    .type            = M_POP,
+    .mx_open_mailbox = pop_open_mailbox,
 };