bindings.cpp

/*
 * Copyright (c) 2017-2020 dresden elektronik ingenieurtechnik gmbh.
 * All rights reserved.
 *
 * The software in this package is published under the terms of the BSD
 * style license a copy of which has been included with this distribution in
 * the LICENSE.txt file.
 *
 */

#include "de_web_plugin.h"
#include "de_web_plugin_private.h"

#define MAX_ACTIVE_BINDING_TASKS 3

/*! Constructor. */
Binding::Binding() :
    srcAddress(0),
    srcEndpoint(0),
    clusterId(0),
    dstAddrMode(0),
    dstEndpoint(0)
{
    dstAddress.ext = 0;
}

/*! Returns true if bindings are equal. */
bool Binding::operator==(const Binding &rhs) const
{
    if (rhs.dstAddrMode == dstAddrMode &&
        rhs.srcAddress == srcAddress &&
        rhs.dstAddress.ext == dstAddress.ext &&
        rhs.clusterId == clusterId &&
        rhs.dstEndpoint == dstEndpoint &&
        rhs.srcEndpoint == srcEndpoint)
    {
        return true;
    }
    return false;
}

/*! Returns false if bindings are not equal. */
bool Binding::operator!=(const Binding &rhs) const
{
    return !(*this == rhs);
}

/*! Reads a binding entry from stream. */
bool Binding::readFromStream(QDataStream &stream)
{
    if (stream.atEnd()) return false;
    stream >> srcAddress;
    if (stream.atEnd()) return false;
    stream >> srcEndpoint;
    if (stream.atEnd()) return false;
    stream >> clusterId;
    if (stream.atEnd()) return false;
    stream >> dstAddrMode;

    if (dstAddrMode == GroupAddressMode)
    {
        if (stream.atEnd()) return false;
        stream >> dstAddress.group;
        dstEndpoint = 0; // not present
        return true;
    }
    else if (dstAddrMode == ExtendedAddressMode)
    {
        if (stream.atEnd()) return false;
        stream >> dstAddress.ext;
        if (stream.atEnd()) return false;
        stream >> dstEndpoint;
        return true;
    }

    return false;
}

/*! Writes a binding to stream.
    \param stream the data stream
 */
bool Binding::writeToStream(QDataStream &stream) const
{
    if (!srcAddress || !srcEndpoint)
    {
        return false;
    }

    stream << srcAddress;
    stream << srcEndpoint;
    stream << clusterId;
    stream << dstAddrMode;

    if (dstAddrMode == GroupAddressMode)
    {
        stream << dstAddress.group;
        return true;
    }
    else if ((dstAddrMode == ExtendedAddressMode) && (dstAddress.ext != 0) && (dstEndpoint != 0))
    {
        stream << dstAddress.ext;
        stream << dstEndpoint;
        return true;
    }

    return false;
}

/*! Queue reading ZDP binding table.
    \param node the node from which the binding table shall be read
    \param startIndex the index to start the reading
    \return true if the request is queued
 */
bool DeRestPluginPrivate::readBindingTable(RestNodeBase *node, quint8 startIndex)
{
    DBG_Assert(node != 0);

    if (!node || !node->node())
    {
        return false;
    }

    Resource *r = dynamic_cast<Resource*>(node);

    // whitelist
    if (checkMacVendor(node->address(), VENDOR_DDEL))
    {
    }
    else if (checkMacVendor(node->address(), VENDOR_UBISYS))
    {
    }
    else if (checkMacVendor(node->address(), VENDOR_DEVELCO))
    {
    }
    else if (r && r->item(RAttrModelId)->toString().startsWith(QLatin1String("FLS-")))
    {
    }
    else
    {
        node->clearRead(READ_BINDING_TABLE);
        return false;
    }

    std::vector<BindingTableReader>::iterator i = bindingTableReaders.begin();
    std::vector<BindingTableReader>::iterator end = bindingTableReaders.end();

    for (; i != end; ++i)
    {
        if (i->apsReq.dstAddress().ext() == node->address().ext())
        {
            // already running
            if (i->state == BindingTableReader::StateIdle)
            {
                i->index = startIndex;
                DBG_Assert(bindingTableReaderTimer->isActive());
            }
            return true;
        }
    }

    BindingTableReader btReader;
    btReader.state = BindingTableReader::StateIdle;
    btReader.index = startIndex;
    btReader.isEndDevice = !node->node()->nodeDescriptor().receiverOnWhenIdle();
    btReader.apsReq.dstAddress() = node->address();

    bindingTableReaders.push_back(btReader);

    if (!bindingTableReaderTimer->isActive())
    {
        bindingTableReaderTimer->start();
    }

    return false;
}

/*! Handle bind table confirm.
    \param conf a APSDE-DATA.confirm
    \return true if confirm was processed
 */
bool DeRestPluginPrivate::handleMgmtBindRspConfirm(const deCONZ::ApsDataConfirm &conf)
{
    if (conf.srcEndpoint() != ZDO_ENDPOINT || conf.dstEndpoint() != ZDO_ENDPOINT)
    {
        return false;
    }

    std::vector<BindingTableReader>::iterator i = bindingTableReaders.begin();
    std::vector<BindingTableReader>::iterator end = bindingTableReaders.end();

    for (; i != end; ++i)
    {
        if (i->apsReq.id() == conf.id())
        {
            if (i->state == BindingTableReader::StateWaitConfirm)
            {
                i->time.start();
                i->state = BindingTableReader::StateWaitResponse;
            }
            return true;
        }
    }
    return false;
}

/*! Handle bind table response.
    \param ind a ZDP MgmtBind_rsp
 */
void DeRestPluginPrivate::handleMgmtBindRspIndication(const deCONZ::ApsDataIndication &ind)
{
    if (ind.asdu().size() < 2)
    {
        // at least seq number and status
        return;
    }

    BindingTableReader *btReader = 0;

    {
        std::vector<BindingTableReader>::iterator i = bindingTableReaders.begin();
        std::vector<BindingTableReader>::iterator end = bindingTableReaders.end();

        if (ind.srcAddress().hasExt())
        {
            for (; i != end; ++i)
            {
                if (i->apsReq.dstAddress().ext() == ind.srcAddress().ext())
                {
                    btReader = &(*i);
                    break;
                }
            }
        }
        else if (ind.srcAddress().hasNwk())
        {
            for (; i != end; ++i)
            {
                if (i->apsReq.dstAddress().nwk() == ind.srcAddress().nwk())
                {
                    btReader = &(*i);
                    break;
                }
            }
        }
    }

    RestNodeBase *node = getSensorNodeForAddress(ind.srcAddress());

    if (!node)
    {
        node = getLightNodeForAddress(ind.srcAddress());
    }

    if (!node)
    {
        if (btReader)
        {
            // no more needed
            btReader->state = BindingTableReader::StateFinished;
        }
        return;
    }

    QDataStream stream(ind.asdu());
    stream.setByteOrder(QDataStream::LittleEndian);

    quint8 seqNo;
    quint8 status;

    stream >> seqNo;
    stream >> status;

    if (btReader)
    {
        DBG_Printf(DBG_ZDP, "MgmtBind_rsp id: %d %s seq: %u, status 0x%02X \n", btReader->apsReq.id(),
                   qPrintable(node->address().toStringExt()), seqNo, status);
    }
    else
    {
        DBG_Printf(DBG_ZDP, "MgmtBind_rsp (no BTR) %s seq: %u, status 0x%02X \n", qPrintable(node->address().toStringExt()), seqNo, status);
    }

    if (status != deCONZ::ZdpSuccess)
    {
        if (status == deCONZ::ZdpNotPermitted ||
            status == deCONZ::ZdpNotSupported)
        {
            if (node->mgmtBindSupported())
            {
                DBG_Printf(DBG_ZDP, "MgmtBind_req/rsp %s not supported, deactivate \n", qPrintable(node->address().toStringExt()));
                node->setMgmtBindSupported(false);
            }
        }

        if (btReader)
        {
            // no more needed
            btReader->state = BindingTableReader::StateFinished;
        }
        return;
    }

    quint8 entries;
    quint8 startIndex;
    quint8 listCount;
    bool bend = false;

    stream >> entries;
    stream >> startIndex;
    stream >> listCount;

    if (entries > (startIndex + listCount))
    {
        if (btReader)
        {
            if (btReader->state == BindingTableReader::StateWaitResponse || btReader->state == BindingTableReader::StateWaitConfirm)
            {
                // read more
                btReader->state = BindingTableReader::StateIdle;
                btReader->index = startIndex + listCount;
            }
            else
            {
                DBG_Printf(DBG_ZDP, "unexpected BTR state %d\n", (int)btReader->state);
            }
        }
    }
    else
    {
        bend = true;
        if (btReader)
        {
            btReader->state = BindingTableReader::StateFinished;
        }
    }

    while (listCount && !stream.atEnd())
    {
        Binding bnd;

        if (bnd.readFromStream(stream))
        {
            if (bnd.dstAddrMode == deCONZ::ApsExtAddress)
            {
                DBG_Printf(DBG_ZDP, "found binding 0x%04X, 0x%02X -> 0x%016llX : 0x%02X\n", bnd.clusterId, bnd.srcEndpoint, bnd.dstAddress.ext, bnd.dstEndpoint);
            }
            else if (bnd.dstAddrMode == deCONZ::ApsGroupAddress)
            {
                DBG_Printf(DBG_ZDP, "found binding 0x%04X, 0x%02X -> 0x%04X\n", bnd.clusterId, bnd.srcEndpoint, bnd.dstAddress.group);
            }
            else
            {
                continue;
            }

            if (std::find(bindingToRuleQueue.begin(), bindingToRuleQueue.end(), bnd) == bindingToRuleQueue.end())
            {
                DBG_Printf(DBG_ZDP, "add binding to check rule queue size: %d\n", static_cast<int>(bindingToRuleQueue.size()));
                bindingToRuleQueue.push_back(bnd);
            }
            else
            {
                DBG_Printf(DBG_ZDP, "binding already in binding to rule queue\n");
            }

            std::list<BindingTask>::iterator i = bindingQueue.begin();
            std::list<BindingTask>::iterator end = bindingQueue.end();

            for (;i != end; ++i)
            {
                if (i->binding == bnd)
                {
                    if (i->action == BindingTask::ActionBind && i->state != BindingTask::StateFinished)
                    {
                        DBG_Printf(DBG_ZDP, "binding 0x%04X, 0x%02X already exists, drop task\n", bnd.clusterId, bnd.dstEndpoint);
                        i->state = BindingTask::StateFinished; // already existing
                        sendConfigureReportingRequest(*i); // (re?)configure
                    }
                    else if (i->action == BindingTask::ActionUnbind && i->state == BindingTask::StateCheck)
                    {
                        DBG_Printf(DBG_ZDP, "binding 0x%04X, 0x%02X exists, start unbind task\n", bnd.clusterId, bnd.dstEndpoint);
                        i->state = BindingTask::StateIdle; // exists -> unbind
                    }
                    break;
                }
            }
        }
        else // invalid
        {
            DBG_Printf(DBG_ZDP, "invalid binding entry");
            break;
        }

        listCount--;
    }

    // end, check remaining tasks
    if (bend)
    {
        std::list<BindingTask>::iterator i = bindingQueue.begin();
        std::list<BindingTask>::iterator end = bindingQueue.end();

        for (;i != end; ++i)
        {
            if (i->state == BindingTask::StateCheck &&
                i->binding.srcAddress == ind.srcAddress().ext())
            {
                // if binding was not found, activate binding task
                if (i->action == BindingTask::ActionBind)
                {
                    DBG_Printf(DBG_ZDP, "binding 0x%04X, 0x%02X not found, start bind task\n", i->binding.clusterId, i->binding.dstEndpoint);
                    i->state = BindingTask::StateIdle;
                }
                else if (i->action == BindingTask::ActionUnbind)
                {
                    // nothing to unbind
                    DBG_Printf(DBG_ZDP, "binding 0x%04X, 0x%02X not found, remove unbind task\n", i->binding.clusterId, i->binding.dstEndpoint);
                    i->state = BindingTask::StateFinished; // already existing
                }
            }
        }
    }

    if (!bindingToRuleTimer->isActive() && !bindingToRuleQueue.empty())
    {
        bindingToRuleTimer->start();
    }
}

/*! Handle incoming ZCL configure reporting response.
 */
void DeRestPluginPrivate::handleZclConfigureReportingResponseIndication(const deCONZ::ApsDataIndication &ind, deCONZ::ZclFrame &zclFrame)
{
    QDateTime now = QDateTime::currentDateTime();
    std::vector<RestNodeBase*> allNodes;
    for (Sensor &s : sensors)
    {
        allNodes.push_back(&s);
    }

    for (LightNode &l : nodes)
    {
        allNodes.push_back(&l);
    }

    // send DefaultResponse if not disabled
    if (!(zclFrame.frameControl() & deCONZ::ZclFCDisableDefaultResponse))
    {
        sendZclDefaultResponse(ind, zclFrame, deCONZ::ZclSuccessStatus);
    }

    for (RestNodeBase * restNode : allNodes)
    {
        if (restNode->address().ext() != ind.srcAddress().ext())
        {
            continue;
        }

        DBG_Assert(zclFrame.sequenceNumber() != 0);

        QDataStream stream(zclFrame.payload());
        stream.setByteOrder(QDataStream::LittleEndian);

        if (zclFrame.payload().size() == 1)
        {
            // Response contains a single status for all attributes
            quint8 status;
            stream >> status;

            for (NodeValue &val : restNode->zclValues())
            {
                if (val.zclSeqNum != zclFrame.sequenceNumber())
                {
                    continue;
                }

                if (val.clusterId != ind.clusterId())
                {
                    continue;
                }

                DBG_Printf(DBG_INFO, "ZCL configure reporting rsp seq: %u 0x%016llX for ep: 0x%02X cluster: 0x%04X attr: 0x%04X status: 0x%02X\n", zclFrame.sequenceNumber(), ind.srcAddress().ext(), ind.srcEndpoint(), ind.clusterId(), val.attributeId, status);

                // mark as succefully configured
                if (status == deCONZ::ZclSuccessStatus)
                {
                    val.timestampLastConfigured = now;
                    val.zclSeqNum = 0; // clear
                }
            }
            break;
        }

        while (!stream.atEnd())
        {
            // Response contains status per attribute
            quint8 status;
            quint8 direction;
            quint16 attrId;

            stream >> status;
            stream >> direction;
            stream >> attrId;

            NodeValue &val = restNode->getZclValue(ind.clusterId(), attrId, ind.srcEndpoint());
            if (val.zclSeqNum == zclFrame.sequenceNumber() && val.clusterId == ind.clusterId())
            {
                DBG_Printf(DBG_INFO, "ZCL configure reporting rsp seq: %u 0x%016llX for ep: 0x%02X cluster: 0x%04X attr: 0x%04X status: 0x%02X\n", zclFrame.sequenceNumber(), ind.srcAddress().ext(), ind.srcEndpoint(), ind.clusterId(), val.attributeId, status);

                if (status == deCONZ::ZclSuccessStatus)
                {
                    // mark as succefully configured
                    val.timestampLastConfigured = now;
                    val.zclSeqNum = 0; // clear
                }
            }
        }
    }

    if (searchSensorsState == SearchSensorsActive && fastProbeAddr.hasExt() && bindingQueue.empty())
    {
        for (auto &s : sensors)
        {
            if (s.address().ext() == fastProbeAddr.ext())
            {
                checkSensorBindingsForAttributeReporting(&s);
            }
        }
    }

    bindingTimer->start(0); // fast process of next request
}

/*! Handle bind/unbind response.
    \param ind a ZDP Bind/Unbind_rsp
 */
void DeRestPluginPrivate::handleBindAndUnbindRspIndication(const deCONZ::ApsDataIndication &ind)
{
    QDataStream stream(ind.asdu());
    stream.setByteOrder(QDataStream::LittleEndian);

    quint8 zdpSeqNum;
    quint8 status;

    stream >> zdpSeqNum;
    stream >> status;

    std::list<BindingTask>::iterator i = bindingQueue.begin();
    std::list<BindingTask>::iterator end = bindingQueue.end();

    for (; i != end; ++i)
    {
        if (i->zdpSeqNum == zdpSeqNum)
        {
            const char *what = (ind.clusterId() == ZDP_BIND_RSP_CLID) ? "Bind" : "Unbind";

            if (status == deCONZ::ZdpSuccess)
            {
                DBG_Printf(DBG_INFO, "%s response success for 0x%016llx ep: 0x%02X cluster: 0x%04X\n", what, i->binding.srcAddress, i->binding.srcEndpoint, i->binding.clusterId);
                if (ind.clusterId() == ZDP_BIND_RSP_CLID)
                {
                    if (sendConfigureReportingRequest(*i))
                    {
                        return;
                    }
                }
            }
            else
            {
                DBG_Printf(DBG_INFO, "%s response failed with status 0x%02X for 0x%016llx ep: 0x%02X cluster: 0x%04X\n", what, status, i->binding.srcAddress, i->binding.srcEndpoint, i->binding.clusterId);
            }

            i->state = BindingTask::StateFinished;
            break;
        }
    }

    bindingTimer->start(0); // fast process of next binding requests
}

