Nimbuzz Android MUC Bot Coded in Java using PURE JAVA SMACK 4.1.4 API

All Available Features in MUC Bot:

- mem user
- kick user
- ban user (ipban user)
- grant mod., admin, owner
- add bot commander
- remove bot commander
- users greeting., etc

Requirements:

- Android 4.0.4 (Ice Cream Sandwich) or Above

Download

Download Full Source Code Available on my Github

STEP 1 : Add following dependencies in app-level build.gradle

dependencies {
compile fileTree(include: ['*.jar'], dir: 'libs')
compile 'org.igniterealtime.smack:smack-android:4.1.4'
compile 'org.igniterealtime.smack:smack-tcp:4.1.4'
compile 'org.igniterealtime.smack:smack-extensions:4.1.4'
compile 'de.greenrobot:eventbus:2.4.0'
compile 'com.android.support:recyclerview-v7:23.1.1'
}

STEP 2 : Create a singleton class for making AbstractXMPPConnection universal throughout app

	package example.com.db.nimbuzz_banbot_android_by_db;
	import org.jivesoftware.smack.AbstractXMPPConnection;
	/**
	* Created by DB on 04-02-2016.
	*/
	public class XMPPLogic {
	public static AbstractXMPPConnection connection = null;
	private static XMPPLogic ourInstance = null;
	public synchronized static XMPPLogic getInstance() {
	if(ourInstance == null){
	ourInstance = new XMPPLogic();
	}
	return ourInstance;
	}
	public AbstractXMPPConnection getConnection()
	{
	return this.connection;
	}
	public XMPPLogic() {
	}
	public void setConnection(AbstractXMPPConnection connection) {
	this.connection = connection;
	}
	}

view raw XMPPLogic.java hosted with ❤ by GitHub

