From Jabber

java new DisconnectedState()

java setName("Jabber");

java this.uid = uid; state.login(uid, pwd);

java state.logout();

java state.addContact(c);

java state.removeContact(c);

java state.send(msg);

java System.out.println("Registering " + user + " at " + getConnection().getServerName()); try { java.util.Hashtable info = IQRegister .getRequiredRegInfo(getConnection()); String key; for (java.util.Enumeration e = info.keys(); e.hasMoreElements();) { key = (String) e.nextElement(); if (key.equals(Const.USERNAME)) info.put(key, user); else if (key.equals(Const.PASSWORD)) info.put(key, pwd); else if (key.equals(Const.EMAIL)) info.put(key, user + "@" + getConnection().getServerName()); else if (key.equals(Const.INSTRUCTIONS)) ; else System.err .println("Unknown registration parameter: " + key); } Chunk chunk = getConnection().send( IQRegister.createSetRequest( getConnection().getServerName(), info), 30000); return (chunk != null && chunk.getType().equals(Const.RESULT)); } catch (java.io.IOException e) { im.InstantMessagingClient.getInstance().report(e); } return false;

java if (uid.equals(jid)) { return jid; } else { // strip resource bit if remote user java.util.Vector strip = com.ssttr.util.Strings.tokenize(jid, '/'); return (String) strip.elementAt(0); }

java java.util.Enumeration children = iq.getChildren().elements(); while (children.hasMoreElements()) { com.ssttr.xml.XMLElement el = (com.ssttr.xml.XMLElement) children .nextElement(); if (el instanceof IQRoster) { for (java.util.Enumeration items = el.enumerateChildren(); items .hasMoreElements();) { IQRoster.Item item = (IQRoster.Item) items.nextElement(); System.out.println("Roster Item: " + item); im.model.Contact c = new im.model.Contact(); c.setNetwork(this); c.setUserId(item.getJID()); c.setName(item.getItemName()); setRecvContact(c); if (item.getSubscription().equals(Const.NONE) && (item.getAsk() == null)) { addContact(c); } } } else { System.out.println("Unknown iq element: " + el); } }

java System.out.println("Message: " + message); if (message.getBody() == null) { return; } im.model.Message msg = new im.model.Message(); msg.setSender(stripResource(message.getFrom())); msg.setRecipient(message.getTo()); msg.setContent(message.getBody()); setRecvMsg(msg);

java String type = presence.getType(); if (type == null) type = ""; if (type.equals(Const.SUBSCRIBE)) { // someone wants to subscribe to our presence // so we slightly re-write the packet to send back presence.setType(Const.SUBSCRIBED); System.out.println(presence.getFrom() + " wants to subscribe to your presence, allowing."); } else if (type.equals(Const.UNSUBSCRIBE)) { // someone wants to unsubscribe from our presence // so we slightly re-write the packet to send back presence.setType(Const.UNSUBSCRIBED); System.out.println(presence.getFrom() + " wants to unsubscribe from your presence, allowing."); } else if (type.equals(Const.SUBSCRIBED)) { System.out.println("Subscribed to: " + presence); } else if (type.equals(Const.UNSUBSCRIBED)) { System.out.println("Unsubscribed from: " + presence); } else if (type.equals(Const.UNAVAILABLE)) { im.model.Contact c = new im.model.Contact(); c.setNetwork(this); c.setUserId(stripResource(presence.getFrom())); c.setStatus("offline"); setRecvContact(c); return; } else { System.out.println("Received presence: " + presence); im.model.Contact c = new im.model.Contact(); c.setNetwork(this); c.setUserId(stripResource(presence.getFrom())); if (presence.getShow() != null) c.setStatus(presence.getShow()); else c.setStatus(Const.AVAILABLE); setRecvContact(c); return; } String from = presence.getTo(); presence.setTo(presence.getFrom()); presence.setFrom(from); try { getConnection().send(presence); } catch (java.io.IOException e) { im.InstantMessagingClient.getInstance().report(e); }

java try { System.out.println("Closing connection for " + getConnection().getServerName()); Presence p = new Presence(); p.setType(Const.UNAVAILABLE); getConnection().send(p); getConnection().close(); synchronized (Jabber.this) { Jabber.this.state = new DisconnectedState(); } } catch (java.io.IOException e) { im.InstantMessagingClient.getInstance().report(e); }

java if (!getConnection().isConnected()) { Jabber.this.state = new DisconnectedState(); return; } addContactAsync(c);

java if (!getConnection().isConnected()) { Jabber.this.state = new DisconnectedState(); return; } removeContactAsync(c);

java if (!getConnection().isConnected()) { Jabber.this.state = new DisconnectedState(); return; } sendAsync(msg);

java try { Presence presence = new Presence(c.getUserId(), Const.SUBSCRIBE); System.out.println("Adding contact " + presence); getConnection().send(presence); IQRoster roster = new IQRoster(); roster.addItem(c.getUserId(), c.getName()); IQ iq = new IQ(Const.SET); iq.addChild(roster); getConnection().send(iq); } catch (java.io.IOException e) { im.InstantMessagingClient.getInstance().report(e); }

java try { IQRoster roster = new IQRoster(); roster.addItem(c.getUserId()); ((IQRoster.Item) roster.getChild(0)) .setSubscription(Const.REMOVE); IQ iq = new IQ(Const.SET); iq.addChild(roster); getConnection().send(iq); Presence presence = new Presence(c.getUserId(), Const.UNSUBSCRIBE); System.out.println("Removing contact " + presence); getConnection().send(presence); } catch (java.io.IOException e) { im.InstantMessagingClient.getInstance().report(e); }

java try { Message message = new Message(); message.setTo(msg.getRecipient()); message.setFrom(msg.getSender()); message.setBody(msg.getContent().toString()); System.out.println("Sending " + msg + ": " + message); getConnection().send(message); } catch (java.io.IOException e) { im.InstantMessagingClient.getInstance().report(e); }

java try { java.util.Vector address = com.ssttr.util.Strings .tokenize(uid, '@'); String user = (String) address.elementAt(0); String server = (String) address.elementAt(1); address = com.ssttr.util.Strings.tokenize(server, '/'); server = (String) address.elementAt(0); String resource = (String) address.elementAt(1); connect(server); getConnection().setMessageListener(Jabber.this); getConnection().setIQListener(Jabber.this); getConnection().setPresenceListener(Jabber.this); boolean try_again; do { try_again = false; System.out.println("Logging in " + uid); switch (getConnection().loginAny(user, resource, pwd, 30000)) { case Client2Server.LOGIN_BAD_PASS : throw new java.io.IOException( "Bad password for " + uid); case Client2Server.LOGIN_BAD_UID : if (!registerUser(user, pwd)) throw new java.io.IOException( "Could not register user for " + uid); else try_again = true; break; case Client2Server.LOGIN_FAILED : throw new java.io.IOException( "Login failed: unknown: " + uid); case Client2Server.LOGIN_PASS_EXP : System.out .println("Your password has expired for " + uid); break; case Client2Server.LOGIN_OK : break; } } while (try_again); Presence pres = new Presence(Const.AVAILABLE, "Available", 1); pres.setFrom(uid); getConnection().send(pres); incomingPresence(pres); getConnection().send(IQRoster.createGetRequest()); synchronized (Jabber.this) { Jabber.this.state = new ConnectedState(); } } catch (Exception e) { im.InstantMessagingClient.getInstance().report(e); }