jabber.java

用JAVA编写的基于J2ME的即时消息通信的客户端的程序。用于与JABBER服务器通信

/*
 * Copyright 2004 Grzegorz Grasza [e-mail]
 *
 * This file is part of mobber. Mobber is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by the Free 
 * Software Foundation; either version 2 of the License, or (at your option) any later version.
 * Mobber is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
 * without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
 * PURPOSE.  See the GNU General Public License for more details.
 * You should have received a copy of the GNU General Public License along with mobber;
 * if not, write to the Free Software Foundation, Inc., 59 Temple Place, Suite 330,
 * Boston, MA 02111-1307 USA .
 */

import javax.microedition.io.*;
import utils.*;
import java.io.*;
import java.util.*;
import javax.microedition.lcdui.*;


public class Jabber extends Thread
{
	String host, port, username, resource, password, myjid;
	
	XmlReader reader;
	XmlWriter writer;
	
	Jabber(String host, String port, String username, String password, String resource)
	{
		this.host = host;
		this.port = port;
		this.username = username;
		this.password = password;
		this.resource = resource;
		myjid = username + "@" + host;
		start();
	}
	
	public void run()
	{
		try
		{
			StreamConnection connection = (StreamConnection)Connector.open("socket://" + host + ":" + port);
			reader = new XmlReader(connection.openInputStream());
			writer = new XmlWriter(connection.openOutputStream());
		}
		catch(Exception e)
		{
			//e.printStackTrace();
			// failed to connect
			connectionFailed();
			return;
		}
		// connected
		try
		{
			login();
			parse();
		}
		catch(Exception e)
		{
			//e.printStackTrace();
			// failed to write data
			connectionFailed();
		}
	}
	private void login() throws IOException
	{
		// start stream
		writer.startTag("stream:stream");
		writer.attribute("to",host);
		writer.attribute("xmlns","jabber:client");
		writer.attribute("xmlns:stream","http://etherx.jabber.org/streams");
		writer.flush();
		// log in
		writer.startTag("iq");
		writer.attribute("type","set");
		writer.attribute("id","auth");
		writer.startTag("query");
		writer.attribute("xmlns","jabber:iq:auth");
		
		writer.startTag("username");
		writer.text(username);
		writer.endTag();
		writer.startTag("password");
		writer.text(password);
		writer.endTag();
		writer.startTag("resource");
		writer.text(resource);
		writer.endTag();
		
		writer.endTag(); // query
		writer.endTag(); // iq
		writer.flush();
	}
	public void end()
	{
		try
		{
			writer.endTag();
			writer.flush();
			writer.close();
		}
		catch(Exception e)
		{
			//e.printStackTrace();
			// failed to write data
			connectionFailed();
		}
	}
	public void sendMessage(String to, String topic, String msg)
	{
		try
		{
			writer.startTag("message");
			writer.attribute("to",to);
			if(topic != null)
			{
				writer.startTag("subject");
				writer.text(topic);
				writer.endTag();
			}
			writer.startTag("body");
			writer.text(msg);
			writer.endTag();
			writer.endTag();
			writer.flush();
		}
		catch(Exception e)
		{
			//e.printStackTrace();
			// failed to write data
			connectionFailed();
		}
	}
	public void sendPresence(String to, String type, String show, String status, int priority)
	{
		try
		{
			writer.startTag("presence");
			if(type != null)
				writer.attribute("type", type);
			if(to != null)
				writer.attribute("to", to);
			if(show != null)
			{
				writer.startTag("show");
				writer.text(show);
				writer.endTag();
			}
			if(status != null)
			{
				writer.startTag("status");
				writer.text(status);
				writer.endTag();
			}
			if(priority != 0)
			{
				writer.startTag("priority");
				writer.text(Integer.toString(priority));
				writer.endTag();
			}
			writer.endTag(); // presence
			writer.flush();
		}
		catch(Exception e)
		{
			//e.printStackTrace();
			// failed to write data
			connectionFailed();
		}
	}
	
