mail.cpp

.net 方面的开发说明资料。

				new_event.size = 0;

				EpDispatchEvent(plug, &new_event);

				// delete the allocated data

				delete [] data;
				return false;
			}

			case POP3_REPLY_ERROR :
				mail->m_event_queue.pop_front();

				new_event.protocol = CLSID_MAILRECV_PROTOCOL;
				new_event.msg = MAILRECV_LOGIN_FAILED;
				new_event.data = event->data;
				new_event.size = event->size;

				EpDispatchEvent(plug, &new_event);
				return false;
		};
	}

	return true;
}

static bool DLL_CALLCONV
FilterMessageCount(void *data, PLUG_HANDLE plug, EpEvent *event) {
	MailData *mail = (MailData *)data;

	if (IsEqualGUID(event->protocol, CLSID_PROTOCOL_SYSTEM)) {
		switch(event->msg) {
			case SYSTEM_NOT_CONNECTED :
			case SYSTEM_DISCONNECTED :
			case SYSTEM_IO_ERROR :
				EpRemoveEventFilter(mail->m_plug_handle, FilterMessageCount);
				mail->m_event_queue.clear();
				break;
		};
	} else if (IsEqualGUID(event->protocol, CLSID_POP3_PROTOCOL)) {
		EpEvent new_event;
		new_event.reference_id = 0;
		new_event.timeout = 0;

		switch(event->msg) {
			case POP3_REPLY_OK :
			{
				mail->m_event_queue.pop_front();

				_STL::string message_count;
				_STL::string message_octets;
				int length = strlen((char *)event->data);
				int i = 0;

				while ((i < length) && (event->data[i] != ' '))
					message_count += event->data[i++];

				while ((i < length) && (event->data[i] == ' '))
					++i;

				while (i < length)
					message_octets += event->data[i++];

				MailMessageCount count;
				count.message_count = atoi(message_count.c_str());
				count.octets = atoi(message_octets.c_str());

				new_event.protocol = CLSID_MAILRECV_PROTOCOL;
				new_event.msg = MAILRECV_GETMESSAGECOUNT;
				new_event.data = (unsigned char *)&count;
				new_event.size = sizeof(count);

				EpDispatchEvent(plug, &new_event);
				return false;
			}

			case POP3_REPLY_ERROR :
				mail->m_event_queue.pop_front();

				new_event.protocol = CLSID_MAILRECV_PROTOCOL;
				new_event.msg = MAILRECV_GETMESSAGECOUNT_FAILED;
				new_event.data = event->data;
				new_event.size = event->size;

				EpDispatchEvent(plug, &new_event);
				return true;
		};
	}

	return true;
}

static bool DLL_CALLCONV
FilterDeleteMessage(void *data, PLUG_HANDLE plug, EpEvent *event) {
	MailData *mail = (MailData *)data;

	// cancel any action we were doing when an error occurs on the socket

	if (IsEqualGUID(event->protocol, CLSID_PROTOCOL_SYSTEM)) {
		switch(event->msg) {
			case SYSTEM_NOT_CONNECTED :
			case SYSTEM_DISCONNECTED :
			case SYSTEM_IO_ERROR :
				EpRemoveEventFilter(mail->m_plug_handle, FilterDeleteMessage);
				mail->m_event_queue.clear();
				break;
		};

	// continue a batch send when this is a pop3 protocol

	} else if (IsEqualGUID(event->protocol, CLSID_POP3_PROTOCOL)) {
		EpEvent new_event;
		new_event.reference_id = 0;
		new_event.timeout = 0;

		switch(event->msg) {
			case POP3_REPLY_OK :
				mail->m_event_queue.pop_front();

				new_event.protocol = CLSID_MAILRECV_PROTOCOL;
				new_event.msg = MAILRECV_DELETEMESSAGE;
				new_event.data = NULL;
				new_event.size = 0;

				EpDispatchEvent(plug, &new_event);
				return false;

			case POP3_REPLY_ERROR :
				mail->m_event_queue.pop_front();

				new_event.protocol = CLSID_MAILRECV_PROTOCOL;
				new_event.msg = MAILRECV_DELETEMESSAGE_FAILED;
				new_event.data = event->data;
				new_event.size = event->size;

				EpDispatchEvent(plug, &new_event);
				return false;
		};
	}

	return true;
}

