frontend

1 files changed, 176 insertions, 0 deletions

diff --git a/src/main/java/derms/frontend/FE.java b/src/main/java/derms/frontend/FE.java
new file mode 100644
index 0000000..e49dd61
--- /dev/null
+++ b/src/main/java/derms/frontend/FE.java
@@ -0,0 +1,176 @@
+package derms.frontend;
+
+import java.io.IOException;
+import java.net.DatagramPacket;
+import java.net.DatagramSocket;
+import java.net.InetAddress;
+import java.net.SocketException;
+
+import javax.xml.ws.Endpoint;
+
+//import constants.Constants;
+
+public class FE {
+    private static final int sequencerPort = 1333;
+    private static final String sequencerIP = "192.168.2.17";
+//        private static final String sequencerIP = "localhost";
+    private static final String RM_Multicast_group_address = "230.1.1.10";
+    private static final int FE_SQ_PORT = 1414;
+    private static final int FE_PORT = 1999;
+    private static final int RM_Multicast_Port = 1234;
+    public static String FE_Address = "http://localhost:8067/service/FE";
+    private static final String FE_IP_Address = "";
+    
+    
+//    public static String FE_IP_Address = "localhost";
+
+    public static void main(String[] args) {
+        try {
+            FEInterface inter = new FEInterface() {
+                @Override
+                public void informRmHasBug(int RmNumber) {
+//                    String errorMessage = new MyRequest(RmNumber, "1").toString();
+                    MyRequest errorMessage = new MyRequest(RmNumber, "1");
+                    System.out.println("Rm:" + RmNumber + "has bug");
+//                    sendMulticastFaultMessageToRms(errorMessage);
+                    sendUnicastToSequencer(errorMessage);
+                }
+
+                @Override
+                public void informRmIsDown(int RmNumber) {
+//                    String errorMessage = new MyRequest(RmNumber, "2").toString();
+                    MyRequest errorMessage = new MyRequest(RmNumber, "2");
+                    System.out.println("Rm:" + RmNumber + "is down");
+//                    sendMulticastFaultMessageToRms(errorMessage);
+                    sendUnicastToSequencer(errorMessage);
+                }
+
+                @Override
+                public int sendRequestToSequencer(MyRequest myRequest) {
+                    return sendUnicastToSequencer(myRequest);
+                }
+
+                @Override
+                public void retryRequest(MyRequest myRequest) {
+                    System.out.println("No response from all Rms, Retrying request...");
+                    sendUnicastToSequencer(myRequest);
+                }
+            };
+            DERMSServerImpl servant = new DERMSServerImpl(inter);
+            Endpoint endpoint = Endpoint.publish(FE_Address, servant);
+            Runnable task = () -> {
+                listenForUDPResponses(servant);
+            };
+            Thread thread = new Thread(task);
+            thread.start();
+
+        } catch (Exception e) {
+//            System.err.println("Exception: " + e);
+            e.printStackTrace(System.out);
+//            Logger.serverLog(serverID, "Exception: " + e);
+        }
+
+//        System.out.println("FrontEnd Server Shutting down");
+//        Logger.serverLog(serverID, " Server Shutting down");
+
+    }
+
+    private static int sendUnicastToSequencer(MyRequest requestFromClient) {
+        DatagramSocket aSocket = null;
+        String dataFromClient = requestFromClient.toString();
+        System.out.println("FE:sendUnicastToSequencer>>>" + dataFromClient);
+        int sequenceID = 0;
+        try {
+            aSocket = new DatagramSocket(FE_SQ_PORT);
+            byte[] message = dataFromClient.getBytes();
+            InetAddress aHost = InetAddress.getByName(sequencerIP);
+            DatagramPacket requestToSequencer = new DatagramPacket(message, dataFromClient.length(), aHost, sequencerPort);
+
+            aSocket.send(requestToSequencer);
+
+            aSocket.setSoTimeout(1000);
+            // Set up an UPD packet for recieving
+            byte[] buffer = new byte[1000];
+            DatagramPacket response = new DatagramPacket(buffer, buffer.length);
+            // Try to receive the response from the ping
+            aSocket.receive(response);
+            String sentence = new String(response.getData(), 0,
+                    response.getLength());
+            System.out.println("FE:sendUnicastToSequencer/ResponseFromSequencer>>>" + sentence);
+            sequenceID = Integer.parseInt(sentence.trim());
+            System.out.println("FE:sendUnicastToSequencer/ResponseFromSequencer>>>SequenceID:" + sequenceID);
+        } catch (SocketException e) {
+            System.out.println("Failed: " + requestFromClient.noRequestSendError());
+            System.out.println("Socket: " + e.getMessage());
+        } catch (IOException e) {
+            System.out.println("Failed: " + requestFromClient.noRequestSendError());
+            e.printStackTrace();
+            System.out.println("IO: " + e.getMessage());
+        } finally {
+            if (aSocket != null)
+                aSocket.close();
+        }
+        return sequenceID;
+    }
+
+    public static void sendMulticastFaultMessageToRms(String errorMessage) {
+        DatagramSocket aSocket = null;
+        try {
+            aSocket = new DatagramSocket();
+            byte[] messages = errorMessage.getBytes();
+            InetAddress aHost = InetAddress.getByName(RM_Multicast_group_address);
+
+            DatagramPacket request = new DatagramPacket(messages, messages.length, aHost, RM_Multicast_Port);
+            System.out.println("FE:sendMulticastFaultMessageToRms>>>" + errorMessage);
+            aSocket.send(request);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+
+    }
+
+    private static void listenForUDPResponses(DERMSServerImpl servant) {
+        DatagramSocket aSocket = null;
+        try {
+
+//            aSocket = new MulticastSocket(1413);
+//            InetAddress[] allAddresses = Inet4Address.getAllByName("SepJ-ROG");
+            InetAddress desiredAddress = InetAddress.getByName(FE_IP_Address);
+//            //In order to find the desired Ip to be routed by other modules (WiFi adapter)
+//            for (InetAddress address :
+//                    allAddresses) {
+//                if (address.getHostAddress().startsWith("192.168.2")) {
+//                    desiredAddress = address;
+//                }
+//            }
+//            aSocket.joinGroup(InetAddress.getByName("230.1.1.5"));
+            aSocket = new DatagramSocket(FE_PORT, desiredAddress);
+            byte[] buffer = new byte[1000];
+            System.out.println("FE Server Started on " + desiredAddress + ":" + FE_PORT + "............");
+
+            while (true) {
+                DatagramPacket response = new DatagramPacket(buffer, buffer.length);
+                aSocket.receive(response);
+                String sentence = new String(response.getData(), 0,
+                        response.getLength()).trim();
+                System.out.println("FE:Response received from Rm>>>" + sentence);
+                RmResponse rmResponse = new RmResponse(sentence);
+//                String[] parts = sentence.split(";");
+
+                System.out.println("Adding response to FrontEndImplementation:");
+                servant.addReceivedResponse(rmResponse);
+//                DatagramPacket reply = new DatagramPacket(response.getData(), response.getLength(), response.getAddress(),
+//                        response.getPort());
+//                aSocket.send(reply);
+            }
+
+        } catch (SocketException e) {
+            System.out.println("Socket: " + e.getMessage());
+        } catch (IOException e) {
+            System.out.println("IO: " + e.getMessage());
+        } finally {
+//            if (aSocket != null)
+//                aSocket.close();
+        }
+    }
+}
\ No newline at end of file