Added image sending

Author: sowmen

app/build.gradle

@@ -40,4 +40,9 @@ dependencies {
  implementation 'androidx.media:media:1.1.0'
  implementation 'com.android.support:support-media-compat:28.0.0'
  implementation 'com.android.support:support-v4:28.0.0'
+
+ implementation ("com.github.bumptech.glide:glide:4.9.0") {
+ exclude group: "com.android.support"
+ }
+ implementation "com.android.support:support-fragment:26.1.0"
 }

app/src/main/java/com/example/chatfull/ChatActivity.java

@@ -1,21 +1,34 @@
 package com.example.chatfull;
 
+import android.content.Context;
 import android.content.Intent;
+import android.database.Cursor;
 import android.net.Uri;
 import android.os.Bundle;
+import android.provider.OpenableColumns;
+import android.util.Base64;
 import android.util.Log;
 import android.view.View;
 import android.widget.Button;
 import android.widget.EditText;
 import android.widget.ImageButton;
+import android.widget.ImageView;
 import android.widget.Toast;
 
 import androidx.annotation.Nullable;
 import androidx.appcompat.app.AppCompatActivity;
 
+import com.bumptech.glide.Glide;
+import com.squareup.picasso.Picasso;
+import com.stfalcon.chatkit.commons.ImageLoader;
 import com.stfalcon.chatkit.messages.MessagesList;
 import com.stfalcon.chatkit.messages.MessagesListAdapter;
 
