actionlistener.java.svn-base

类似QQ的功能

/*******************************************************************************
 Jimm - Mobile Messaging - J2ME ICQ clone
 Copyright (C) 2003-08  Jimm Project

 This program 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.

 This program 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 this program; if not, write to the Free Software
 Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
 ********************************************************************************
 File: src/jimm/comm/ActionListener.java
 Version: ###VERSION###  Date: ###DATE###
 Author(s): Manuel Linsmayer, Andreas Rossbacher, Spassky Alexander, Igor Palkin
 *******************************************************************************/

package jimm.comm;

import java.io.ByteArrayInputStream;

import jimm.ContactList;
import jimm.ContactItem;
import jimm.DebugLog;
import jimm.Jimm;
import jimm.JimmUI;
import jimm.MainThread;
import jimm.JimmException;
import jimm.Options;
import jimm.SplashCanvas;
import jimm.StatusInfo;

//#sijapp cond.if (target!="DEFAULT")&(modules_FILES="true")#
import jimm.FileTransfer;
//#sijapp cond.end#


public class ActionListener
{
	/** ************************************************************************* */

	// Forwards received packet
	protected void forward(Packet packet) throws JimmException
	{
		// Watch out for channel 4 (Disconnect) packets
		if (packet instanceof DisconnectPacket)
		{
			DisconnectPacket disconnectPacket = (DisconnectPacket) packet;

			// Throw exception
			if (disconnectPacket.getError() == 0x0001)
			{ // Multiple logins
				throw (new JimmException(110, 0));
			} else
			{ // Unknown error
				throw (new JimmException(100, 0));
			}

		}

		/** *********************************************************************** */

		// Watch out for requested offline messages
		if (packet instanceof FromIcqSrvPacket) {
			FromIcqSrvPacket fromIcqSrvPacket = (FromIcqSrvPacket) packet;
			if (fromIcqSrvPacket.getFamily() == 0x0015) {
				int subCommand = fromIcqSrvPacket.getSubcommand();
				switch (subCommand) {
					// Watch out for SRV_OFFLINEMSG
					case FromIcqSrvPacket.SRV_OFFLINEMSG_SUBCMD:
						// Get raw data
						byte[] buf = fromIcqSrvPacket.getData();

						// Check length
						if (buf.length > 13) {
							// Extract UIN
							long uinRaw = Util.getDWord(buf, 0, false);

							String uin = String.valueOf(uinRaw);

							// Extract date of dispatch
							long date = Util.createLongTime(
									Util.getWord(buf, 4, false),
									Util.getByte(buf, 6),
									Util.getByte(buf, 7),
									Util.getByte(buf, 8),
									Util.getByte(buf, 9),
									0);

							// Get type
							int type = Util.getWord(buf, 10, false);

							// Get text length
							int textLen = Util.getWord(buf, 12, false);

							// Get text
							String text = Util.removeCr(Util.byteArrayToString(buf, 14, textLen, Util.isDataUTF8(buf, 14, textLen)));

							// Normal message
							if (type == 0x0001) {
								// Check length
								if (buf.length != 14 + textLen) {
									throw (new JimmException(116, 1));
								}

								// Forward message to contact list
								PlainMessage message = new PlainMessage(uin, Options.getString(Options.OPTION_UIN), Util.gmtTimeToLocalTime(date), text, true);
								MainThread.addMessageSerially(message);
							} // URL message
							else if (type == 0x0004) {
								if (buf.length != 14 + textLen) {
									throw (new JimmException(116, 1));
								}

								// Search for delimiter
								int delim = text.indexOf(0xFE);

								// Split message, if delimiter could be found
								String urlText;
								String url;
								if (delim != -1) {
									urlText = text.substring(0, delim);
									url = text.substring(delim + 1);
								} else {
									urlText = text;
									url = "";
								}

								// Forward message message to contact list
								UrlMessage message = new UrlMessage(uin, Options.getString(Options.OPTION_UIN), Util.gmtTimeToLocalTime(date), url, urlText);
								MainThread.addMessageSerially(message);
							}
						}
						break;

					// Watch out for SRV_DONEOFFLINEMSGS
					case FromIcqSrvPacket.SRV_DONEOFFLINEMSGS_SUBCMD:
						// Send a CLI_TOICQSRV/CLI_ACKOFFLINEMSGS packet
						ToIcqSrvPacket reply = new ToIcqSrvPacket(0x00000000, Options.getString(Options.OPTION_UIN), ToIcqSrvPacket.CLI_ACKOFFLINEMSGS_SUBCMD, new byte[0], new byte[0]);
						Icq.c.sendPacket(reply);
						break;
				}
			}
		}

		// Watch out for channel 2 (SNAC) packets
		else if (packet instanceof SnacPacket)
		{
			SnacPacket snacPacket = (SnacPacket) packet;

			// Typing notify
			//#sijapp cond.if target isnot "DEFAULT"#
			if ((snacPacket.getFamily() == 0x0004)
					&& (snacPacket.getCommand() == 0x0014)
					&& Options.getInt(Options.OPTION_TYPING_MODE) > 0)
			{
				byte[] p = snacPacket.getData();
				int uin_len = Util.getByte(p, 10);
				String uin = Util.byteArrayToString(p, 11, uin_len);
				int flag = Util.getWord(p, 11 + uin_len);
				DebugLog.addText("Typing notify: " + flag);

				if (flag == 0x0002)
					//Begin typing
					MainThread.BeginTyping(uin, true);
				else
					//End typing
					MainThread.BeginTyping(uin, false);
			}
			//#sijapp cond.end#

			// Error after requesting offline messages?
			if ((snacPacket.getFamily() == 0x0015) && (snacPacket.getCommand() == 0x0001))
			{
				// Get data
				byte[] buf = snacPacket.getData();

				// Read the error code from the packet
				int errCode = Util.getWord(buf, 0);

				DebugLog.addText("Error after requesting offline messages, error code: " + errCode);
			}

			// Watch out for SRV_USERONLINE packets
			else if ((snacPacket.getFamily() == SnacPacket.SRV_USERONLINE_FAMILY)
					&& (snacPacket.getCommand() == SnacPacket.SRV_USERONLINE_COMMAND))
			{
				int xStatus = -1;
				String xStatusMessage = null;

//#sijapp cond.if (target!="DEFAULT")&(modules_FILES="true")#
				// DC variables
				byte[] internalIP = new byte[4];
				byte[] externalIP = new byte[4];
				int dcPort = 0;
				int dcType = -1;
				int icqProt = 0;
				int authCookie = 0;
//#sijapp cond.end#

				boolean statusChange = true;
				int dwFT1 = 0, dwFT2 = 0, dwFT3 = 0;
				// int wVersion = 0;
				byte[] capabilities_old = null; // Buffer for old style capabilities (TLV 0x000D)
				byte[] capabilities_new = null; // Buffer for new style capabilities (TLV 0x0019)

				//#sijapp cond.if target!="DEFAULT" & modules_AVATARS="true"#
				// Buddy Icon
				byte[] biHash = new byte[16];	// Buffer for buddy icon md5 hash
				//#sijapp cond.end#

				// Time variables
				int idle = -1;
				int online = -1;
				int signon = -1;
				int regdate = -1;

				// Get data
				byte[] buf = snacPacket.getData();

				// Get UIN of the contact changing status
				int uinLen = Util.getByte(buf, 0);
				String uin = Util.byteArrayToString(buf, 1, uinLen);
				// Get new status and client capabilities
				int status = ContactList.STATUS_ONLINE;
				int marker = 1 + uinLen + 2;
				int tlvNum = Util.getWord(buf, marker);
				marker += 2;
				for (int i = 0; i < tlvNum; i++)
				{
					int tlvType = Util.getWord(buf, marker);
					byte[] tlvData = Util.getTlv(buf, marker);
					if (tlvType == 0x0006) // STATUS
					{
						status = (int) Util.getDWord(tlvData, 0);
					} else if (tlvType == 0x000D) // Old style CAPABILITIES
					{
						//DebugLog.addText("Old caps");
						capabilities_old = tlvData;
					} else if (tlvType == 0x0019) // New style CAPABILITIES
					{
						//DebugLog.addText("New caps");
						capabilities_new = tlvData;
					}

					else if (tlvType == 0x001D)
					{
						int marker1d = 0;
						while (tlvData.length > marker1d)
						{
							int bart_id = Util.getWord(tlvData, marker1d);
							marker1d += 2;
							int bart_flg = Util.getByte(tlvData, marker1d);
							marker1d ++;
							int bart_len = Util.getByte(tlvData, marker1d);
							marker1d ++;

							//#sijapp cond.if target!="DEFAULT" & modules_AVATARS="true"#
							if ((bart_id == 0x0001) && (bart_flg == 0x0001))	// ICON HASH
							{
								System.arraycopy(tlvData, marker1d, biHash, 0, (bart_len < 17) ? bart_len : 0x0010);
							}
							else
							//#sijapp cond.end#
							if ((bart_id == 0x0002) && (bart_flg == 0x0004))
							{
								int textLen = (int)Util.getWord(tlvData, marker1d);
								xStatusMessage = Util.byteArrayToString(tlvData, marker1d+2, textLen, true);
								if (xStatusMessage == null) xStatusMessage = new String();
							}
							else if ((bart_id == 0x000E) && (bart_flg == 0x0000))
							{
								String strData = Util.byteArrayToString(tlvData, marker1d, bart_len, false);
								xStatus = Icq.detectStandartXStatus(strData);
							}
							marker1d += bart_len;
						}
					}
					
//#sijapp cond.if (target != "DEFAULT") & (modules_FILES = "true")#
					else if (tlvType == 0x000A) // External IP
					{
						System.arraycopy(tlvData, 0, externalIP, 0, 4);
					}
					else if (tlvType == 0x000c) // DC Infos
					{
						// dcMarker
						int dcMarker = 0;

						// Get internal IP
						System.arraycopy(tlvData, dcMarker, internalIP, 0, 4);
						dcMarker += 4;

						// Get tcp port
						dcPort = (int) Util.getDWord(tlvData, dcMarker);
						dcMarker += 4;

						// Get DC type
						dcType = Util.getByte(tlvData, dcMarker);
						dcMarker++;

						// Get protocol version
						icqProt = Util.getWord(tlvData, dcMarker);
						dcMarker += 2;

						// Get auth cookie
						authCookie = (int) Util.getDWord(tlvData, dcMarker);
						dcMarker += 12;

						// Get data for client detection
						dwFT1 = (int) Util.getDWord(tlvData, dcMarker);
						dcMarker += 4;
						dwFT2 = (int) Util.getDWord(tlvData, dcMarker);
						dcMarker += 4;
						dwFT3 = (int) Util.getDWord(tlvData, dcMarker);

						statusChange = false;

					}
//#sijapp cond.end#
					
					else if (tlvType == 0x0003) // Signon time
					{
						signon = (int) Util.gmtTimeToLocalTime(Util.byteArrayToLong(tlvData));
						//System.out.println(Util.getDateString(false,signon));
					} else if (tlvType == 0x0004) // Idle time
					{
						idle = (int) Util.byteArrayToLong(tlvData) / 256;
					} else if (tlvType == 0x000F) // Online time
					{
						online = (int) Util.byteArrayToLong(tlvData);
					} else if (tlvType == 0x0005) // Date of registration
					{
						regdate = (int) Util.byteArrayToLong(tlvData);
					}

					marker += 2 + 2 + tlvData.length;

				}

//#sijapp cond.if (target!="DEFAULT") & (modules_FILES="true") #				
				ContactItem item = ContactList.getItembyUIN(uin);

				if (item != null)
				{
					byte[] capsArray = Icq.mergeCapabilities(capabilities_old, capabilities_new);
					Icq.detectUserClientAndParseCaps(item, dwFT1, dwFT2, dwFT3, capsArray, icqProt, statusChange);
					if (xStatus == -1)
						xStatus = Icq.detectXStatus(capsArray);
				}
				MainThread.updateContactList(uin, status, xStatus, xStatusMessage, internalIP, externalIP, dcPort, dcType, icqProt, authCookie, signon, online, idle, regdate
					//#sijapp cond.if modules_AVATARS="true"#
					, biHash
					//#sijapp cond.end#
				);
//#sijapp cond.else#
				MainThread.updateContactList(uin, status, -1, null, null, null, 0, 0, 0, 0, signon, online, idle, regdate
					//#sijapp cond.if target!="DEFAULT" & modules_AVATARS="true"#
					, null
					//#sijapp cond.end#
				);
//#sijapp cond.end#
			}

			/** ********************************************************************* */

			// Watch out for SRV_USEROFFLINE packets
			if ((snacPacket.getFamily() == SnacPacket.SRV_USEROFFLINE_FAMILY)
					&& (snacPacket.getCommand() == SnacPacket.SRV_USEROFFLINE_COMMAND))
			{

				// Get raw data
				byte[] buf = snacPacket.getData();

				// Get UIN of the contact that goes offline
				int uinLen = Util.getByte(buf, 0);
				String uin = Util.byteArrayToString(buf, 1, uinLen);

				// Update contact list
				MainThread.userOffline(uin);
			}

			/** ********************************************************************* */

			// Watch out for CLI_ACKMSG_COMMAND packets
			else if ((snacPacket.getFamily() == SnacPacket.CLI_ACKMSG_FAMILY)
					&& (snacPacket.getCommand() == SnacPacket.CLI_ACKMSG_COMMAND))
			{
				// Get raw data
				byte[] buf = snacPacket.getData();
				
				int msgId1 = (int)Util.getDWord(buf, 0);
				int msgId2 = (int)Util.getDWord(buf, 4);
				
				// Get length of the uin 
				int uinLen = Util.getByte(buf, 10);
				String uin = Util.byteArrayToString(buf, 11, uinLen);

				// Get message type
				int msgType = Util.getWord(buf, 58 + uinLen, false); // TODO: fix java.lang.ArrayIndexOutOfBoundsException
				boolean gotStausMsg = false;
				int skip = 0;

				if (((msgType == Message.MESSAGE_TYPE_NORM) || (msgType == 26)) // 26 is sended from ICQ6
					&& (msgId2 == 0x0002) 
					&& Options.getBoolean(Options.OPTION_DELIV_MES_INFO))
				{
					MainThread.messageIsDelevered(uin, msgId1);
					return;
				}
				
				if ((msgType >= Message.MESSAGE_TYPE_AWAY)	&& (msgType <= Message.MESSAGE_TYPE_FFC))
				{
					skip = 64;
					gotStausMsg = true;
				} 
				if (msgType == Message.MESSAGE_TYPE_EXTENDED)
				{