path: root/src/uscxml/Message.h

#ifndef EVENT_H_XZAQ4HR
#define EVENT_H_XZAQ4HR

#include <map>
#include <list>
#include <set>
#include <vector>
#include <string>

#include <DOM/Document.hpp>
#include <DOM/io/Stream.hpp>

#include <inttypes.h>

#define TAGNAME(elem) ((Arabica::DOM::Element<std::string>)elem).getTagName()
#define LOCALNAME(elem) ((Arabica::DOM::Element<std::string>)elem).getLocalName()
#define ATTR(elem, attr) ((Arabica::DOM::Element<std::string>)elem).getAttribute(attr)
#define HAS_ATTR(elem, attr) ((Arabica::DOM::Element<std::string>)elem).hasAttribute(attr)

namespace uscxml {

class Data {
public:
	enum Type {
	    VERBATIM,
	    INTERPRETED
	};

	Data() {}
	Data(const std::string& atom_, Type type_ = INTERPRETED) : atom(atom_), type(type_) {}
	Data(const Arabica::DOM::Node<std::string>& dom);
	virtual ~Data() {}

	static Data fromJSON(const std::string& jsonString);
	static Data fromXML(const std::string& xmlString);
	Arabica::DOM::Document<std::string> toDocument();
	std::string toXMLString() {
		std::stringstream ss;
		ss << toDocument();
		return ss.str();
	}

	std::map<std::string, Data> getCompund() { return compound; }
	void setCompound(const std::map<std::string, Data>& compound) { this->compound = compound; }

	std::list<Data> getArray() { return array; }
	void setArray(const std::list<Data>& 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

	std::map<std::string, Data> compound;
	std::list<Data> array;
	std::string atom;
	Type type;

protected:
	Arabica::DOM::Document<std::string> toNode(const Arabica::DOM::Document<std::string>& factory, const Data& data);

#ifndef SWIGJAVA
	friend std::ostream& operator<< (std::ostream& os, const Data& data);
#endif
};

class Event {
public:
	enum Type {
	    INTERNAL = 1,
	    EXTERNAL = 2,
	    PLATFORM = 3
	};

	Event() : type(INTERNAL) {}
	Event(const Arabica::DOM::Node<std::string>& xmlString) : type(INTERNAL) {};
	bool operator< (const Event& other) const     {
		return this < &other;
	}

	std::string getName() { return name; }
	void setName(const std::string& name) { this->name = name; }

	Type getType() { return type; }
	void setType(const Type type) { this->type = 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<std::string> getDOM() { return dom; }
	void setDOM(const Arabica::DOM::Node<std::string>& dom) { this->dom = dom; }

	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& invokeId) { this->data = data; }

	static Event fromXML(const std::string& xmlString);
	Arabica::DOM::Document<std::string> toDocument();
	std::string toXMLString() {
		std::stringstream ss;
		ss << toDocument();
		return ss.str();
	}

#ifdef SWIGIMPORTED
protected:
#endif

	std::string name;
	Type type;
	std::string origin;
	std::string origintype;
	Arabica::DOM::Node<std::string> dom;
	std::string sendid;
	std::string invokeid;
	Data data;

#ifndef SWIG
	friend std::ostream& operator<< (std::ostream& os, const Event& event);
#endif
};

class 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; }

	std::string getContent() { return content; }
	void setContent(const std::string& content) { this->content = content; }
	
	bool isAutoForwarded() { return autoForward; }
	void setAutoForwarded(bool autoForward) { this->autoForward = autoForward; }

#ifdef SWIG
	/// TODO: Do we want to set namelist and params as well?
	std::map<std::string, std::string> getNameList() { return namelist; }

	virtual const std::vector<std::string> getNameListKeys() {
		std::set<std::string> keys;
		namelist_t::const_iterator nameListIter = namelist.begin();
		while (nameListIter != namelist.end()) {
			keys.insert(nameListIter->first);
			nameListIter++;
		}
		return std::vector<std::string>(keys.begin(), keys.end());
	}

	// substitute multimap by map with vectors for language bindings
	std::map<std::string, std::vector<std::string> > getParams() {
		std::map<std::string, std::vector<std::string> > paramsMap;
		params_t::iterator paramIter = params.begin();
		while(paramIter != params.end()) {
			paramsMap[paramIter->first].push_back(paramIter->second);
			paramIter++;
		}
		return paramsMap;
	}
	
	const std::vector<std::string> getParamKeys() {
		std::set<std::string> keys;
		params_t::iterator paramIter = params.begin();
		while(paramIter != params.end()) {
			keys.insert(paramIter->first);
			paramIter++;
		}
		return std::vector<std::string>(keys.begin(), keys.end());
	}
	
#else
	std::map<std::string, std::string>& getNameList() { return namelist; }
	std::multimap<std::string, std::string>& getParams() { return params; }
#endif

	static InvokeRequest fromXML(const std::string& xmlString);
	Arabica::DOM::Document<std::string> toDocument();
	std::string toXMLString() {
		std::stringstream ss;
		ss << toDocument();
		return ss.str();
	}

#ifdef SWIGIMPORTED
protected:
#endif
	std::string type;
	std::string src;
	std::string content;
	bool autoForward;
	std::map<std::string, std::string> namelist;
	std::multimap<std::string, std::string> params;

	typedef std::multimap<std::string, std::string> params_t;
	typedef std::map<std::string, std::string> namelist_t;

#ifndef SWIG
	friend std::ostream& operator<< (std::ostream& os, const InvokeRequest& sendReq);
#endif

};

class 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; }
	
	std::string getContent() { return content; }
	void setContent(const std::string& content) { this->content = content; }

#ifdef SWIG
	/// TODO: Do we want to set namelist and params as well?
	std::map<std::string, std::string> getNameList() { return namelist; }

	virtual const std::vector<std::string> getNameListKeys() {
		std::set<std::string> keys;
		namelist_t::const_iterator nameListIter = namelist.begin();
		while (nameListIter != namelist.end()) {
			keys.insert(nameListIter->first);
			nameListIter++;
		}
		return std::vector<std::string>(keys.begin(), keys.end());
	}

	// substitute multimap by map with vectors for language bindings
	std::map<std::string, std::vector<std::string> > getParams() {
		std::map<std::string, std::vector<std::string> > paramsMap;
		params_t::iterator paramIter = params.begin();
		while(paramIter != params.end()) {
			paramsMap[paramIter->first].push_back(paramIter->second);
			paramIter++;
		}
		return paramsMap;
	}
	
	const std::vector<std::string> getParamKeys() {
		std::set<std::string> keys;
		params_t::iterator paramIter = params.begin();
		while(paramIter != params.end()) {
			keys.insert(paramIter->first);
			paramIter++;
		}
		return std::vector<std::string>(keys.begin(), keys.end());
	}
	
#else
	std::map<std::string, std::string>& getNameList() { return namelist; }
	std::multimap<std::string, std::string>& getParams() { return params; }
#endif

	static SendRequest fromXML(const std::string& xmlString);
	Arabica::DOM::Document<std::string> 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;
	std::string content;

	std::map<std::string, std::string> namelist;
	std::multimap<std::string, std::string> params;
	
	typedef std::map<std::string, std::string> namelist_t;
	typedef std::multimap<std::string, std::string> params_t;

#ifndef SWIG
	friend std::ostream& operator<< (std::ostream& os, const SendRequest& sendReq);
#endif

};

}


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