package efrei.ngo.servlet;
import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.json.JSONException;
import org.json.JSONObject;
import efrei.ngo.entity.MsgPiece;
import efrei.ngo.util.DatabaseAccess;
/**
* Servlet implementation class StoreIMIntoMsgServlet
*/
public class StoreIMIntoMsgServlet extends HttpServlet {
private static final long serialVersionUID = 1L;
/**
* @see HttpServlet#HttpServlet()
*/
public StoreIMIntoMsgServlet() {
super();
// TODO Auto-generated constructor stub
}
/**
* @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse response)
*/
protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
// TODO Auto-generated method stub
}
/**
* @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response)
*/
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
// TODO Auto-generated method stub
String temp=request.getParameter("pFrom");
int pFrom=Integer.parseInt(temp);
int pTo=Integer.parseInt(request.getParameter("pTo"));
String msg=request.getParameter("msg");
JSONObject jObResponse=new JSONObject();
MsgPiece onePiece=new MsgPiece(pFrom,pTo,msg);
DatabaseAccess.connectToDB();
try{
if(DatabaseAccess.dbStoreIMIntoDB(onePiece)){
jObResponse.accumulate("result", true);
} else {
jObResponse.accumulate("result", false);
}
} catch (JSONException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
DatabaseAccess.endConnectionToDB();
System.out.println(jObResponse.toString());
response.getWriter().write(jObResponse.toString());
}
}