voice: add initial support for voice agents configuration

Bug-AGL: SPEC-2981
Signed-off-by: Raquel Medina <raquel.medina@konsulko.com>
Change-Id: I0195d914dc10f4fcdea1cb6df0e6a5859ad8269d

1 files changed, 213 insertions, 0 deletions

diff --git a/voice/voice.cpp b/voice/voice.cpp
new file mode 100644
index 0000000..71c93d2
--- /dev/null
+++ b/voice/voice.cpp
@@ -0,0 +1,213 @@
+/*
+ * Copyright (C) 2019 Konsulko Group
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <QStringList>
+#include "voice.h"
+#include "message.h"
+#include "messageengine.h"
+#include "responsemessage.h"
+#include "voicemessage.h"
+#include "voiceagentregistry.h"
+
+Voice::Voice (QUrl &url, QQmlContext *context, QObject *parent) :
+	QObject(parent),
+	m_loop(nullptr)
+{
+	m_loop = new MessageEngine(url);
+	m_var = new VoiceAgentRegistry(this, context, parent);
+
+	QObject::connect(m_loop, &MessageEngine::connected,
+			 this, &Voice::onConnected);
+	QObject::connect(m_loop, &MessageEngine::disconnected,
+			 this, &Voice::onDisconnected);
+	QObject::connect(m_loop, &MessageEngine::messageReceived,
+			 this, &Voice::onMessageReceived);
+}
+
+Voice::~Voice()
+{
+	delete m_loop;
+	delete m_var;
+}
+
+void Voice::scan()
+{
+	VoiceMessage *vmsg = new VshlCoreVoiceMessage();
+	QJsonObject parameter;
+
+	vmsg->createRequest("enumerateVoiceAgents", parameter);
+	m_loop->sendMessage(vmsg);
+	delete vmsg;
+}
+
+void Voice::getCBLpair(QString id)
+{
+	VoiceMessage *vmsg = new AlexaVoiceMessage();
+	QJsonObject parameter;
+
+	vmsg->createRequest("subscribeToCBLEvents", parameter);
+	m_loop->sendMessage(vmsg);
+	delete vmsg;
+}
+
+void Voice::subscribeAgentToVshlEvents(QString id)
+{
+	QJsonArray events = QJsonArray::fromStringList(vshl_events);
+	VoiceMessage *vmsg = new VshlCoreVoiceMessage();
+	QJsonObject parameter;
+
+	parameter.insert("va_id", id);
+	parameter.insert("events", events);
+	vmsg->createRequest("subscribe", parameter);
+	m_loop->sendMessage(vmsg);
+	delete vmsg;
+}
+
+void Voice::unsubscribeAgentFromVshlEvents(QString id)
+{
+	QJsonArray events = QJsonArray::fromStringList(vshl_events);
+	VoiceMessage *vmsg = new VshlCoreVoiceMessage();
+	QJsonObject parameter;
+
+	parameter.insert("va_id", id);
+	parameter.insert("events", events);
+	vmsg->createRequest("unsubscribe", parameter);
+	m_loop->sendMessage(vmsg);
+	delete vmsg;
+}
+
+void Voice::subscribeAgentToCblEvents(QString id)
+{
+	QJsonArray events = QJsonArray::fromStringList(cbl_events);
+	VoiceMessage *vmsg = new AlexaVoiceMessage();
+	QJsonObject parameter;
+
+	parameter.insert("va_id", id);
+	parameter.insert("events", events);
+	vmsg->createRequest("subscribeToCBLEvent", parameter);
+	m_loop->sendMessage(vmsg);
+	delete vmsg;
+}
+
+void Voice::parseAgentsList(QJsonArray agents)
+{
+	for (auto value : agents) {
+		QJsonObject a = value.toObject();
+		QString id = m_var->addAgent(a);
+		subscribeAgentToVshlEvents(id);
+	}
+}
+
+void Voice::processVshlEvent(VoiceMessage *vmsg)
+{
+	const QString str = vmsg->eventName();
+	const QJsonObject obj = vmsg->eventData();
+	QStringList strlist;
+
+	if (str.contains('#'))
+		strlist = str.split('#');
+	QString agentId = (strlist.isEmpty())?  m_var->getDefaultId() :
+						strlist.takeLast();
+	if (vmsg->isAuthStateEvent()) {
+		const QString authstate = obj.value("state").toString();
+		m_var->setAuthState(
+			agentId,
+			static_cast<VoiceAgentRegistry::ServiceAuthState>(
+				m_var->stringToEnum(authstate, "ServiceAuthState")));
+	} else if (vmsg->isConnectionStateEvent()) {
+		const QString connstate = obj.value("state").toString();
+		m_var->setConnectionState(
+			agentId,
+			static_cast<VoiceAgentRegistry::AgentConnectionState>(
+				m_var->stringToEnum(connstate, "AgentConnectionState")));
+	} else if (vmsg->isDialogStateEvent()) {
+		const QString dialogstate = obj.value("state").toString();
+		m_var->setDialogState(
+			agentId,
+			static_cast<VoiceAgentRegistry::VoiceDialogState>(
+			m_var->stringToEnum(dialogstate, "VoiceDialogState")));
+	} else
+		qWarning() << "Discarding vshl event:" << str;
+}
+
+void Voice::processCblEvent(VoiceMessage *vmsg)
+{
+	const QString str = vmsg->eventName();
+	const QJsonObject obj = vmsg->eventData();
+	QStringList strlist;
+
+	if (str.contains('#'))
+		strlist = str.split('#');
+	QString cblevent = (strlist.isEmpty())? QString() : strlist.takeFirst();
+	QString agentId =  (strlist.isEmpty())? m_var->getDefaultId() :
+						strlist.takeLast();
+	if (cblevent == "voice_cbl_codepair_received_event") {
+		QString code = obj.value("code").toString();
+		QString url = obj.value("url").toString();
+		m_var->updateCblPair(agentId, code, url, false);
+	} else if (cblevent == "voice_cbl_codepair_expired_event") {
+		QString code = obj.value("code").toString();
+		QString url = obj.value("url").toString();
+		m_var->updateCblPair(agentId, code, url, true);
+	} else
+		qWarning() << "Discarding cbl event:" << str;
+}
+
+void Voice::processEvent(VoiceMessage *vmsg)
+{
+	const QString api = vmsg->eventApi();
+	if (api == "vshl-core")
+		processVshlEvent(vmsg);
+	else if (api == "alexa-voiceagent")
+		processCblEvent(vmsg);
+	else
+		qWarning() << "Unknown api:" << api;
+}
+
+void Voice::processReply(ResponseMessage *rmsg)
+{
+	if (rmsg->requestVerb() == "enumerateVoiceAgents") {
+		parseAgentsList(rmsg->replyData().value("agents").toArray());
+		m_var->setDefaultId(
+				rmsg->replyData().value("default").toString());
+	} else
+		qWarning() << "Reply received for unknown verb:" <<
+							rmsg->requestVerb();
+}
+
+void Voice::onConnected()
+{
+	scan();
+}
+
+void Voice::onDisconnected()
+{
+	QStringList mvarlist = m_var->getAgentsListById();
+	QStringList::iterator it;
+	for (it = mvarlist.begin(); it != mvarlist.end(); ++it)
+		unsubscribeAgentFromVshlEvents(*it);
+}
+
+void Voice::onMessageReceived(MessageType type, Message *msg)
+{
+	if (msg->isEvent() && type == VoiceEventMessage) {
+		processEvent(qobject_cast<VoiceMessage*>(msg));
+	} else if (msg->isReply() && (type == ResponseRequestMessage)) {
+		processReply(qobject_cast<ResponseMessage*>(msg));
+	} else
+		qWarning() << "Received unknown message type:" << type;
+	msg->deleteLater();
+}