/** * @file * @author 2012-2013 Stefan Radomski (stefan.radomski@cs.tu-darmstadt.de) * @copyright Simplified BSD * * @cond * This program is free software: you can redistribute it and/or modify * it under the terms of the FreeBSD license as published by the FreeBSD * project. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. * * You should have received a copy of the FreeBSD license along with this * program. If not, see . * @endcond */ #ifndef EVENT_H_XZAQ4HR #define EVENT_H_XZAQ4HR #include #include #include #include #include #include #include #include #include #include #include "uscxml/Common.h" #include "uscxml/Convenience.h" #include "uscxml/util/MD5.hpp" #include "uscxml/util/Base64.hpp" namespace uscxml { class USCXML_API Blob { public: ~Blob(); Blob(size_t size); Blob(void* data, size_t size, const std::string& mimeType, bool adopt = false); char* data; size_t size; std::string mimeType; std::string md5() { return uscxml::md5(data, size); } std::string base64(); Blob* fromBase64(const std::string base64) { std::string decoded = base64Decode(base64); return new Blob((void*)decoded.c_str(), decoded.length(), mimeType); } }; class USCXML_API Data { public: enum Type { VERBATIM, INTERPRETED, }; Data() : type(INTERPRETED) {} Data(const std::string& atom_, Type type_ = INTERPRETED) : atom(atom_), type(type_) {} Data(const char* data, size_t size, const std::string& mimeType, bool adopt = false); Data(bool atom_) : type(INTERPRETED) { if (atom_) { atom = "true"; } else { atom = "false"; } } template Data(T value) : atom(toStr(value)), type(INTERPRETED) {} template Data(T value, Type type_) : atom(toStr(value)), type(type_) {} explicit Data(const Arabica::DOM::Node& dom); virtual ~Data() {} operator bool() const { return (atom.length() > 0 || !compound.empty() || !array.empty() || binary || node); } bool hasKey(const std::string& key) const { return (!compound.empty() && compound.find(key) != compound.end()); } const Data operator[](const std::string& key) const { return operator[](key.c_str()); } const Data operator[](const char* key) const { if (hasKey(key)) return compound.at(key); Data data; return data; } operator std::string() const { return atom; } operator std::map() { return compound; } operator std::list() { return array; } static Data fromJSON(const std::string& jsonString); static std::string toJSON(const Data& data); static Data fromXML(const std::string& xmlString); Arabica::DOM::Document toDocument(); std::string toXMLString() { std::stringstream ss; ss << toDocument(); return ss.str(); } std::map getCompound() { return compound; } void setCompound(const std::map& compound) { this->compound = compound; } std::list getArray() { return array; } void setArray(const std::list& array) { this->array = array; } std::string getAtom() { return atom; } void setAtom(const std::string& atom) { this->atom = atom; } Type getType() { return type; } void setType(const Type type) { this->type = type; } #ifdef SWIGIMPORTED protected: #endif Arabica::DOM::Node node; std::map compound; std::list array; std::string atom; boost::shared_ptr binary; Type type; protected: Arabica::DOM::Document toNode(const Arabica::DOM::Document& factory, const Data& data); friend USCXML_API std::ostream& operator<< (std::ostream& os, const Data& data); }; class USCXML_API Event { public: enum Type { INTERNAL = 1, EXTERNAL = 2, PLATFORM = 3 }; Event() : eventType(INTERNAL), hideSendId(false) {} Event(const std::string& name, Type type = INTERNAL) : name(name), eventType(type), hideSendId(false) {} Event(const Arabica::DOM::Node& xmlString) : eventType(INTERNAL), hideSendId(false) {}; bool operator< (const Event& other) const { return this < &other; } std::string getName() { return name; } void setName(const std::string& name) { this->name = name; } Type getEventType() { return eventType; } void setEventType(const Type type) { this->eventType = type; } std::string getOrigin() { return origin; } void setOrigin(const std::string& origin) { this->origin = origin; } std::string getOriginType() { return origintype; } void setOriginType(const std::string& originType) { this->origintype = originType; } Arabica::DOM::Node getDOM() { return dom; } void setDOM(const Arabica::DOM::Node& dom) { this->dom = dom; } // Arabica::DOM::Node getFirstDOMElement() const; // Arabica::DOM::Document getStrippedDOM() const; // // static Arabica::DOM::Node getFirstDOMElement(const Arabica::DOM::Document dom); // static Arabica::DOM::Document getStrippedDOM(const Arabica::DOM::Document dom); std::string getRaw() { return raw; } void setRaw(const std::string& raw) { this->raw = raw; } std::string getContent() { return content; } void setContent(const std::string& content) { this->content = content; } std::string getXML() { return xml; } void setXML(const std::string& xml) { this->xml = xml; } std::string getSendId() { return sendid; } void setSendId(const std::string& sendId) { this->sendid = sendId; } std::string getInvokeId() { return invokeid; } void setInvokeId(const std::string& invokeId) { this->invokeid = invokeId; } Data getData() { return data; } void setData(const Data& data) { this->data = data; } void initContent(const std::string& content); static Event fromXML(const std::string& xmlString); Arabica::DOM::Document toDocument(); std::string toXMLString() { std::stringstream ss; ss << toDocument(); return ss.str(); } std::map& getNameList() { return namelist; } std::multimap& getParams() { return params; } typedef std::multimap params_t; typedef std::map namelist_t; static bool getParam(params_t params, const std::string& name, Data& target) { if (params.find(name) != params.end()) { target = params.find(name)->second; return true; } return false; } static bool getParam(params_t params, const std::string& name, std::list& target) { if (params.find(name) != params.end()) { std::pair rangeIter = params.equal_range(name); while(rangeIter.first != rangeIter.second) { target.push_back(rangeIter.first->second); rangeIter.first++; } return true; } return false; } template static bool getParam(params_t params, const std::string& name, T& target) { if (params.find(name) != params.end()) { target = boost::lexical_cast(params.find(name)->second.atom); return true; } return false; } template static bool getParam(params_t params, const std::string& name, std::list& target) { if (params.find(name) != params.end()) { std::pair rangeIter = params.equal_range(name); while(rangeIter.first != rangeIter.second) { target.push_back(boost::lexical_cast(rangeIter.first->second.atom)); rangeIter.first++; } return true; } return false; } #ifdef SWIGIMPORTED protected: #endif std::string raw; std::string xml; std::string name; Type eventType; std::string origin; std::string origintype; Arabica::DOM::Node dom; std::string sendid; bool hideSendId; std::string invokeid; Data data; std::string content; std::map namelist; std::multimap params; friend USCXML_API std::ostream& operator<< (std::ostream& os, const Event& event); }; class USCXML_API InvokeRequest : public Event { public: InvokeRequest(Event event) : Event(event) {} InvokeRequest() {} std::string getType() { return type; } void setType(const std::string& type) { this->type = type; } std::string getSource() { return src; } void setSource(const std::string& src) { this->src = src; } bool isAutoForwarded() { return autoForward; } void setAutoForwarded(bool autoForward) { this->autoForward = autoForward; } static InvokeRequest fromXML(const std::string& xmlString); Arabica::DOM::Document toDocument(); std::string toXMLString() { std::stringstream ss; ss << toDocument(); return ss.str(); } #ifdef SWIGIMPORTED protected: #endif std::string type; std::string src; bool autoForward; friend USCXML_API std::ostream& operator<< (std::ostream& os, const InvokeRequest& sendReq); }; class USCXML_API SendRequest : public Event { public: SendRequest() {} SendRequest(Event event) : Event(event) {} std::string getTarget() { return target; } void setTarget(const std::string& target) { this->target = target; } std::string getType() { return type; } void setType(const std::string& type) { this->type = type; } uint32_t getDelayMs() { return delayMs; } void setDelayMs(uint32_t delayMs) { this->delayMs = delayMs; } static SendRequest fromXML(const std::string& xmlString); Arabica::DOM::Document toDocument(); std::string toXMLString() { std::stringstream ss; ss << toDocument(); // std::cout << ss.str() << std::endl; return ss.str(); } #ifdef SWIGIMPORTED protected: #endif std::string target; std::string type; uint32_t delayMs; friend USCXML_API std::ostream& operator<< (std::ostream& os, const SendRequest& sendReq); }; USCXML_API std::ostream& operator<< (std::ostream& os, const InvokeRequest& invokeReq); USCXML_API std::ostream& operator<< (std::ostream& os, const SendRequest& sendReq); USCXML_API std::ostream& operator<< (std::ostream& os, const Event& event); USCXML_API std::ostream& operator<< (std::ostream& os, const Data& data); } #endif /* end of include guard: EVENT_H_XZAQ4HR */