order);
+}
diff --git a/app/src/main/java/com/fazemeright/chatbotmetcs622/intentservice/FireBaseIntentService.java b/app/src/main/java/com/fazemeright/chatbotmetcs622/intentservice/FireBaseIntentService.java
new file mode 100644
index 0000000..269e23d
--- /dev/null
+++ b/app/src/main/java/com/fazemeright/chatbotmetcs622/intentservice/FireBaseIntentService.java
@@ -0,0 +1,144 @@
+package com.fazemeright.chatbotmetcs622.intentservice;
+
+import android.app.IntentService;
+import android.app.Notification;
+import android.app.NotificationManager;
+import android.content.Intent;
+import android.os.Build;
+import android.os.PowerManager;
+
+import androidx.annotation.Nullable;
+import androidx.core.app.NotificationCompat;
+
+import com.fazemeright.chatbotmetcs622.ChatBotApp;
+import com.fazemeright.chatbotmetcs622.R;
+import com.fazemeright.chatbotmetcs622.database.ChatBotDatabase;
+import com.fazemeright.chatbotmetcs622.database.messages.Message;
+import com.fazemeright.chatbotmetcs622.repositories.MessageRepository;
+import com.fazemeright.firebase_api_library.api.FireBaseApiManager;
+import com.fazemeright.firebase_api_library.listeners.DBValueListener;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import timber.log.Timber;
+
+public class FireBaseIntentService extends IntentService {
+
+ public static final String ACTION_ADD_MESSAGE = "AddMessage";
+ public static final String ACTION_SYNC_MESSAGES = "SyncMessages";
+ /**
+ * TAG for logs
+ */
+ private static final String TAG = "FireBaseIntentService";
+ /**
+ * Use to send data with intent
+ */
+ public static final String ACTION = "IntentAction";
+ public static final String MESSAGE = "Message";
+ public static final String RESULT_RECEIVER = "ResultReceiver";
+
+ protected ChatBotDatabase database;
+ private PowerManager.WakeLock wakeLock;
+ private FireBaseApiManager fireBaseApiManager;
+ private MessageRepository messageRepository;
+
+ /**
+ * Creates an IntentService. Invoked by your subclass's constructor.
+ *
+ * TAG Used to name the worker thread, important only for debugging.
+ */
+ public FireBaseIntentService() {
+ super(TAG);
+ }
+
+ @Override
+ public void onCreate() {
+ super.onCreate();
+ Timber.i("onCreate");
+ database = ChatBotDatabase.getInstance(getApplicationContext());
+ PowerManager powerManager = (PowerManager) getSystemService(POWER_SERVICE);
+ if (powerManager != null) {
+ wakeLock = powerManager.newWakeLock(PowerManager.PARTIAL_WAKE_LOCK, "ChatBot:WakeLockTag");
+ wakeLock.acquire(60 * 1000); // acquire CPU
+ Timber.i("onCreate: Wake Lock acquired");
+ }
+ showForegroundServiceNotification("Chat Bot", "Syncing Messages...");
+ }
+
+ @Override
+ public void onDestroy() {
+ super.onDestroy();
+ Timber.i("onDestroy");
+ wakeLock.release();
+ Timber.i("onDestroy: Wake Lock released");
+
+ }
+
+ @Override
+ protected void onHandleIntent(@Nullable Intent intent) {
+ Timber.d("onHandleIntent");
+ if (intent != null) {
+ switch (intent.getStringExtra(ACTION)) {
+ case ACTION_ADD_MESSAGE:
+ addMessageToFireStore((Message) intent.getSerializableExtra(MESSAGE));
+ break;
+ case ACTION_SYNC_MESSAGES:
+ syncMessages();
+ break;
+ }
+ }
+
+ }
+
+ /**
+ * Call to sync messages from FireStore to Room for the logged in user
+ */
+ private void syncMessages() {
+ /*try {
+ Thread.sleep(5000); // intentionally kept delay to show in presentation TODO: Remove afterwards
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }*/
+ messageRepository.syncMessagesFromFireStoreToRoom();
+ }
+
+ /**
+ * Call to add given message to FireStore
+ *
+ * @param message given message
+ */
+ private void addMessageToFireStore(Message message) {
+ messageRepository.addMessageToFireBase(Message.getHashMap(message));
+ }
+
+ /**
+ * Call to display foreground running notification to notify user of a background operation running
+ *
+ * @param title title to display in notification
+ * @param text text to display in notification
+ */
+ private void showForegroundServiceNotification(String title, String text) {
+ Timber.i("Show notification called");
+ if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
+
+ Notification notification = new NotificationCompat.Builder(this, ChatBotApp.CHANNEL_ID)
+ .setContentTitle(title)
+ .setContentText(text)
+ .setSmallIcon(R.drawable.ic_launcher_foreground)
+ .setPriority(NotificationManager.IMPORTANCE_DEFAULT)
+ .build();
+
+ startForeground(1, notification);
+ }
+ }
+
+ @Override
+ public void onStart(@Nullable Intent intent, int startId) {
+ super.onStart(intent, startId);
+ fireBaseApiManager = FireBaseApiManager.getInstance();
+ messageRepository = MessageRepository.getInstance(getApplicationContext());
+ }
+}
diff --git a/app/src/main/java/com/fazemeright/chatbotmetcs622/models/ChatRoom.java b/app/src/main/java/com/fazemeright/chatbotmetcs622/models/ChatRoom.java
new file mode 100644
index 0000000..45e002d
--- /dev/null
+++ b/app/src/main/java/com/fazemeright/chatbotmetcs622/models/ChatRoom.java
@@ -0,0 +1,48 @@
+package com.fazemeright.chatbotmetcs622.models;
+
+import java.io.Serializable;
+
+/**
+ * POJO to hold Chat room
+ */
+public class ChatRoom implements Serializable {
+ public static final int BRUTE_FORCE_ID = 0;
+ public static final int LUCENE_ID = 1;
+ public static final int MONGO_DB_ID = 2;
+ public static final int MY_SQL_ID = 3;
+
+ public static final String MONGO_DB = "MongoDB";
+ public static final String MY_SQL = "MySQL";
+ public static final String LUCENE = "Lucene";
+ public static final String BRUTE_FORCE = "Brute Force";
+ /**
+ * is of the chat room
+ */
+ private long id;
+ /**
+ * Name of the chat room
+ */
+ private String name;
+ /**
+ * Id of resource file associated with the ChatRoom
+ */
+ private int logoId;
+
+ public ChatRoom(int id, String name, int logoId) {
+ this.id = id;
+ this.name = name;
+ this.logoId = logoId;
+ }
+
+ public long getId() {
+ return id;
+ }
+
+ public String getName() {
+ return name;
+ }
+
+ public int getLogoId() {
+ return logoId;
+ }
+}
diff --git a/app/src/main/java/com/fazemeright/chatbotmetcs622/network/ApiManager.java b/app/src/main/java/com/fazemeright/chatbotmetcs622/network/ApiManager.java
new file mode 100644
index 0000000..e18117e
--- /dev/null
+++ b/app/src/main/java/com/fazemeright/chatbotmetcs622/network/ApiManager.java
@@ -0,0 +1,112 @@
+package com.fazemeright.chatbotmetcs622.network;
+
+import android.content.Context;
+
+import com.fazemeright.chatbotmetcs622.database.messages.Message;
+import com.fazemeright.chatbotmetcs622.models.ChatRoom;
+import com.fazemeright.chatbotmetcs622.network.handlers.NetworkCallback;
+import com.fazemeright.chatbotmetcs622.network.handlers.NetworkWrapper;
+import com.fazemeright.chatbotmetcs622.network.models.NetError;
+import com.fazemeright.chatbotmetcs622.network.models.NetResponse;
+import com.fazemeright.chatbotmetcs622.network.models.request.MessageQueryRequestModel;
+import com.fazemeright.chatbotmetcs622.network.models.response.QueryResponseMessage;
+import com.google.gson.reflect.TypeToken;
+
+public class ApiManager {
+
+ private static ApiManager apiManager = null;
+ private NetworkManager networkManager;
+
+ public static ApiManager getInstance() {
+ if (apiManager == null) {
+ apiManager = new ApiManager();
+ }
+ return apiManager;
+ }
+
+ /**
+ * Initialize base url,alias key and {@link NetworkWrapper} from application side,
+ * so that no need to pass base url in every user related network call.
+ *
+ * @param networkManager
+ */
+ public void init(NetworkManager networkManager) {
+ this.networkManager = networkManager;
+
+ }
+
+
+ /**
+ * Call Query API to backend to fetch results for the given Message query
+ *
+ * @param context context
+ * @param newMessage given message query
+ * @param networkCallback callback to listen to response
+ */
+ public void queryDatabase(Context context, Message newMessage,
+ final NetworkCallback networkCallback) {
+ String serverEndPoint;
+ switch ((int) newMessage.getChatRoomId()) {
+ case ChatRoom.BRUTE_FORCE_ID:
+ serverEndPoint = DatabaseUrl.BRUTE_FORCE;
+ break;
+ case ChatRoom.LUCENE_ID:
+ serverEndPoint = DatabaseUrl.LUCENE;
+ break;
+ case ChatRoom.MONGO_DB_ID:
+ serverEndPoint = DatabaseUrl.MONGO_DB;
+ break;
+ default:
+ serverEndPoint = DatabaseUrl.MY_SQL;
+ break;
+ }
+ String url = BaseUrl.BASE_URL.concat(BaseUrl.BASE_APP_NAME).concat(serverEndPoint);
+
+ MessageQueryRequestModel messageQuery = new MessageQueryRequestModel(newMessage.getMsg());
+
+ TypeToken typeToken = new TypeToken() {
+ };
+ networkManager.makePostRequest(context, url, messageQuery, typeToken, "", new NetworkCallback() {
+ @Override
+ public void onSuccess(NetResponse response) {
+ networkCallback.onSuccess(response);
+ }
+
+ @Override
+ public void onError(NetError error) {
+ networkCallback.onError(error);
+ }
+ });
+
+ }
+
+ /**
+ * DatabaseUrl module Api sub url
+ */
+ static class DatabaseUrl {
+ final static String MONGO_DB = "/mongodb";
+ final static String LUCENE = "/lucene";
+ final static String MY_SQL = "/mysql";
+ final static String BRUTE_FORCE = "/bruteforce";
+
+ }
+
+ /**
+ * baseURL model for all the BASE URL addresses
+ */
+ public static class BaseUrl {
+ static String BASE_URL = "http://192.168.43.28:8080"; // Update the url as per your local ip address
+ final static String BASE_APP_NAME = "/MET_CS622_ChatBot_Backend_war_exploded";
+
+ /**
+ * Set the local IP address or the base url address for the server where the database back end is hosted.
+ * Also include the port.
+ *
+ * @param hostAddress ip address
+ */
+ public static void setLocalIP(String hostAddress) {
+ BASE_URL = hostAddress;
+ }
+
+ }
+}
diff --git a/app/src/main/java/com/fazemeright/chatbotmetcs622/network/NetworkManager.java b/app/src/main/java/com/fazemeright/chatbotmetcs622/network/NetworkManager.java
new file mode 100644
index 0000000..6921e00
--- /dev/null
+++ b/app/src/main/java/com/fazemeright/chatbotmetcs622/network/NetworkManager.java
@@ -0,0 +1,498 @@
+package com.fazemeright.chatbotmetcs622.network;
+
+
+import android.content.Context;
+
+import androidx.annotation.Nullable;
+
+import com.androidnetworking.AndroidNetworking;
+import com.androidnetworking.common.Priority;
+import com.androidnetworking.error.ANError;
+import com.androidnetworking.interceptors.HttpLoggingInterceptor;
+import com.androidnetworking.interfaces.ParsedRequestListener;
+import com.fazemeright.chatbotmetcs622.R;
+import com.fazemeright.chatbotmetcs622.network.handlers.NetworkCallback;
+import com.fazemeright.chatbotmetcs622.network.handlers.NetworkWrapper;
+import com.fazemeright.chatbotmetcs622.network.models.ChatBotError;
+import com.fazemeright.chatbotmetcs622.network.models.NetCompoundRes;
+import com.fazemeright.chatbotmetcs622.network.models.NetError;
+import com.fazemeright.chatbotmetcs622.network.models.NetResponse;
+import com.fazemeright.chatbotmetcs622.network.utils.CoreUtils;
+import com.google.gson.reflect.TypeToken;
+
+import java.util.HashMap;
+import java.util.concurrent.TimeUnit;
+
+import okhttp3.OkHttpClient;
+import timber.log.Timber;
+
+public class NetworkManager implements NetworkWrapper {
+
+ private final static String TAG = NetworkManager.class.getSimpleName();
+ private static final String CONTENT_TYPE = "application/json; charset=utf-8";
+ private static NetworkManager networkManager = null;
+
+ public static NetworkManager getInstance() {
+ if (networkManager == null) {
+ networkManager = new NetworkManager();
+ }
+ return networkManager;
+ }
+
+ /**
+ * To get Http client
+ *
+ * @param requestTimeOut Network Request timeout in millisecond it's configurable from backend
+ * @return OkHttpClient
+ */
+ public static OkHttpClient getHttpClient(int requestTimeOut) {
+ //if set < 2 second then we put our default timeout
+
+ OkHttpClient.Builder builder = new OkHttpClient.Builder();
+ builder.connectTimeout(requestTimeOut, TimeUnit.SECONDS);
+ builder.readTimeout(requestTimeOut, TimeUnit.SECONDS);
+ builder.writeTimeout(requestTimeOut, TimeUnit.SECONDS);
+
+ return builder.build();
+ }
+
+ /**
+ * Initializing at the very first time
+ * Set Request Timeout
+ * Enabling network logging
+ *
+ * @param requestTimeOut Network Request timeout in millisecond it's configurable from backend
+ * @param context
+ */
+ public void init(Context context, int requestTimeOut) {
+ initSecureClient(context, requestTimeOut);
+ }
+
+ /**
+ * To initialize network manager
+ *
+ * @param context App context
+ * @param requestTimeOut Network Request timeout in millisecond it's configurable from backend
+ */
+ private void initSecureClient(Context context, int requestTimeOut) {
+ AndroidNetworking.initialize(context, getHttpClient(requestTimeOut));
+ }
+
+ @Override
+ public void makeGetRequest(Context context, String url, TypeToken typeToken, String tag,
+ final NetworkCallback networkCallback) {
+ if (CoreUtils.isValidUrl(url)) {
+ if (CoreUtils.isNetworkAvailable(context)) {
+ printURLAndRequestParameters(url, null);
+ AndroidNetworking.get(url)
+ .setTag(tag)
+ .setPriority(Priority.MEDIUM)
+ .build()
+ .getAsParsed(typeToken, new ParsedRequestListener() {
+ @Override
+ public void onResponse(T response) {
+ Timber.i("onResponse :: %s", CoreUtils.getStringFromObject(response));
+ NetResponse netResponse = new NetResponse();
+ netResponse.setResponse(response);
+ networkCallback.onSuccess(netResponse);
+ }
+
+ @Override
+ public void onError(ANError anError) {
+ Timber.e("onError :: %s", CoreUtils.getStringFromObject(anError));
+ networkCallback.onError(getNetError(anError, null));
+ }
+ });
+ } else {
+ networkCallback.onError(getNetErrorConnectivityError(getConnectivityError(context), null));
+ }
+ } else {
+ networkCallback.onError(getInvalidUrlError(url));
+ }
+ }
+
+ @Override
+ public void makePostRequest(Context context, String url, TypeToken typeToken,
+ HashMap hashMapHeader, String tag,
+ final NetworkCallback networkCallback) {
+ if (CoreUtils.isValidUrl(url)) {
+ if (CoreUtils.isNetworkAvailable(context)) {
+ AndroidNetworking.post(url)
+ .setContentType("application/x-www-form-urlencoded") // custom ContentType
+ .setTag(tag)
+ .addHeaders(hashMapHeader)
+ .setPriority(Priority.MEDIUM)
+ .build()
+ .getAsParsed(typeToken, new ParsedRequestListener() {
+ @Override
+ public void onResponse(T response) {
+ NetResponse netResponse = new NetResponse();
+ netResponse.setResponse(response);
+ networkCallback.onSuccess(netResponse);
+ }
+
+ @Override
+ public void onError(ANError anError) {
+ networkCallback.onError(getNetError(anError, null));
+ }
+ });
+ } else {
+ networkCallback.onError(getNetErrorConnectivityError(getConnectivityError(context),
+ null));
+ }
+ } else {
+ networkCallback.onError(getInvalidUrlError(url));
+ }
+ }
+
+
+ @Override
+ public void makeGetRequestHeader(Context context, String url, TypeToken typeToken,
+ HashMap hashMapHeader, String tag,
+ final NetworkCallback networkCallback) {
+ if (CoreUtils.isValidUrl(url)) {
+ if (CoreUtils.isNetworkAvailable(context)) {
+ printURLAndRequestParameters(url, null);
+ AndroidNetworking.get(url)
+ .setTag(tag)
+ .addHeaders(hashMapHeader)
+ .setPriority(Priority.MEDIUM)
+ .build()
+ .getAsParsed(typeToken, new ParsedRequestListener() {
+ @Override
+ public void onResponse(T response) {
+ Timber.i("onResponse :: %s", CoreUtils.getStringFromObject(response));
+ NetResponse netResponse = new NetResponse();
+ netResponse.setResponse(response);
+ networkCallback.onSuccess(netResponse);
+ }
+
+ @Override
+ public void onError(ANError anError) {
+ Timber.e("onError :: %s", CoreUtils.getStringFromObject(anError));
+ networkCallback.onError(getNetError(anError, null));
+ }
+ });
+ } else {
+ networkCallback.onError(getNetErrorConnectivityError(getConnectivityError(context), null));
+ }
+ } else {
+ networkCallback.onError(getInvalidUrlError(url));
+ }
+ }
+
+ @Override
+ public void makePutRequestHeader(Context context, String url, final Object dataObject,
+ TypeToken typeToken, HashMap hashMapHeader,
+ String tag, final NetworkCallback networkCallback) {
+ if (CoreUtils.isValidUrl(url)) {
+ if (CoreUtils.isNetworkAvailable(context)) {
+ printURLAndRequestParameters(url, dataObject);
+ //.addBodyParameter(dataObject)
+ //.addStringBody(NetworkUtility.getStringFromObject(dataObject))
+ AndroidNetworking.put(url)
+ .addApplicationJsonBody(dataObject)
+ .addHeaders(hashMapHeader)
+ .setContentType(CONTENT_TYPE) // custom ContentType
+ .setTag(tag)
+ .setPriority(Priority.MEDIUM)
+ .build()
+ .getAsParsed(typeToken, new ParsedRequestListener() {
+ @Override
+ public void onResponse(T response) {
+ // LogUtils.getInstance().printLog(TAG, "onResponse :: "
+ // + CoreUtils.getStringFromObject(response));
+ NetResponse netResponse = new NetResponse();
+ netResponse.setResponse(response);
+ networkCallback.onSuccess(netResponse);
+ }
+
+ @Override
+ public void onError(ANError anError) {
+ // LogUtils.getInstance().printLog(TAG, "onError :: "
+ // + CoreUtils.getStringFromObject(anError));
+ networkCallback.onError(getNetError(anError, dataObject));
+ }
+ });
+ } else {
+ networkCallback.onError(getNetErrorConnectivityError(getConnectivityError(context), dataObject));
+ }
+ } else {
+ networkCallback.onError(getInvalidUrlError(url));
+ }
+ }
+
+
+ @Override
+ public void makePostRequest(Context context, String url, final Object dataObject, TypeToken typeToken,
+ String tag, final NetworkCallback networkCallback) {
+ if (CoreUtils.isValidUrl(url)) {
+ if (CoreUtils.isNetworkAvailable(context)) {
+ printURLAndRequestParameters(url, dataObject);
+//.addBodyParameter(dataObject)
+//.addStringBody(NetworkUtility.getStringFromObject(dataObject))
+ AndroidNetworking.post(url)
+ .addApplicationJsonBody(dataObject)
+// .addHeaders(hashMapHeader)
+ .setContentType(CONTENT_TYPE) // custom ContentType
+ .setTag(tag)
+ .setPriority(Priority.MEDIUM)
+ .build()
+ .getAsParsed(typeToken, new ParsedRequestListener() {
+ @Override
+ public void onResponse(T response) {
+ // LogUtils.getInstance().printLog(TAG, "onResponse :: "
+ // + CoreUtils.getStringFromObject(response));
+ NetResponse netResponse = new NetResponse();
+ netResponse.setResponse(response);
+ networkCallback.onSuccess(netResponse);
+ }
+
+ @Override
+ public void onError(ANError anError) {
+ // LogUtils.getInstance().printLog(TAG, "onError :: "
+ // + CoreUtils.getStringFromObject(anError));
+ networkCallback.onError(getNetError(anError, dataObject));
+ }
+ });
+ } else {
+ networkCallback.onError(getNetErrorConnectivityError(getConnectivityError(context), dataObject));
+ }
+ } else {
+ networkCallback.onError(getInvalidUrlError(url));
+ }
+ }
+
+ @Override
+ public void makePostStringRequest(Context context, String url, String data, TypeToken typeToken,
+ String tag, NetworkCallback networkCallback) {
+
+ }
+
+ @Override
+ public NetCompoundRes makePostRequestSync(Context context, String url, Object dataObject,
+ TypeToken typeToken, String tag) {
+ return null;
+ }
+
+ @Override
+ public void makePostRequestHeader(Context context, String url, final Object dataObject,
+ TypeToken typeToken, HashMap hashMapHeader,
+ String tag, final NetworkCallback networkCallback) {
+
+ if (CoreUtils.isValidUrl(url)) {
+ if (CoreUtils.isNetworkAvailable(context)) {
+ printURLAndRequestParameters(url, dataObject);
+//.addBodyParameter(dataObject)
+//.addStringBody(NetworkUtility.getStringFromObject(dataObject))
+ AndroidNetworking.post(url)
+ .addApplicationJsonBody(dataObject)
+ .addHeaders(hashMapHeader)
+ .setContentType(CONTENT_TYPE) // custom ContentType
+ .setTag(tag)
+ .setPriority(Priority.MEDIUM)
+ .build()
+ .getAsParsed(typeToken, new ParsedRequestListener() {
+ @Override
+ public void onResponse(T response) {
+ // LogUtils.getInstance().printLog(TAG, "onResponse :: "
+ // + CoreUtils.getStringFromObject(response));
+ NetResponse netResponse = new NetResponse();
+ netResponse.setResponse(response);
+ networkCallback.onSuccess(netResponse);
+ }
+
+ @Override
+ public void onError(ANError anError) {
+ // LogUtils.getInstance().printLog(TAG, "onError :: "
+ // + CoreUtils.getStringFromObject(anError));
+ networkCallback.onError(getNetError(anError, dataObject));
+ }
+ });
+ } else {
+ networkCallback.onError(getNetErrorConnectivityError(getConnectivityError(context), dataObject));
+ }
+ } else {
+ networkCallback.onError(getInvalidUrlError(url));
+ }
+ }
+
+ @Override
+ public void makeDeleteRequestHeader(Context context, String url, /*final Object dataObject,*/
+ TypeToken typeToken, HashMap hashMapHeader,
+ String tag, final NetworkCallback networkCallback) {
+
+ if (CoreUtils.isValidUrl(url)) {
+ if (CoreUtils.isNetworkAvailable(context)) {
+// printURLAndRequestParameters(url, dataObject);
+//.addBodyParameter(dataObject)
+//.addStringBody(NetworkUtility.getStringFromObject(dataObject))
+ AndroidNetworking.delete(url)
+// .addApplicationJsonBody(dataObject)
+ .addHeaders(hashMapHeader)
+ .setContentType(CONTENT_TYPE) // custom ContentType
+ .setTag(tag)
+ .setPriority(Priority.MEDIUM)
+ .build()
+ .getAsParsed(typeToken, new ParsedRequestListener() {
+ @Override
+ public void onResponse(T response) {
+ // LogUtils.getInstance().printLog(TAG, "onResponse :: "
+ // + CoreUtils.getStringFromObject(response));
+ NetResponse netResponse = new NetResponse();
+ netResponse.setResponse(response);
+ networkCallback.onSuccess(netResponse);
+ }
+
+ @Override
+ public void onError(ANError anError) {
+ // LogUtils.getInstance().printLog(TAG, "onError :: "
+ // + CoreUtils.getStringFromObject(anError));
+ networkCallback.onError(getNetError(anError, null));
+ }
+ });
+ } else {
+ networkCallback.onError(getNetErrorConnectivityError(getConnectivityError(context), null));
+ }
+ } else {
+ networkCallback.onError(getInvalidUrlError(url));
+ }
+ }
+
+ @Override
+ public void cancelRequest(String tag) {
+
+ }
+
+ /**
+ * To use only for get id_token,access_token and refresh_token when login with Social
+ *
+ * @param context
+ * @param url
+ * @param dataObject
+ * @param typeToken
+ * @param hashMapHeader
+ * @param tag
+ * @param networkCallback
+ * @param
+ */
+ @Override
+ public void makeCustomPostForSocialRequest(Context context, String url, final String dataObject,
+ TypeToken typeToken,
+ HashMap hashMapHeader, String tag,
+ final NetworkCallback networkCallback) {
+
+ String stringURL = url.concat("?grant_type=authorization_code&redirect_uri=rosedaleapp://login&client_id=2idjeho7u7717nur0uhb6kmuhj&")
+ .concat("code=").concat(dataObject).concat("&scope=email openid profile");
+
+ if (CoreUtils.isValidUrl(url)) {
+ if (CoreUtils.isNetworkAvailable(context)) {
+ printURLAndRequestParameters(stringURL, dataObject);
+ AndroidNetworking.post(stringURL)
+ .setContentType("application/x-www-form-urlencoded") // custom ContentType
+ .setTag(tag)
+ .setPriority(Priority.MEDIUM)
+ .build()
+ .getAsParsed(typeToken, new ParsedRequestListener() {
+ @Override
+ public void onResponse(T response) {
+ NetResponse netResponse = new NetResponse();
+ netResponse.setResponse(response);
+ networkCallback.onSuccess(netResponse);
+ }
+
+ @Override
+ public void onError(ANError anError) {
+ networkCallback.onError(getNetError(anError, dataObject));
+ }
+ });
+ } else {
+ networkCallback.onError(getNetErrorConnectivityError(getConnectivityError(context), dataObject));
+ }
+ } else {
+ networkCallback.onError(getInvalidUrlError(url));
+ }
+ }
+
+ /**
+ * To create class for error from network/api
+ *
+ * @param anError
+ * @param requestObject
+ */
+ private NetError getNetError(ANError anError, @Nullable Object requestObject) {
+ NetError netError = new NetError(anError.getMessage());
+ netError.setErrorBody(anError.getErrorBody());
+ netError.setErrorCode(anError.getErrorCode());
+ netError.setErrorDetail(anError.getErrorDetail());
+ netError.setErrorLocalizeMessage(anError.getLocalizedMessage());
+ netError.setApiRequest(requestObject);
+ netError.setResponseErrorMessage(anError.getErrorBody());
+ return netError;
+ }
+
+ /**
+ * To create class for error from network/api
+ *
+ * @param anError
+ * @param requestObject
+ */
+ private NetError getNetErrorConnectivityError(ANError anError, @Nullable Object requestObject) {
+ NetError netError = new NetError(anError.getMessage());
+ netError.setErrorBody(anError.getErrorBody());
+ netError.setErrorCode(anError.getErrorCode());
+ netError.setErrorDetail(anError.getErrorDetail());
+ netError.setErrorLocalizeMessage(anError.getLocalizedMessage());
+ netError.setApiRequest(requestObject);
+ netError.setResponseErrorMessage(anError.getErrorBody());
+ return netError;
+ }
+
+ /**
+ * To get Connectivity Error
+ *
+ * @param context
+ * @return
+ */
+ private ANError getConnectivityError(Context context) {
+ ANError anError = new ANError(context.getString(R.string.no_internet_connection_available));
+ anError.setErrorCode(ChatBotError.ChatBotErrorCodes.INTERNET_NOT_AVAILABLE);
+ anError.setErrorBody(context.getString(R.string.no_internet_connection_available));
+ return anError;
+ }
+
+ /**
+ * To Print Request
+ *
+ * @param url
+ * @param data
+ */
+ private void printURLAndRequestParameters(String url, Object data) {
+ Timber.i("url :: %s", url);
+ Timber.i("requestParameters :: %s",
+ CoreUtils.getStringFromObject(data));
+ }
+
+
+ /**
+ * To get Invalid Url Error
+ *
+ * @param url
+ * @return
+ */
+ private NetError getInvalidUrlError(String url) {
+ NetError anError = new NetError("Invalid url: " + url);
+ anError.setErrorCode(ChatBotError.ChatBotErrorCodes.INVALID_URL);
+ return anError;
+ }
+
+
+ private void enableAndroidNetworkingLogging(boolean enable) {
+ if (enable) {
+ AndroidNetworking.enableLogging(HttpLoggingInterceptor.Level.BODY);
+ } else {
+ AndroidNetworking.enableLogging(HttpLoggingInterceptor.Level.NONE);
+ }
+ }
+
+}
diff --git a/app/src/main/java/com/fazemeright/chatbotmetcs622/network/handlers/NetworkCallback.java b/app/src/main/java/com/fazemeright/chatbotmetcs622/network/handlers/NetworkCallback.java
new file mode 100644
index 0000000..dac9c4e
--- /dev/null
+++ b/app/src/main/java/com/fazemeright/chatbotmetcs622/network/handlers/NetworkCallback.java
@@ -0,0 +1,25 @@
+package com.fazemeright.chatbotmetcs622.network.handlers;
+
+
+import com.fazemeright.chatbotmetcs622.network.models.NetError;
+import com.fazemeright.chatbotmetcs622.network.models.NetResponse;
+
+/*
+ * Interface for handling API response
+ * */
+public interface NetworkCallback {
+
+ /**
+ * Interface method called on success of api call
+ *
+ * @param response {@link NetResponse}
+ */
+ void onSuccess(NetResponse response);
+
+ /**
+ * Interface method called on api/network failure
+ *
+ * @param error Error obj with error detail
+ */
+ void onError(NetError error);
+}
\ No newline at end of file
diff --git a/app/src/main/java/com/fazemeright/chatbotmetcs622/network/handlers/NetworkWrapper.java b/app/src/main/java/com/fazemeright/chatbotmetcs622/network/handlers/NetworkWrapper.java
new file mode 100644
index 0000000..bb2ea71
--- /dev/null
+++ b/app/src/main/java/com/fazemeright/chatbotmetcs622/network/handlers/NetworkWrapper.java
@@ -0,0 +1,152 @@
+package com.fazemeright.chatbotmetcs622.network.handlers;
+
+
+import android.content.Context;
+
+import com.fazemeright.chatbotmetcs622.network.models.NetCompoundRes;
+import com.google.gson.reflect.TypeToken;
+
+import java.util.HashMap;
+
+/*
+ * Interface for calling API
+ * */
+public interface NetworkWrapper {
+
+ /**
+ * API GET method Request
+ *
+ * @param context App context
+ * @param url Request URL
+ * @param typeToken {@link TypeToken} of the expected parsed object
+ * @param tag request tag
+ * @param networkCallback Network callback
+ */
+ void makeGetRequest(Context context, String url, TypeToken typeToken, String tag,
+ NetworkCallback networkCallback);
+
+ /**
+ * API POST method Request
+ *
+ * @param context App context
+ * @param url Request URL
+ * @param typeToken {@link TypeToken} of the expected parsed object
+ * @param tag request tag
+ * @param networkCallback Network callback
+ */
+ void makePostRequest(Context context, String url, TypeToken typeToken,
+ HashMap hashMapHeader, String tag,
+ NetworkCallback networkCallback);
+
+ /**
+ * API POST method Request
+ *
+ * @param context App context
+ * @param url Request URL
+ * @param dataObject Request body
+ * @param typeToken {@link TypeToken} of the expected parsed object
+ * @param tag request tag
+ * @param networkCallback Network callback
+ */
+ void makePostRequest(Context context, String url, Object dataObject, TypeToken typeToken,
+ String tag, NetworkCallback networkCallback);
+
+ /**
+ * API POST method Request
+ *
+ * @param context App context
+ * @param url Request URL
+ * @param data Request body
+ * @param typeToken {@link TypeToken} of the expected parsed object
+ * @param tag request tag
+ * @param networkCallback Network callback
+ */
+ void makePostStringRequest(Context context, String url, String data, TypeToken typeToken,
+ String tag, NetworkCallback networkCallback);
+
+ /**
+ * API sync POST method Request. Expect a response/error in {@link NetCompoundRes}
+ *
+ * @param context App context
+ * @param url Request URL
+ * @param dataObject Request body
+ * @param typeToken {@link TypeToken} of the expected parsed object
+ * @param tag request tag
+ * @return Compound response ( It contains success / error ). First check it using method
+ * isSuccess() to find whether response contains error or not
+ */
+ NetCompoundRes makePostRequestSync(Context context, String url, Object dataObject,
+ TypeToken typeToken, String tag);
+
+ /**
+ * API POST method Request with header
+ *
+ * @param context App context
+ * @param url Request URL
+ * @param dataObject Request body
+ * @param typeToken {@link TypeToken} of the expected parsed object
+ * @param hashMapHeader HashMap of request header
+ * @param tag request tag
+ * @param networkCallback Network callback
+ */
+ void makePostRequestHeader(Context context, String url, Object dataObject, TypeToken typeToken,
+ HashMap hashMapHeader, String tag,
+ NetworkCallback networkCallback);
+
+ /**
+ * API POST method Request with header
+ *
+ * @param context App context
+ * @param url Request URL
+ * @param typeToken {@link TypeToken} of the expected parsed object
+ * @param hashMapHeader HashMap of request header
+ * @param tag request tag
+ * @param networkCallback Network callback
+ */
+ void makeDeleteRequestHeader(Context context, String url/*, Object dataObject*/, TypeToken typeToken,
+ HashMap hashMapHeader, String tag,
+ NetworkCallback networkCallback);
+
+
+ /**
+ * API Get method Request with header
+ *
+ * @param context App context
+ * @param url Request URL
+ * @param typeToken {@link TypeToken} of the expected parsed object
+ * @param hashMapHeader HashMap of request header
+ * @param tag request tag
+ * @param networkCallback Network callback
+ */
+ void makeGetRequestHeader(Context context, String url, TypeToken typeToken,
+ HashMap hashMapHeader, String tag,
+ NetworkCallback networkCallback);
+
+ /**
+ * API PUT Method Request with header
+ *
+ * @param context
+ * @param url
+ * @param dataObject
+ * @param typeToken
+ * @param hashMapHeader
+ * @param tag
+ * @param networkCallback
+ * @param
+ */
+ void makePutRequestHeader(Context context, String url, Object dataObject, TypeToken typeToken,
+ HashMap hashMapHeader, String tag,
+ NetworkCallback networkCallback);
+
+ /**
+ * Cancel api request by tag
+ *
+ * @param tag request tag
+ */
+ void cancelRequest(String tag);
+
+ void makeCustomPostForSocialRequest(Context context, String url,
+ String dataObject, TypeToken typeToken,
+ HashMap hashMapAuthenticate, String s,
+ NetworkCallback networkCallback);
+}
diff --git a/app/src/main/java/com/fazemeright/chatbotmetcs622/network/models/ChatBotError.java b/app/src/main/java/com/fazemeright/chatbotmetcs622/network/models/ChatBotError.java
new file mode 100644
index 0000000..4e525c6
--- /dev/null
+++ b/app/src/main/java/com/fazemeright/chatbotmetcs622/network/models/ChatBotError.java
@@ -0,0 +1,60 @@
+package com.fazemeright.chatbotmetcs622.network.models;
+
+
+import androidx.annotation.IntDef;
+
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+
+
+
+public class ChatBotError {
+
+ @Retention(RetentionPolicy.SOURCE)
+ @IntDef({ChatBotErrorCodes.INTERNET_NOT_AVAILABLE, /*SOMETHING_WENT_WRONG,*/ ChatBotErrorCodes.INVALID_URL, ChatBotErrorCodes.DATA_NOT_FOUND, ChatBotErrorCodes.BAD_REQUEST, ChatBotErrorCodes.UN_AUTHORIZED, ChatBotErrorCodes.UN_EXPECTED_SERVER_ERROR})
+ public @interface ChatBotErrorCodes {
+
+ /**
+ * Internet is not available
+ */
+ public static final int INTERNET_NOT_AVAILABLE = 1001;
+
+
+ /**
+ * Invalid URL
+ */
+ public static final int INVALID_URL = 1002;
+
+
+ /**
+ * Used for unknown error
+ */
+
+ public static final int SOMETHING_WENT_WRONG = -123456;
+
+ /**
+ * Used for data not found error
+ */
+ public static final int DATA_NOT_FOUND = 204;
+
+
+ /**
+ * Used for Bad request (Malformed Parameters or parameters missing)
+ */
+ public static final int BAD_REQUEST = 400;
+
+
+ /**
+ * Used for Unauthorized (Authorization header is incorrec, log-in user again)
+ */
+ public static final int UN_AUTHORIZED = 401;
+
+
+ /**
+ * Used for Unexpected server error (Error)
+ */
+ public static final int UN_EXPECTED_SERVER_ERROR = 500;
+
+ }
+
+}
diff --git a/app/src/main/java/com/fazemeright/chatbotmetcs622/network/models/NetCompoundRes.java b/app/src/main/java/com/fazemeright/chatbotmetcs622/network/models/NetCompoundRes.java
new file mode 100644
index 0000000..33867a1
--- /dev/null
+++ b/app/src/main/java/com/fazemeright/chatbotmetcs622/network/models/NetCompoundRes.java
@@ -0,0 +1,37 @@
+package com.fazemeright.chatbotmetcs622.network.models;
+
+/**
+ * To use when we want to have sync response from network manager
+ *
+ * @param
+ */
+public class NetCompoundRes {
+
+ private boolean isSuccess;
+ private NetResponse netResponse;
+ private NetError netError;
+
+ public void setSuccess(boolean success) {
+ isSuccess = success;
+ }
+
+ public void setNetResponse(NetResponse netResponse) {
+ this.netResponse = netResponse;
+ }
+
+ public void setNetError(NetError netError) {
+ this.netError = netError;
+ }
+
+ public boolean isSuccess() {
+ return isSuccess;
+ }
+
+ public NetResponse getNetResponse() {
+ return netResponse;
+ }
+
+ public NetError getNetError() {
+ return netError;
+ }
+}
diff --git a/app/src/main/java/com/fazemeright/chatbotmetcs622/network/models/NetError.java b/app/src/main/java/com/fazemeright/chatbotmetcs622/network/models/NetError.java
new file mode 100644
index 0000000..7e00820
--- /dev/null
+++ b/app/src/main/java/com/fazemeright/chatbotmetcs622/network/models/NetError.java
@@ -0,0 +1,114 @@
+package com.fazemeright.chatbotmetcs622.network.models;
+
+
+import android.text.TextUtils;
+
+import org.json.JSONException;
+import org.json.JSONObject;
+
+/*
+ * Class for handling Network/API related errors
+ * */
+public class NetError extends Exception {
+
+ private String errorBody = "";
+ private int errorCode = ChatBotError.ChatBotErrorCodes.SOMETHING_WENT_WRONG;
+ private String errorDetail = "";
+ private String errorLocalizeMessage = "";
+ private Object apiRequest;
+ private String requestName = "";
+ private String responseErrorMessage;
+
+ public String getResponseErrorMessage() {
+ return responseErrorMessage;
+ }
+
+ public void setResponseErrorMessage(String responseErrorMessage) {
+ this.responseErrorMessage = parseJson(responseErrorMessage);
+ }
+
+ private String parseJson(String responseErrorMessage) {
+ String errorMessage = "Something went wrong!";
+ if (!TextUtils.isEmpty(responseErrorMessage)) {
+ try {
+ JSONObject jsonObject = new JSONObject(responseErrorMessage);
+ if (jsonObject.has("responseMessage")) {
+ errorMessage = jsonObject.getString("responseMessage");
+ } else {
+ return responseErrorMessage;
+ }
+ } catch (JSONException e) {
+ e.printStackTrace();
+ return responseErrorMessage;
+ }
+ }
+ return errorMessage;
+
+ }
+
+ public String getRequestName() {
+ return requestName;
+ }
+
+ public void setRequestName(String requestName) {
+ if (requestName != null) {
+ this.requestName = requestName;
+ }
+ }
+
+ public Object getApiRequest() {
+ return apiRequest;
+ }
+
+ public void setApiRequest(Object apiRequest) {
+ this.apiRequest = apiRequest;
+ }
+
+ public String getErrorLocalizeMessage() {
+ return errorLocalizeMessage;
+ }
+
+ public void setErrorLocalizeMessage(String errorLocalizeMessage) {
+ if (errorLocalizeMessage != null) {
+ this.errorLocalizeMessage = errorLocalizeMessage;
+ }
+ }
+
+ public NetError(String message) {
+ super(message);
+ if (message == null) {
+ message = "Getting null error message.";
+ }
+ setErrorLocalizeMessage(message);
+ setErrorBody(message);
+ setErrorDetail(message);
+ }
+
+ public void setErrorDetail(String errorDetail) {
+ if (errorDetail != null) {
+ this.errorDetail = errorDetail;
+ }
+ }
+
+ public String getErrorDetail() {
+ return this.errorDetail;
+ }
+
+ public void setErrorCode(int errorCode) {
+ this.errorCode = errorCode;
+ }
+
+ public int getErrorCode() {
+ return this.errorCode;
+ }
+
+ public String getErrorBody() {
+ return errorBody;
+ }
+
+ public void setErrorBody(String errorBody) {
+ if (errorBody != null) {
+ this.errorBody = errorBody;
+ }
+ }
+}
diff --git a/app/src/main/java/com/fazemeright/chatbotmetcs622/network/models/NetResponse.java b/app/src/main/java/com/fazemeright/chatbotmetcs622/network/models/NetResponse.java
new file mode 100644
index 0000000..3ad6b07
--- /dev/null
+++ b/app/src/main/java/com/fazemeright/chatbotmetcs622/network/models/NetResponse.java
@@ -0,0 +1,20 @@
+package com.fazemeright.chatbotmetcs622.network.models;
+
+import com.google.gson.annotations.SerializedName;
+
+/**
+ * Class for handling generic response
+ */
+public class NetResponse {
+
+ @SerializedName("response")
+ private T response;
+
+ public T getResponse() {
+ return response;
+ }
+
+ public void setResponse(T response) {
+ this.response = response;
+ }
+}
diff --git a/app/src/main/java/com/fazemeright/chatbotmetcs622/network/models/request/MessageQueryRequestModel.java b/app/src/main/java/com/fazemeright/chatbotmetcs622/network/models/request/MessageQueryRequestModel.java
new file mode 100644
index 0000000..85d8bb9
--- /dev/null
+++ b/app/src/main/java/com/fazemeright/chatbotmetcs622/network/models/request/MessageQueryRequestModel.java
@@ -0,0 +1,22 @@
+package com.fazemeright.chatbotmetcs622.network.models.request;
+
+import com.google.gson.annotations.Expose;
+import com.google.gson.annotations.SerializedName;
+
+public class MessageQueryRequestModel {
+ @SerializedName("query")
+ @Expose
+ private String query;
+
+ public MessageQueryRequestModel(String query) {
+ this.query = query;
+ }
+
+ public String getQuery() {
+ return query;
+ }
+
+ public void setQuery(String query) {
+ this.query = query;
+ }
+}
diff --git a/app/src/main/java/com/fazemeright/chatbotmetcs622/network/models/response/QueryResponseMessage.java b/app/src/main/java/com/fazemeright/chatbotmetcs622/network/models/response/QueryResponseMessage.java
new file mode 100644
index 0000000..93077ad
--- /dev/null
+++ b/app/src/main/java/com/fazemeright/chatbotmetcs622/network/models/response/QueryResponseMessage.java
@@ -0,0 +1,36 @@
+package com.fazemeright.chatbotmetcs622.network.models.response;
+
+import com.google.gson.annotations.Expose;
+import com.google.gson.annotations.SerializedName;
+
+public class QueryResponseMessage {
+
+ @SerializedName("data")
+ @Expose
+ private Data data;
+
+ public Data getData() {
+ return data;
+ }
+
+ public void setData(Data data) {
+ this.data = data;
+ }
+
+ public class Data {
+
+
+ @SerializedName("responseMsg")
+ @Expose
+ private String responseMsg;
+
+ public String getResponseMsg() {
+ return responseMsg;
+ }
+
+ public void setResponseMsg(String responseMsg) {
+ this.responseMsg = responseMsg;
+ }
+ }
+}
+
diff --git a/app/src/main/java/com/fazemeright/chatbotmetcs622/network/utils/CoreUtils.java b/app/src/main/java/com/fazemeright/chatbotmetcs622/network/utils/CoreUtils.java
new file mode 100644
index 0000000..c34cf18
--- /dev/null
+++ b/app/src/main/java/com/fazemeright/chatbotmetcs622/network/utils/CoreUtils.java
@@ -0,0 +1,43 @@
+package com.fazemeright.chatbotmetcs622.network.utils;
+
+import android.content.Context;
+import android.net.ConnectivityManager;
+import android.net.NetworkInfo;
+import android.webkit.URLUtil;
+
+import com.google.gson.Gson;
+
+
+public class CoreUtils {
+
+ /**
+ * To check internet connection
+ *
+ * @param mContext App context
+ * @return true if available else false
+ */
+ public static boolean isNetworkAvailable(Context mContext) {
+ ConnectivityManager cm = (ConnectivityManager) mContext.getSystemService(Context.CONNECTIVITY_SERVICE);
+ NetworkInfo networkInfo = null;
+ if (cm != null) {
+ networkInfo = cm.getActiveNetworkInfo();
+ }
+ return networkInfo != null && networkInfo.isConnected();
+ }
+
+ public static String getStringFromObject(Object data) {
+ Gson gson = new Gson();
+ return gson.toJson(data);
+ }
+
+ /**
+ * Check whether URL is valid or not
+ *
+ * @param url url
+ * @return true if valid else false
+ */
+ public static boolean isValidUrl(String url) {
+ return URLUtil.isValidUrl(url);
+ }
+
+}
diff --git a/app/src/main/java/com/fazemeright/chatbotmetcs622/repositories/MessageRepository.java b/app/src/main/java/com/fazemeright/chatbotmetcs622/repositories/MessageRepository.java
new file mode 100644
index 0000000..4961091
--- /dev/null
+++ b/app/src/main/java/com/fazemeright/chatbotmetcs622/repositories/MessageRepository.java
@@ -0,0 +1,427 @@
+package com.fazemeright.chatbotmetcs622.repositories;
+
+import android.content.Context;
+import android.content.Intent;
+import android.os.AsyncTask;
+import android.os.Build;
+
+import androidx.core.content.ContextCompat;
+
+import com.fazemeright.chatbotmetcs622.database.ChatBotDatabase;
+import com.fazemeright.chatbotmetcs622.database.messages.Message;
+import com.fazemeright.chatbotmetcs622.database.messages.MessageDao;
+import com.fazemeright.chatbotmetcs622.intentservice.FireBaseIntentService;
+import com.fazemeright.chatbotmetcs622.models.ChatRoom;
+import com.fazemeright.chatbotmetcs622.network.ApiManager;
+import com.fazemeright.chatbotmetcs622.network.NetworkManager;
+import com.fazemeright.chatbotmetcs622.network.handlers.NetworkCallback;
+import com.fazemeright.chatbotmetcs622.network.models.NetError;
+import com.fazemeright.chatbotmetcs622.network.models.NetResponse;
+import com.fazemeright.chatbotmetcs622.network.models.response.QueryResponseMessage;
+import com.fazemeright.firebase_api_library.api.FireBaseApiManager;
+import com.fazemeright.firebase_api_library.listeners.DBValueListener;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ExecutionException;
+
+import timber.log.Timber;
+
+
+public class MessageRepository {
+
+ private static MessageRepository repository;
+ private ChatBotDatabase database;
+ private ApiManager apiManager;
+ private FireBaseApiManager fireBaseApiManager;
+
+ private MessageRepository(ChatBotDatabase database, ApiManager apiManager, FireBaseApiManager fireBaseApiManager) {
+ this.database = database;
+ this.apiManager = apiManager;
+ this.fireBaseApiManager = fireBaseApiManager;
+// messageList = this.database.messageDao().getAllMessages();
+ }
+
+ /**
+ * Call to get instance of MessageRepository with the given context
+ *
+ * @param context given context
+ * @return synchronized call to get Instance of MessageRepository class
+ */
+ public static MessageRepository getInstance(Context context) {
+ if (repository == null) {
+ synchronized (MessageRepository.class) {
+// get instance of database
+ ChatBotDatabase database = ChatBotDatabase.getInstance(context);
+ ApiManager apiManager = ApiManager.getInstance();
+ FireBaseApiManager fireBaseApiManager = FireBaseApiManager.getInstance();
+ apiManager.init(NetworkManager.getInstance());
+ repository = new MessageRepository(database, apiManager, fireBaseApiManager);
+ }
+ }
+ return repository;
+ }
+
+ /**
+ * Call to insert given project into database with thread safety
+ *
+ * @param newMessage given project
+ * @return
+ */
+ private Message insertMessageInRoom(Message newMessage) {
+// insert into Room using AsyncTask
+ Timber.i("Insert message in Room called%s", newMessage.getMsg());
+ try {
+ return new InsertAsyncTask(database.messageDao()).execute(newMessage).get();
+ } catch (ExecutionException | InterruptedException e) {
+ e.printStackTrace();
+ }
+ return newMessage;
+ }
+
+ /**
+ * Call to update given project into database with thread safety
+ *
+ * @param oldMessage given project
+ */
+ private void updateMessage(Message oldMessage) {
+ // insert into Room using AsyncTask
+ new UpdateAsyncTask(database.messageDao()).execute(oldMessage);
+ }
+
+ /**
+ * Call to get Message with given Message ID
+ *
+ * @param mid given Message ID
+ * @return Message with given ID
+ */
+ public Message getMessage(long mid) {
+ return fetchMessage(mid);
+ }
+
+ /**
+ * Call to get Message with given Message ID with thread safety
+ *
+ * @param pid given Message ID
+ * @return Message with given ID
+ */
+ private Message fetchMessage(long pid) {
+ try {
+ return new FetchMessageAsyncTask(database.messageDao()).execute(pid).get();
+ } catch (ExecutionException | InterruptedException e) {
+ e.printStackTrace();
+ return null;
+ }
+ }
+
+ /**
+ * Call to delete project with given project
+ *
+ * @param project given Message
+ * @return Deleted Message
+ */
+ public void deleteMessage(Message project) {
+ deleteMessageFromRoom(project);
+ }
+
+ /**
+ * Delete given Message from Room with Thread Safety
+ *
+ * @param project given Message
+ */
+ private void deleteMessageFromRoom(Message project) {
+ try {
+ new DeleteMessageAsyncTask(database.messageDao()).execute(project).get();
+ } catch (ExecutionException | InterruptedException e) {
+ e.printStackTrace();
+ }
+ }
+
+ public ArrayList getMessagesForChatRoom(ChatRoom chatRoom) {
+ return getChatRoomMessagesFromDatabase(chatRoom);
+ }
+
+ private ArrayList getChatRoomMessagesFromDatabase(ChatRoom chatRoom) {
+ try {
+ return (ArrayList) new FetchChatRoomMessagesAsyncTask(database.messageDao()).execute(chatRoom).get();
+ } catch (ExecutionException | InterruptedException e) {
+ e.printStackTrace();
+ return new ArrayList<>();
+ }
+ }
+
+ /**
+ * Called when user sends a given new message in the ChatRoom
+ * - Add new Message to Room
+ * - Call API to fetch answer for new message
+ * - Sync message with FireStore
+ *
+ * @param newMessage given new message
+ */
+ public void newMessageSent(final Context context, final Message newMessage, final OnMessageResponseReceivedListener listener) {
+ final Message roomLastMessage = insertMessageInRoom(newMessage);
+ insertMessageInFireBase(context, roomLastMessage);
+ apiManager.queryDatabase(context, newMessage, new NetworkCallback() {
+ @Override
+ public void onSuccess(NetResponse response) {
+ Message queryResponseMessage = Message.newMessage(response.getResponse().getData().getResponseMsg(),
+ newMessage.getReceiver(), newMessage.getSender(), newMessage.getChatRoomId());
+
+ Message roomLastInsertedMessage = insertMessageInRoom(queryResponseMessage);
+ insertMessageInFireBase(context, roomLastInsertedMessage);
+ listener.onMessageResponseReceived(queryResponseMessage);
+ }
+
+ @Override
+ public void onError(NetError error) {
+ listener.onNoResponseReceived(new Error(error.getErrorLocalizeMessage()));
+ }
+ });
+
+// TODO: Finish the remaining cart
+ }
+
+ /**
+ * Call to insert the given new message to FireStore database
+ *
+ * @param context context
+ * @param newMessage given new message
+ */
+ private void insertMessageInFireBase(Context context, Message newMessage) {
+ Intent intent = new Intent(context, FireBaseIntentService.class);
+ intent.putExtra(FireBaseIntentService.ACTION, FireBaseIntentService.ACTION_ADD_MESSAGE);
+ intent.putExtra(FireBaseIntentService.MESSAGE, newMessage);
+ context.startService(intent);
+ }
+
+ public ArrayList getAllMessages() {
+ return (ArrayList) database.messageDao().getAllMessages();
+ }
+
+ /**
+ * Clear all given chat room messages
+ * - From Room
+ * - From FireStore
+ *
+ * @param chatRoom given chat room
+ */
+ public void clearAllChatRoomMessages(ChatRoom chatRoom) {
+ clearAllChatRoomMessagesFromRoom(chatRoom);
+ }
+
+ private void clearAllChatRoomMessagesFromRoom(ChatRoom chatRoom) {
+ new ClearAllMessagesInChatRoomAsyncTask(database.messageDao()).execute(chatRoom);
+ }
+
+ /**
+ * Call to logout user and clear all messages from Room
+ */
+ public void logOutUser() {
+ fireBaseApiManager.logOutUser();
+ clearAllMessages();
+ }
+
+ /**
+ * Call to clear all messages from Room
+ */
+ private void clearAllMessages() {
+ new ClearAllMessagesAsyncTask(database.messageDao()).execute();
+ }
+
+ /**
+ * Add given list of messages to Room
+ *
+ * @param messages
+ */
+ public void addMessages(List messages) {
+ new AddAllMessagesAsyncTask(database.messageDao()).execute(messages);
+ }
+
+ /**
+ * Call to add the given message to FireStore
+ *
+ * @param messageHashMap given message converted into HashMap
+ */
+ public void addMessageToFireBase(Map messageHashMap) {
+ fireBaseApiManager.addMessageToUserDatabase(messageHashMap);
+ }
+
+ /**
+ * Call to sync messages from FireStore to Room for the logged in user
+ */
+ public void syncMessagesFromFireStoreToRoom() {
+ fireBaseApiManager.syncMessages(new DBValueListener>>() {
+ @Override
+ public void onDataReceived(List> data) {
+// This code runs on the UI thread
+ List messages = new ArrayList<>();
+ for (Map object :
+ data) {
+ Timber.i(String.valueOf(object.get("mid")));
+ Message newMessage = new Message((long) object.get("mid"), String.valueOf(object.get("msg")),
+ String.valueOf(object.get("sender")), String.valueOf(object.get("receiver")),
+ (long) object.get("chatRoomId"), (long) object.get("timestamp"));
+ Timber.i(newMessage.toString());
+ messages.add(newMessage);
+ }
+ addMessages(messages);
+ }
+
+ @Override
+ public void onCancelled(Error error) {
+
+ }
+ });
+ }
+
+ /**
+ * Fetch all chat room messages for the given ChatRoom through AsyncTask from Room
+ */
+ private static class FetchChatRoomMessagesAsyncTask extends AsyncTask> {
+
+ private MessageDao mAsyncTaskDao;
+
+ FetchChatRoomMessagesAsyncTask(MessageDao dao) {
+ mAsyncTaskDao = dao;
+ }
+
+ @Override
+ protected List doInBackground(ChatRoom... params) {
+ return mAsyncTaskDao.getAllMessagesFromChatRoom(params[0].getId());
+ }
+ }
+
+ /**
+ * Fetch all chat room messages for the given ChatRoom through AsyncTask from Room
+ */
+ private static class ClearAllMessagesInChatRoomAsyncTask extends AsyncTask {
+
+ private MessageDao mAsyncTaskDao;
+
+ ClearAllMessagesInChatRoomAsyncTask(MessageDao dao) {
+ mAsyncTaskDao = dao;
+ }
+
+ @Override
+ protected Void doInBackground(ChatRoom... params) {
+ mAsyncTaskDao.clearChatRoomMessages(params[0].getId());
+ return null;
+ }
+ }
+
+ /**
+ * Fetch all messages through AsyncTask from Room
+ */
+ private static class AddAllMessagesAsyncTask extends AsyncTask, Void, Void> {
+
+ private MessageDao mAsyncTaskDao;
+
+ AddAllMessagesAsyncTask(MessageDao dao) {
+ mAsyncTaskDao = dao;
+ }
+
+ @Override
+ protected Void doInBackground(List... lists) {
+ mAsyncTaskDao.insertAllMessages(lists[0]);
+ return null;
+ }
+ }
+
+ /**
+ * Fetch all messages through AsyncTask from Room
+ */
+ private static class ClearAllMessagesAsyncTask extends AsyncTask {
+
+ private MessageDao mAsyncTaskDao;
+
+ ClearAllMessagesAsyncTask(MessageDao dao) {
+ mAsyncTaskDao = dao;
+ }
+
+ @Override
+ protected Void doInBackground(Void... params) {
+ mAsyncTaskDao.clear();
+ return null;
+ }
+ }
+
+ /**
+ * Call to get favorite projects from Room through AsyncTask
+ */
+ private static class DeleteMessageAsyncTask extends AsyncTask {
+
+ private MessageDao dao;
+
+ DeleteMessageAsyncTask(MessageDao mDao) {
+ dao = mDao;
+ }
+
+
+ @Override
+ protected Message doInBackground(Message... params) {
+ dao.deleteItem(params[0]);
+ return params[0];
+ }
+ }
+
+ /**
+ * Fetch a specific project for the given Message ID through AsyncTask
+ */
+ private static class FetchMessageAsyncTask extends AsyncTask {
+
+ private MessageDao mAsyncTaskDao;
+
+ FetchMessageAsyncTask(MessageDao dao) {
+ mAsyncTaskDao = dao;
+ }
+
+ @Override
+ protected Message doInBackground(Long... params) {
+ return mAsyncTaskDao.get(params[0]);
+ }
+ }
+
+ /**
+ * AsyncTask which makes insert operation thread safe and does not block the main thread for a long time
+ */
+ private static class InsertAsyncTask extends AsyncTask {
+
+ private MessageDao mAsyncTaskDao;
+
+ InsertAsyncTask(MessageDao dao) {
+ mAsyncTaskDao = dao;
+ }
+
+ @Override
+ protected Message doInBackground(final Message... params) {
+ mAsyncTaskDao.insert(params[0]);
+ Timber.i("Inside AsyncTask to insert message in Room %s", params[0].getMsg());
+ return mAsyncTaskDao.getLatestMessage(params[0].getChatRoomId());
+ }
+ }
+
+ /**
+ * AsyncTask which makes insert operation thread safe and does not block the main thread for a long time
+ */
+ private static class UpdateAsyncTask extends AsyncTask {
+
+ private MessageDao mAsyncTaskDao;
+
+ UpdateAsyncTask(MessageDao dao) {
+ mAsyncTaskDao = dao;
+ }
+
+ @Override
+ protected Void doInBackground(final Message... params) {
+ mAsyncTaskDao.update(params[0]);
+ return null;
+ }
+ }
+
+ public interface OnMessageResponseReceivedListener {
+ void onMessageResponseReceived(Message response);
+
+ void onNoResponseReceived(Error error);
+ }
+}
diff --git a/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/base/BaseActivity.java b/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/base/BaseActivity.java
new file mode 100644
index 0000000..86edcfc
--- /dev/null
+++ b/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/base/BaseActivity.java
@@ -0,0 +1,127 @@
+package com.fazemeright.chatbotmetcs622.ui.base;
+
+import android.app.Activity;
+import android.content.Context;
+import android.net.ConnectivityManager;
+import android.net.NetworkInfo;
+import android.os.Bundle;
+import android.view.View;
+import android.view.inputmethod.InputMethodManager;
+import android.widget.Button;
+import android.widget.EditText;
+
+import androidx.annotation.LayoutRes;
+import androidx.annotation.Nullable;
+import androidx.appcompat.app.AppCompatActivity;
+
+import com.fazemeright.chatbotmetcs622.network.ApiManager;
+import com.fazemeright.chatbotmetcs622.network.NetworkManager;
+import com.fazemeright.chatbotmetcs622.repositories.MessageRepository;
+import com.fazemeright.firebase_api_library.api.FireBaseApiManager;
+
+public abstract class BaseActivity extends AppCompatActivity {
+
+ public Context mContext;
+ protected FireBaseApiManager fireBaseApiManager;
+ protected MessageRepository messageRepository;
+ protected ApiManager apiManager;
+
+ @Override
+ protected void onCreate(@Nullable Bundle savedInstanceState) {
+ super.onCreate(savedInstanceState);
+ mContext = this;
+ fireBaseApiManager = FireBaseApiManager.getInstance();
+ messageRepository = MessageRepository.getInstance(mContext);
+ apiManager = ApiManager.getInstance();
+ apiManager.init(NetworkManager.getInstance());
+ setContentView(getLayoutResId());
+ }
+
+ @Override
+ public void setContentView(@LayoutRes int layoutResID) {
+ super.setContentView(layoutResID);
+ initViews();
+ setListeners();
+ }
+
+ /**
+ * Call to hide soft keyboard
+ *
+ * @param activity
+ */
+ public void hideKeyboard(Activity activity) {
+ InputMethodManager imm = (InputMethodManager) activity.getSystemService(Activity.INPUT_METHOD_SERVICE);
+ //Find the currently focused view, so we can grab the correct window token from it.
+ View view = activity.getCurrentFocus();
+ //If no view currently has focus, create a new one, just so we can grab a window token from it
+ if (view == null) {
+ view = new View(activity);
+ }
+ if (imm != null) {
+ imm.hideSoftInputFromWindow(view.getWindowToken(), 0);
+ }
+ }
+
+ public void showKeyBoard(EditText yourEditText) {
+ InputMethodManager imm = (InputMethodManager) getSystemService(Context.INPUT_METHOD_SERVICE);
+ if (imm != null) {
+ imm.showSoftInput(yourEditText, InputMethodManager.SHOW_IMPLICIT);
+ }
+ }
+
+ /**
+ * Call to disable the given button
+ *
+ * @param button given button
+ */
+ protected void disableButton(Button button) {
+ button.setEnabled(false);
+ }
+
+ /**
+ * Call to enable the given button
+ *
+ * @param button given button
+ */
+ protected void enableButton(Button button) {
+ button.setEnabled(true);
+ }
+
+ /**
+ * To initialize views of activity
+ */
+ public abstract void initViews();
+
+ /**
+ * To set listeners of view or callback
+ */
+ public abstract void setListeners();
+
+ /**
+ * To get layout resource id
+ */
+ public abstract int getLayoutResId();
+
+ public boolean isNetworkConnected() {
+ ConnectivityManager cm = (ConnectivityManager) getSystemService(Context.CONNECTIVITY_SERVICE);
+ NetworkInfo networkInfo = null;
+ if (cm != null) {
+ networkInfo = cm.getActiveNetworkInfo();
+ }
+ return networkInfo != null && networkInfo.isConnected();
+ }
+
+ public Context getContext() {
+ return mContext;
+ }
+
+ @Override
+ protected void onResume() {
+ super.onResume();
+ }
+
+ @Override
+ protected void onPause() {
+ super.onPause();
+ }
+}
diff --git a/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/base/BaseFragment.java b/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/base/BaseFragment.java
new file mode 100644
index 0000000..90812a4
--- /dev/null
+++ b/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/base/BaseFragment.java
@@ -0,0 +1,79 @@
+package com.fazemeright.chatbotmetcs622.ui.base;
+
+import android.content.Context;
+import android.net.ConnectivityManager;
+import android.net.NetworkInfo;
+import android.os.Bundle;
+import android.view.LayoutInflater;
+import android.view.View;
+import android.view.ViewGroup;
+
+import androidx.annotation.LayoutRes;
+import androidx.annotation.NonNull;
+import androidx.annotation.Nullable;
+import androidx.fragment.app.Fragment;
+
+import com.fazemeright.chatbotmetcs622.network.ApiManager;
+import com.fazemeright.chatbotmetcs622.network.NetworkManager;
+import com.fazemeright.chatbotmetcs622.repositories.MessageRepository;
+import com.fazemeright.firebase_api_library.api.FireBaseApiManager;
+
+public abstract class BaseFragment extends Fragment {
+
+ public Context mContext;
+ public FireBaseApiManager fireBaseApiManager;
+ protected MessageRepository messageRepository;
+ protected ApiManager apiManager;
+
+ @Override
+ public void onCreate(@Nullable Bundle savedInstanceState) {
+ super.onCreate(savedInstanceState);
+ mContext = getActivity();
+ fireBaseApiManager = FireBaseApiManager.getInstance();
+ messageRepository = MessageRepository.getInstance(mContext);
+ apiManager = ApiManager.getInstance();
+ apiManager.init(NetworkManager.getInstance());
+ }
+
+ @Nullable
+ @Override
+ public View onCreateView(@NonNull LayoutInflater inflater, @Nullable ViewGroup container, @Nullable Bundle savedInstanceState) {
+ View view = inflater.inflate(getLayoutResId(), container, false);
+ initViews(view);
+ setListeners(view);
+ return view;
+ }
+
+ /**
+ * To get layout resource id
+ */
+ public abstract @LayoutRes
+ int getLayoutResId();
+
+ /**
+ * To initialize views of activity
+ */
+ public abstract void initViews(View view);
+
+ /**
+ * To set listeners of view or callback
+ *
+ * @param view
+ */
+ public abstract void setListeners(View view);
+
+ public boolean isNetworkConnected() {
+ ConnectivityManager cm = (ConnectivityManager) mContext.getSystemService(Context.CONNECTIVITY_SERVICE);
+ NetworkInfo networkInfo = null;
+ if (cm != null) {
+ networkInfo = cm.getActiveNetworkInfo();
+ }
+ return networkInfo != null && networkInfo.isConnected();
+ }
+
+ @Nullable
+ @Override
+ public Context getContext() {
+ return mContext;
+ }
+}
diff --git a/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/chat/ChatActivity.java b/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/chat/ChatActivity.java
new file mode 100644
index 0000000..b04986a
--- /dev/null
+++ b/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/chat/ChatActivity.java
@@ -0,0 +1,193 @@
+package com.fazemeright.chatbotmetcs622.ui.chat;
+
+import android.text.TextUtils;
+import android.view.Menu;
+import android.view.MenuItem;
+import android.view.View;
+import android.widget.CompoundButton;
+import android.widget.EditText;
+import android.widget.ImageView;
+import android.widget.Toast;
+
+import androidx.annotation.NonNull;
+import androidx.recyclerview.widget.LinearLayoutManager;
+import androidx.recyclerview.widget.RecyclerView;
+
+import com.fazemeright.chatbotmetcs622.R;
+import com.fazemeright.chatbotmetcs622.database.messages.Message;
+import com.fazemeright.chatbotmetcs622.models.ChatRoom;
+import com.fazemeright.chatbotmetcs622.repositories.MessageRepository;
+import com.fazemeright.chatbotmetcs622.ui.base.BaseActivity;
+import com.fazemeright.chatbotmetcs622.ui.landing.LandingActivity;
+import com.google.android.material.chip.Chip;
+import com.google.android.material.chip.ChipGroup;
+
+import java.util.ArrayList;
+import java.util.Objects;
+
+public class ChatActivity extends BaseActivity implements View.OnClickListener {
+
+ private RecyclerView rvChatList;
+ private ChatListAdapter adapter;
+ private ArrayList messages;
+ private EditText etMsg;
+ private ImageView ivSendMsg;
+ private ChatRoom chatRoom;
+ private ChipGroup dataFilterChipGroup;
+
+ @Override
+ public void initViews() {
+
+ etMsg = findViewById(R.id.etMsg);
+ ivSendMsg = findViewById(R.id.ivSendMsg);
+ rvChatList = findViewById(R.id.rvChatList);
+ dataFilterChipGroup = findViewById(R.id.dataFilterChipGroup);
+
+ if (getIntent() != null) {
+ chatRoom = (ChatRoom) getIntent().getSerializableExtra(LandingActivity.SELECTED_CHAT_ROOM);
+ if (getSupportActionBar() != null) {
+ getSupportActionBar().setTitle(chatRoom.getName());
+ getSupportActionBar().setHomeButtonEnabled(true);
+ getSupportActionBar().setDisplayHomeAsUpEnabled(true);
+ }
+ }
+
+ String[] dataFilters = getResources().getStringArray(R.array.query_sample_selection);
+ setupFilterKeywords(dataFilters);
+
+ rvChatList.setHasFixedSize(true);
+ LinearLayoutManager linearLayoutManager = new LinearLayoutManager(mContext);
+ linearLayoutManager.setReverseLayout(true);
+ linearLayoutManager.setStackFromEnd(true);
+ rvChatList.setLayoutManager(linearLayoutManager);
+
+ ArrayList messages = messageRepository.getMessagesForChatRoom(chatRoom);
+ adapter = new ChatListAdapter(messages, mContext);
+
+ rvChatList.setAdapter(adapter);
+// Show user the most recent messages, hence scroll to the top
+ rvChatList.scrollToPosition(ChatListAdapter.MOST_RECENT_MSG_POSITION);
+ }
+
+ /**
+ * Use to setup chips for the given list of data filter for device usage
+ *
+ * @param dataFilters given array of data filter
+ */
+ private void setupFilterKeywords(String[] dataFilters) {
+// remove all views from ChipGroup if any
+ dataFilterChipGroup.removeAllViews();
+ if (dataFilters != null) {
+ for (final String dataFilter :
+ dataFilters) {
+// create new chip and apply attributes
+ Chip chip = new Chip(Objects.requireNonNull(mContext)) {{
+ setText(dataFilter); // set text
+ setClickable(true);
+ setCloseIconVisible(false); // no need for close icon in our scenario
+ setCheckable(true); // set checkable to be true, hence allow check changes
+ }};
+ dataFilterChipGroup.addView(chip); // add chip to ChipGroup
+ chip.setOnCheckedChangeListener(new CompoundButton.OnCheckedChangeListener() {
+ @Override
+ public void onCheckedChanged(CompoundButton buttonView, boolean isChecked) {
+ if (isChecked) {
+ etMsg.requestFocus();
+ etMsg.setText(buttonView.getText().toString());
+ etMsg.setSelection(buttonView.getText().toString().length());
+ showKeyBoard(etMsg);
+ }
+ }
+ });
+
+ }
+// show ChipGroup if list is not empty
+ dataFilterChipGroup.setVisibility(View.VISIBLE);
+ } else {
+// hide ChipGroup if list is empty
+ dataFilterChipGroup.setVisibility(View.INVISIBLE);
+ }
+ }
+
+ @Override
+ public boolean onOptionsItemSelected(@NonNull MenuItem item) {
+ switch (item.getItemId()) {
+ case android.R.id.home:
+ onBackPressed();
+ break;
+ case R.id.action_clear:
+ clearChatRoomMessagesClicked(chatRoom);
+ break;
+ }
+ return super.onOptionsItemSelected(item);
+ }
+
+ /**
+ * Call to clear all message for the given ChatRoom
+ *
+ * @param chatRoom given ChatRoom
+ */
+ private void clearChatRoomMessagesClicked(ChatRoom chatRoom) {
+ messageRepository.clearAllChatRoomMessages(chatRoom);
+ adapter.clearAllMessages();
+ }
+
+ @Override
+ public void setListeners() {
+ ivSendMsg.setOnClickListener(this);
+ }
+
+ @Override
+ public int getLayoutResId() {
+ return R.layout.activity_chat;
+ }
+
+ @Override
+ public void onClick(View v) {
+ if (v.getId() == R.id.ivSendMsg) {
+ sendMessageClicked();
+ }
+ }
+
+ /**
+ * User clicked send message. Show new message to user and pass it to repository
+ */
+ private void sendMessageClicked() {
+ String msg = etMsg.getText().toString().trim();
+ if (TextUtils.isEmpty(msg)) {
+ return;
+ }
+ etMsg.setText("");
+ Message newMessage = Message.newMessage(msg, Message.SENDER_USER, chatRoom.getName(), chatRoom.getId());
+ addMessageToAdapter(newMessage);
+// send new message to repository
+ messageRepository.newMessageSent(mContext, newMessage, new MessageRepository.OnMessageResponseReceivedListener() {
+ @Override
+ public void onMessageResponseReceived(Message response) {
+ addMessageToAdapter(response);
+ }
+
+ @Override
+ public void onNoResponseReceived(Error error) {
+ Toast.makeText(mContext, error.getLocalizedMessage(), Toast.LENGTH_SHORT).show();
+// TODO: Show error to the user
+ }
+ });
+ }
+
+ /**
+ * Call to add given new message to the Adapter and display it to the user and scroll to it
+ *
+ * @param newMessage given new message to be displayed
+ */
+ private void addMessageToAdapter(Message newMessage) {
+ adapter.addMessage(newMessage);
+ rvChatList.scrollToPosition(ChatListAdapter.MOST_RECENT_MSG_POSITION);
+ }
+
+ @Override
+ public boolean onCreateOptionsMenu(Menu menu) {
+ getMenuInflater().inflate(R.menu.menu_chat, menu);
+ return super.onCreateOptionsMenu(menu);
+ }
+}
diff --git a/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/chat/ChatListAdapter.java b/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/chat/ChatListAdapter.java
new file mode 100644
index 0000000..992968b
--- /dev/null
+++ b/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/chat/ChatListAdapter.java
@@ -0,0 +1,128 @@
+package com.fazemeright.chatbotmetcs622.ui.chat;
+
+import android.content.Context;
+import android.view.LayoutInflater;
+import android.view.View;
+import android.view.ViewGroup;
+import android.widget.TextView;
+
+import androidx.annotation.NonNull;
+import androidx.recyclerview.widget.RecyclerView;
+
+import com.fazemeright.chatbotmetcs622.R;
+import com.fazemeright.chatbotmetcs622.database.messages.Message;
+
+import java.util.ArrayList;
+
+/**
+ * RecyclerView Adapter to display Chat
+ *
+ * @see ChatActivity for use
+ */
+public class ChatListAdapter extends RecyclerView.Adapter {
+
+ static final int MOST_RECENT_MSG_POSITION = 0;
+ private static final int TYPE_SENT = 0;
+ private static final int TYPE_RECEIVED = 1;
+ private ArrayList messages;
+ private Context context;
+
+
+ ChatListAdapter(ArrayList messages, Context context) {
+ this.messages = messages;
+ this.context = context;
+ }
+
+ @NonNull
+ @Override
+ public RecyclerView.ViewHolder onCreateViewHolder(@NonNull ViewGroup viewGroup, int viewType) {
+ View view;
+ if (viewType == TYPE_SENT) { // for sent message layout
+ view = LayoutInflater.from(context).inflate(R.layout.sender_message_display_view_item, viewGroup, false);
+ return new SentViewHolder(view);
+
+ } else { // for received message layout
+ view = LayoutInflater.from(context).inflate(R.layout.receiver_message_display_view_item, viewGroup, false);
+ return new ReceivedViewHolder(view);
+ }
+ }
+
+ @Override
+ public void onBindViewHolder(@NonNull RecyclerView.ViewHolder holder, int position) {
+ if (getItemViewType(position) == TYPE_SENT) {
+ ((SentViewHolder) holder).bind(messages.get(position));
+ } else {
+ ((ReceivedViewHolder) holder).bind(messages.get(position));
+ }
+ }
+
+ @Override
+ public int getItemViewType(int position) {
+ if (messages.get(position).getSender().equals(Message.SENDER_USER)) {
+ return TYPE_SENT;
+ } else {
+ return TYPE_RECEIVED;
+ }
+ }
+
+ @Override
+ public int getItemCount() {
+ return messages == null ? 0 : messages.size();
+ }
+
+ /**
+ * Call to add given new message to ArrayList at the bottom of the list and notify it was inserted
+ *
+ * @param newMessage given new message
+ */
+ void addMessage(Message newMessage) {
+ if (messages == null) {
+ messages = new ArrayList<>();
+ }
+ messages.add(MOST_RECENT_MSG_POSITION, newMessage);
+ notifyItemInserted(MOST_RECENT_MSG_POSITION);
+ }
+
+ /**
+ * Call to remove all messages from the Data List and notify data set changed
+ */
+ void clearAllMessages() {
+ messages.clear();
+ notifyDataSetChanged();
+ }
+
+ public interface ChatMessageInteractionListener {
+ }
+
+ public class SentViewHolder extends RecyclerView.ViewHolder {
+
+ TextView tvMsg, tvTimestamp;
+
+ SentViewHolder(@NonNull View itemView) {
+ super(itemView);
+ tvMsg = itemView.findViewById(R.id.tvMsg);
+ tvTimestamp = itemView.findViewById(R.id.tvTimestamp);
+ }
+
+ void bind(Message item) {
+ tvMsg.setText(item.getMsg());
+ tvTimestamp.setText(item.getFormattedTime());
+ }
+ }
+
+ public class ReceivedViewHolder extends RecyclerView.ViewHolder {
+
+ TextView tvMsg, tvTimestamp;
+
+ ReceivedViewHolder(@NonNull View itemView) {
+ super(itemView);
+ tvMsg = itemView.findViewById(R.id.tvMsg);
+ tvTimestamp = itemView.findViewById(R.id.tvTimestamp);
+ }
+
+ void bind(Message item) {
+ tvMsg.setText(item.getMsg());
+ tvTimestamp.setText(item.getFormattedTime());
+ }
+ }
+}
diff --git a/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/landing/ChatSelectionListAdapter.java b/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/landing/ChatSelectionListAdapter.java
new file mode 100644
index 0000000..e56df88
--- /dev/null
+++ b/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/landing/ChatSelectionListAdapter.java
@@ -0,0 +1,92 @@
+package com.fazemeright.chatbotmetcs622.ui.landing;
+
+import android.view.LayoutInflater;
+import android.view.View;
+import android.view.ViewGroup;
+import android.widget.ImageView;
+import android.widget.TextView;
+
+import androidx.annotation.NonNull;
+import androidx.recyclerview.widget.DiffUtil;
+import androidx.recyclerview.widget.ListAdapter;
+import androidx.recyclerview.widget.RecyclerView;
+
+import com.fazemeright.chatbotmetcs622.R;
+import com.fazemeright.chatbotmetcs622.models.ChatRoom;
+
+import java.util.ArrayList;
+
+/**
+ * RecyclerView Adapter to show Chat Rooms
+ *
+ * @see LandingActivity for use
+ */
+public class ChatSelectionListAdapter extends ListAdapter {
+
+ private ChatListInteractionListener listener;
+
+ protected ChatSelectionListAdapter(ChatListInteractionListener listener) {
+ super(new ChatRoomDiffCallBack());
+ this.listener = listener;
+ }
+
+ @NonNull
+ @Override
+ public ViewHolder onCreateViewHolder(@NonNull ViewGroup parent, int viewType) {
+ View v = LayoutInflater.from(parent.getContext())
+ .inflate(R.layout.chat_room_display_view_item, parent, false);
+
+ return new ViewHolder(v);
+ }
+
+ @Override
+ public void onBindViewHolder(@NonNull ViewHolder holder, int position) {
+ holder.bind(getItem(position));
+ }
+
+ public void submitDataList(ArrayList dataList) {
+ submitList(dataList);
+ }
+
+ public interface ChatListInteractionListener {
+ void onChatRoomClicked(ChatRoom chatRoom);
+ }
+
+ static class ChatRoomDiffCallBack extends DiffUtil.ItemCallback {
+
+ @Override
+ public boolean areItemsTheSame(@NonNull ChatRoom oldItem, @NonNull ChatRoom newItem) {
+ return oldItem.getId() == newItem.getId();
+ }
+
+ @Override
+ public boolean areContentsTheSame(@NonNull ChatRoom oldItem, @NonNull ChatRoom newItem) {
+ return oldItem.equals(newItem);
+ }
+ }
+
+ public class ViewHolder extends RecyclerView.ViewHolder {
+
+ TextView tvChatRoomName;
+ ImageView ivChatRoom;
+
+ public ViewHolder(@NonNull View itemView) {
+ super(itemView);
+ tvChatRoomName = itemView.findViewById(R.id.tvChatRoomName);
+ ivChatRoom = itemView.findViewById(R.id.ivChatRoom);
+ }
+
+ public void bind(ChatRoom item) {
+ tvChatRoomName.setText(item.getName());
+
+ ivChatRoom.setBackgroundResource(item.getLogoId());
+
+ itemView.setOnClickListener(new View.OnClickListener() {
+ @Override
+ public void onClick(View v) {
+ listener.onChatRoomClicked(getItem(getAdapterPosition()));
+ }
+ });
+ }
+ }
+}
diff --git a/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/landing/LandingActivity.java b/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/landing/LandingActivity.java
new file mode 100644
index 0000000..159a450
--- /dev/null
+++ b/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/landing/LandingActivity.java
@@ -0,0 +1,99 @@
+package com.fazemeright.chatbotmetcs622.ui.landing;
+
+import android.content.Intent;
+import android.view.Menu;
+import android.view.MenuItem;
+
+import androidx.annotation.NonNull;
+import androidx.recyclerview.widget.DividerItemDecoration;
+import androidx.recyclerview.widget.LinearLayoutManager;
+import androidx.recyclerview.widget.RecyclerView;
+
+import com.fazemeright.chatbotmetcs622.R;
+import com.fazemeright.chatbotmetcs622.models.ChatRoom;
+import com.fazemeright.chatbotmetcs622.ui.base.BaseActivity;
+import com.fazemeright.chatbotmetcs622.ui.chat.ChatActivity;
+import com.fazemeright.chatbotmetcs622.ui.login.LoginActivity;
+import com.fazemeright.chatbotmetcs622.ui.registration.RegistrationActivity;
+
+import java.util.ArrayList;
+
+public class LandingActivity extends BaseActivity implements ChatSelectionListAdapter.ChatListInteractionListener {
+
+ public static final String SELECTED_CHAT_ROOM = "chatRoomSelected";
+ private RecyclerView rvChatRoomList;
+ private ChatSelectionListAdapter adapter;
+
+ @Override
+ public void initViews() {
+ if (getSupportActionBar() != null) {
+ String firstName = fireBaseApiManager.getCurrentUserFirstName();
+ if (firstName == null) {
+ firstName = "Adit";
+ }
+ getSupportActionBar().setTitle(getString(R.string.welcome_title) + " " + firstName);
+ }
+
+ rvChatRoomList = findViewById(R.id.rvChatRoomList);
+ rvChatRoomList.setHasFixedSize(true);
+ rvChatRoomList.setLayoutManager(new LinearLayoutManager(mContext));
+ rvChatRoomList.addItemDecoration(new DividerItemDecoration(rvChatRoomList.getContext(), LinearLayoutManager.VERTICAL));
+ adapter = new ChatSelectionListAdapter(this);
+ rvChatRoomList.setAdapter(adapter);
+
+ adapter.submitDataList(getChatRoomList());
+ }
+
+ private ArrayList getChatRoomList() {
+ ArrayList chatRooms = new ArrayList<>();
+ chatRooms.add(new ChatRoom(ChatRoom.BRUTE_FORCE_ID, ChatRoom.BRUTE_FORCE, R.drawable.brute_force_logo));
+ chatRooms.add(new ChatRoom(ChatRoom.LUCENE_ID, ChatRoom.LUCENE, R.drawable.lucene_logo));
+ chatRooms.add(new ChatRoom(ChatRoom.MONGO_DB_ID, ChatRoom.MONGO_DB, R.drawable.mongodb_logo));
+ chatRooms.add(new ChatRoom(ChatRoom.MY_SQL_ID, ChatRoom.MY_SQL, R.drawable.mysql_logo));
+ return chatRooms;
+ }
+
+ @Override
+ public boolean onCreateOptionsMenu(Menu menu) {
+ getMenuInflater().inflate(R.menu.menu_landing, menu);
+ return true;
+ }
+
+ @Override
+ public boolean onOptionsItemSelected(@NonNull MenuItem item) {
+ switch (item.getItemId()) {
+ case R.id.action_logout:
+ logoutUser();
+ openRegistrationActivity();
+ return true;
+ }
+
+ return super.onOptionsItemSelected(item);
+ }
+
+ private void openRegistrationActivity() {
+ startActivity(new Intent(LandingActivity.this, RegistrationActivity.class));
+ finish();
+ }
+
+ private void logoutUser() {
+ messageRepository.logOutUser();
+ }
+
+ @Override
+ public void setListeners() {
+
+ }
+
+ @Override
+ public int getLayoutResId() {
+ return R.layout.activity_landing;
+ }
+
+ @Override
+ public void onChatRoomClicked(ChatRoom chatRoom) {
+ Intent intent = new Intent(LandingActivity.this, ChatActivity.class);
+ intent.putExtra(SELECTED_CHAT_ROOM, chatRoom);
+ startActivity(intent);
+ }
+}
diff --git a/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/login/LoginActivity.java b/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/login/LoginActivity.java
new file mode 100644
index 0000000..f803fbc
--- /dev/null
+++ b/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/login/LoginActivity.java
@@ -0,0 +1,143 @@
+package com.fazemeright.chatbotmetcs622.ui.login;
+
+import android.content.Context;
+import android.content.Intent;
+import android.os.Build;
+import android.view.MenuItem;
+import android.view.View;
+import android.widget.Button;
+import android.widget.EditText;
+import android.widget.TextView;
+
+import androidx.annotation.NonNull;
+import androidx.core.content.ContextCompat;
+
+import com.fazemeright.chatbotmetcs622.R;
+import com.fazemeright.chatbotmetcs622.intentservice.FireBaseIntentService;
+import com.fazemeright.chatbotmetcs622.ui.base.BaseActivity;
+import com.fazemeright.chatbotmetcs622.ui.landing.LandingActivity;
+import com.fazemeright.chatbotmetcs622.utils.AppUtils;
+import com.fazemeright.firebase_api_library.listeners.OnTaskCompleteListener;
+
+import timber.log.Timber;
+
+public class LoginActivity extends BaseActivity implements View.OnClickListener {
+
+ private EditText userEmailEditText, userPasswordEditText;
+ private TextView tvDontHaveAccount;
+ private Button btnLogin;
+
+ @Override
+ public void initViews() {
+// set title for activity
+ if (getSupportActionBar() != null) {
+ getSupportActionBar().setTitle(getString(R.string.login_title));
+ getSupportActionBar().setHomeButtonEnabled(true);
+ getSupportActionBar().setDisplayHomeAsUpEnabled(true);
+ }
+
+
+ userEmailEditText = findViewById(R.id.userLoginEmailEditText);
+ userPasswordEditText = findViewById(R.id.userPasswordEditText);
+ tvDontHaveAccount = findViewById(R.id.tvDontHaveAccount);
+ btnLogin = findViewById(R.id.btnLogin);
+ }
+
+ @Override
+ public boolean onOptionsItemSelected(@NonNull MenuItem item) {
+ if (item.getItemId() == android.R.id.home) {
+ finish();
+ }
+ return super.onOptionsItemSelected(item);
+ }
+
+ @Override
+ public void setListeners() {
+ btnLogin.setOnClickListener(this);
+ tvDontHaveAccount.setOnClickListener(this);
+ }
+
+ @Override
+ public int getLayoutResId() {
+ return R.layout.activity_login;
+ }
+
+ @Override
+ public void onClick(View v) {
+ switch (v.getId()) {
+ case R.id.tvDontHaveAccount:
+ openRegistrationActivity();
+ break;
+ case R.id.btnLogin:
+// TODO: Disable and re-enable the button after performing registration and validation
+ disableButton(btnLogin);
+ String email = userEmailEditText.getText().toString();
+ String password = userPasswordEditText.getText().toString();
+ performLogin(email, password);
+ enableButton(btnLogin);
+ break;
+ }
+ }
+
+ /**
+ * Perform login with the given credentials
+ *
+ * @param email user email address
+ * @param password user password
+ */
+ private void performLogin(String email, String password) {
+ if (!AppUtils.isValidEmail(email)) {
+ userEmailEditText.setError(mContext.getString(R.string.incorrect_email_err_msg));
+ userEmailEditText.requestFocus();
+ return;
+ }
+
+ if (!AppUtils.isValidPassword(password)) {
+ userPasswordEditText.setError(mContext.getString(R.string.incorrect_pass_err_msg));
+ userPasswordEditText.requestFocus();
+ return;
+ }
+
+ Timber.i("Login clicked");
+ fireBaseApiManager.logInWithEmailAndPassword(email, password, new OnTaskCompleteListener() {
+ @Override
+ public void onTaskSuccessful() {
+ Timber.i("User logged in successfully %s", fireBaseApiManager.getCurrentLoggedInUserEmail());
+ btnLogin.setText(getString(R.string.login_success_msg));
+ Intent intent = new Intent(mContext, FireBaseIntentService.class);
+ intent.putExtra(FireBaseIntentService.ACTION, FireBaseIntentService.ACTION_SYNC_MESSAGES);
+// ContextCompat.startForegroundService(LoginActivity.this, intent);
+// ContextCompat.startForegroundService(mContext, intent);
+ ContextCompat.startForegroundService(mContext, intent);
+ openLandingActivity();
+ }
+
+ @Override
+ public void onTaskCompleteButFailed(String errMsg) {
+ Timber.e(errMsg);
+// TODO: Show error to user
+ }
+
+ @Override
+ public void onTaskFailed(Exception e) {
+ Timber.e(e);
+// TODO: Show error to user
+ }
+ });
+ }
+
+ /**
+ * Open LandingActivity and finish this one
+ */
+ private void openLandingActivity() {
+ startActivity(new Intent(LoginActivity.this, LandingActivity.class));
+ finishAffinity();
+ }
+
+ /**
+ * Open Registration Activity
+ */
+ private void openRegistrationActivity() {
+ finish();
+ }
+}
diff --git a/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/registration/RegistrationActivity.java b/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/registration/RegistrationActivity.java
new file mode 100644
index 0000000..0541698
--- /dev/null
+++ b/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/registration/RegistrationActivity.java
@@ -0,0 +1,150 @@
+package com.fazemeright.chatbotmetcs622.ui.registration;
+
+import android.content.Intent;
+import android.view.View;
+import android.widget.Button;
+import android.widget.EditText;
+import android.widget.TextView;
+
+import com.fazemeright.chatbotmetcs622.ui.landing.LandingActivity;
+import com.fazemeright.chatbotmetcs622.R;
+import com.fazemeright.chatbotmetcs622.ui.base.BaseActivity;
+import com.fazemeright.chatbotmetcs622.ui.login.LoginActivity;
+import com.fazemeright.chatbotmetcs622.utils.AppUtils;
+import com.fazemeright.firebase_api_library.listeners.OnTaskCompleteListener;
+
+import timber.log.Timber;
+
+public class RegistrationActivity extends BaseActivity implements View.OnClickListener {
+
+ private EditText userEmailEditText, userPasswordEditText, userConPasswordEditText, etFirstName, etLastName;
+ private TextView tvHaveAccount;
+ private Button btnRegister;
+
+ @Override
+ public void initViews() {
+// set title for activity
+ if (getSupportActionBar() != null) {
+ getSupportActionBar().setTitle(getString(R.string.registration));
+ }
+
+ userEmailEditText = findViewById(R.id.userLoginEmailEditText);
+ etFirstName = findViewById(R.id.etFirstName);
+ etLastName = findViewById(R.id.etLastName);
+ userPasswordEditText = findViewById(R.id.userPasswordEditText);
+ userConPasswordEditText = findViewById(R.id.userConPasswordEditText);
+ tvHaveAccount = findViewById(R.id.tvHaveAccount);
+ btnRegister = findViewById(R.id.btnRegister);
+
+ }
+
+ @Override
+ public void setListeners() {
+ btnRegister.setOnClickListener(this);
+ tvHaveAccount.setOnClickListener(this);
+ }
+
+ @Override
+ public int getLayoutResId() {
+ return R.layout.activity_registration;
+ }
+
+ @Override
+ public void onClick(View v) {
+ switch (v.getId()) {
+ case R.id.tvHaveAccount:
+ openLoginActivity();
+ break;
+ case R.id.btnRegister:
+ disableButton(btnRegister);
+ String email = userEmailEditText.getText().toString();
+ String firstName = etFirstName.getText().toString();
+ String lastName = etLastName.getText().toString();
+ String password = userPasswordEditText.getText().toString();
+ String conPassword = userConPasswordEditText.getText().toString();
+ performRegistration(email, firstName, lastName, password, conPassword);
+ enableButton(btnRegister);
+ break;
+ }
+ }
+
+ /**
+ * Open Login Activity
+ */
+ private void openLoginActivity() {
+ startActivity(new Intent(RegistrationActivity.this, LoginActivity.class));
+ }
+
+ /**
+ * Call to perform validation on the input parameters and then perform registration
+ *
+ * @param email user email address
+ * @param firstName first name of user
+ * @param lastName last name of user
+ * @param password user selected password
+ * @param conPassword user selected confirmation password
+ */
+ private void performRegistration(final String email, String firstName, String lastName, final String password, String conPassword) {
+ if (!AppUtils.isValidEmail(email)) {
+ userEmailEditText.setError(mContext.getString(R.string.incorrect_email_err_msg));
+ userEmailEditText.requestFocus();
+ return;
+ }
+
+ if (!AppUtils.isValidName(firstName)) {
+ etFirstName.setError(mContext.getString(R.string.incorrect_first_name));
+ etFirstName.requestFocus();
+ return;
+ }
+
+ if (!AppUtils.isValidName(lastName)) {
+ etLastName.setError(mContext.getString(R.string.incorrect_last_name));
+ etLastName.requestFocus();
+ return;
+ }
+
+ if (!AppUtils.isValidPassword(password)) {
+ userPasswordEditText.setError(mContext.getString(R.string.incorrect_pass_err_msg));
+ userPasswordEditText.requestFocus();
+ return;
+ }
+
+ if (!AppUtils.arePasswordsValid(password, conPassword)) {
+ userPasswordEditText.setError(mContext.getString(R.string.passwords_dont_match_err_msg));
+ userPasswordEditText.requestFocus();
+ userPasswordEditText.setText("");
+ userConPasswordEditText.setText("");
+ return;
+ }
+
+ fireBaseApiManager.registerNewUserWithEmailPassword(email, password, firstName, lastName, new OnTaskCompleteListener() {
+ @Override
+ public void onTaskSuccessful() {
+ Timber.i("New user registered successfully %s", fireBaseApiManager.getCurrentLoggedInUserEmail());
+ btnRegister.setText(getString(R.string.registration_success_msg));
+ openLandingActivity();
+ }
+
+ @Override
+ public void onTaskCompleteButFailed(String errMsg) {
+ Timber.e(errMsg);
+// TODO: Show error to user
+ }
+
+ @Override
+ public void onTaskFailed(Exception e) {
+ Timber.e(e);
+// TODO: Show error to user
+ }
+ });
+
+ }
+
+ /**
+ * Open LandingActivity and finish this one
+ */
+ private void openLandingActivity() {
+ startActivity(new Intent(RegistrationActivity.this, LandingActivity.class));
+ finish();
+ }
+}
diff --git a/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/splash/SplashActivity.java b/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/splash/SplashActivity.java
new file mode 100644
index 0000000..2619afc
--- /dev/null
+++ b/app/src/main/java/com/fazemeright/chatbotmetcs622/ui/splash/SplashActivity.java
@@ -0,0 +1,149 @@
+package com.fazemeright.chatbotmetcs622.ui.splash;
+
+import android.content.Intent;
+import android.content.pm.PackageInfo;
+import android.content.pm.PackageManager;
+import android.os.Handler;
+import android.view.WindowManager;
+import android.view.animation.Animation;
+import android.view.animation.AnimationUtils;
+import android.widget.TextView;
+
+import androidx.work.Constraints;
+import androidx.work.PeriodicWorkRequest;
+import androidx.work.WorkManager;
+
+import com.fazemeright.chatbotmetcs622.ui.landing.LandingActivity;
+import com.fazemeright.chatbotmetcs622.R;
+import com.fazemeright.chatbotmetcs622.ui.base.BaseActivity;
+import com.fazemeright.chatbotmetcs622.ui.registration.RegistrationActivity;
+import com.fazemeright.chatbotmetcs622.workers.FireBaseSyncWorker;
+import com.fazemeright.firebase_api_library.listeners.OnTaskCompleteListener;
+
+import java.util.concurrent.TimeUnit;
+
+import timber.log.Timber;
+
+public class SplashActivity extends BaseActivity {
+
+ private TextView tvAppVersion, tvAppTitle;
+
+ @Override
+ public void initViews() {
+ hideSystemUI();
+ tvAppVersion = findViewById(R.id.tvAppVersion);
+ tvAppTitle = findViewById(R.id.tvAppTitle);
+
+ tvAppVersion.setText(getAppVersion());
+
+ fadeInViews();
+
+ final Handler handler = new Handler();
+ handler.postDelayed(new Runnable() {
+ @Override
+ public void run() {
+ determineIfUserIsLoggedIn();
+ }
+ }, 800);
+ }
+
+ private void fadeInViews() {
+ Animation aniFade = AnimationUtils.loadAnimation(getApplicationContext(), R.anim.fade_in);
+ tvAppTitle.startAnimation(aniFade);
+ tvAppVersion.startAnimation(aniFade);
+ }
+
+ private void determineIfUserIsLoggedIn() {
+ fireBaseApiManager.reloadUserAuthState(new OnTaskCompleteListener() {
+ @Override
+ public void onTaskSuccessful() {
+// user is logged in, open landing activity
+ Constraints constraints = new Constraints.Builder()
+ .setRequiresCharging(true)
+ .build();
+
+ PeriodicWorkRequest saveRequest =
+ new PeriodicWorkRequest.Builder(FireBaseSyncWorker.class, 1, TimeUnit.DAYS)
+ .setConstraints(constraints)
+ .build();
+
+ WorkManager.getInstance(mContext)
+ .enqueue(saveRequest);
+
+ Timber.i("Open Landing Activity");
+ openLandingActivity();
+ }
+
+ @Override
+ public void onTaskCompleteButFailed(String errMsg) {
+ // user not logged in, open registration activity
+ Timber.i("Open Registration Activity");
+ openRegistrationActivity();
+ }
+
+ @Override
+ public void onTaskFailed(Exception e) {
+ // user not logged in or could not perform check, open registration activity
+ Timber.i("Open Registration Activity");
+ openRegistrationActivity();
+ }
+ });
+ }
+
+ /**
+ * Call to open RegistrationActivity from the current activity
+ */
+ private void openRegistrationActivity() {
+ Animation animFadeOut = AnimationUtils.loadAnimation(getApplicationContext(), R.anim.fade_out);
+ tvAppVersion.startAnimation(animFadeOut);
+ tvAppTitle.startAnimation(animFadeOut);
+
+ startActivity(new Intent(SplashActivity.this, RegistrationActivity.class));
+ finish();
+ }
+
+ /**
+ * Open LandingActivity and finish this one
+ */
+ private void openLandingActivity() {
+ Animation animFadeOut = AnimationUtils.loadAnimation(getApplicationContext(), R.anim.fade_out);
+ tvAppVersion.startAnimation(animFadeOut);
+ tvAppTitle.startAnimation(animFadeOut);
+
+ startActivity(new Intent(SplashActivity.this, LandingActivity.class));
+ finish();
+ }
+
+ /**
+ * Call to get the version of the Application
+ *
+ * @return version name of the application
+ */
+ private String getAppVersion() {
+ PackageInfo pInfo;
+ try {
+ pInfo = getPackageManager().getPackageInfo(getPackageName(), 0);
+ return pInfo.versionName;
+ } catch (PackageManager.NameNotFoundException e) {
+ return "beta-testing";
+ }
+ }
+
+ /**
+ * Makes the screen layout to cover the full display of the device
+ */
+ private void hideSystemUI() {
+ getWindow().setFlags(WindowManager.LayoutParams.FLAG_LAYOUT_NO_LIMITS,
+ WindowManager.LayoutParams.FLAG_LAYOUT_NO_LIMITS);
+ }
+
+ @Override
+ public void setListeners() {
+
+ }
+
+ @Override
+ public int getLayoutResId() {
+ return R.layout.activity_splash;
+ }
+}
diff --git a/app/src/main/java/com/fazemeright/chatbotmetcs622/utils/AppUtils.java b/app/src/main/java/com/fazemeright/chatbotmetcs622/utils/AppUtils.java
new file mode 100644
index 0000000..76eb38a
--- /dev/null
+++ b/app/src/main/java/com/fazemeright/chatbotmetcs622/utils/AppUtils.java
@@ -0,0 +1,48 @@
+package com.fazemeright.chatbotmetcs622.utils;
+
+import android.text.TextUtils;
+import android.util.Patterns;
+
+public class AppUtils {
+
+ /**
+ * Call to check validity of given email address
+ *
+ * @param email given email address
+ * @return true if given email is valid, else false
+ */
+ public static boolean isValidEmail(String email) {
+ return !TextUtils.isEmpty(email) && Patterns.EMAIL_ADDRESS.matcher(email).matches();
+ }
+
+ /**
+ * Call to check if given password is valid i.e. it is longer than 7 characters
+ *
+ * @param password given password
+ * @return true if given password is valid, else false
+ */
+ public static boolean isValidPassword(String password) {
+ return !TextUtils.isEmpty(password) && password.length() > 7;
+ }
+
+ /**
+ * Call to check if given password match or not
+ *
+ * @param password given password
+ * @param conPassword given confirm password
+ * @return true if both passwords match, else false
+ */
+ public static boolean arePasswordsValid(String password, String conPassword) {
+ return password.equals(conPassword);
+ }
+
+ /**
+ * Call to check if given name is valid or not. It should not be empty
+ *
+ * @param name given name
+ * @return true if given name is valid, else false
+ */
+ public static boolean isValidName(String name) {
+ return !TextUtils.isEmpty(name);
+ }
+}
diff --git a/app/src/main/java/com/fazemeright/chatbotmetcs622/workers/FireBaseSyncWorker.java b/app/src/main/java/com/fazemeright/chatbotmetcs622/workers/FireBaseSyncWorker.java
new file mode 100644
index 0000000..0febbf8
--- /dev/null
+++ b/app/src/main/java/com/fazemeright/chatbotmetcs622/workers/FireBaseSyncWorker.java
@@ -0,0 +1,30 @@
+package com.fazemeright.chatbotmetcs622.workers;
+
+import android.content.Context;
+
+import androidx.annotation.NonNull;
+import androidx.work.Worker;
+import androidx.work.WorkerParameters;
+
+import com.fazemeright.chatbotmetcs622.database.messages.Message;
+import com.fazemeright.chatbotmetcs622.repositories.MessageRepository;
+
+public class FireBaseSyncWorker extends Worker {
+ public FireBaseSyncWorker(@NonNull Context context, @NonNull WorkerParameters workerParams) {
+ super(context, workerParams);
+ }
+
+ @NonNull
+ @Override
+ public Result doWork() {
+// add all messages from Room to FireBase
+ MessageRepository messageRepository = MessageRepository.getInstance(getApplicationContext());
+ for (Message message : messageRepository.getAllMessages()) {
+ messageRepository.addMessageToFireBase(Message.getHashMap(message));
+ }
+// get all messages from FireBase to Room
+ messageRepository.syncMessagesFromFireStoreToRoom();
+
+ return Result.success();
+ }
+}
diff --git a/app/src/main/res/anim/fade_in.xml b/app/src/main/res/anim/fade_in.xml
new file mode 100644
index 0000000..306b605
--- /dev/null
+++ b/app/src/main/res/anim/fade_in.xml
@@ -0,0 +1,8 @@
+
+
+
+
\ No newline at end of file
diff --git a/app/src/main/res/anim/fade_out.xml b/app/src/main/res/anim/fade_out.xml
new file mode 100644
index 0000000..d7841b9
--- /dev/null
+++ b/app/src/main/res/anim/fade_out.xml
@@ -0,0 +1,8 @@
+
+
+
+
\ No newline at end of file
diff --git a/app/src/main/res/drawable-anydpi/ic_send.xml b/app/src/main/res/drawable-anydpi/ic_send.xml
new file mode 100644
index 0000000..8b51306
--- /dev/null
+++ b/app/src/main/res/drawable-anydpi/ic_send.xml
@@ -0,0 +1,11 @@
+
+
+
diff --git a/app/src/main/res/drawable-hdpi/ic_send.png b/app/src/main/res/drawable-hdpi/ic_send.png
new file mode 100644
index 0000000..fb9e7ed
Binary files /dev/null and b/app/src/main/res/drawable-hdpi/ic_send.png differ
diff --git a/app/src/main/res/drawable-mdpi/ic_send.png b/app/src/main/res/drawable-mdpi/ic_send.png
new file mode 100644
index 0000000..f3d26b0
Binary files /dev/null and b/app/src/main/res/drawable-mdpi/ic_send.png differ
diff --git a/app/src/main/res/drawable-v24/ic_launcher_foreground.xml b/app/src/main/res/drawable-v24/ic_launcher_foreground.xml
new file mode 100644
index 0000000..1f6bb29
--- /dev/null
+++ b/app/src/main/res/drawable-v24/ic_launcher_foreground.xml
@@ -0,0 +1,34 @@
+
+
+
+
+ - @array/com_google_android_gms_fonts_certs_dev
+ - @array/com_google_android_gms_fonts_certs_prod
+
+
+ -
+ MIIEqDCCA5CgAwIBAgIJANWFuGx90071MA0GCSqGSIb3DQEBBAUAMIGUMQswCQYDVQQGEwJVUzETMBEGA1UECBMKQ2FsaWZvcm5pYTEWMBQGA1UEBxMNTW91bnRhaW4gVmlldzEQMA4GA1UEChMHQW5kcm9pZDEQMA4GA1UECxMHQW5kcm9pZDEQMA4GA1UEAxMHQW5kcm9pZDEiMCAGCSqGSIb3DQEJARYTYW5kcm9pZEBhbmRyb2lkLmNvbTAeFw0wODA0MTUyMzM2NTZaFw0zNTA5MDEyMzM2NTZaMIGUMQswCQYDVQQGEwJVUzETMBEGA1UECBMKQ2FsaWZvcm5pYTEWMBQGA1UEBxMNTW91bnRhaW4gVmlldzEQMA4GA1UEChMHQW5kcm9pZDEQMA4GA1UECxMHQW5kcm9pZDEQMA4GA1UEAxMHQW5kcm9pZDEiMCAGCSqGSIb3DQEJARYTYW5kcm9pZEBhbmRyb2lkLmNvbTCCASAwDQYJKoZIhvcNAQEBBQADggENADCCAQgCggEBANbOLggKv+IxTdGNs8/TGFy0PTP6DHThvbbR24kT9ixcOd9W+EaBPWW+wPPKQmsHxajtWjmQwWfna8mZuSeJS48LIgAZlKkpFeVyxW0qMBujb8X8ETrWy550NaFtI6t9+u7hZeTfHwqNvacKhp1RbE6dBRGWynwMVX8XW8N1+UjFaq6GCJukT4qmpN2afb8sCjUigq0GuMwYXrFVee74bQgLHWGJwPmvmLHC69EH6kWr22ijx4OKXlSIx2xT1AsSHee70w5iDBiK4aph27yH3TxkXy9V89TDdexAcKk/cVHYNnDBapcavl7y0RiQ4biu8ymM8Ga/nmzhRKya6G0cGw8CAQOjgfwwgfkwHQYDVR0OBBYEFI0cxb6VTEM8YYY6FbBMvAPyT+CyMIHJBgNVHSMEgcEwgb6AFI0cxb6VTEM8YYY6FbBMvAPyT+CyoYGapIGXMIGUMQswCQYDVQQGEwJVUzETMBEGA1UECBMKQ2FsaWZvcm5pYTEWMBQGA1UEBxMNTW91bnRhaW4gVmlldzEQMA4GA1UEChMHQW5kcm9pZDEQMA4GA1UECxMHQW5kcm9pZDEQMA4GA1UEAxMHQW5kcm9pZDEiMCAGCSqGSIb3DQEJARYTYW5kcm9pZEBhbmRyb2lkLmNvbYIJANWFuGx90071MAwGA1UdEwQFMAMBAf8wDQYJKoZIhvcNAQEEBQADggEBABnTDPEF+3iSP0wNfdIjIz1AlnrPzgAIHVvXxunW7SBrDhEglQZBbKJEk5kT0mtKoOD1JMrSu1xuTKEBahWRbqHsXclaXjoBADb0kkjVEJu/Lh5hgYZnOjvlba8Ld7HCKePCVePoTJBdI4fvugnL8TsgK05aIskyY0hKI9L8KfqfGTl1lzOv2KoWD0KWwtAWPoGChZxmQ+nBli+gwYMzM1vAkP+aayLe0a1EQimlOalO762r0GXO0ks+UeXde2Z4e+8S/pf7pITEI/tP+MxJTALw9QUWEv9lKTk+jkbqxbsh8nfBUapfKqYn0eidpwq2AzVp3juYl7//fKnaPhJD9gs=
+
+
+
+ -
+ MIIEQzCCAyugAwIBAgIJAMLgh0ZkSjCNMA0GCSqGSIb3DQEBBAUAMHQxCzAJBgNVBAYTAlVTMRMwEQYDVQQIEwpDYWxpZm9ybmlhMRYwFAYDVQQHEw1Nb3VudGFpbiBWaWV3MRQwEgYDVQQKEwtHb29nbGUgSW5jLjEQMA4GA1UECxMHQW5kcm9pZDEQMA4GA1UEAxMHQW5kcm9pZDAeFw0wODA4MjEyMzEzMzRaFw0zNjAxMDcyMzEzMzRaMHQxCzAJBgNVBAYTAlVTMRMwEQYDVQQIEwpDYWxpZm9ybmlhMRYwFAYDVQQHEw1Nb3VudGFpbiBWaWV3MRQwEgYDVQQKEwtHb29nbGUgSW5jLjEQMA4GA1UECxMHQW5kcm9pZDEQMA4GA1UEAxMHQW5kcm9pZDCCASAwDQYJKoZIhvcNAQEBBQADggENADCCAQgCggEBAKtWLgDYO6IIrgqWbxJOKdoR8qtW0I9Y4sypEwPpt1TTcvZApxsdyxMJZ2JORland2qSGT2y5b+3JKkedxiLDmpHpDsz2WCbdxgxRczfey5YZnTJ4VZbH0xqWVW/8lGmPav5xVwnIiJS6HXk+BVKZF+JcWjAsb/GEuq/eFdpuzSqeYTcfi6idkyugwfYwXFU1+5fZKUaRKYCwkkFQVfcAs1fXA5V+++FGfvjJ/CxURaSxaBvGdGDhfXE28LWuT9ozCl5xw4Yq5OGazvV24mZVSoOO0yZ31j7kYvtwYK6NeADwbSxDdJEqO4k//0zOHKrUiGYXtqw/A0LFFtqoZKFjnkCAQOjgdkwgdYwHQYDVR0OBBYEFMd9jMIhF1Ylmn/Tgt9r45jk14alMIGmBgNVHSMEgZ4wgZuAFMd9jMIhF1Ylmn/Tgt9r45jk14aloXikdjB0MQswCQYDVQQGEwJVUzETMBEGA1UECBMKQ2FsaWZvcm5pYTEWMBQGA1UEBxMNTW91bnRhaW4gVmlldzEUMBIGA1UEChMLR29vZ2xlIEluYy4xEDAOBgNVBAsTB0FuZHJvaWQxEDAOBgNVBAMTB0FuZHJvaWSCCQDC4IdGZEowjTAMBgNVHRMEBTADAQH/MA0GCSqGSIb3DQEBBAUAA4IBAQBt0lLO74UwLDYKqs6Tm8/yzKkEu116FmH4rkaymUIE0P9KaMftGlMexFlaYjzmB2OxZyl6euNXEsQH8gjwyxCUKRJNexBiGcCEyj6z+a1fuHHvkiaai+KL8W1EyNmgjmyy8AW7P+LLlkR+ho5zEHatRbM/YAnqGcFh5iZBqpknHf1SKMXFh4dd239FJ1jWYfbMDMy3NS5CTMQ2XFI1MvcyUTdZPErjQfTbQe3aDQsQcafEQPD+nqActifKZ0Np0IS9L9kR/wbNvyz6ENwPiTrjV2KRkEjH78ZMcUQXg0L3BYHJ3lc69Vs5Ddf9uUGGMYldX3WfMBEmh/9iFBDAaTCK
+
+
+
diff --git a/app/src/main/res/values/preloaded_fonts.xml b/app/src/main/res/values/preloaded_fonts.xml
new file mode 100644
index 0000000..45c8c66
--- /dev/null
+++ b/app/src/main/res/values/preloaded_fonts.xml
@@ -0,0 +1,6 @@
+
+
+
+ - @font/aclonica
+
+
diff --git a/app/src/main/res/values/strings.xml b/app/src/main/res/values/strings.xml
new file mode 100644
index 0000000..3214188
--- /dev/null
+++ b/app/src/main/res/values/strings.xml
@@ -0,0 +1,42 @@
+
+ ChatBot MET CS622
+
+
+
+ Registration
+ Register
+ Email Address
+ Password
+ Confirm Password
+ Already have an account?
+ Please enter email address in correct format
+ Please enter password longer than 8 characters
+ Both passwords should match
+ Registered Successfully
+ Welcome
+ Login
+ Logout
+ Login
+ Logged In
+ Select your chat:
+ Don\'t have an account? Register now!
+ Chat Room photo
+ Type a message
+ Clear
+ No internet available
+ Chat Bot
+ Last Name
+ First Name
+ Please enter your first name
+ Please enter your last name
+
+
+
+
+ - Did I run on
+ - How many steps did I take on
+ - Did I receive heart rate notifications on
+ - Did I receive heart rate notifications on
+
+
+
diff --git a/app/src/main/res/values/styles.xml b/app/src/main/res/values/styles.xml
new file mode 100644
index 0000000..de35d2c
--- /dev/null
+++ b/app/src/main/res/values/styles.xml
@@ -0,0 +1,19 @@
+
+
+
+
+
+
+
diff --git a/app/src/test/java/com/fazemeright/chatbotmetcs622/ExampleUnitTest.java b/app/src/test/java/com/fazemeright/chatbotmetcs622/ExampleUnitTest.java
new file mode 100644
index 0000000..41a398b
--- /dev/null
+++ b/app/src/test/java/com/fazemeright/chatbotmetcs622/ExampleUnitTest.java
@@ -0,0 +1,17 @@
+package com.fazemeright.chatbotmetcs622;
+
+import org.junit.Test;
+
+import static org.junit.Assert.*;
+
+/**
+ * Example local unit test, which will execute on the development machine (host).
+ *
+ * @see Testing documentation
+ */
+public class ExampleUnitTest {
+ @Test
+ public void addition_isCorrect() {
+ assertEquals(4, 2 + 2);
+ }
+}
\ No newline at end of file
diff --git a/app/src/test/java/com/fazemeright/chatbotmetcs622/utils/AppUtilsTest.java b/app/src/test/java/com/fazemeright/chatbotmetcs622/utils/AppUtilsTest.java
new file mode 100644
index 0000000..db77439
--- /dev/null
+++ b/app/src/test/java/com/fazemeright/chatbotmetcs622/utils/AppUtilsTest.java
@@ -0,0 +1,6 @@
+package com.fazemeright.chatbotmetcs622.utils;
+
+public class AppUtilsTest {
+
+
+}
\ No newline at end of file
diff --git a/build.gradle b/build.gradle
new file mode 100644
index 0000000..026cfa5
--- /dev/null
+++ b/build.gradle
@@ -0,0 +1,31 @@
+// Top-level build file where you can add configuration options common to all sub-projects/modules.
+
+buildscript {
+ repositories {
+ google()
+ jcenter()
+ maven {
+ url 'https://maven.fabric.io/public'
+ }
+ }
+ dependencies {
+ classpath 'com.android.tools.build:gradle:3.5.3'
+ classpath 'com.google.gms:google-services:4.3.3'
+
+ classpath 'io.fabric.tools:gradle:1.31.2' // Crashlytics plugin
+
+ // NOTE: Do not place your application dependencies here; they belong
+ // in the individual module build.gradle files
+ }
+}
+
+allprojects {
+ repositories {
+ google()
+ jcenter()
+ }
+}
+
+task clean(type: Delete) {
+ delete rootProject.buildDir
+}
diff --git a/firebase-api-library/.gitignore b/firebase-api-library/.gitignore
new file mode 100644
index 0000000..796b96d
--- /dev/null
+++ b/firebase-api-library/.gitignore
@@ -0,0 +1 @@
+/build
diff --git a/firebase-api-library/build.gradle b/firebase-api-library/build.gradle
new file mode 100644
index 0000000..88105dc
--- /dev/null
+++ b/firebase-api-library/build.gradle
@@ -0,0 +1,41 @@
+apply plugin: 'com.android.library'
+
+android {
+ compileSdkVersion 29
+ buildToolsVersion "29.0.2"
+
+
+ defaultConfig {
+ minSdkVersion 22
+ targetSdkVersion 29
+ versionCode 1
+ versionName "1.0"
+
+ testInstrumentationRunner "androidx.test.runner.AndroidJUnitRunner"
+ consumerProguardFiles 'consumer-rules.pro'
+ }
+
+ buildTypes {
+ release {
+ minifyEnabled false
+ proguardFiles getDefaultProguardFile('proguard-android-optimize.txt'), 'proguard-rules.pro'
+ }
+ }
+
+}
+
+dependencies {
+ implementation fileTree(dir: 'libs', include: ['*.jar'])
+
+ implementation 'androidx.appcompat:appcompat:1.1.0'
+ testImplementation 'junit:junit:4.12'
+ androidTestImplementation 'androidx.test.ext:junit:1.1.1'
+ androidTestImplementation 'androidx.test.espresso:espresso-core:3.2.0'
+
+ implementation 'com.google.firebase:firebase-core:17.2.1' // FireBase core
+ implementation 'com.google.firebase:firebase-firestore:21.3.0' // FireBase FireStore
+ implementation 'com.google.firebase:firebase-auth:19.2.0' // FireBase authentication
+ implementation 'com.google.firebase:firebase-analytics:17.2.1' // FireBase analy tics
+ implementation 'com.crashlytics.sdk.android:crashlytics:2.10.1' // FireBase crashlytics
+ implementation 'com.google.firebase:firebase-firestore:21.3.0' // FireBase FireStore
+}
diff --git a/firebase-api-library/consumer-rules.pro b/firebase-api-library/consumer-rules.pro
new file mode 100644
index 0000000..e69de29
diff --git a/firebase-api-library/proguard-rules.pro b/firebase-api-library/proguard-rules.pro
new file mode 100644
index 0000000..f1b4245
--- /dev/null
+++ b/firebase-api-library/proguard-rules.pro
@@ -0,0 +1,21 @@
+# Add project specific ProGuard rules here.
+# You can control the set of applied configuration files using the
+# proguardFiles setting in build.gradle.
+#
+# For more details, see
+# http://developer.android.com/guide/developing/tools/proguard.html
+
+# If your project uses WebView with JS, uncomment the following
+# and specify the fully qualified class name to the JavaScript interface
+# class:
+#-keepclassmembers class fqcn.of.javascript.interface.for.webview {
+# public *;
+#}
+
+# Uncomment this to preserve the line number information for
+# debugging stack traces.
+#-keepattributes SourceFile,LineNumberTable
+
+# If you keep the line number information, uncomment this to
+# hide the original source file name.
+#-renamesourcefileattribute SourceFile
diff --git a/firebase-api-library/src/androidTest/java/com/fazemeright/firebase_api_library/ExampleInstrumentedTest.java b/firebase-api-library/src/androidTest/java/com/fazemeright/firebase_api_library/ExampleInstrumentedTest.java
new file mode 100644
index 0000000..f3f4aaf
--- /dev/null
+++ b/firebase-api-library/src/androidTest/java/com/fazemeright/firebase_api_library/ExampleInstrumentedTest.java
@@ -0,0 +1,27 @@
+package com.fazemeright.firebase_api_library;
+
+import android.content.Context;
+
+import androidx.test.platform.app.InstrumentationRegistry;
+import androidx.test.ext.junit.runners.AndroidJUnit4;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+
+import static org.junit.Assert.*;
+
+/**
+ * Instrumented test, which will execute on an Android device.
+ *
+ * @see Testing documentation
+ */
+@RunWith(AndroidJUnit4.class)
+public class ExampleInstrumentedTest {
+ @Test
+ public void useAppContext() {
+ // Context of the app under test.
+ Context appContext = InstrumentationRegistry.getInstrumentation().getTargetContext();
+
+ assertEquals("com.fazemeright.firebase_api_library.test", appContext.getPackageName());
+ }
+}
diff --git a/firebase-api-library/src/main/AndroidManifest.xml b/firebase-api-library/src/main/AndroidManifest.xml
new file mode 100644
index 0000000..25bf607
--- /dev/null
+++ b/firebase-api-library/src/main/AndroidManifest.xml
@@ -0,0 +1,2 @@
+
diff --git a/firebase-api-library/src/main/java/com/fazemeright/firebase_api_library/api/FireBaseApiManager.java b/firebase-api-library/src/main/java/com/fazemeright/firebase_api_library/api/FireBaseApiManager.java
new file mode 100644
index 0000000..680a1d7
--- /dev/null
+++ b/firebase-api-library/src/main/java/com/fazemeright/firebase_api_library/api/FireBaseApiManager.java
@@ -0,0 +1,227 @@
+package com.fazemeright.firebase_api_library.api;
+
+import android.util.Log;
+
+import androidx.annotation.NonNull;
+
+import com.fazemeright.firebase_api_library.listeners.DBValueListener;
+import com.fazemeright.firebase_api_library.listeners.OnTaskCompleteListener;
+import com.google.android.gms.tasks.OnCompleteListener;
+import com.google.android.gms.tasks.OnFailureListener;
+import com.google.android.gms.tasks.OnSuccessListener;
+import com.google.android.gms.tasks.Task;
+import com.google.firebase.FirebaseNetworkException;
+import com.google.firebase.auth.AuthResult;
+import com.google.firebase.auth.FirebaseAuth;
+import com.google.firebase.auth.FirebaseAuthInvalidCredentialsException;
+import com.google.firebase.auth.FirebaseAuthUserCollisionException;
+import com.google.firebase.auth.FirebaseUser;
+import com.google.firebase.auth.UserProfileChangeRequest;
+import com.google.firebase.firestore.DocumentReference;
+import com.google.firebase.firestore.DocumentSnapshot;
+import com.google.firebase.firestore.FirebaseFirestore;
+import com.google.firebase.firestore.QueryDocumentSnapshot;
+import com.google.firebase.firestore.QuerySnapshot;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+
+public class FireBaseApiManager extends FireBaseApiWrapper {
+
+ private static final String TAG = "FireBaseApiManager";
+ private static FireBaseApiManager apiManager;
+
+ public static FireBaseApiManager getInstance() {
+ if (apiManager == null) {
+ apiManager = new FireBaseApiManager();
+ }
+ return apiManager;
+ }
+
+ public void logOutUser() {
+// todo: log analytics event
+ signOutUser();
+ }
+
+ /**
+ * To determine whether user has verifies their email address or not
+ *
+ * @return boolean value for user email verification
+ */
+ public boolean isUserEmailVerified() {
+ return isUserVerified();
+ }
+
+ public void registerNewUserWithEmailPassword(final String userEmail, String password, final String firstName, final String lastName, final OnTaskCompleteListener onTaskCompleteListener) {
+ createNewUserWithEmailPassword(userEmail, password, new OnCompleteListener() {
+ @Override
+ public void onComplete(@NonNull Task task) {
+ if (task.isSuccessful()) {
+ Map userProfile = new HashMap<>();
+ userProfile.put("emailAddress", userEmail);
+ userProfile.put("firstName", firstName);
+ userProfile.put("lastName", lastName);
+ DocumentReference dr = FirebaseFirestore.getInstance().collection(BaseUrl.USERS)
+ .document(getCurrentUserUid());
+
+ writeToFireStoreDocument(dr, userProfile, new OnTaskCompleteListener() {
+ @Override
+ public void onTaskSuccessful() {
+ onTaskCompleteListener.onTaskSuccessful();
+ }
+
+ @Override
+ public void onTaskCompleteButFailed(String errMsg) {
+ onTaskCompleteListener.onTaskCompleteButFailed(errMsg);
+ }
+
+ @Override
+ public void onTaskFailed(Exception e) {
+ onTaskCompleteListener.onTaskFailed(e);
+ }
+ });
+
+ FirebaseUser user = FirebaseAuth.getInstance().getCurrentUser();
+
+ UserProfileChangeRequest profileUpdates = new UserProfileChangeRequest.Builder()
+ .setDisplayName(firstName).build();
+
+ if (user != null) {
+ user.updateProfile(profileUpdates)
+ .addOnCompleteListener(new OnCompleteListener() {
+ @Override
+ public void onComplete(@NonNull Task task) {
+ if (task.isSuccessful()) {
+ Log.d(TAG, "User profile updated.");
+ }
+ }
+ });
+ }
+ } else {
+ onTaskFailed(task.getException(), onTaskCompleteListener);
+ }
+ }
+ });
+ }
+
+ private String getCurrentUserUid() {
+ return Objects.requireNonNull(FirebaseAuth.getInstance().getCurrentUser()).getUid();
+ }
+
+ public void logInWithEmailAndPassword(@NonNull String userEmail, @NonNull String password, final OnTaskCompleteListener onCompleteListener) {
+ signInWithEmailAndPassword(userEmail, password, new OnCompleteListener() {
+ @Override
+ public void onComplete(@NonNull Task task) {
+ if (task.isSuccessful()) {
+ onCompleteListener.onTaskSuccessful();
+ } else {
+ onTaskFailed(task.getException(), onCompleteListener);
+ }
+ }
+ });
+ }
+
+ public String getCurrentLoggedInUserEmail() {
+ return getCurrentUserEmail();
+ }
+
+ public void sendPasswordResetEmail(String userEmail, final OnTaskCompleteListener onTaskCompleteListener) {
+ sendPasswordResetEmail(userEmail, new OnCompleteListener() {
+ @Override
+ public void onComplete(@NonNull Task task) {
+ if (task.isSuccessful()) {
+ onTaskCompleteListener.onTaskSuccessful();
+ } else {
+ onTaskFailed(task.getException(), onTaskCompleteListener);
+ }
+ }
+ }, new OnFailureListener() {
+ @Override
+ public void onFailure(@NonNull Exception e) {
+ onTaskCompleteListener.onTaskFailed(e);
+ }
+ });
+ }
+
+ private void onTaskFailed(Exception exception, OnTaskCompleteListener onTaskCompleteListener) {
+ if (exception instanceof FirebaseNetworkException) {
+ onTaskCompleteListener.onTaskCompleteButFailed("No Internet");
+ } else if (exception instanceof FirebaseAuthUserCollisionException) {
+ onTaskCompleteListener.onTaskCompleteButFailed("Email ID is already in use");
+ } else if (exception instanceof FirebaseAuthInvalidCredentialsException) {
+ onTaskCompleteListener.onTaskCompleteButFailed("Invalid Credentials");
+ } else {
+ onTaskCompleteListener.onTaskCompleteButFailed("Error Occurred");
+ }
+ }
+
+ public void reloadUserAuthState(final OnTaskCompleteListener onTaskCompleteListener) {
+ reloadCurrentUserAuthState(new OnSuccessListener() {
+ @Override
+ public void onSuccess(Void aVoid) {
+ onTaskCompleteListener.onTaskSuccessful();
+ }
+ }, new OnFailureListener() {
+ @Override
+ public void onFailure(@NonNull Exception e) {
+ onTaskCompleteListener.onTaskFailed(e);
+ }
+ });
+
+ }
+
+ public boolean isUserLoggedIn() {
+ return getCurrentUserEmail() != null;
+ }
+
+ public void addMessageToUserDatabase(Map messageHashMap) {
+ db.collection(BaseUrl.USERS)
+ .document(getCurrentUserUid())
+ .collection(BaseUrl.MESSAGES)
+ .document(String.valueOf(messageHashMap.get("mid"))).set(messageHashMap)
+ .addOnSuccessListener(new OnSuccessListener() {
+ @Override
+ public void onSuccess(Void aVoid) {
+ Log.i(TAG, "onSuccess: Message written to database");
+ }
+ });
+ }
+
+ public void syncMessages(final DBValueListener>> listDBValueListener) {
+ db.collection(BaseUrl.USERS)
+ .document(getCurrentUserUid())
+ .collection(BaseUrl.MESSAGES)
+ .get()
+ .addOnCompleteListener(new OnCompleteListener() {
+ @Override
+ public void onComplete(@NonNull Task task) {
+ if (task.isSuccessful()) {
+ List> hashMaps = new ArrayList<>();
+ for (QueryDocumentSnapshot document : Objects.requireNonNull(task.getResult())) {
+ Log.d(TAG, document.getId() + " => " + document.getData());
+ hashMaps.add(document.getData());
+
+ }
+ listDBValueListener.onDataReceived(hashMaps);
+ } else {
+ Log.e(TAG, "onComplete: \"Error getting documents" + task.getException());
+ }
+ }
+ });
+ }
+
+ public String getCurrentUserFirstName() {
+ return getCurrentUser().getDisplayName();
+ }
+
+
+ public static class BaseUrl {
+ static final String USERS = "users";
+ static final String MESSAGES = "messages";
+ // Declare the constants over here
+ }
+
+}
diff --git a/firebase-api-library/src/main/java/com/fazemeright/firebase_api_library/api/FireBaseApiWrapper.java b/firebase-api-library/src/main/java/com/fazemeright/firebase_api_library/api/FireBaseApiWrapper.java
new file mode 100644
index 0000000..f3b4312
--- /dev/null
+++ b/firebase-api-library/src/main/java/com/fazemeright/firebase_api_library/api/FireBaseApiWrapper.java
@@ -0,0 +1,110 @@
+package com.fazemeright.firebase_api_library.api;
+
+import androidx.annotation.NonNull;
+
+import com.fazemeright.firebase_api_library.listeners.OnTaskCompleteListener;
+import com.google.android.gms.tasks.OnCompleteListener;
+import com.google.android.gms.tasks.OnFailureListener;
+import com.google.android.gms.tasks.OnSuccessListener;
+import com.google.firebase.auth.ActionCodeSettings;
+import com.google.firebase.auth.AuthResult;
+import com.google.firebase.auth.FirebaseAuth;
+import com.google.firebase.auth.FirebaseUser;
+import com.google.firebase.firestore.DocumentReference;
+import com.google.firebase.firestore.FirebaseFirestore;
+
+import java.util.Map;
+
+
+/**
+ * Keep this as a Singleton Class
+ */
+abstract class FireBaseApiWrapper implements FireBaseApiWrapperInterface {
+
+// private static DatabaseReference mDatabase = FirebaseDatabase.getInstance().getReference();
+
+ FirebaseFirestore db = FirebaseFirestore.getInstance();
+
+ /**
+ * Signs out user
+ */
+ @Override
+ public void signOutUser() {
+ FirebaseAuth.getInstance().signOut();
+ }
+
+ @Override
+ public void createNewUserWithEmailPassword(String userEmail, String password, OnCompleteListener onCompleteListener) {
+ FirebaseAuth.getInstance().createUserWithEmailAndPassword(userEmail, password).addOnCompleteListener(onCompleteListener);
+ }
+
+ @Override
+ public void signInWithEmailAndPassword(@NonNull String userEmail, @NonNull String password, OnCompleteListener onCompleteListener) {
+ FirebaseAuth.getInstance().signInWithEmailAndPassword(userEmail, password).addOnCompleteListener(onCompleteListener);
+ }
+
+ @Override
+ public String getCurrentUserEmail() {
+ return getCurrentUser() != null
+ ? getCurrentUser().getEmail() : null;
+ }
+
+ @Override
+ public void sendEmailVerification(ActionCodeSettings actionCodeSettings,
+ OnCompleteListener onCompleteListener, OnFailureListener onFailureListener) {
+ if (getCurrentUser() != null) {
+ getCurrentUser().sendEmailVerification(actionCodeSettings)
+ .addOnCompleteListener(onCompleteListener)
+ .addOnFailureListener(onFailureListener);
+ } else {
+ onFailureListener.onFailure(new Exception("User not logged in"));
+ }
+ }
+
+ @Override
+ public void sendPasswordResetEmail(String userEmail, OnCompleteListener onCompleteListener, OnFailureListener onFailureListener) {
+ FirebaseAuth.getInstance().sendPasswordResetEmail(userEmail)
+ .addOnCompleteListener(onCompleteListener)
+ .addOnFailureListener(onFailureListener);
+ }
+
+ @Override
+ public boolean isUserVerified() {
+ return getCurrentUser() != null &&
+ getCurrentUser().isEmailVerified();
+ }
+
+ @Override
+ public void reloadCurrentUserAuthState(final OnSuccessListener onSuccessListener, final OnFailureListener onFailureListener) {
+ if (getCurrentUser() != null) {
+ getCurrentUser().reload()
+ .addOnSuccessListener(onSuccessListener)
+ .addOnFailureListener(onFailureListener);
+ } else {
+ onFailureListener.onFailure(new Exception("Some Error Occurred, Try again later"));
+ }
+ }
+
+ void writeToFireStoreDocument(DocumentReference dr, Map map, final OnTaskCompleteListener onTaskCompleteListener) {
+ dr.set(map).addOnSuccessListener(new OnSuccessListener() {
+ @Override
+ public void onSuccess(Void aVoid) {
+ onTaskCompleteListener.onTaskSuccessful();
+ }
+ }).addOnFailureListener(new OnFailureListener() {
+ @Override
+ public void onFailure(@NonNull Exception e) {
+ onTaskCompleteListener.onTaskFailed(e);
+ }
+ });
+ }
+
+ /**
+ * Call to get current logged in user
+ *
+ * @return current logged in user
+ */
+ protected FirebaseUser getCurrentUser() {
+ return FirebaseAuth.getInstance().getCurrentUser();
+ }
+}
diff --git a/firebase-api-library/src/main/java/com/fazemeright/firebase_api_library/api/FireBaseApiWrapperInterface.java b/firebase-api-library/src/main/java/com/fazemeright/firebase_api_library/api/FireBaseApiWrapperInterface.java
new file mode 100644
index 0000000..d2e217d
--- /dev/null
+++ b/firebase-api-library/src/main/java/com/fazemeright/firebase_api_library/api/FireBaseApiWrapperInterface.java
@@ -0,0 +1,27 @@
+package com.fazemeright.firebase_api_library.api;
+
+import com.google.android.gms.tasks.OnCompleteListener;
+import com.google.android.gms.tasks.OnFailureListener;
+import com.google.android.gms.tasks.OnSuccessListener;
+import com.google.firebase.auth.ActionCodeSettings;
+import com.google.firebase.auth.AuthResult;
+
+public interface FireBaseApiWrapperInterface {
+
+ // FireBase Auth functions
+ void signOutUser();
+
+ boolean isUserVerified();
+
+ void createNewUserWithEmailPassword(String userEmail, String password, OnCompleteListener onCompleteListener);
+
+ void signInWithEmailAndPassword(String userEmail, String password, OnCompleteListener onCompleteListener);
+
+ void sendEmailVerification(ActionCodeSettings actionCodeSettings, OnCompleteListener onCompleteListener, OnFailureListener onFailureListener);
+
+ String getCurrentUserEmail();
+
+ void sendPasswordResetEmail(String userEmail, OnCompleteListener onCompleteListener, OnFailureListener onFailureListener);
+
+ void reloadCurrentUserAuthState(OnSuccessListener onSuccessListener, OnFailureListener onFailureListener);
+}
diff --git a/firebase-api-library/src/main/java/com/fazemeright/firebase_api_library/listeners/DBValueListener.java b/firebase-api-library/src/main/java/com/fazemeright/firebase_api_library/listeners/DBValueListener.java
new file mode 100644
index 0000000..41b7a95
--- /dev/null
+++ b/firebase-api-library/src/main/java/com/fazemeright/firebase_api_library/listeners/DBValueListener.java
@@ -0,0 +1,8 @@
+package com.fazemeright.firebase_api_library.listeners;
+
+public interface DBValueListener {
+
+ void onDataReceived(T data);
+
+ void onCancelled(Error error);
+}
diff --git a/firebase-api-library/src/main/java/com/fazemeright/firebase_api_library/listeners/OnTaskCompleteListener.java b/firebase-api-library/src/main/java/com/fazemeright/firebase_api_library/listeners/OnTaskCompleteListener.java
new file mode 100644
index 0000000..7692dfe
--- /dev/null
+++ b/firebase-api-library/src/main/java/com/fazemeright/firebase_api_library/listeners/OnTaskCompleteListener.java
@@ -0,0 +1,10 @@
+package com.fazemeright.firebase_api_library.listeners;
+
+public interface OnTaskCompleteListener {
+
+ void onTaskSuccessful();
+
+ void onTaskCompleteButFailed(String errMsg);
+
+ void onTaskFailed(Exception e);
+}
diff --git a/firebase-api-library/src/main/res/values/strings.xml b/firebase-api-library/src/main/res/values/strings.xml
new file mode 100644
index 0000000..b200f44
--- /dev/null
+++ b/firebase-api-library/src/main/res/values/strings.xml
@@ -0,0 +1,3 @@
+
+ Firebase-Api-Library
+
diff --git a/firebase-api-library/src/test/java/com/fazemeright/firebase_api_library/ExampleUnitTest.java b/firebase-api-library/src/test/java/com/fazemeright/firebase_api_library/ExampleUnitTest.java
new file mode 100644
index 0000000..688d049
--- /dev/null
+++ b/firebase-api-library/src/test/java/com/fazemeright/firebase_api_library/ExampleUnitTest.java
@@ -0,0 +1,17 @@
+package com.fazemeright.firebase_api_library;
+
+import org.junit.Test;
+
+import static org.junit.Assert.*;
+
+/**
+ * Example local unit test, which will execute on the development machine (host).
+ *
+ * @see Testing documentation
+ */
+public class ExampleUnitTest {
+ @Test
+ public void addition_isCorrect() {
+ assertEquals(4, 2 + 2);
+ }
+}
\ No newline at end of file
diff --git a/gradle.properties b/gradle.properties
new file mode 100644
index 0000000..199d16e
--- /dev/null
+++ b/gradle.properties
@@ -0,0 +1,20 @@
+# Project-wide Gradle settings.
+# IDE (e.g. Android Studio) users:
+# Gradle settings configured through the IDE *will override*
+# any settings specified in this file.
+# For more details on how to configure your build environment visit
+# http://www.gradle.org/docs/current/userguide/build_environment.html
+# Specifies the JVM arguments used for the daemon process.
+# The setting is particularly useful for tweaking memory settings.
+org.gradle.jvmargs=-Xmx1536m
+# When configured, Gradle will run in incubating parallel mode.
+# This option should only be used with decoupled projects. More details, visit
+# http://www.gradle.org/docs/current/userguide/multi_project_builds.html#sec:decoupled_projects
+# org.gradle.parallel=true
+# AndroidX package structure to make it clearer which packages are bundled with the
+# Android operating system, and which are packaged with your app's APK
+# https://developer.android.com/topic/libraries/support-library/androidx-rn
+android.useAndroidX=true
+# Automatically convert third-party libraries to use AndroidX
+android.enableJetifier=true
+
diff --git a/gradle/wrapper/gradle-wrapper.jar b/gradle/wrapper/gradle-wrapper.jar
new file mode 100644
index 0000000..f6b961f
Binary files /dev/null and b/gradle/wrapper/gradle-wrapper.jar differ
diff --git a/gradle/wrapper/gradle-wrapper.properties b/gradle/wrapper/gradle-wrapper.properties
new file mode 100644
index 0000000..f94a5cd
--- /dev/null
+++ b/gradle/wrapper/gradle-wrapper.properties
@@ -0,0 +1,6 @@
+#Tue Mar 10 17:34:51 EDT 2020
+distributionBase=GRADLE_USER_HOME
+distributionPath=wrapper/dists
+zipStoreBase=GRADLE_USER_HOME
+zipStorePath=wrapper/dists
+distributionUrl=https\://services.gradle.org/distributions/gradle-5.6.4-all.zip
diff --git a/gradlew b/gradlew
new file mode 100644
index 0000000..cccdd3d
--- /dev/null
+++ b/gradlew
@@ -0,0 +1,172 @@
+#!/usr/bin/env sh
+
+##############################################################################
+##
+## Gradle start up script for UN*X
+##
+##############################################################################
+
+# Attempt to set APP_HOME
+# Resolve links: $0 may be a link
+PRG="$0"
+# Need this for relative symlinks.
+while [ -h "$PRG" ] ; do
+ ls=`ls -ld "$PRG"`
+ link=`expr "$ls" : '.*-> \(.*\)$'`
+ if expr "$link" : '/.*' > /dev/null; then
+ PRG="$link"
+ else
+ PRG=`dirname "$PRG"`"/$link"
+ fi
+done
+SAVED="`pwd`"
+cd "`dirname \"$PRG\"`/" >/dev/null
+APP_HOME="`pwd -P`"
+cd "$SAVED" >/dev/null
+
+APP_NAME="Gradle"
+APP_BASE_NAME=`basename "$0"`
+
+# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+DEFAULT_JVM_OPTS=""
+
+# Use the maximum available, or set MAX_FD != -1 to use that value.
+MAX_FD="maximum"
+
+warn () {
+ echo "$*"
+}
+
+die () {
+ echo
+ echo "$*"
+ echo
+ exit 1
+}
+
+# OS specific support (must be 'true' or 'false').
+cygwin=false
+msys=false
+darwin=false
+nonstop=false
+case "`uname`" in
+ CYGWIN* )
+ cygwin=true
+ ;;
+ Darwin* )
+ darwin=true
+ ;;
+ MINGW* )
+ msys=true
+ ;;
+ NONSTOP* )
+ nonstop=true
+ ;;
+esac
+
+CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
+
+# Determine the Java command to use to start the JVM.
+if [ -n "$JAVA_HOME" ] ; then
+ if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
+ # IBM's JDK on AIX uses strange locations for the executables
+ JAVACMD="$JAVA_HOME/jre/sh/java"
+ else
+ JAVACMD="$JAVA_HOME/bin/java"
+ fi
+ if [ ! -x "$JAVACMD" ] ; then
+ die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+ fi
+else
+ JAVACMD="java"
+ which java >/dev/null 2>&1 || die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+fi
+
+# Increase the maximum file descriptors if we can.
+if [ "$cygwin" = "false" -a "$darwin" = "false" -a "$nonstop" = "false" ] ; then
+ MAX_FD_LIMIT=`ulimit -H -n`
+ if [ $? -eq 0 ] ; then
+ if [ "$MAX_FD" = "maximum" -o "$MAX_FD" = "max" ] ; then
+ MAX_FD="$MAX_FD_LIMIT"
+ fi
+ ulimit -n $MAX_FD
+ if [ $? -ne 0 ] ; then
+ warn "Could not set maximum file descriptor limit: $MAX_FD"
+ fi
+ else
+ warn "Could not query maximum file descriptor limit: $MAX_FD_LIMIT"
+ fi
+fi
+
+# For Darwin, add options to specify how the application appears in the dock
+if $darwin; then
+ GRADLE_OPTS="$GRADLE_OPTS \"-Xdock:name=$APP_NAME\" \"-Xdock:icon=$APP_HOME/media/gradle.icns\""
+fi
+
+# For Cygwin, switch paths to Windows format before running java
+if $cygwin ; then
+ APP_HOME=`cygpath --path --mixed "$APP_HOME"`
+ CLASSPATH=`cygpath --path --mixed "$CLASSPATH"`
+ JAVACMD=`cygpath --unix "$JAVACMD"`
+
+ # We build the pattern for arguments to be converted via cygpath
+ ROOTDIRSRAW=`find -L / -maxdepth 1 -mindepth 1 -type d 2>/dev/null`
+ SEP=""
+ for dir in $ROOTDIRSRAW ; do
+ ROOTDIRS="$ROOTDIRS$SEP$dir"
+ SEP="|"
+ done
+ OURCYGPATTERN="(^($ROOTDIRS))"
+ # Add a user-defined pattern to the cygpath arguments
+ if [ "$GRADLE_CYGPATTERN" != "" ] ; then
+ OURCYGPATTERN="$OURCYGPATTERN|($GRADLE_CYGPATTERN)"
+ fi
+ # Now convert the arguments - kludge to limit ourselves to /bin/sh
+ i=0
+ for arg in "$@" ; do
+ CHECK=`echo "$arg"|egrep -c "$OURCYGPATTERN" -`
+ CHECK2=`echo "$arg"|egrep -c "^-"` ### Determine if an option
+
+ if [ $CHECK -ne 0 ] && [ $CHECK2 -eq 0 ] ; then ### Added a condition
+ eval `echo args$i`=`cygpath --path --ignore --mixed "$arg"`
+ else
+ eval `echo args$i`="\"$arg\""
+ fi
+ i=$((i+1))
+ done
+ case $i in
+ (0) set -- ;;
+ (1) set -- "$args0" ;;
+ (2) set -- "$args0" "$args1" ;;
+ (3) set -- "$args0" "$args1" "$args2" ;;
+ (4) set -- "$args0" "$args1" "$args2" "$args3" ;;
+ (5) set -- "$args0" "$args1" "$args2" "$args3" "$args4" ;;
+ (6) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" ;;
+ (7) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" ;;
+ (8) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" ;;
+ (9) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" "$args8" ;;
+ esac
+fi
+
+# Escape application args
+save () {
+ for i do printf %s\\n "$i" | sed "s/'/'\\\\''/g;1s/^/'/;\$s/\$/' \\\\/" ; done
+ echo " "
+}
+APP_ARGS=$(save "$@")
+
+# Collect all arguments for the java command, following the shell quoting and substitution rules
+eval set -- $DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS "\"-Dorg.gradle.appname=$APP_BASE_NAME\"" -classpath "\"$CLASSPATH\"" org.gradle.wrapper.GradleWrapperMain "$APP_ARGS"
+
+# by default we should be in the correct project dir, but when run from Finder on Mac, the cwd is wrong
+if [ "$(uname)" = "Darwin" ] && [ "$HOME" = "$PWD" ]; then
+ cd "$(dirname "$0")"
+fi
+
+exec "$JAVACMD" "$@"
diff --git a/gradlew.bat b/gradlew.bat
new file mode 100644
index 0000000..f955316
--- /dev/null
+++ b/gradlew.bat
@@ -0,0 +1,84 @@
+@if "%DEBUG%" == "" @echo off
+@rem ##########################################################################
+@rem
+@rem Gradle startup script for Windows
+@rem
+@rem ##########################################################################
+
+@rem Set local scope for the variables with windows NT shell
+if "%OS%"=="Windows_NT" setlocal
+
+set DIRNAME=%~dp0
+if "%DIRNAME%" == "" set DIRNAME=.
+set APP_BASE_NAME=%~n0
+set APP_HOME=%DIRNAME%
+
+@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+set DEFAULT_JVM_OPTS=
+
+@rem Find java.exe
+if defined JAVA_HOME goto findJavaFromJavaHome
+
+set JAVA_EXE=java.exe
+%JAVA_EXE% -version >NUL 2>&1
+if "%ERRORLEVEL%" == "0" goto init
+
+echo.
+echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+echo.
+echo Please set the JAVA_HOME variable in your environment to match the
+echo location of your Java installation.
+
+goto fail
+
+:findJavaFromJavaHome
+set JAVA_HOME=%JAVA_HOME:"=%
+set JAVA_EXE=%JAVA_HOME%/bin/java.exe
+
+if exist "%JAVA_EXE%" goto init
+
+echo.
+echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME%
+echo.
+echo Please set the JAVA_HOME variable in your environment to match the
+echo location of your Java installation.
+
+goto fail
+
+:init
+@rem Get command-line arguments, handling Windows variants
+
+if not "%OS%" == "Windows_NT" goto win9xME_args
+
+:win9xME_args
+@rem Slurp the command line arguments.
+set CMD_LINE_ARGS=
+set _SKIP=2
+
+:win9xME_args_slurp
+if "x%~1" == "x" goto execute
+
+set CMD_LINE_ARGS=%*
+
+:execute
+@rem Setup the command line
+
+set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar
+
+@rem Execute Gradle
+"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %CMD_LINE_ARGS%
+
+:end
+@rem End local scope for the variables with windows NT shell
+if "%ERRORLEVEL%"=="0" goto mainEnd
+
+:fail
+rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of
+rem the _cmd.exe /c_ return code!
+if not "" == "%GRADLE_EXIT_CONSOLE%" exit 1
+exit /b 1
+
+:mainEnd
+if "%OS%"=="Windows_NT" endlocal
+
+:omega
diff --git a/settings.gradle b/settings.gradle
new file mode 100644
index 0000000..06c5531
--- /dev/null
+++ b/settings.gradle
@@ -0,0 +1,2 @@
+include ':app', ':firebase-api-library'
+rootProject.name='ChatBot MET CS622'