/*! Sends a ZDP bind request.
    \param bt a binding task
 */
bool DeRestPluginPrivate::sendBindRequest(BindingTask &bt)
{
    DBG_Assert(apsCtrl != nullptr);

    if (!apsCtrl)
    {
        return false;
    }

    for (auto &s : sensors)
    {
        if (s.address().ext() != bt.binding.srcAddress)
        {
            continue;
        }

        if (!s.node() || s.node()->nodeDescriptor().isNull())
        {
            // Whitelist sensors which don't seem to have a valid node descriptor.
            // This is a workaround currently only required for Develco smoke sensor
            // and potentially Bosch motion sensor
            if (s.modelId().startsWith(QLatin1String("SMSZB-120")) ||    // Develco smoke sensor
                s.modelId().startsWith(QLatin1String("EMIZB-132")) ||    // Develco EMI Norwegian HAN
                s.modelId().startsWith(QLatin1String("ISW-ZPR1-WP13")))  // Bosch motion sensor
            {
            }
            else
            {
                return false; // needs to be known
            }
        }

        if (s.node()->nodeDescriptor().receiverOnWhenIdle())
        {
            break; // ok
        }

        if (permitJoinFlag || searchSensorsState == SearchSensorsActive)
        {
            break; // ok
        }

        const QDateTime now = QDateTime::currentDateTime();
        if (s.lastRx().secsTo(now) > 7)
        {
            return false;
        }

        break; // ok
    }

    Binding &bnd = bt.binding;
    deCONZ::ApsDataRequest apsReq;

    // set destination addressing
    apsReq.setDstAddressMode(deCONZ::ApsExtAddress);
    apsReq.setTxOptions(deCONZ::ApsTxAcknowledgedTransmission);
    apsReq.dstAddress().setExt(bnd.srcAddress);
    apsReq.setDstEndpoint(ZDO_ENDPOINT);
    apsReq.setSrcEndpoint(ZDO_ENDPOINT);
    apsReq.setProfileId(ZDP_PROFILE_ID);

    if (bt.action == BindingTask::ActionBind)
    {
        apsReq.setClusterId(ZDP_BIND_REQ_CLID);
    }
    else
    {
        apsReq.setClusterId(ZDP_UNBIND_REQ_CLID);
    }

    // prepare payload
    QDataStream stream(&apsReq.asdu(), QIODevice::WriteOnly);
    stream.setByteOrder(QDataStream::LittleEndian);

    // generate and remember a new ZDP transaction sequence number
    bt.zdpSeqNum = (uint8_t)qrand();

    stream << bt.zdpSeqNum; // ZDP transaction sequence number

    if (!bnd.writeToStream(stream))
    {
        return false;
    }

    if (apsCtrl && (apsCtrl->apsdeDataRequest(apsReq) == deCONZ::Success))
    {
        return true;
    }

    return false;
}

/*! Sends a ZCL configure attribute reporting request.
    \param bt a former binding task
    \param requests list of configure reporting requests which will be combined in a message
 */
bool DeRestPluginPrivate::sendConfigureReportingRequest(BindingTask &bt, const std::vector<ConfigureReportingRequest> &requests)
{
    DBG_Assert(!requests.empty());
    if (requests.empty())
    {
        return false;
    }

    if (zclSeq == 0) // don't use zero, simplify matching
    {
        zclSeq = 1;
    }
    const quint8 zclSeqNum = zclSeq++; // to match in configure reporting response handler
    LightNode *lightNode = dynamic_cast<LightNode*>(bt.restNode);
    QDateTime now = QDateTime::currentDateTime();
    std::vector<ConfigureReportingRequest> out;

    for (const ConfigureReportingRequest &rq : requests)
    {
        NodeValue &val = bt.restNode->getZclValue(bt.binding.clusterId, rq.attributeId, bt.binding.srcEndpoint);
        if (val.clusterId == bt.binding.clusterId)
        {
            // value exists
            if (val.timestampLastReport.isValid() &&
                val.timestampLastReport.secsTo(now) < qMin((rq.maxInterval * 3), 1800))
            {
                DBG_Printf(DBG_INFO, "skip configure report for cluster: 0x%04X attr: 0x%04X of node 0x%016llX (seems to be active)\n",
                           bt.binding.clusterId, rq.attributeId, bt.restNode->address().ext());
            }
            else
            {
                if (!val.timestampLastReport.isValid())
                {
                    // fake first report timestamp to mark succesful binding
                    // and prevent further bind requests before reports arrive
                    val.timestampLastReport = QDateTime::currentDateTime();
                }
                val.zclSeqNum = zclSeqNum;
                val.minInterval = rq.minInterval;
                val.maxInterval = rq.maxInterval;
                out.push_back(rq);
            }
        }
        else if (lightNode)
        {
            // wait for value is created via polling
            DBG_Printf(DBG_INFO, "skip configure report for cluster: 0x%04X attr: 0x%04X of node 0x%016llX (wait reading or unsupported)\n",
                       bt.binding.clusterId, rq.attributeId, bt.restNode->address().ext());
        }
        else // sensors
        {
            // values doesn't exist, create
            deCONZ::NumericUnion dummy;
            dummy.u64 = 0;
            bt.restNode->setZclValue(NodeValue::UpdateByZclReport, bt.binding.srcEndpoint, bt.binding.clusterId, rq.attributeId, dummy);
            val.zclSeqNum = zclSeqNum;
            val.minInterval = rq.minInterval;
            val.maxInterval = rq.maxInterval;
            out.push_back(rq);
        }
    }

    if (out.empty())
    {
        return false;
    }

    deCONZ::ApsDataRequest apsReq;

    // ZDP Header
    apsReq.dstAddress() = bt.restNode->address();
    apsReq.setDstAddressMode(deCONZ::ApsExtAddress);
    apsReq.setDstEndpoint(bt.binding.srcEndpoint);
    apsReq.setSrcEndpoint(endpoint());
    apsReq.setProfileId(HA_PROFILE_ID);
    apsReq.setRadius(0);
    apsReq.setClusterId(bt.binding.clusterId);
    apsReq.setTxOptions(deCONZ::ApsTxAcknowledgedTransmission);

    deCONZ::ZclFrame zclFrame;
    zclFrame.setSequenceNumber(zclSeqNum);
    zclFrame.setCommandId(deCONZ::ZclConfigureReportingId);

    if (requests.front().manufacturerCode)
    {
        zclFrame.setFrameControl(deCONZ::ZclFCProfileCommand |
                                 deCONZ::ZclFCManufacturerSpecific |
                                 deCONZ::ZclFCDirectionClientToServer |
                                 deCONZ::ZclFCDisableDefaultResponse);
        zclFrame.setManufacturerCode(requests.front().manufacturerCode);
    }
    else
    {
        zclFrame.setFrameControl(deCONZ::ZclFCProfileCommand |
                                 deCONZ::ZclFCDirectionClientToServer |
                                 deCONZ::ZclFCDisableDefaultResponse);
    }

    { // payload
        QDataStream stream(&zclFrame.payload(), QIODevice::WriteOnly);
        stream.setByteOrder(QDataStream::LittleEndian);

        for (const ConfigureReportingRequest &rq : out)
        {
            stream << rq.direction;
            stream << rq.attributeId;
            stream << rq.dataType;
            stream << rq.minInterval;
            stream << rq.maxInterval;

            if (rq.reportableChange16bit != 0xFFFF)
            {
                stream << rq.reportableChange16bit;
            }
            else if (rq.reportableChange8bit != 0xFF)
            {
                stream << rq.reportableChange8bit;
            }
            else if (rq.reportableChange24bit != 0xFFFFFF)
            {
                stream << (qint8) (rq.reportableChange24bit & 0xFF);
                stream << (qint8) ((rq.reportableChange24bit >> 8) & 0xFF);
                stream << (qint8) ((rq.reportableChange24bit >> 16) & 0xFF);
            }
            else if (rq.reportableChange48bit != 0xFFFFFFFF)
            {
                stream << (qint8) (rq.reportableChange48bit & 0xFF);
                stream << (qint8) ((rq.reportableChange48bit >> 8) & 0xFF);
                stream << (qint8) ((rq.reportableChange48bit >> 16) & 0xFF);
                stream << (qint8) ((rq.reportableChange48bit >> 24) & 0xFF);
                stream << (qint8) 0x00;
                stream << (qint8) 0x00;
            }
            DBG_Printf(DBG_INFO_L2, "configure reporting rq seq %u for 0x%016llX, attribute 0x%04X/0x%04X\n", zclSeqNum, bt.restNode->address().ext(), bt.binding.clusterId, rq.attributeId);
        }
    }

    { // ZCL frame
        QDataStream stream(&apsReq.asdu(), QIODevice::WriteOnly);
        stream.setByteOrder(QDataStream::LittleEndian);
        zclFrame.writeToStream(stream);
    }


    if (apsCtrl && apsCtrl->apsdeDataRequest(apsReq) == deCONZ::Success)
    {
        queryTime = queryTime.addSecs(1);
        return true;
    }

    return false;
}

/*! Sends a ZCL configure attribute reporting request.
    \param bt a former binding task
 */
