Fixed bugs and worked on MMI bridge

2 files changed, 118 insertions, 0 deletions

diff --git a/src/uscxml/plugins/invoker/vxml/VoiceXMLInvoker.cpp b/src/uscxml/plugins/invoker/vxml/VoiceXMLInvoker.cpp
new file mode 100644
index 0000000..e7d1440
--- /dev/null
+++ b/src/uscxml/plugins/invoker/vxml/VoiceXMLInvoker.cpp
@@ -0,0 +1,67 @@
+#include "VoiceXMLInvoker.h"
+#include <glog/logging.h>
+
+#ifdef BUILD_AS_PLUGINS
+#include <Pluma/Connector.hpp>
+#endif
+
+namespace uscxml {
+
+#ifdef BUILD_AS_PLUGINS
+PLUMA_CONNECTOR
+bool connect(pluma::Host& host) {
+	host.add( new VoiceXMLInvokerProvider() );
+	return true;
+}
+#endif
+
+VoiceXMLInvoker::VoiceXMLInvoker() {
+}
+
+VoiceXMLInvoker::~VoiceXMLInvoker() {
+};
+
+boost::shared_ptr<IOProcessorImpl> VoiceXMLInvoker::create(InterpreterImpl* interpreter) {
+	boost::shared_ptr<VoiceXMLInvoker> invoker = boost::shared_ptr<VoiceXMLInvoker>(new VoiceXMLInvoker());
+	invoker->_interpreter = interpreter;
+	invoker->_pub = umundo::TypedPublisher("mmi:jvoicexml");
+	invoker->_sub = umundo::TypedSubscriber("mmi:jvoicexml");
+
+	invoker->_pub.registerType("LifeCycleEvent", new ::LifeCycleEvent());
+
+	
+	invoker->_node.addPublisher(invoker->_pub);
+	invoker->_node.addSubscriber(invoker->_sub);
+
+	return invoker;
+}
+
+void VoiceXMLInvoker::receive(void* object, umundo::Message* msg) {
+	std::cout << msg->getMeta("um.s11n.type") << std::endl;
+}
+
+Data VoiceXMLInvoker::getDataModelVariables() {
+	Data data;
+	return data;
+}
+
+void VoiceXMLInvoker::send(const SendRequest& req) {
+	StartRequest start;
+	std::stringstream domSS;
+	domSS << req.getFirstDOMElement();
+	start.content = domSS.str();
+	
+	start.contentURL.href = "http://localhost/~sradomski/hello.vxml";
+	start.requestId = "asdf";
+	start.source = "asdf";
+	start.target = "umundo://mmi/jvoicexml";
+	::LifeCycleEvent lce = MMIProtoBridge::toProto(start);
+	_pub.sendObj("LifeCycleEvent", &lce);
+}
+
+void VoiceXMLInvoker::invoke(const InvokeRequest& req) {
+	_pub.waitForSubscribers(1);
+	
+}
+
+}
\ No newline at end of file
diff --git a/src/uscxml/plugins/invoker/vxml/VoiceXMLInvoker.h b/src/uscxml/plugins/invoker/vxml/VoiceXMLInvoker.h
new file mode 100644
index 0000000..450af5d
--- /dev/null
+++ b/src/uscxml/plugins/invoker/vxml/VoiceXMLInvoker.h
@@ -0,0 +1,51 @@
+#ifndef VOICEXMLINVOKER_H_W09J90F0
+#define VOICEXMLINVOKER_H_W09J90F0
+
+#include <uscxml/Interpreter.h>
+#include <uscxml/plugins/ioprocessor/modality/MMIComponent.h>
+#include <uscxml/plugins/ioprocessor/modality/MMIProtoBridge.h>
+
+#include <umundo/core.h>
+#include <umundo/s11n.h>
+
+#ifdef BUILD_AS_PLUGINS
+#include "uscxml/plugins/Plugins.h"
+#endif
+
+namespace uscxml {
+
+class VoiceXMLInvoker : public InvokerImpl, public umundo::TypedReceiver {
+public:
+	VoiceXMLInvoker();
+	virtual ~VoiceXMLInvoker();
+	virtual boost::shared_ptr<IOProcessorImpl> create(InterpreterImpl* interpreter);
+
+	virtual std::set<std::string> getNames() {
+		std::set<std::string> names;
+		names.insert("vxml");
+		names.insert("voicexml");
+		names.insert("http://www.w3.org/TR/voicexml21/");
+		return names;
+	}
+
+	virtual void receive(void* object, umundo::Message* msg);
+
+	virtual Data getDataModelVariables();
+	virtual void send(const SendRequest& req);
+	virtual void invoke(const InvokeRequest& req);
+
+	
+protected:
+	umundo::Node _node;
+	umundo::TypedPublisher _pub;
+	umundo::TypedSubscriber _sub;
+};
+
+#ifdef BUILD_AS_PLUGINS
+PLUMA_INHERIT_PROVIDER(VoiceXMLInvoker, InvokerImpl);
+#endif
+
+}
+
+
+#endif /* end of include guard: VOICEXMLINVOKER_H_W09J90F0 */