ETM-Schurig/etm-powersync-plugins
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Shelly: Add support for settings for the Shelyl I3

Browse Source
This commit is contained in:
Michael Zanetti 2021-08-15 00:46:39 +02:00
parent 79ef655ae9
commit 02791d1411
2 changed files with 98 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

91
shelly/integrationpluginshelly.cpp
View File

@ -416,6 +416,18 @@ static QHash<ActionTypeId, ThingClassId> updateActionTypesMap = {
{shellyMotionPerformUpdateActionTypeId, shellyMotionThingClassId} {shellyMotionPerformUpdateActionTypeId, shellyMotionThingClassId}
}; };
// Settings
static QHash<ThingClassId, ParamTypeId> longpushMinDurationSettingIds = {
{shellyI3ThingClassId, shellyI3SettingsLongpushMinDurationParamTypeId}
};
static QHash<ThingClassId, ParamTypeId> longpushMaxDurationSettingIds = {
{shellyButton1ThingClassId, shellyButton1SettingsLongpushMaxDurationParamTypeId},
{shellyI3ThingClassId, shellyI3SettingsLongpushMaxDurationParamTypeId}
};
static QHash<ThingClassId, ParamTypeId> multipushTimeBetweenPushesSettingIds = {
{shellyButton1ThingClassId, shellyButton1SettingsMultipushTimeBetweenPushesParamTypeId},
{shellyI3ThingClassId, shellyI3SettingsMultipushTimeBetweenPushesParamTypeId}
};
IntegrationPluginShelly::IntegrationPluginShelly() IntegrationPluginShelly::IntegrationPluginShelly()
{ {
@ -742,7 +754,7 @@ void IntegrationPluginShelly::onPublishReceived(MqttChannel *channel, const QStr
return; return;
} }
qCDebug(dcShelly()) << "Publish received from" << thing->name() << topic; qCDebug(dcShelly()) << "Publish received from" << thing->name() << topic << payload;
QString shellyId = thing->paramValue(idParamTypeMap.value(thing->thingClassId())).toString(); QString shellyId = thing->paramValue(idParamTypeMap.value(thing->thingClassId())).toString();
if (topic == "shellies/" + shellyId + "/info") { if (topic == "shellies/" + shellyId + "/info") {
@ -753,7 +765,6 @@ void IntegrationPluginShelly::onPublishReceived(MqttChannel *channel, const QStr
qCWarning(dcShelly()) << qUtf8Printable(payload); qCWarning(dcShelly()) << qUtf8Printable(payload);
return; return;
} }
// qCDebug(dcShelly()) << "Payload:" << qUtf8Printable(jsonDoc.toJson());
QVariantMap data = jsonDoc.toVariant().toMap(); QVariantMap data = jsonDoc.toVariant().toMap();
// Wifi signal strength // Wifi signal strength
@ -773,6 +784,36 @@ void IntegrationPluginShelly::onPublishReceived(MqttChannel *channel, const QStr
thing->setStateValue(currentVersionStateTypesMap.value(thing->thingClassId()), data.value("update").toMap().value("old_version").toString()); thing->setStateValue(currentVersionStateTypesMap.value(thing->thingClassId()), data.value("update").toMap().value("old_version").toString());
thing->setStateValue(availableVersionStateTypesMap.value(thing->thingClassId()), data.value("update").toMap().value("new_version").toString()); thing->setStateValue(availableVersionStateTypesMap.value(thing->thingClassId()), data.value("update").toMap().value("new_version").toString());
if (data.contains("longpush_duration_ms")) {
if (longpushMinDurationSettingIds.contains(thing->thingClassId())) {
thing->setSettingValue(longpushMinDurationSettingIds.value(thing->thingClassId()), data.value("longpush_duration_ms").toMap().value("min").toUInt());
}
foreach (Thing *child, myThings().filterByParentId(thing->id())) {
if (longpushMinDurationSettingIds.contains(child->thingClassId())) {
thing->setSettingValue(longpushMinDurationSettingIds.value(thing->thingClassId()), data.value("longpush_duration_ms").toMap().value("min").toUInt());
}
}
if (longpushMaxDurationSettingIds.contains(thing->thingClassId())) {
thing->setSettingValue(longpushMaxDurationSettingIds.value(thing->thingClassId()), data.value("longpush_duration_ms").toMap().value("max").toUInt());
}
foreach (Thing *child, myThings().filterByParentId(thing->id())) {
if (longpushMaxDurationSettingIds.contains(child->thingClassId())) {
thing->setSettingValue(longpushMaxDurationSettingIds.value(thing->thingClassId()), data.value("longpush_duration_ms").toMap().value("max").toUInt());
}
}
}
if (data.contains("multipush_time_between_pushes_ms")) {
if (multipushTimeBetweenPushesSettingIds.contains(thing->thingClassId())) {
thing->setSettingValue(multipushTimeBetweenPushesSettingIds.value(thing->thingClassId()), data.value("multipush_time_between_pushes_ms").toMap().value("max").toUInt());
}
foreach (Thing *child, myThings().filterByParentId(thing->id())) {
if (multipushTimeBetweenPushesSettingIds.contains(child->thingClassId())) {
thing->setSettingValue(multipushTimeBetweenPushesSettingIds.value(thing->thingClassId()), data.value("multipush_time_between_pushes_ms").toMap().value("max").toUInt());
}
}
}
// While we normally use the specific topics instead of the "info" object, the Shell H&T posts it very rarely // While we normally use the specific topics instead of the "info" object, the Shell H&T posts it very rarely
// and in combination with its power safe mode let's use this one to get temp/humidity // and in combination with its power safe mode let's use this one to get temp/humidity
if (thing->thingClassId() == shellyHTThingClassId) { if (thing->thingClassId() == shellyHTThingClassId) {
@ -787,27 +828,17 @@ void IntegrationPluginShelly::onPublishReceived(MqttChannel *channel, const QStr
if (topic.startsWith("shellies/" + shellyId + "/input/")) { if (topic.startsWith("shellies/" + shellyId + "/input/")) {
// qCDebug(dcShelly()) << "Payload:" << payload;
int channel = topic.split("/").last().toInt(); int channel = topic.split("/").last().toInt();
// "1" or "0" // "1" or "0"
// Emit event button pressed // Emit event button pressed
bool on = payload == "1"; bool on = payload == "1";
if (thing->thingClassId() == shellyI3ThingClassId) { if (thing->thingClassId() == shellyI3ThingClassId) {
if (channel == 0) { if (channel == 0) {
if (thing->stateValue(shellyI3Input1StateTypeId).toBool() != on) { thing->setStateValue(shellyI3Input1StateTypeId, on);
thing->setStateValue(shellyI3Input1StateTypeId, on);
emit emitEvent(Event(shellyI3Input1EventTypeId, thing->id()));
}
} else if (channel == 1) { } else if (channel == 1) {
if (thing->stateValue(shellyI3Input2StateTypeId).toBool() != on) { thing->setStateValue(shellyI3Input2StateTypeId, on);
thing->setStateValue(shellyI3Input2StateTypeId, on);
emit emitEvent(Event(shellyI3Input2EventTypeId, thing->id()));
}
} else { } else {
if (thing->stateValue(shellyI3Input3StateTypeId).toBool() != on) { thing->setStateValue(shellyI3Input3StateTypeId, on);
thing->setStateValue(shellyI3Input3StateTypeId, on);
emit emitEvent(Event(shellyI3Input3EventTypeId, thing->id()));
}
} }
return; return;
} }
@ -823,7 +854,6 @@ void IntegrationPluginShelly::onPublishReceived(MqttChannel *channel, const QStr
QRegExp topicMatcher = QRegExp("shellies/" + shellyId + "/relay/[0-1]"); QRegExp topicMatcher = QRegExp("shellies/" + shellyId + "/relay/[0-1]");
if (topicMatcher.exactMatch(topic)) { if (topicMatcher.exactMatch(topic)) {
// qCDebug(dcShelly()) << "Payload:" << payload;
QStringList parts = topic.split("/"); QStringList parts = topic.split("/");
int channel = parts.at(3).toInt(); int channel = parts.at(3).toInt();
bool on = payload == "on"; bool on = payload == "on";
@ -855,7 +885,6 @@ void IntegrationPluginShelly::onPublishReceived(MqttChannel *channel, const QStr
topicMatcher = QRegExp("shellies/" + shellyId + "/(relay|roller)/[0-1]/power"); topicMatcher = QRegExp("shellies/" + shellyId + "/(relay|roller)/[0-1]/power");
if (topicMatcher.exactMatch(topic)) { if (topicMatcher.exactMatch(topic)) {
// qCDebug(dcShelly()) << "Payload:" << payload;
QStringList parts = topic.split("/"); QStringList parts = topic.split("/");
int channel = parts.at(3).toInt(); int channel = parts.at(3).toInt();
double power = payload.toDouble(); double power = payload.toDouble();
@ -874,7 +903,6 @@ void IntegrationPluginShelly::onPublishReceived(MqttChannel *channel, const QStr
topicMatcher = QRegExp("shellies/" + shellyId + "/(relay|roller)/[0-1]/energy"); topicMatcher = QRegExp("shellies/" + shellyId + "/(relay|roller)/[0-1]/energy");
if (topicMatcher.exactMatch(topic)) { if (topicMatcher.exactMatch(topic)) {
// qCDebug(dcShelly()) << "Payload:" << payload;
QStringList parts = topic.split("/"); QStringList parts = topic.split("/");
int channel = parts.at(3).toInt(); int channel = parts.at(3).toInt();
// W/min => kW/h // W/min => kW/h
@ -893,7 +921,6 @@ void IntegrationPluginShelly::onPublishReceived(MqttChannel *channel, const QStr
} }
if (topic == "shellies/" + shellyId + "/color/0") { if (topic == "shellies/" + shellyId + "/color/0") {
// qCDebug(dcShelly()) << "Payload:" << payload;
bool on = payload == "on"; bool on = payload == "on";
if (powerStateTypeMap.contains(thing->thingClassId())) { if (powerStateTypeMap.contains(thing->thingClassId())) {
thing->setStateValue(powerStateTypeMap.value(thing->thingClassId()), on); thing->setStateValue(powerStateTypeMap.value(thing->thingClassId()), on);
@ -901,7 +928,6 @@ void IntegrationPluginShelly::onPublishReceived(MqttChannel *channel, const QStr
} }
if (topic == "shellies/" + shellyId + "/color/0/status") { if (topic == "shellies/" + shellyId + "/color/0/status") {
// qCDebug(dcShelly()) << "Payload:" << payload;
QJsonParseError error; QJsonParseError error;
QJsonDocument jsonDoc = QJsonDocument::fromJson(payload, &error); QJsonDocument jsonDoc = QJsonDocument::fromJson(payload, &error);
if (error.error != QJsonParseError::NoError) { if (error.error != QJsonParseError::NoError) {
@ -924,7 +950,6 @@ void IntegrationPluginShelly::onPublishReceived(MqttChannel *channel, const QStr
} }
if (topic == "shellies/" + shellyId + "/light/0") { if (topic == "shellies/" + shellyId + "/light/0") {
// qCDebug(dcShelly()) << "Payload:" << payload;
bool on = payload == "on"; bool on = payload == "on";
if (powerStateTypeMap.contains(thing->thingClassId())) { if (powerStateTypeMap.contains(thing->thingClassId())) {
thing->setStateValue(powerStateTypeMap.value(thing->thingClassId()), on); thing->setStateValue(powerStateTypeMap.value(thing->thingClassId()), on);
@ -979,6 +1004,7 @@ void IntegrationPluginShelly::onPublishReceived(MqttChannel *channel, const QStr
} }
if (topic.startsWith("shellies/" + shellyId + "/input_event/")) { if (topic.startsWith("shellies/" + shellyId + "/input_event/")) {
qCDebug(dcShelly()) << "Payload:" << payload;
if (thing->thingClassId() == shellyButton1ThingClassId) { // it can be only at channel 0 if (thing->thingClassId() == shellyButton1ThingClassId) { // it can be only at channel 0
QJsonParseError error; QJsonParseError error;
QJsonDocument jsonDoc = QJsonDocument::fromJson(payload, &error); QJsonDocument jsonDoc = QJsonDocument::fromJson(payload, &error);
@ -1004,9 +1030,6 @@ void IntegrationPluginShelly::onPublishReceived(MqttChannel *channel, const QStr
return; return;
} }
QString event = jsonDoc.toVariant().toMap().value("event").toString(); QString event = jsonDoc.toVariant().toMap().value("event").toString();
if (event.isEmpty()) {
return;
}
QString param = ""; QString param = "";
EventTypeId eventTypeId = shellyI3LongPressedEventTypeId; EventTypeId eventTypeId = shellyI3LongPressedEventTypeId;
ParamTypeId paramTypeId = shellyI3LongPressedEventButtonNameParamTypeId; ParamTypeId paramTypeId = shellyI3LongPressedEventButtonNameParamTypeId;
@ -1256,7 +1279,11 @@ void IntegrationPluginShelly::setupShellyGateway(ThingSetupInfo *info)
info->thing()->setSettingValue(shellyButton1SettingsRemainAwakeParamTypeId, settingsMap.value("remain_awake").toInt()); info->thing()->setSettingValue(shellyButton1SettingsRemainAwakeParamTypeId, settingsMap.value("remain_awake").toInt());
info->thing()->setSettingValue(shellyButton1SettingsStatusLedEnabledParamTypeId, !settingsMap.value("led_status_disable").toBool()); info->thing()->setSettingValue(shellyButton1SettingsStatusLedEnabledParamTypeId, !settingsMap.value("led_status_disable").toBool());
info->thing()->setSettingValue(shellyButton1SettingsLongpushMaxDurationParamTypeId, settingsMap.value("longpush_duration_ms").toMap().value("max").toUInt()); info->thing()->setSettingValue(shellyButton1SettingsLongpushMaxDurationParamTypeId, settingsMap.value("longpush_duration_ms").toMap().value("max").toUInt());
info->thing()->setSettingValue(shellyButton1SettingsMultipressIntervalParamTypeId, settingsMap.value("multipush_time_between_pushes_ms").toMap().value("max").toUInt()); info->thing()->setSettingValue(shellyButton1SettingsMultipushTimeBetweenPushesParamTypeId, settingsMap.value("multipush_time_between_pushes_ms").toMap().value("max").toUInt());
} else if (info->thing()->thingClassId() == shellyI3ThingClassId) {
info->thing()->setSettingValue(shellyI3SettingsLongpushMinDurationParamTypeId, settingsMap.value("longpush_duration_ms").toMap().value("min").toUInt());
info->thing()->setSettingValue(shellyI3SettingsLongpushMaxDurationParamTypeId, settingsMap.value("longpush_duration_ms").toMap().value("max").toUInt());
info->thing()->setSettingValue(shellyI3SettingsMultipushTimeBetweenPushesParamTypeId, settingsMap.value("multipush_time_between_pushes_ms").toMap().value("max").toUInt());
} }
ThingDescriptors autoChilds; ThingDescriptors autoChilds;
@ -1410,7 +1437,8 @@ void IntegrationPluginShelly::setupShellyGateway(ThingSetupInfo *info)
// Handle thing settings of gateway devices // Handle thing settings of gateway devices
if (info->thing()->thingClassId() == shellyPlugThingClassId || if (info->thing()->thingClassId() == shellyPlugThingClassId ||
info->thing()->thingClassId() == shellyButton1ThingClassId) { info->thing()->thingClassId() == shellyButton1ThingClassId ||
info->thing()->thingClassId() == shellyI3ThingClassId) {
connect(info->thing(), &Thing::settingChanged, this, [this, thing, shellyId](const ParamTypeId &settingTypeId, const QVariant &value) { connect(info->thing(), &Thing::settingChanged, this, [this, thing, shellyId](const ParamTypeId &settingTypeId, const QVariant &value) {
pluginStorage()->beginGroup(thing->id().toString()); pluginStorage()->beginGroup(thing->id().toString());
@ -1434,14 +1462,23 @@ void IntegrationPluginShelly::setupShellyGateway(ThingSetupInfo *info)
} else if (settingTypeId == shellyButton1SettingsStatusLedEnabledParamTypeId) { } else if (settingTypeId == shellyButton1SettingsStatusLedEnabledParamTypeId) {
url.setPath("/settings"); url.setPath("/settings");
query.addQueryItem("led_status_disable", value.toBool() ? "false" : "true"); query.addQueryItem("led_status_disable", value.toBool() ? "false" : "true");
} else if (settingTypeId == shellyButton1SettingsLongpushMaxDurationParamTypeId) { } else if (settingTypeId == shellyI3SettingsLongpushMinDurationParamTypeId) {
url.setPath("/settings");
query.addQueryItem("longpush_duration_ms_min", value.toString());
} else if (settingTypeId == shellyButton1SettingsLongpushMaxDurationParamTypeId
|| settingTypeId == shellyI3SettingsLongpushMaxDurationParamTypeId) {
url.setPath("/settings"); url.setPath("/settings");
query.addQueryItem("longpush_duration_ms_max", value.toString()); query.addQueryItem("longpush_duration_ms_max", value.toString());
} else if (settingTypeId == shellyButton1SettingsMultipushTimeBetweenPushesParamTypeId
|| settingTypeId == shellyI3SettingsMultipushTimeBetweenPushesParamTypeId) {
url.setPath("/settings");
query.addQueryItem("multipush_time_between_pushes_ms_max", value.toString());
} }
url.setQuery(query); url.setQuery(query);
QNetworkReply *reply = hardwareManager()->networkManager()->get(QNetworkRequest(url)); QNetworkReply *reply = hardwareManager()->networkManager()->get(QNetworkRequest(url));
qCDebug(dcShelly()) << "Setting configuration:" << url.toString();
connect(reply, &QNetworkReply::finished, reply, &QNetworkReply::deleteLater); connect(reply, &QNetworkReply::finished, reply, &QNetworkReply::deleteLater);
}); });
} }

35
shelly/integrationpluginshelly.json
View File

@ -1013,9 +1013,10 @@
}, },
{ {
"id": "b1f5a911-76ec-42e5-ac64-17f85d82b875", "id": "b1f5a911-76ec-42e5-ac64-17f85d82b875",
"name": "multipressInterval", "name": "multipushTimeBetweenPushes",
"displayName": "Max time between multiple presses", "displayName": "Max time between multiple presses",
"type": "uint", "type": "uint",
"unit": "MilliSeconds",
"minValue": 200, "minValue": 200,
"maxValue": 2000, "maxValue": 2000,
"defaultValue": 500 "defaultValue": 500
@ -1152,6 +1153,38 @@
"type": "QString" "type": "QString"
} }
], ],
"settingsTypes": [
{
"id": "a04fda4b-f187-477c-b7a8-b56613bf9264",
"name": "longpushMinDuration",
"displayName": "Minimum longpress duration",
"type": "uint",
"unit": "MilliSeconds",
"minValue": 100,
"maxValue": 2900,
"defaultValue": 100
},
{
"id": "6485685e-0097-48db-958b-43126c6fb5a6",
"name": "longpushMaxDuration",
"displayName": "Maximum longpress duration",
"type": "uint",
"unit": "MilliSeconds",
"minValue": 200,
"maxValue": 6000,
"defaultValue": 3000
},
{
"id": "52699a1b-3526-4f60-83ec-f35faa863597",
"name": "multipushTimeBetweenPushes",
"displayName": "Max time between multiple presses",
"type": "uint",
"unit": "MilliSeconds",
"minValue": 100,
"maxValue": 500,
"defaultValue": 500
}
],
"stateTypes": [ "stateTypes": [
{ {
"id": "9b17b10d-07ee-4a3d-813f-ef37e79e7241", "id": "9b17b10d-07ee-4a3d-813f-ef37e79e7241",