package app.tabsample;

import org.jivesoftware.smack.ConnectionConfiguration;import org.jivesoftware.smack.XMPPConnection;import org.jivesoftware.smack.XMPPException;import org.jivesoftware.smack.packet.Message;import org.jivesoftware.smack.packet.Presence;

import android.app.Dialog;import android.util.Log;import android.view.View;import android.widget.Button;import android.widget.EditText;

/** * Gather the xmpp settings and create an XMPPConnection*/public class SettingsDialog extends Dialog implements android.view.View.OnClickListener {private XMPPClient xmppClient;

public SettingsDialog(XMPPClient xmppClient) {super(xmppClient);this.xmppClient = xmppClient;    }

protected void onStart() {super.onStart();        setContentView(R.layout.settings);        getWindow().setFlags(4, 4);        setTitle("XMPP Settings");        Button ok = (Button) findViewById(R.id.ok);        ok.setOnClickListener(this);    }

public void onClick(View v) {        String host = "talk.google.com";        String port = "5222";        String service = "google.com";        String username = getText(R.id.userid);        String password = getText(R.id.password);

// Create a connection        ConnectionConfiguration connConfig =new ConnectionConfiguration(host, Integer.parseInt(port), service);        XMPPConnection connection = new XMPPConnection(connConfig);

try {            connection.connect();            Log.i("XMPPClient", "[SettingsDialog] Connected to " + connection.getHost());        } catch (XMPPException ex) {            Log.e("XMPPClient", "[SettingsDialog] Failed to connect to " + connection.getHost());            Log.e("XMPPClient", ex.toString());            xmppClient.setConnection(null);        }try {            connection.login(username, password);            Log.i("XMPPClient", "Logged in as " + connection.getUser());

// Set the status to available            Presence presence = new Presence(Presence.Type.available);            connection.sendPacket(presence);            xmppClient.setConnection(connection);

//Send initial messages to the server            String t = Temp.getID();            String to = "wihoho@appspot.com";            Log.i("XMPPClient", "Sending text [" + t + "] to [" + to + "]");            Message msg = new Message(to, Message.Type.chat);             msg.setSubject("VideoID");            msg.setBody("i"+t); // i is used to indicate this message as sending video ID            connection.sendPacket(msg);

        } catch (XMPPException ex) {            Log.e("XMPPClient", "[SettingsDialog] Failed to log in as " + username);            Log.e("XMPPClient", ex.toString());                xmppClient.setConnection(null);        }        dismiss();    }

private String getText(int id) {        EditText widget = (EditText) this.findViewById(id);return widget.getText().toString();    }}

package app.tabsample;

import android.app.Activity;import android.os.Bundle;import android.os.Handler;import android.util.Log;import android.view.View;import android.widget.ArrayAdapter;import android.widget.Button;import android.widget.EditText;import android.widget.ListView;import org.jivesoftware.smack.PacketListener;import org.jivesoftware.smack.XMPPConnection;import org.jivesoftware.smack.filter.MessageTypeFilter;import org.jivesoftware.smack.filter.PacketFilter;import org.jivesoftware.smack.packet.Message;import org.jivesoftware.smack.packet.Packet;import org.jivesoftware.smack.util.StringUtils;

import java.util.ArrayList;