bool DeRestPluginPrivate::sendConfigureReportingRequest(BindingTask &bt)
{
    if (!bt.restNode || !bt.restNode->node())
    {
        return false;
    }

    deCONZ::SimpleDescriptor *sd = bt.restNode->node()->getSimpleDescriptor(bt.binding.srcEndpoint);
    if (!sd)
    {
        return false;
    }

    // check if bound cluster is server cluster
    deCONZ:: ZclCluster *cl = sd->cluster(bt.binding.clusterId, deCONZ::ServerCluster);
    if (!cl)
    {
        return false;
    }

    const QDateTime now = QDateTime::currentDateTime();
    ConfigureReportingRequest rq;

    LightNode *lightNode = dynamic_cast<LightNode *>(bt.restNode);
    const quint16 manufacturerCode = lightNode ? lightNode->manufacturerCode() : 0;

    if (bt.binding.clusterId == OCCUPANCY_SENSING_CLUSTER_ID)
    {
        // add values if not already present
        deCONZ::NumericUnion dummy;
        dummy.u64 = 0;
        if (bt.restNode->getZclValue(bt.binding.clusterId, 0x0000, bt.binding.srcEndpoint).clusterId != bt.binding.clusterId)
        {
            bt.restNode->setZclValue(NodeValue::UpdateInvalid, bt.binding.srcEndpoint, bt.binding.clusterId, 0x0000, dummy);
        }

        rq.dataType = deCONZ::Zcl8BitBitMap;
        rq.attributeId = 0x0000; // occupancy
        rq.minInterval = 1;     // value used by Hue bridge
        rq.maxInterval = 300;   // value used by Hue bridge

        int processed = 0;
        if (sendConfigureReportingRequest(bt, {rq}))
        {
            processed++;
        }

        const Sensor *sensor = static_cast<Sensor *>(bt.restNode);
        if (sensor && sensor->modelId().startsWith(QLatin1String("SML00"))) // Hue motion sensor
        {
            if (bt.restNode->getZclValue(bt.binding.clusterId, 0x0030, bt.binding.srcEndpoint).clusterId != bt.binding.clusterId)
            {
                bt.restNode->setZclValue(NodeValue::UpdateInvalid, bt.binding.srcEndpoint, bt.binding.clusterId, 0x0030, dummy);
            }
            ConfigureReportingRequest rq2;
            rq2.dataType = deCONZ::Zcl8BitUint;
            rq2.attributeId = 0x0030;     // sensitivity
            rq2.minInterval = 5;         // value used by Hue bridge
            rq2.maxInterval = 7200;      // value used by Hue bridge
            rq2.reportableChange8bit = 1;  // value used by Hue bridge
            rq2.manufacturerCode = VENDOR_PHILIPS;

            if (sendConfigureReportingRequest(bt, {rq2}))
            {
                processed++;
            }
        }

        return processed > 0;
    }
    else if (bt.binding.clusterId == IAS_ZONE_CLUSTER_ID)
    {
        // zone status reporting only supported by some devices
        if (bt.restNode->node()->nodeDescriptor().manufacturerCode() != VENDOR_CENTRALITE &&
            bt.restNode->node()->nodeDescriptor().manufacturerCode() != VENDOR_SAMJIN)
        {
            return false;
        }

        // add values if not already present
        deCONZ::NumericUnion dummy;
        dummy.u64 = 0;
        if (bt.restNode->getZclValue(bt.binding.clusterId, IAS_ZONE_CLUSTER_ATTR_ZONE_STATUS_ID, bt.binding.srcEndpoint).clusterId != bt.binding.clusterId)
        {
            bt.restNode->setZclValue(NodeValue::UpdateInvalid, bt.binding.srcEndpoint, bt.binding.clusterId, IAS_ZONE_CLUSTER_ATTR_ZONE_STATUS_ID, dummy);
        }

        const Sensor *sensor = dynamic_cast<Sensor *>(bt.restNode);

        if (sensor->type() == QLatin1String("ZHAVibration") && sensor->modelId() == QLatin1String("multi")) // FIXME: check if this also applies to other Samjin sensors
        // if (bt.restNode->node()->nodeDescriptor().manufacturerCode() == VENDOR_SAMJIN)
        {
            // Only configure periodic reports, as events are already sent though zone status change notification commands
            rq.minInterval = 300;
            rq.maxInterval = 300;
        }
        else
        {
            rq.minInterval = 1;
            rq.maxInterval = 300;

            const ResourceItem *item = sensor ? sensor->item(RConfigDuration) : nullptr;

            if (item && item->toNumber() > 15 && item->toNumber() <= UINT16_MAX)
            {
                rq.maxInterval = static_cast<quint16>(item->toNumber());
                rq.maxInterval -= 5; // report before going presence: false
            }
        }

        rq.dataType = deCONZ::Zcl16BitBitMap;
        rq.attributeId = IAS_ZONE_CLUSTER_ATTR_ZONE_STATUS_ID;
        rq.reportableChange16bit = 0xffff;
        return sendConfigureReportingRequest(bt, {rq});
    }
    else if (bt.binding.clusterId == ILLUMINANCE_MEASUREMENT_CLUSTER_ID)
    {
        Sensor *sensor = dynamic_cast<Sensor *>(bt.restNode);

        rq.dataType = deCONZ::Zcl16BitUint;
        rq.attributeId = 0x0000;         // measured value

        if (sensor && sensor->modelId().startsWith(QLatin1String("MOSZB-130"))) // Develco motion sensor
        {
            rq.minInterval = 0;
            rq.maxInterval = 600;
            rq.reportableChange16bit = 0xFFFF;
        }
        else
        {
            rq.minInterval = 5;              // value used by Hue bridge
            rq.maxInterval = 300;            // value used by Hue bridge
            rq.reportableChange16bit = 2000; // value used by Hue bridge
        }
        return sendConfigureReportingRequest(bt, {rq});
    }
    else if (bt.binding.clusterId == TEMPERATURE_MEASUREMENT_CLUSTER_ID)
    {
        Sensor *sensor = dynamic_cast<Sensor *>(bt.restNode);

        rq.dataType = deCONZ::Zcl16BitInt;
        rq.attributeId = 0x0000;       // measured value

        if (sensor && (sensor->modelId().startsWith(QLatin1String("SMSZB-120")) ||   // Develco smoke sensor
                        sensor->modelId().startsWith(QLatin1String("HESZB-120")) ||  // Develco heat sensor
                        sensor->modelId().startsWith(QLatin1String("MOSZB-130")) ||  // Develco motion sensor
                        sensor->modelId().startsWith(QLatin1String("WISZB-120")) ||  // Develco window sensor
                        sensor->modelId().startsWith(QLatin1String("FLSZB-110")) ||  // Develco water leak sensor
                        sensor->modelId().startsWith(QLatin1String("ZHMS101"))))     // Wattle (Develco) magnetic sensor
        {
            rq.minInterval = 60;           // according to technical manual
            rq.maxInterval = 600;          // according to technical manual
            rq.reportableChange16bit = 10; // according to technical manual
        }
        else
        {
            rq.minInterval = 10;           // value used by Hue bridge
            rq.maxInterval = 300;          // value used by Hue bridge
            rq.reportableChange16bit = 20; // value used by Hue bridge
        }

        return sendConfigureReportingRequest(bt, {rq});
    }
    else if (bt.binding.clusterId == THERMOSTAT_CLUSTER_ID)
    {
        Sensor *sensor = dynamic_cast<Sensor *>(bt.restNode);

        if (sensor && sensor->modelId().startsWith(QLatin1String("SPZB"))) // Eurotronic Spirit
        {
            rq.dataType = deCONZ::Zcl16BitInt;
            rq.attributeId = 0x0000;        // Local Temperature
            rq.minInterval = 1;             // report changes every second
            rq.maxInterval = 600;           // recommended value
            rq.reportableChange16bit = 20;  // value from TEMPERATURE_MEASUREMENT_CLUSTER_ID

            ConfigureReportingRequest rq2;
            rq2.dataType = deCONZ::Zcl8BitUint;
            rq2.attributeId = 0x0008;        // Pi Heating Demand (valve position %)
            rq2.minInterval = 1;             // report changes every second
            rq2.maxInterval = 600;           // recommended value
            rq2.reportableChange8bit = 1;    // recommended value

            ConfigureReportingRequest rq3;
            rq3.dataType = deCONZ::Zcl16BitInt;
            rq3.attributeId = 0x0012;        // Occupied Heating Setpoint - unused
            rq3.minInterval = 65535;         // disable
            rq3.maxInterval = 65535;         // disable
            rq3.reportableChange16bit = 0;   // disable

            ConfigureReportingRequest rq4;
            rq4.dataType = deCONZ::Zcl16BitInt;
            rq4.attributeId = 0x0014;        // Unoccupied Heating Setpoint - unused
            rq4.minInterval = 65535;         // disable
            rq4.maxInterval = 65535;         // disable
            rq4.reportableChange16bit = 0;   // disable

            ConfigureReportingRequest rq5;
            rq5.dataType = deCONZ::Zcl16BitInt;
            rq5.attributeId = 0x4003;        // Current Temperature Set point
            rq5.minInterval = 1;             // report changes every second
            rq5.maxInterval = 600;           // recommended value
            rq5.reportableChange16bit = 50;  // recommended value
            rq5.manufacturerCode = VENDOR_JENNIC;

            ConfigureReportingRequest rq6;
            rq6.dataType = deCONZ::Zcl24BitUint;
            rq6.attributeId = 0x4008;        // Host Flags
            rq6.minInterval = 1;             // report changes every second
            rq6.maxInterval = 600;           // recommended value
            rq6.reportableChange24bit = 1;   // recommended value
            rq6.manufacturerCode = VENDOR_JENNIC;

            return sendConfigureReportingRequest(bt, {rq, rq2, rq3, rq4}) ||
                   sendConfigureReportingRequest(bt, {rq5, rq6});
        }
        else if (sensor && sensor->modelId() == QLatin1String("Zen-01")) // Zen
        {
            rq.dataType = deCONZ::Zcl16BitInt;
            rq.attributeId = 0x0000;        // Local Temperature
            rq.minInterval = 1;             // report changes every second
            rq.maxInterval = 600;           // recommended value
            rq.reportableChange16bit = 20;  // value from TEMPERATURE_MEASUREMENT_CLUSTER_ID

            ConfigureReportingRequest rq2;
            rq2.dataType = deCONZ::Zcl16BitInt;
            rq2.attributeId = 0x0011;        // Occupied cooling setpoint
            rq2.minInterval = 1;             // report changes every second
            rq2.maxInterval = 600;
            rq2.reportableChange16bit = 50;

            ConfigureReportingRequest rq3;
            rq3.dataType = deCONZ::Zcl16BitInt;
            rq3.attributeId = 0x0012;        // Occupied heating setpoint
            rq3.minInterval = 1;
            rq3.maxInterval = 600;
            rq3.reportableChange16bit = 50;

            ConfigureReportingRequest rq4;
            rq4.dataType = deCONZ::Zcl16BitBitMap;
            rq4.attributeId = 0x0029;        // Thermostat running state
            rq4.minInterval = 1;
            rq4.maxInterval = 600;
            rq4.reportableChange16bit = 0xffff;

            return sendConfigureReportingRequest(bt, {rq, rq2, rq3, rq4});
        }
        else
        {
            rq.dataType = deCONZ::Zcl16BitInt;
            rq.attributeId = 0x0000;       // local temperature
            rq.minInterval = 0;
            rq.maxInterval = 300;
            rq.reportableChange16bit = 10;
            return sendConfigureReportingRequest(bt, {rq});
        }

    }
    else if (bt.binding.clusterId == RELATIVE_HUMIDITY_CLUSTER_ID)
    {
        rq.dataType = deCONZ::Zcl16BitUint;
        rq.attributeId = 0x0000;       // measured value
        rq.minInterval = 10;
        rq.maxInterval = 300;
        rq.reportableChange16bit = 100; // resolution: 1%
        return sendConfigureReportingRequest(bt, {rq});
    }
    else if (bt.binding.clusterId == PRESSURE_MEASUREMENT_CLUSTER_ID)
    {
        rq.dataType = deCONZ::Zcl16BitUint;
        rq.attributeId = 0x0000; // measured value
        rq.minInterval = 10;
        rq.maxInterval = 300;
        rq.reportableChange16bit = 20;
        return sendConfigureReportingRequest(bt, {rq});
    }
    else if (bt.binding.clusterId == BINARY_INPUT_CLUSTER_ID)
    {
        rq.dataType = deCONZ::ZclBoolean;
        rq.attributeId = 0x0055; // present value
        rq.minInterval = 10;
        rq.maxInterval = 300;
        return sendConfigureReportingRequest(bt, {rq});
    }
    else if (bt.binding.clusterId == POWER_CONFIGURATION_CLUSTER_ID)
    {
        Sensor *sensor = dynamic_cast<Sensor *>(bt.restNode);

        rq.dataType = deCONZ::Zcl8BitUint;
        rq.attributeId = 0x0021;   // battery percentage remaining
        if (sensor && (sensor->modelId().startsWith(QLatin1String("SML00")) || // Hue motion sensor
                       sensor->modelId().startsWith(QLatin1String("SPZB"))))   // Eurotronic Spirit
        {
            rq.minInterval = 7200;       // value used by Hue bridge
            rq.maxInterval = 7200;       // value used by Hue bridge
            rq.reportableChange8bit = 0; // value used by Hue bridge
        }
        else if (sensor && sensor->modelId().startsWith(QLatin1String("RWL02"))) // Hue dimmer switch
        {
            rq.minInterval = 300;        // value used by Hue bridge
            rq.maxInterval = 300;        // value used by Hue bridge
            rq.reportableChange8bit = 0; // value used by Hue bridge
        }
        else if (sensor && sensor->modelId().startsWith(QLatin1String("ROM00"))) // Hue smart button
        {
            rq.minInterval = 900;        // value used by Hue bridge
            rq.maxInterval = 900;        // value used by Hue bridge
            rq.reportableChange8bit = 2; // value used by Hue bridge
        }
        else if (sensor && sensor->modelId().startsWith(QLatin1String("Z3-1BRL"))) // Lutron Aurora Friends-of-Hue dimmer switch
        {
            rq.minInterval = 900;        // value used by Hue bridge
            rq.maxInterval = 900;        // value used by Hue bridge
            rq.reportableChange8bit = 4; // value used by Hue bridge
        }
        else if (sensor && (sensor->manufacturer().startsWith(QLatin1String("Climax")) ||
                            sensor->modelId().startsWith(QLatin1String("902010/23"))))
        {
            rq.attributeId = 0x0035; // battery alarm mask
            rq.dataType = deCONZ::Zcl8BitBitMap;
            rq.minInterval = 300;
            rq.maxInterval = 1800;
            rq.reportableChange8bit = 0xFF;
        }
        else if (sensor && (sensor->modelId() == QLatin1String("Motion Sensor-A") ||
                            sensor->modelId() == QLatin1String("tagv4") ||
                            sensor->modelId() == QLatin1String("motionv4") ||
                            sensor->modelId() == QLatin1String("RFDL-ZB-MS") ||
                            sensor->modelId() == QLatin1String("Zen-01")))
        {
            rq.attributeId = 0x0020;   // battery voltage
            rq.minInterval = 3600;
            rq.maxInterval = 3600;
            rq.reportableChange8bit = 0;
        }
        else if (sensor && (sensor->modelId().startsWith(QLatin1String("SMSZB-120")) || // Develco smoke sensor
                           sensor->modelId().startsWith(QLatin1String("HESZB-120")) ||  // Develco heat sensor
                           sensor->modelId().startsWith(QLatin1String("MOSZB-130")) ||  // Develco motion sensor
                           sensor->modelId().startsWith(QLatin1String("WISZB-120")) ||  // Develco window sensor
                           sensor->modelId().startsWith(QLatin1String("FLSZB-110")) ||  // Develco water leak sensor
                           sensor->modelId().startsWith(QLatin1String("ZHMS101"))))     // Wattle (Develco) magnetic sensor
        {
            rq.attributeId = 0x0020;   // battery voltage
            rq.minInterval = 43200;    // according to technical manual
            rq.maxInterval = 43200;    // according to technical manual
            rq.reportableChange8bit = 0;
        }
        else
        {
            rq.minInterval = 300;
            rq.maxInterval = 60 * 45;
            rq.reportableChange8bit = 1;
        }

        // add values if not already present
        deCONZ::NumericUnion dummy;
        dummy.u64 = 0;
        if (bt.restNode->getZclValue(POWER_CONFIGURATION_CLUSTER_ID, rq.attributeId, bt.binding.srcEndpoint).attributeId != rq.attributeId)
        {
            bt.restNode->setZclValue(NodeValue::UpdateInvalid, bt.binding.srcEndpoint, POWER_CONFIGURATION_CLUSTER_ID, rq.attributeId, dummy);
        }

        NodeValue &val = bt.restNode->getZclValue(POWER_CONFIGURATION_CLUSTER_ID, rq.attributeId, bt.binding.srcEndpoint);

        if (val.timestampLastReport.isValid() && (val.timestampLastReport.secsTo(now) < val.maxInterval * 1.5))
        {
            return false;
        }

        return sendConfigureReportingRequest(bt, {rq});
    }
    else if (bt.binding.clusterId == ONOFF_CLUSTER_ID)
    {
        rq.dataType = deCONZ::ZclBoolean;
        rq.attributeId = 0x0000; // on/off

        if (checkMacVendor(bt.restNode->address(), VENDOR_DDEL))
        {
            rq.minInterval = 5;
            rq.maxInterval = 180;
        }
        else if (checkMacVendor(bt.restNode->address(), VENDOR_XAL) ||
                 bt.restNode->node()->nodeDescriptor().manufacturerCode() == VENDOR_XAL)
        {
            rq.minInterval = 5;
            rq.maxInterval = 3600;
        }
        else if (manufacturerCode == VENDOR_IKEA)
        {
            rq.minInterval = 0; // same as IKEA gateway
            rq.maxInterval = 0; // same as IKEA gateway
        }
        else // default configuration
        {
            rq.minInterval = 1;
            rq.maxInterval = 300;
        }
        return sendConfigureReportingRequest(bt, {rq});
    }
    else if (bt.binding.clusterId == METERING_CLUSTER_ID)
    {
        Sensor *sensor = dynamic_cast<Sensor *>(bt.restNode);

        rq.dataType = deCONZ::Zcl48BitUint;
        rq.attributeId = 0x0000; // Curent Summation Delivered
        rq.minInterval = 1;
        rq.maxInterval = 300;
        if (sensor && (sensor->modelId() == QLatin1String("SmartPlug") || // Heiman
                       sensor->modelId() == QLatin1String("SKHMP30-I1"))) // GS smart plug
        {
            rq.reportableChange48bit = 10; // 0.001 kWh (1 Wh)
        }
        else if (sensor && (sensor->modelId() == QLatin1String("SZ-ESW01-AU"))) // Sercomm / Telstra smart plug
        {
            rq.reportableChange48bit = 1000; // 0.001 kWh (1 Wh)
        }
        else
        {
            rq.reportableChange48bit = 1; // 0.001 kWh (1 Wh)
        }

        ConfigureReportingRequest rq2;
        rq2.dataType = deCONZ::Zcl24BitInt;
        rq2.attributeId = 0x0400; // Instantaneous Demand
        rq2.minInterval = 1;
        rq2.maxInterval = 300;
        if (sensor && (sensor->modelId() == QLatin1String("SmartPlug") || // Heiman
                       sensor->modelId() == QLatin1String("902010/25") || // Bitron
                       sensor->modelId() == QLatin1String("SKHMP30-I1"))) // GS smart plug
        {
            rq2.reportableChange24bit = 10; // 1 W
        }
        else if (sensor && (sensor->modelId() == QLatin1String("SZ-ESW01-AU"))) // Sercomm / Telstra smart plug
        {
            rq2.reportableChange24bit = 1000; // 1 W
        }
        else
        {
            rq2.reportableChange24bit = 1; // 1 W
        }

        return sendConfigureReportingRequest(bt, {rq, rq2});
    }
    else if (bt.binding.clusterId == ELECTRICAL_MEASUREMENT_CLUSTER_ID)
    {
        Sensor *sensor = dynamic_cast<Sensor *>(bt.restNode);

        rq.dataType = deCONZ::Zcl16BitInt;
        rq.attributeId = 0x050B; // Active power
        rq.minInterval = 1;
        rq.maxInterval = 300;
        if (sensor && (sensor->modelId() == QLatin1String("SmartPlug") ||   // Heiman
                       sensor->modelId() == QLatin1String("SKHMP30-I1") ||  // GS smart plug
                       sensor->modelId() == QLatin1String("SZ-ESW01-AU")))  // Sercomm / Telstra smart plug
        {
            rq.reportableChange16bit = 10; // 1 W
        }
        else
        {
            rq.reportableChange16bit = 1; // 1 W
        }

        ConfigureReportingRequest rq2;
        rq2.dataType = deCONZ::Zcl16BitUint;
        rq2.attributeId = 0x0505; // RMS Voltage
        rq2.minInterval = 1;
        rq2.maxInterval = 300;
        if (sensor && (sensor->modelId() == QLatin1String("SmartPlug") || // Heiman
                       sensor->modelId() == QLatin1String("SKHMP30-I1"))) // GS smart plug
        {
            rq2.reportableChange16bit = 100; // 1 V
        }
        else if (sensor && sensor->modelId() == QLatin1String("SZ-ESW01-AU")) // Sercomm / Telstra smart plug
        {
            rq2.reportableChange16bit = 125; // 1 V
        }
        else
        {
            rq2.reportableChange16bit = 1; // 1 V
        }

        ConfigureReportingRequest rq3;
        rq3.dataType = deCONZ::Zcl16BitUint;
        rq3.attributeId = 0x0508; // RMS Current
        rq3.minInterval = 1;
        rq3.maxInterval = 300;
        if (sensor && (sensor->modelId() == QLatin1String("SP 120") ||           // innr
                       sensor->modelId() == QLatin1String("DoubleSocket50AU") || // Aurora
                       sensor->modelId() == QLatin1String("SZ-ESW01-AU")))       // Sercomm / Telstra smart plug
        {
            rq3.reportableChange16bit = 100; // 0.1 A
        }
        else if (sensor && (sensor->modelId() == QLatin1String("SmartPlug") ||  // Heiman
                            sensor->modelId() == QLatin1String("EMIZB-132") ||  // Develco
                            sensor->modelId() == QLatin1String("SKHMP30-I1")))  // GS smart plug
        {
            rq3.reportableChange16bit = 10; // 0.1 A
        }
        else
        {
            rq3.reportableChange16bit = 1; // 0.1 A
        }

        return sendConfigureReportingRequest(bt, {rq, rq2, rq3});
    }
    else if (bt.binding.clusterId == LEVEL_CLUSTER_ID)
    {
        rq.dataType = deCONZ::Zcl8BitUint;
        rq.attributeId = 0x0000; // current level

        if (checkMacVendor(bt.restNode->address(), VENDOR_DDEL))
        {
            rq.minInterval = 5;
            rq.maxInterval = 180;
            rq.reportableChange8bit = 5;
        }
        else if (manufacturerCode ==  VENDOR_IKEA)
        {
            // same as IKEA gateway
            rq.minInterval = 1;
            rq.maxInterval = 0;
            rq.reportableChange8bit = 0;
        }
        else // default configuration
        {
            rq.minInterval = 1;
            rq.maxInterval = 300;
            rq.reportableChange8bit = 1;
        }
        return sendConfigureReportingRequest(bt, {rq});
    }
    else if (bt.binding.clusterId == WINDOW_COVERING_CLUSTER_ID)
    {
        rq.dataType = deCONZ::Zcl8BitUint;
        rq.attributeId = 0x0008; // Current Position Lift Percentage
        rq.minInterval = 1;
        rq.maxInterval = 300;
        rq.reportableChange8bit = 1;

        return sendConfigureReportingRequest(bt, {rq});
    }
    else if (bt.binding.clusterId == FAN_CONTROL_CLUSTER_ID)
    {
        rq.dataType = deCONZ::Zcl8BitEnum;
        rq.attributeId = 0x0000; // fan speed
        rq.minInterval = 1;
        rq.maxInterval = 300;

        return sendConfigureReportingRequest(bt, {rq});
    }
    else if (bt.binding.clusterId == COLOR_CLUSTER_ID)
    {
        rq.dataType = deCONZ::Zcl16BitUint;
        rq.attributeId = 0x0007; // color temperature
        rq.minInterval = 1;
        rq.maxInterval = 300;
        rq.reportableChange16bit = 1;

        ConfigureReportingRequest rq2;
        rq2.dataType = deCONZ::Zcl16BitUint;
        rq2.attributeId = 0x0003; // colorX
        rq2.minInterval = 1;
        rq2.maxInterval = 300;
        rq2.reportableChange16bit = 10;

        ConfigureReportingRequest rq3;
        rq3.dataType = deCONZ::Zcl16BitUint;
        rq3.attributeId = 0x0004; // colorY
        rq3.minInterval = 1;
        rq3.maxInterval = 300;
        rq3.reportableChange16bit = 10;

        ConfigureReportingRequest rq4;
        rq4.dataType = deCONZ::Zcl8BitEnum;
        rq4.attributeId = 0x0008; // color mode
        rq4.minInterval = 1;
        rq4.maxInterval = 300;

        if (manufacturerCode == VENDOR_IKEA)
        {
            // same as IKEA gateway
            rq.minInterval = 0;
            rq.maxInterval = 0;
            rq.reportableChange16bit = 0;
            rq2.minInterval = 0;
            rq2.maxInterval = 0;
            rq2.reportableChange16bit = 0;
            rq3.minInterval = 0;
            rq3.maxInterval = 0;
            rq3.reportableChange16bit = 0;
            rq4.minInterval = 0;
            rq4.maxInterval = 0;
        }

        return sendConfigureReportingRequest(bt, {rq, rq2, rq3, rq4});
    }
    else if (bt.binding.clusterId == SAMJIN_CLUSTER_ID && checkMacVendor(bt.restNode->address(), VENDOR_SAMJIN))
    {
        Sensor *sensor = dynamic_cast<Sensor*>(bt.restNode);
        if (!sensor)
        {
            return false;
        }

        // based on https://github.com/SmartThingsCommunity/SmartThingsPublic/blob/master/devicetypes/smartthings/smartsense-multi-sensor.src/smartsense-multi-sensor.groovy
        if (sensor->type() == QLatin1String("ZHAVibration") && sensor->modelId() == QLatin1String("multi"))
        {
            rq.dataType = deCONZ::Zcl16BitInt;
            rq.attributeId = 0x0012; // acceleration x
            rq.minInterval = 1;
            rq.maxInterval = 300;
            rq.reportableChange16bit = 1;
            rq.manufacturerCode = VENDOR_SAMJIN;

            ConfigureReportingRequest rq2;
            rq2.dataType = deCONZ::Zcl16BitInt;
            rq2.attributeId = 0x0013; // acceleration y
            rq2.minInterval = 1;
            rq2.maxInterval = 300;
            rq2.reportableChange16bit = 1;
            rq2.manufacturerCode = VENDOR_SAMJIN;

            ConfigureReportingRequest rq3;
            rq3.dataType = deCONZ::Zcl16BitInt;
            rq3.attributeId = 0x0014; // acceleration z
            rq3.minInterval = 1;
            rq3.maxInterval = 300;
            rq3.reportableChange16bit = 1;
            rq3.manufacturerCode = VENDOR_SAMJIN;

            return sendConfigureReportingRequest(bt, {rq, rq2, rq3});
        }
    }
    else if (bt.binding.clusterId == BASIC_CLUSTER_ID && checkMacVendor(bt.restNode->address(), VENDOR_PHILIPS))
    {
        Sensor *sensor = dynamic_cast<Sensor*>(bt.restNode);
        if (!sensor)
        {
            return false;
        }

        // only process for presence sensor: don't issue configuration for temperature and illuminance sensors
        // TODO check if just used for hue motion sensor or also hue dimmer switch?
        if (sensor->type() != QLatin1String("ZHAPresence"))
        {
            return false;
        }

        deCONZ::NumericUnion dummy;
        dummy.u64 = 0;
        // add usertest value if not already present
        if (bt.restNode->getZclValue(BASIC_CLUSTER_ID, 0x0032, bt.binding.srcEndpoint).attributeId != 0x0032)
        {
            bt.restNode->setZclValue(NodeValue::UpdateInvalid, bt.binding.srcEndpoint, BASIC_CLUSTER_ID, 0x0032, dummy);
        }
        // ledindication value if not already present
        if (bt.restNode->getZclValue(BASIC_CLUSTER_ID, 0x0033, bt.binding.srcEndpoint).attributeId != 0x0033)
        {
            bt.restNode->setZclValue(NodeValue::UpdateInvalid, bt.binding.srcEndpoint, BASIC_CLUSTER_ID, 0x0033, dummy);
        }

        NodeValue &val = bt.restNode->getZclValue(BASIC_CLUSTER_ID, 0x0032, bt.binding.srcEndpoint);

        if (val.timestampLastReport.isValid() && (val.timestampLastReport.secsTo(now) < val.maxInterval * 1.5))
        {
            return false;
        }

        // already configured? wait for report ...
        if (val.timestampLastConfigured.isValid() && (val.timestampLastConfigured.secsTo(now) < val.maxInterval * 1.5))
        {
            return false;
        }

        rq.dataType = deCONZ::ZclBoolean;
        rq.attributeId = 0x0032; // usertest
        rq.minInterval = 5;   // value used by Hue bridge
        rq.maxInterval = 7200;   // value used by Hue bridge
        rq.manufacturerCode = VENDOR_PHILIPS;

        ConfigureReportingRequest rq2;
        rq2 = ConfigureReportingRequest();
        rq2.dataType = deCONZ::ZclBoolean;
        rq2.attributeId = 0x0033; // ledindication
        rq2.minInterval = 5; // value used by Hue bridge
        rq2.maxInterval = 7200; // value used by Hue bridge
        rq2.manufacturerCode = VENDOR_PHILIPS;

        return sendConfigureReportingRequest(bt, {rq, rq2});
    }
    else if (bt.binding.clusterId == BASIC_CLUSTER_ID && manufacturerCode == VENDOR_IKEA && lightNode)
    {
        deCONZ::NumericUnion dummy;
        dummy.u64 = 0;
        // 'sw build id' value if not already present
        if (bt.restNode->getZclValue(BASIC_CLUSTER_ID, 0x4000, bt.binding.srcEndpoint).attributeId != 0x4000)
        {
            bt.restNode->setZclValue(NodeValue::UpdateInvalid, bt.binding.srcEndpoint, BASIC_CLUSTER_ID, 0x4000, dummy);
        }

        NodeValue &val = bt.restNode->getZclValue(BASIC_CLUSTER_ID, 0x4000, bt.binding.srcEndpoint);

        if (val.timestampLastReport.isValid() && (val.timestampLastReport.secsTo(now) < val.maxInterval * 1.5))
        {
            return false;
        }

        // already configured? wait for report ...
        if (val.timestampLastConfigured.isValid() && (val.timestampLastConfigured.secsTo(now) < val.maxInterval * 1.5))
        {
            return false;
        }

        rq.dataType = deCONZ::ZclCharacterString;
        rq.attributeId = 0x4000; // sw build id
        rq.minInterval = 0;   // value used by IKEA gateway
        rq.maxInterval = 1800;   // value used by IKEA gateway

        return sendConfigureReportingRequest(bt, {rq});
    }
    else if (bt.binding.clusterId == VENDOR_CLUSTER_ID)
    {
        Sensor *sensor = dynamic_cast<Sensor *>(bt.restNode);

        if (sensor && (sensor->modelId().startsWith(QLatin1String("RWL02")) || // Hue dimmer switch
                       sensor->modelId().startsWith(QLatin1String("ROM00")) || // Hue smart button
                       sensor->modelId().startsWith(QLatin1String("Z3-1BRL")))) // Lutron Aurora Friends-of-Hue dimmer switch
        {
            deCONZ::NumericUnion val;
            val.u64 = 0;

            // mark button event binding as resolved
            sensor->setZclValue(NodeValue::UpdateByZclReport, bt.binding.srcEndpoint, VENDOR_CLUSTER_ID, 0x0000, val);
            NodeValue &val2 = bt.restNode->getZclValue(VENDOR_CLUSTER_ID, 0x0000, bt.binding.srcEndpoint);
            if (val2.maxInterval == 0)
            {
                val2.maxInterval = 60 * 60 * 8; // prevent further check for 8 hours
            }
        }
        else if (sensor && sensor->modelId() == QLatin1String("de_spect")) // dresden elektronik spectral sensor
        {
            rq.dataType = deCONZ::Zcl8BitUint;
            rq.attributeId = 0x0000; // sensor enabled
            rq.minInterval = 1;
            rq.maxInterval = 120;
            rq.reportableChange8bit = 1;

            ConfigureReportingRequest rq2;
            rq2 = ConfigureReportingRequest();
            rq2.dataType = deCONZ::Zcl16BitUint;
            rq2.attributeId = 0x0001; // spectral x
            rq2.minInterval = 1;
            rq2.maxInterval = 300;
            rq2.reportableChange16bit = 200;

            ConfigureReportingRequest rq3;
            rq3 = ConfigureReportingRequest();
            rq3.dataType = deCONZ::Zcl16BitUint;
            rq3.attributeId = 0x0002; // spectral x
            rq3.minInterval = 1;
            rq3.maxInterval = 300;
            rq3.reportableChange16bit = 200;

            ConfigureReportingRequest rq4;
            rq4 = ConfigureReportingRequest();
            rq4.dataType = deCONZ::Zcl16BitUint;
            rq4.attributeId = 0x0003; // spectral x
            rq4.minInterval = 1;
            rq4.maxInterval = 300;
            rq4.reportableChange16bit = 200;

            return sendConfigureReportingRequest(bt, {rq, rq2, rq3, rq4});
        }
    }
    return false;
}

