ChatSupervisor.h

#ifndef _ots_ChatSupervisor_h
#define _ots_ChatSupervisor_h
 
#include "otsdaq/CoreSupervisors/CoreSupervisorBase.h"
 
namespace ots
{
class ChatSupervisor : public CoreSupervisorBase
{
  public:
    XDAQ_INSTANTIATOR();
 
    ChatSupervisor(xdaq::ApplicationStub* s);
    virtual ~ChatSupervisor(void);
 
    void destroy(void);
 
    virtual void defaultPage(xgi::Input* in, xgi::Output* out) override;
    void         Default(xgi::Input* in, xgi::Output* out);
 
    virtual void request(const std::string&               requestType,
                         cgicc::Cgicc&                    cgiIn,
                         HttpXmlDocument&                 xmlOut,
                         const WebUsers::RequestUserInfo& userInfo) override;
 
    virtual void forceSupervisorPropertyValues(void)
        override;  
 
  private:
    std::vector<std::string> ChatHistoryEntry_, ChatHistoryAuthor_;
    std::vector<std::string> ChatHistoryType_;
    std::vector<time_t>      ChatHistoryTime_;
    std::vector<uint64_t>    ChatHistoryIndex_;
 
    uint64_t ChatLastUpdateIndex;
 
    std::vector<std::string> ChatUsers_;
    std::vector<time_t>      ChatUsersTime_;
 
    std::string chatSupervisorToolsPath_;
    bool        enableSlackChat;
    std::string slackInboxPath_;
    int         slackDaemonPid_;
 
    enum
    {
        CHAT_HISTORY_EXPIRATION_TIME = 30 * 60,  
        CHAT_HISTORY_MAX_ENTRIES     = 100,      
    };
 
    uint64_t incrementAndGetLastUpdate();
    bool     isLastUpdateIndexStale(uint64_t last);
    bool     isChatOld(uint64_t chatIndex, uint64_t last);
 
    void newUser(const std::string& user);
    void newChat(const std::string& chat, const std::string& user, const std::string& type = "", bool fromSlack = false);
    void sendToSlack(const std::string& user, const std::string& message);
    void receiveFromSlack();
    void startSlackDaemon();
    void stopSlackDaemon();
    void removeChatHistoryEntry(uint64_t i);
    void removeChatUserEntry(uint64_t i);
    void cleanupExpiredChats(void);
 
    void insertActiveUsers(HttpXmlDocument* xmldoc);
    void insertChatRefresh(HttpXmlDocument*   xmldoc,
                           uint64_t           lastUpdateIndex,
                           const std::string& user);
 
    void escapeChat(std::string& chat);
};
}  // namespace ots
 
#endif