//////////////////////////////////////////////////////////////////////////////
   // dexterIM - Instant Messaging Framework
   // Copyright (C) 2003 Christoph Walcher
   //
   // 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
  //////////////////////////////////////////////////////////////////////////////
  package net.sf.dexterim.oscar;
  
  import java.io.IOException;
  import java.net.InetSocketAddress;
  import java.util.ArrayList;
  import java.util.Iterator;
  import java.util.List;
  
  import net.sf.dexterim.core.AbstractIMConnection;
  import net.sf.dexterim.core.Account;
  import net.sf.dexterim.core.Contact;
  import net.sf.dexterim.core.ContactList;
  import net.sf.dexterim.core.Conversation;
  import net.sf.dexterim.oscar.client.BosRightsRequest;
  import net.sf.dexterim.oscar.client.BuddyListRightsRequest;
  import net.sf.dexterim.oscar.client.ClientReadyRequest;
  import net.sf.dexterim.oscar.client.LocationRightsRequest;
  import net.sf.dexterim.oscar.client.MessageBuilder;
  import net.sf.dexterim.oscar.client.PersonalInfoRequest;
  import net.sf.dexterim.oscar.client.ServiceRequest;
  import net.sf.dexterim.oscar.client.SetUserInformationRequest;
  import net.sf.dexterim.oscar.entity.CapabilitiesBuilder;
  import net.sf.dexterim.oscar.entity.SnacFamiliesVersions;
  import net.sf.dexterim.oscar.entity.SnacFamily;
  import net.sf.dexterim.oscar.icbm.ICBMParameterRequest;
  import net.sf.dexterim.oscar.icbm.SendMessageRequest;
  import net.sf.dexterim.oscar.io.OscarChannel;
  import net.sf.dexterim.oscar.io.ParserException;
  import net.sf.dexterim.oscar.server.CookieResponse;
  import net.sf.dexterim.oscar.server.MessageOfTheDayResponse;
  import net.sf.dexterim.oscar.server.RateInfoResponse;
  import net.sf.dexterim.oscar.server.Response;
  import net.sf.dexterim.oscar.server.SupportedSnacFamilies;
  
  import org.apache.commons.logging.Log;
  import org.apache.commons.logging.LogFactory;
  
  /***
   * @author christoph
   */
  public class OscarConnection extends AbstractIMConnection {
  
  	private boolean connected;
  
  	private OscarChannel bosChannel;
  
  	private Account account;
  	private Log log = LogFactory.getLog(getClass());
  
  	private List conversations;
  	
  	public OscarConnection() {
  		this.conversations = new ArrayList();
  		this.connected = false;
  	}
  
  	/*
  	 * Connects the initially unconnected AIMConnection to AIM Service
  	 * 
  	 * @see net.sf.dexterim.core.IMConnection#connect(net.sf.dexterim.core.Account)
  	 */
  	public void connect(Account account) {
  		this.account = account;
  
  		try {
  			InetSocketAddress loginServer = new InetSocketAddress("login.icq.com",
  					5190);
  
  			OscarChannel channel = new OscarChannel();
  			channel.connect(loginServer);
  
  			log.debug("Receiving Welcome Message...");
  			channel.readMessage();
  			log.debug("...Welcome Message Received");
  
  			MessageBuilder builder = new MessageBuilder();
  			byte[] identMessage = builder.buildIdentRequest(account);
  
  			log.debug("Sending Ident Message...");
  			channel.write(identMessage);
  			log.debug("...Ident Message sent");
 
 			log.debug("Receiving Cookie Message...");
 			Response message = channel.readMessage();
 			log.debug("...Cookie Message Received");
 
 			channel.close();
 
 			if (!(message instanceof CookieResponse)) {
 				log.error("message:" + message);
 
 				throw new IllegalStateException("Wrong message type received!");
 			}
 
 			CookieResponse cookieResponse = (CookieResponse) message;
 			InetSocketAddress bosAddress = cookieResponse.getBosAddress();
 
 			bosChannel = new OscarChannel();
 			bosChannel.connect(bosAddress);
 
 			Response m = bosChannel.readMessage();
 
 			if (m != null) {
 				log.debug("Welcome message from BOS received...");
 				log.debug(m.toString());
 			}
 			else {
 				log.debug("Welcome message from BOS received but null!");
 			}
 
 			bosChannel.write(builder.buildCookieRequest(cookieResponse.getCookie()));
 			Response snac = bosChannel.readMessage();
 
 			if (!(snac instanceof SupportedSnacFamilies)) {
 				throw new IllegalStateException("Wrong message type received!");
 			}
 
 			SupportedSnacFamilies families = (SupportedSnacFamilies) snac;
 
 			for (Iterator iter = families.iterator(); iter.hasNext();) {
 				Integer family = (Integer) iter.next();
 				log.debug("Family: " + family);
 			}
 
 			byte[] familyVersionRequest = builder.buildFamilyVersionRequest();
 			bosChannel.write(familyVersionRequest);
 
 			SnacFamiliesVersions versionsResponse = (SnacFamiliesVersions) bosChannel
 					.readMessage();
 
 			for (Iterator iter = versionsResponse.iterator(); iter.hasNext();) {
 				SnacFamily family = (SnacFamily) iter.next();
 
 				log.debug(family.toString());
 			}
 
 			Response motdMessage = bosChannel.readMessage();
 
 			if (motdMessage instanceof MessageOfTheDayResponse) {
 				MessageOfTheDayResponse motd = (MessageOfTheDayResponse) motdMessage;
 
 				log.debug("MOTD: " + motd.toString());
 			}
 
 			log.debug("Sending Rate Request...");
 			bosChannel.write(builder.buildRateRequest());
 			log.debug("Rate Request sent!");
 
 			Response rateResponse = bosChannel.readMessage();
 
 			if (rateResponse instanceof RateInfoResponse) {
 				log.debug("Rate Response from BOS received!");
 				bosChannel.write(builder
 						.buildRateInfoAcknowledge((RateInfoResponse) rateResponse));
 			}
 
 			log.debug("Connected!");
 			this.connected = true;
 
 			bosChannel.write(new ServiceRequest(ServiceRequest.ADVERTISEMENTS));
 			bosChannel.write(new PersonalInfoRequest());
 			bosChannel.write(new LocationRightsRequest());
 			bosChannel.write(new ICBMParameterRequest());
 			bosChannel.write(new BosRightsRequest());
 			bosChannel.write(new BuddyListRightsRequest());
 
 			bosChannel.write(new SetUserInformationRequest(CapabilitiesBuilder
 					.getInstance().buildCapabilities("icq")));
 
 			
 
 			bosChannel.write(new ClientReadyRequest(families));
 			
 			new Thread("Oscar Message Receiver") {
 				public void run() {
 					Response response = null;
 
 					try {
 						while ((response = bosChannel.readMessage()) != null) {
 							log.debug(response);
 						}
 					}
 					catch (IOException e) {
 						//e.printStackTrace();
 					}
 					catch (ParserException e) {
 						//e.printStackTrace();
 					}
 				}
 			}.start();
 
 		}
 		catch (IOException e) {
 			e.printStackTrace();
 		}
 		catch (ParserException pex) {
 			pex.printStackTrace();
 		}
 	}
 
 	/***
 	 * @see net.sf.dexterim.core.IMConnection#connectedAs()
 	 */
 	public Account connectedAs() {
 		return this.account;
 	}
 
 	/***
 	 * @see net.sf.dexterim.core.IMConnection#disconnect()
 	 */
 	public void disconnect() {
 		try {
 			if (this.bosChannel != null) {
 				this.bosChannel.close();
 			}
 
 			if (this.bosChannel != null) {
 				this.bosChannel.close();
 			}
 		}
 		catch (IOException e) {
 			e.printStackTrace();
 		}
 
 		connected = false;
 	}
 
 	/***
 	 * @see net.sf.dexterim.core.IMConnection#synchronizeContactList(net.sf.dexterim.core.ContactList)
 	 */
 	public void synchronizeContactList(ContactList contactList) {
 		// TODO Auto-generated method stub
 	}
 
 	/***
 	 * @see net.sf.dexterim.core.IMConnection#isConnected()
 	 */
 	public boolean isConnected() {
 		return connected;
 	}
 
 	/***
 	 * @see net.sf.dexterim.core.IMConnection#createConversation()
 	 */
 	public Conversation createConversation() {
 		OscarConversation conversation = new OscarConversation(this);
 		
 		conversations.add(conversation);
 		return conversation;
 	}
 
 	/***
 	 * TODO: Document this
 	 * @param conversation
 	 */
 	public void closeConversation(Conversation conversation) {
 		this.conversations.remove(conversation);
 	}
 
 	/***
 	 * TODO should throw an Exception
 	 * @param contact
 	 * @param message
 	 */
 	public void sendMessage(Contact contact, String message) {
 		try {
 			bosChannel.write(new SendMessageRequest(contact, message, false, true));
 		}
 		catch (IOException e) {
 			e.printStackTrace();
 		}
 	}
 }