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

Bosswerk: Improve discovery for setup

master
Michael Zanetti 2022-07-12 15:29:36 +02:00
parent b4aeeefa48
commit f0068d910a
1 changed files with 30 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
bosswerk/integrationpluginbosswerk.cpp
View File

@ -53,26 +53,42 @@ IntegrationPluginBosswerk::~IntegrationPluginBosswerk()
} }
void IntegrationPluginBosswerk::discoverThings(ThingDiscoveryInfo *info) void IntegrationPluginBosswerk::discoverThings(ThingDiscoveryInfo *info)
{ {
NetworkDeviceDiscoveryReply *reply = hardwareManager()->networkDeviceDiscovery()->discover(); NetworkDeviceDiscoveryReply *discoveryReply = hardwareManager()->networkDeviceDiscovery()->discover();
connect(reply, &NetworkDeviceDiscoveryReply::finished, info, [info, reply, this](){
foreach (const NetworkDeviceInfo &deviceInfo, reply->networkDeviceInfos()) {
// qCDebug(dcBosswerk) << "Discovery result" << deviceInfo;
QString cover_mid = deviceInfo.hostName().split(".").first();
// qCDebug(dcBosswerk()) << "Cover mid" << cover_mid;
if (QRegExp("[0-9]{10}").exactMatch(cover_mid)) { // This device doesn't give much information without login credentials. In order to identify it we'll
qCDebug(dcBosswerk()) << "Potential result:" << deviceInfo; // do an unauthorized GET call on it and compare the server header "HTTPD" as well as the static
ThingDescriptor descriptor(mix00ThingClassId, "MI-300/600", deviceInfo.hostName()); // Unauthorized page which looks unique enough.
descriptor.setParams({Param(mix00ThingMacAddressParamTypeId, deviceInfo.macAddress())}); // If this proves to not be reliable enough, one more option would be to connect to TCP port 8899 which is open
Thing *existingThing = myThings().findByParams({Param(mix00ThingMacAddressParamTypeId, deviceInfo.macAddress())}); // and responds to a proprietary binary protocol which would need to be reverse engineered first.
connect(discoveryReply, &NetworkDeviceDiscoveryReply::networkDeviceInfoAdded, info, [=](const NetworkDeviceInfo &networkDeviceInfo){
qCDebug(dcBosswerk()) << "Probing device" << networkDeviceInfo.address();
QUrl url("http://" + networkDeviceInfo.address().toString() + "/status.html");
QNetworkRequest request(url);
QNetworkReply *probeReply = hardwareManager()->networkManager()->get(QNetworkRequest(url));
connect(probeReply, &QNetworkReply::finished, probeReply, &QNetworkReply::deleteLater);
connect(probeReply, &QNetworkReply::finished, info, [=](){
QByteArray data = probeReply->readAll();
qCDebug(dcBosswerk()) << "Probe reply from" << networkDeviceInfo.address() << ":" << probeReply->rawHeaderPairs() << data;
if (probeReply->header(QNetworkRequest::ServerHeader) == "HTTPD" && data == "<HTML><HEAD><TITLE>401 Unauthorized</TITLE></HEAD>\n<BODY BGCOLOR=\"#cc9999\"><H4>401 Unauthorized</H4>\nAuthorization required.\n</BODY></HTML>\n") {
qCDebug(dcBosswerk()) << "Found bosswerk MI-300/600:" << networkDeviceInfo.address();
ThingDescriptor descriptor(mix00ThingClassId, "MI-300/600", networkDeviceInfo.hostName());
descriptor.setParams({Param(mix00ThingMacAddressParamTypeId, networkDeviceInfo.macAddress())});
Thing *existingThing = myThings().findByParams({Param(mix00ThingMacAddressParamTypeId, networkDeviceInfo.macAddress())});
if (existingThing) { if (existingThing) {
descriptor.setThingId(existingThing->id()); descriptor.setThingId(existingThing->id());
} }
info->addThingDescriptor(descriptor); info->addThingDescriptor(descriptor);
} }
} });
qCInfo(dcBosswerk) << "Discovery finished." << info->thingDescriptors().count() << "results."; });
QTimer *timeout = new QTimer(info);
timeout->start(28000);
connect(timeout, &QTimer::timeout, info, [=](){
info->finish(Thing::ThingErrorNoError); info->finish(Thing::ThingErrorNoError);
}); });
} }