summaryrefslogtreecommitdiffstats
path: root/hvac/hvac.cpp
diff options
context:
space:
mode:
authorRaquel Medina <raquel.medina@konsulko.com>2020-03-18 23:56:31 +0100
committerRaquel Medina <raquel.medina@konsulko.com>2020-03-23 14:02:28 +0100
commit0ed292d3ccf93c889734960676a321d1166d3f66 (patch)
treeb8d64d1685d2f4bf599ab3867a0d3ff557ff0479 /hvac/hvac.cpp
parent5c750385d02116a92fa4c120ccc26abb8267bc97 (diff)
rework message hierarchy
Rework message hierarchy with the final objective of splitting libqtappfw into several libraries. This commit carries the following changes: - Simplify message hierarchy, keeping abstract Message class, adding specialization for call and event messages, keeping ResponseMessage, and removing all module specific specializations. - Add MessageFactory class to create message objects. - Change messages life cycle: using smart pointers and removing QObject from message hierarchy (a Message is not a QObject anymore and thus 'deleteLater()' is not available). - Adapt all modules to use new message hierarchy. - Keep ResponseMessage original constructor to avoid breaking TaskManager. - Message constructors have been kept public, but will go private on a follow-up patch (once TaskManager class has been modified to use new MessageFactory). Bug-AGL: SPEC-3112 Signed-off-by: Raquel Medina <raquel.medina@konsulko.com> Change-Id: I3a7a6325209ddeca2293f1ac745371861a947bfb
Diffstat (limited to 'hvac/hvac.cpp')
-rw-r--r--hvac/hvac.cpp32
1 files changed, 20 insertions, 12 deletions
diff --git a/hvac/hvac.cpp b/hvac/hvac.cpp
index f9e509b..23aef30 100644
--- a/hvac/hvac.cpp
+++ b/hvac/hvac.cpp
@@ -19,9 +19,9 @@
#include <QMimeDatabase>
#include <QtQml/QQmlEngine>
-#include "message.h"
-#include "hvacmessage.h"
-#include "responsemessage.h"
+#include "callmessage.h"
+#include "eventmessage.h"
+#include "messagefactory.h"
#include "messageengine.h"
#include "hvac.h"
@@ -45,13 +45,16 @@ HVAC::~HVAC()
void HVAC::control(QString verb, QString field, int value)
{
- HVACMessage *tmsg = new HVACMessage();
+ std::unique_ptr<Message> msg = MessageFactory::getInstance().createOutboundMessage(MessageId::Call);
+ if (!msg)
+ return;
+
+ CallMessage* hmsg = static_cast<CallMessage*>(msg.get());
QJsonObject parameter;
parameter.insert(field, value);
- tmsg->createRequest(verb, parameter);
- m_mloop->sendMessage(tmsg);
- delete tmsg;
+ hmsg->createRequest("hvac", verb, parameter);
+ m_mloop->sendMessage(std::move(msg));
}
void HVAC::set_fanspeed(int speed)
@@ -75,14 +78,19 @@ void HVAC::set_temp_right_zone(int temp)
emit rightTemperatureChanged(temp);
}
-void HVAC::onMessageReceived(MessageType type, Message *msg)
+void HVAC::onMessageReceived(std::shared_ptr<Message> msg)
{
- if (msg->isEvent() && type == MessageType::HVACEventMessage) {
- HVACMessage *tmsg = qobject_cast<HVACMessage*>(msg);
+ if (!msg)
+ return;
+
+ if (msg->isEvent()) {
+ std::shared_ptr<EventMessage> emsg = std::static_pointer_cast<EventMessage>(msg);
+ if (emsg->eventApi() != "hvac")
+ return;
- if (tmsg->isLanguageEvent()) {
+ if (emsg->eventName() == "language") {
// TODO: cannot be currently tested with identity service
- QVariantMap data = tmsg->eventData().toVariantMap();
+ QVariantMap data = emsg->eventData().toVariantMap();
emit languageChanged(data.value("language").toString());
}
}