+import java.io.ByteArrayOutputStream;
+import java.io.File;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.UnsupportedEncodingException;
 import java.util.Calendar;
 
 public class ChatActivity extends AppCompatActivity {
@@ -50,7 +63,18 @@ protected void onCreate(Bundle savedInstanceState) {
  messageReceiveServer = new MessageReceiveServer(ShowInfoActivity.getSelfIpAddress(), ShowInfoActivity.getSelfPort(),this);
 
  this.messagesList = findViewById(R.id.messagesList);
- adapter = new MessagesListAdapter<>(senderId, null);
+
+ ImageLoader imageLoader = new ImageLoader() {
+ @Override
+ public void loadImage(ImageView imageView, @Nullable String url, @Nullable Object payload) {
+ byte[] byteArray = Base64.decode(url,Base64.DEFAULT);
+ Glide.with(getApplicationContext())
+ .asBitmap()
+ .load(byteArray)
+ .into(imageView);
+ }
+ };
+ adapter = new MessagesListAdapter<>(senderId, imageLoader);
  messagesList.setAdapter(adapter);
 
  input = findViewById(R.id.et_message);
@@ -60,10 +84,14 @@ protected void onCreate(Bundle savedInstanceState) {
  }
 
  public void onBtnSendClick(View view) {
+ if(input.getText().toString() == null) return;
+
  Message message = new Message(Integer.toString(++cnt), me, input.getText().toString(), Calendar.getInstance().getTime());
+ message.setIsImage(false);
+ message.setFilename(null);
  adapter.addToStart(message, true);
 
- sender = new SendMessage(user.getIpAddress(), user.getPort(), input.getText().toString(),this);
+ sender = new SendMessage(user.getIpAddress(), user.getPort(), message,this);
  sender.execute();
  Log.e("SEND",input.getText().toString());
  input.setText("");
@@ -96,11 +124,93 @@ protected void onActivityResult(int requestCode, int resultCode, @Nullable Inten
  }else if (requestCode == PICK_IMAGE_REQUEST && data!=null) {
  if (resultCode == RESULT_OK) {
  Uri file = data.getData();
- Toast.makeText(this, file.getPath() + "IMAGE", Toast.LENGTH_SHORT).show();
+ Message message = new Message(Integer.toString(++cnt), me, null, Calendar.getInstance().getTime());
+ message.setFilename(getFileName(file));
+ try {
+ message.setFile(getBytes(this,file));
+ } catch (IOException e) {
+ e.printStackTrace();
+ Log.e("SEND_FILE","COULD NOT CONVERT TO BYTE");
+ }
+ message.setIsImage(true);
+
+ adapter.addToStart(message,true);
+ sender = new SendMessage(user.getIpAddress(), user.getPort(), message,this);
+ sender.execute();
+// Toast.makeText(this, file.getPath() + "IMAGE", Toast.LENGTH_SHORT).show();
+ }
+ }
+ }
+
+ public String getFileName(Uri uri) {
+ String result = null;
+ if (uri.getScheme().equals("content")) {
+ Cursor cursor = getContentResolver().query(uri, null, null, null, null);
+ try {
+ if (cursor != null && cursor.moveToFirst()) {
+ result = cursor.getString(cursor.getColumnIndex(OpenableColumns.DISPLAY_NAME));
+ }
+ } finally {
+ cursor.close();
+ }
+ }
+ if (result == null) {
+ result = uri.getPath();
+ int cut = result.lastIndexOf('/');
+ if (cut != -1) {
+ result = result.substring(cut + 1);
  }
  }
+ return result;
  }
 
+ /**
+ * get bytes array from Uri.
+ *
+ * @param context current context.
+ * @param uri uri fo the file to read.
+ * @return a bytes array.
+ * @throws IOException
+ */
+ public static byte[] getBytes(Context context, Uri uri) throws IOException {
+ InputStream iStream = context.getContentResolver().openInputStream(uri);
+ try {
+ return getBytes(iStream);
+ } finally {
+ // close the stream
+ try {
+ iStream.close();
+ } catch (IOException ignored) { /* do nothing */ }
+ }
+ }
+
+
+
+ /**
+ * get bytes from input stream.
+ *
+ * @param inputStream inputStream.
+ * @return byte array read from the inputStream.
+ * @throws IOException
+ */
+ public static byte[] getBytes(InputStream inputStream) throws IOException {
+
+ byte[] bytesResult = null;
+ ByteArrayOutputStream byteBuffer = new ByteArrayOutputStream();
+ int bufferSize = 1024;
+ byte[] buffer = new byte[bufferSize];
+ try {
+ int len;
+ while ((len = inputStream.read(buffer)) != -1) {
+ byteBuffer.write(buffer, 0, len);
+ }
+ bytesResult = byteBuffer.toByteArray();
+ } finally {
+ // close the stream
+ try{ byteBuffer.close(); } catch (IOException ignored){ /* do nothing */ }
+ }
+ return bytesResult;
+ }
 // @Override
 // public boolean onSubmit(CharSequence input) {
 // Message message = new Message(Integer.toString(++cnt), me, input.toString(), Calendar.getInstance().getTime());
@@ -116,9 +226,9 @@ public void stopSender(){
  sender.cancel(true);
  }
 
- public void setMessage(final String msg){
- Log.e("IN_SET",msg);
- if(msg.equalsIgnoreCase("OFFLINE")){
+ public void setMessage(final Message msg){
+ Log.e("IN_SET",msg.toString());
+ if(msg.getText()!= null && msg.getText().equalsIgnoreCase("OFFLINE")){
  if(sender != null)
  sender.cancel(true);
  if(messageReceiveServer != null)
@@ -131,8 +241,13 @@ public void setMessage(final String msg){
  runOnUiThread(new Runnable() {
  @Override
  public void run() {
- Message message = new Message(Integer.toString(++cnt), user, msg, Calendar.getInstance().getTime());
- adapter.addToStart(message, true);
+ if(msg.getText() != null) {
+ Message message = new Message(Integer.toString(++cnt), user, msg.getText(), Calendar.getInstance().getTime());
+ adapter.addToStart(message, true);
+ } else if(msg.isImage()){
+ msg.setUser(user);
+ adapter.addToStart(msg,true);
+ }
  }
  });
  }
@@ -150,7 +265,7 @@ protected void onDestroy() {
  @Override
  public void onBackPressed() {
  Log.e("CHAT_ACTIVITY", "PAUSE");
- sender = new SendMessage(user.getIpAddress(), user.getPort(), "OFFLINE",this);
+ sender = new SendMessage(user.getIpAddress(), user.getPort(), new Message(Integer.toString(++cnt), me, "OFFLINE"),this);
  sender.execute();
  try {
  Thread.sleep(500);

app/src/main/java/com/example/chatfull/Message.java

@@ -1,15 +1,36 @@
 package com.example.chatfull;
 
+import android.annotation.TargetApi;
+import android.os.Build;
+import android.util.Base64;
+
+import androidx.annotation.Nullable;
+
 import com.stfalcon.chatkit.commons.models.IMessage;
 import com.stfalcon.chatkit.commons.models.IUser;
+import com.stfalcon.chatkit.commons.models.MessageContentType;
 
+import java.io.Serializable;
 import java.util.Date;
 
-public class Message implements IMessage {
+public class Message implements IMessage, Serializable, MessageContentType.Image {
+
+ private String id, text;
+ private User user;
+ private Date createdAt;
+
+ private String filename;
+ private byte[] file;
+
+ public void setId(String id) {
+ this.id = id;
+ }
+
+ public void setCreatedAt(Date createdAt) {
+ this.createdAt = createdAt;
+ }
 
- String id, text;
- User user;
- Date createdAt;
+ private boolean isImage;
 
  public Message(String id, User user, String text) {
  this(id, user, text, new Date());
@@ -22,6 +43,7 @@ public Message(String id, User user, String text, Date createdAt) {
  this.createdAt = createdAt;
  }
 
+
  @Override
  public String getId() {
  return id;
@@ -41,4 +63,47 @@ public IUser getUser() {
  public Date getCreatedAt() {
  return createdAt;
  }
+
+ @Override
+ public String toString() {
+ if(filename != null) return filename;
+ else return id;
+ }
+
+ public void setText(String text) { this.text = text; }
+
+ public void setUser(User user) { this.user = user; }
+
+ public String getFilename() {
+ return filename;
+ }
+
+ public void setFilename(String filename) {
+ this.filename = filename;
+ }
+
+ public byte[] getFile() {
+ return file;
+ }
+
+ public void setFile(byte[] file) {
+ this.file = file;
+ }
+
+ public boolean isImage() {
+ return isImage;
+ }
+
+ public void setIsImage(boolean image) {
+ isImage = image;
+ }
+
+ @Nullable
+ @Override
+ public String getImageUrl() {
+ if(isImage == false) return null;
+ else{
+ return Base64.encodeToString(file,Base64.DEFAULT);
+ }
+ }
 }

app/src/main/java/com/example/chatfull/MessageReceiveServer.java

@@ -5,6 +5,7 @@
 import java.io.BufferedReader;
 import java.io.IOException;
 import java.io.InputStreamReader;
+import java.io.ObjectInputStream;
 import java.net.ServerSocket;
 import java.net.Socket;
 
@@ -34,14 +35,16 @@ public void run() {
  Log.e("RECEIVE","Connected");
 
  try {
- BufferedReader input = new BufferedReader(new InputStreamReader(received_userSocket.getInputStream()));
- String message;
- message = input.readLine();
+ ObjectInputStream in = new ObjectInputStream(received_userSocket.getInputStream());
+ Message message = (Message) in.readObject();
+
  Log.e("RECEIVE","RECEIVED ==>" + message);
  activity.setMessage(message);
 
  } catch (IOException e) {
  e.printStackTrace();
+ } catch (ClassNotFoundException e) {
+ e.printStackTrace();
  }
 
  }

app/src/main/java/com/example/chatfull/SendMessage.java

@@ -2,17 +2,20 @@
 
 import android.os.AsyncTask;
 import android.util.Log;
+
+import java.io.ObjectOutputStream;
 import java.io.PrintWriter;
 import java.net.Socket;
 
 public class SendMessage extends AsyncTask<Void, Void, String> {
 
  ChatActivity activity;
- private String dstAddress, message;
+ private String dstAddress;
+ private Message message;
  private int dstPort;
  private Socket clientSocket = null;
 
- SendMessage(String addr, int port, String message, ChatActivity activity) {
+ SendMessage(String addr, int port, Message message, ChatActivity activity) {
  this.dstAddress = addr;
  this.dstPort = port;
  this.message = message;
@@ -23,16 +26,18 @@ public class SendMessage extends AsyncTask<Void, Void, String> {
  protected String doInBackground(Void... arg0) {
  try {
  clientSocket = new Socket(dstAddress, dstPort);
- Log.e("SEND_MSG","Connected, Sending: " + message);
+ Log.e("SEND_MSG","Connected, Sending: " + message.getText());
 
  if(clientSocket != null) {
- PrintWriter out = new PrintWriter(clientSocket.getOutputStream(),true);
- out.println(message);
- Log.e("SEND_MSG","DONE: " + message);
+ ObjectOutputStream out = new ObjectOutputStream(clientSocket.getOutputStream());
+ out.writeObject(message);
+ out.flush();
+
+ Log.e("SEND_MSG","DONE: " + message.getText());
  activity.stopSender();
  }
  } catch (Exception e) {
- Log.e("SEND_MSG","ConnectHoyNai "+ message);
+ Log.e("SEND_MSG","ConnectHoyNai "+ message.getText());
  e.printStackTrace();
  }
  return null;