/*! Creates binding for attribute reporting to gateway node. */
void DeRestPluginPrivate::checkLightBindingsForAttributeReporting(LightNode *lightNode)
{
    if (!apsCtrl || !lightNode || !lightNode->address().hasExt())
    {
        return;
    }

    // prevent binding action if otau was busy recently
    if (otauLastBusyTimeDelta() < OTA_LOW_PRIORITY_TIME)
    {
        if (lightNode->modelId().startsWith(QLatin1String("FLS-")))
        {
            DBG_Printf(DBG_INFO, "don't check binding for attribute reporting of %s (otau busy)\n", qPrintable(lightNode->name()));
            return;
        }
    }

    BindingTask::Action action = BindingTask::ActionUnbind;

    // whitelist
    if (gwReportingEnabled)
    {
        action = BindingTask::ActionBind;
        if (lightNode->modelId().startsWith(QLatin1String("FLS-NB")))
        {
        }
        else if (lightNode->manufacturer() == QLatin1String("OSRAM"))
        {
        }
        else if (lightNode->manufacturer() == QLatin1String("LEDVANCE"))
        {
        }
        else if (lightNode->manufacturerCode() == VENDOR_JASCO)
        {
        }
        else if (lightNode->manufacturerCode() == VENDOR_UBISYS)
        {
        }
        else if (lightNode->manufacturerCode() == VENDOR_IKEA)
        {
        }
        else if (lightNode->manufacturerCode() == VENDOR_EMBER)
        {
        }
        else if (lightNode->manufacturerCode() == VENDOR_LGE)
        {
        }
        else if (lightNode->manufacturerCode() == VENDOR_KEEN_HOME)
        {
        }
        else if (lightNode->manufacturerCode() == VENDOR_XAL)
        {
        }
        else if (lightNode->manufacturerCode() == VENDOR_SINOPE)
        {
        }
        else if (lightNode->modelId() == QLatin1String("SP 120"))
        {
        }
        else if (lightNode->manufacturer().startsWith(QLatin1String("Climax")))
        {
        }
        else if (lightNode->manufacturer().startsWith(QLatin1String("Bitron")))
        {
        }
        else if (lightNode->modelId() == QLatin1String("NL08-0800")) // Nanoleaf Ivy
        {
        }
        else if (lightNode->modelId().startsWith(QLatin1String("ICZB-"))) // iCasa Dimmer and Switch
        {
        }
        else if (lightNode->manufacturer().startsWith(QLatin1String("Develco"))) // Develco devices
        {
        }
        else if (lightNode->modelId().startsWith(QLatin1String("RICI01"))) // LifeControl smart plug
        {
        }
        else if (lightNode->modelId() == QLatin1String("SPLZB-131"))
        {
        }
        else if (lightNode->manufacturer() == QString("欧瑞博") || lightNode->manufacturer() == QLatin1String("ORVIBO"))
        {
        }
        else if (lightNode->manufacturerCode() == VENDOR_LEGRAND) // Legrand switch and plug
        {
        }
        else if (lightNode->manufacturerCode() == VENDOR_NETVOX) // Netvox smart plug
        {
        }
        else
        {
            return;
        }
    }
    else
    {
        return;
    }

    QList<deCONZ::ZclCluster>::const_iterator i = lightNode->haEndpoint().inClusters().begin();
    QList<deCONZ::ZclCluster>::const_iterator end = lightNode->haEndpoint().inClusters().end();

    int tasksAdded = 0;
    QDateTime now = QDateTime::currentDateTime();

    for (; i != end; ++i)
    {
        switch (i->id())
        {
        case BASIC_CLUSTER_ID:
        case ONOFF_CLUSTER_ID:
        case LEVEL_CLUSTER_ID:
        case COLOR_CLUSTER_ID:
        case WINDOW_COVERING_CLUSTER_ID:
        case IAS_ZONE_CLUSTER_ID:
        case FAN_CONTROL_CLUSTER_ID:
        {
            bool bindingExists = false;
            for (const NodeValue &val : lightNode->zclValues())
            {
                if (val.clusterId != i->id())
                {
                    continue;
                }

                quint16 maxInterval = val.maxInterval > 0 && val.maxInterval < 65535 ? val.maxInterval : (10 * 60);

                if (val.timestampLastReport.isValid() && val.timestampLastReport.secsTo(now) < (maxInterval * 1.2))
                {
                    bindingExists = true;
                    break;
                }

                if (val.timestampLastConfigured.isValid())
                {
                    bindingExists = true;
                    break;
                }
            }

            // only IKEA lights should report basic cluster attributes
            if (lightNode->manufacturerCode() != VENDOR_IKEA && i->id() == BASIC_CLUSTER_ID)
            {
                continue;
            }

            BindingTask bt;
            if (checkMacVendor(lightNode->address(), VENDOR_DDEL))
            {
                bt.state = BindingTask::StateCheck;
            }
            else
            {
                bt.state = BindingTask::StateIdle;
            }
            bt.action = action;
            bt.restNode = lightNode;
            Binding &bnd = bt.binding;
            bnd.srcAddress = lightNode->address().ext();
            bnd.dstAddrMode = deCONZ::ApsExtAddress;
            bnd.srcEndpoint = lightNode->haEndpoint().endpoint();
            bnd.clusterId = i->id();
            bnd.dstAddress.ext = apsCtrl->getParameter(deCONZ::ParamMacAddress);
            bnd.dstEndpoint = endpoint();

            if (bnd.dstEndpoint > 0) // valid gateway endpoint?
            {
                if (bindingExists)
                {
                    DBG_Printf(DBG_INFO, "binding for cluster 0x%04X of 0x%016llX exists (verified by reporting)\n", i->id(), lightNode->address().ext());
                    sendConfigureReportingRequest(bt);
                }
                else
                {
                    DBG_Printf(DBG_INFO_L2, "create binding for attribute reporting of cluster 0x%04X\n", i->id());
                    queueBindingTask(bt);
                    tasksAdded++;
                }
            }
        }
            break;

        default:
            break;
        }
    }

    if (tasksAdded == 0)
    {
        return;
    }

    if (checkMacVendor(lightNode->address(), VENDOR_DDEL) || lightNode->manufacturerCode() == VENDOR_XAL)
    {
        lightNode->enableRead(READ_BINDING_TABLE);
        lightNode->setNextReadTime(READ_BINDING_TABLE, queryTime);
        queryTime = queryTime.addSecs(5);
        Q_Q(DeRestPlugin);
        q->startZclAttributeTimer(1000);
    }

    if (!bindingTimer->isActive())
    {
        bindingTimer->start();
    }
}


/*! Creates binding for attribute reporting to gateway node.
    \return true - when a binding request got queued.
 */
