123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644 |
- #include "curl_setup.h"
- #ifndef CURL_DISABLE_POP3
- #ifdef HAVE_NETINET_IN_H
- #include <netinet/in.h>
- #endif
- #ifdef HAVE_ARPA_INET_H
- #include <arpa/inet.h>
- #endif
- #ifdef HAVE_NETDB_H
- #include <netdb.h>
- #endif
- #ifdef __VMS
- #include <in.h>
- #include <inet.h>
- #endif
- #include <curl/curl.h>
- #include "urldata.h"
- #include "sendf.h"
- #include "hostip.h"
- #include "progress.h"
- #include "transfer.h"
- #include "escape.h"
- #include "http.h"
- #include "socks.h"
- #include "pop3.h"
- #include "strtoofft.h"
- #include "strcase.h"
- #include "vtls/vtls.h"
- #include "cfilters.h"
- #include "connect.h"
- #include "select.h"
- #include "multiif.h"
- #include "url.h"
- #include "bufref.h"
- #include "curl_sasl.h"
- #include "curl_md5.h"
- #include "warnless.h"
- #include "strdup.h"
- #include "curl_printf.h"
- #include "curl_memory.h"
- #include "memdebug.h"
- #ifndef ARRAYSIZE
- #define ARRAYSIZE(A) (sizeof(A)/sizeof((A)[0]))
- #endif
- static CURLcode pop3_regular_transfer(struct Curl_easy *data, bool *done);
- static CURLcode pop3_do(struct Curl_easy *data, bool *done);
- static CURLcode pop3_done(struct Curl_easy *data, CURLcode status,
- bool premature);
- static CURLcode pop3_connect(struct Curl_easy *data, bool *done);
- static CURLcode pop3_disconnect(struct Curl_easy *data,
- struct connectdata *conn, bool dead);
- static CURLcode pop3_multi_statemach(struct Curl_easy *data, bool *done);
- static int pop3_getsock(struct Curl_easy *data,
- struct connectdata *conn, curl_socket_t *socks);
- static CURLcode pop3_doing(struct Curl_easy *data, bool *dophase_done);
- static CURLcode pop3_setup_connection(struct Curl_easy *data,
- struct connectdata *conn);
- static CURLcode pop3_parse_url_options(struct connectdata *conn);
- static CURLcode pop3_parse_url_path(struct Curl_easy *data);
- static CURLcode pop3_parse_custom_request(struct Curl_easy *data);
- static CURLcode pop3_perform_auth(struct Curl_easy *data, const char *mech,
- const struct bufref *initresp);
- static CURLcode pop3_continue_auth(struct Curl_easy *data, const char *mech,
- const struct bufref *resp);
- static CURLcode pop3_cancel_auth(struct Curl_easy *data, const char *mech);
- static CURLcode pop3_get_message(struct Curl_easy *data, struct bufref *out);
- static CURLcode pop3_write(struct Curl_easy *data,
- const char *str, size_t nread, bool is_eos);
- const struct Curl_handler Curl_handler_pop3 = {
- "pop3",
- pop3_setup_connection,
- pop3_do,
- pop3_done,
- ZERO_NULL,
- pop3_connect,
- pop3_multi_statemach,
- pop3_doing,
- pop3_getsock,
- pop3_getsock,
- ZERO_NULL,
- ZERO_NULL,
- pop3_disconnect,
- pop3_write,
- ZERO_NULL,
- ZERO_NULL,
- ZERO_NULL,
- PORT_POP3,
- CURLPROTO_POP3,
- CURLPROTO_POP3,
- PROTOPT_CLOSEACTION | PROTOPT_NOURLQUERY |
- PROTOPT_URLOPTIONS
- };
- #ifdef USE_SSL
- const struct Curl_handler Curl_handler_pop3s = {
- "pop3s",
- pop3_setup_connection,
- pop3_do,
- pop3_done,
- ZERO_NULL,
- pop3_connect,
- pop3_multi_statemach,
- pop3_doing,
- pop3_getsock,
- pop3_getsock,
- ZERO_NULL,
- ZERO_NULL,
- pop3_disconnect,
- pop3_write,
- ZERO_NULL,
- ZERO_NULL,
- ZERO_NULL,
- PORT_POP3S,
- CURLPROTO_POP3S,
- CURLPROTO_POP3,
- PROTOPT_CLOSEACTION | PROTOPT_SSL
- | PROTOPT_NOURLQUERY | PROTOPT_URLOPTIONS
- };
- #endif
- static const struct SASLproto saslpop3 = {
- "pop",
- pop3_perform_auth,
- pop3_continue_auth,
- pop3_cancel_auth,
- pop3_get_message,
- 255 - 8,
- '*',
- '+',
- SASL_AUTH_DEFAULT,
- SASL_FLAG_BASE64
- };
- #ifdef USE_SSL
- static void pop3_to_pop3s(struct connectdata *conn)
- {
-
- conn->handler = &Curl_handler_pop3s;
-
- conn->bits.tls_upgraded = TRUE;
- }
- #else
- #define pop3_to_pop3s(x) Curl_nop_stmt
- #endif
- struct pop3_cmd {
- const char *name;
- unsigned short nlen;
- BIT(multiline);
- BIT(multiline_with_args);
- };
- static const struct pop3_cmd pop3cmds[] = {
- { "APOP", 4, FALSE, FALSE },
- { "AUTH", 4, FALSE, FALSE },
- { "CAPA", 4, TRUE, TRUE },
- { "DELE", 4, FALSE, FALSE },
- { "LIST", 4, TRUE, FALSE },
- { "MSG", 3, TRUE, TRUE },
- { "NOOP", 4, FALSE, FALSE },
- { "PASS", 4, FALSE, FALSE },
- { "QUIT", 4, FALSE, FALSE },
- { "RETR", 4, TRUE, TRUE },
- { "RSET", 4, FALSE, FALSE },
- { "STAT", 4, FALSE, FALSE },
- { "STLS", 4, FALSE, FALSE },
- { "TOP", 3, TRUE, TRUE },
- { "UIDL", 4, TRUE, FALSE },
- { "USER", 4, FALSE, FALSE },
- { "UTF8", 4, FALSE, FALSE },
- { "XTND", 4, TRUE, TRUE },
- };
- static bool pop3_is_multiline(const char *cmdline)
- {
- size_t i;
- for(i = 0; i < ARRAYSIZE(pop3cmds); ++i) {
- if(strncasecompare(pop3cmds[i].name, cmdline, pop3cmds[i].nlen)) {
- if(!cmdline[pop3cmds[i].nlen])
- return pop3cmds[i].multiline;
- else if(cmdline[pop3cmds[i].nlen] == ' ')
- return pop3cmds[i].multiline_with_args;
- }
- }
-
- return TRUE;
- }
- static bool pop3_endofresp(struct Curl_easy *data, struct connectdata *conn,
- char *line, size_t len, int *resp)
- {
- struct pop3_conn *pop3c = &conn->proto.pop3c;
- (void)data;
-
- if(len >= 4 && !memcmp("-ERR", line, 4)) {
- *resp = '-';
- return TRUE;
- }
-
- if(pop3c->state == POP3_CAPA) {
-
- if(len >= 1 && line[0] == '.')
-
- *resp = '+';
- else
-
- *resp = '*';
- return TRUE;
- }
-
- if(len >= 3 && !memcmp("+OK", line, 3)) {
- *resp = '+';
- return TRUE;
- }
-
- if(len >= 1 && line[0] == '+') {
- *resp = '*';
- return TRUE;
- }
- return FALSE;
- }
- static CURLcode pop3_get_message(struct Curl_easy *data, struct bufref *out)
- {
- char *message = Curl_dyn_ptr(&data->conn->proto.pop3c.pp.recvbuf);
- size_t len = data->conn->proto.pop3c.pp.nfinal;
- if(len > 2) {
-
- len -= 2;
- for(message += 2; *message == ' ' || *message == '\t'; message++, len--)
- ;
-
- while(len--)
- if(message[len] != '\r' && message[len] != '\n' && message[len] != ' ' &&
- message[len] != '\t')
- break;
-
- message[++len] = '\0';
- Curl_bufref_set(out, message, len, NULL);
- }
- else
-
- Curl_bufref_set(out, "", 0, NULL);
- return CURLE_OK;
- }
- static void pop3_state(struct Curl_easy *data, pop3state newstate)
- {
- struct pop3_conn *pop3c = &data->conn->proto.pop3c;
- #if defined(DEBUGBUILD) && !defined(CURL_DISABLE_VERBOSE_STRINGS)
-
- static const char * const names[] = {
- "STOP",
- "SERVERGREET",
- "CAPA",
- "STARTTLS",
- "UPGRADETLS",
- "AUTH",
- "APOP",
- "USER",
- "PASS",
- "COMMAND",
- "QUIT",
-
- };
- if(pop3c->state != newstate)
- infof(data, "POP3 %p state change from %s to %s",
- (void *)pop3c, names[pop3c->state], names[newstate]);
- #endif
- pop3c->state = newstate;
- }
- static CURLcode pop3_perform_capa(struct Curl_easy *data,
- struct connectdata *conn)
- {
- CURLcode result = CURLE_OK;
- struct pop3_conn *pop3c = &conn->proto.pop3c;
- pop3c->sasl.authmechs = SASL_AUTH_NONE;
- pop3c->sasl.authused = SASL_AUTH_NONE;
- pop3c->tls_supported = FALSE;
-
- result = Curl_pp_sendf(data, &pop3c->pp, "%s", "CAPA");
- if(!result)
- pop3_state(data, POP3_CAPA);
- return result;
- }
- static CURLcode pop3_perform_starttls(struct Curl_easy *data,
- struct connectdata *conn)
- {
-
- CURLcode result = Curl_pp_sendf(data, &conn->proto.pop3c.pp, "%s", "STLS");
- if(!result)
- pop3_state(data, POP3_STARTTLS);
- return result;
- }
- static CURLcode pop3_perform_upgrade_tls(struct Curl_easy *data,
- struct connectdata *conn)
- {
-
- struct pop3_conn *pop3c = &conn->proto.pop3c;
- CURLcode result;
- bool ssldone = FALSE;
- if(!Curl_conn_is_ssl(conn, FIRSTSOCKET)) {
- result = Curl_ssl_cfilter_add(data, conn, FIRSTSOCKET);
- if(result)
- goto out;
- }
- result = Curl_conn_connect(data, FIRSTSOCKET, FALSE, &ssldone);
- if(!result) {
- pop3c->ssldone = ssldone;
- if(pop3c->state != POP3_UPGRADETLS)
- pop3_state(data, POP3_UPGRADETLS);
- if(pop3c->ssldone) {
- pop3_to_pop3s(conn);
- result = pop3_perform_capa(data, conn);
- }
- }
- out:
- return result;
- }
- static CURLcode pop3_perform_user(struct Curl_easy *data,
- struct connectdata *conn)
- {
- CURLcode result = CURLE_OK;
-
- if(!data->state.aptr.user) {
- pop3_state(data, POP3_STOP);
- return result;
- }
-
- result = Curl_pp_sendf(data, &conn->proto.pop3c.pp, "USER %s",
- conn->user ? conn->user : "");
- if(!result)
- pop3_state(data, POP3_USER);
- return result;
- }
- #ifndef CURL_DISABLE_DIGEST_AUTH
- static CURLcode pop3_perform_apop(struct Curl_easy *data,
- struct connectdata *conn)
- {
- CURLcode result = CURLE_OK;
- struct pop3_conn *pop3c = &conn->proto.pop3c;
- size_t i;
- struct MD5_context *ctxt;
- unsigned char digest[MD5_DIGEST_LEN];
- char secret[2 * MD5_DIGEST_LEN + 1];
-
- if(!data->state.aptr.user) {
- pop3_state(data, POP3_STOP);
- return result;
- }
-
- ctxt = Curl_MD5_init(&Curl_DIGEST_MD5);
- if(!ctxt)
- return CURLE_OUT_OF_MEMORY;
- Curl_MD5_update(ctxt, (const unsigned char *) pop3c->apoptimestamp,
- curlx_uztoui(strlen(pop3c->apoptimestamp)));
- Curl_MD5_update(ctxt, (const unsigned char *) conn->passwd,
- curlx_uztoui(strlen(conn->passwd)));
-
- Curl_MD5_final(ctxt, digest);
-
- for(i = 0; i < MD5_DIGEST_LEN; i++)
- msnprintf(&secret[2 * i], 3, "%02x", digest[i]);
- result = Curl_pp_sendf(data, &pop3c->pp, "APOP %s %s", conn->user, secret);
- if(!result)
- pop3_state(data, POP3_APOP);
- return result;
- }
- #endif
- static CURLcode pop3_perform_auth(struct Curl_easy *data,
- const char *mech,
- const struct bufref *initresp)
- {
- CURLcode result = CURLE_OK;
- struct pop3_conn *pop3c = &data->conn->proto.pop3c;
- const char *ir = (const char *) Curl_bufref_ptr(initresp);
- if(ir) {
-
- result = Curl_pp_sendf(data, &pop3c->pp, "AUTH %s %s", mech, ir);
- }
- else {
-
- result = Curl_pp_sendf(data, &pop3c->pp, "AUTH %s", mech);
- }
- return result;
- }
- static CURLcode pop3_continue_auth(struct Curl_easy *data,
- const char *mech,
- const struct bufref *resp)
- {
- struct pop3_conn *pop3c = &data->conn->proto.pop3c;
- (void)mech;
- return Curl_pp_sendf(data, &pop3c->pp,
- "%s", (const char *) Curl_bufref_ptr(resp));
- }
- static CURLcode pop3_cancel_auth(struct Curl_easy *data, const char *mech)
- {
- struct pop3_conn *pop3c = &data->conn->proto.pop3c;
- (void)mech;
- return Curl_pp_sendf(data, &pop3c->pp, "*");
- }
- static CURLcode pop3_perform_authentication(struct Curl_easy *data,
- struct connectdata *conn)
- {
- CURLcode result = CURLE_OK;
- struct pop3_conn *pop3c = &conn->proto.pop3c;
- saslprogress progress = SASL_IDLE;
-
- if(!Curl_sasl_can_authenticate(&pop3c->sasl, data)) {
- pop3_state(data, POP3_STOP);
- return result;
- }
- if(pop3c->authtypes & pop3c->preftype & POP3_TYPE_SASL) {
-
- result = Curl_sasl_start(&pop3c->sasl, data, FALSE, &progress);
- if(!result)
- if(progress == SASL_INPROGRESS)
- pop3_state(data, POP3_AUTH);
- }
- if(!result && progress == SASL_IDLE) {
- #ifndef CURL_DISABLE_DIGEST_AUTH
- if(pop3c->authtypes & pop3c->preftype & POP3_TYPE_APOP)
-
- result = pop3_perform_apop(data, conn);
- else
- #endif
- if(pop3c->authtypes & pop3c->preftype & POP3_TYPE_CLEARTEXT)
-
- result = pop3_perform_user(data, conn);
- else {
-
- infof(data, "No known authentication mechanisms supported");
- result = CURLE_LOGIN_DENIED;
- }
- }
- return result;
- }
- static CURLcode pop3_perform_command(struct Curl_easy *data)
- {
- CURLcode result = CURLE_OK;
- struct connectdata *conn = data->conn;
- struct POP3 *pop3 = data->req.p.pop3;
- const char *command = NULL;
-
- if(pop3->id[0] == '\0' || data->set.list_only) {
- command = "LIST";
- if(pop3->id[0] != '\0')
-
- pop3->transfer = PPTRANSFER_INFO;
- }
- else
- command = "RETR";
- if(pop3->custom && pop3->custom[0] != '\0')
- command = pop3->custom;
-
- if(pop3->id[0] != '\0')
- result = Curl_pp_sendf(data, &conn->proto.pop3c.pp, "%s %s",
- command, pop3->id);
- else
- result = Curl_pp_sendf(data, &conn->proto.pop3c.pp, "%s", command);
- if(!result) {
- pop3_state(data, POP3_COMMAND);
- data->req.no_body = !pop3_is_multiline(command);
- }
- return result;
- }
- static CURLcode pop3_perform_quit(struct Curl_easy *data,
- struct connectdata *conn)
- {
-
- CURLcode result = Curl_pp_sendf(data, &conn->proto.pop3c.pp, "%s", "QUIT");
- if(!result)
- pop3_state(data, POP3_QUIT);
- return result;
- }
- static CURLcode pop3_state_servergreet_resp(struct Curl_easy *data,
- int pop3code,
- pop3state instate)
- {
- CURLcode result = CURLE_OK;
- struct connectdata *conn = data->conn;
- struct pop3_conn *pop3c = &conn->proto.pop3c;
- const char *line = Curl_dyn_ptr(&data->conn->proto.pop3c.pp.recvbuf);
- size_t len = data->conn->proto.pop3c.pp.nfinal;
- (void)instate;
- if(pop3code != '+') {
- failf(data, "Got unexpected pop3-server response");
- result = CURLE_WEIRD_SERVER_REPLY;
- }
- else if(len > 3) {
-
- char *lt;
- char *gt = NULL;
-
- lt = memchr(line, '<', len);
- if(lt)
-
- gt = memchr(lt, '>', len - (lt - line));
- if(gt) {
-
- size_t timestamplen = gt - lt + 1;
- char *at = memchr(lt, '@', timestamplen);
-
- if(at) {
-
- pop3c->apoptimestamp = Curl_memdup0(lt, timestamplen);
- if(!pop3c->apoptimestamp)
- return CURLE_OUT_OF_MEMORY;
-
- pop3c->authtypes |= POP3_TYPE_APOP;
- }
- }
- if(!result)
- result = pop3_perform_capa(data, conn);
- }
- return result;
- }
- static CURLcode pop3_state_capa_resp(struct Curl_easy *data, int pop3code,
- pop3state instate)
- {
- CURLcode result = CURLE_OK;
- struct connectdata *conn = data->conn;
- struct pop3_conn *pop3c = &conn->proto.pop3c;
- const char *line = Curl_dyn_ptr(&data->conn->proto.pop3c.pp.recvbuf);
- size_t len = data->conn->proto.pop3c.pp.nfinal;
- (void)instate;
-
- if(pop3code == '*') {
-
- if(len >= 4 && !memcmp(line, "STLS", 4))
- pop3c->tls_supported = TRUE;
-
- else if(len >= 4 && !memcmp(line, "USER", 4))
- pop3c->authtypes |= POP3_TYPE_CLEARTEXT;
-
- else if(len >= 5 && !memcmp(line, "SASL ", 5)) {
- pop3c->authtypes |= POP3_TYPE_SASL;
-
- line += 5;
- len -= 5;
-
- for(;;) {
- size_t llen;
- size_t wordlen;
- unsigned short mechbit;
- while(len &&
- (*line == ' ' || *line == '\t' ||
- *line == '\r' || *line == '\n')) {
- line++;
- len--;
- }
- if(!len)
- break;
-
- for(wordlen = 0; wordlen < len && line[wordlen] != ' ' &&
- line[wordlen] != '\t' && line[wordlen] != '\r' &&
- line[wordlen] != '\n';)
- wordlen++;
-
- mechbit = Curl_sasl_decode_mech(line, wordlen, &llen);
- if(mechbit && llen == wordlen)
- pop3c->sasl.authmechs |= mechbit;
- line += wordlen;
- len -= wordlen;
- }
- }
- }
- else {
-
- if(pop3code != '+')
- pop3c->authtypes |= POP3_TYPE_CLEARTEXT;
- if(!data->set.use_ssl || Curl_conn_is_ssl(conn, FIRSTSOCKET))
- result = pop3_perform_authentication(data, conn);
- else if(pop3code == '+' && pop3c->tls_supported)
-
- result = pop3_perform_starttls(data, conn);
- else if(data->set.use_ssl <= CURLUSESSL_TRY)
-
- result = pop3_perform_authentication(data, conn);
- else {
- failf(data, "STLS not supported.");
- result = CURLE_USE_SSL_FAILED;
- }
- }
- return result;
- }
- static CURLcode pop3_state_starttls_resp(struct Curl_easy *data,
- struct connectdata *conn,
- int pop3code,
- pop3state instate)
- {
- CURLcode result = CURLE_OK;
- (void)instate;
-
- if(data->conn->proto.pop3c.pp.overflow)
- return CURLE_WEIRD_SERVER_REPLY;
- if(pop3code != '+') {
- if(data->set.use_ssl != CURLUSESSL_TRY) {
- failf(data, "STARTTLS denied");
- result = CURLE_USE_SSL_FAILED;
- }
- else
- result = pop3_perform_authentication(data, conn);
- }
- else
- result = pop3_perform_upgrade_tls(data, conn);
- return result;
- }
- static CURLcode pop3_state_auth_resp(struct Curl_easy *data,
- int pop3code,
- pop3state instate)
- {
- CURLcode result = CURLE_OK;
- struct connectdata *conn = data->conn;
- struct pop3_conn *pop3c = &conn->proto.pop3c;
- saslprogress progress;
- (void)instate;
- result = Curl_sasl_continue(&pop3c->sasl, data, pop3code, &progress);
- if(!result)
- switch(progress) {
- case SASL_DONE:
- pop3_state(data, POP3_STOP);
- break;
- case SASL_IDLE:
- #ifndef CURL_DISABLE_DIGEST_AUTH
- if(pop3c->authtypes & pop3c->preftype & POP3_TYPE_APOP)
-
- result = pop3_perform_apop(data, conn);
- else
- #endif
- if(pop3c->authtypes & pop3c->preftype & POP3_TYPE_CLEARTEXT)
-
- result = pop3_perform_user(data, conn);
- else {
- failf(data, "Authentication cancelled");
- result = CURLE_LOGIN_DENIED;
- }
- break;
- default:
- break;
- }
- return result;
- }
- #ifndef CURL_DISABLE_DIGEST_AUTH
- static CURLcode pop3_state_apop_resp(struct Curl_easy *data, int pop3code,
- pop3state instate)
- {
- CURLcode result = CURLE_OK;
- (void)instate;
- if(pop3code != '+') {
- failf(data, "Authentication failed: %d", pop3code);
- result = CURLE_LOGIN_DENIED;
- }
- else
-
- pop3_state(data, POP3_STOP);
- return result;
- }
- #endif
- static CURLcode pop3_state_user_resp(struct Curl_easy *data, int pop3code,
- pop3state instate)
- {
- CURLcode result = CURLE_OK;
- struct connectdata *conn = data->conn;
- (void)instate;
- if(pop3code != '+') {
- failf(data, "Access denied. %c", pop3code);
- result = CURLE_LOGIN_DENIED;
- }
- else
-
- result = Curl_pp_sendf(data, &conn->proto.pop3c.pp, "PASS %s",
- conn->passwd ? conn->passwd : "");
- if(!result)
- pop3_state(data, POP3_PASS);
- return result;
- }
- static CURLcode pop3_state_pass_resp(struct Curl_easy *data, int pop3code,
- pop3state instate)
- {
- CURLcode result = CURLE_OK;
- (void)instate;
- if(pop3code != '+') {
- failf(data, "Access denied. %c", pop3code);
- result = CURLE_LOGIN_DENIED;
- }
- else
-
- pop3_state(data, POP3_STOP);
- return result;
- }
- static CURLcode pop3_state_command_resp(struct Curl_easy *data,
- int pop3code,
- pop3state instate)
- {
- CURLcode result = CURLE_OK;
- struct connectdata *conn = data->conn;
- struct POP3 *pop3 = data->req.p.pop3;
- struct pop3_conn *pop3c = &conn->proto.pop3c;
- struct pingpong *pp = &pop3c->pp;
- (void)instate;
- if(pop3code != '+') {
- pop3_state(data, POP3_STOP);
- return CURLE_WEIRD_SERVER_REPLY;
- }
-
- pop3c->eob = 2;
-
- pop3c->strip = 2;
- if(pop3->transfer == PPTRANSFER_BODY) {
-
- Curl_xfer_setup1(data, CURL_XFER_RECV, -1, FALSE);
- if(pp->overflow) {
-
-
- Curl_dyn_tail(&pp->recvbuf, pp->overflow);
- pp->nfinal = 0;
- if(!data->req.no_body) {
- result = pop3_write(data, Curl_dyn_ptr(&pp->recvbuf),
- Curl_dyn_len(&pp->recvbuf), FALSE);
- if(result)
- return result;
- }
-
- Curl_dyn_reset(&pp->recvbuf);
- pp->overflow = 0;
- }
- }
- else
- pp->overflow = 0;
-
- pop3_state(data, POP3_STOP);
- return result;
- }
- static CURLcode pop3_statemachine(struct Curl_easy *data,
- struct connectdata *conn)
- {
- CURLcode result = CURLE_OK;
- int pop3code;
- struct pop3_conn *pop3c = &conn->proto.pop3c;
- struct pingpong *pp = &pop3c->pp;
- size_t nread = 0;
- (void)data;
-
- if(pop3c->state == POP3_UPGRADETLS)
- return pop3_perform_upgrade_tls(data, conn);
-
- if(pp->sendleft)
- return Curl_pp_flushsend(data, pp);
- do {
-
- result = Curl_pp_readresp(data, FIRSTSOCKET, pp, &pop3code, &nread);
- if(result)
- return result;
- if(!pop3code)
- break;
-
- switch(pop3c->state) {
- case POP3_SERVERGREET:
- result = pop3_state_servergreet_resp(data, pop3code, pop3c->state);
- break;
- case POP3_CAPA:
- result = pop3_state_capa_resp(data, pop3code, pop3c->state);
- break;
- case POP3_STARTTLS:
- result = pop3_state_starttls_resp(data, conn, pop3code, pop3c->state);
- break;
- case POP3_AUTH:
- result = pop3_state_auth_resp(data, pop3code, pop3c->state);
- break;
- #ifndef CURL_DISABLE_DIGEST_AUTH
- case POP3_APOP:
- result = pop3_state_apop_resp(data, pop3code, pop3c->state);
- break;
- #endif
- case POP3_USER:
- result = pop3_state_user_resp(data, pop3code, pop3c->state);
- break;
- case POP3_PASS:
- result = pop3_state_pass_resp(data, pop3code, pop3c->state);
- break;
- case POP3_COMMAND:
- result = pop3_state_command_resp(data, pop3code, pop3c->state);
- break;
- case POP3_QUIT:
- pop3_state(data, POP3_STOP);
- break;
- default:
-
- pop3_state(data, POP3_STOP);
- break;
- }
- } while(!result && pop3c->state != POP3_STOP && Curl_pp_moredata(pp));
- return result;
- }
- static CURLcode pop3_multi_statemach(struct Curl_easy *data, bool *done)
- {
- CURLcode result = CURLE_OK;
- struct connectdata *conn = data->conn;
- struct pop3_conn *pop3c = &conn->proto.pop3c;
- if((conn->handler->flags & PROTOPT_SSL) && !pop3c->ssldone) {
- bool ssldone = FALSE;
- result = Curl_conn_connect(data, FIRSTSOCKET, FALSE, &ssldone);
- pop3c->ssldone = ssldone;
- if(result || !pop3c->ssldone)
- return result;
- }
- result = Curl_pp_statemach(data, &pop3c->pp, FALSE, FALSE);
- *done = (pop3c->state == POP3_STOP);
- return result;
- }
- static CURLcode pop3_block_statemach(struct Curl_easy *data,
- struct connectdata *conn,
- bool disconnecting)
- {
- CURLcode result = CURLE_OK;
- struct pop3_conn *pop3c = &conn->proto.pop3c;
- while(pop3c->state != POP3_STOP && !result)
- result = Curl_pp_statemach(data, &pop3c->pp, TRUE, disconnecting);
- return result;
- }
- static CURLcode pop3_init(struct Curl_easy *data)
- {
- CURLcode result = CURLE_OK;
- struct POP3 *pop3;
- pop3 = data->req.p.pop3 = calloc(1, sizeof(struct POP3));
- if(!pop3)
- result = CURLE_OUT_OF_MEMORY;
- return result;
- }
- static int pop3_getsock(struct Curl_easy *data,
- struct connectdata *conn, curl_socket_t *socks)
- {
- return Curl_pp_getsock(data, &conn->proto.pop3c.pp, socks);
- }
- static CURLcode pop3_connect(struct Curl_easy *data, bool *done)
- {
- CURLcode result = CURLE_OK;
- struct connectdata *conn = data->conn;
- struct pop3_conn *pop3c = &conn->proto.pop3c;
- struct pingpong *pp = &pop3c->pp;
- *done = FALSE;
-
- connkeep(conn, "POP3 default");
- PINGPONG_SETUP(pp, pop3_statemachine, pop3_endofresp);
-
- pop3c->preftype = POP3_TYPE_ANY;
- Curl_sasl_init(&pop3c->sasl, data, &saslpop3);
-
- Curl_pp_init(pp);
-
- result = pop3_parse_url_options(conn);
- if(result)
- return result;
-
- pop3_state(data, POP3_SERVERGREET);
- result = pop3_multi_statemach(data, done);
- return result;
- }
- static CURLcode pop3_done(struct Curl_easy *data, CURLcode status,
- bool premature)
- {
- CURLcode result = CURLE_OK;
- struct POP3 *pop3 = data->req.p.pop3;
- (void)premature;
- if(!pop3)
- return CURLE_OK;
- if(status) {
- connclose(data->conn, "POP3 done with bad status");
- result = status;
- }
-
- Curl_safefree(pop3->id);
- Curl_safefree(pop3->custom);
-
- pop3->transfer = PPTRANSFER_BODY;
- return result;
- }
- static CURLcode pop3_perform(struct Curl_easy *data, bool *connected,
- bool *dophase_done)
- {
-
- CURLcode result = CURLE_OK;
- struct POP3 *pop3 = data->req.p.pop3;
- DEBUGF(infof(data, "DO phase starts"));
- if(data->req.no_body) {
-
- pop3->transfer = PPTRANSFER_INFO;
- }
- *dophase_done = FALSE;
-
- result = pop3_perform_command(data);
- if(result)
- return result;
-
- result = pop3_multi_statemach(data, dophase_done);
- *connected = Curl_conn_is_connected(data->conn, FIRSTSOCKET);
- if(*dophase_done)
- DEBUGF(infof(data, "DO phase is complete"));
- return result;
- }
- static CURLcode pop3_do(struct Curl_easy *data, bool *done)
- {
- CURLcode result = CURLE_OK;
- *done = FALSE;
-
- result = pop3_parse_url_path(data);
- if(result)
- return result;
-
- result = pop3_parse_custom_request(data);
- if(result)
- return result;
- result = pop3_regular_transfer(data, done);
- return result;
- }
- static CURLcode pop3_disconnect(struct Curl_easy *data,
- struct connectdata *conn, bool dead_connection)
- {
- struct pop3_conn *pop3c = &conn->proto.pop3c;
- (void)data;
-
- if(!dead_connection && conn->bits.protoconnstart) {
- if(!pop3_perform_quit(data, conn))
- (void)pop3_block_statemach(data, conn, TRUE);
- }
-
- Curl_pp_disconnect(&pop3c->pp);
-
- Curl_sasl_cleanup(conn, pop3c->sasl.authused);
-
- Curl_safefree(pop3c->apoptimestamp);
- return CURLE_OK;
- }
- static CURLcode pop3_dophase_done(struct Curl_easy *data, bool connected)
- {
- (void)data;
- (void)connected;
- return CURLE_OK;
- }
- static CURLcode pop3_doing(struct Curl_easy *data, bool *dophase_done)
- {
- CURLcode result = pop3_multi_statemach(data, dophase_done);
- if(result)
- DEBUGF(infof(data, "DO phase failed"));
- else if(*dophase_done) {
- result = pop3_dophase_done(data, FALSE );
- DEBUGF(infof(data, "DO phase is complete"));
- }
- return result;
- }
- static CURLcode pop3_regular_transfer(struct Curl_easy *data,
- bool *dophase_done)
- {
- CURLcode result = CURLE_OK;
- bool connected = FALSE;
-
- data->req.size = -1;
-
- Curl_pgrsSetUploadCounter(data, 0);
- Curl_pgrsSetDownloadCounter(data, 0);
- Curl_pgrsSetUploadSize(data, -1);
- Curl_pgrsSetDownloadSize(data, -1);
-
- result = pop3_perform(data, &connected, dophase_done);
-
- if(!result && *dophase_done)
- result = pop3_dophase_done(data, connected);
- return result;
- }
- static CURLcode pop3_setup_connection(struct Curl_easy *data,
- struct connectdata *conn)
- {
-
- CURLcode result = pop3_init(data);
- if(result)
- return result;
-
- conn->bits.tls_upgraded = FALSE;
- return CURLE_OK;
- }
- static CURLcode pop3_parse_url_options(struct connectdata *conn)
- {
- CURLcode result = CURLE_OK;
- struct pop3_conn *pop3c = &conn->proto.pop3c;
- const char *ptr = conn->options;
- while(!result && ptr && *ptr) {
- const char *key = ptr;
- const char *value;
- while(*ptr && *ptr != '=')
- ptr++;
- value = ptr + 1;
- while(*ptr && *ptr != ';')
- ptr++;
- if(strncasecompare(key, "AUTH=", 5)) {
- result = Curl_sasl_parse_url_auth_option(&pop3c->sasl,
- value, ptr - value);
- if(result && strncasecompare(value, "+APOP", ptr - value)) {
- pop3c->preftype = POP3_TYPE_APOP;
- pop3c->sasl.prefmech = SASL_AUTH_NONE;
- result = CURLE_OK;
- }
- }
- else
- result = CURLE_URL_MALFORMAT;
- if(*ptr == ';')
- ptr++;
- }
- if(pop3c->preftype != POP3_TYPE_APOP)
- switch(pop3c->sasl.prefmech) {
- case SASL_AUTH_NONE:
- pop3c->preftype = POP3_TYPE_NONE;
- break;
- case SASL_AUTH_DEFAULT:
- pop3c->preftype = POP3_TYPE_ANY;
- break;
- default:
- pop3c->preftype = POP3_TYPE_SASL;
- break;
- }
- return result;
- }
- static CURLcode pop3_parse_url_path(struct Curl_easy *data)
- {
-
- struct POP3 *pop3 = data->req.p.pop3;
- const char *path = &data->state.up.path[1];
-
- return Curl_urldecode(path, 0, &pop3->id, NULL, REJECT_CTRL);
- }
- static CURLcode pop3_parse_custom_request(struct Curl_easy *data)
- {
- CURLcode result = CURLE_OK;
- struct POP3 *pop3 = data->req.p.pop3;
- const char *custom = data->set.str[STRING_CUSTOMREQUEST];
-
- if(custom)
- result = Curl_urldecode(custom, 0, &pop3->custom, NULL, REJECT_CTRL);
- return result;
- }
- static CURLcode pop3_write(struct Curl_easy *data, const char *str,
- size_t nread, bool is_eos)
- {
-
- CURLcode result = CURLE_OK;
- struct SingleRequest *k = &data->req;
- struct connectdata *conn = data->conn;
- struct pop3_conn *pop3c = &conn->proto.pop3c;
- bool strip_dot = FALSE;
- size_t last = 0;
- size_t i;
- (void)is_eos;
-
- for(i = 0; i < nread; i++) {
- size_t prev = pop3c->eob;
- switch(str[i]) {
- case 0x0d:
- if(pop3c->eob == 0) {
- pop3c->eob++;
- if(i) {
-
- result = Curl_client_write(data, CLIENTWRITE_BODY, &str[last],
- i - last);
- if(result)
- return result;
- last = i;
- }
- }
- else if(pop3c->eob == 3)
- pop3c->eob++;
- else
-
- pop3c->eob = 1;
- break;
- case 0x0a:
- if(pop3c->eob == 1 || pop3c->eob == 4)
- pop3c->eob++;
- else
-
- pop3c->eob = 0;
- break;
- case 0x2e:
- if(pop3c->eob == 2)
- pop3c->eob++;
- else if(pop3c->eob == 3) {
-
- strip_dot = TRUE;
- pop3c->eob = 0;
- }
- else
-
- pop3c->eob = 0;
- break;
- default:
- pop3c->eob = 0;
- break;
- }
-
- if(prev && prev >= pop3c->eob) {
-
- while(prev && pop3c->strip) {
- prev--;
- pop3c->strip--;
- }
- if(prev) {
-
- if(strip_dot && prev - 1 > 0) {
- result = Curl_client_write(data, CLIENTWRITE_BODY, (char *)POP3_EOB,
- prev - 1);
- }
- else if(!strip_dot) {
- result = Curl_client_write(data, CLIENTWRITE_BODY, (char *)POP3_EOB,
- prev);
- }
- else {
- result = CURLE_OK;
- }
- if(result)
- return result;
- last = i;
- strip_dot = FALSE;
- }
- }
- }
- if(pop3c->eob == POP3_EOB_LEN) {
-
- result = Curl_client_write(data, CLIENTWRITE_BODY, (char *)POP3_EOB, 2);
- k->keepon &= ~KEEP_RECV;
- pop3c->eob = 0;
- return result;
- }
- if(pop3c->eob)
-
- return CURLE_OK;
- if(nread - last) {
- result = Curl_client_write(data, CLIENTWRITE_BODY, &str[last],
- nread - last);
- }
- return result;
- }
- #endif
|