diff --git a/zigbeegeneric/integrationpluginzigbeegeneric.cpp b/zigbeegeneric/integrationpluginzigbeegeneric.cpp index c2fac542..740ec69a 100644 --- a/zigbeegeneric/integrationpluginzigbeegeneric.cpp +++ b/zigbeegeneric/integrationpluginzigbeegeneric.cpp @@ -91,15 +91,20 @@ bool IntegrationPluginZigbeeGeneric::handleNode(ZigbeeNode *node, const QUuid &n handled = true; } - // Check on/off plug - if ((endpoint->profile() == Zigbee::ZigbeeProfile::ZigbeeProfileLightLink && - endpoint->deviceId() == Zigbee::LightLinkDevice::LightLinkDeviceOnOffPlugin) || - (endpoint->profile() == Zigbee::ZigbeeProfile::ZigbeeProfileHomeAutomation && - endpoint->deviceId() == Zigbee::HomeAutomationDeviceOnOffPlugin)) { + // Check on/off thing + if ((endpoint->profile() == Zigbee::ZigbeeProfile::ZigbeeProfileLightLink && endpoint->deviceId() == Zigbee::LightLinkDevice::LightLinkDeviceOnOffPlugin) || + (endpoint->profile() == Zigbee::ZigbeeProfile::ZigbeeProfileHomeAutomation && endpoint->deviceId() == Zigbee::HomeAutomationDeviceOnOffPlugin) || + (endpoint->profile() == Zigbee::ZigbeeProfile::ZigbeeProfileHomeAutomation && endpoint->deviceId() == Zigbee::HomeAutomationDeviceMainPowerOutlet) || + (endpoint->profile() == Zigbee::ZigbeeProfile::ZigbeeProfileHomeAutomation && endpoint->deviceId() == Zigbee::HomeAutomationDeviceSmartPlug)) { - qCDebug(dcZigbeeGeneric()) << "Handeling power socket endpoint for" << node << endpoint; - createThing(powerSocketThingClassId, networkUuid, node, endpoint); - handled = true; + // Simple on/off device + if (endpoint->hasInputCluster(ZigbeeClusterLibrary::ClusterIdOnOff)) { + // FIXME: create powersocket with metering for SmartPlug device ID + qCDebug(dcZigbeeGeneric()) << "Handeling power socket endpoint for" << node << endpoint; + createThing(powerSocketThingClassId, networkUuid, node, endpoint); + initSimplePowerSocket(node, endpoint); + handled = true; + } } // Check door lock @@ -187,7 +192,7 @@ void IntegrationPluginZigbeeGeneric::setupThing(ThingSetupInfo *info) qCWarning(dcZigbeeGeneric()) << "Failed to read thermostat cluster"; return; } -// thermostatCluster->attribute(ZigbeeClusterLibrary::ClusterIdThermostat); + // thermostatCluster->attribute(ZigbeeClusterLibrary::ClusterIdThermostat); // We need to read them from the lamp ZigbeeClusterReply *reply = thermostatCluster->readAttributes({ZigbeeClusterThermostat::AttributeLocalTemperature, ZigbeeClusterThermostat::AttributeOccupiedHeatingSetpoint}); @@ -239,15 +244,15 @@ void IntegrationPluginZigbeeGeneric::setupThing(ThingSetupInfo *info) }); connect(node, &ZigbeeNode::reachableChanged, thing, [=](bool reachable){ - if (reachable) { - ZigbeeClusterReply *reply = onOffCluster->readAttributes({ZigbeeClusterOnOff::AttributeOnOff}); - connect(reply, &ZigbeeClusterReply::finished, thing, [=](){ - if (reply->error() != ZigbeeClusterReply::ErrorNoError) { - qCWarning(dcZigbeeGeneric()) << "Reading attribute from" << thing << "finished with error" << reply->error(); - } - // Note: the state will be updated using the power changed signal from the cluster - }); - } + if (reachable) { + ZigbeeClusterReply *reply = onOffCluster->readAttributes({ZigbeeClusterOnOff::AttributeOnOff}); + connect(reply, &ZigbeeClusterReply::finished, thing, [=](){ + if (reply->error() != ZigbeeClusterReply::ErrorNoError) { + qCWarning(dcZigbeeGeneric()) << "Reading attribute from" << thing << "finished with error" << reply->error(); + } + // Note: the state will be updated using the power changed signal from the cluster + }); + } }); } else { qCWarning(dcZigbeeGeneric()) << "Could not find the OnOff input cluster on" << thing << endpoint; @@ -450,6 +455,23 @@ void IntegrationPluginZigbeeGeneric::createThing(const ThingClassId &thingClassI emit autoThingsAppeared({descriptor}); } +void IntegrationPluginZigbeeGeneric::initSimplePowerSocket(ZigbeeNode *node, ZigbeeNodeEndpoint *endpoint) +{ + // Get the on/off server cluster from the endpoint + ZigbeeClusterOnOff *onOffCluster = endpoint->inputCluster(ZigbeeClusterLibrary::ClusterIdOnOff); + if (!onOffCluster) + return; + + qCDebug(dcZigbeeGeneric()) << "Reading on/off power value for" << node << endpoint; + ZigbeeClusterReply *reply = onOffCluster->readAttributes({ZigbeeClusterOnOff::AttributeOnOff}); + connect(reply, &ZigbeeClusterReply::finished, node, [=](){ + if (reply->error() != ZigbeeClusterReply::ErrorNoError) { + qCWarning(dcZigbeeGeneric()) << "Failed to read on/off cluster attribute from" << node << endpoint << reply->error(); + return; + } + }); +} + void IntegrationPluginZigbeeGeneric::initializeDoorLock(ZigbeeNode *node, ZigbeeNodeEndpoint *endpoint) { qCDebug(dcZigbeeGeneric()) << "Read power configuration cluster attributes" << node; diff --git a/zigbeegeneric/integrationpluginzigbeegeneric.h b/zigbeegeneric/integrationpluginzigbeegeneric.h index 788c7d26..cf90c3f6 100644 --- a/zigbeegeneric/integrationpluginzigbeegeneric.h +++ b/zigbeegeneric/integrationpluginzigbeegeneric.h @@ -73,6 +73,7 @@ private: ZigbeeNodeEndpoint *findEndpoint(Thing *thing); void createThing(const ThingClassId &thingClassId, const QUuid &networkUuid, ZigbeeNode *node, ZigbeeNodeEndpoint *endpoint); + void initSimplePowerSocket(ZigbeeNode *node, ZigbeeNodeEndpoint *endpoint); void initializeDoorLock(ZigbeeNode *node, ZigbeeNodeEndpoint *endpoint); };