diff options
Diffstat (limited to 'assets/cert')
0 files changed, 0 insertions, 0 deletions
 |
index : flutter-instrument-cluster | |
| flutter-based instrument-cluster | Grokmirror user |
| summaryrefslogtreecommitdiffstats |
|
index : flutter-instrument-cluster | |
| flutter-based instrument-cluster | Grokmirror user |
| summaryrefslogtreecommitdiffstats |
/*
* Copyright (C) 2017 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 "message.h"
#include "messageengine.h"
#include "bluetoothmessage.h"
#include "mapmessage.h"
#include "mediaplayermessage.h"
#include "navigationmessage.h"
#include "networkmessage.h"
#include "pbapmessage.h"
#include "radiomessage.h"
#include "responsemessage.h"
#include "telephonymessage.h"
#include "weathermessage.h"
#include "voicemessage.h"
#include "signalcomposermessage.h"
#include <QJsonArray>
MessageEngine::MessageEngine(const QUrl &url, QObject *parent) :
QObject(parent),
m_callid(0),
m_url(url)
{
connect(&m_websocket, &QWebSocket::connected, this, &MessageEngine::onConnected);
connect(&m_websocket, &QWebSocket::disconnected, this, &MessageEngine::onDisconnected);
m_websocket.open(url);
}
unsigned int MessageEngine::requestCallId()
{
int callid;
m_mutex.lock();
callid = ++m_callid;
m_mutex.unlock();
return callid;
}
bool MessageEngine::sendMessage(Message *message)
{
if (!message->isValid())
return false;
auto callid = requestCallId();
message->setCallId(callid);
QByteArray data = message->toJson().data();
qint64 size = m_websocket.sendTextMessage(data);
if (size == 0)
return false;
m_calls.insert(callid, data);
return true;
}
void MessageEngine::onConnected()
{
connect(&m_websocket, &QWebSocket::textMessageReceived, this, &MessageEngine::onTextMessageReceived);
emit connected();
}
void MessageEngine::onDisconnected()
{
disconnect(&m_websocket, &QWebSocket::textMessageReceived, this, &MessageEngine::onTextMessageReceived);
emit disconnected();
}
void MessageEngine::onTextMessageReceived(QString jsonStr)
{
jsonStr = jsonStr.simplified();
QJsonDocument jdoc(QJsonDocument::fromJson(jsonStr.toUtf8()));
if (jdoc.isEmpty()) {
qWarning() << "Received invalid JSON: empty appfw message";
return;
}
QJsonArray msg = jdoc.array();
int msgid = msg[0].toInt();
Message *message;
MessageType type;
switch (msgid) {
case RetOk:
case RetErr: {
auto callid = msg[1].toString().toInt();
message = new ResponseMessage(m_calls[callid]);
type = ResponseRequestMessage;
m_calls.remove(callid);
break;
}
case Event: {
QStringList api_str_list = msg[1].toString().split(QRegExp("/"));
QString api = api_str_list[0].toLower();
// FIXME: This should be rewritten using a factory class with a
// parser parameter to remove API specific handling here
if (api == "bluetooth-manager") {
message = new BluetoothMessage;
type = BluetoothEventMessage;
} else if (api == "bluetooth-pbap") {
message = new PbapMessage;
type = PbapEventMessage;
} else if (api == "telephony") {
message = new TelephonyMessage;
type = TelephonyEventMessage;
} else if (api == "weather") {
message = new WeatherMessage;
type = WeatherEventMessage;
} else if (api == "mediaplayer") {
message = new MediaplayerMessage;
type = MediaplayerEventMessage;
} else if (api == "navigation") {
message = new NavigationMessage;
type = NavigationEventMessage;
} else if (api == "network-manager") {
message = new NetworkMessage;
type = NetworkEventMessage;
} else if (api == "radio") {
message = new RadioMessage;
type = RadioEventMessage;
} else if (api == "bluetooth-map") {
message = new MapMessage;
type = MapEventMessage;
} else if (api == "vshl-core" ) {
message = new VoiceMessage;
type = VoiceEventMessage;
} else if (api == "signal-composer") {
message = new SignalComposerMessage;
type = SignalComposerEventMessage;
} else {
message = new Message;
type = GenericMessage;
}
break;
}
default:
break;
}
if (message->fromJDoc(jdoc) == false) {
delete message;
return;
}
emit messageReceived(type, message);
}