Diffstat (limited to 'noncore/net/mail/pop3wrapper.cpp') (more/less context) (ignore whitespace changes)
-rw-r--r-- | noncore/net/mail/pop3wrapper.cpp | 40 |
1 files changed, 32 insertions, 8 deletions
diff --git a/noncore/net/mail/pop3wrapper.cpp b/noncore/net/mail/pop3wrapper.cpp index 65cd4ba..d3447f4 100644 --- a/noncore/net/mail/pop3wrapper.cpp +++ b/noncore/net/mail/pop3wrapper.cpp | |||
@@ -7,33 +7,46 @@ | |||
7 | #include <libetpan/data_message_driver.h> | 7 | #include <libetpan/data_message_driver.h> |
8 | #include <qfile.h> | 8 | #include <qfile.h> |
9 | 9 | ||
10 | /* we don't fetch messages larger than 5 MB */ | 10 | /* we don't fetch messages larger than 5 MB */ |
11 | #define HARD_MSG_SIZE_LIMIT 5242880 | 11 | #define HARD_MSG_SIZE_LIMIT 5242880 |
12 | 12 | ||
13 | POP3wrapper::POP3wrapper( POP3account *a ) | 13 | POP3wrapper::POP3wrapper( POP3account *a ) |
14 | { | 14 | { |
15 | account = a; | 15 | account = a; |
16 | m_pop3 = NULL; | 16 | m_pop3 = NULL; |
17 | msgTempName = a->getFileName()+"_msg_cache"; | 17 | msgTempName = a->getFileName()+"_msg_cache"; |
18 | last_msg_id = 0; | 18 | last_msg_id = 0; |
19 | bodyCache.clear(); | ||
19 | } | 20 | } |
20 | 21 | ||
21 | POP3wrapper::~POP3wrapper() | 22 | POP3wrapper::~POP3wrapper() |
22 | { | 23 | { |
23 | logout(); | 24 | logout(); |
24 | QFile msg_cache(msgTempName); | 25 | QFile msg_cache(msgTempName); |
25 | if (msg_cache.exists()) { | 26 | if (msg_cache.exists()) { |
26 | msg_cache.remove(); | 27 | msg_cache.remove(); |
27 | } | 28 | } |
29 | cleanUpCache(); | ||
30 | } | ||
31 | |||
32 | void POP3wrapper::cleanUpCache() | ||
33 | { | ||
34 | QMap<QString,encodedString*>::Iterator it = bodyCache.begin(); | ||
35 | for (;it!=bodyCache.end();++it) { | ||
36 | encodedString*t = it.data(); | ||
37 | //it.setValue(0); | ||
38 | if (t) delete t; | ||
39 | } | ||
40 | bodyCache.clear(); | ||
28 | } | 41 | } |
29 | 42 | ||
30 | void POP3wrapper::pop3_progress( size_t current, size_t maximum ) | 43 | void POP3wrapper::pop3_progress( size_t current, size_t maximum ) |
31 | { | 44 | { |
32 | //qDebug( "POP3: %i of %i", current, maximum ); | 45 | //qDebug( "POP3: %i of %i", current, maximum ); |
33 | } | 46 | } |
34 | 47 | ||
35 | RecBody POP3wrapper::fetchBody( const RecMail &mail ) | 48 | RecBody POP3wrapper::fetchBody( const RecMail &mail ) |
36 | { | 49 | { |
37 | int err = MAILPOP3_NO_ERROR; | 50 | int err = MAILPOP3_NO_ERROR; |
38 | char *message; | 51 | char *message; |
39 | size_t length = 0; | 52 | size_t length = 0; |
@@ -42,24 +55,25 @@ RecBody POP3wrapper::fetchBody( const RecMail &mail ) | |||
42 | if ( !m_pop3 ) { | 55 | if ( !m_pop3 ) { |
43 | return RecBody(); | 56 | return RecBody(); |
44 | } | 57 | } |
45 | 58 | ||
46 | RecBody body; | 59 | RecBody body; |
47 | 60 | ||
48 | QFile msg_cache(msgTempName); | 61 | QFile msg_cache(msgTempName); |
49 | 62 | ||
50 | if (mail.Msgsize()>HARD_MSG_SIZE_LIMIT) { | 63 | if (mail.Msgsize()>HARD_MSG_SIZE_LIMIT) { |
51 | qDebug("Message to large: %i",mail.Msgsize()); | 64 | qDebug("Message to large: %i",mail.Msgsize()); |
52 | return body; | 65 | return body; |
53 | } | 66 | } |
67 | cleanUpCache(); | ||
54 | if (mail.getNumber()!=last_msg_id) { | 68 | if (mail.getNumber()!=last_msg_id) { |
55 | if (msg_cache.exists()) { | 69 | if (msg_cache.exists()) { |
56 | msg_cache.remove(); | 70 | msg_cache.remove(); |
57 | } | 71 | } |
58 | msg_cache.open(IO_ReadWrite|IO_Truncate); | 72 | msg_cache.open(IO_ReadWrite|IO_Truncate); |
59 | last_msg_id = mail.getNumber(); | 73 | last_msg_id = mail.getNumber(); |
60 | err = mailpop3_retr( m_pop3, mail.getNumber(), &message, &length ); | 74 | err = mailpop3_retr( m_pop3, mail.getNumber(), &message, &length ); |
61 | if ( err != MAILPOP3_NO_ERROR ) { | 75 | if ( err != MAILPOP3_NO_ERROR ) { |
62 | qDebug( "POP3: error retrieving body with index %i", mail.getNumber() ); | 76 | qDebug( "POP3: error retrieving body with index %i", mail.getNumber() ); |
63 | last_msg_id = 0; | 77 | last_msg_id = 0; |
64 | return RecBody(); | 78 | return RecBody(); |
65 | } | 79 | } |
@@ -396,51 +410,60 @@ void POP3wrapper::logout() | |||
396 | QList<Folder>* POP3wrapper::listFolders() | 410 | QList<Folder>* POP3wrapper::listFolders() |
397 | { | 411 | { |
398 | /* TODO: integrate MH directories | 412 | /* TODO: integrate MH directories |
399 | but not before version 0.1 ;) | 413 | but not before version 0.1 ;) |
400 | */ | 414 | */ |
401 | QList<Folder> * folders = new QList<Folder>(); | 415 | QList<Folder> * folders = new QList<Folder>(); |
402 | folders->setAutoDelete( false ); | 416 | folders->setAutoDelete( false ); |
403 | Folder*inb=new Folder("INBOX","/"); | 417 | Folder*inb=new Folder("INBOX","/"); |
404 | folders->append(inb); | 418 | folders->append(inb); |
405 | return folders; | 419 | return folders; |
406 | } | 420 | } |
407 | 421 | ||
408 | QString POP3wrapper::fetchTextPart(const RecMail&,const RecPart&) | 422 | QString POP3wrapper::fetchTextPart(const RecMail&mail,const RecPart&part) |
409 | { | 423 | { |
410 | return ""; | 424 | encodedString*t = fetchDecodedPart(mail,part); |
425 | QString text=t->Content(); | ||
426 | delete t; | ||
427 | return text; | ||
411 | } | 428 | } |
412 | 429 | ||
413 | void POP3wrapper::deleteMail(const RecMail&mail) | 430 | void POP3wrapper::deleteMail(const RecMail&mail) |
414 | { | 431 | { |
415 | login(); | 432 | login(); |
416 | if (!m_pop3) return; | 433 | if (!m_pop3) return; |
417 | int err = mailpop3_dele(m_pop3,mail.getNumber()); | 434 | int err = mailpop3_dele(m_pop3,mail.getNumber()); |
418 | if (err != MAILPOP3_NO_ERROR) { | 435 | if (err != MAILPOP3_NO_ERROR) { |
419 | qDebug("error deleting mail"); | 436 | qDebug("error deleting mail"); |
420 | } | 437 | } |
421 | } | 438 | } |
422 | 439 | ||
423 | void POP3wrapper::answeredMail(const RecMail&) | 440 | void POP3wrapper::answeredMail(const RecMail&) |
424 | { | 441 | { |
425 | } | 442 | } |
426 | 443 | ||
427 | encodedString* POP3wrapper::fetchDecodedPart(const RecMail&,const RecPart&) | 444 | encodedString* POP3wrapper::fetchDecodedPart(const RecMail&,const RecPart&part) |
428 | { | 445 | { |
429 | return new encodedString(); | 446 | QMap<QString,encodedString*>::ConstIterator it = bodyCache.find(part.Identifier()); |
447 | if (it==bodyCache.end()) return new encodedString(); | ||
448 | encodedString*t = decode_String(it.data(),part.Encoding()); | ||
449 | return t; | ||
430 | } | 450 | } |
431 | 451 | ||
432 | encodedString* POP3wrapper::fetchRawPart(const RecMail&,const RecPart&) | 452 | encodedString* POP3wrapper::fetchRawPart(const RecMail&mail,const RecPart&part) |
433 | { | 453 | { |
434 | return new encodedString(); | 454 | QMap<QString,encodedString*>::ConstIterator it = bodyCache.find(part.Identifier()); |
455 | if (it==bodyCache.end()) return new encodedString(); | ||
456 | encodedString*t = it.data(); | ||
457 | return t; | ||
435 | } | 458 | } |
436 | 459 | ||
437 | void POP3wrapper::traverseBody(RecBody&target,mailmessage*message,mailmime*mime,unsigned int current_rec) | 460 | void POP3wrapper::traverseBody(RecBody&target,mailmessage*message,mailmime*mime,unsigned int current_rec) |
438 | { | 461 | { |
439 | if (current_rec >= 10) { | 462 | if (current_rec >= 10) { |
440 | qDebug("too deep recursion!"); | 463 | qDebug("too deep recursion!"); |
441 | } | 464 | } |
442 | if (!message || !mime) { | 465 | if (!message || !mime) { |
443 | return; | 466 | return; |
444 | } | 467 | } |
445 | int r; | 468 | int r; |
446 | char*data = 0; | 469 | char*data = 0; |
@@ -456,26 +479,27 @@ void POP3wrapper::traverseBody(RecBody&target,mailmessage*message,mailmime*mime, | |||
456 | part.setSize(len); | 479 | part.setSize(len); |
457 | fillSingleBody(part,message,mime); | 480 | fillSingleBody(part,message,mime); |
458 | if (part.Type()=="text" && target.Bodytext().isNull()) { | 481 | if (part.Type()=="text" && target.Bodytext().isNull()) { |
459 | encodedString*r = new encodedString(); | 482 | encodedString*r = new encodedString(); |
460 | r->setContent(data,len); | 483 | r->setContent(data,len); |
461 | encodedString*res = decode_String(r,part.Encoding()); | 484 | encodedString*res = decode_String(r,part.Encoding()); |
462 | b = QString(res->Content()); | 485 | b = QString(res->Content()); |
463 | delete r; | 486 | delete r; |
464 | delete res; | 487 | delete res; |
465 | target.setBodytext(b); | 488 | target.setBodytext(b); |
466 | target.setDescription(part); | 489 | target.setDescription(part); |
467 | } else { | 490 | } else { |
468 | /* TODO: Add the content to a list and store it for later use */ | 491 | b = gen_attachment_id(); |
469 | if (data) free(data); | 492 | part.setIdentifier(b); |
493 | bodyCache[b]=new encodedString(data,len); | ||
470 | target.addPart(part); | 494 | target.addPart(part); |
471 | } | 495 | } |
472 | break; | 496 | break; |
473 | case MAILMIME_MULTIPLE: | 497 | case MAILMIME_MULTIPLE: |
474 | for (cur = clist_begin(mime->mm_data.mm_multipart.mm_mp_list) ; cur != NULL ; cur = clist_next(cur)) { | 498 | for (cur = clist_begin(mime->mm_data.mm_multipart.mm_mp_list) ; cur != NULL ; cur = clist_next(cur)) { |
475 | traverseBody(target,message, (mailmime*)clist_content(cur),current_rec+1); | 499 | traverseBody(target,message, (mailmime*)clist_content(cur),current_rec+1); |
476 | } | 500 | } |
477 | break; | 501 | break; |
478 | case MAILMIME_MESSAGE: | 502 | case MAILMIME_MESSAGE: |
479 | if (mime->mm_data.mm_message.mm_msg_mime != NULL) { | 503 | if (mime->mm_data.mm_message.mm_msg_mime != NULL) { |
480 | traverseBody(target,message,mime->mm_data.mm_message.mm_msg_mime,current_rec+1); | 504 | traverseBody(target,message,mime->mm_data.mm_message.mm_msg_mime,current_rec+1); |
481 | } | 505 | } |