VIP Open Access

package MyBot;

import  java.text.SimpleDateFormat;

import  java.util.Date;

import  java.net.*;

import  java.io.*;

import net.sf.jml.Email;

import  net.sf.jml.MsnContact;

import  net.sf.jml.MsnList;

import  net.sf.jml.MsnMessenger;

import  net.sf.jml.MsnProtocol;

import  net.sf.jml.MsnSwitchboard;

import  net.sf.jml.MsnUserStatus;

import  net.sf.jml.event.MsnAdapter;

import  net.sf.jml.impl.MsnContactImpl;

import  net.sf.jml.impl.MsnMessengerFactory;

import  net.sf.jml.message.MsnControlMessage;

import  net.sf.jml.message.MsnDatacastMessage;

import  net.sf.jml.message.MsnInstantMessage;

import  net.sf.jml.message.MsnSystemMessage;

import  net.sf.jml.message.MsnUnknownMessage;

import net.sf.jml.protocol.MsnOutgoingMessage;

/** 

 * @author  tanghf

 * @version 1.3

 * @since 2011/5/10

 **/ 

public class ChatBot extends MsnAdapter {

        private String email;

        private String password;

        private MsnMessenger messenger=null;

        private int timeout=1000;

        public static final int PORT = 8088;

        SimpleDateFormat sdf  =   new  SimpleDateFormat( " MM-dd HH:mm " );

        PrintWriter out;

        public ChatBot() throws IOException{

        }

        public static void main(String [] args)

    throws java.lang.ClassNotFoundException, java.lang.InstantiationException, java.lang.IllegalAccessException

{

                String email,password;

                ChatBot chatbot=(ChatBot) Class.forName( "MyBot.ChatBot" ).newInstance();

                if(args.length==2){

                        email = args[0];

                        password = args[1];

                }else{

                        email = "ask_answer2011@hotmail.com";

                        password = "chatbot";

                }

                chatbot.set(email,password);

                chatbot.start();                

        }

        public void start() {

                messenger = MsnMessengerFactory.createMsnMessenger(email, password);

                messenger.setSupportedProtocol(new MsnProtocol[]{MsnProtocol.MSNP12});

                messenger.getOwner().setInitStatus(MsnUserStatus.ONLINE);

                messenger.addListener( this );

                messenger.login();

        }

        public void loginCompleted(MsnMessenger messenger){        

                System.out.println(messenger+sdf.format(new Date())+" login complete" );

                messenger.getOwner().setDisplayName("I am bot"); 

                String content= messenger+" login complete";

                String fileName="login.log";

                try{

                        writeFile(fileName,content);

                }catch (Exception e){

                        e.printStackTrace();

                        System.out.println(content+"cannot be write to"+fileName);

                }

        }

        public   void instantMessageReceived(MsnSwitchboard switchboard,

            MsnInstantMessage message, MsnContact contact)  {

                System.out.println("message received");

        //String tobox=sdf.format( new  Date())+"#"+contact.getEmail().getEmailAddress()+"#"+message.getContent();

        String XMLstring;

        XMLstring = XMLDisposal.XmlBuild("TVs", sdf.format(new Date()).toString(),

                                contact.getEmail().getEmailAddress().toString(), message.getContent().toString());

        String emailstring=XMLDisposal.GetUser(XMLstring);

                Email con=Email.parseStr(emailstring);

                messenger.sendText(con, "I have login");

        Socket socket=null;

                try{

                        socket=new Socket("localhost",PORT);

                        System.out.println("socket:"+socket);

                        DataInputStream in = new DataInputStream(socket.getInputStream());

                        DataOutputStream out = new DataOutputStream(socket.getOutputStream());

                        socket.setSoTimeout(timeout);

                        //BufferedReader in=new BufferedReader(new InputStreamReader(

                                        //socket.getInputStream()));

                        //PrintWriter out=new PrintWriter(new BufferedWriter(

                                        //new OutputStreamWriter(socket.getOutputStream())),true);

                        //out.println(tobox);

                        //String touser=in.readLine();

                        out.writeUTF(XMLstring);

                        String touser;                 

                        try{

                                touser = in.readUTF();

                        }catch (Exception e){

                                System.out.println(e);

                                touser = "problem occurs, please resend latter";

                        }

                        System.out.println(touser);

                        message.setContent(touser);

                        switchboard.sendMessage(message);

                }catch(Exception e){

                        System.out.println("Exception"+e);

                        System.out.println("database cannot be connect,check it!");

                        String err = "problem occurs, please resend latter";

                        message.setContent(err);

                        switchboard.sendMessage(message);

                }finally{

                        try{

                                socket.close();

                        }catch(Exception e){

                                System.out.println("Exception"+e);

                        }

                }  

   } 

        public void set(String email, String password){

                this.email=email;

                this.password=password;

        }

        public void systemMessageReceived(MsnMessenger messenger,MsnSystemMessage message){                

        }

        public void controlMessageReceived(MsnSwitchboard switchboard,MsnControlMessage message, MsnContact contact){

                switchboard.sendMessage(message,false);

        }

        public void datacastMessageReceived(MsnSwitchboard switchboard,MsnDatacastMessage message, MsnContact friend){

                switchboard.sendMessage(message,false);

        }

        public void unknownMessageReceived(MsnSwitchboard switchboard,MsnUnknownMessage message, MsnContact friend){

        }

        public void contactListInitCompleted(MsnMessenger messenger){

                MsnContact [] mycontact = messenger.getContactList().getContactsInList(MsnList.AL);

                String fileName="login.log";

                String content = "I have "+ mycontact.length+ "contacts";

                ListContact(messenger);

                try{

                        writeFile(fileName,content);

                }catch (Exception e){

                        e.printStackTrace();

                        System.out.println(content+"cannot be write to"+fileName);

                }

        }

        public void ListContact(MsnMessenger messenger){

                MsnContact [] mycontact = messenger.getContactList().getContactsInList(MsnList.AL);

                for(int i=0;i<mycontact.length;i++){

                        String personal = mycontact[i].getDisplayName()+" is "+mycontact[i].getStatus() + 

                                mycontact[i].getPersonalMessage();

                        System.out.println(personal);

                }

        }

        public void contactListSyncCompleted(MsnMessenger messenger){

        }

        public void contactStatusChanged(MsnMessenger messenger,MsnContact friend){

        }

        public void ownerStatusChanged(MsnMessenger messenger){                

        }

        public void contactAddedMe(MsnMessenger messenger, MsnContact friend){

                String content= friend.getEmail() + " add " + messenger;

                String fileName="contactAddedMe.log";

                System.out.println(content);

                messenger.addFriend(friend.getEmail(),friend.getFriendlyName());

                try{

                        writeFile(fileName,content);

                }catch (Exception e){

                        e.printStackTrace();

                        System.out.println(content+"cannot be write to"+fileName);

                }

        }

        public void contactRemovedMe(MsnMessenger messenger, MsnContact friend){

                String content= friend.getEmail() + " delete " + messenger;

                String fileName="contactRemoveMe.log";

                System.out.println(content);

                try{

                        writeFile(fileName,content);

                }catch (Exception e){

                        e.printStackTrace();

                        System.out.println(content+"cannot be write to"+fileName);

                }

                System.out.println(friend.getEmail() + " delete " + messenger);

                messenger.removeFriend(friend.getEmail(),false);

        }

        public void writeFile(String fileName,String content) throws IOException 

        { 

        FileWriter fw = new FileWriter(fileName);

        String time=sdf.format(new Date());

        fw.write("at " + time + "\t"+content); 

        fw.close(); 

        } 

}