static bool DLL_CALLCONV
FilterGetMessage(void *data, PLUG_HANDLE plug, EpEvent *event) {
	MailData *mail = (MailData *)data;

	// cancel any action we were doing when an error occurs on the socket

	if (IsEqualGUID(event->protocol, CLSID_PROTOCOL_SYSTEM)) {
		switch(event->msg) {
			case SYSTEM_NOT_CONNECTED :
			case SYSTEM_DISCONNECTED :
			case SYSTEM_IO_ERROR :
				EpRemoveEventFilter(mail->m_plug_handle, FilterGetMessage);
				mail->m_event_queue.clear();
				break;
		};
	} else if (IsEqualGUID(event->protocol, CLSID_POP3_PROTOCOL)) {
		EpEvent new_event;
		new_event.reference_id = 0;
		new_event.timeout = 0;

		switch(event->msg) {
			case POP3_REPLY_LISTING :
				if (!mail->mail_content.empty())
					mail->mail_content += _STL::string("\r\n");
				
				mail->mail_content += _STL::string((char *)event->data);
				return false;

			case POP3_REPLY_ENDLIST :
			{
				mail->m_event_queue.pop_front();

				new_event.protocol = CLSID_MAILRECV_PROTOCOL;
				new_event.msg = MAILRECV_GETMESSAGE;
				new_event.data = (unsigned char *)mail->mail_content.c_str();
				new_event.size = mail->mail_content.length() + 1;

				MailDecoder decoder;
				decoder.open(mail->mail_content);

				EpDispatchEvent(plug, &new_event);
				return false;
			}

			case POP3_REPLY_ERROR :
				mail->m_event_queue.pop_front();

				new_event.protocol = CLSID_MAILRECV_PROTOCOL;
				new_event.msg = MAILRECV_GETMESSAGE_FAILED;
				new_event.data = event->data;
				new_event.size = event->size;

				EpDispatchEvent(plug, &new_event);
				return false;
		};
	}

	return true;
}

// --------------------------------------------------------

static void *DLL_CALLCONV
ProtocolCreate(PLUG_HANDLE plug) {
	MailData *mail = new MailData;
	mail->m_plug_handle = plug;
	mail->m_pop3_handle = s_pop3_protocol->create(plug);
	return mail;
}

static bool DLL_CALLCONV
ProtocolReceive(void *self, const unsigned char *data, int size) {
	MailData *mail = (MailData *)self;

	return s_pop3_protocol->receive(mail->m_pop3_handle, data, size);
}

static bool DLL_CALLCONV
ProtocolSend(void *self, EpEvent *event) {
	MailData *mail = (MailData *)self;

	if (IsEqualGUID(event->protocol, CLSID_MAILRECV_PROTOCOL)) {
		EpEvent new_event;
		new_event.protocol = CLSID_POP3_PROTOCOL;
		new_event.reference_id = 0;
		new_event.timeout = 0;

		QueueData data;
		data.m_count = 0;
		data.m_event = (MailReceiveEvents)event->msg;

		switch(event->msg) {
			case MAILRECV_LOGIN :
			{
				EpInstallEventFilter(mail->m_plug_handle, FilterLogin, mail);

				mail->m_event_queue.push_back(data);

				MailRecvLogin *login = (MailRecvLogin *)event->data;
				mail->username = login->username;
				mail->password = login->password;

				new_event.msg = POP3_USER;
				new_event.data = (unsigned char *)mail->username.c_str();
				new_event.size = mail->username.length() + 1;
			
				s_pop3_protocol->send(mail->m_pop3_handle, &new_event);
				return true;
			}

			case MAILRECV_GETMESSAGE :
				EpInstallEventFilter(mail->m_plug_handle, FilterGetMessage, mail);

				mail->m_event_queue.push_back(data);

				mail->mail_content.erase();

				new_event.msg = POP3_RETR;
				new_event.data = event->data;
				new_event.size = event->size;
			
				s_pop3_protocol->send(mail->m_pop3_handle, &new_event);
				return true;

			case MAILRECV_GETMESSAGECOUNT :
				EpInstallEventFilter(mail->m_plug_handle, FilterMessageCount, mail);

				mail->m_event_queue.push_back(data);

				new_event.msg = POP3_STAT;
				new_event.data = event->data;
				new_event.size = event->size;
			
				s_pop3_protocol->send(mail->m_pop3_handle, &new_event);
				return true;

			case MAILRECV_DELETEMESSAGE :
				EpInstallEventFilter(mail->m_plug_handle, FilterDeleteMessage, mail);

				mail->m_event_queue.push_back(data);

				new_event.msg = POP3_DELE;
				new_event.data = event->data;
				new_event.size = event->size;
			
				s_pop3_protocol->send(mail->m_pop3_handle, &new_event);
				return true;
		}


		return false;
	}

	return s_pop3_protocol->send(mail->m_pop3_handle, event);
}

static void DLL_CALLCONV
ProtocolDestroy(void *self) {
	MailData *mail = (MailData *)self;

	s_pop3_protocol->destroy(mail->m_pop3_handle);

	delete mail;
}
*/

// --------------------------------------------------------
// Instantation function
// --------------------------------------------------------

HRESULT DLL_CALLCONV
Pop3CreateSession(void **iif) {
	CPop3Session *object = new CPop3Session;

	if (object) {
		object->AddRef();
		*iif = object;
		return S_OK;
	}

	return E_FAIL;
}