	public void setContact(String jid, String name, Enumeration group, String subscription)
	{
		try
		{
			writer.startTag("iq");
			writer.attribute("type","set");
			writer.startTag("query");
			writer.attribute("xmlns","jabber:iq:roster");
			writer.startTag("item");
			writer.attribute("jid", jid);
			if(name != null)
				writer.attribute("name", name);
			if(subscription!=null)
				writer.attribute("subscription",subscription);
			if(group != null)
				while(group.hasMoreElements())
				{
					writer.startTag("group");
					writer.text((String)group.nextElement());
					writer.endTag(); // group
				}
			writer.endTag(); // item
			writer.endTag(); // query
			writer.endTag(); // iq
			writer.flush();
		}
		catch(Exception e)
		{
			//e.printStackTrace();
			// failed to write data
			connectionFailed();
		}
	}
	public void getRoster() throws IOException
	{
		writer.startTag("iq");
		writer.attribute("id","roster");
		writer.attribute("type","get");
		writer.startTag("query");
		writer.attribute("xmlns","jabber:iq:roster");
		writer.endTag(); // query
		writer.endTag(); // iq
		writer.flush();
		mobber.roster.noRoster = false;
		mobber.roster.addCommand(Action.edit);
		mobber.roster.addCommand(Action.add);
		mobber.roster.addCommand(Action.delete);
	}
	
	private void parse() throws IOException
	{
		reader.next(); // start tag
		while(reader.next() == reader.START_TAG)
		{
			String tmp = reader.getName();
			if(tmp.equals("message"))
				parseMessage();
			else if(tmp.equals("presence"))
				parsePresence();
			else if(tmp.equals("iq"))
				parseIq();
			else
				parseIgnore();
		}
		reader.close();
	}
	public void parseIq() throws IOException
	{
		String type = reader.getAttribute("type");
		String id = reader.getAttribute("id");
		String from = reader.getAttribute("from");
		if(type.equals("error"))
		while(reader.next() == reader.START_TAG)
		if(reader.getName().equals("error"))
		{
			if(id.equals("auth"))
			{
				// not authorized
				end();
				mobber.display.setCurrent(new Alert(Label.error, parseText(), null, AlertType.ERROR), mobber.login);
			}
			else
				mobber.display.setCurrent(new Alert(Label.error, parseText(), null, AlertType.ERROR));
		}
		if(type.equals("result") && id != null && id.equals("auth"))
		{
			// authorized
			reader.next();
			if(mobber.roster.noRoster)
				getRoster();
			sendPresence(null, null, null, null, 0);
		}
		else
		while(reader.next() == reader.START_TAG)
		{
			if(reader.getName().equals("query"))
			{
				if(reader.getAttribute("xmlns").equals("jabber:iq:roster"))
				{
					while(reader.next() == reader.START_TAG)
					{
						if(reader.getName().equals("item"))
						{
							type = reader.getAttribute("type");
							String jid = reader.getAttribute("jid"),
							name = reader.getAttribute("name"),
							subscription = reader.getAttribute("subscription"),
							ask = reader.getAttribute("ask"),
							newjid = (jid.indexOf('/') == -1) ? jid : jid.substring(0, jid.indexOf('/'));
							boolean check = true;
							mobber.roster.removeContact(newjid);
							while(reader.next() == reader.START_TAG)
							{
								if(reader.getName().equals("group"))
								{
									mobber.roster.setContact(new Contact(newjid, name, parseText()));
									check = false;
								}
								else
									parseIgnore(); //other
							}
							if(check && !subscription.equals("remove"))
								mobber.roster.setContact(new Contact(newjid, name, ""));
						}
						else
							parseIgnore(); //other
					}
				}
				else if(reader.getAttribute("xmlns").equals("jabber:iq:version"))
				{
					while(reader.next() == reader.START_TAG)
					{
						parseIgnore();
					}
					//reader.next();
					// send version
					writer.startTag("iq");
					writer.attribute("type", "result");
					writer.attribute("id", id);
					writer.attribute("to", from);
					writer.startTag("query");
					writer.attribute("xmlns","jabber:iq:version");
					
					writer.startTag("name");
					writer.text("mobber");
					writer.endTag();
					writer.startTag("version");
					writer.text(mobber.version);
					writer.endTag();
					writer.startTag("os");
					writer.text("J2ME");
					writer.endTag();
					
					writer.endTag(); // query
					writer.endTag(); // iq
				}
				else
					parseIgnore();
			}
			else
				parseIgnore();
		}
	}
	
