StringHandlerImpl.java 1.6 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455
  1. package de.tudarmstadt.informatik.hostage.handler;
  2. import java.io.IOException;
  3. import java.io.InputStream;
  4. import java.io.OutputStream;
  5. import java.net.Socket;
  6. import java.util.List;
  7. import de.tudarmstadt.informatik.hostage.HoneyListener;
  8. import de.tudarmstadt.informatik.hostage.HoneyService;
  9. import de.tudarmstadt.informatik.hostage.io.ReaderWriter;
  10. import de.tudarmstadt.informatik.hostage.io.StringReaderWriter;
  11. import de.tudarmstadt.informatik.hostage.logging.Record.TYPE;
  12. import de.tudarmstadt.informatik.hostage.protocol.Protocol;
  13. import de.tudarmstadt.informatik.hostage.protocol.Protocol.TALK_FIRST;
  14. public class StringHandlerImpl extends AbstractHandler {
  15. public StringHandlerImpl(HoneyService service, HoneyListener listener,
  16. Protocol protocol, Socket client) {
  17. super(service, listener, protocol, client);
  18. }
  19. @Override
  20. protected void talkToClient(InputStream in, OutputStream out)
  21. throws IOException {
  22. ReaderWriter<String> stream = new StringReaderWriter(in, out);
  23. String inputLine;
  24. List<String> outputLine;
  25. if (protocol.whoTalksFirst() == TALK_FIRST.SERVER) {
  26. outputLine = protocol.processMessage(null);
  27. stream.write(outputLine);
  28. for (String s : outputLine) {
  29. log.write(createRecord(TYPE.SEND, s));
  30. }
  31. }
  32. while (!thread.isInterrupted() && (inputLine = stream.read()) != null) {
  33. log.write(createRecord(TYPE.RECEIVE, inputLine));
  34. outputLine = protocol.processMessage(inputLine);
  35. if (outputLine != null) {
  36. stream.write(outputLine);
  37. for (String s : outputLine) {
  38. log.write(createRecord(TYPE.SEND, s));
  39. }
  40. }
  41. if (protocol.isClosed()) {
  42. break;
  43. }
  44. }
  45. }
  46. }