X-Git-Url: http://cgit.babelmonkeys.de/?a=blobdiff_plain;f=src%2Fcore%2FJubChatClient.m;h=fa4bd9e0aa2309957810b6e85f711c7296a9f0ef;hb=HEAD;hp=4efa89464e2935ea8e3527526e1a99b97fd8b6fd;hpb=8571a0b0bc73062951d6ba55cc17e0ae2fc87cfc;p=jubjub.git diff --git a/src/core/JubChatClient.m b/src/core/JubChatClient.m index 4efa894..fa4bd9e 100644 --- a/src/core/JubChatClient.m +++ b/src/core/JubChatClient.m @@ -1,31 +1,57 @@ #import "JubChatClient.h" +#import "ObjXMPP/namespaces.h" + +#import "JubAvatarManager.h" + +#define JUB_CLIENT_URI @"http://babelmonkeys.de/jubjub" @implementation JubChatClient -@synthesize connection; -@synthesize roster; -@synthesize presence; -@synthesize ui; +@synthesize connection = _connection; +@synthesize roster = _roster; +@synthesize avatarManager = _avatarManager; +@synthesize contactManager = _contactManager; +@synthesize discoEntity = _discoEntity; +@synthesize presence = _presence; +@synthesize ui = _ui; - initWithConfig: (JubConfig*)config { self = [super init]; @try { - connection = [XMPPConnection new]; + _chatMap = [[OFMutableDictionary alloc] init]; + + _connection = [XMPPConnection new]; + _connection.username = config.username; + _connection.domain = config.domain; + _connection.server = config.server; + _connection.password = config.password; + [_connection addDelegate: self]; + + _roster = [[XMPPRoster alloc] initWithConnection: _connection]; + [_roster addDelegate: self]; - connection.username = config.username; - connection.domain = config.domain; - connection.server = config.server; - connection.password = config.password; - [connection addDelegate: self]; + _discoEntity = + [[XMPPDiscoEntity alloc] initWithConnection: _connection + capsNode: JUB_CLIENT_URI]; - roster = [[XMPPRoster alloc] initWithConnection: connection]; - [roster addDelegate: self]; + XMPPDiscoIdentity *identity = + [XMPPDiscoIdentity identityWithCategory: @"client" + type: @"pc" + name: @"JubJub"]; + [_discoEntity addIdentity: identity]; + [_discoEntity addFeature: XMPP_NS_CAPS]; - streamManagement = [[XMPPStreamManagement alloc] - initWithConnection: connection]; + _avatarManager = + [[JubAvatarManager alloc] initWithClient: self]; - [connection asyncConnectAndHandle]; + _contactManager = [[XMPPContactManager alloc] + initWithConnection: _connection + roster: _roster]; + [_contactManager addDelegate: self]; + + _streamManagement = [[XMPPStreamManagement alloc] + initWithConnection: _connection]; } @catch (id e) { [self release]; @throw e; @@ -36,36 +62,122 @@ - (void)dealloc { - [roster release]; - [streamManagement release]; - [connection release]; - [presence release]; + [_roster removeDelegate: self]; + [_contactManager removeDelegate: self]; + [_connection removeDelegate: self]; + + [_roster release]; + [_contactManager release]; + [_discoEntity release]; + [_streamManagement release]; + [_avatarManager release]; + [_connection release]; + [_presence release]; + [_chatMap release]; [super dealloc]; } -- (void)connection: (XMPPConnection*)connection_ - wasBoundToJID: (XMPPJID*)jid +- (id)chatForContact: (XMPPContact*)contact +{ + OFAutoreleasePool *pool = [OFAutoreleasePool new]; + OFString *bareJID = [contact.rosterItem.JID bareJID]; + + id chat = [_chatMap objectForKey: bareJID]; + if (chat == nil) { + OFString * title = + [@"Chat with " stringByAppendingString: bareJID]; + + chat = [[[[_ui chatUIClass] alloc] + initWithTitle: title + closeBlock: ^{ + [_chatMap removeObjectForKey: bareJID]; + } + sendBlock: ^(OFString *text) { + XMPPMessage *msg = + [XMPPMessage messageWithType: @"chat"]; + msg.body = text; + [contact sendMessage: msg + connection: _connection]; + } + ] autorelease]; + + [_chatMap setObject: chat + forKey: bareJID]; + } + + [pool release]; + + return chat; +} + +- (void)sendPresenceWithStatus: (OFString*)status { - of_log(@"Bound to JID: %@", [jid fullJID]); + [self sendPresenceWithStatus: status + text: nil]; +} + +- (void)sendPresenceWithStatus: (OFString*)status + text: (OFString*)text +{ + XMPPPresence *presence; + + if ([status isEqual: @"unavailable"]) + presence = [XMPPPresence presenceWithType: @"unavailable"]; + else + presence = [XMPPPresence presence]; + + if (!([status isEqual: @"available"] || + [status isEqual: @"unavailable"])) + presence.show = status; + + if (text != nil) + presence.status = text; + + OFXMLElement *caps = [OFXMLElement elementWithName: @"c" + namespace: XMPP_NS_CAPS]; + [caps addAttributeWithName: @"hash" + stringValue: @"sha-1"]; + [caps addAttributeWithName: @"ver" + stringValue: [_discoEntity capsHash]]; + [caps addAttributeWithName: @"node" + stringValue: JUB_CLIENT_URI]; + + [presence addChild: caps]; - [roster requestRoster]; + [_connection sendStanza: presence]; } -- (void)connection: (XMPPConnection*)connection_ - didReceivePresence: (XMPPPresence*)presence_ +- (void)connection: (XMPPConnection*)connection + wasBoundToJID: (XMPPJID*)jid +{ + [_roster requestRoster]; +} + +- (void)connection: (XMPPConnection*)connection + didReceivePresence: (XMPPPresence*)presence { - if ([presence_.from isEqual: connection.JID]) { - [ui client: self - didChangePresence: presence_]; - OF_SETTER(presence, presence_, YES, 0); + if ([presence.from isEqual: connection.JID]) { + [_ui client: self + didChangePresence: presence]; + OF_SETTER(_presence, presence, true, 0); } } +- (void)contact: (XMPPContact*)contact + didSendMessage: (XMPPMessage*)message +{ + if (message.body == nil || ![message.type isEqual: @"chat"]) + return; + + id chat = [self chatForContact: contact]; + [chat addMessage: message.body + sender: [message.from bareJID]]; +} + - (void)rosterWasReceived: (XMPPRoster*)roster { - XMPPPresence *pres = [XMPPPresence presence]; - [pres setStatus: @"Hello from JubJub"]; - [connection sendStanza: pres]; + [self sendPresenceWithStatus: @"available" + text: @"Hello from JubJub"]; } @end