ChatSupervisor.h

#ifndef _ots_ChatSupervisor_h
#define _ots_ChatSupervisor_h
 
#include "otsdaq/CoreSupervisors/CoreSupervisorBase.h"
 
// clang-format off
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<time_t>      ChatHistoryTime_;
    std::vector<uint64_t>    ChatHistoryIndex_;
 
    uint64_t ChatLastUpdateIndex;
 
    std::vector<std::string> ChatUsers_;
    std::vector<time_t>      ChatUsersTime_;
 
    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);
    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
// clang-format on
 
#endif