bool DeRestPluginPrivate::checkSensorBindingsForAttributeReporting(Sensor *sensor)
{
    if (!apsCtrl || !sensor || !sensor->address().hasExt() || !sensor->node() || !sensor->toBool(RConfigReachable))
    {
        return false;
    }

    if (searchSensorsState != SearchSensorsActive &&
        idleTotalCounter < (IDLE_READ_LIMIT + (60 * 15))) // wait for some input before fire bindings
    {
        return false;
    }

    if (sensor->node()->nodeDescriptor().isNull())
    {
        // Whitelist sensors which don't seem to have a valid node descriptor.
        // This is a workaround currently only required for Develco smoke sensor
        // and potentially Bosch motion sensor
        if (sensor->modelId().startsWith(QLatin1String("SMSZB-120")) ||   // Develco smoke sensor
            sensor->modelId().startsWith(QLatin1String("EMIZB-132")) ||   // Develco EMI Norwegian HAN
            sensor->modelId().startsWith(QLatin1String("ISW-ZPR1-WP13"))) // Bosch motion sensor
        {
        }
        else
        {
            return false;
        }
    }

    if (sensor->deletedState() != Sensor::StateNormal)
    {
        return false;
    }

    bool deviceSupported = false;
    // whitelist
        // Climax
    if (sensor->modelId().startsWith(QLatin1String("LM_")) ||
        sensor->modelId().startsWith(QLatin1String("LMHT_")) ||
        sensor->modelId().startsWith(QLatin1String("IR_")) ||
        sensor->modelId().startsWith(QLatin1String("DC_")) ||
        sensor->modelId().startsWith(QLatin1String("PSMD_")) ||
        sensor->modelId().startsWith(QLatin1String("PSMP5_")) ||
        // CentraLite
        sensor->modelId().startsWith(QLatin1String("Motion Sensor-A")) ||
        sensor->modelId().startsWith(QLatin1String("332")) ||
        sensor->modelId().startsWith(QLatin1String("3200-S")) ||
        sensor->modelId().startsWith(QLatin1String("3305-S")) ||
        sensor->modelId().startsWith(QLatin1String("3320-L")) ||
        sensor->modelId().startsWith(QLatin1String("3326-L")) ||
        // dresden elektronik
        (sensor->manufacturer() == QLatin1String("dresden elektronik") && sensor->modelId() == QLatin1String("de_spect")) ||
        // GE
        (sensor->manufacturer() == QLatin1String("Jasco Products") && sensor->modelId() == QLatin1String("45856")) ||
        // NYCE
        sensor->modelId() == QLatin1String("3011") ||
        sensor->modelId() == QLatin1String("3014") ||
        sensor->modelId() == QLatin1String("3043") ||
        // Philips
        sensor->modelId().startsWith(QLatin1String("SML00")) ||
        sensor->modelId().startsWith(QLatin1String("RWL02")) ||
        sensor->modelId().startsWith(QLatin1String("ROM00")) ||
        // Lutron Aurora Friends-of-Hue dimmer switch
        sensor->modelId().startsWith(QLatin1String("Z3-1BRL")) ||
        // ubisys
        sensor->modelId().startsWith(QLatin1String("C4")) ||
        sensor->modelId().startsWith(QLatin1String("D1")) ||
        sensor->modelId().startsWith(QLatin1String("S1")) ||
        sensor->modelId().startsWith(QLatin1String("S2")) ||
        // IKEA
        sensor->modelId().startsWith(QLatin1String("TRADFRI")) ||
        sensor->modelId().startsWith(QLatin1String("SYMFONISK")) ||
        // Keen Home
        sensor->modelId().startsWith(QLatin1String("SV01-")) ||
        // Trust ZPIR-8000
        sensor->modelId().startsWith(QLatin1String("VMS_ADUROLIGHT")) ||
        // Trust ZMST-808
        sensor->modelId().startsWith(QLatin1String("CSW_ADUROLIGHT")) ||
        // iCasa
        sensor->modelId().startsWith(QLatin1String("ICZB-RM")) ||
        // innr
        sensor->modelId() == QLatin1String("SP 120") ||
        sensor->modelId().startsWith(QLatin1String("RC 110")) ||
        // Eurotronic
        sensor->modelId() == QLatin1String("SPZB0001") ||
        // Heiman
        // I don't think the IAS Zone sensor need to be listed here?
        sensor->modelId().startsWith(QLatin1String("SmartPlug")) ||
        sensor->modelId().startsWith(QLatin1String("CO_")) ||
        sensor->modelId().startsWith(QLatin1String("DOOR_")) ||
        sensor->modelId().startsWith(QLatin1String("PIR_")) ||
        sensor->modelId().startsWith(QLatin1String("GAS")) ||
        sensor->modelId().startsWith(QLatin1String("TH-")) ||
        sensor->modelId().startsWith(QLatin1String("SMOK_")) ||
        sensor->modelId().startsWith(QLatin1String("WATER_")) ||
        sensor->modelId().startsWith(QLatin1String("Smoke")) ||
        sensor->modelId().startsWith(QLatin1String("COSensor")) ||
        sensor->modelId().startsWith(QLatin1String("Water")) ||
        sensor->modelId().startsWith(QLatin1String("Door")) ||
        sensor->modelId().startsWith(QLatin1String("WarningDevice")) ||
        sensor->modelId().startsWith(QLatin1String("SKHMP30")) || // GS smart plug
        // Konke
        sensor->modelId() == QLatin1String("3AFE140103020000") ||
        sensor->modelId() == QLatin1String("3AFE130104020015") ||
        sensor->modelId() == QLatin1String("3AFE14010402000D") ||
        // Nimbus
        sensor->modelId().startsWith(QLatin1String("FLS-NB")) ||
        // SmartThings
        sensor->modelId().startsWith(QLatin1String("tagv4")) ||
        sensor->modelId().startsWith(QLatin1String("motionv4")) ||
        (sensor->manufacturer() == QLatin1String("Samjin") && sensor->modelId() == QLatin1String("button")) ||
        (sensor->manufacturer() == QLatin1String("Samjin") && sensor->modelId() == QLatin1String("motion")) ||
        (sensor->manufacturer() == QLatin1String("Samjin") && sensor->modelId() == QLatin1String("multi")) ||
        (sensor->manufacturer() == QLatin1String("Samjin") && sensor->modelId() == QLatin1String("water")) ||
        (sensor->manufacturer() == QLatin1String("Samjin") && sensor->modelId() == QLatin1String("outlet")) ||
        // Bitron
        sensor->modelId().startsWith(QLatin1String("902010")) ||
        // Develco
        sensor->modelId().startsWith(QLatin1String("SMSZB-120")) || // smoke sensor
        sensor->modelId().startsWith(QLatin1String("HESZB-120")) || // heat sensor
        sensor->modelId().startsWith(QLatin1String("WISZB-120")) || // window sensor
        sensor->modelId().startsWith(QLatin1String("FLSZB-110")) || // water leak sensor
        sensor->modelId().startsWith(QLatin1String("MOSZB-130")) || // motion sensor
        sensor->modelId().startsWith(QLatin1String("ZHMS101")) ||   // Wattle (Develco) magnetic sensor
        sensor->modelId().startsWith(QLatin1String("EMIZB-132")) || // EMI Norwegian HAN
        sensor->modelId().startsWith(QLatin1String("SMRZB-33")) || // Smart Relay DIN
        sensor->modelId() == QLatin1String("SPLZB-131") ||
        // LG
        sensor->modelId() == QLatin1String("LG IP65 HMS") ||
        // Sinope
        sensor->modelId() == QLatin1String("WL4200S") ||
        //LifeControl smart plug
        sensor->modelId() == QLatin1String("RICI01") ||
        //LifeControl enviroment sensor
        sensor->modelId() == QLatin1String("VOC_Sensor") ||
        //Legrand
        sensor->modelId() == QLatin1String("Connected outlet") || //Legrand Plug
        sensor->modelId() == QLatin1String("Shutter switch with neutral") || //Legrand shutter switch
        sensor->modelId() == QLatin1String("Dimmer switch w/o neutral") || //Legrand dimmer wired
        sensor->modelId() == QLatin1String("Cable outlet") || //Legrand Cable outlet
        sensor->modelId() == QLatin1String("Remote switch") || //Legrand wireless switch
        sensor->modelId() == QLatin1String("Shutters central remote switch") || //Legrand wireless shutter switch
        sensor->modelId() == QLatin1String("DIN power consumption module") || //Legrand DIN power consumption module
        // ORVIBO
        sensor->modelId().startsWith(QLatin1String("SN10ZW")) ||
        sensor->modelId().startsWith(QLatin1String("SF2")) ||
        // Netvox
        sensor->modelId().startsWith(QLatin1String("Z809A")) ||
        // Samsung SmartPlug 2019
        sensor->modelId().startsWith(QLatin1String("ZB-ONOFFPlug-D0005")) ||
        // Aurora
        sensor->modelId().startsWith(QLatin1String("DoubleSocket50AU")) ||
        // Bosch
        sensor->modelId().startsWith(QLatin1String("ISW-ZDL1-WP11G")) ||
        sensor->modelId().startsWith(QLatin1String("ISW-ZPR1-WP13")) ||
        sensor->modelId().startsWith(QLatin1String("RFDL-ZB-MS")) ||
        // Salus
        sensor->modelId().contains(QLatin1String("SP600")) ||
        // Zen
        sensor->modelId().contains(QLatin1String("Zen-01")) ||
        // eCozy
        sensor->modelId() == QLatin1String("Thermostat") ||
        // Stelpro
        sensor->modelId().contains(QLatin1String("ST218")) ||
        // Tuya
        sensor->modelId().contains(QLatin1String("TS0201")) ||
        // Tuyatec
        sensor->modelId().startsWith(QLatin1String("RH3040")) ||
        sensor->modelId().startsWith(QLatin1String("RH3001")) ||
        sensor->modelId().startsWith(QLatin1String("RH3052")) ||
        // Xiaomi
        sensor->modelId().startsWith(QLatin1String("lumi.plug.maeu01")) ||
        // iris
        sensor->modelId().startsWith(QLatin1String("1116-S")) ||
        sensor->modelId().startsWith(QLatin1String("1117-S")) ||
        // Hive
        sensor->modelId() == QLatin1String("MOT003"))
    {
        deviceSupported = true;
        if (!sensor->node()->nodeDescriptor().receiverOnWhenIdle() ||
            (sensor->node()->nodeDescriptor().manufacturerCode() != VENDOR_DDEL))
        {
            sensor->setMgmtBindSupported(false);
        }
    }

    if (!deviceSupported)
    {
        DBG_Printf(DBG_INFO_L2, "don't create binding for attribute reporting of sensor %s\n", qPrintable(sensor->name()));
        return false;
    }

    // prevent binding action if otau was busy recently
    if (otauLastBusyTimeDelta() < OTA_LOW_PRIORITY_TIME)
    {
        if (sensor->modelId().startsWith(QLatin1String("FLS-")))
        {
            DBG_Printf(DBG_INFO_L2, "don't check binding for attribute reporting of %s (otau busy)\n", qPrintable(sensor->name()));
            return false;
        }
    }

    BindingTask::Action action = BindingTask::ActionUnbind;

    // whitelist by Model ID
    if (gwReportingEnabled)
    {
//        if (sensor->modelId().startsWith(QLatin1String("FLS-NB")))
//        {
//            // temporary disable, delete bindings and use read attributes
//        }
        if (deviceSupported)
        {
            action = BindingTask::ActionBind;
        }
    }

    bool ret = false;
    bool checkBindingTable = false;
    QDateTime now = QDateTime::currentDateTime();

    // sort server clusters so that 'more important' clusters will be bound as soon as possible
    // 0xfc00, 0x0500, 0x0406, 0x0402, 0x0400, 0x0001

    // for example for Philips motion sensor after joining the occupancy cluster 0x0406 is more
    // important than power configuration cluster 0x0001 and should be bound first

    // for the Philips dimmer switch the 0xfc00 for button events is also the most important
    std::vector<quint16> inClusters = sensor->fingerPrint().inClusters;
    std::sort(sensor->fingerPrint().inClusters.begin(), sensor->fingerPrint().inClusters.end(),
              [](quint16 a, quint16 b) { return a < b; });

    std::vector<quint16>::const_iterator i = inClusters.begin();
    std::vector<quint16>::const_iterator end = inClusters.end();

    for (; i != end; ++i)
    {
        NodeValue val;

        if (*i == ILLUMINANCE_MEASUREMENT_CLUSTER_ID)
        {
            val = sensor->getZclValue(*i, 0x0000); // measured value
        }
        else if (*i == TEMPERATURE_MEASUREMENT_CLUSTER_ID)
        {
            val = sensor->getZclValue(*i, 0x0000); // measured value
        }
        else if (*i == RELATIVE_HUMIDITY_CLUSTER_ID)
        {
            val = sensor->getZclValue(*i, 0x0000); // measured value
        }
        else if (*i == PRESSURE_MEASUREMENT_CLUSTER_ID)
        {
            val = sensor->getZclValue(*i, 0x0000); // measured value
        }
        else if (*i == OCCUPANCY_SENSING_CLUSTER_ID)
        {
            if (sensor->modelId() == QLatin1String("Motion Sensor-A"))
            {
                continue; // use ias zone cluster
            }
            val = sensor->getZclValue(*i, 0x0000); // occupied state
        }
        else if (*i == POWER_CONFIGURATION_CLUSTER_ID)
        {
            if (sensor->modelId().startsWith(QLatin1String("SML00")) && sensor->type() != QLatin1String("ZHAPresence"))
            {
                continue; // process only once
            }
            if (sensor->modelId() == QLatin1String("Remote switch") || sensor->modelId() == QLatin1String("Shutters central remote switch") )
            {
                //This device don't support report attribute
                continue;
            }
            if (sensor->manufacturer().startsWith(QLatin1String("Climax")) ||
                sensor->modelId().startsWith(QLatin1String("902010/23")))
            {
                val = sensor->getZclValue(*i, 0x0035); // battery alarm mask
            }
            else if (sensor->modelId() == QLatin1String("Motion Sensor-A") ||
                     sensor->modelId() == QLatin1String("SMSZB-120") ||
                     sensor->modelId() == QLatin1String("HESZB-120") ||
                     sensor->modelId() == QLatin1String("WISZB-120") ||
                     sensor->modelId() == QLatin1String("MOSZB-130") ||
                     sensor->modelId() == QLatin1String("FLSZB-110") ||
                     sensor->modelId() == QLatin1String("Zen-01") ||
                     sensor->modelId() == QLatin1String("Remote switch") ||
                     sensor->modelId() == QLatin1String("Shutters central remote switch") ||
                     sensor->modelId().startsWith(QLatin1String("ZHMS101")) ||
                     sensor->modelId().endsWith(QLatin1String("86opcn01")) || // Aqara Opple
                     sensor->modelId().startsWith(QLatin1String("1116-S")) ||
                     sensor->modelId().startsWith(QLatin1String("1117-S")) ||
                     sensor->modelId().startsWith(QLatin1String("3326-L")) ||
                     sensor->modelId().startsWith(QLatin1String("3305-S")) ||
                     sensor->modelId() == QLatin1String("113D"))
            {
                val = sensor->getZclValue(*i, 0x0020); // battery voltage
            }
            else
            {
                val = sensor->getZclValue(*i, 0x0021); // battery percentage remaining
            }

            if (sensor->modelId() == QLatin1String("TRADFRI remote control") && sensor->swVersion() == QLatin1String("0.9.8.1-5.7.0.0"))
            {
                continue; // too old doesn't support battery percentage remaining attribute
            }

            if (val.timestampLastConfigured.isValid() && val.timestampLastConfigured.secsTo(now) < (val.maxInterval * 1.5))
            {
                continue;
            }

            // assume reporting is working
            if (val.isValid() && val.timestamp.isValid() && val.timestamp.secsTo(now) < (val.maxInterval * 3 / 2))
            {
                continue;
            }
        }
        else if (*i == IAS_ZONE_CLUSTER_ID)
        {
            val = sensor->getZclValue(*i, IAS_ZONE_CLUSTER_ATTR_ZONE_STATUS_ID); // zone status

            if (sensor->manufacturer() == QLatin1String("CentraLite"))
            {
                const ResourceItem *item = sensor->item(RConfigDuration);
                // update max reporting interval according to config.duration
                if (item && item->toNumber() > 15 && item->toNumber() <= UINT16_MAX)
                {
                    val.maxInterval = static_cast<quint16>(item->toNumber());
                    val.maxInterval -= 5; // report before going presence: false
                }
            }
        }
        else if (*i == VENDOR_CLUSTER_ID)
        {
            if (sensor->modelId().startsWith(QLatin1String("RWL02")) || // Hue dimmer switch
                sensor->modelId().startsWith(QLatin1String("ROM00")) || // Hue smart button
                sensor->modelId().startsWith(QLatin1String("Z3-1BRL"))) // Lutron Aurora Friends-of-Hue dimmer switch
            {
                val = sensor->getZclValue(*i, 0x0000); // button event
            }
            if (sensor->modelId() == QLatin1String("de_spect")) // dresden elektronik spectral sensor
            {
                val = sensor->getZclValue(*i, 0x0000, sensor->fingerPrint().endpoint); // sensor enabled per endpoint
            }
        }
        else if (*i == BASIC_CLUSTER_ID)
        {
            if (sensor->modelId().startsWith(QLatin1String("SML00")) && // Hue motion sensor
                sensor->type() == QLatin1String("ZHAPresence"))
            {
                val = sensor->getZclValue(*i, 0x0032); // usertest
                // val = sensor->getZclValue(*i, 0x0033); // ledindication

                if (searchSensorsState != SearchSensorsActive &&
                    idleTotalCounter < (IDLE_READ_LIMIT + (7200))) // wait for max reporting interval before fire bindings
                {
                    continue;
                }

                if (val.timestampLastConfigured.isValid() && val.timestampLastConfigured.secsTo(now) < (val.maxInterval * 1.5))
                {
                    continue;
                }
            }
            else
            {
                continue;
            }
        }
        else if (*i == METERING_CLUSTER_ID)
        {
            val = sensor->getZclValue(*i, 0x0000); // Curent Summation Delivered

        }
        else if (*i == ELECTRICAL_MEASUREMENT_CLUSTER_ID)
        {
            val = sensor->getZclValue(*i, 0x050b); // Active power
        }
        else if (*i == BINARY_INPUT_CLUSTER_ID)
        {
            val = sensor->getZclValue(*i, 0x0055); // Present value
        }
        else if (*i == THERMOSTAT_CLUSTER_ID)
        {
            val = sensor->getZclValue(*i, 0x0000); // Local temperature
        }
        else if (*i == SAMJIN_CLUSTER_ID)
        {
            if (sensor->modelId() == QLatin1String("multi"))
            {
                val = sensor->getZclValue(*i, 0x0012); // Acceleration X
            }
            else
            {
                continue;
            }
        }

        quint16 maxInterval = (val.maxInterval > 0) ? (val.maxInterval * 3 / 2) : (60 * 45);

        if (val.timestampLastReport.isValid() &&
            val.timestampLastReport.secsTo(now) < maxInterval) // got update in timely manner
        {
            DBG_Printf(DBG_INFO_L2, "binding for attribute reporting of ep: 0x%02X cluster 0x%04X seems to be active\n", val.endpoint, *i);
            continue;
        }

        if (!sensor->node()->nodeDescriptor().receiverOnWhenIdle() && sensor->lastRx().secsTo(now) > 6)
        {
            DBG_Printf(DBG_INFO, "skip binding for attribute reporting of ep: 0x%02X cluster 0x%04X (end-device might sleep)\n", val.endpoint, *i);
            return false;
        }

        quint8 srcEndpoint = sensor->fingerPrint().endpoint;

        {  // some clusters might not be on fingerprint endpoint (power configuration), search in other simple descriptors
            deCONZ::SimpleDescriptor *sd= sensor->node()->getSimpleDescriptor(srcEndpoint);
            if (!sd || !sd->cluster(*i, deCONZ::ServerCluster))
            {
                for (int j = 0; j < sensor->node()->simpleDescriptors().size(); j++)
                {
                    sd = &sensor->node()->simpleDescriptors()[j];

                    if (sd && sd->cluster(*i, deCONZ::ServerCluster))
                    {
                        srcEndpoint = sd->endpoint();
                        break;
                    }
                }
            }
        }

        switch (*i)
        {
        case POWER_CONFIGURATION_CLUSTER_ID:
        case OCCUPANCY_SENSING_CLUSTER_ID:
        case IAS_ZONE_CLUSTER_ID:
        case ILLUMINANCE_MEASUREMENT_CLUSTER_ID:
        case TEMPERATURE_MEASUREMENT_CLUSTER_ID:
        case RELATIVE_HUMIDITY_CLUSTER_ID:
        case PRESSURE_MEASUREMENT_CLUSTER_ID:
        case METERING_CLUSTER_ID:
        case ELECTRICAL_MEASUREMENT_CLUSTER_ID:
        case VENDOR_CLUSTER_ID:
        case BASIC_CLUSTER_ID:
        case BINARY_INPUT_CLUSTER_ID:
        case THERMOSTAT_CLUSTER_ID:
        case SAMJIN_CLUSTER_ID:
        {
            DBG_Printf(DBG_INFO_L2, "0x%016llX (%s) create binding for attribute reporting of cluster 0x%04X on endpoint 0x%02X\n",
                       sensor->address().ext(), qPrintable(sensor->modelId()), (*i), srcEndpoint);

            BindingTask bindingTask;

            if (sensor->mgmtBindSupported())
            {
                bindingTask.state = BindingTask::StateCheck;
                checkBindingTable = true;
            }
            else
            {
                bindingTask.state = BindingTask::StateIdle;
            }

            bindingTask.action = action;
            bindingTask.restNode = sensor;
            bindingTask.timeout = BindingTask::TimeoutEndDevice;
            Binding &bnd = bindingTask.binding;
            bnd.srcAddress = sensor->address().ext();
            bnd.dstAddrMode = deCONZ::ApsExtAddress;
            bnd.srcEndpoint = srcEndpoint;
            bnd.clusterId = *i;
            bnd.dstAddress.ext = apsCtrl->getParameter(deCONZ::ParamMacAddress);
            bnd.dstEndpoint = endpoint();

            if (bnd.dstEndpoint > 0) // valid gateway endpoint?
            {
                ret = queueBindingTask(bindingTask);
            }
        }
            break;

        default:
            break;
        }
    }

    if (checkBindingTable)
    {
        sensor->enableRead(READ_BINDING_TABLE);
        sensor->setNextReadTime(READ_BINDING_TABLE, queryTime);
        queryTime = queryTime.addSecs(5);
        Q_Q(DeRestPlugin);
        q->startZclAttributeTimer(1000);
    }

    if (ret)
    {
        // fast iteration
        bindingTimer->start(0);
    }
    else if (!bindingTimer->isActive())
    {
        bindingTimer->start(1000);
    }

    return ret;
}

