DebuggerServlet.h

Go to the documentation of this file.

#ifndef DEBUGGERSERVLET_H_ATUMDA3G
#define DEBUGGERSERVLET_H_ATUMDA3G

#include "uscxml/Common.h"
#include "uscxml/util/BlockingQueue.h"
#include "uscxml/server/HTTPServer.h"

#include "uscxml/debug/Debugger.h"

namespace uscxml {

class USCXML_API DebuggerServlet : public Debugger, public HTTPServlet {
public:
    virtual ~DebuggerServlet() {}

    // from Debugger
    virtual void addBreakpoint(const Breakpoint& breakpoint) {};

    bool isCORS(const HTTPServer::Request& request);
    void handleCORS(const HTTPServer::Request& request);

    bool requestFromHTTP(const HTTPServer::Request& request);
    void setURL(const std::string& url) {
        _url = url;
    }

    void pushData(std::shared_ptr<DebugSession> session, Data pushData);
    void returnData(const HTTPServer::Request& request, Data replyData);

    void processDisconnect(const HTTPServer::Request& request);
    void processConnect(const HTTPServer::Request& request);
    void processListSessions(const HTTPServer::Request& request);

    void processIssues(const HTTPServer::Request& request);

//  void processDebugPrepare(const HTTPServer::Request& request);
//  void processDebugAttach(const HTTPServer::Request& request);
//  void processDebugStart(const HTTPServer::Request& request);
//  void processDebugStop(const HTTPServer::Request& request);

//  void processDebugEval(const HTTPServer::Request& request);
//  void processDebugStart(const HTTPServer::Request& request);
//  void processDebugStop(const HTTPServer::Request& request);
//  void processDebugStep(const HTTPServer::Request& request);
//  void processDebugResume(const HTTPServer::Request& request);
//  void processDebugPause(const HTTPServer::Request& request);
//  void processAddBreakPoint(const HTTPServer::Request& request);
//  void processRemoveBreakPoint(const HTTPServer::Request& request);
//  void processPoll(const HTTPServer::Request& request);


protected:
    void serverPushData(std::shared_ptr<DebugSession>);

    std::string _url;
    std::map<std::shared_ptr<DebugSession>, HTTPServer::Request> _clientConns;
    std::map<std::shared_ptr<DebugSession>, BlockingQueue<Data> > _sendQueues;
    std::map<std::string, std::shared_ptr<DebugSession> > _sessionForId;

    std::recursive_mutex _mutex;
};

}

#endif /* end of include guard: DEBUGGERSERVLET_H_ATUMDA3G */