Release 0.2

Author: daeynasvistas

app/src/main/java/pt/IPG/messenger/Conversation.java

@@ -1,8 +1,11 @@
 package pt.IPG.messenger;
 
 import android.content.Context;
+import android.content.SharedPreferences;
+import android.os.AsyncTask;
 import android.os.Bundle;
 
+import android.support.v4.app.FragmentTransaction;
 import android.support.v7.widget.LinearLayoutManager;
 import android.support.v7.widget.RecyclerView;
 import android.view.Menu;
@@ -17,15 +20,25 @@
 import org.json.JSONObject;
 
 import java.io.BufferedReader;
+import java.io.BufferedWriter;
 import java.io.File;
 import java.io.FileInputStream;
 import java.io.FileNotFoundException;
 import java.io.FileOutputStream;
 import java.io.IOException;
 import java.io.InputStreamReader;
+import java.io.OutputStream;
+import java.io.OutputStreamWriter;
+import java.io.UnsupportedEncodingException;
+import java.net.HttpURLConnection;
 import java.net.URISyntaxException;
+import java.net.URL;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
 import java.util.ArrayList;
 import java.util.Collection;
+import java.util.Collections;
+import java.util.Date;
 import java.util.List;
 import java.util.Random;
 
@@ -140,14 +153,72 @@ public static String random() {
     @Override
     protected void onCreate(Bundle savedInstanceState) {
         super.onCreate(savedInstanceState);
+        mAdapter = new ConversationRecyclerView(this,setData());
+        room = getIntent().getExtras().getString("roomName",null);
+        ID = getIntent().getExtras().getString("ID",null);
+
         setContentView(R.layout.activity_conversation);
+        setupToolbarWithUpNav(R.id.toolbar, "Alterar para API getuser" , R.drawable.ic_action_back);
 
-        setupToolbarWithUpNav(R.id.toolbar, "Julia do Trabalho", R.drawable.ic_action_back);
 
-        room = getIntent().getExtras().getString("roomName",null);
-        ID = getIntent().getExtras().getString("ID",null);
 
+        // receber conversa do mongodb
+        AsyncTask.execute(new Runnable() {
+            List<ChatData> data = new ArrayList<ChatData>();
+
+            @Override
+            public void run() {
+                //TODO your background code
+                //retrieve
+                String result =  getJSONFromUrl(room);
+
+                try {
+                    JSONObject jsonRoot  = new JSONObject(result);
+                    JSONArray jsonData = jsonRoot.getJSONArray("conversation");
+
+
+                    for (int i = 0; i < jsonData.length(); i++) {
+                        ChatData item = new ChatData();
+                        String time = jsonData.getJSONObject(i).getString("createdAt");
+                        //2019-02-19T12:24:06.557Z
+                        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSSZ");
+                        SimpleDateFormat newFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm");
+                        Date date = format.parse(time.replaceAll("Z$", "+0000"));
+
+
+                        item.setTime( newFormat.format(date));
+                        String author = jsonData.getJSONObject(i).getJSONObject("author").getString("_id");
+                        if (!author.equals(ID)) {
+                            item.setType("1");
+                        }else{item.setType("2");}
+                        String body = jsonData.getJSONObject(i).getString("body");
+                        item.setText(body);
+
+                        data.add(item);
+                    }
+                    // update do UI deve ser feito pelo UI
+                    runOnUiThread(new Runnable() {
+
+                        @Override
+                        public void run() {
+                            Collections.reverse(data);
+                            mAdapter.addItem(data);
+                            // Stuff that updates the UI
+
+                        }
+                    });
+
+                } catch (JSONException e) {
+                    //   System.out.println(e.getMessage());
+                } catch (ParseException e) {
+                    e.printStackTrace();
+                }
+
+
+            }
+        });
 
+        //--fim receber conversas
         // IPG - Alteração -------------- Dinis
         encryption = new Encryption();
 
@@ -164,7 +235,6 @@ protected void onCreate(Bundle savedInstanceState) {
         mRecyclerView = (RecyclerView) findViewById(R.id.recyclerView);
         mRecyclerView.setHasFixedSize(true);
         mRecyclerView.setLayoutManager(new LinearLayoutManager(this));
-        mAdapter = new ConversationRecyclerView(this,setData());
         mRecyclerView.setAdapter(mAdapter);
         mRecyclerView.postDelayed(new Runnable() {
             @Override
@@ -210,6 +280,17 @@ public void onClick(View view) {
 
                     // IPG - Alteração -------------- Dinis
                     try {
+                        // background para fazer cenas na base de dados mongop
+                        AsyncTask.execute(new Runnable() {
+                            @Override
+                            public void run() {
+                                //TODO your background code
+                                // mongoDB save stuff
+                                sendReplyToConversation(room, text.getText().toString());
+                            }
+                        });
+
+
                         //mSocket.emit("new message", room, encryption.Encrypt(text.getText().toString(), Encryption.MessageType.Encrypted), ID);
                         mSocket.emit("new message", room, text.getText() , ID);
                     } catch (Exception e) {
@@ -231,7 +312,7 @@ public void onClick(View view) {
 
     @Override
     public void onBackPressed() {
-        Toast.makeText(this,"Fechar Socket!!",Toast.LENGTH_LONG).show();
+       // Toast.makeText(this,"Fechar Socket!!",Toast.LENGTH_LONG).show();
         // fechar socket!!!
        // mSocket.disconnect();
       //  mSocket.emit("leave-room", room);
@@ -243,54 +324,111 @@ public void onBackPressed() {
 
     public List<ChatData> setData(){
         List<ChatData> data = new ArrayList<>();
-/*
-        String text[] = {"15 September","Hi, Julia! How are you?", "Hi, Joe, looks great! :) ", "I'm fine. Wanna go out somewhere?", "Yes! Coffe maybe?", "Great idea! You can come 9:00 pm? :)))", "Ok!", "Ow my good, this Kit is totally awesome", "Can you provide other kit?", "I don't have much time, :`("};
-        String time[] = {"", "5:30pm", "5:35pm", "5:36pm", "5:40pm", "5:41pm", "5:42pm", "5:40pm", "5:41pm", "5:42pm"};
-        String type[] = {"0", "2", "1", "1", "2", "1", "2", "2", "2", "1"};
+        return data;
+    }
 
 
+    @Override
+    public boolean onCreateOptionsMenu(Menu menu) {
+        MenuInflater inflater = getMenuInflater();
+        inflater.inflate(R.menu.menu_userphoto, menu);
+        return true;
+    }
 
-        String jsonText = new Gson().toJson(text);
-        String jsonTime = new Gson().toJson(time);
-        String jsonType = new Gson().toJson(type);
 
-        create(this, "storage_text.json", jsonText);
-        create(this, "storage_time.json", jsonTime);
-        create(this, "storage_type.json", jsonType);
-*/
+    public String getJSONFromUrl(String ConversationID) {
+        SharedPreferences settings = getApplication().getSharedPreferences("myPrefs", 0);
+        String tokenOK = settings.getString("token", ""/*default value*/);
+        String result ="";
+        try {
+            //Connect
+            // cache problema .... + "?_=" + System.currentTimeMillis()
+            HttpURLConnection urlConnection = (HttpURLConnection) (new URL("http://chat-ipg-04.azurewebsites.net/api/chat/"+ConversationID+ "?_=" + System.currentTimeMillis()).openConnection());
+            //   urlConnection.setDoOutput(false);
+            urlConnection.setRequestMethod("GET");
+            urlConnection.setUseCaches(false);
+
+            urlConnection.setRequestProperty("Content-Type", "application/json");
+            urlConnection.setRequestProperty("Accept", "application/json");
+            urlConnection.setRequestProperty("Authorization", tokenOK);
+
+            urlConnection.connect();
+            urlConnection.setConnectTimeout(10000);
+
+
+            //Read
+            BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(urlConnection.getInputStream(), "UTF-8"));
+            String line = null;
+            StringBuilder sb = new StringBuilder();
+            while ((line = bufferedReader.readLine()) != null) {
+                sb.append(line);
+            }
+            bufferedReader.close();
+            result = sb.toString();
+            urlConnection.disconnect();
+
+        } catch (UnsupportedEncodingException e){
+            return result;
+            //  e.printStackTrace();
+        } catch (IOException e) {
+            return result;
+            // e.printStackTrace();
+        }
 
-/*
-        String storagejsonText = read(this, "storage_text.json");
-        String[] text = storagejsonText.substring(1, storagejsonText.length()-1).split("\",\""); //remove [ and ] , then split by ','
-        String storagejsonTime = read(this, "storage_time.json");
-        String[] time = storagejsonTime.substring(1, storagejsonTime.length()-1).split("\",\"");//remove [ and ] , then split by ','
-        String storagejsonType = read(this, "storage_type.json");
-        String[] type = storagejsonType.substring(1, storagejsonType.length()-1).split("\",\""); //remove [ and ] , then split by ','
+        return result;
 
+    }
 
 
-        for (int i=0; i<text.length; i++){
-            ChatData item = new ChatData();
-            item.setType(type[i]);
-            item.setText(text[i]);
-            item.setTime(time[i]);
-            data.add(item);
-        }
-*/
-// ler
-        return data;
+    public String sendReplyToConversation(String ConversationID, String msg) {
+        SharedPreferences settings = getApplication().getSharedPreferences("myPrefs", 0);
+        String tokenOK = settings.getString("token", ""/*default value*/);
 
-    }
+        String result ="";
+        try {
+            //Connect
+            HttpURLConnection urlConnection = (HttpURLConnection) (new URL("http://chat-ipg-04.azurewebsites.net/api/chat/"+ConversationID).openConnection());
+            urlConnection.setDoOutput(true);
+            urlConnection.setRequestProperty("Accept", "application/json");
+            urlConnection.setRequestProperty("Content-Type","application/x-www-form-urlencoded");
+            urlConnection.setRequestMethod("POST");
+            urlConnection.setRequestProperty("Authorization", tokenOK);
+
+            String params =  "composedMessage="+msg;
+            urlConnection.setRequestProperty("Content-Length", Integer.toString(params.getBytes().length));
+
+            urlConnection.connect();
+            urlConnection.setConnectTimeout(10000);
+
+            //Write
+            OutputStream outputStream = urlConnection.getOutputStream();
+            BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(outputStream, "UTF-8"));
+            writer.write(params);
+            writer.close();
+            outputStream.close();
+
+            //Read
+            BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(urlConnection.getInputStream(), "UTF-8"));
+            String line = null;
+            StringBuilder sb = new StringBuilder();
+            while ((line = bufferedReader.readLine()) != null) {
+                sb.append(line);
+            }
+            bufferedReader.close();
+            result = sb.toString();
 
 
-    @Override
-    public boolean onCreateOptionsMenu(Menu menu) {
-        MenuInflater inflater = getMenuInflater();
-        inflater.inflate(R.menu.menu_userphoto, menu);
-        return true;
-    }
 
+        } catch (UnsupportedEncodingException e){
+            return result;
+            //  e.printStackTrace();
+        } catch (IOException e) {
+            return result;
+            // e.printStackTrace();
+        }
+        return result;
 
+    }
 
 
 }