Skip to content

Instantly share code, notes, and snippets.

@DeepakRattan

DeepakRattan/GroupChatActivity.java Secret

Last active March 10, 2016 05:15
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save DeepakRattan/92a26edc0346743ed402 to your computer and use it in GitHub Desktop.
Save DeepakRattan/92a26edc0346743ed402 to your computer and use it in GitHub Desktop.
Download ZIP
Problem in using PUSH notification using socket.io-client
Raw
GroupChatActivity.java
public class GroupChatActivity extends AppCompatActivity implements EmojiconGridFragment.OnEmojiconClickedListener, EmojiconsFragment.OnEmojiconBackspaceClickedListener {
private Socket mSocket;
private Toolbar toolbarGroupChat;
private SharedPreferences sharedPreferences;
private String roomID, message;
private EmojiconEditText edMessage;
private boolean showEmoji = false;
private boolean hideEmoji;
int deviceHeight;
FrameLayout frameLayout;
private Bean_Group_Message bean_group_message;
private List<Bean_Group_Message> listBeanGroupMessage;
private String md5LoggedInID;
private boolean isSelf;
private Adapter_Group_Message adapter_group_message;
private String url_old_messages_group;
private ApiConfiguration apiConfiguration;
private HttpRequestProcessor httpRequestProcessor;
private ProgressDialog progressDialog;
private NetworkConnectionDetector networkConnectionDetector;
private ListView lv_groupMessage;
private PopupWindow popupWindow;
// instance initialization block
{
try {
mSocket = IO.socket(Constants.CHAT_SERVER_URL);
Log.e("Socket", String.valueOf(mSocket));
} catch (URISyntaxException e) {
throw new RuntimeException(e);
}
}
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_group_chat);
//FIndViewByID
toolbarGroupChat = (Toolbar) findViewById(R.id.toolbarGroupChat);
edMessage = (EmojiconEditText) findViewById(R.id.edtMessageGroup);
lv_groupMessage = (ListView) findViewById(R.id.lv_group_message);
//initialization
sharedPreferences = getApplicationContext().getSharedPreferences(Prefs_Registration.prefsName, Context.MODE_PRIVATE);
listBeanGroupMessage = new ArrayList<Bean_Group_Message>();
adapter_group_message = new Adapter_Group_Message(GroupChatActivity.this, listBeanGroupMessage);
apiConfiguration = new ApiConfiguration();
httpRequestProcessor = new HttpRequestProcessor();
progressDialog = new ProgressDialog(GroupChatActivity.this);
networkConnectionDetector = new NetworkConnectionDetector(GroupChatActivity.this);
lv_groupMessage.setAdapter(adapter_group_message);
//inflate the popupwindow_attachment.xml
LinearLayout viewGroup = (LinearLayout) GroupChatActivity.this.findViewById(R.id.popup_element);
LayoutInflater inflater = (LayoutInflater) GroupChatActivity.this.getSystemService(Context.LAYOUT_INFLATER_SERVICE);
View layout = inflater.inflate(R.layout.popupwindow_attachment, viewGroup);
popupWindow = new PopupWindow(layout, WindowManager.LayoutParams.MATCH_PARENT, WindowManager.LayoutParams.WRAP_CONTENT);
//Close the popup when touch outside
popupWindow.setOutsideTouchable(true);
popupWindow.setFocusable(true);
popupWindow.setBackgroundDrawable(new ColorDrawable(Color.TRANSPARENT));
Bundle bundle = getIntent().getExtras();
String group_members = bundle.getString("group_members", null);
String group_name = bundle.getString("group_name", null);
String owner_id = bundle.getString("owner_id", null);
String group_imge = bundle.getString("group_imege", null);
String chat_group_id = bundle.getString("chat_group_id", null);
Log.e("ChatGroupID", chat_group_id);
//Adding title to the toolbar
toolbarGroupChat.setTitle(group_name);
setSupportActionBar(toolbarGroupChat);
getSupportActionBar().setDisplayHomeAsUpEnabled(true);
String[] membersID = group_members.split(",");
StringBuffer appendMembers = new StringBuffer();
for (String s : membersID) {
appendMembers.append(s);
}
Log.e("MembersID", String.valueOf(appendMembers));
//Combining id of owner and membersID and group name
String combinedID = owner_id + appendMembers + group_name;
Log.e("Combined ID", combinedID);
roomID = convertPassMd5(combinedID);
Log.e("RoomID", roomID);
//Load old messages in the chat room
String api_message = apiConfiguration.getApi_message();
url_old_messages_group = api_message + roomID;
Log.e("URl old messages group", url_old_messages_group);
//Load old messages of the group chat
//Checking Internet Connection
if (networkConnectionDetector.isConnectedToInternet()) {
new GetOldMessages().execute();
} else {
showAlertDialog(GroupChatActivity.this, "Internet Connection", "Please Check your Internet Connection .You don't have internet Connection");
}
//Listening on Events
mSocket.on(Socket.EVENT_CONNECT, onConnect);
mSocket.on(Socket.EVENT_CONNECT_ERROR, onConnectionError);
mSocket.on(Socket.EVENT_DISCONNECT, onDisconnect);
mSocket.on("send:notice", onReceive); // Listening event for receiving messages
mSocket.connect(); // Explicitly call connect method to establish connection here
mSocket.emit("subscribe", roomID);
// Getting the ID of logged in user and convert it into md5
String loggedInUserID = sharedPreferences.getString(Prefs_Registration.get_user_id, null);
md5LoggedInID = convertPassMd5(loggedInUserID);
//Handling click event on drawableLeft and drawableRight inside EmojiconEditText
edMessage.setOnTouchListener(new View.OnTouchListener() {
@Override
public boolean onTouch(View view, MotionEvent event) {
final int DRAWABLE_LEFT = 0;
final int DRAWABLE_TOP = 1;
final int DRAWABLE_RIGHT = 2;
final int DRAWABLE_BOTTOM = 3;
if (event.getAction() == MotionEvent.ACTION_UP) {
//Handling drawableRight
int leftEdgeOfRightDrawable = edMessage.getRight() - edMessage.getCompoundDrawables()[DRAWABLE_RIGHT].getBounds().width();
//EditText has padding here.So adjust left edge
leftEdgeOfRightDrawable -= getResources().getDimension(R.dimen.padding10); //Here we have set the padding of 10 from left and right in edittext
if (event.getRawX() >= leftEdgeOfRightDrawable) {
// your action here
Toast.makeText(getApplicationContext(), "Clicked", Toast.LENGTH_SHORT).show();
message = edMessage.getText().toString().trim();
// Spannable s = getSmiledText(getApplicationContext(),message);
// Log.e("Spannable", String.valueOf(s));
// Encoding emoji into unicode characters
String toServer = StringEscapeUtils.escapeJava(message);
//To find the current time in timestamp format
Date d = new Date();
final long time = d.getTime();
Log.e("Time", String.valueOf(time));
Log.e("To Server", toServer);
Log.e("Sending", "Sending data-----" + toServer);
if (!message.equals("")) {
edMessage.setText(" ");
JSONObject jsonObject = new JSONObject();
try {
jsonObject.put("room_id", roomID);
// jsonObject.put("user", loggedInUpper);
jsonObject.put("id", md5LoggedInID);
jsonObject.put("message", toServer);
jsonObject.put("date", time);
jsonObject.put("status", "sent");
} catch (JSONException e) {
e.printStackTrace();
}
// isSelf = true; // Boolean isSelf is set to be true as sender of the message is logged in user i.e. you
//attemptToSend(loggedInUpper, message, isSelf);
mSocket.emit("send", jsonObject); // owner i.e LoggedIn user is sending the message
/* msg = new Bean_Message();
msg.setMessageStatus(Status.SENT);
listBeanMessages.add(msg);
adapter.notifyDataSetChanged();*/
} else {
runOnUiThread(new Runnable() {
@Override
public void run() {
Toast.makeText(getApplicationContext(), "Please enter some text", Toast.LENGTH_LONG).show();
}
});
}
return true;
}
//Handling drawable Left
if (event.getRawX() <= (edMessage.getCompoundDrawables()[DRAWABLE_LEFT].getBounds().width())) {
// your action here
Toast.makeText(getApplicationContext(), "Clicked", Toast.LENGTH_SHORT).show();
hideKeyboard(); // hiding the keyboard
showEmojiPopUp(!showEmoji);
return true;
}
}
return false;
}
}
);
// On clicking the edit text Emoji panel will be hidden
edMessage.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View view) {
hideEmoji = true;
hideEmojiPopUp(hideEmoji);
showKeyboard(edMessage);
}
});
// Hiding soft keyboard
getWindow().setSoftInputMode(WindowManager.LayoutParams.SOFT_INPUT_STATE_HIDDEN);
setEmojiconFragment(false);
//Disabling cut,copy and paste
edMessage.setCustomSelectionActionModeCallback(new ActionMode.Callback() {
@Override
public boolean onCreateActionMode(ActionMode actionMode, Menu menu) {
return false;
}
@Override
public boolean onPrepareActionMode(ActionMode actionMode, Menu menu) {
return false;
}
@Override
public boolean onActionItemClicked(ActionMode actionMode, MenuItem menuItem) {
return false;
}
@Override
public void onDestroyActionMode(ActionMode actionMode) {
}
});
}
// This method will set a panel of emoticons in the fragment
private void setEmojiconFragment(boolean useSystemDefault) {
// Replacing the existing frame having id emojicons with the fragment of emoticons library containing emoticons
getSupportFragmentManager().beginTransaction().replace(R.id.emojicons, EmojiconsFragment.newInstance(useSystemDefault)).commit();
}
// Hiding the keyboard
public void hideKeyboard() {
InputMethodManager inputManager = (InputMethodManager) getSystemService(this.INPUT_METHOD_SERVICE);
inputManager.hideSoftInputFromWindow(getCurrentFocus().getWindowToken(), InputMethodManager.HIDE_NOT_ALWAYS);
}
public void showEmojiPopUp(boolean showEmoji) {
Display display = getWindowManager().getDefaultDisplay();
Point size = new Point();
display.getSize(size);
deviceHeight = size.y;
Log.e("Device Height", String.valueOf(deviceHeight));
frameLayout = (FrameLayout) findViewById(R.id.emojicons);
frameLayout.getLayoutParams().height = (int) (deviceHeight / 2.5); // Setting the height of FrameLayout
frameLayout.requestLayout();
frameLayout.setVisibility(View.VISIBLE);
hideKeyboard();
}
// Hiding the FrameLayout containing the list of Emoticons
public void hideEmojiPopUp(boolean hideEmoji) {
FrameLayout frameLayout = (FrameLayout) findViewById(R.id.emojicons);
frameLayout.setVisibility(View.GONE);
}
//Show the soft keyboard
public void showKeyboard(EditText editText) {
InputMethodManager imm = (InputMethodManager) getSystemService(Context.INPUT_METHOD_SERVICE);
imm.showSoftInput(editText, InputMethodManager.SHOW_IMPLICIT);
hideEmojiPopUp(true);
//setHeightOfEmojiEditText();
}
// Event Listeners
private Emitter.Listener onConnect = new Emitter.Listener() {
@Override
public void call(Object... args) {
Log.e("Socket", "Connected");
}
};
private Emitter.Listener onConnectionError = new Emitter.Listener() {
@Override
public void call(Object... args) {
Log.e("Error", "Error in connecting server");
}
};
private Emitter.Listener onDisconnect = new Emitter.Listener() {
@Override
public void call(Object... args) {
Log.e("Disconnect", "Socket Disconnected");
}
};
private Emitter.Listener onReceive = new Emitter.Listener() {
@Override
public void call(final Object... args) {
runOnUiThread(new Runnable() {
@Override
public void run() {
JSONObject data = (JSONObject) args[0];
Log.e("DATA", String.valueOf(data));
try {
JSONArray ops = data.getJSONArray("ops");
for (int i = 0; i < ops.length(); i++) {
JSONObject object = ops.getJSONObject(i);
String room_id = object.getString("room_id"); // Getting room_id from json array
Log.e("room_id", room_id);
//Comparing the received room_id with the roomID generated here
if (roomID.equals(room_id)) {
String date = object.getString("date");
long time = Long.parseLong(date); //Converting String into long
String t = getDateFromTimestamp(time); // Getting date and time from timestamp
Log.e("DateReceived", date);
String unicodeMessageReceived = object.getString("message");
Log.e("UnicodeMessageReceived", unicodeMessageReceived);
//Decoding unicode characters for emoji
String messageReceived = StringEscapeUtils.unescapeJava(unicodeMessageReceived);
Log.e("DecodedMessageReceived", messageReceived);
// String loggedInUSerNAme = sharedPreferences.getString(Prefs_Registration.get_user_name, null);
String id = object.getString("id");
Log.e("ID", id);
Log.e("md5LoggedInID", md5LoggedInID);
//If the message is owned by the loggedInUser
if (id.equals(md5LoggedInID)) {
isSelf = true;
bean_group_message = new Bean_Group_Message();
bean_group_message.setMessage(messageReceived);
bean_group_message.setDate(t);
bean_group_message.setIsSelf(isSelf);
listBeanGroupMessage.add(bean_group_message);
adapter_group_message.notifyDataSetChanged();
playBeep();
} else {
isSelf = false;
bean_group_message = new Bean_Group_Message();
bean_group_message.setMessage(messageReceived);
bean_group_message.setDate(t);
bean_group_message.setIsSelf(isSelf);
listBeanGroupMessage.add(bean_group_message);
adapter_group_message.notifyDataSetChanged();
playBeep();
}
}
}
} catch (JSONException e) {
e.printStackTrace();
}
}
});
}
};
// Playing sound when the message is sent by other
public void playBeep() {
try {
Uri notification = RingtoneManager.getDefaultUri(RingtoneManager.TYPE_NOTIFICATION);
Ringtone r = RingtoneManager.getRingtone(getApplicationContext(), notification);
r.play();
} catch (Exception e) {
e.printStackTrace();
}
}
// Converting timestamp to string
private String getDateFromTimestamp(long time) {
//String date = (String) DateFormat.format("dd-MM-yyyy hh:mm a", time);
String date = (String) DateFormat.format("hh:mm a", time);
return date;
}
// encrypting string into MD5
public static String convertPassMd5(String pass) {
String password = null;
MessageDigest mdEnc;
try {
mdEnc = MessageDigest.getInstance("MD5");
mdEnc.update(pass.getBytes(), 0, pass.length());
pass = new BigInteger(1, mdEnc.digest()).toString(16);
while (pass.length() < 32) {
pass = "0" + pass;
}
password = pass;
} catch (NoSuchAlgorithmException e1) {
e1.printStackTrace();
}
return password;
}
@Override
public void onEmojiconBackspaceClicked(View view) {
EmojiconsFragment.backspace(edMessage);
}
@Override
public void onEmojiconClicked(Emojicon emojicon) {
EmojiconsFragment.input(edMessage, emojicon);
}
//Get old messages of group chat
public class GetOldMessages extends AsyncTask<String, String, String> {
@Override
protected String doInBackground(String... strings) {
// progressDialog.show();
String response = httpRequestProcessor.gETRequestProcessor(url_old_messages_group);
return response;
}
@Override
protected void onPostExecute(String response) {
// progressDialog.dismiss();
try {
JSONArray jsonArray = new JSONArray(response);
parseJsonFeed(jsonArray);
} catch (JSONException e) {
e.printStackTrace();
}
}
}
public void parseJsonFeed(JSONArray jsonArray) {
for (int i = 0; i < jsonArray.length(); i++) {
try {
JSONObject jsonObject = jsonArray.getJSONObject(i);
String roomID_oldMessage = jsonObject.getString("room_id");
Log.e("RoomIDOldMessages", roomID_oldMessage);
Log.e("RoomID", roomID);
if (roomID_oldMessage.equals(roomID)) {
Log.e("RoomIDs", "Are equal");
JSONObject id = jsonObject.getJSONObject("_id");
String md5IDSender = id.getString("$id");
Log.e("md5IDSender", md5IDSender);
if (md5IDSender.equals(md5LoggedInID)) {
Log.e("Message", "is owned by the loggedin user");
String message = jsonObject.getString("message");
Log.e("message", message);
String date = jsonObject.getString("date");
Log.e("Date", date);
String messageReceived = StringEscapeUtils.unescapeJava(message);
Long time = Long.parseLong(date);
String t = getDateFromTimestamp(time);
Log.e("TimeC", t);
Log.e("Date", date);
isSelf = true;
bean_group_message = new Bean_Group_Message();
bean_group_message.setMessage(messageReceived);
bean_group_message.setDate(t);
bean_group_message.setIsSelf(true);
listBeanGroupMessage.add(bean_group_message);
adapter_group_message.notifyDataSetChanged();
} else {
Log.e("Message", "is not owned by the loggedin user");
String message = jsonObject.getString("message");
Log.e("message", message);
String date = jsonObject.getString("date");
Log.e("Date", date);
String messageReceived = StringEscapeUtils.unescapeJava(message);
Long time = Long.parseLong(date);
String t = getDateFromTimestamp(time);
Log.e("TimeC", t);
Log.e("Date", date);
isSelf = false;
bean_group_message = new Bean_Group_Message();
bean_group_message.setMessage(messageReceived);
bean_group_message.setDate(t);
bean_group_message.setIsSelf(false);
listBeanGroupMessage.add(bean_group_message);
adapter_group_message.notifyDataSetChanged();
}
}
} catch (JSONException e) {
e.printStackTrace();
}
}
}
public void showAlertDialog(Context context, String title, String message) {
AlertDialog dialog = new AlertDialog.Builder(context).create();
//Setting Dialog Title
dialog.setTitle(title);
//Setting Dialog message
dialog.setMessage(message);
//Setting OK button
dialog.setButton("OK", new DialogInterface.OnClickListener() {
@Override
public void onClick(DialogInterface dialog, int which) {
}
});
dialog.show();
}
@Override
public boolean onCreateOptionsMenu(Menu menu) {
Log.e("Option Menu", "called");
menu.clear();
MenuInflater inflater = getMenuInflater();
inflater.inflate(R.menu.menu_group_chat_activity, menu);
return super.onCreateOptionsMenu(menu);
}
@Override
public boolean onOptionsItemSelected(MenuItem item) {
switch (item.getItemId()) {
case R.id.groupInfo:
return true;
case R.id.viewContact:
return true;
case R.id.groupMedia:
return true;
case R.id.search:
return true;
case R.id.mute:
return true;
case R.id.emailchat:
return true;
case R.id.clear_chat:
return true;
case R.id.action_attach:
initializePopUpWindow();
return true;
default:
return super.onOptionsItemSelected(item);
}
}
private void initializePopUpWindow() {
//Placing the popup window below the toolbar
popupWindow.showAsDropDown(toolbarGroupChat, 0, 0);
}
}
Raw
SingleChatActivity.java
public class SingleChatActivity extends AppCompatActivity implements EmojiconGridFragment.OnEmojiconClickedListener, EmojiconsFragment.OnEmojiconBackspaceClickedListener {
private String URL_FEED_Message, api_message;
private String frndID, id;
private SharedPreferences sharedPreferences;
private int loggedInUserID, friendID, smallerID, largerID;
private String sID, lID, md5StringRoomID;
private ApiConfiguration apiConfiguration;
private HttpRequestProcessor httpRequestProcessor;
private NetworkConnectionDetector networkConnectionDetector;
private Bean_Message msg;
private Boolean isSelf;
private List<Bean_Message> listBeanMessages;
private Adapter_Message adapter_message;
private ListView lv_message;
private String friendName, completeURLFriend;
private EmojiconEditText edMessage;
private Socket mSocket;
private boolean showEmoji = false;
private boolean hideEmoji;
int deviceHeight;
FrameLayout frameLayout;
private String message;
private String loggedInUpper, loggedInUser;
private PopupWindow popupWindow;
private Toolbar toolbar;
// instance initialization block
{
try {
mSocket = IO.socket(Constants.CHAT_SERVER_URL);
Log.e("Socket", String.valueOf(mSocket));
} catch (URISyntaxException e) {
throw new RuntimeException(e);
}
}
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_single_chat);
//Toolbar
toolbar = (Toolbar) findViewById(R.id.toolbarSingleChat);
toolbar.setNavigationIcon(R.drawable.back); // Setting Navigation Icon in the Toolbar
setSupportActionBar(toolbar);
//findViewByID
lv_message = (ListView) findViewById(R.id.lv_message);
edMessage = (EmojiconEditText) findViewById(R.id.edtMessage);
//Handling click event on the Navigation icon
toolbar.setNavigationOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View view) {
startActivity(new Intent(SingleChatActivity.this, FriendsListActivity.class));
}
});
//Getting values from previos screen(ChatFragment)
Bundle bundle = getIntent().getExtras();
friendName = bundle.getString("friendsName", null);
completeURLFriend = bundle.getString("absoluteURL", null);
frndID = bundle.getString("friendID");
//Initialization
sharedPreferences = getApplicationContext().getSharedPreferences(Prefs_Registration.prefsName, Context.MODE_PRIVATE);
apiConfiguration = new ApiConfiguration();
httpRequestProcessor = new HttpRequestProcessor();
networkConnectionDetector = new NetworkConnectionDetector(SingleChatActivity.this);
listBeanMessages = new ArrayList<Bean_Message>();
adapter_message = new Adapter_Message(SingleChatActivity.this, listBeanMessages, completeURLFriend);
//Setting adapter to listview
lv_message.setAdapter(adapter_message);
//inflate the popupwindow_attachment.xml
LinearLayout viewGroup = (LinearLayout) SingleChatActivity.this.findViewById(R.id.popup_element);
LayoutInflater inflater = (LayoutInflater) SingleChatActivity.this.getSystemService(Context.LAYOUT_INFLATER_SERVICE);
View layout = inflater.inflate(R.layout.popupwindow_attachment, viewGroup);
popupWindow = new PopupWindow(layout, WindowManager.LayoutParams.MATCH_PARENT, WindowManager.LayoutParams.WRAP_CONTENT);
//Close the popup when touch outside
popupWindow.setOutsideTouchable(true);
popupWindow.setFocusable(true);
popupWindow.setBackgroundDrawable(new ColorDrawable(Color.TRANSPARENT));
friendID = Integer.parseInt(frndID);//Converting friendID to integer
//Getting id of LoggedIn user
id = sharedPreferences.getString(Prefs_Registration.get_user_id, null);
loggedInUserID = Integer.parseInt(id);
// Comparing the loggedInUserId and friendID
if (friendID < loggedInUserID) {
smallerID = friendID;
largerID = loggedInUserID;
} else {
smallerID = loggedInUserID;
largerID = friendID;
}
sID = String.valueOf(smallerID);
lID = String.valueOf(largerID);
String combinedID = sID + lID;
Log.e("combined ID", combinedID);
md5StringRoomID = convertPassMd5(combinedID); // Encrypting the combinedID to generate Room ID
Log.e("md5StringRoomID", md5StringRoomID);
api_message = apiConfiguration.getApi_message(); // Getting the API of messages
URL_FEED_Message = api_message + md5StringRoomID; // md5String is the encrypted room ID here
Log.e("URL_FEED_MESSAGE", URL_FEED_Message);
//Getting name of LoggedInUSer
loggedInUser = sharedPreferences.getString(Prefs_Registration.get_user_name, null);
// loggedInUpper = upperCase(loggedInUser);
//Checking Internet Connection
if (networkConnectionDetector.isConnectedToInternet()) {
new MessageTask().execute();
} else {
showAlertDialog(SingleChatActivity.this, "Internet Connection", "Please Check your Internet Connection .You don't have internet Connection");
}
//Listening on Events
mSocket.on(Socket.EVENT_CONNECT, onConnect);
mSocket.on(Socket.EVENT_CONNECT_ERROR, onConnectionError);
mSocket.on(Socket.EVENT_DISCONNECT, onDisconnect);
mSocket.on("send:notice", onReceive); // Listening event for receiving messages
mSocket.connect(); // Explicitly call connect method to establish connection here
mSocket.emit("subscribe", md5StringRoomID);
// On clicking the edit text Emoji panel will be hidden
edMessage.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View view) {
hideEmoji = true;
hideEmojiPopUp(hideEmoji);
showKeyboard(edMessage);
}
});
//Disabling cut,copy and paste
edMessage.setCustomSelectionActionModeCallback(new ActionMode.Callback() {
@Override
public boolean onCreateActionMode(ActionMode actionMode, Menu menu) {
return false;
}
@Override
public boolean onPrepareActionMode(ActionMode actionMode, Menu menu) {
return false;
}
@Override
public boolean onActionItemClicked(ActionMode actionMode, MenuItem menuItem) {
return false;
}
@Override
public void onDestroyActionMode(ActionMode actionMode) {
}
});
//Handling click event on drawableLeft and drawableRight inside EmojiconEditText
edMessage.setOnTouchListener(new View.OnTouchListener() {
@Override
public boolean onTouch(View view, MotionEvent event) {
final int DRAWABLE_LEFT = 0;
final int DRAWABLE_TOP = 1;
final int DRAWABLE_RIGHT = 2;
final int DRAWABLE_BOTTOM = 3;
if (event.getAction() == MotionEvent.ACTION_UP) {
//Handling drawableRight
int leftEdgeOfRightDrawable = edMessage.getRight() - edMessage.getCompoundDrawables()[DRAWABLE_RIGHT].getBounds().width();
//EditText has padding here.So adjust left edge
leftEdgeOfRightDrawable -= getResources().getDimension(R.dimen.padding10); //Here we have set the padding of 10 from left and right in edittext
if (event.getRawX() >= leftEdgeOfRightDrawable) {
// your action here
Toast.makeText(getApplicationContext(), "Clicked", Toast.LENGTH_SHORT).show();
message = edMessage.getText().toString().trim();
// Spannable s = getSmiledText(getApplicationContext(),message);
// Log.e("Spannable", String.valueOf(s));
// Encoding emoji into unicode characters
String toServer = StringEscapeUtils.escapeJava(message);
//To find the current time in timestamp format
Date d = new Date();
final long time = d.getTime();
Log.e("Time", String.valueOf(time));
Log.e("To Server", toServer);
Log.e("Sending", "Sending data-----" + toServer);
if (!message.equals("")) {
edMessage.setText(" ");
JSONObject jsonObject = new JSONObject();
try {
jsonObject.put("room_id", md5StringRoomID);
jsonObject.put("user", loggedInUser);
jsonObject.put("id", friendID);
jsonObject.put("by", id); //ID of logged In user
jsonObject.put("message", toServer);
jsonObject.put("date", time);
jsonObject.put("status", "sent");
} catch (JSONException e) {
e.printStackTrace();
}
// isSelf = true; // Boolean isSelf is set to be true as sender of the message is logged in user i.e. you
//attemptToSend(loggedInUpper, message, isSelf);
mSocket.emit("send", jsonObject); // owner i.e LoggedIn user is sending the message
/* msg = new Bean_Message();
msg.setMessageStatus(Status.SENT);
listBeanMessages.add(msg);
adapter.notifyDataSetChanged();*/
} else {
runOnUiThread(new Runnable() {
@Override
public void run() {
Toast.makeText(getApplicationContext(), "Please enter some text", Toast.LENGTH_LONG).show();
}
});
}
return true;
}
//Handling drawable Left
if (event.getRawX() <= (edMessage.getCompoundDrawables()[DRAWABLE_LEFT].getBounds().width())) {
// your action here
Toast.makeText(getApplicationContext(), "Clicked", Toast.LENGTH_SHORT).show();
hideKeyboard(); // hiding the keyboard
showEmojiPopUp(!showEmoji);
return true;
}
}
return false;
}
}
);
setEmojiconFragment(false);
getWindow().setSoftInputMode(WindowManager.LayoutParams.SOFT_INPUT_STATE_HIDDEN); // Hiding soft keyboard
}
// Converting first lowercase letter of every word in Uppercase
String upperCase(String source) {
StringBuffer res = new StringBuffer();
String[] strArr = source.split(" ");
for (String str : strArr) {
char[] stringArray = str.trim().toCharArray();
stringArray[0] = Character.toUpperCase(stringArray[0]);
str = new String(stringArray);
res.append(str).append(" ");
}
return res.toString().trim();
}
// This method will set a panel of emoticons in the fragment
private void setEmojiconFragment(boolean useSystemDefault) {
// Replacing the existing frame having id emojicons with the fragment of emoticons library containing emoticons
getSupportFragmentManager().beginTransaction().replace(R.id.emojicons, EmojiconsFragment.newInstance(useSystemDefault)).commit();
}
// Hiding the keyboard
public void hideKeyboard() {
InputMethodManager inputManager = (InputMethodManager) getSystemService(this.INPUT_METHOD_SERVICE);
inputManager.hideSoftInputFromWindow(getCurrentFocus().getWindowToken(), InputMethodManager.HIDE_NOT_ALWAYS);
}
public void showEmojiPopUp(boolean showEmoji) {
Display display = getWindowManager().getDefaultDisplay();
Point size = new Point();
display.getSize(size);
deviceHeight = size.y;
Log.e("Device Height", String.valueOf(deviceHeight));
frameLayout = (FrameLayout) findViewById(R.id.emojicons);
frameLayout.getLayoutParams().height = (int) (deviceHeight / 2.5); // Setting the height of FrameLayout
frameLayout.requestLayout();
frameLayout.setVisibility(View.VISIBLE);
hideKeyboard();
}
//Setting the height of EmojiconEditText programmatically
public void setHeightOfEmojiEditText() {
ViewGroup.LayoutParams lp = edMessage.getLayoutParams();
lp.height = 100;
edMessage.setLayoutParams(lp);
/*
View v = (View) findViewById(R.id.view);
v.setVisibility(View.VISIBLE);*/
}
// Hiding the FrameLayout containing the list of Emoticons
public void hideEmojiPopUp(boolean hideEmoji) {
FrameLayout frameLayout = (FrameLayout) findViewById(R.id.emojicons);
frameLayout.setVisibility(View.GONE);
}
//Show the soft keyboard
public void showKeyboard(EditText editText) {
InputMethodManager imm = (InputMethodManager) getSystemService(Context.INPUT_METHOD_SERVICE);
imm.showSoftInput(editText, InputMethodManager.SHOW_IMPLICIT);
hideEmojiPopUp(true);
//setHeightOfEmojiEditText();
}
// Event Listeners
private Emitter.Listener onConnect = new Emitter.Listener() {
@Override
public void call(Object... args) {
Log.e("Socket", "Connected");
}
};
private Emitter.Listener onConnectionError = new Emitter.Listener() {
@Override
public void call(Object... args) {
Log.e("Error", "Error in connecting server");
}
};
private Emitter.Listener onDisconnect = new Emitter.Listener() {
@Override
public void call(Object... args) {
Log.e("Disconnect", "Socket Disconnected");
}
};
// Event Listener for receiving messages
private Emitter.Listener onReceive = new Emitter.Listener() {
@Override
public void call(final Object... args) {
Log.e("Receive", "Bean_Message received");
runOnUiThread(new Runnable() {
@Override
public void run() {
JSONObject data = (JSONObject) args[0];
Log.e("DATA", String.valueOf(data));
try {
JSONArray ops = data.getJSONArray("ops");
Log.e("JSONArray", ops.toString());
for (int i = 0; i < ops.length(); i++) {
JSONObject object = ops.getJSONObject(i);
String roomID = object.getString("room_id");
Log.e("RoomID", roomID); // Getting room ID from JSON array
Log.e("Md5RoomID", md5StringRoomID); // Getting room id which we have created using logged in user ID and room id of the user through which chat has to be done
//Comparing the room IDs
if (md5StringRoomID.equals(roomID)) {
String senderName = object.getString("user");
Log.e("Sender Name", senderName);
String senderID = object.getString("id");
Log.e("SenderID", senderID);
String date = object.getString("date"); // Getting timestamp value in the form of string
long time = Long.parseLong(date); //Converting String into long
String t = getDateFromTimestamp(time); // Getting date and time from timestamp
Log.e("DateReceived", date);
// JSONObject message = object.getJSONObject("message");
String unicodeMessageReceived = object.getString("message");
Log.e("UnicodeMessageReceived", unicodeMessageReceived);
//Decoding unicode characters for emoji
String messageReceived = StringEscapeUtils.unescapeJava(unicodeMessageReceived);
Log.e("DecodedMessageReceived", messageReceived);
String loggedInUSerNAme = sharedPreferences.getString(Prefs_Registration.get_user_name, null);
//String loggedInUSerNAme = almaChatDatabase.getUserName();
//If the message is sent by the owner to other from webapp ,then we need to check whether the sender is the loggedinUSer in the App or not and we will right align the messages .
if (loggedInUSerNAme.equalsIgnoreCase(senderName)) {
isSelf = true;
msg = new Bean_Message(senderName, messageReceived, isSelf);
msg.setMessageStatus(Status.SENT);
msg.setTime(t);
listBeanMessages.add(msg);
// Log.e("List Elements", String.valueOf(listBeanMessages));
adapter_message.notifyDataSetChanged();
playBeep();
} else {
isSelf = false;
msg = new Bean_Message(senderName, messageReceived, isSelf);
msg.setTime(t);
listBeanMessages.add(msg);
Log.e("List Elements", String.valueOf(listBeanMessages));
adapter_message.notifyDataSetChanged();
playBeep();
}
}
//else part will be executed when the message is sent by different user to logged in (i.e the user who is not a member of current chat room
else {
//Here id1 stores the id of the user to which the message has been sent
String id1 = object.getString("id");
//We are comparing the id of logged in user with the id of the user to which message has been sent
if (id.equals(id1)) {
String message_from = object.getString("by");
Log.e("Message_from", message_from);
String message = object.getString("message");
String sender_name = object.getString("user");
Log.e("message", message);
//As the message has been sent to the logged in user but logged in user is busy in talking with other,this message will be sent as notification
sendNotification(message);
}
}
}
} catch (JSONException e) {
e.printStackTrace();
}
}
});
}
private void sendNotification(String message) {
int mNotificationId = new Random().nextInt(5000);
Intent intent = new Intent();
intent.addFlags(Intent.FLAG_ACTIVITY_CLEAR_TOP);
int icon = R.drawable.logo;
PendingIntent pendingIntent = PendingIntent.getActivity(getApplicationContext(), 0, intent, PendingIntent.FLAG_CANCEL_CURRENT);
NotificationCompat.InboxStyle inboxStyle = new NotificationCompat.InboxStyle();
NotificationCompat.Builder mBuilder = new NotificationCompat.Builder(getApplicationContext());
Notification notification = mBuilder.setSmallIcon(icon).setTicker("Almachat").setWhen(0)
.setAutoCancel(true)
.setContentTitle("Almachat")
.setStyle(inboxStyle)
.setContentIntent(pendingIntent)
.setSound(RingtoneManager.getDefaultUri(RingtoneManager.TYPE_NOTIFICATION))
.setContentText(message)
.build();
NotificationManager notificationManager = (NotificationManager) getApplicationContext().getSystemService(Context.NOTIFICATION_SERVICE);
notificationManager.notify(mNotificationId, notification);
}
// Playing sound when the message is sent by other
public void playBeep() {
try {
Uri notification = RingtoneManager.getDefaultUri(RingtoneManager.TYPE_NOTIFICATION);
Ringtone r = RingtoneManager.getRingtone(getApplicationContext(), notification);
r.play();
} catch (Exception e) {
e.printStackTrace();
}
}
};
@Override
public void onEmojiconBackspaceClicked(View view) {
EmojiconsFragment.backspace(edMessage);
}
@Override
public void onEmojiconClicked(Emojicon emojicon) {
EmojiconsFragment.input(edMessage, emojicon);
}
//Getting old messages of the user
public class MessageTask extends AsyncTask<String, String, String> {
@Override
protected String doInBackground(String... strings) {
String response = httpRequestProcessor.gETRequestProcessor(URL_FEED_Message);
return response;
}
@Override
protected void onPostExecute(String s) {
Log.e("ResponseMessage", s);
try {
JSONArray jsonArray = new JSONArray(s);
parseJsonFeed(jsonArray);
} catch (JSONException e) {
e.printStackTrace();
}
}
}
// encrypting string into MD5
public static String convertPassMd5(String pass) {
String password = null;
MessageDigest mdEnc;
try {
mdEnc = MessageDigest.getInstance("MD5");
mdEnc.update(pass.getBytes(), 0, pass.length());
pass = new BigInteger(1, mdEnc.digest()).toString(16);
while (pass.length() < 32) {
pass = "0" + pass;
}
password = pass;
} catch (NoSuchAlgorithmException e1) {
e1.printStackTrace();
}
return password;
}
public void showAlertDialog(Context context, String title, String message) {
AlertDialog dialog = new AlertDialog.Builder(context).create();
//Setting Dialog Title
dialog.setTitle(title);
//Setting Dialog message
dialog.setMessage(message);
//Setting OK button
dialog.setButton("OK", new DialogInterface.OnClickListener() {
@Override
public void onClick(DialogInterface dialog, int which) {
}
});
dialog.show();
}
// Parsing JSon Array which corresponds to the old chat messages
public void parseJsonFeed(JSONArray jsonArray) {
for (int i = 0; i < jsonArray.length(); i++) {
try {
JSONObject jsonObject = jsonArray.getJSONObject(i);
String roomID = jsonObject.getString("room_id");
Log.e("RoomID", roomID);
Log.e("Md5RoomID", md5StringRoomID);
// If Room ID(created using id of logged in user and id of friend) matches with the room id obtained from JSON String
if (md5StringRoomID.equals(roomID)) {
String userName = jsonObject.getString("user");
Log.e("Name", userName);
String loggedInUSerNAme = sharedPreferences.getString(Prefs_Registration.get_user_name, null);
//String loggedInUSerNAme = almaChatDatabase.getUserName();
Log.e("LoggedInUSer", loggedInUSerNAme);
//If the message is sent by the owner to other from webapp ,then we need to check whether the sender is the loggedinUSer in the App or not and we will right align the messages .
if (loggedInUSerNAme.equalsIgnoreCase(userName)) {
String message = jsonObject.getString("message");
Log.e("message", message);
//Decoding unicode characters for emoji
try {
String messageReceived = StringEscapeUtils.unescapeJava(message);
String date = jsonObject.getString("date");
Long time = Long.parseLong(date);
String t = getDateFromTimestamp(time);
Log.e("TimeC", t);
Log.e("Date", date);
isSelf = true;
msg = new Bean_Message(userName, messageReceived, isSelf);
msg.setTime(t);
listBeanMessages.add(msg);
adapter_message.notifyDataSetChanged();
} catch (NumberFormatException e) {
Log.e("Exception", String.valueOf(e));
}
//playBeep();
} else {
//JSONObject jsonMessage = jsonObject.getJSONObject("message");
try {
String message = jsonObject.getString("message");
//Decoding unicode characters for emoji
String messageReceived = StringEscapeUtils.unescapeJava(message);
String date = jsonObject.getString("date");
Long time = Long.parseLong(date);
String t = getDateFromTimestamp(time);
Log.e("TimeC", t);
Log.e("Date", date);
isSelf = false;
msg = new Bean_Message(userName, messageReceived, isSelf);
msg.setTime(t);
listBeanMessages.add(msg);
adapter_message.notifyDataSetChanged();
// playBeep();
} catch (NumberFormatException e) {
Log.e("Exception ", String.valueOf(e));
}
}
}
} catch (JSONException e) {
e.printStackTrace();
}
}
}
// Converting timestamp to string
private String getDateFromTimestamp(long time) {
//String date = (String) DateFormat.format("dd-MM-yyyy hh:mm a", time);
String date = (String) DateFormat.format("hh:mm a", time);
return date;
}
@Override
public boolean onCreateOptionsMenu(Menu menu) {
Log.e("Option Menu", "called");
menu.clear();
MenuInflater inflater = getMenuInflater();
inflater.inflate(R.menu.menu_chat_activity, menu);
return super.onCreateOptionsMenu(menu);
}
@Override
public boolean onOptionsItemSelected(MenuItem item) {
switch (item.getItemId()) {
case R.id.action_viewContacts:
return true;
case R.id.action_media:
return true;
case R.id.action_search:
return true;
case R.id.action_block:
return true;
case R.id.action_email_chat:
return true;
case R.id.action_clear_chat:
return true;
case R.id.action_attach:
initializePopUpWindow();
return true;
default:
return super.onOptionsItemSelected(item);
}
}
private void initializePopUpWindow() {
//Placing the popup window below the toolbar
popupWindow.showAsDropDown(toolbar, 0, 0);
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment