From 868a75a0404884392d8739c48c48f3bb3d30dfc6 Mon Sep 17 00:00:00 2001
From: christian <christian@debian.com>
Date: Tue, 6 Apr 2021 23:37:44 +0200
Subject: [PATCH] again fixing chatting

---
 .../main/java/FunctionLayer/Datahandler.java  | 37 ++++++++++++++++---
 .../PresentationLayer/DiscordHandler.java     |  3 ++
 2 files changed, 34 insertions(+), 6 deletions(-)

diff --git a/ArtificialAutism/src/main/java/FunctionLayer/Datahandler.java b/ArtificialAutism/src/main/java/FunctionLayer/Datahandler.java
index 7fa0d4cc..59ae6679 100644
--- a/ArtificialAutism/src/main/java/FunctionLayer/Datahandler.java
+++ b/ArtificialAutism/src/main/java/FunctionLayer/Datahandler.java
@@ -769,11 +769,7 @@ public class Datahandler {
 
     public void update_autismo_socket_msg() {
         try {
-            List<Integer> portlists = new ArrayList<>();
-            portlists.add(48477);
-            portlists.add(48478);
-            for (Integer port : portlists)
-            try (DatagramSocket serverSocket = new DatagramSocket(port)) {
+            try (DatagramSocket serverSocket = new DatagramSocket(48477)) {
                 byte[] receiveData = new byte[4096];
                 InetAddress IPAddress = InetAddress.getByName("144.76.218.19");
                 DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length);
@@ -783,7 +779,34 @@ public class Datahandler {
                     sentence = sentence.replace("clientmessage:", "");
                     String getResponseMsg = getResponseMsg(sentence);
                     byte[] sendData = getResponseMsg.getBytes("UTF-8");
-                    DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, IPAddress, port);
+                    DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, IPAddress, 48477);
+                    serverSocket.send(sendPacket);
+                }
+            } catch (CustomError ex) {
+                Logger.getLogger(Datahandler.class.getName()).log(Level.SEVERE, null, ex);
+            }
+        } catch (SocketException ex) {
+            Logger.getLogger(Datahandler.class.getName()).log(Level.SEVERE, null, ex);
+        } catch (UnsupportedEncodingException ex) {
+            Logger.getLogger(Datahandler.class.getName()).log(Level.SEVERE, null, ex);
+        } catch (IOException ex) {
+            Logger.getLogger(Datahandler.class.getName()).log(Level.SEVERE, null, ex);
+        }
+    }
+    
+    public void update_autismo_socket_msg1() {
+        try {
+            try (DatagramSocket serverSocket = new DatagramSocket(48478)) {
+                byte[] receiveData = new byte[4096];
+                InetAddress IPAddress = InetAddress.getByName("144.76.218.19");
+                DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length);
+                while (true) {
+                    serverSocket.receive(receivePacket);
+                    String sentence = new String(receivePacket.getData(), 0, receivePacket.getLength());
+                    sentence = sentence.replace("clientmessage:", "");
+                    String getResponseMsg = getResponseMsg(sentence);
+                    byte[] sendData = getResponseMsg.getBytes("UTF-8");
+                    DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, IPAddress, 48478);
                     serverSocket.send(sendPacket);
                 }
             } catch (CustomError ex) {
@@ -809,6 +832,8 @@ public class Datahandler {
             annotationsT.add(ann);
         }
     }
+    
+    
 
     public static ConcurrentMap<String, CoreDocument> getMultipleCoreDocumentsWaySuggestion(Collection<String> str, StanfordCoreNLP localNLP) {
         AnnotationCollector<Annotation> annCollector = new AnnotationCollector();
diff --git a/ArtificialAutism/src/main/java/PresentationLayer/DiscordHandler.java b/ArtificialAutism/src/main/java/PresentationLayer/DiscordHandler.java
index 23d87a64..25108e1e 100644
--- a/ArtificialAutism/src/main/java/PresentationLayer/DiscordHandler.java
+++ b/ArtificialAutism/src/main/java/PresentationLayer/DiscordHandler.java
@@ -61,6 +61,9 @@ public class DiscordHandler {
         new Thread(() -> {
             Datahandler.instance.update_autismo_socket_msg();
         }).start();
+        new Thread(() -> {
+            Datahandler.instance.update_autismo_socket_msg1();
+        }).start();
         gateway.on(MessageCreateEvent.class).subscribe(event -> {
             if (!FunctionLayer.DoStuff.isOccupied()) {
                 FunctionLayer.DoStuff.doStuff(event, usernameBot);