/*! Creates binding for group control (switches, motion sensor, ...). */
bool DeRestPluginPrivate::checkSensorBindingsForClientClusters(Sensor *sensor)
{
    if (!apsCtrl || !sensor || !sensor->node() || !sensor->address().hasExt() || !sensor->toBool(RConfigReachable))
    {
        return false;
    }

    if (searchSensorsState != SearchSensorsActive &&
        idleTotalCounter < (IDLE_READ_LIMIT + (60 * 15))) // wait for some input before fire bindings
    {
        return false;
    }

    Q_Q(DeRestPlugin);
    QDateTime now = QDateTime::currentDateTime();
    if (!sensor->node()->nodeDescriptor().receiverOnWhenIdle() && sensor->lastRx().secsTo(now) > 10)
    {
        DBG_Printf(DBG_INFO_L2, "skip check bindings for client clusters (end-device might sleep)\n");
        return false;
    }

    ResourceItem *item = sensor->item(RConfigGroup);

    if (!item || item->toString().isEmpty())
    {
        DBG_Printf(DBG_INFO_L2, "skip check bindings for client clusters (no group)\n");
        return false;
    }

    std::vector<quint8> srcEndpoints;
    QStringList gids = item->toString().split(',', QString::SkipEmptyParts);

    //quint8 srcEndpoint = sensor->fingerPrint().endpoint;
    std::vector<quint16> clusters;

    if (sensor->modelId().startsWith(QLatin1String("RWL02")) || // Hue dimmer switch
        sensor->modelId().startsWith(QLatin1String("ROM00"))) // Hue smart button

    {
        srcEndpoints.push_back(0x01);
        clusters.push_back(ONOFF_CLUSTER_ID);
        clusters.push_back(LEVEL_CLUSTER_ID);
    }
    else if (sensor->modelId().startsWith(QLatin1String("Z3-1BRL"))) // Lutron Aurora FoH dimmer switch
    {
        srcEndpoints.push_back(0x01);
        clusters.push_back(LEVEL_CLUSTER_ID);
    }
    // Busch-Jaeger
    else if (sensor->modelId() == QLatin1String("RB01") ||
             sensor->modelId() == QLatin1String("RM01"))
    {
        quint8 firstEp = 0x0A;

        // the model RM01 might have an relais or dimmer switch on endpoint 0x12
        // in that case the endpoint 0x0A has no function
        if (getLightNodeForAddress(sensor->address(), 0x12))
        {
            firstEp = 0x0B;
        }

        if (sensor->fingerPrint().endpoint == firstEp)
        {
            clusters.push_back(LEVEL_CLUSTER_ID);
        }
        else if (sensor->fingerPrint().endpoint > firstEp)
        {
            clusters.push_back(SCENE_CLUSTER_ID);
        }
        srcEndpoints.push_back(sensor->fingerPrint().endpoint);
        sensor->setMgmtBindSupported(false);
    }
    // GE on/off switch 45856GE
    else if (sensor->manufacturer() == QLatin1String("Jasco Products") && sensor->modelId() == QLatin1String("45856"))
    {
        clusters.push_back(ONOFF_CLUSTER_ID);
        srcEndpoints.push_back(sensor->fingerPrint().endpoint);
    }
    // IKEA Trådfri dimmer
    else if (sensor->modelId() == QLatin1String("TRADFRI wireless dimmer"))
    {
        clusters.push_back(LEVEL_CLUSTER_ID);
        srcEndpoints.push_back(sensor->fingerPrint().endpoint);
    }
    // IKEA Trådfri remote
    else if (sensor->modelId().startsWith(QLatin1String("TRADFRI remote")))
    {
        clusters.push_back(ONOFF_CLUSTER_ID);
        clusters.push_back(LEVEL_CLUSTER_ID);
        clusters.push_back(SCENE_CLUSTER_ID);
        srcEndpoints.push_back(sensor->fingerPrint().endpoint);
    }
    // IKEA Trådfri on/off switch
    else if (sensor->modelId().startsWith(QLatin1String("TRADFRI on/off switch")))
    {
        clusters.push_back(ONOFF_CLUSTER_ID);
        srcEndpoints.push_back(sensor->fingerPrint().endpoint);
    }
    // IKEA Trådfri open/close remote
    else if (sensor->modelId().startsWith(QLatin1String("TRADFRI open/close remote")))
    {
        clusters.push_back(WINDOW_COVERING_CLUSTER_ID);
        srcEndpoints.push_back(sensor->fingerPrint().endpoint);
    }
    // IKEA Trådfri motion sensor
    else if (sensor->modelId().startsWith(QLatin1String("TRADFRI motion sensor")))
    {
        clusters.push_back(ONOFF_CLUSTER_ID);
        clusters.push_back(LEVEL_CLUSTER_ID);
        srcEndpoints.push_back(sensor->fingerPrint().endpoint);
    }
    // IKEA SYMFONISK sound controller
    else if (sensor->modelId().startsWith(QLatin1String("SYMFONISK")))
    {
        clusters.push_back(ONOFF_CLUSTER_ID);
        clusters.push_back(LEVEL_CLUSTER_ID);
        srcEndpoints.push_back(sensor->fingerPrint().endpoint);
    }
    // LEGRAND Remote switch
    else if (sensor->modelId() == QLatin1String("Remote switch"))
    {
        clusters.push_back(ONOFF_CLUSTER_ID);
        clusters.push_back(LEVEL_CLUSTER_ID);
        srcEndpoints.push_back(sensor->fingerPrint().endpoint);
    }
    // LEGRAND Remote shutter switch
    else if (sensor->modelId() == QLatin1String("Shutters central remote switch"))
    {
        clusters.push_back(WINDOW_COVERING_CLUSTER_ID);
        srcEndpoints.push_back(sensor->fingerPrint().endpoint);
    }
    else if (sensor->modelId().startsWith(QLatin1String("RC 110")))
    {
        clusters.push_back(ONOFF_CLUSTER_ID);
        clusters.push_back(LEVEL_CLUSTER_ID);
        gids.removeFirst(); // Remote doesn't support bindings on first endpoint.
        srcEndpoints.push_back(0x03);
        srcEndpoints.push_back(0x04);
        srcEndpoints.push_back(0x05);
        srcEndpoints.push_back(0x06);
        srcEndpoints.push_back(0x07);
        srcEndpoints.push_back(0x08);
    }
    else if (sensor->modelId().startsWith(QLatin1String("ICZB-RM")))
    {
        clusters.push_back(ONOFF_CLUSTER_ID);
        clusters.push_back(LEVEL_CLUSTER_ID);
        clusters.push_back(SCENE_CLUSTER_ID);
        srcEndpoints.push_back(0x01);
        srcEndpoints.push_back(0x02);
        srcEndpoints.push_back(0x03);
        srcEndpoints.push_back(0x04);
    }
    else if (sensor->modelId().startsWith(QLatin1String("D1")))
    {
        clusters.push_back(ONOFF_CLUSTER_ID);
        clusters.push_back(LEVEL_CLUSTER_ID);
        srcEndpoints.push_back(0x02);
        srcEndpoints.push_back(0x03);
        sensor->setMgmtBindSupported(true);
    }
    else if (sensor->modelId().startsWith(QLatin1String("S1")))
    {
        clusters.push_back(ONOFF_CLUSTER_ID);
        clusters.push_back(LEVEL_CLUSTER_ID);
        srcEndpoints.push_back(0x02);
        if (sensor->modelId().startsWith(QLatin1String("S1-R")))
        {
            srcEndpoints.push_back(0x03);
        }
        sensor->setMgmtBindSupported(true);
    }
    else if (sensor->modelId().startsWith(QLatin1String("S2")))
    {
        clusters.push_back(ONOFF_CLUSTER_ID);
        clusters.push_back(LEVEL_CLUSTER_ID);
        srcEndpoints.push_back(0x03);
        srcEndpoints.push_back(0x04);
        sensor->setMgmtBindSupported(true);
    }
    else if (sensor->modelId().startsWith(QLatin1String("C4")))
    {
        clusters.push_back(ONOFF_CLUSTER_ID);
        clusters.push_back(LEVEL_CLUSTER_ID);
        srcEndpoints.push_back(0x01);
        srcEndpoints.push_back(0x02);
        srcEndpoints.push_back(0x03);
        srcEndpoints.push_back(0x04);
        sensor->setMgmtBindSupported(true);
    }
    // LifeControl Enviroment Sensor
    else if (sensor->modelId().startsWith(QLatin1String("VOC_Sensor")))
    {
        clusters.push_back(TEMPERATURE_MEASUREMENT_CLUSTER_ID);
        srcEndpoints.push_back(0x00);
        srcEndpoints.push_back(0x01);
        sensor->setMgmtBindSupported(true);
    }
    // Bitron remote control
    else if (sensor->modelId().startsWith(QLatin1String("902010/23")))
    {
        clusters.push_back(ONOFF_CLUSTER_ID);
        clusters.push_back(LEVEL_CLUSTER_ID);
        srcEndpoints.push_back(sensor->fingerPrint().endpoint);
    }
    else
    {
        return false;
    }

    // prevent binding action if otau was busy recently
    if (otauLastBusyTimeDelta() < OTA_LOW_PRIORITY_TIME)
    {
        return false;
    }

    bool ret = false;
    for (int j = 0; j < (int)srcEndpoints.size() && j < gids.size(); j++)
    {
        QString gid = gids[j];
        quint8 srcEndpoint = srcEndpoints[j];
        Group *group = getGroupForId(gid);

        if (!group)
        {
            continue;
        }

        std::vector<quint16>::const_iterator i = clusters.begin();
        std::vector<quint16>::const_iterator end = clusters.end();

        for (; i != end; ++i)
        {
            DBG_Printf(DBG_ZDP, "0x%016llX [%s] create binding for client cluster 0x%04X on endpoint 0x%02X\n",
                       sensor->address().ext(), qPrintable(sensor->modelId()), (*i), srcEndpoint);

            BindingTask bindingTask;

            bindingTask.state = BindingTask::StateIdle;
            bindingTask.action = BindingTask::ActionBind;
            bindingTask.timeout = BindingTask::TimeoutEndDevice;
            bindingTask.restNode = sensor;
            Binding &bnd = bindingTask.binding;
            bnd.srcAddress = sensor->address().ext();
            bnd.dstAddrMode = deCONZ::ApsGroupAddress;
            bnd.srcEndpoint = srcEndpoint;
            bnd.clusterId = *i;
            bnd.dstAddress.group = group->address();

            if (sensor->mgmtBindSupported())
            {
                bindingTask.state = BindingTask::StateCheck;
            }

            if (queueBindingTask(bindingTask))
            {
                ret = true;
            }

            // group addressing has no destination endpoint
//            bnd.dstEndpoint = endpoint();

//            if (bnd.dstEndpoint > 0) // valid gateway endpoint?
//            {
//                queueBindingTask(bindingTask);
//            }
        }
    }

    if (sensor->mgmtBindSupported())
    {
        if (!sensor->mustRead(READ_BINDING_TABLE))
        {
            sensor->enableRead(READ_BINDING_TABLE);
            sensor->setNextReadTime(READ_BINDING_TABLE, queryTime);
            queryTime = queryTime.addSecs(1);
        }
        q->startZclAttributeTimer(1000);
    }

    if (!bindingTimer->isActive())
    {
        bindingTimer->start();
    }

    return ret;
}