public class XMPPClient extends Activity {

private ArrayList<String> messages = new ArrayList<String>();private Handler mHandler = new Handler();private SettingsDialog mDialog;//private EditText mRecipient;    private EditText mSendText;private ListView mList;private XMPPConnection connection;

/**     * Called with the activity is first created.*/    @Overridepublic void onCreate(Bundle icicle) {super.onCreate(icicle);        Log.i("XMPPClient", "onCreate called");        setContentView(R.layout.chatting);

//mRecipient = (EditText) this.findViewById(R.id.recipient);//Log.i("XMPPClient", "mRecipient = " + mRecipient);        mSendText = (EditText) this.findViewById(R.id.sendText);        Log.i("XMPPClient", "mSendText = " + mSendText);        mList = (ListView) this.findViewById(R.id.listMessages);        Log.i("XMPPClient", "mList = " + mList);        setListAdapter();

// Dialog for getting the xmpp settings        mDialog = new SettingsDialog(this);

//Sending the Video ID to the app engine//        Temp app = (Temp)getApplicationContext();//        String t = app.getID();//        String to = "gongli.huge@gmail.com";//        Log.i("XMPPClient", "Sending text [" + t + "] to [" + to + "]");//        Message msg = new Message(to, Message.Type.chat);//        msg.setBody(t);//        connection.sendPacket(msg);//End of updating the chatting room

// Set a listener to show the settings dialog        Button setup = (Button) this.findViewById(R.id.setup);        setup.setOnClickListener(new View.OnClickListener() {public void onClick(View view) {                mHandler.post(new Runnable() {public void run() {                        mDialog.show();//........................Send the current video Id to the app engine//                        String t = Temp.getID();//                        String to = "gongli.huge@gmail.com";//                        Log.i("XMPPClient", "Sending text [" + t + "] to [" + to + "]");//                        Message msg = new Message(to, Message.Type.chat);//                        msg.setBody(t);//                        connection.sendPacket(msg);//........................End                    }                });            }        });

// Set a listener to send a chat text message        Button send = (Button) this.findViewById(R.id.send);        send.setOnClickListener(new View.OnClickListener() {public void onClick(View view) {//String to = mRecipient.getText().toString();                String to = "wihoho@appspot.com";                String text = mSendText.getText().toString();

                Log.i("XMPPClient", "Sending text [" + text + "] to [" + to + "]");                Message msg = new Message(to, Message.Type.chat);                msg.setSubject("chat");                msg.setBody("c"+text); //c is used to indicate this message is chatting txt                connection.sendPacket(msg);//messages.add(connection.getUser() + ":"); //messages.add(text);                setListAdapter();            }        });    }

/**     * Called by Settings dialog when a connection is establised with the XMPP server     *     * @param connection*/public void setConnection            (XMPPConnection                    connection) {this.connection = connection;if (connection != null) {// Add a packet listener to get messages sent to us            PacketFilter filter = new MessageTypeFilter(Message.Type.chat);            connection.addPacketListener(new PacketListener() {public void processPacket(Packet packet) {                    Message message = (Message) packet;if (message.getBody() != null) {                        String fromName = StringUtils.parseBareAddress(message.getFrom());                        Log.i("XMPPClient", "Got text [" + message.getBody() + "] from [" + fromName + "]");//messages.add(fromName + ":");                        messages.add(message.getBody());// Add the incoming message to the list view                        mHandler.post(new Runnable() {public void run() {                                setListAdapter();                            }                        });                    }                }            }, filter);        }    }

private void setListAdapter() {        ArrayAdapter<String> adapter = new ArrayAdapter<String>(this,                R.layout.multi_line_list_item,                messages);        mList.setAdapter(adapter);    }}

package com.chat;

import java.io.IOException;import java.util.LinkedList;import java.util.logging.Logger;

import javax.servlet.http.HttpServlet;import javax.servlet.http.HttpServletRequest;import javax.servlet.http.HttpServletResponse;

import com.google.appengine.api.xmpp.JID;import com.google.appengine.api.xmpp.Message;import com.google.appengine.api.xmpp.MessageBuilder;import com.google.appengine.api.xmpp.XMPPService;import com.google.appengine.api.xmpp.XMPPServiceFactory;

@SuppressWarnings("serial")public class ChattingServiceServlet extends HttpServlet {private static final Logger LOG = Logger.getLogger(ChattingServiceServlet.class.getName());private LinkedList<User> users = new LinkedList<User>();

              @Overridepublic void doPost(HttpServletRequest req, HttpServletResponse resp) throws IOException {

// Parse incoming message                XMPPService xmpp = XMPPServiceFactory.getXMPPService();                Message msg = xmpp.parseMessage(req);                JID jid = msg.getFromJid();                String body = msg.getBody();

// Analyze the received message

//Send the video ID                if(body.charAt(0) == 'i'){                    LOG.info(jid.getId() + ": " + body);int m;for(m = 0; m < users.size(); m ++){if(users.get(m).user.toString().equals(getRealID(jid).toString()))break;                    }

//if found                    if(m < users.size())                        users.get(m).videoID = body.substring(1);//if not found                    else{                        users.add(new User(getRealID(jid) ,body.substring(1)));                    }

//indicate that the user has entered the chat room                    String response = "You have entered chatting room: "+body.substring(1)+"\nThe below users are in the same chatting room with you ";                    msg = new MessageBuilder().withRecipientJids(jid).withBody(response).build();                    xmpp.sendMessage(msg);

//Used to print out the current users

for(int n = 0 ; n < users.size(); n++){    if(users.get(n).videoID.equals(body.substring(1))){                            String userinfo = users.get(n).user.toString();                            msg = new MessageBuilder().withRecipientJids(jid).withBody(userinfo).build();                            xmpp.sendMessage(msg);                        }                    }                }

//Send text                else if(body.charAt(0) == 'c'){                    LOG.info(jid.getId() + ": " + body);//Find the video ID of the current user                    int index;for(index = 0; index < users.size(); index ++){if(users.get(index).user.toString().equals(getRealID(jid).toString()))break;                    }//Find the users with the same vdieo ID                    if(index < users.size()){                        LinkedList<JID> jids = getJIDsID(users.get(index).videoID);                        String response = jid.toString()+": "+body.substring(1);

for(int n = 0 ; n < jids.size(); n++){                                                    msg = new MessageBuilder().withRecipientJids(jids.get(n)).withBody(response).build();                            xmpp.sendMessage(msg);                        }                    }                }              }

public JID getRealID(JID receiveID){                  StringBuffer sb = new StringBuffer();int i = 5;

while(receiveID.toString().charAt(i) != '/'){                      sb.append(receiveID.toString().charAt(i));                      i++;assert i < receiveID.toString().length();                  }

return new JID(sb.toString().trim());              }

public LinkedList<JID> getJIDsID(String video){                  LinkedList<JID> jids = new LinkedList<JID>();for(int i= 0; i < users.size();i++){if(users.get(i).videoID.equals(video))                          jids.add(users.get(i).user);                  }return jids;              }

public LinkedList<String> getVideoIDs(){                  LinkedList<String> ids = new LinkedList<String>();for(int i = 0; i < users.size(); i ++){if(!ids.contains(users.get(i).videoID))                          ids.add(users.get(i).videoID);                  }return ids;              }    }