fanccMSNr.src.rar MessageFactory.cpp

www.pudn.com > fanccMSNr.src.rar > MessageFactory.cpp
#include "MessageFactory.hpp" 
#include "BinaryMessage.hpp" 
#include  
 
namespace poral { 
	namespace { 
		BinaryMessage *extractBinaryMessage(string &buffer) { 
			const char *byteBuffer=buffer.data(); 
			size_t size=(unsigned char)byteBuffer[1] + ((unsigned char)byteBuffer[2])*256; 
			if(buffer.size()> nMIMEMessage; 
				nMIMEMessage+=nHeader; 
 
				if((int)(buffer.size())>=nMIMEMessage) { 
					// 버퍼로부터 메시지를 뽑아낸다. 
					string stringMessage = buffer.substr(0, nMIMEMessage); 
					MIMEMessage *message = new MIMEMessage(stringMessage); 
 
					// 뽑아낸 메시지를 버퍼에서 삭제한다. 
					buffer.replace(0, nMIMEMessage, ""); 
					 
					return message; 
				} 
			} 
			return NULL; 
		} 
 
		Message *extractMessage(string &buffer) { 
			string::size_type posNewLine = buffer.find('\n'); 
			if(posNewLine!=string::npos) { 
				// 버퍼로부터 메시지를 뽑아낸다. 
				string stringMessage = buffer.substr(0, posNewLine+1); 
				Message *message = new Message(stringMessage); 
				// 뽑아낸 메시지를 버퍼에서 삭제한다. 
				buffer.replace(0, posNewLine+1, ""); 
 
				return message; 
			} 
			return NULL; 
		} 
	} 
 
	Message *MessageFactory::createMessage(string &buffer) { 
		if(buffer.size()==0) { 
			return NULL; 
		} 
		const char *byteBuffer=buffer.data(); 
		if(byteBuffer[0]==1) { 
			buffer.erase(buffer.begin(), buffer.end()); 
 
			Message *message= new Message; 
			message->setName("CANCEL"); 
			return message; 
		}  
		else if(buffer.data()[0]==0) { 
			return extractBinaryMessage(buffer); 
		}  
		else if(buffer.compare(0,3, "MSG")==0) { 
			return extractMIMEHeader(buffer); 
		}  
		else { 
			return extractMessage(buffer); 
		} 
	} 
 
}