/*! Creates groups for \p sensor if needed. */
void DeRestPluginPrivate::checkSensorGroup(Sensor *sensor)
{
    if (!sensor)
    {
        return;
    }

    Group *group = nullptr;

    {
        std::vector<Group>::iterator i = groups.begin();
        std::vector<Group>::iterator end = groups.end();

        for (; i != end; ++i)
        {
            if (i->address() == 0)
            {
                continue;
            }

            if (i->state() == Group::StateNormal &&
                (i->deviceIsMember(sensor->uniqueId()) || i->deviceIsMember(sensor->id())))
            {
                group = &*i;
                break;
            }
        }
    }

    if (sensor->modelId().startsWith(QLatin1String("RWL02")) || // Hue dimmer switch
        sensor->modelId().startsWith(QLatin1String("ROM00")) || // Hue smart button
        sensor->modelId().startsWith(QLatin1String("Z3-1BRL")) || // Lutron Aurora FoH smart dimmer
        sensor->modelId().startsWith(QLatin1String("TRADFRI on/off switch")) ||
        sensor->modelId().startsWith(QLatin1String("TRADFRI open/close remote")) ||
        sensor->modelId().startsWith(QLatin1String("TRADFRI motion sensor")) ||
        sensor->modelId().startsWith(QLatin1String("TRADFRI remote control")) ||
        sensor->modelId().startsWith(QLatin1String("TRADFRI wireless dimmer")) ||
        sensor->modelId().startsWith(QLatin1String("SYMFONISK")) ||
        sensor->modelId().startsWith(QLatin1String("902010/23"))) // bitron remote
    {

    }
    else if (sensor->modelId() == QLatin1String("Remote switch") ||
	     sensor->modelId() == QLatin1String("Shutters central remote switch"))
    {
        //Make group but without uniqueid
    }
    else if (sensor->modelId() == QLatin1String("RB01") ||
             sensor->modelId() == QLatin1String("RM01"))
    {
        // check if group is created for other endpoint
        for (quint8 ep = 0x0A; !group && ep < 0x0F; ep++)
        {
            Sensor *s = getSensorNodeForAddressAndEndpoint(sensor->address(), ep);
            if (s && s->deletedState() == Sensor::StateNormal && s != sensor)
            {
                ResourceItem *item = s->item(RConfigGroup);
                if (item && item->lastSet().isValid())
                {
                    const QString &gid = item->toString();

                    std::vector<Group>::iterator i = groups.begin();
                    std::vector<Group>::iterator end = groups.end();

                    for (; i != end; ++i)
                    {
                        if (!gid.isEmpty() && i->state() == Group::StateNormal && i->id() == gid)
                        {
                            group = &*i;
                            break;
                        }
                    }
                }
            }
        }
    }
    else
    {
        return;
    }

    ResourceItem *item = sensor->item(RConfigGroup);

    if (!item)
    {
        item = sensor->addItem(DataTypeString, RConfigGroup);
    }
    else if (!group && item->lastSet().isValid())
    {
        const QString &gid = item->toString(); //FIXME: handle list of groups

        std::vector<Group>::iterator i = groups.begin();
        std::vector<Group>::iterator end = groups.end();

        for (; i != end; ++i)
        {
            if (i->address() == 0)
            {
                continue;
            }

            if (!gid.isEmpty() && i->state() == Group::StateNormal && i->id() == gid)
            {
                group = &*i;
                break;
            }
        }
    }

    if (!group)
    {
        group = addGroup();
        group->setName(sensor->name());
        ResourceItem *item2 = group->addItem(DataTypeString, RAttrUniqueId);
        DBG_Assert(item2);
        if (item2)
        {
            const QString uid = generateUniqueId(sensor->address().ext(), 0, 0);
            item2->setValue(uid);
        }
    }

    DBG_Assert(group);
    if (!group)
    {
        return;
    }

    if (group->addDeviceMembership(sensor->id()))
    {

    }

    if (item->toString() != group->id()) // FIXME: handle list of groups
    {
        item->setValue(group->id()); // FIXME: handle list of groups
        sensor->setNeedSaveDatabase(true);
        queSaveDb(DB_SENSORS, DB_SHORT_SAVE_DELAY);
        Event e(RSensors, RConfigGroup, sensor->id(), item);
        enqueueEvent(e);
    }
}

/*! Checks if there are any orphan groups for \p sensor and removes them. */
void DeRestPluginPrivate::checkOldSensorGroups(Sensor *sensor)
{
    if (!sensor)
    {
        return;
    }

    ResourceItem *item = sensor->item(RConfigGroup);

    if (!item || !item->lastSet().isValid() || item->toString().isEmpty())
    {
        return;
    }

    QStringList gids = item->toString().split(',', QString::SkipEmptyParts);

    {
        std::vector<Group>::iterator i = groups.begin();
        std::vector<Group>::iterator end = groups.end();

        for (; i != end; ++i)
        {
            if (gids.contains(i->id())) // current group
            {
                if (i->state() != Group::StateNormal)
                {
                    DBG_Printf(DBG_INFO, "reanimate group %u for sensor %s\n", i->address(), qPrintable(sensor->name()));
                    i->setState(Group::StateNormal);
                    updateGroupEtag(&*i);
                    queSaveDb(DB_GROUPS, DB_SHORT_SAVE_DELAY);
                }
            }
            else if (i->deviceIsMember(sensor->uniqueId()) || i->deviceIsMember(sensor->id()))
            {
                if (!i->removeDeviceMembership(sensor->uniqueId()))
                {
                    i->removeDeviceMembership(sensor->id());
                }

                if (i->state() == Group::StateNormal && !i->hasDeviceMembers())
                {
                    DBG_Printf(DBG_INFO, "delete old group %u of sensor %s\n", i->address(), qPrintable(sensor->name()));
                    i->setState(Group::StateDeleted);
                    updateGroupEtag(&*i);
                    queSaveDb(DB_GROUPS | DB_LIGHTS, DB_SHORT_SAVE_DELAY);

                    // for each node which is part of this group send a remove group request (will be unicast)
                    // note: nodes which are curently switched off will not be removed!
                    std::vector<LightNode>::iterator j = nodes.begin();
                    std::vector<LightNode>::iterator jend = nodes.end();

                    for (; j != jend; ++j)
                    {
                        GroupInfo *groupInfo = getGroupInfo(&*j, i->address());

                        if (groupInfo)
                        {
                            j->setNeedSaveDatabase(true);
                            groupInfo->actions &= ~GroupInfo::ActionAddToGroup; // sanity
                            groupInfo->actions |= GroupInfo::ActionRemoveFromGroup;
                            groupInfo->state = GroupInfo::StateNotInGroup;
                        }
                    }
                }
            }
        }
    }
}

/*! Remove groups which are controlled by device \p id. */
void DeRestPluginPrivate::deleteGroupsWithDeviceMembership(const QString &id)
{
    std::vector<Group>::iterator i = groups.begin();
    std::vector<Group>::iterator end = groups.end();
    for (; i != end; ++i)
    {
        if (i->deviceIsMember(id) && i->state() == Group::StateNormal)
        {
            i->removeDeviceMembership(id);

            updateGroupEtag(&*i);
            queSaveDb(DB_GROUPS | DB_LIGHTS, DB_SHORT_SAVE_DELAY);

            if (i->hasDeviceMembers())
            {
                continue;
            }

            i->setState(Group::StateDeleted);

            // for each node which is part of this group send a remove group request (will be unicast)
            // note: nodes which are curently switched off will not be removed!
            std::vector<LightNode>::iterator j = nodes.begin();
            std::vector<LightNode>::iterator jend = nodes.end();

            for (; j != jend; ++j)
            {
                GroupInfo *groupInfo = getGroupInfo(&*j, i->address());

                if (groupInfo)
                {
                    j->setNeedSaveDatabase(true);
                    groupInfo->actions &= ~GroupInfo::ActionAddToGroup; // sanity
                    groupInfo->actions |= GroupInfo::ActionRemoveFromGroup;
                    groupInfo->state = GroupInfo::StateNotInGroup;
                }
            }
        }
    }
}

/*! Check existing bindings on ubisys devices. */
void DeRestPluginPrivate::processUbisysBinding(Sensor *sensor, const Binding &bnd)
{
    if (!sensor)
    {
        return;
    }

    ResourceItem *item = 0;

    if (sensor->type() == QLatin1String("ZHASwitch") && bnd.dstAddrMode == deCONZ::ApsGroupAddress)
    {
        item = sensor->item(RConfigGroup);

        DBG_Assert(item != 0);
        if (!item)
        {
            return;
        }

        if (bnd.clusterId != ONOFF_CLUSTER_ID && bnd.clusterId != LEVEL_CLUSTER_ID)
        {
            return;
        }

        int pos = -1; // index in config.group: "1,4"

        if (sensor->modelId().startsWith(QLatin1String("D1")))
        {
            DBG_Assert(sensor->fingerPrint().endpoint == 0x02);

            if       (bnd.srcEndpoint == 0x02) { pos = 0; }
            else if  (bnd.srcEndpoint == 0x03) { pos = 1; }

        }
        else if (sensor->modelId().startsWith(QLatin1String("S1")))
        {
            DBG_Assert(sensor->fingerPrint().endpoint == 0x02);

            if       (bnd.srcEndpoint == 0x02) { pos = 0; }
            else if  (bnd.srcEndpoint == 0x03) { pos = 1; } // S1-R only
        }
        else if (sensor->modelId().startsWith(QLatin1String("S2")))
        {
            DBG_Assert(sensor->fingerPrint().endpoint == 0x03);

            if       (bnd.srcEndpoint == 0x03) { pos = 0; }
            else if  (bnd.srcEndpoint == 0x04) { pos = 1; }

        }
        else if (sensor->modelId().startsWith(QLatin1String("C4")))
        {
            DBG_Assert(sensor->fingerPrint().endpoint == 0x01);

            if       (bnd.srcEndpoint == 0x01) { pos = 0; }
            else if  (bnd.srcEndpoint == 0x02) { pos = 1; }
            else if  (bnd.srcEndpoint == 0x03) { pos = 2; }
            else if  (bnd.srcEndpoint == 0x04) { pos = 3; }
        }
        else
        {
            return;
        }

        // remove group bindings which aren't configured via 'config.group'
        QString dstGroup = QString::number(bnd.dstAddress.group);
        QStringList gids = item->toString().split(',');

        if (!gids.contains(dstGroup) || (pos == -1) || (gids.size() < (pos + 1)) || gids[pos] != dstGroup)
        {
            DBG_Printf(DBG_INFO, "0x%016llx remove old group binding group: %u, cluster: 0x%04X\n", bnd.srcAddress, bnd.dstAddress.group, bnd.clusterId);

            BindingTask bindingTask;
            bindingTask.state = BindingTask::StateIdle;
            bindingTask.action = BindingTask::ActionUnbind;
            bindingTask.binding = bnd;
            queueBindingTask(bindingTask);
            if (!bindingTimer->isActive())
            {
                bindingTimer->start();
            }
        }
    }
}

void DeRestPluginPrivate::processUbisysC4Configuration(Sensor *sensor)
{
    DBG_Assert(sensor);
    if (!sensor)
    {
        return;
    }

    DBG_Assert(sensor->node());
    if (!sensor->node())
    {
        return;
    }

    // device management endpoint
    const deCONZ::SimpleDescriptor *sd = sensor->node()->getSimpleDescriptor(0xE8);
    DBG_Assert(sd);
    if (!sd)
    {
        return;
    }

    const deCONZ::ZclCluster *cl = 0;
    for (const auto &c : sd->inClusters())
    {
        if (c.id() == UBISYS_DEVICE_SETUP_CLUSTER_ID)
        {
            cl = &c;
            break;
        }
    }

    DBG_Assert(cl);
    if (!cl)
    {
        return;
    }

    const deCONZ::ZclAttribute *attr1 = 0;
    for (const auto &a : cl->attributes())
    {
        if (a.id() == 0x0001) //
        {
            attr1 = &a;
            break;
        }
    }

    DBG_Assert(cl);
    if (!attr1)
    {
        return;
    }

    ResourceItem *item = 0;

    item = sensor->item(RConfigMode);
    DBG_Assert(item);
    if (!item)
    {
        return;
    }

    deCONZ::ApsDataRequest req;
    req.setProfileId(HA_PROFILE_ID);
    req.setClusterId(UBISYS_DEVICE_SETUP_CLUSTER_ID);
    req.setDstAddressMode(deCONZ::ApsExtAddress);
    req.dstAddress() = sensor->address();
    req.setDstEndpoint(0xE8);
    req.setSrcEndpoint(endpoint());

    deCONZ::ZclFrame zclFrame;
    zclFrame.setSequenceNumber(zclSeq++);
    zclFrame.setCommandId(deCONZ::ZclWriteAttributesStructuredId);
    //zclFrame.setManufacturerCode(VENDOR_UBISYS);

    {
        QDataStream stream(&zclFrame.payload(), QIODevice::ReadWrite);
        stream.setByteOrder(QDataStream::LittleEndian);

        if (item->toString() == QLatin1String("momentary"))
        {
            // write attribute record 1
            stream << (quint16)0x0001; // attribute id
            stream << (quint8)0x01; // selector: indicator 1
            stream << (quint8)0x01; // selector: index #1
            stream << (quint8)0x41; // attribute datatype: octed string
            stream << (quint8)0x06; // length: 6
            stream << (quint8)0x00; // InputAndOptions: 0x00
            stream << (quint8)0x0D; // transition: released -> pressed
            stream << (quint8)0x01; // source endpoint: 0x01
            stream << (quint16)0x0006; // cluster id: on/off
            stream << (quint8)0x02; // ZCL command template: toggle
        }
    }

    QDataStream stream(&req.asdu(), QIODevice::ReadWrite);
    stream.setByteOrder(QDataStream::LittleEndian);
    zclFrame.writeToStream(stream);

    if (apsCtrl->apsdeDataRequest(req) == deCONZ::Success)
    {

    }

}

/*! Process binding related tasks queue every one second. */
void DeRestPluginPrivate::bindingTimerFired()
{
    if (bindingQueue.empty())
    {
        return;
    }

    Q_Q(DeRestPlugin);
    if (!q->pluginActive())
    {
        bindingQueue.clear();
        return;
    }

    int active = 0;
    std::list<BindingTask>::iterator i = bindingQueue.begin();
    std::list<BindingTask>::iterator end = bindingQueue.end();

    for (; i != end; ++i)
    {
        if (i->state == BindingTask::StateIdle)
        {
            if (active >= MAX_ACTIVE_BINDING_TASKS)
            { /* do nothing */ }
            else if (sendBindRequest(*i))
            {
                i->state = BindingTask::StateInProgress;
                break;
            }
            else if (i->retries < 5)
            {
                i->retries++;
            }
            else
            {
                // too harsh?
                DBG_Printf(DBG_INFO_L2, "failed to send bind/unbind request to 0x%016llX cluster 0x%04X. drop\n", i->binding.srcAddress, i->binding.clusterId);
                i->state = BindingTask::StateFinished;
            }
        }
        else if (i->state == BindingTask::StateInProgress)
        {
            i->timeout--;
            if (i->timeout < 0)
            {
                i->retries--;
                if (i->retries > 0)
                {
                    if (i->restNode && !i->restNode->isAvailable())
                    {
                        DBG_Printf(DBG_INFO_L2, "giveup binding srcAddr: %llX (not available)\n", i->binding.srcAddress);
                        i->state = BindingTask::StateFinished;
                    }
                    else
                    {
                        DBG_Printf(DBG_INFO_L2, "binding/unbinding timeout srcAddr: %llX, retry\n", i->binding.srcAddress);
                        i->state = BindingTask::StateIdle;
                        i->timeout = BindingTask::Timeout;
                        if (i->restNode && i->restNode->node() && !i->restNode->node()->nodeDescriptor().receiverOnWhenIdle())
                        {
                            i->timeout = BindingTask::TimeoutEndDevice;
                        }
                    }
                }
                else
                {
                    DBG_Printf(DBG_INFO_L2, "giveup binding srcAddr: %llX\n", i->binding.srcAddress);
                    i->state = BindingTask::StateFinished;
                }
            }
            else
            {
                active++;
            }
        }
        else if (i->state == BindingTask::StateFinished)
        {
            bindingQueue.erase(i);
            break;
        }
        else if (i->state == BindingTask::StateCheck)
        {
            i->timeout--;
            if (i->timeout < 0)
            {
                i->retries--;
                if (i->retries > 0 && i->restNode)
                {
                    if (i->restNode->mgmtBindSupported())
                    {
                        if (!i->restNode->mustRead(READ_BINDING_TABLE))
                        {
                            i->restNode->enableRead(READ_BINDING_TABLE);
                            i->restNode->setNextReadTime(READ_BINDING_TABLE, queryTime);
                            queryTime = queryTime.addSecs(5);
                        }
                        q->startZclAttributeTimer(1000);

                        i->state = BindingTask::StateCheck;
                    }
                    else
                    {
                        i->state = BindingTask::StateIdle;
                    }
                    i->timeout = BindingTask::Timeout;
                    if (i->restNode && i->restNode->node() && !i->restNode->node()->nodeDescriptor().receiverOnWhenIdle())
                    {
                        i->timeout = BindingTask::TimeoutEndDevice;
                    }

                    DBG_Printf(DBG_INFO_L2, "%s check timeout, retries = %d (srcAddr: 0x%016llX cluster: 0x%04X)\n",
                               (i->action == BindingTask::ActionBind ? "bind" : "unbind"), i->retries, i->binding.srcAddress, i->binding.clusterId);

                    bindingQueue.push_back(*i);
                    bindingQueue.pop_front();
                    break;
                }
                else
                {
                    DBG_Printf(DBG_INFO_L2, "giveup binding\n");
                    DBG_Printf(DBG_INFO_L2, "giveup %s (srcAddr: 0x%016llX cluster: 0x%04X)\n",
                               (i->action == BindingTask::ActionBind ? "bind" : "unbind"), i->binding.srcAddress, i->binding.clusterId);
                    i->state = BindingTask::StateFinished;
                }
            }
        }
    }

    if (!bindingQueue.empty())
    {
        bindingTimer->start(1000);
    }
}