	public void parsePresence() throws IOException
	{
		String from = reader.getAttribute("from"),
		type = reader.getAttribute("type"),
		status = "", show = null;
		//int priority=-1;
		while(reader.next() == reader.START_TAG)
		{
			String tmp = reader.getName();
			if(tmp.equals("status"))
				status = parseText();
			else if(tmp.equals("show"))
				show = parseText();
			//else if(tmp.equals("priority"))
			//	priority = Integer.parseInt(parseText());
			else
				parseIgnore();
		}
		// (from, type, status, show, priority);
		int showint = Contact.none;
		if(show == null)
			showint = Contact.online;
		else if(show.equals(Presence.show[Contact.chat]))
			showint = Contact.chat;
		else if(show.equals(Presence.show[Contact.dnd]))
			showint = Contact.dnd;
		else if(show.equals(Presence.show[Contact.away]))
			showint = Contact.away;
		else if(show.equals(Presence.show[Contact.xa]))
			showint = Contact.xa;
		if(type != null && (type.equals("unavailable") || type.equals("unsubscribed") || type.equals("error")))
			showint = Contact.offline;
		if(type != null && type.equals("subscribe"))
			mobber.display.setCurrent(new SubscriptionRequest(from, status));
		else
		{
			String jid = (from.indexOf('/') == -1) ? from : from.substring(0, from.indexOf('/'));
			if(!myjid.equals(jid))
			{
				boolean check = true;
				if(mobber.roster.groups.containsKey(jid))
				{
					Enumeration groups = ((Vector)mobber.roster.groups.get(jid)).elements();
					while(groups.hasMoreElements())
					{
						check = false;
						mobber.roster.setContact(new Contact(jid, status, showint, (String)groups.nextElement()));
					}
				}
				if(check)
					mobber.roster.setContact(new Contact(jid, status, showint, ""));
			}
		}
	}
	
	public void parseMessage() throws IOException
	{
		String from = reader.getAttribute("from"),
		type = reader.getAttribute("type"),
		body=null, subject=null;
		while(reader.next() == reader.START_TAG)
		{
			String tmp = reader.getName();
			if(tmp.equals("body"))
				body = parseText();
			else if(tmp.equals("subject"))
				subject = parseText();
			else
				parseIgnore();
		}
		// (from, subject, body);
		mobber.message.add((from.indexOf('/') == -1) ? from : from.substring(0, from.indexOf('/')), body);
	}
	
	public String parseText() throws IOException
	{
		String endTagName = reader.getName();
		StringBuffer str = new StringBuffer("");
		int t = reader.next(); // omit start tag
		while(!endTagName.equals(reader.getName()))
		{
			if(t == reader.TEXT)
				str.append(reader.getText());
			t = reader.next();
		}
		return str.toString();
	}
	
	public void parseIgnore() throws IOException
	{
		int x;
		while((x=reader.next()) != reader.END_TAG)
			if(x == reader.START_TAG)
				parseIgnore();
	}
	private void connectionFailed()
	{
		mobber.display.setCurrent(new Alert(Label.error, Label.failed, null, AlertType.ERROR), mobber.login);
	}
};