!7

sS chatBotID = #1026221;

cmodule MultiComm > DynMultiComm {
  void blablu {}
  
  start {
    dm_vmBus_onMessage_q chatBot_userPolling(voidfunc(O mc, virtual Conversation conv) {
      Customer c = customerFromConv(mc, conv);
      if (c == null) ret;
    });
    
    dm_vmBus_onMessage_q chatBot_messageAdded(voidfunc(O mc, virtual Conversation conv, virtual Msg msg) {
      Customer c = customerFromConv(mc, conv);
      if (c == null) ret;
      S text = getString text(msg);
      bool fromUser = getBool fromUser(msg);
      if (fromUser)
        cnew(IncomingMessage, customer := c, +text, unread := true);
      else
        cnew(OutgoingMessage, customer := c, +text);
    });
    
    dm_registerAs_direct iptvMultiComm();
  }
  
  Customer customerFromConv(O mc, virtual Conversation conv) {
    S cookie = getString cookie(conv);
    if (empty(cookie)) null;
    Customer c = uniq(Customer, +cookie);
    cset(c, ip := getString ip(conv));
    cset(c, lastPing := now(), botConversationID := 
      BotConversationID(programID(mc), getLong id(conv));
    ret c;
  }
}