/*
QString Binding::toString()
{
    //        QString dbg = QString("srcAddr: 0x%1 srcEp: %2 clusterId: %3")
    //            .arg(i->srcAddress, 16, 16, QChar('0'))
    //            .arg(i->srcEndpoint)
    //            .arg(i->clusterId);

    //        if (i->dstAddrMode == 0x01) // group address
    //        {
    //            dbg.append(QString(" dstGroup: 0x%1").arg(i->dstAddress.group, 2, 16, QChar('0')));
    //        }
    //        else if (i->dstAddrMode == 0x03) // ext address + dst endpoint
    //        {
    //            dbg.append(QString(" dstExt: 0x%1 dstEp: %2").arg(i->dstAddress.ext, 16, 16, QChar('0'))
    //                                                         .arg(i->dstEndpoint));
    //        }

    //        DBG_Printf(DBG_INFO, "Binding %s\n", qPrintable(dbg));
}
*/

/*! Process binding to rule conversion.
    For bindings found via binding table query, check if there exists already
    a rule representing it. If such a rule does not exist it will be created.
*/
void DeRestPluginPrivate::bindingToRuleTimerFired()
{
    if (bindingToRuleQueue.empty())
    {
        return;
    }

    Binding bnd = bindingToRuleQueue.front();
    bindingToRuleQueue.pop_front();

    if (!bindingToRuleQueue.empty())
    {
        bindingToRuleTimer->start();
    }

    if (!apsCtrl)
    {
        return;
    }

    int idx = 0;
    bool found = false;
    const deCONZ::Node *node = 0;
    while (apsCtrl->getNode(idx, &node) == 0)
    {
        if (bnd.srcAddress == node->address().ext())
        {
            found = true;
            break;
        }
        idx++;
    }

    // check if cluster does exist
    if (found && node)
    {
        found = false;
        for (const deCONZ::SimpleDescriptor &sd : node->simpleDescriptors())
        {
            if (sd.endpoint() != bnd.srcEndpoint)
            {
                continue;
            }

            for (const deCONZ::ZclCluster &cl : sd.inClusters())
            {
                if (cl.id() == bnd.clusterId)
                {
                    found = true;
                    break;
                }
            }

            for (const deCONZ::ZclCluster &cl : sd.outClusters())
            {
                if (cl.id() == ILLUMINANCE_MEASUREMENT_CLUSTER_ID && checkMacVendor(node->address(), VENDOR_DDEL))
                {
                    continue; // ignore, binding only allowed for server cluster
                }

                if (cl.id() == bnd.clusterId)
                {
                    found = true;
                    break;
                }
            }

            if (found)
            {
                break;
            }
        }

        if (!found)
        {
            DBG_Printf(DBG_INFO, "remove binding from 0x%016llX cluster 0x%04X due non existing cluster\n", bnd.srcAddress, bnd.clusterId);
            BindingTask bindingTask;
            bindingTask.state = BindingTask::StateIdle;
            bindingTask.action = BindingTask::ActionUnbind;
            bindingTask.binding = bnd;
            queueBindingTask(bindingTask);
            if (!bindingTimer->isActive())
            {
                bindingTimer->start();
            }
            return;
        }
    }

    // binding table maintenance
    // check if destination node exist and remove binding if not
    if (bnd.dstAddrMode == deCONZ::ApsExtAddress)
    {
        idx = 0;
        found = false;
        node = nullptr;
        while (apsCtrl->getNode(idx, &node) == 0)
        {
            if (bnd.dstAddress.ext == node->address().ext())
            {
                found = true;
                break;
            }
            idx++;
        }

        if (!found)
        {
            DBG_Printf(DBG_INFO, "remove binding from 0x%016llX cluster 0x%04X to non existing node 0x%016llX\n", bnd.srcAddress, bnd.clusterId, bnd.dstAddress.ext);
            BindingTask bindingTask;
            bindingTask.state = BindingTask::StateIdle;
            bindingTask.action = BindingTask::ActionUnbind;
            bindingTask.binding = bnd;
            queueBindingTask(bindingTask);
            if (!bindingTimer->isActive())
            {
                bindingTimer->start();
            }
            return;
        }
    }


    std::vector<Sensor>::iterator i = sensors.begin();
    std::vector<Sensor>::iterator end = sensors.end();

    Sensor *sensor = 0;

    for (; i != end; ++i)
    {
        if (bnd.srcAddress != i->address().ext())
        {
            continue;
        }

        if (checkMacVendor(bnd.srcAddress, VENDOR_UBISYS))
        {
            processUbisysBinding(&*i, bnd);
            return;
        }

        if (!i->modelId().startsWith(QLatin1String("FLS-NB")))
        {
            continue;
        }

        if (bnd.srcEndpoint == i->fingerPrint().endpoint)
        {
            // match only valid sensors
            switch (bnd.clusterId)
            {
            case ONOFF_CLUSTER_ID:
            case LEVEL_CLUSTER_ID:
            case SCENE_CLUSTER_ID:
            {
                if (i->type() == "ZHASwitch")
                {
                    sensor = &(*i);
                }
            }
                break;

            case ILLUMINANCE_MEASUREMENT_CLUSTER_ID:
            {
                if (i->type() == "ZHALightLevel")
                {
                    sensor = &(*i);
                }
            }
                break;

            case OCCUPANCY_SENSING_CLUSTER_ID:
            {
                if (i->type() == "ZHAPresence")
                {
                    sensor = &(*i);
                }
            }
                break;

            default:
                break;
            }
        }

        if (sensor)
        {
            break;
        }
    }

    // only proceed if the sensor (binding source) is known
    if (!sensor)
    {
//        deCONZ::Address addr;
//        addr.setExt(bnd.srcAddress);
//        DBG_Printf(DBG_INFO, "Binding to Rule unsupported sensor %s\n", qPrintable(addr.toStringExt()));
        return;
    }

    Rule rule;
    RuleCondition cond;
    RuleAction action;

    if (bnd.dstAddrMode == Binding::ExtendedAddressMode)
    {
        deCONZ::Address addr;
        addr.setExt(bnd.dstAddress.ext);
        LightNode *lightNode = getLightNodeForAddress(addr, bnd.dstEndpoint);

        if (lightNode)
        {
            action.setAddress(QString("/lights/%1/state").arg(lightNode->id()));
        }
        else
        {
            DBG_Printf(DBG_INFO_L2, "Binding to Rule no LightNode found for dstAddress: %s\n",
                       qPrintable(QString("0x%1").arg(bnd.dstAddress.ext, 16,16, QChar('0'))));
            return;
        }

    }
    else if (bnd.dstAddrMode == Binding::GroupAddressMode)
    {
        action.setAddress(QString("/groups/%1/action").arg(bnd.dstAddress.group));
    }
    else
    {
        DBG_Printf(DBG_INFO, "Binding to Rule unsupported dstAddrMode 0x%02X\n", bnd.dstAddrMode);
        return;
    }

    action.setMethod("BIND");

    QVariantMap body;
    QString item;

    if (bnd.clusterId == ONOFF_CLUSTER_ID)
    {
        body["on"] = true;
        item = "buttonevent";
    }
    else if (bnd.clusterId == LEVEL_CLUSTER_ID)
    {
        body["bri"] = (double)1;
        item = "buttonevent";
    }
    else if (bnd.clusterId == ILLUMINANCE_MEASUREMENT_CLUSTER_ID)
    {
        body["illum"] = QString("report");
        item = "illuminance";
    }
    else if (bnd.clusterId == OCCUPANCY_SENSING_CLUSTER_ID)
    {
        body["occ"] = QString("report");
        item = "presence";
    }
    else if (bnd.clusterId == SCENE_CLUSTER_ID)
    {
        body["scene"] = QString("S%1").arg(bnd.srcEndpoint);
        item = "buttonevent";
    }
    else
    {
        return;
    }

    action.setBody(deCONZ::jsonStringFromMap(body));

    cond.setAddress(QString("/sensors/%1/state/%2").arg(sensor->id()).arg(item));
    cond.setOperator("eq");
    cond.setValue(bnd.srcEndpoint);

    // check if a rule for that binding already exists
    bool foundRule = false;

    std::vector<Rule>::const_iterator ri = rules.begin();
    std::vector<Rule>::const_iterator rend = rules.end();

    for (; !foundRule && (ri != rend); ++ri) // rule loop
    {
        std::vector<RuleCondition>::const_iterator ci = ri->conditions().begin();
        std::vector<RuleCondition>::const_iterator cend = ri->conditions().end();
        for (; !foundRule && (ci != cend); ++ci) // rule.conditions loop
        {
            // found matching condition
            if ((ci->address()   == cond.address()) &&
                (ci->ooperator() == cond.ooperator()) &&
                (ci->value()     == cond.value()))
            {
                std::vector<RuleAction>::const_iterator ai = ri->actions().begin();
                std::vector<RuleAction>::const_iterator aend = ri->actions().end();

                for (; !foundRule && (ai != aend); ++ai) // rule.actions loop
                {
                    if ((ai->method() == action.method()) && (ai->address() == action.address()))
                    {
                        // search action body which covers the binding clusterId
                        if (bnd.clusterId == ONOFF_CLUSTER_ID)
                        {
                            if (ai->body().contains("on"))
                            {
                                rule = *ri;
                                foundRule = true;
                            }
                        }
                        else if (bnd.clusterId == ILLUMINANCE_MEASUREMENT_CLUSTER_ID)
                        {
                            if (ai->body().contains("illum"))
                            {
                                rule = *ri;
                                foundRule = true;
                            }
                        }
                        else if (bnd.clusterId == OCCUPANCY_SENSING_CLUSTER_ID)
                        {
                            if (ai->body().contains("occ"))
                            {
                                rule = *ri;
                                foundRule = true;
                            }
                        }
                        else if (bnd.clusterId == LEVEL_CLUSTER_ID)
                        {
                            if (ai->body().contains("bri"))
                            {
                                rule = *ri;
                                foundRule = true;
                            }
                        }
                        else if (bnd.clusterId == SCENE_CLUSTER_ID)
                        {
                            if (ai->body().contains("scene"))
                            {
                                rule = *ri;
                                foundRule = true;
                            }
                        }
                        else
                        {
                            DBG_Printf(DBG_INFO, "Binding to Rule unhandled clusterId 0x%04X\n", bnd.clusterId);
                        }
                    }
                }
            }
        }
    }

    if (DBG_IsEnabled(DBG_INFO_L2))
    {
        DBG_Printf(DBG_INFO_L2, "cond.address: %s\n", qPrintable(cond.address()));
        DBG_Printf(DBG_INFO_L2, "cond.value: %s\n", qPrintable(cond.value().toString()));
        DBG_Printf(DBG_INFO_L2, "action.address: %s\n", qPrintable(action.address()));
        DBG_Printf(DBG_INFO_L2, "action.body: %s\n", qPrintable(action.body()));
    }

    if (!foundRule)
    {
        if (sensor && sensor->item(RConfigOn)->toBool())
        {
            std::vector<RuleAction> actions;
            std::vector<RuleCondition> conditions;

            actions.push_back(action);
            conditions.push_back(cond);

            updateEtag(rule.etag);
            rule.setOwner("deCONZ");
            rule.setCreationtime(QDateTime::currentDateTimeUtc().toString("yyyy-MM-ddTHH:mm:ss"));
            rule.setActions(actions);
            rule.setConditions(conditions);

            // create a new rule id // don't overwrite already existing rules
            rule.setId("1");

            bool ok;
            do {
                ok = true;
                std::vector<Rule>::const_iterator i = rules.begin();
                std::vector<Rule>::const_iterator end = rules.end();

                for (; i != end; ++i)
                {
                    if (i->id() == rule.id())
                    {
                        rule.setId(QString::number(i->id().toInt() + 1));
                        ok = false;
                    }
                }
            } while (!ok);

            rule.setName(QString("Rule %1").arg(rule.id()));
            rules.push_back(rule);

            queSaveDb(DB_RULES, DB_SHORT_SAVE_DELAY);

            DBG_Printf(DBG_INFO, "Rule %s created from Binding\n", qPrintable(rule.id()));
        }
        else if (gwDeleteUnknownRules)
        {

            DBG_Printf(DBG_INFO, "Rule for Binding doesn't exists start unbind 0x%04X\n", bnd.clusterId);
            BindingTask bt;
            bt.state = BindingTask::StateIdle;
            bt.restNode = sensor; // might be 0
            bt.action = BindingTask::ActionUnbind;
            bt.binding = bnd;
            queueBindingTask(bt);
        }
    }
    else
    {
        if (rule.state() == Rule::StateDeleted || rule.status() == "disabled")
        {
            DBG_Printf(DBG_INFO, "Rule for Binding already exists (inactive), start unbind 0x%04X\n", bnd.clusterId);
            BindingTask bt;
            bt.state = BindingTask::StateIdle;
            bt.restNode = sensor; // might be 0
            bt.action = BindingTask::ActionUnbind;
            bt.binding = bnd;
            queueBindingTask(bt);
        }
        else
        {
            DBG_Printf(DBG_INFO_L2, "Rule for Binding 0x%04X already exists\n", bnd.clusterId);
        }
    }

    if (!bindingTimer->isActive())
    {
        bindingTimer->start();
    }
}

/*! Process ongoing binding table queries.
*/
void DeRestPluginPrivate::bindingTableReaderTimerFired()
{
    std::vector<BindingTableReader>::iterator i = bindingTableReaders.begin();

    for (; i != bindingTableReaders.end(); )
    {
        if (i->state == BindingTableReader::StateIdle)
        {
            deCONZ::ApsDataRequest &apsReq = i->apsReq;

            i->apsReq.setDstAddressMode(deCONZ::ApsExtAddress);
            i->apsReq.setProfileId(ZDP_PROFILE_ID);
            i->apsReq.setClusterId(ZDP_MGMT_BIND_REQ_CLID);
            i->apsReq.setDstEndpoint(ZDO_ENDPOINT);
            i->apsReq.setSrcEndpoint(ZDO_ENDPOINT);
            i->apsReq.setTxOptions(0);
            i->apsReq.setRadius(0);

            QDataStream stream(&apsReq.asdu(), QIODevice::WriteOnly);
            stream.setByteOrder(QDataStream::LittleEndian);

            QTime now = QTime::currentTime();
            stream << (uint8_t)now.second(); // seqno
            stream << i->index;

            // send
            if (apsCtrl && apsCtrl->apsdeDataRequest(apsReq) == deCONZ::Success)
            {
                DBG_Printf(DBG_ZDP, "Mgmt_Bind_req id: %d to 0x%016llX send\n", i->apsReq.id(), i->apsReq.dstAddress().ext());
                i->time.start();
                i->state = BindingTableReader::StateWaitConfirm;
                break;
            }
            else
            {
                DBG_Printf(DBG_ZDP, "failed to send Mgmt_Bind_req to 0x%016llX\n", i->apsReq.dstAddress().ext());
                i->state = BindingTableReader::StateFinished;
            }
        }
        else if (i->state == BindingTableReader::StateWaitConfirm)
        {
            if (i->time.elapsed() > BindingTableReader::MaxConfirmTime)
            {
                DBG_Printf(DBG_ZDP, "timeout for Mgmt_Bind_req id %d to 0x%016llX\n", i->apsReq.id(), i->apsReq.dstAddress().ext());
                i->state = BindingTableReader::StateFinished;
            }
        }
        else if (i->state == BindingTableReader::StateWaitResponse)
        {
            const int maxResponseTime = i->isEndDevice ? BindingTableReader::MaxEndDeviceResponseTime
                                                 : BindingTableReader::MaxResponseTime;
            if (i->time.elapsed() > maxResponseTime)
            {
                DBG_Printf(DBG_ZDP, "timeout for response to Mgmt_Bind_req id %d to 0x%016llX\n", i->apsReq.id(), i->apsReq.dstAddress().ext());
                i->state = BindingTableReader::StateFinished;
            }
        }

        if (i->state == BindingTableReader::StateFinished)
        {
            *i = bindingTableReaders.back();
            bindingTableReaders.pop_back();
        }
        else
        {
            ++i;
        }
    }

    if (!bindingTableReaders.empty())
    {
        bindingTableReaderTimer->start();
    }
}