From 389b5994553fdae59d484068d542910efee79e9c Mon Sep 17 00:00:00 2001 From: Matt Porter Date: Mon, 25 Jun 2018 11:01:11 -0400 Subject: Reorg binding-specific modules into subdirectories Move binding-specific code into per-binding subdirectories. This separates the core message engine code and simplifies adding new binding-specific modules. Bug-AGL: SPEC-1525 Change-Id: I8fc545e3af375e2ed9e79a41363b7ade97e9b20a Signed-off-by: Matt Porter --- weather/CMakeLists.txt | 2 ++ weather/weather.cpp | 67 ++++++++++++++++++++++++++++++++++++++++++++++ weather/weather.h | 52 +++++++++++++++++++++++++++++++++++ weather/weathermessage.cpp | 34 +++++++++++++++++++++++ weather/weathermessage.h | 37 +++++++++++++++++++++++++ 5 files changed, 192 insertions(+) create mode 100644 weather/CMakeLists.txt create mode 100644 weather/weather.cpp create mode 100644 weather/weather.h create mode 100644 weather/weathermessage.cpp create mode 100644 weather/weathermessage.h (limited to 'weather') diff --git a/weather/CMakeLists.txt b/weather/CMakeLists.txt new file mode 100644 index 0000000..44b4d4d --- /dev/null +++ b/weather/CMakeLists.txt @@ -0,0 +1,2 @@ +add_headers(weather.h weathermessage.h) +add_sources(weather.cpp weathermessage.cpp) diff --git a/weather/weather.cpp b/weather/weather.cpp new file mode 100644 index 0000000..a4edb2a --- /dev/null +++ b/weather/weather.cpp @@ -0,0 +1,67 @@ +/* + * Copyright (C) 2018 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 "weather.h" +#include "weathermessage.h" + +Weather::Weather (QUrl &url, QObject * parent) : + QObject(parent), + m_mloop(nullptr) +{ + m_mloop = new MessageEngine(url); + QObject::connect(m_mloop, &MessageEngine::connected, this, &Weather::onConnected); + QObject::connect(m_mloop, &MessageEngine::disconnected, this, &Weather::onDisconnected); + QObject::connect(m_mloop, &MessageEngine::messageReceived, this, &Weather::onMessageReceived); +} + +Weather::~Weather() +{ + delete m_mloop; +} + +void Weather::onConnected() +{ + WeatherMessage *tmsg = new WeatherMessage(); + tmsg->createRequest("subscribe", "weather"); + m_mloop->sendMessage(tmsg); + tmsg->deleteLater(); +} + +void Weather::onDisconnected() +{ + WeatherMessage *tmsg = new WeatherMessage(); + tmsg->createRequest("unsubscribe", "weather"); + m_mloop->sendMessage(tmsg); + tmsg->deleteLater(); +} + +void Weather::onMessageReceived(MessageType type, Message *message) +{ + if (type == WeatherEventMessage) { + WeatherMessage *tmsg = qobject_cast(message); + + if (tmsg->isEvent()) { + m_temperature = tmsg->temperature(); + m_condition = tmsg->condition(); + + emit temperatureChanged(m_temperature); + emit conditionChanged(m_condition); + } + } + message->deleteLater(); +} diff --git a/weather/weather.h b/weather/weather.h new file mode 100644 index 0000000..ffbbcc6 --- /dev/null +++ b/weather/weather.h @@ -0,0 +1,52 @@ +/* + * Copyright (C) 2018 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. + */ + +#ifndef WEATHER_H +#define WEATHER_H + +#include +#include + +#include "messageengine.h" + +class Weather : public QObject +{ + Q_OBJECT + Q_PROPERTY(QString temperature READ temperature NOTIFY temperatureChanged) + Q_PROPERTY(QString condition READ condition NOTIFY conditionChanged) + + public: + explicit Weather(QUrl &url, QObject * parent = Q_NULLPTR); + virtual ~Weather(); + + QString temperature() { return m_temperature; } + QString condition() { return m_condition; } + + signals: + void temperatureChanged(QString temperature); + void conditionChanged(QString condition); + + private: + MessageEngine *m_mloop; + QString m_temperature; + QString m_condition; + + void onConnected(); + void onDisconnected(); + void onMessageReceived(MessageType, Message*); +}; + +#endif // WEATHER_H diff --git a/weather/weathermessage.cpp b/weather/weathermessage.cpp new file mode 100644 index 0000000..6b4aa3c --- /dev/null +++ b/weather/weathermessage.cpp @@ -0,0 +1,34 @@ +/* + * Copyright (C) 2018 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 +#include +#include +#include + +#include "weathermessage.h" + +bool WeatherMessage::createRequest(QString verb, QString value) +{ + QStringList verbs {"current_weather", "subscribe", "unsubscribe"}; + if (!verbs.contains(verb)) + return false; + + QJsonObject parameter; + parameter.insert("value", value); + + return Message::createRequest("weather", verb, parameter); +} diff --git a/weather/weathermessage.h b/weather/weathermessage.h new file mode 100644 index 0000000..e1d4dac --- /dev/null +++ b/weather/weathermessage.h @@ -0,0 +1,37 @@ +/* + * Copyright (C) 2018 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. + */ + +#ifndef WEATHER_MESSAGE_H +#define WEATHER_MESSAGE_H + +#include +#include +#include "message.h" + +class WeatherMessage : public Message +{ + Q_OBJECT + public: + bool createRequest(QString verb, QString value = "None"); + QString condition() { + return m_event_data.value("weather").toArray().at(0).toObject().value("description").toString(); + }; + QString temperature() { + return QString::number(m_event_data.value("main").toObject().value("temp").toDouble()); + }; +}; + +#endif // WEATHER_MESSAGE_H -- cgit 1.2.3-korg