imsgbundle.m

使用CFNetwork.framework实现的通信中间件。

//
//  iMsgBundle.m
//  Communicate
//
//  Created by Owen.Qin on 9/23/08.
//  Copyright 2008 __MyCompanyName__. All rights reserved.
//

#import "iMsgBundle.h"


@implementation iMsgBundle


- (id)init{
	return self;
}

- (void)dealloc{
	[super dealloc];
}

//- (NSString*)bundleMsgHeaderWithID:(NSString*)msgId AndUser:(NSString*)user{
//	NSString* head = [NSString stringWithString:msgId];
//	head = [head stringByAppendingString:MSG_HEADER_SEPRATOR];
//	head = [head stringByAppendingString:user];
//	return head;
//}
//
//- (NSString*)bundleMsgWithMsgHeader:(NSString*)header AndBody:(NSString*)body{
//	NSString* msg = [NSString stringWithString:header];
//	msg = [msg stringByAppendingString:MSG_SEPRATOR];
//	msg = [msg stringByAppendingString:body];
//	return msg;
//}
//
//- (NSArray*)unBundleMsgHeadAndBody:(NSString*)nstrMsg{
//	NSArray* array = [nstrMsg componentsSeparatedByString:MSG_SEPRATOR];
//	return array;
//};
//
//- (NSArray*)unBundleMsgHeader:(NSString*)header{
//	NSArray* array = [header componentsSeparatedByString:MSG_HEADER_SEPRATOR];
//	return array;
//}

- (iMsg*)bundleMsgWithMsgId:(NSString*)msgId Dest:(NSString*)dest Body:(NSString*)body{
	iMsg* tagMsg = [[iMsg alloc] init];
	tagMsg->_msgId = msgId;
	tagMsg->_msgDest = dest;
	tagMsg->_msgBody = body;
	
	return tagMsg;
}

- (iMsg*)unBundleMsgWithRecvData:(NSData*)dataMsg{
	iMsg* tagMsg = [[iMsg alloc] init];
	NSString* nstrMsg = [[NSString alloc] initWithData:dataMsg encoding:NSUTF8StringEncoding];
	if ([nstrMsg length] == 0){
		return nil;
	}
	NSArray* arrayMsg = [nstrMsg componentsSeparatedByString:MSG_SEPRATOR];
	[nstrMsg release];
	if ([arrayMsg count] == 1 ){
		// parse header
		NSArray* arrayHead = [[arrayMsg objectAtIndex:0] componentsSeparatedByString:MSG_HEADER_SEPRATOR];
		if ([arrayHead count] == 1){
			tagMsg->_msgId = [arrayHead objectAtIndex:0];
			tagMsg->_msgDest = nil;
		}
		else if ([arrayHead count] == 2){
			tagMsg->_msgId = [arrayHead objectAtIndex:0];
			tagMsg->_msgDest = [arrayHead objectAtIndex:1];
		}
	}
	else if([arrayMsg count] == 2){
		NSArray* arrayHead = [[arrayMsg objectAtIndex:0] componentsSeparatedByString:MSG_HEADER_SEPRATOR];
		if ([arrayHead count] == 1){
			tagMsg->_msgId = [arrayHead objectAtIndex:0];
			tagMsg->_msgDest = nil;
		}
		else if ([arrayHead count] == 2){
			tagMsg->_msgId = [arrayHead objectAtIndex:0];
			tagMsg->_msgDest = [arrayHead objectAtIndex:1];
		}
		// message body
		tagMsg->_msgBody = [arrayMsg objectAtIndex:1];
	}
	
	return tagMsg;
}

- (NSData*)unBundleMsgHeader:(iMsg*)msg{
	NSString* nstrMsg = msg->_msgId;
	if (msg->_msgDest){
		nstrMsg = [nstrMsg stringByAppendingFormat:MSG_HEADER_SEPRATOR];
		nstrMsg = [nstrMsg stringByAppendingFormat:msg->_msgDest];
	}
	if (msg->_msgBody){
		nstrMsg = [nstrMsg stringByAppendingFormat:MSG_SEPRATOR];
		nstrMsg = [nstrMsg stringByAppendingFormat:msg->_msgBody];
	}
	
	NSData* dataMsg = [nstrMsg dataUsingEncoding:NSUTF8StringEncoding];

	return dataMsg;
}

@end