public class AllListnerEvents {

    String userID,senderID,fromID,room_name;
    UIHandler uiHandler;
    Context con1;
    //boolean flag_state;

    public AllListnerEvents(Context con){
        //flag_state = flag;
        this.con1 = con;

        Main.connection.addPacketListener(new myRequestListener(), new PacketTypeFilter(Presence.class));

        MultiUserChat.addInvitationListener(Main.connection, new InvitationListener() {

            @Override
            public void invitationReceived(Connection arg0, String arg1,
                    String arg2, String arg3, String arg4, Message arg5) {

                try{
                    Log.d("Details", ""+"arg1 = "+arg1+" arg2 = "+arg2+" arg3 = "+arg3+" arg4 = "+arg4);
                    userID = arg2;
                    senderID = arg1;
                    HandlerThread uiThread = new HandlerThread("UIHandler");
                    uiThread.start();
                    uiHandler  = new UIHandler( uiThread.getLooper());

                    handleUIRequest1(""+arg1);

                }catch (Exception e) {
                    Log.d("Listner", ""+e.toString());
                }
            }
        });
    }

    public class UIHandler extends Handler{

        public static final int DISPLAY_UI_TOAST = 0;
        public static final int DISPLAY_UI_DIALOG = 1;
        public static final int DISPLAY_UI_DIALOG1 = 2;

        public UIHandler(Looper looper){
            super(looper);
        }

        @Override
        public void handleMessage(final android.os.Message msg)
        {
            switch(msg.what)
            {
            case UIHandler.DISPLAY_UI_TOAST:
            {
                Context context = con1;
                Toast t = Toast.makeText(context, (String)msg.obj, Toast.LENGTH_LONG);
                t.show();
                break;
            }
            case UIHandler.DISPLAY_UI_DIALOG:
            {
                 final AlertDialog alertDialog = new AlertDialog.Builder(con1).create();
                 fromID = (String)msg.obj;
                 alertDialog.setTitle("Friend invitaion received from "+fromID);
                 alertDialog.setMessage("Do you want to Add it?");

                 alertDialog.setButton("YES", new DialogInterface.OnClickListener() {
                        public void onClick(DialogInterface dialog, int which) {
                            try{
                                String[] grp = {"Default"};
                                Roster roster = Main.connection.getRoster();
                                roster.createEntry(fromID,fromID.substring(0, fromID.indexOf("@")),grp);
                                Presence subscribed = new Presence(Presence.Type.subscribed);
                                subscribed.setTo(fromID);
                                Main.connection.sendPacket(subscribed);
                                //getListofUsers();
                            }catch (Exception e) {
                                Log.e("LogC",""+e.getMessage());
                            }
                            alertDialog.dismiss();
                           // if(flag_state){
                                con1.startActivity(new Intent(con1,ChatBox.class).setFlags(Intent.FLAG_ACTIVITY_NEW_TASK).
                                        putExtra("id", fromID).putExtra("chat", true));

                            //}
                        }
                    });

                 alertDialog.setButton2("Cancel", new DialogInterface.OnClickListener() {
                        public void onClick(DialogInterface dialog, int which) {
                            alertDialog.dismiss();
                        }
                    });

                 alertDialog.show();
                 break;
            }
            case UIHandler.DISPLAY_UI_DIALOG1:
            {
                 final AlertDialog alertDialog = new AlertDialog.Builder(con1).create();
                 alertDialog.setTitle("Room invitaion received from "+msg.obj);
                 alertDialog.setMessage("Do you wanna join it?");

                 alertDialog.setButton("YES", new DialogInterface.OnClickListener() {
                        public void onClick(DialogInterface dialog, int which) {
                            try{

                                Log.d("User12", ""+userID+" "+senderID);

                                MultiUserChat muc1 = new MultiUserChat(Main.connection, senderID) ;
                                Log.d("User", "afetr muc");

                                muc1.join(Main.connection.getUser());
                                room_name = muc1.getRoom();
                                Log.d("Room name", ""+muc1.getRoom());

                            }catch (Exception e) {
                                Log.d("MUC EX", ""+e.getMessage());
                            }
                            alertDialog.dismiss();
                            //if(flag_state){
                                con1.startActivity(new Intent(con1,ChatBox.class).setFlags(Intent.FLAG_ACTIVITY_NEW_TASK).
                                        putExtra("Rname",room_name).putExtra("chat",false));
                            //}
                        }
                    });

                 alertDialog.setButton2("Cancel", new DialogInterface.OnClickListener() {
                        public void onClick(DialogInterface dialog, int which) {
                            alertDialog.dismiss();
                        }
                    });

                 alertDialog.show();

                 break;
            }
            default:
                break;
            }
        }
    }

    protected void handleUIRequest(String message){
        android.os.Message msg = uiHandler.obtainMessage(UIHandler.DISPLAY_UI_DIALOG);
        msg.obj = message;
        uiHandler.sendMessage(msg);
    }

    protected void handleUIRequest1(String message){
        message = message.substring(0, message.indexOf("@"));
        android.os.Message msg = uiHandler.obtainMessage(UIHandler.DISPLAY_UI_DIALOG1);
        msg.obj = message;
        uiHandler.sendMessage(msg);
    }

    public class myRequestListener implements PacketListener{

    @Override
    public void processPacket(Packet arg0) {

        Presence pres = (Presence) arg0;
        if(pres.getType().equals(Presence.Type.subscribe)){

            Log.d("Packet", "m in packet listner");
            try{
                HandlerThread uiThread = new HandlerThread("UIHandler");
                uiThread.start();
                uiHandler  = new UIHandler( uiThread.getLooper());

                handleUIRequest(""+pres.getFrom());

            }catch (Exception e) {
                Log.d("Listner1", ""+e.toString());
            }
        }
    }
}