!747

!1000868 // dialogHandler {

m {
  static int chatPort = 9751; // just any number, but must match the server's number.
  static S programID; // filled by JavaX

  static abstract class DialogIO {
    abstract boolean isStillConnected();
    abstract String readLineNoBlock();
    abstract boolean waitForLine();
    abstract void sendLine(String line);
    abstract void close();
  }
  
  p {
    installHelloMessage(programID + " - Chat client");
    
    startChatServerIfNotUp();
    waitForChatServer();
    
    final Socket s = new Socket("localhost", chatPort);    
    print("connect");
    
    final Writer w = new OutputStreamWriter(s.getOutputStream(), "UTF-8");
    final BufferedReader in = new BufferedReader(
      new InputStreamReader(s.getInputStream(), "UTF-8"));
    DialogIO io = new DialogIO() {
      S line;
      boolean buff;
      
      boolean isStillConnected() {
        return !(buff || s.isClosed());
      }
      
      String readLineNoBlock() {
        S l = line;
        line = null;
        return l;
      }
      
      boolean waitForLine() ctex {
        if (line != null) return true;
        print("Readline");
        line = in.readLine();
        print("Readline done: " + line);
        if (line == null) buff = true;
        return line != null;
      }
      
      void sendLine(String line) ctex {
        w.write(line + "\n");
        w.flush();
      }
      
      void close() ctex {
        s.close();
      }
    };
  
    //io.waitForLine();
    io.sendLine("hello chat");
    print("Sent line.");
    io.close();
    print("Closed.");
  }
}