!7

cmodule MachineGroupChat > DynPrintLog {
  S msg;
  bool sign;
  transient StefansOS_ConnectToServer connector;
  
  visualize {
    JComponent log = super.visualize();
    enableWordWrap();
    ret centerAndSouthWithMargins(log,
      centerAndEastWithMargin(withLabel("Talk to everyone:", onEnterAndCtrlEnter(jLiveValueTextField_bothWays(dm_fieldLiveValue('msg)), rThread sendMsg)),
        centerAndEastWithMargin(jLiveValueCheckBox("Sign", dm_fieldLiveValue('sign)), jbutton("Send", rThread sendMsg))));
  }
  
  void sendMsg {
    postMsg(trim(msg), sign);
    setField(msg := "");
  }
  
  void postSigned(S msg) q { postMsg(msg, true); }
  void postMsg(S _msg, bool sign) q {
    S msg = _msg;
    if (empty(msg = trim(msg))) ret;
    if (sign) msg = signWithComputerIDAndDate(msg);
    vmBus_send('sendingToMachineChat, msg);
    //logQuotedWithDate(javaxDataDir("OS Chat/sent.log"), msg);
    //print("Sending to machine chat: " + msg);
    connector.sendLine("machineChat: " + quote(msg));
  }
  
  void cleanMeUp { cleanUp(connector); }
  
  start {
    thread { exportComputerPublicKeyToServerMechList(); }
    connector = new StefansOS_ConnectToServer;
    connector.onLine = voidfunc(S line) {
      new Matches m;
      if (startsWith(line, "machineChat:", m)) {
        S msg = unquote(m.rest());
        //infoBox(indent(">> ", msg));
        vmBus_send('gotFromMachineChat, msg);
        //logQuotedWithDate(stefansOS_chat_receivedLogFile(), msg);
      }
    };
    connector.startWithSubs("machineChat");
  }
}