diff options
author | Matt Porter <mporter@konsulko.com> | 2017-11-08 08:57:32 -0500 |
---|---|---|
committer | Matt Porter <mporter@konsulko.com> | 2017-11-09 08:24:23 -0500 |
commit | 112fc8be473f02befc7596750ad7044113f29849 (patch) | |
tree | 5e70e7dc6c33a5cde68bad84165144ea9a86d7ab /message.cpp | |
parent | a2fa6ce695f8532a8f974990b3b12dded18caa92 (diff) |
Add base AGL libqtappfw and Telephony supporteel_4.99.3eel/4.99.34.99.3
Implements several QtObject subclasses that wrap
functionality provided by the AGL Application Framework.
* Message provides facilities to create new AppFW requests
and parse AppFw replies/events from a JSON buffer.
* MessageEngine provides a websocket message processing client
that can send or receive Messages on a given websocket address.
* TelephonyMessage subclasses Message to provide accessors and
methods specific to the AGL Telephony API.
* Telephony provides a complete set of Qt properties/signals/methods
that expose the AGL Telephony functionality to Qt/QML applications.
An application normally instantiates only this class and has no
need to handle low-level AppFW messages.
Bug-AGL: SPEC-1064
Change-Id: I2e41fb866bb4f867c81ccaf9bf33d627893879c8
Signed-off-by: Matt Porter <mporter@konsulko.com>
Diffstat (limited to 'message.cpp')
-rw-r--r-- | message.cpp | 137 |
1 files changed, 137 insertions, 0 deletions
diff --git a/message.cpp b/message.cpp new file mode 100644 index 0000000..014e8e7 --- /dev/null +++ b/message.cpp @@ -0,0 +1,137 @@ +/* + * 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 <QDebug> +#include <QJsonArray> +#include <QJsonDocument> +#include <QJsonObject> +#include <QJsonValue> + +#include "message.h" + +Message::Message() + : m_init(false), m_event(false), m_reply(false) +{ +} + +bool Message::createRequest(QString api, QString verb, QJsonValue parameter) +{ + QJsonArray *request = new QJsonArray; + request->append(Call); + request->append(9999); + request->append(api + (QString)("/") + verb); + request->append(QJsonValue(parameter)); + + QJsonDocument jdoc; + jdoc.setArray(*request); + + m_jdoc = jdoc; + m_init = true; + + return true; +} + +bool Message::fromJson(QByteArray jsonData) +{ + QJsonDocument jdoc(QJsonDocument::fromJson(jsonData)); + + if (jdoc.isNull()) { + qWarning("Imported invalid JSON: empty appfw message"); + return false; + } + + return Message::fromJDoc(jdoc); +} + +bool Message::fromJDoc(QJsonDocument jdoc) +{ + // Validate message is array + if (!jdoc.isArray()) { + qWarning("Invalid appfw message: not an array"); + return false; + } + QJsonArray msg = jdoc.array(); + + // Validate array is proper length + if ((msg.size() < 3) || (msg.size() > 4)) { + qWarning("Invalid appfw message: invalid array size"); + return false; + } + + // Validate msgid type + double msgid; + if (msg[0].isDouble()) { + msgid = msg[0].toDouble(); + } else { + qWarning("Invalid appfw message: invalid msgid type"); + return false; + } + + // Validate msgid element + if ((msgid < Call) || (msgid > Event)) { + qWarning("Invalid appfw message: msgid out of range"); + return false; + } + + // Validate that the payload has a request object + QJsonObject payload; + if (msg[2].isObject()) { + payload = msg[2].toObject(); + } else { + qWarning("Invalid appfw payload: no JSON object"); + return false; + } + + if ((msgid == RetOk) || (msgid == RetErr)) { + auto request_iter = payload.find("request"); + auto request = request_iter.value().toObject(); + if (request.empty()) { + qWarning("Invalid appfw reply message: empty request data"); + return false; + } + auto status_iter = request.find("status"); + m_reply_status = status_iter.value().toString(); + m_reply = true; + } else if (msgid == Event) { + // If event, save data object + auto data_iter = payload.find("data"); + m_event_data = data_iter.value().toObject(); + + auto event_iter = payload.find("event"); + auto event_string = event_iter.value().toString(); + if (event_string.isEmpty()) { + qWarning("Invalid appfw event message: empty event name"); + return false; + } + QStringList event_strings = event_string.split(QRegExp("/")); + if (event_strings.size() != 2) { + qWarning("Invalid appfw event message: malformed event name"); + return false; + } + m_event_api = event_strings[0]; + m_event_name = event_strings[1]; + m_event = true; + } + + m_jdoc = jdoc; + m_init = true; + return m_init; +} + +QByteArray Message::toJson(QJsonDocument::JsonFormat format) +{ + return m_jdoc.toJson(format).data(); +} |