import javax.servlet.*;
import javax.servlet.http.*;
import java.io.*;
import java.util.*;

public class TestGet extends HttpServlet {
//Initialize global variables
  MDBuddySource source = new MDBuddySource();  
  public void init(ServletConfig config) throws ServletException {
    super.init(config);
  }
//Process the HTTP Get request

  public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
    String mode = request.getParameter("mode");
    if(mode.equalsIgnoreCase("get")){
System.out.println("Processing get: ");
      PrintWriter out = response.getWriter();
      try{
        response.setContentType("text/plain");
        out.println(getNextMessage());
      }
      catch(Exception ex){
        ex.printStackTrace();
      }
      finally{
        out.close();
      }
    }
    else{
      String message = request.getParameter("message");
System.out.println("Processing post: " + message);
      if(message != null) broadcastMessage(message);
    }
  }

  public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
      String message = request.getParameter("message");
System.out.println("Processing new post: " + message);
      if(message != null) broadcastMessage(message);
  }


  public String getNextMessage(){
    return new MDBuddySink().getNextMessage(source);
  }

  public void broadcastMessage(String message){
    source.sendMessage(message);
  }

//Get Servlet information

  public String getServletInfo() {
    return "TestGet Information";
  }
}