package network.jms;

import gui.Lab;
import java.net.Socket;
import java.util.logging.Logger;
import network.MessageGenerator;
import network.MessageType;
import server.jms.JmsConnection;

/**
 *
 * @author Mark
 */
public class RequestSender {

	private static final Logger LOG = Logger.getLogger(RequestSender.class.getName());

	private final MessageGenerator messageGenerator = new MessageGenerator();
	private final Lab lab;
	private final String machineId;

	public RequestSender(final Lab lab, String machineId) {
		this.lab = lab;
		this.machineId = machineId;
	}

	public void sendRequest(final MessageType type) {
		JmsConnection connection = new JmsConnection();
		
		if(type == MessageType.HELP ) {
			connection.sendMessageToTopic(lab.getLabName()+"_help", machineId);
		} else if (type == MessageType.MARKING) {
			connection.sendMessageToTopic(lab.getLabName()+"_marking", machineId);
		}
	}

//   @SuppressWarnings({"rawtypes", "unchecked"})
//   public Collection<Integer> requestQueue() {
//      try {
//         final Socket socket = new Socket(destinationIp, Constants.PORT);
//         final PrintWriter writer = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));
//         writer.println(messageGenerator.requestQueue());
//         writer.flush();
//         final ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
//         final Collection<Integer> response = (Collection<Integer>) ois.readObject();
//         writer.close();
//         ois.close();
//         socket.close();
//         return response;
//      } catch (Exception ex) {
//         LOG.log(Level.SEVERE, null, ex);
//      }
//      return Collections.EMPTY_SET;
//   }
	@SuppressWarnings({"rawtypes", "unchecked"})
	public Socket registerTutorClient() {
//		try {
//			final Socket socket = new Socket(destinationIp, Constants.PORT);
//			final PrintWriter writer = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));
//			
//			writer.println(messageGenerator.registerTutorClient());
//			writer.flush();
//			
//			return socket;
//		} catch (Exception ex) {
//			LOG.log(Level.SEVERE, "Error registering tutor client", ex);
//		}
		return null;
	}

}