STEP 3 : Create a New Service class for creating xmpp connection to the server and connection Listener to handle connection state & other xmpp basic capabilities on Service Create and run this service in Foregroung as well:

	package example.com.db.nimbuzz_banbot_android_by_db;
	import android.app.Service;
	import android.content.Intent;
	import android.os.AsyncTask;
	import android.os.Handler;
	import android.os.IBinder;
	import android.os.Looper;
	import android.util.Log;
	import android.widget.Toast;
	import org.jivesoftware.smack.ConnectionConfiguration;
	import org.jivesoftware.smack.ConnectionListener;
	import org.jivesoftware.smack.SmackException;
	import org.jivesoftware.smack.XMPPConnection;
	import org.jivesoftware.smack.XMPPException;
	import org.jivesoftware.smack.packet.Presence;
	import org.jivesoftware.smack.tcp.XMPPTCPConnection;
	import org.jivesoftware.smack.tcp.XMPPTCPConnectionConfiguration;
	import org.jivesoftware.smackx.ping.PingFailedListener;
	import org.jivesoftware.smackx.ping.PingManager;
	import java.io.IOException;
	public class dbXMPPConn extends Service {
	private PingManager pingManager;
	private static final String TAG = "ConnectXmpp";
	private static final String DOMAIN = "nimbuzz.com";
	private static final String HOST = "o.nimbuzz.com";
	private static final int PORT = 5222;
	private String userName ="";
	private String passWord = "";
	XMPPConnectionListener connectionListener = new XMPPConnectionListener();
	public static boolean connected = false;
	public static boolean isToasted = true;
	public static boolean chat_created = true;
	public dbXMPPConn() {
	}
	@Override
	public int onStartCommand(Intent intent, int flags, int startId)
	{
	if(intent != null){
	userName = intent.getStringExtra("user");
	passWord = intent.getStringExtra("pwd");
	dbcon.init(userName, passWord);
	dbcon.connectConnection();
	}
	return 0;
	}
	@Override
	public void onCreate() {
	super.onCreate();
	}
	@Override
	public void onDestroy() {
	dbcon.disconnectConnection();
	super.onDestroy();
	}
	@Override
	public IBinder onBind(Intent intent) {
	// TODO: Return the communication channel to the service.
	throw new UnsupportedOperationException("Not yet implemented");
	}
	private dbXMPP dbcon = new dbXMPP();
	public class dbXMPP{
	public void init(final String userName, final String passWord) {
	Log.i("dbXMPP", "Initializing!");
	XMPPTCPConnectionConfiguration.Builder configBuilder = XMPPTCPConnectionConfiguration.builder();
	configBuilder.setUsernameAndPassword(userName, passWord);
	configBuilder.setSecurityMode(ConnectionConfiguration.SecurityMode.disabled);
	configBuilder.setResource("dbanbot-4droid-coded-by-db~");
	configBuilder.setServiceName(DOMAIN);
	configBuilder.setHost(HOST);
	configBuilder.setPort(PORT);
	XMPPLogic.connection = new XMPPTCPConnection(configBuilder.build());
	XMPPLogic.connection.addConnectionListener(connectionListener);
	}
	public void connectConnection() {
	AsyncTask<Void, Void, Boolean> connectionThread = new AsyncTask<Void, Void, Boolean>() {
	@Override
	protected Boolean doInBackground(Void... arg0) {
	// Create a connection
	try {
	XMPPLogic.connection.connect();
	login();
	connected = true;
	} catch (IOException e) {
	} catch (SmackException e) {
	} catch (XMPPException e) {
	}
	return null;
	}
	};
	connectionThread.execute();
	}
	public void disconnectConnection() {
	new Thread(new Runnable() {
	@Override
	public void run() {
	XMPPLogic.connection.disconnect();
	}
	}).start();
	}
	}
	private void sendping() throws InterruptedException {
	pingManager = PingManager.getInstanceFor(XMPPLogic.connection);
	pingManager.setPingInterval(10);
	pingManager.registerPingFailedListener(new PingFailedListener() {
	@Override
	public void pingFailed() {
	pingManager.setPingInterval(10);
	}
	});
	}
	private boolean loggedin = true;
	public void login() {
	try {
	XMPPLogic.connection.login(userName, passWord);
	//connection.login(userName, passWord);
	} catch (XMPPException | SmackException | IOException e) {
	e.printStackTrace();
	} catch (Exception e) {
	loggedin = false;
	chat_created = false;
	}
	if (!loggedin)
	{
	Log.e(TAG, "Unable to login");
	disconnect();
	loggedin = true;
	}
	else {
	Log.e(TAG, "Logged in");
	}
	}
	private void disconnect() {
	if(XMPPLogic.connection != null && XMPPLogic.connection.isConnected()) {
	new AsyncTask<Void, Void, Void>() {
	@Override
	protected Void doInBackground(Void... params) {
	XMPPLogic.connection.disconnect();
	Log.e(TAG, "Connection disconnected");
	return null;
	}
	}.execute();
	}
	}
	public void setPresence() throws SmackException.NotConnectedException {
	Presence dbpres = new Presence(Presence.Type.available);
	dbpres.setMode(Presence.Mode.dnd);
	dbpres.setStatus("Nimbuzz Login SMACK XMPP Android Coded By DB~@NC");
	XMPPLogic.connection.sendStanza(dbpres);
	}
	// Connection Listener to check connection state
	public class XMPPConnectionListener implements ConnectionListener {
	@Override
	public void connected(final XMPPConnection connection) {
	Log.d("dbXMPP", "Connected!");
	connected = true;
	if (!connection.isAuthenticated()) {
	login();
	}
	}
	@Override
	public void connectionClosed() {
	if (isToasted)
	new Handler(Looper.getMainLooper()).post(new Runnable() {
	@Override
	public void run() {
	// TODO Auto-generated method stub
	Toast.makeText(getApplicationContext(), "Connection Closed!" , Toast.LENGTH_SHORT).show();
	}
	});
	Log.d("dbXMPP", "Connection Closed!");
	connected = false;
	chat_created = false;
	loggedin = false;
	}
	@Override
	public void connectionClosedOnError(Exception arg0) {
	if (isToasted)
	new Handler(Looper.getMainLooper()).post(new Runnable() {
	@Override
	public void run() {
	Toast.makeText(getApplicationContext(), "Connection Closed On Error", Toast.LENGTH_SHORT).show();
	}
	});
	Log.d("dbXMPP", "ConnectionClosedOn Error!");
	connected = false;
	chat_created = false;
	loggedin = false;
	}
	@Override
	public void reconnectingIn(int arg0) {
	Log.d("dbXMPP", "Reconnecting " + arg0);
	loggedin = false;
	}
	@Override
	public void reconnectionFailed(Exception arg0) {
	if (isToasted)
	new Handler(Looper.getMainLooper()).post(new Runnable() {
	@Override
	public void run() {
	Toast.makeText(getApplicationContext(), "Re-Connection Failed", Toast.LENGTH_SHORT).show();
	}
	});
	Log.d("dbXMPP", "ReconnectionFailed!");
	connected = false;
	chat_created = false;
	loggedin = false;
	}
	@Override
	public void reconnectionSuccessful() {
	if (isToasted)
	new Handler(Looper.getMainLooper()).post(new Runnable() {
	@Override
	public void run() {
	// TODO Auto-generated method stub
	Toast.makeText(getApplicationContext(), "Re-Connected!", Toast.LENGTH_SHORT).show();
	}
	});
	Log.d("dbXMPP", "ReconnectionSuccessful");
	connected = true;
	chat_created = false;
	loggedin = false;
	}
	@Override
	public void authenticated(XMPPConnection arg0, boolean arg1) {
	Log.d("dbXMPP", "Authenticated!");
	loggedin = true;
	//xmppClient.dbhere();
	chat_created = true;
	if (isToasted)
	new Handler(Looper.getMainLooper()).post(new Runnable() {
	@Override
	public void run() {
	// TODO Auto-generated method stub
	Toast.makeText(getApplicationContext(), "Logged In Successfully", Toast.LENGTH_SHORT).show();
	try {
	setPresence();
	} catch (SmackException.NotConnectedException e) {
	e.printStackTrace();
	}
	// conference();
	Intent dbint = new Intent(dbXMPPConn.this, BotMainTabActivity.class);
	dbint.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
	startActivity(dbint);
	try {
	sendping();
	} catch (InterruptedException e) {
	e.printStackTrace();
	}
	}
	});
	}
	}
	}

view raw dbXMPPConn.java hosted with ❤ by GitHub