666 lines
36 KiB
C++
666 lines
36 KiB
C++
/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
|
|
*
|
|
* Copyright 2013 - 2022, nymea GmbH
|
|
* Contact: contact@nymea.io
|
|
*
|
|
* This file is part of nymea.
|
|
* This project including source code and documentation is protected by
|
|
* copyright law, and remains the property of nymea GmbH. All rights, including
|
|
* reproduction, publication, editing and translation, are reserved. The use of
|
|
* this project is subject to the terms of a license agreement to be concluded
|
|
* with nymea GmbH in accordance with the terms of use of nymea GmbH, available
|
|
* under https://nymea.io/license
|
|
*
|
|
* GNU Lesser General Public License Usage
|
|
* Alternatively, this project may be redistributed and/or modified under the
|
|
* terms of the GNU Lesser General Public License as published by the Free
|
|
* Software Foundation; version 3. This project is distributed in the hope that
|
|
* it will be useful, but WITHOUT ANY WARRANTY; without even the implied
|
|
* warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
* Lesser General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Lesser General Public License
|
|
* along with this project. If not, see <https://www.gnu.org/licenses/>.
|
|
*
|
|
* For any further details and any questions please contact us under
|
|
* contact@nymea.io or see our FAQ/Licensing Information on
|
|
* https://nymea.io/license/faq
|
|
*
|
|
* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
|
|
|
|
#include "integrationpluginsomfytahoma.h"
|
|
|
|
#include <QJsonDocument>
|
|
#include <QJsonObject>
|
|
#include <QJsonArray>
|
|
|
|
#include "network/networkaccessmanager.h"
|
|
#include "network/zeroconf/zeroconfservicebrowser.h"
|
|
#include "platform/platformzeroconfcontroller.h"
|
|
|
|
#include "plugininfo.h"
|
|
#include "somfytahomarequests.h"
|
|
|
|
void IntegrationPluginSomfyTahoma::init()
|
|
{
|
|
m_zeroConfBrowser = hardwareManager()->zeroConfController()->createServiceBrowser("_kizboxdev._tcp");
|
|
}
|
|
|
|
void IntegrationPluginSomfyTahoma::discoverThings(ThingDiscoveryInfo *info)
|
|
{
|
|
foreach (const ZeroConfServiceEntry &entry, m_zeroConfBrowser->serviceEntries()) {
|
|
qCDebug(dcSomfyTahoma()) << "Found local gateway:" << entry;
|
|
|
|
ThingDescriptor descriptor(info->thingClassId(), "Somfy TaHoma Gateway", entry.hostAddress().toString());
|
|
ParamList params;
|
|
params << Param(gatewayThingGatewayIdParamTypeId, entry.name());
|
|
params << Param(gatewayThingGatewayPinParamTypeId, entry.txt("gateway_pin"));
|
|
descriptor.setParams(params);
|
|
|
|
Things existingThings = myThings().filterByParam(gatewayThingGatewayIdParamTypeId, entry.name());
|
|
if (existingThings.count() == 1) {
|
|
qCDebug(dcSomfyTahoma()) << "This gateway already exists in the system!";
|
|
descriptor.setThingId(existingThings.first()->id());
|
|
}
|
|
|
|
info->addThingDescriptor(descriptor);
|
|
}
|
|
|
|
info->finish(Thing::ThingErrorNoError);
|
|
}
|
|
|
|
void IntegrationPluginSomfyTahoma::startPairing(ThingPairingInfo *info)
|
|
{
|
|
info->finish(Thing::ThingErrorNoError, QT_TR_NOOP("Please enter the cloud login credentials for Somfy TaHoma in order to set up local access to the Gateway."));
|
|
}
|
|
|
|
void IntegrationPluginSomfyTahoma::confirmPairing(ThingPairingInfo *info, const QString &username, const QString &password)
|
|
{
|
|
// Request local token from cloud account.
|
|
SomfyTahomaRequest *request = createCloudSomfyTahomaLoginRequest(hardwareManager()->networkManager(), username, password, this);
|
|
connect(request, &SomfyTahomaRequest::error, info, [info](){
|
|
info->finish(Thing::ThingErrorAuthenticationFailure, QT_TR_NOOP("Failed to login to Somfy TaHoma."));
|
|
});
|
|
connect(request, &SomfyTahomaRequest::finished, info, [this, info, username, password](const QVariant &/*result*/){
|
|
SomfyTahomaRequest *request = createCloudSomfyTahomaGetRequest(hardwareManager()->networkManager(), "/config/" + info->params().paramValue(gatewayThingGatewayPinParamTypeId).toString() + "/local/tokens/generate", this);
|
|
connect(request, &SomfyTahomaRequest::error, info, [info](){
|
|
info->finish(Thing::ThingErrorAuthenticationFailure, QT_TR_NOOP("Failed to generate token."));
|
|
});
|
|
connect(request, &SomfyTahomaRequest::finished, info, [this, info, username, password](const QVariant &result){
|
|
QString token = result.toMap()["token"].toString();
|
|
QJsonDocument jsonRequest{QJsonObject{
|
|
{"label", "nymea_" + info->thingId().toString()},
|
|
{"token", token},
|
|
{"scope", "devmode"},
|
|
}};
|
|
SomfyTahomaRequest *request = createCloudSomfyTahomaPostRequest(hardwareManager()->networkManager(), "/config/" + info->params().paramValue(gatewayThingGatewayPinParamTypeId).toString() + "/local/tokens", "application/json", jsonRequest.toJson(QJsonDocument::Compact), this);
|
|
connect(request, &SomfyTahomaRequest::error, info, [info](){
|
|
info->finish(Thing::ThingErrorAuthenticationFailure, QT_TR_NOOP("Failed to activate token."));
|
|
});
|
|
connect(request, &SomfyTahomaRequest::finished, info, [this, info, username, password, token](const QVariant &/*result*/){
|
|
pluginStorage()->beginGroup(info->thingId().toString());
|
|
pluginStorage()->setValue("username", username);
|
|
pluginStorage()->setValue("password", password);
|
|
pluginStorage()->setValue("token", token);
|
|
pluginStorage()->endGroup();
|
|
|
|
info->finish(Thing::ThingErrorNoError);
|
|
});
|
|
});
|
|
});
|
|
}
|
|
|
|
void IntegrationPluginSomfyTahoma::setupThing(ThingSetupInfo *info)
|
|
{
|
|
// Compatibility to older cloud based versions of the plugin.
|
|
if (info->thing()->thingClassId() == tahomaThingClassId ||
|
|
(info->thing()->thingClassId() == gatewayThingClassId && getToken(info->thing()).isEmpty())) {
|
|
info->finish(Thing::ThingErrorSetupFailed, QT_TR_NOOP("The Somfy Plugin switched to local connection. Please enable 'Developer Mode' on somfy.com, remove the account from Nymea and re-setup the Somfy TaHoma Gateway."));
|
|
return;
|
|
}
|
|
|
|
if (info->thing()->thingClassId() == gatewayThingClassId) {
|
|
SomfyTahomaRequest *request = createLocalSomfyTahomaGetRequest(hardwareManager()->networkManager(), getHost(info->thing()), getToken(info->thing()), "/setup", this);
|
|
connect(request, &SomfyTahomaRequest::error, info, [info](){
|
|
info->finish(Thing::ThingErrorHardwareFailure, QT_TR_NOOP("Failed to connect to gateway."));
|
|
});
|
|
connect(request, &SomfyTahomaRequest::finished, info, [info, this](const QVariant &result){
|
|
QList<ThingDescriptor> unknownDevices;
|
|
QUuid gatewayId = info->thing()->id();
|
|
|
|
info->thing()->setParamValue(gatewayThingGatewayIdParamTypeId, result.toMap()["gateways"].toList().first().toMap().value("gatewayId").toString());
|
|
|
|
foreach (const QVariant &deviceVariant, result.toMap()["devices"].toList()) {
|
|
QVariantMap deviceMap = deviceVariant.toMap();
|
|
QString type = deviceMap.value("controllableName").toString();
|
|
QString deviceUrl = deviceMap.value("deviceURL").toString();
|
|
QString label = deviceMap.value("label").toString();
|
|
|
|
if (type.startsWith(QStringLiteral("io:RollerShutter"))) {
|
|
Thing *thing = myThings().findByParams(ParamList() << Param(rollershutterThingDeviceUrlParamTypeId, deviceUrl));
|
|
if (thing) {
|
|
qCDebug(dcSomfyTahoma()) << "Found existing roller shutter:" << label << deviceUrl;
|
|
} else {
|
|
qCInfo(dcSomfyTahoma()) << "Found new roller shutter:" << label << deviceUrl;
|
|
ThingDescriptor descriptor(rollershutterThingClassId, label, QString(), gatewayId);
|
|
descriptor.setParams(ParamList() << Param(rollershutterThingDeviceUrlParamTypeId, deviceUrl));
|
|
unknownDevices.append(descriptor);
|
|
}
|
|
} else if (type == QStringLiteral("io:ExteriorVenetianBlindIOComponent")) {
|
|
Thing *thing = myThings().findByParams(ParamList() << Param(venetianblindThingDeviceUrlParamTypeId, deviceUrl));
|
|
if (thing) {
|
|
qCDebug(dcSomfyTahoma()) << "Found existing venetian blind:" << label << deviceUrl;
|
|
} else {
|
|
qCInfo(dcSomfyTahoma()) << "Found new venetian blind:" << label << deviceUrl;
|
|
ThingDescriptor descriptor(venetianblindThingClassId, label, QString(), gatewayId);
|
|
descriptor.setParams(ParamList() << Param(venetianblindThingDeviceUrlParamTypeId, deviceUrl));
|
|
unknownDevices.append(descriptor);
|
|
}
|
|
} else if (type == QStringLiteral("io:GarageOpenerIOComponent")) {
|
|
Thing *thing = myThings().findByParams(ParamList() << Param(garagedoorThingDeviceUrlParamTypeId, deviceUrl));
|
|
if (thing) {
|
|
qCDebug(dcSomfyTahoma()) << "Found existing garage door:" << label << deviceUrl;
|
|
} else {
|
|
qCInfo(dcSomfyTahoma()) << "Found new garage door:" << label << deviceUrl;
|
|
ThingDescriptor descriptor(garagedoorThingClassId, label, QString(), gatewayId);
|
|
descriptor.setParams(ParamList() << Param(garagedoorThingDeviceUrlParamTypeId, deviceUrl));
|
|
unknownDevices.append(descriptor);
|
|
}
|
|
} else if (type == QStringLiteral("io:HorizontalAwningIOComponent")) {
|
|
Thing *thing = myThings().findByParams(ParamList() << Param(awningThingDeviceUrlParamTypeId, deviceUrl));
|
|
if (thing) {
|
|
qCDebug(dcSomfyTahoma()) << "Found existing awning:" << label << deviceUrl;
|
|
} else {
|
|
qCInfo(dcSomfyTahoma()) << "Found new awning:" << label << deviceUrl;
|
|
ThingDescriptor descriptor(awningThingClassId, label, QString(), gatewayId);
|
|
descriptor.setParams(ParamList() << Param(awningThingDeviceUrlParamTypeId, deviceUrl));
|
|
unknownDevices.append(descriptor);
|
|
}
|
|
} else if (type == QStringLiteral("io:DimmableLightIOComponent")) {
|
|
Thing *thing = myThings().findByParams(ParamList() << Param(lightThingDeviceUrlParamTypeId, deviceUrl));
|
|
if (thing) {
|
|
qCDebug(dcSomfyTahoma()) << "Found existing light:" << label << deviceUrl;
|
|
} else {
|
|
qCInfo(dcSomfyTahoma()) << "Found new light:" << label << deviceUrl;
|
|
ThingDescriptor descriptor(lightThingClassId, label, QString(), gatewayId);
|
|
descriptor.setParams(ParamList() << Param(lightThingDeviceUrlParamTypeId, deviceUrl));
|
|
unknownDevices.append(descriptor);
|
|
}
|
|
} else if (type == QStringLiteral("io:StackComponent") ||
|
|
type.startsWith("internal:")) {
|
|
continue;
|
|
} else {
|
|
qCInfo(dcSomfyTahoma()) << "Found unsupperted Somfy device:" << label << type << deviceUrl;
|
|
}
|
|
}
|
|
info->finish(Thing::ThingErrorNoError);
|
|
if (!unknownDevices.isEmpty()) {
|
|
emit autoThingsAppeared(unknownDevices);
|
|
}
|
|
});
|
|
}
|
|
|
|
else if (info->thing()->thingClassId() == rollershutterThingClassId ||
|
|
info->thing()->thingClassId() == venetianblindThingClassId ||
|
|
info->thing()->thingClassId() == garagedoorThingClassId ||
|
|
info->thing()->thingClassId() == awningThingClassId ||
|
|
info->thing()->thingClassId() == lightThingClassId) {
|
|
info->finish(Thing::ThingErrorNoError);
|
|
}
|
|
}
|
|
|
|
void IntegrationPluginSomfyTahoma::postSetupThing(Thing *thing)
|
|
{
|
|
if (thing->thingClassId() != gatewayThingClassId) {
|
|
return;
|
|
}
|
|
|
|
// Call /setup and update the state of all devices
|
|
SomfyTahomaRequest *setupRequest = createLocalSomfyTahomaGetRequest(hardwareManager()->networkManager(), getHost(thing), getToken(thing), "/setup", this);
|
|
connect(setupRequest, &SomfyTahomaRequest::error, this, [this, thing](){
|
|
markDisconnected(thing);
|
|
});
|
|
connect(setupRequest, &SomfyTahomaRequest::finished, this, [this, thing](const QVariant &result){
|
|
thing->setStateValue(gatewayConnectedStateTypeId, true);
|
|
foreach (const QVariant &deviceVariant, result.toMap()["devices"].toList()) {
|
|
updateThingStates(deviceVariant.toMap()["deviceURL"].toString(), deviceVariant.toMap()["states"].toList());
|
|
}
|
|
});
|
|
|
|
// Register event handler
|
|
SomfyTahomaRequest *eventRegistrationRequest = createLocalSomfyTahomaPostRequest(hardwareManager()->networkManager(), getHost(thing), getToken(thing), "/events/register", "application/json", QByteArray(), this);
|
|
connect(eventRegistrationRequest, &SomfyTahomaRequest::error, this, [this, thing](){
|
|
markDisconnected(thing);
|
|
});
|
|
connect(eventRegistrationRequest, &SomfyTahomaRequest::finished, this, [this, thing](const QVariant &result){
|
|
QString eventListenerId = result.toMap()["id"].toString();
|
|
m_eventPollTimer[thing] = hardwareManager()->pluginTimerManager()->registerTimer(2 /*sec*/);
|
|
connect(m_eventPollTimer[thing], &PluginTimer::timeout, thing, [this, thing, eventListenerId](){
|
|
SomfyTahomaRequest *eventFetchRequest = createLocalSomfyTahomaEventFetchRequest(hardwareManager()->networkManager(), getHost(thing), getToken(thing), eventListenerId, this);
|
|
connect(eventFetchRequest, &SomfyTahomaRequest::error, thing, [this, thing](QNetworkReply::NetworkError error){
|
|
qCWarning(dcSomfyTahoma()) << "Failed to fetch events:" << error;
|
|
markDisconnected(thing);
|
|
});
|
|
connect(eventFetchRequest, &SomfyTahomaRequest::finished, thing, [this, thing](const QVariant &result){
|
|
thing->setStateValue(gatewayConnectedStateTypeId, true);
|
|
restoreChildConnectedState(thing);
|
|
handleEvents(result.toList());
|
|
});
|
|
});
|
|
});
|
|
}
|
|
|
|
void IntegrationPluginSomfyTahoma::thingRemoved(Thing *thing)
|
|
{
|
|
m_eventPollTimer.remove(thing);
|
|
|
|
if (thing->thingClassId() != gatewayThingClassId) {
|
|
return;
|
|
}
|
|
|
|
// Unregister local token from cloud account.
|
|
pluginStorage()->beginGroup(thing->id().toString());
|
|
QString username = pluginStorage()->value("username").toString();
|
|
QString password = pluginStorage()->value("password").toString();
|
|
QString gatewayPin = thing->paramValue(gatewayThingGatewayPinParamTypeId).toString();
|
|
QString tokenName = "nymea_" + thing->id().toString();
|
|
pluginStorage()->endGroup();
|
|
|
|
SomfyTahomaRequest *request = createCloudSomfyTahomaLoginRequest(hardwareManager()->networkManager(), username, password, this);
|
|
connect(request, &SomfyTahomaRequest::error, this, [](){
|
|
qCWarning(dcSomfyTahoma()) << "Failed to login to Somfy TaHoma.";
|
|
});
|
|
connect(request, &SomfyTahomaRequest::finished, this, [this, gatewayPin, tokenName](const QVariant &/*result*/){
|
|
SomfyTahomaRequest *request = createCloudSomfyTahomaGetRequest(hardwareManager()->networkManager(), "/config/" + gatewayPin + "/local/tokens/devmode", this);
|
|
connect(request, &SomfyTahomaRequest::error, this, [](){
|
|
qCWarning(dcSomfyTahoma()) << "Failed to get list of tokens.";
|
|
});
|
|
connect(request, &SomfyTahomaRequest::finished, this, [this, gatewayPin, tokenName](const QVariant &result){
|
|
foreach (const QVariant &tokenVariant, result.toList()) {
|
|
QVariantMap tokenMap = tokenVariant.toMap();
|
|
QString label = tokenMap["label"].toString();
|
|
QString uuid = tokenMap["uuid"].toString();
|
|
if (label == tokenName) {
|
|
SomfyTahomaRequest *request = createCloudSomfyTahomaDeleteRequest(hardwareManager()->networkManager(), "/config/" + gatewayPin + "/local/tokens/" + uuid, this);
|
|
connect(request, &SomfyTahomaRequest::error, this, [](){
|
|
qCWarning(dcSomfyTahoma()) << "Failed to remove token.";
|
|
});
|
|
}
|
|
}
|
|
});
|
|
});
|
|
}
|
|
|
|
void IntegrationPluginSomfyTahoma::handleEvents(const QVariantList &events)
|
|
{
|
|
Thing *thing;
|
|
foreach (const QVariant &eventVariant, events) {
|
|
QVariantMap eventMap = eventVariant.toMap();
|
|
|
|
QString device = eventMap["deviceURL"].toString();
|
|
thing = myThings().findByParams(ParamList() << Param(rollershutterThingDeviceUrlParamTypeId, eventMap["deviceURL"]));
|
|
if (thing) {
|
|
device = thing->name();
|
|
}
|
|
thing = myThings().findByParams(ParamList() << Param(venetianblindThingDeviceUrlParamTypeId, eventMap["deviceURL"]));
|
|
if (thing) {
|
|
device = thing->name();
|
|
}
|
|
thing = myThings().findByParams(ParamList() << Param(garagedoorThingDeviceUrlParamTypeId, eventMap["deviceURL"]));
|
|
if (thing) {
|
|
device = thing->name();
|
|
}
|
|
thing = myThings().findByParams(ParamList() << Param(awningThingDeviceUrlParamTypeId, eventMap["deviceURL"]));
|
|
if (thing) {
|
|
device = thing->name();
|
|
}
|
|
thing = myThings().findByParams(ParamList() << Param(lightThingDeviceUrlParamTypeId, eventMap["deviceURL"]));
|
|
if (thing) {
|
|
device = thing->name();
|
|
}
|
|
qCDebug(dcSomfyTahoma()) << "Got event" << eventMap["name"].toString() << "for device" << device;
|
|
qCDebug(dcSomfyTahoma()) << qUtf8Printable(QJsonDocument::fromVariant(eventVariant).toJson());
|
|
|
|
if (eventMap["name"] == "DeviceStateChangedEvent") {
|
|
updateThingStates(eventMap["deviceURL"].toString(), eventMap["deviceStates"].toList());
|
|
} else if (eventMap["name"] == "ExecutionRegisteredEvent") {
|
|
QList<Thing *> things;
|
|
foreach (const QVariant &action, eventMap["actions"].toList()) {
|
|
thing = myThings().findByParams(ParamList() << Param(rollershutterThingDeviceUrlParamTypeId, action.toMap()["deviceURL"]));
|
|
if (thing) {
|
|
thing->setStateValue(rollershutterMovingStateTypeId, true);
|
|
things.append(thing);
|
|
continue;
|
|
}
|
|
thing = myThings().findByParams(ParamList() << Param(venetianblindThingDeviceUrlParamTypeId, action.toMap()["deviceURL"]));
|
|
if (thing) {
|
|
thing->setStateValue(venetianblindMovingStateTypeId, true);
|
|
things.append(thing);
|
|
}
|
|
thing = myThings().findByParams(ParamList() << Param(garagedoorThingDeviceUrlParamTypeId, action.toMap()["deviceURL"]));
|
|
if (thing) {
|
|
thing->setStateValue(garagedoorMovingStateTypeId, true);
|
|
things.append(thing);
|
|
}
|
|
thing = myThings().findByParams(ParamList() << Param(awningThingDeviceUrlParamTypeId, action.toMap()["deviceURL"]));
|
|
if (thing) {
|
|
thing->setStateValue(awningMovingStateTypeId, true);
|
|
things.append(thing);
|
|
continue;
|
|
}
|
|
}
|
|
qCDebug(dcSomfyTahoma()) << "ExecutionRegisteredEvent" << eventMap["execId"];
|
|
m_currentExecutions.insert(eventMap["execId"].toString(), things);
|
|
} else if (eventMap["name"] == "ExecutionStateChangedEvent" &&
|
|
(eventMap["newState"] == "COMPLETED" || eventMap["newState"] == "FAILED")) {
|
|
QList<Thing *> things = m_currentExecutions.take(eventMap["execId"].toString());
|
|
foreach (Thing *thing, things) {
|
|
if (thing->thingClassId() == rollershutterThingClassId) {
|
|
thing->setStateValue(rollershutterMovingStateTypeId, false);
|
|
} else if (thing->thingClassId() == venetianblindThingClassId) {
|
|
thing->setStateValue(venetianblindMovingStateTypeId, false);
|
|
} else if (thing->thingClassId() == garagedoorThingClassId) {
|
|
thing->setStateValue(garagedoorMovingStateTypeId, false);
|
|
} else if (thing->thingClassId() == awningThingClassId) {
|
|
thing->setStateValue(awningMovingStateTypeId, false);
|
|
}
|
|
}
|
|
|
|
QPointer<ThingActionInfo> thingActionInfo = m_pendingActions.take(eventMap["execId"].toString());
|
|
if (!thingActionInfo.isNull()) {
|
|
if (eventMap["newState"] == "COMPLETED") {
|
|
qCDebug(dcSomfyTahoma()) << "Action finished" << thingActionInfo->thing() << thingActionInfo->action().actionTypeId();
|
|
thingActionInfo->finish(Thing::ThingErrorNoError);
|
|
} else if (eventMap["newState"] == "FAILED") {
|
|
qCWarning(dcSomfyTahoma()) << "Action failed" << thingActionInfo->thing() << thingActionInfo->action().actionTypeId();
|
|
thingActionInfo->finish(Thing::ThingErrorHardwareFailure);
|
|
} else {
|
|
qCWarning(dcSomfyTahoma()) << "Action in unknown state" << thingActionInfo->thing() << thingActionInfo->action().actionTypeId() << eventMap["newState"].toString();
|
|
thingActionInfo->finish(Thing::ThingErrorHardwareFailure);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
void IntegrationPluginSomfyTahoma::updateThingStates(const QString &deviceUrl, const QVariantList &stateList)
|
|
{
|
|
Thing *thing = myThings().findByParams(ParamList() << Param(rollershutterThingDeviceUrlParamTypeId, deviceUrl));
|
|
if (thing) {
|
|
foreach (const QVariant &stateVariant, stateList) {
|
|
QVariantMap stateMap = stateVariant.toMap();
|
|
if (stateMap["name"] == "core:ClosureState") {
|
|
thing->setStateValue(rollershutterPercentageStateTypeId, stateMap["value"]);
|
|
} else if (stateMap["name"] == "core:StatusState") {
|
|
thing->setStateValue(rollershutterConnectedStateTypeId, stateMap["value"] == "available");
|
|
pluginStorage()->beginGroup(thing->id().toString());
|
|
pluginStorage()->setValue("connected", stateMap["value"] == "available");
|
|
pluginStorage()->endGroup();
|
|
} else if (stateMap["name"] == "core:RSSILevelState") {
|
|
thing->setStateValue(rollershutterSignalStrengthStateTypeId, stateMap["value"]);
|
|
}
|
|
}
|
|
return;
|
|
}
|
|
thing = myThings().findByParams(ParamList() << Param(venetianblindThingDeviceUrlParamTypeId, deviceUrl));
|
|
if (thing) {
|
|
foreach (const QVariant &stateVariant, stateList) {
|
|
QVariantMap stateMap = stateVariant.toMap();
|
|
if (stateMap["name"] == "core:ClosureState") {
|
|
thing->setStateValue(venetianblindPercentageStateTypeId, stateMap["value"]);
|
|
} else if (stateMap["name"] == "core:SlateOrientationState") {
|
|
// Convert percentage (0%/100%, 50%=open) into degree (-90/+90)
|
|
int degree = (stateMap["value"].toInt() * 1.8) - 90;
|
|
thing->setStateValue(venetianblindAngleStateTypeId, degree);
|
|
} else if (stateMap["name"] == "core:StatusState") {
|
|
thing->setStateValue(venetianblindConnectedStateTypeId, stateMap["value"] == "available");
|
|
pluginStorage()->beginGroup(thing->id().toString());
|
|
pluginStorage()->setValue("connected", stateMap["value"] == "available");
|
|
pluginStorage()->endGroup();
|
|
} else if (stateMap["name"] == "core:RSSILevelState") {
|
|
thing->setStateValue(venetianblindSignalStrengthStateTypeId, stateMap["value"]);
|
|
}
|
|
}
|
|
return;
|
|
}
|
|
thing = myThings().findByParams(ParamList() << Param(garagedoorThingDeviceUrlParamTypeId, deviceUrl));
|
|
if (thing) {
|
|
foreach (const QVariant &stateVariant, stateList) {
|
|
QVariantMap stateMap = stateVariant.toMap();
|
|
if (stateMap["name"] == "core:ClosureState") {
|
|
thing->setStateValue(garagedoorPercentageStateTypeId, stateMap["value"]);
|
|
if (stateMap["value"] == 100) {
|
|
thing->setStateValue(garagedoorStateStateTypeId, "closed");
|
|
} else if (stateMap["value"] == 0) {
|
|
thing->setStateValue(garagedoorStateStateTypeId, "open");
|
|
} else {
|
|
thing->setStateValue(garagedoorStateStateTypeId, "intermediate");
|
|
}
|
|
} else if (stateMap["name"] == "core:StatusState") {
|
|
thing->setStateValue(garagedoorConnectedStateTypeId, stateMap["value"] == "available");
|
|
pluginStorage()->beginGroup(thing->id().toString());
|
|
pluginStorage()->setValue("connected", stateMap["value"] == "available");
|
|
pluginStorage()->endGroup();
|
|
} else if (stateMap["name"] == "core:RSSILevelState") {
|
|
thing->setStateValue(garagedoorSignalStrengthStateTypeId, stateMap["value"]);
|
|
}
|
|
}
|
|
return;
|
|
}
|
|
thing = myThings().findByParams(ParamList() << Param(awningThingDeviceUrlParamTypeId, deviceUrl));
|
|
if (thing) {
|
|
foreach (const QVariant &stateVariant, stateList) {
|
|
QVariantMap stateMap = stateVariant.toMap();
|
|
if (stateMap["name"] == "core:DeploymentState") {
|
|
thing->setStateValue(awningPercentageStateTypeId, stateMap["value"]);
|
|
} else if (stateMap["name"] == "core:StatusState") {
|
|
thing->setStateValue(awningConnectedStateTypeId, stateMap["value"] == "available");
|
|
pluginStorage()->beginGroup(thing->id().toString());
|
|
pluginStorage()->setValue("connected", stateMap["value"] == "available");
|
|
pluginStorage()->endGroup();
|
|
} else if (stateMap["name"] == "core:RSSILevelState") {
|
|
thing->setStateValue(awningSignalStrengthStateTypeId, stateMap["value"]);
|
|
}
|
|
}
|
|
return;
|
|
}
|
|
thing = myThings().findByParams(ParamList() << Param(lightThingDeviceUrlParamTypeId, deviceUrl));
|
|
if (thing) {
|
|
foreach (const QVariant &stateVariant, stateList) {
|
|
QVariantMap stateMap = stateVariant.toMap();
|
|
if (stateMap["name"] == "core:OnOffState") {
|
|
thing->setStateValue(lightPowerStateTypeId, stateMap["value"] == "on");
|
|
} else if (stateMap["name"] == "core:LightIntensityState") {
|
|
thing->setStateValue(lightBrightnessStateTypeId, stateMap["value"]);
|
|
} else if (stateMap["name"] == "core:StatusState") {
|
|
thing->setStateValue(lightConnectedStateTypeId, stateMap["value"] == "available");
|
|
pluginStorage()->beginGroup(thing->id().toString());
|
|
pluginStorage()->setValue("connected", stateMap["value"] == "available");
|
|
pluginStorage()->endGroup();
|
|
} else if (stateMap["name"] == "core:RSSILevelState") {
|
|
thing->setStateValue(lightSignalStrengthStateTypeId, stateMap["value"]);
|
|
}
|
|
}
|
|
return;
|
|
}
|
|
}
|
|
|
|
void IntegrationPluginSomfyTahoma::executeAction(ThingActionInfo *info)
|
|
{
|
|
qCInfo(dcSomfyTahoma()) << "Action request:" << info->thing() << info->action().actionTypeId() << info->action().params();
|
|
|
|
QString deviceUrl;
|
|
QString actionName;
|
|
QJsonArray actionParameters;
|
|
|
|
if (info->thing()->thingClassId() == rollershutterThingClassId) {
|
|
deviceUrl = info->thing()->paramValue(rollershutterThingDeviceUrlParamTypeId).toString();
|
|
if (info->action().actionTypeId() == rollershutterPercentageActionTypeId) {
|
|
actionName = "setClosureAndLinearSpeed";
|
|
actionParameters = { info->action().param(rollershutterPercentageActionPercentageParamTypeId).value().toInt(), "lowspeed" };
|
|
} else if (info->action().actionTypeId() == rollershutterOpenActionTypeId) {
|
|
actionName = "setClosureAndLinearSpeed";
|
|
actionParameters = { 0, "lowspeed" };
|
|
} else if (info->action().actionTypeId() == rollershutterCloseActionTypeId) {
|
|
actionName = "setClosureAndLinearSpeed";
|
|
actionParameters = { 100, "lowspeed" };
|
|
} else if (info->action().actionTypeId() == rollershutterStopActionTypeId) {
|
|
actionName = "stop";
|
|
}
|
|
} else if (info->thing()->thingClassId() == venetianblindThingClassId) {
|
|
deviceUrl = info->thing()->paramValue(venetianblindThingDeviceUrlParamTypeId).toString();
|
|
if (info->action().actionTypeId() == venetianblindPercentageActionTypeId) {
|
|
actionName = "setClosure";
|
|
actionParameters = { info->action().param(venetianblindPercentageActionPercentageParamTypeId).value().toInt() };
|
|
} else if (info->action().actionTypeId() == venetianblindAngleActionTypeId) {
|
|
actionName = "setOrientation";
|
|
// Convert degree (-90/+90) into percentage (0%/100%, 50%=open)
|
|
int degree = (info->action().param(venetianblindAngleActionAngleParamTypeId).value().toInt() + 90) / 1.8;
|
|
actionParameters = { degree };
|
|
} else if (info->action().actionTypeId() == venetianblindOpenActionTypeId) {
|
|
actionName = "open";
|
|
} else if (info->action().actionTypeId() == venetianblindCloseActionTypeId) {
|
|
actionName = "close";
|
|
} else if (info->action().actionTypeId() == venetianblindStopActionTypeId) {
|
|
actionName = "stop";
|
|
}
|
|
} else if (info->thing()->thingClassId() == garagedoorThingClassId) {
|
|
deviceUrl = info->thing()->paramValue(garagedoorThingDeviceUrlParamTypeId).toString();
|
|
if (info->action().actionTypeId() == garagedoorPercentageActionTypeId) {
|
|
actionName = "setClosure";
|
|
actionParameters = { info->action().param(garagedoorPercentageActionPercentageParamTypeId).value().toInt() };
|
|
} else if (info->action().actionTypeId() == garagedoorOpenActionTypeId) {
|
|
actionName = "open";
|
|
} else if (info->action().actionTypeId() == garagedoorCloseActionTypeId) {
|
|
actionName = "close";
|
|
} else if (info->action().actionTypeId() == garagedoorStopActionTypeId) {
|
|
actionName = "stop";
|
|
}
|
|
} else if (info->thing()->thingClassId() == awningThingClassId) {
|
|
deviceUrl = info->thing()->paramValue(awningThingDeviceUrlParamTypeId).toString();
|
|
if (info->action().actionTypeId() == awningPercentageActionTypeId) {
|
|
actionName = "setDeployment";
|
|
actionParameters = { info->action().param(awningPercentageActionPercentageParamTypeId).value().toInt() };
|
|
} else if (info->action().actionTypeId() == awningOpenActionTypeId) {
|
|
actionName = "deploy";
|
|
} else if (info->action().actionTypeId() == awningCloseActionTypeId) {
|
|
actionName = "undeploy";
|
|
} else if (info->action().actionTypeId() == awningStopActionTypeId) {
|
|
actionName = "stop";
|
|
}
|
|
} else if (info->thing()->thingClassId() == lightThingClassId) {
|
|
deviceUrl = info->thing()->paramValue(lightThingDeviceUrlParamTypeId).toString();
|
|
if (info->action().actionTypeId() == lightPowerActionTypeId) {
|
|
actionName = info->action().param(lightPowerActionPowerParamTypeId).value().toBool() ? "on" : "off";
|
|
} else if (info->action().actionTypeId() == lightBrightnessActionTypeId) {
|
|
actionName = "setIntensity";
|
|
actionParameters = { info->action().param(lightBrightnessActionBrightnessParamTypeId).value().toInt() };
|
|
}
|
|
}
|
|
|
|
if (!actionName.isEmpty()) {
|
|
QJsonDocument jsonRequest{QJsonObject
|
|
{
|
|
{"label", info->thing()->name()},
|
|
{"actions", QJsonArray{QJsonObject{{"deviceURL", deviceUrl},
|
|
{"commands", QJsonArray{QJsonObject{{"name", actionName},
|
|
{"parameters", actionParameters}}}}}}}
|
|
}};
|
|
SomfyTahomaRequest *request = createLocalSomfyTahomaPostRequest(hardwareManager()->networkManager(), getHost(info->thing()), getToken(info->thing()), "/exec/apply", "application/json", jsonRequest.toJson(QJsonDocument::Compact), this);
|
|
connect(request, &SomfyTahomaRequest::error, info, [info](){
|
|
info->finish(Thing::ThingErrorHardwareFailure);
|
|
});
|
|
connect(request, &SomfyTahomaRequest::finished, info, [this, info](const QVariant &result){
|
|
qCInfo(dcSomfyTahoma()) << "Action started" << info->thing() << info->action().actionTypeId();
|
|
m_pendingActions.insert(result.toMap()["execId"].toString(), info);
|
|
});
|
|
} else {
|
|
info->finish(Thing::ThingErrorActionTypeNotFound);
|
|
}
|
|
}
|
|
|
|
void IntegrationPluginSomfyTahoma::markDisconnected(Thing *thing)
|
|
{
|
|
if (thing->thingClassId() == gatewayThingClassId) {
|
|
thing->setStateValue(gatewayConnectedStateTypeId, false);
|
|
} else if (thing->thingClassId() == rollershutterThingClassId) {
|
|
thing->setStateValue(rollershutterConnectedStateTypeId, false);
|
|
} else if (thing->thingClassId() == venetianblindThingClassId) {
|
|
thing->setStateValue(venetianblindConnectedStateTypeId, false);
|
|
} else if (thing->thingClassId() == garagedoorThingClassId) {
|
|
thing->setStateValue(garagedoorConnectedStateTypeId, false);
|
|
} else if (thing->thingClassId() == awningThingClassId) {
|
|
thing->setStateValue(awningConnectedStateTypeId, false);
|
|
} else if (thing->thingClassId() == lightThingClassId) {
|
|
thing->setStateValue(lightConnectedStateTypeId, false);
|
|
}
|
|
foreach (Thing *child, myThings().filterByParentId(thing->id())) {
|
|
markDisconnected(child);
|
|
}
|
|
}
|
|
|
|
void IntegrationPluginSomfyTahoma::restoreChildConnectedState(Thing *thing)
|
|
{
|
|
pluginStorage()->beginGroup(thing->id().toString());
|
|
if (pluginStorage()->contains("connected")) {
|
|
if (thing->thingClassId() == rollershutterThingClassId) {
|
|
thing->setStateValue(rollershutterConnectedStateTypeId, pluginStorage()->value("connected").toBool());
|
|
} else if (thing->thingClassId() == venetianblindThingClassId) {
|
|
thing->setStateValue(venetianblindConnectedStateTypeId, pluginStorage()->value("connected").toBool());
|
|
} else if (thing->thingClassId() == garagedoorThingClassId) {
|
|
thing->setStateValue(garagedoorConnectedStateTypeId, pluginStorage()->value("connected").toBool());
|
|
} else if (thing->thingClassId() == awningThingClassId) {
|
|
thing->setStateValue(awningConnectedStateTypeId, pluginStorage()->value("connected").toBool());
|
|
} else if (thing->thingClassId() == lightThingClassId) {
|
|
thing->setStateValue(lightConnectedStateTypeId, pluginStorage()->value("connected").toBool());
|
|
}
|
|
}
|
|
pluginStorage()->endGroup();
|
|
foreach (Thing *child, myThings().filterByParentId(thing->id())) {
|
|
restoreChildConnectedState(child);
|
|
}
|
|
}
|
|
|
|
QString IntegrationPluginSomfyTahoma::getHost(Thing *thing) const
|
|
{
|
|
Thing *gateway = thing;
|
|
if (!thing->parentId().isNull()) {
|
|
gateway = myThings().findById(thing->parentId());
|
|
}
|
|
|
|
QString gatewayId = gateway->paramValue(gatewayThingGatewayIdParamTypeId).toString();
|
|
ZeroConfServiceEntry zeroConfEntry;
|
|
foreach (const ZeroConfServiceEntry &entry, m_zeroConfBrowser->serviceEntries()) {
|
|
if (entry.name() == gatewayId) {
|
|
zeroConfEntry = entry;
|
|
}
|
|
}
|
|
QString host;
|
|
pluginStorage()->beginGroup(gateway->id().toString());
|
|
if (zeroConfEntry.isValid()) {
|
|
host = zeroConfEntry.hostAddress().toString() + ":" + QString::number(zeroConfEntry.port());
|
|
pluginStorage()->setValue("cachedAddress", host);
|
|
} else if (pluginStorage()->contains("cachedAddress")){
|
|
host = pluginStorage()->value("cachedAddress").toString();
|
|
} else {
|
|
qCWarning(dcSomfyTahoma()) << "Unable to determine IP address for:" << gatewayId;
|
|
}
|
|
pluginStorage()->endGroup();
|
|
|
|
return host;
|
|
}
|
|
|
|
QString IntegrationPluginSomfyTahoma::getToken(Thing *thing) const
|
|
{
|
|
Thing *gateway = thing;
|
|
if (!thing->parentId().isNull()) {
|
|
gateway = myThings().findById(thing->parentId());
|
|
}
|
|
|
|
QString token;
|
|
pluginStorage()->beginGroup(gateway->id().toString());
|
|
token = pluginStorage()->value("token").toString();
|
|
pluginStorage()->endGroup();
|
|
return token;
|
|
}
|