summaryrefslogtreecommitdiff
path: root/noncore/net/mail/pop3wrapper.cpp
Unidiff
Diffstat (limited to 'noncore/net/mail/pop3wrapper.cpp') (more/less context) (ignore whitespace changes)
-rw-r--r--noncore/net/mail/pop3wrapper.cpp40
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
13POP3wrapper::POP3wrapper( POP3account *a ) 13POP3wrapper::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
21POP3wrapper::~POP3wrapper() 22POP3wrapper::~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
32void 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
30void POP3wrapper::pop3_progress( size_t current, size_t maximum ) 43void 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
35RecBody POP3wrapper::fetchBody( const RecMail &mail ) 48RecBody 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()
396QList<Folder>* POP3wrapper::listFolders() 410QList<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
408QString POP3wrapper::fetchTextPart(const RecMail&,const RecPart&) 422QString 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
413void POP3wrapper::deleteMail(const RecMail&mail) 430void 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
423void POP3wrapper::answeredMail(const RecMail&) 440void POP3wrapper::answeredMail(const RecMail&)
424{ 441{
425} 442}
426 443
427encodedString* POP3wrapper::fetchDecodedPart(const RecMail&,const RecPart&) 444encodedString* 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
432encodedString* POP3wrapper::fetchRawPart(const RecMail&,const RecPart&) 452encodedString* 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
437void POP3wrapper::traverseBody(RecBody&target,mailmessage*message,mailmime*mime,unsigned int current_rec) 460void 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 }