1 package org.kuali.ole.sip2.servlet;
2
3
4 import org.apache.log4j.Logger;
5 import org.kuali.ole.sip2.constants.OLESIP2Constants;
6 import org.kuali.ole.sip2.service.OLESIP2HelperService;
7 import org.kuali.ole.sip2.service.impl.OLESIP2HelperServiceImpl;
8
9 import javax.servlet.ServletException;
10 import javax.servlet.http.HttpServlet;
11 import javax.servlet.http.HttpServletRequest;
12 import javax.servlet.http.HttpServletResponse;
13 import java.io.IOException;
14 import java.io.PrintWriter;
15 import java.util.HashMap;
16 import java.util.Map;
17
18
19
20
21 public class OLENettyServlet extends HttpServlet {
22
23 OLESIP2HelperService OLESIP2HelperService = new OLESIP2HelperServiceImpl();
24
25
26 Logger LOG = Logger.getLogger(OLENettyServlet.class);
27
28 @Override
29 public void init() throws ServletException {
30 super.init();
31 }
32
33 @Override
34 protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
35
36 LOG.info("Inside OLENettyServlet.doGet olefs");
37 if(OLESIP2Constants.ALREADY_REQUEST_PROCESSING.equalsIgnoreCase("Y")){
38 StringBuffer responseString = new StringBuffer();
39 responseString.append(OLESIP2Constants.REFRESH_PAGE);
40 PrintWriter out = response.getWriter();
41 LOG.info("Inside OLENettyServlet.doGet olefs : **"+responseString.toString());
42 out.print(responseString.toString());
43 }else if (OLESIP2Constants.olesip2Server != null) {
44 if (!OLESIP2Constants.olesip2Server.isStopped()) {
45 StringBuffer responseString = new StringBuffer();
46 responseString.append(OLESIP2Constants.SERVER_RUNNING);
47 PrintWriter out = response.getWriter();
48 LOG.info("Inside OLENettyServlet.doGet olefs : **"+responseString.toString());
49 out.print(responseString.toString());
50 }
51 }
52 }
53
54 @Override
55 protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
56 StringBuffer responseString = new StringBuffer();
57 PrintWriter out = response.getWriter();
58 Map<String, String[]> parameterMap = new HashMap<String, String[]>();
59
60 parameterMap = request.getParameterMap();
61
62 String action = parameterMap.get("action")[0];
63 if(OLESIP2Constants.ALREADY_REQUEST_PROCESSING.equalsIgnoreCase("N") && action.equalsIgnoreCase("start") && OLESIP2Constants.olesip2Server == null){
64 OLESIP2Constants.ALREADY_REQUEST_PROCESSING = "Y";
65 OLESIP2Constants.olesip2Server = OLESIP2HelperService.doActionForSocketServer(action, responseString, OLESIP2Constants.olesip2Server);
66 OLESIP2Constants.ALREADY_REQUEST_PROCESSING = "N";
67 out.write(responseString.toString());
68
69 }else if(action.equalsIgnoreCase("start") && OLESIP2Constants.ALREADY_REQUEST_PROCESSING.equalsIgnoreCase("Y")){
70 responseString.append(OLESIP2Constants.REFRESH_PAGE);
71 out.print(responseString.toString());
72 }else if(action.equalsIgnoreCase("start")){
73 if (OLESIP2Constants.olesip2Server != null) {
74 if (!OLESIP2Constants.olesip2Server.isStopped()) {
75 responseString.append(OLESIP2Constants.SERVER_RUNNING);
76 out.print(responseString.toString());
77 }else{
78 OLESIP2Constants.ALREADY_REQUEST_PROCESSING = "Y";
79 OLESIP2Constants.olesip2Server = OLESIP2HelperService.doActionForSocketServer(action, responseString, OLESIP2Constants.olesip2Server);
80 OLESIP2Constants.ALREADY_REQUEST_PROCESSING = "N";
81 out.write(responseString.toString());
82 }
83 }
84 }else{
85 OLESIP2Constants.olesip2Server = OLESIP2HelperService.doActionForSocketServer(action, responseString, OLESIP2Constants.olesip2Server);
86 out.write(responseString.toString());
87 }
88
89
90 }
91
92 }