Fixed multiple bugs in POP3 protocol.

This commit is contained in:
Vincent Richard 2005-03-23 08:19:23 +00:00
parent b3af751a92
commit 29cc768d1a
5 changed files with 139 additions and 46 deletions

View File

@ -2,6 +2,12 @@
VERSION 0.6.4cvs
================
2005-03-23 Vincent Richard <vincent@vincent-richard.net>
* messaging/POP3*: fixed incorrect message size. Fixed a bug in
deleteMessages() when 'to == -1' and last message not being
deleted (thanks to Stefan Uhrig).
2005-03-17 Vincent Richard <vincent@vincent-richard.net>
* base.{cpp|hpp}: renamed 'MIME_VERSION' to 'SUPPORTED_MIME_VERSION'.

View File

@ -314,6 +314,51 @@ void POP3Folder::fetchMessages(std::vector <message*>& msg, const int options,
progress->progress(++current, total);
}
if (options & FETCH_SIZE)
{
// Send the "LIST" command
std::ostringstream command;
command << "LIST";
m_store->sendRequest(command.str());
// Get the response
string response;
m_store->readResponse(response, true, NULL);
if (m_store->isSuccessResponse(response))
{
m_store->stripFirstLine(response, response, NULL);
// C: LIST
// S: +OK
// S: 1 47548
// S: 2 12653
// S: .
std::map <int, string> result;
parseMultiListOrUidlResponse(response, result);
for (std::vector <message*>::iterator it = msg.begin() ;
it != msg.end() ; ++it)
{
POP3Message* m = dynamic_cast <POP3Message*>(*it);
std::map <int, string>::const_iterator x = result.find(m->m_num);
if (x != result.end())
{
int size = 0;
std::istringstream iss((*x).second);
iss >> size;
m->m_size = size;
}
}
}
}
if (options & FETCH_UID)
{
// Send the "UIDL" command
@ -335,50 +380,18 @@ void POP3Folder::fetchMessages(std::vector <message*>& msg, const int options,
// S: 1 whqtswO00WBw418f9t5JxYwZ
// S: 2 QhdPYR:00WBw1Ph7x7
// S: .
std::istringstream iss(response);
std::map <int, string> ids;
string line;
while (std::getline(iss, line))
{
string::iterator it = line.begin();
while (it != line.end() && (*it == ' ' || *it == '\t'))
++it;
if (it != line.end())
{
int number = 0;
while (it != line.end() && (*it >= '0' && *it <= '9'))
{
number = (number * 10) + (*it - '0');
++it;
}
while (it != line.end() && !(*it == ' ' || *it == '\t')) ++it;
while (it != line.end() && (*it == ' ' || *it == '\t')) ++it;
if (it != line.end())
{
ids.insert(std::map <int, string>::value_type
(number, string(it, line.end())));
}
}
}
std::map <int, string> result;
parseMultiListOrUidlResponse(response, result);
for (std::vector <message*>::iterator it = msg.begin() ;
it != msg.end() ; ++it)
{
POP3Message* m = dynamic_cast <POP3Message*>(*it);
std::map <int, string>::const_iterator id =
ids.find(m->m_num);
std::map <int, string>::const_iterator x = result.find(m->m_num);
if (id != ids.end())
m->m_uid = (*id).second;
if (x != result.end())
m->m_uid = (*x).second;
}
}
}
@ -397,11 +410,47 @@ void POP3Folder::fetchMessage(message* msg, const int options)
dynamic_cast <POP3Message*>(msg)->fetch(this, options);
if (options & FETCH_SIZE)
{
// Send the "LIST" command
std::ostringstream command;
command << "LIST " << msg->getNumber();
m_store->sendRequest(command.str());
// Get the response
string response;
m_store->readResponse(response, false, NULL);
if (m_store->isSuccessResponse(response))
{
m_store->stripResponseCode(response, response);
// C: LIST 2
// S: +OK 2 4242
string::iterator it = response.begin();
while (it != response.end() && (*it == ' ' || *it == '\t')) ++it;
while (it != response.end() && !(*it == ' ' || *it == '\t')) ++it;
while (it != response.end() && (*it == ' ' || *it == '\t')) ++it;
if (it != response.end())
{
int size = 0;
std::istringstream iss(string(it, response.end()));
iss >> size;
dynamic_cast <POP3Message*>(msg)->m_size = size;
}
}
}
if (options & FETCH_UID)
{
// Send the "UIDL" command
std::ostringstream command;
command << "UIDL";
command << "UIDL " << msg->getNumber();
m_store->sendRequest(command.str());
@ -504,7 +553,9 @@ void POP3Folder::deleteMessages(const int from, const int to)
else if (!isOpen())
throw exceptions::illegal_state("Folder not open");
for (int i = from ; i < to ; ++i)
const int to2 = (to == -1 ? m_messageCount : to);
for (int i = from ; i <= to2 ; ++i)
{
std::ostringstream command;
command << "DELE " << i;
@ -666,5 +717,41 @@ void POP3Folder::expunge()
}
void POP3Folder::parseMultiListOrUidlResponse(const string& response, std::map <int, string>& result)
{
std::istringstream iss(response);
std::map <int, string> ids;
string line;
while (std::getline(iss, line))
{
string::iterator it = line.begin();
while (it != line.end() && (*it == ' ' || *it == '\t'))
++it;
if (it != line.end())
{
int number = 0;
while (it != line.end() && (*it >= '0' && *it <= '9'))
{
number = (number * 10) + (*it - '0');
++it;
}
while (it != line.end() && !(*it == ' ' || *it == '\t')) ++it;
while (it != line.end() && (*it == ' ' || *it == '\t')) ++it;
if (it != line.end())
{
result.insert(std::map <int, string>::value_type(number, string(it, line.end())));
}
}
}
}
} // messaging
} // vmime

View File

@ -29,7 +29,7 @@ namespace messaging {
POP3Message::POP3Message(POP3Folder* folder, const int num)
: m_folder(folder), m_num(num), m_header(NULL)
: m_folder(folder), m_num(num), m_size(-1), m_header(NULL)
{
m_folder->registerMessage(this);
}
@ -64,13 +64,10 @@ const message::uid POP3Message::getUniqueId() const
const int POP3Message::getSize() const
{
if (!m_folder)
throw exceptions::illegal_state("Folder closed");
if (m_size == -1)
throw exceptions::unfetched_object();
POP3Folder::MessageMap::const_iterator it =
m_folder->m_messages.find(const_cast <POP3Message*>(this));
return ((it != m_folder->m_messages.end()) ? (*it).second : 0);
return (m_size);
}

View File

@ -120,6 +120,8 @@ private:
void onClose();
void parseMultiListOrUidlResponse(const string& response, std::map <int, string>& result);
POP3Store* m_store;

View File

@ -77,6 +77,7 @@ private:
POP3Folder* m_folder;
int m_num;
uid m_uid;
int m_size;
header* m_header;
};