diff options
Diffstat (limited to 'voice/voice.cpp')
| -rw-r--r-- | voice/voice.cpp | 213 |
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(); +} |