Skip to content

Commit

Permalink
Fix missing bridge UID in thing UID during discovery (openhab#8449)
Browse files Browse the repository at this point in the history
Fixes exceptions thrown in OH3 when building discovery results for things with bridges where the thing UID is missing the bridge UID.

Related to openhab/openhab-core#1481

Signed-off-by: Wouter Born <github@maindrain.net>
  • Loading branch information
wborn authored and markus7017 committed Sep 18, 2020
1 parent 3a39ab8 commit 54bb7a7
Show file tree
Hide file tree
Showing 11 changed files with 34 additions and 40 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -12,15 +12,7 @@
*/
package org.openhab.binding.amazonechocontrol.internal.discovery;

import static org.openhab.binding.amazonechocontrol.internal.AmazonEchoControlBindingConstants.DEVICE_PROPERTY_FAMILY;
import static org.openhab.binding.amazonechocontrol.internal.AmazonEchoControlBindingConstants.DEVICE_PROPERTY_FLASH_BRIEFING_PROFILE;
import static org.openhab.binding.amazonechocontrol.internal.AmazonEchoControlBindingConstants.DEVICE_PROPERTY_SERIAL_NUMBER;
import static org.openhab.binding.amazonechocontrol.internal.AmazonEchoControlBindingConstants.SUPPORTED_ECHO_THING_TYPES_UIDS;
import static org.openhab.binding.amazonechocontrol.internal.AmazonEchoControlBindingConstants.THING_TYPE_ECHO;
import static org.openhab.binding.amazonechocontrol.internal.AmazonEchoControlBindingConstants.THING_TYPE_ECHO_SHOW;
import static org.openhab.binding.amazonechocontrol.internal.AmazonEchoControlBindingConstants.THING_TYPE_ECHO_SPOT;
import static org.openhab.binding.amazonechocontrol.internal.AmazonEchoControlBindingConstants.THING_TYPE_ECHO_WHA;
import static org.openhab.binding.amazonechocontrol.internal.AmazonEchoControlBindingConstants.THING_TYPE_FLASH_BRIEFING_PROFILE;
import static org.openhab.binding.amazonechocontrol.internal.AmazonEchoControlBindingConstants.*;

import java.util.Date;
import java.util.HashMap;
Expand Down Expand Up @@ -160,13 +152,13 @@ synchronized void setDevices(List<Device> deviceList) {
continue;
}

ThingUID brigdeThingUID = this.accountHandler.getThing().getUID();
ThingUID thingUID = new ThingUID(thingTypeId, brigdeThingUID, serialNumber);
ThingUID bridgeThingUID = this.accountHandler.getThing().getUID();
ThingUID thingUID = new ThingUID(thingTypeId, bridgeThingUID, serialNumber);

DiscoveryResult result = DiscoveryResultBuilder.create(thingUID).withLabel(device.accountName)
.withProperty(DEVICE_PROPERTY_SERIAL_NUMBER, serialNumber)
.withProperty(DEVICE_PROPERTY_FAMILY, deviceFamily)
.withRepresentationProperty(DEVICE_PROPERTY_SERIAL_NUMBER).withBridge(brigdeThingUID)
.withRepresentationProperty(DEVICE_PROPERTY_SERIAL_NUMBER).withBridge(bridgeThingUID)
.build();

logger.debug("Device [{}: {}] found. Mapped to thing type {}", device.deviceFamily, serialNumber,
Expand All @@ -184,8 +176,8 @@ public synchronized void discoverFlashBriefingProfiles(String currentFlashBriefi
}

if (!discoveredFlashBriefings.contains(currentFlashBriefingJson)) {
ThingUID brigdeThingUID = this.accountHandler.getThing().getUID();
ThingUID freeThingUID = new ThingUID(THING_TYPE_FLASH_BRIEFING_PROFILE, brigdeThingUID,
ThingUID bridgeThingUID = this.accountHandler.getThing().getUID();
ThingUID freeThingUID = new ThingUID(THING_TYPE_FLASH_BRIEFING_PROFILE, bridgeThingUID,
Integer.toString(currentFlashBriefingJson.hashCode()));
DiscoveryResult result = DiscoveryResultBuilder.create(freeThingUID).withLabel("FlashBriefing")
.withProperty(DEVICE_PROPERTY_FLASH_BRIEFING_PROFILE, currentFlashBriefingJson)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +85,7 @@ public void deactivate() {
private void addThing(final FoobotDevice foobot) {
logger.debug("Adding new Foobot '{}' with uuid: {}", foobot.getName(), foobot.getUuid());

final ThingUID thingUID = new ThingUID(FoobotBindingConstants.THING_TYPE_FOOBOT, foobot.getUuid());
final ThingUID thingUID = new ThingUID(FoobotBindingConstants.THING_TYPE_FOOBOT, bridgeUID, foobot.getUuid());
final Map<String, Object> properties = new HashMap<>();
properties.put(Thing.PROPERTY_SERIAL_NUMBER, foobot.getUuid());
properties.put(FoobotBindingConstants.CONFIG_UUID, foobot.getUuid());
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -79,10 +79,10 @@ protected void startScan() {
ThingUID thingUID = null;
switch (appliance.getType()) {
case org.grohe.ondus.api.model.guard.Appliance.TYPE:
thingUID = new ThingUID(THING_TYPE_SENSEGUARD, appliance.getApplianceId());
thingUID = new ThingUID(THING_TYPE_SENSEGUARD, bridgeUID, appliance.getApplianceId());
break;
case org.grohe.ondus.api.model.sense.Appliance.TYPE:
thingUID = new ThingUID(THING_TYPE_SENSE, appliance.getApplianceId());
thingUID = new ThingUID(THING_TYPE_SENSE, bridgeUID, appliance.getApplianceId());
break;
default:
return;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -108,7 +108,7 @@ private void handleDiscoveredPlayers(Map<Integer, Player> currentPlayers) {
ThingUID bridgeUID = bridge.getThing().getUID();

for (Player player : currentPlayers.values()) {
ThingUID uid = new ThingUID(THING_TYPE_PLAYER, String.valueOf(player.playerId));
ThingUID uid = new ThingUID(THING_TYPE_PLAYER, bridgeUID, String.valueOf(player.playerId));
Map<String, Object> properties = new HashMap<>();
HeosPlayerHandler.propertiesFromPlayer(properties, player);

Expand Down Expand Up @@ -162,7 +162,7 @@ private void handleDiscoveredGroups(HashMap<String, Group> currentGroups) {
// Using an unsigned hashCode from the group members to identify
// the group and generates the Thing UID.
// This allows identifying the group even if the sorting within the group has changed
ThingUID uid = new ThingUID(THING_TYPE_GROUP, groupMemberHash);
ThingUID uid = new ThingUID(THING_TYPE_GROUP, bridgeUID, groupMemberHash);
Map<String, Object> properties = new HashMap<>();
properties.put(PROP_NAME, group.name);
properties.put(PROP_GID, group.id);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ public void addInsteonDevices(List<String> addresses, ThingUID bridgeUid) {
}

String name = parts[0] + parts[1] + parts[2];
ThingUID uid = new ThingUID(InsteonBindingConstants.DEVICE_THING_TYPE, name);
ThingUID uid = new ThingUID(InsteonBindingConstants.DEVICE_THING_TYPE, bridgeUid, name);
Map<String, Object> properties = new HashMap<>();
properties.put(ADDRESS, address);

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -102,35 +102,36 @@ public void handleReading(Reading reading) {
|| id.equals(t.getConfiguration().as(JeeLinkSensorConfig.class).sensorId);
}

ThingUID bridgeUID = bridge.getThing().getUID();

if (!sensorThingExists) {
SensorDefinition<?> def = SensorDefinition.getSensorDefinition(reading);
logger.debug("discovery for bridge {} found unknown sensor of type {} with id {}",
bridge.getThing().getUID(), def.getThingTypeUID(), id);
logger.debug("discovery for bridge {} found unknown sensor of type {} with id {}", bridgeUID,
def.getThingTypeUID(), id);

boolean idExists = idExistsAtBridge(id);
String newId = id;

if (idExists) {
logger.debug("bridge {} already has a connected sensor with thing id {}", bridge.getThing().getUID(),
id);
logger.debug("bridge {} already has a connected sensor with thing id {}", bridgeUID, id);

int idx = 1;
while (idExists) {
newId = id + "-" + idx++;
idExists = idExistsAtBridge(newId);
}

logger.debug("Bridge {} uses thing id {} instead of {}", bridge.getThing().getUID(), newId, id);
logger.debug("Bridge {} uses thing id {} instead of {}", bridgeUID, newId, id);
}

ThingUID sensorThing = new ThingUID(def.getThingTypeUID(), newId);
ThingUID sensorThing = new ThingUID(def.getThingTypeUID(), bridgeUID, newId);

DiscoveryResult discoveryResult = DiscoveryResultBuilder.create(sensorThing).withLabel(def.getName())
.withBridge(bridge.getThing().getUID()).withRepresentationProperty("id")
.withProperty(PROPERTY_SENSOR_ID, id).build();
.withBridge(bridgeUID).withRepresentationProperty("id").withProperty(PROPERTY_SENSOR_ID, id)
.build();
thingDiscovered(discoveryResult);
} else {
logger.debug("discovery for bridge {} found already known sensor id {}", bridge.getThing().getUID(), id);
logger.debug("discovery for bridge {} found already known sensor id {}", bridgeUID, id);
}
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -105,12 +105,12 @@ public void onItemUpdate(String sid, String command, JsonObject data) {
Map<String, Object> properties = new HashMap<>(1);
properties.put(ITEM_ID, sid);

ThingUID thingUID = new ThingUID(thingType, sid);
ThingUID bridgeUID = xiaomiBridgeHandler.getThing().getUID();
ThingUID thingUID = new ThingUID(thingType, bridgeUID, sid);

logger.debug("Discovered device - sid: {} model: {}", sid, model);
thingDiscovered(DiscoveryResultBuilder.create(thingUID).withThingType(thingType).withProperties(properties)
.withRepresentationProperty(ITEM_ID).withLabel(modelLabel)
.withBridge(xiaomiBridgeHandler.getThing().getUID()).build());
.withRepresentationProperty(ITEM_ID).withLabel(modelLabel).withBridge(bridgeUID).build());
}
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -87,7 +87,7 @@ private void addThing(Robot robot) {
logger.debug("addThing(): Adding new Neato unit {} to the smarthome inbox", robot.getName());

Map<String, Object> properties = new HashMap<>();
ThingUID thingUID = new ThingUID(NeatoBindingConstants.THING_TYPE_VACUUMCLEANER, robot.getSerial());
ThingUID thingUID = new ThingUID(NeatoBindingConstants.THING_TYPE_VACUUMCLEANER, bridgeUID, robot.getSerial());
properties.put(NeatoBindingConstants.CONFIG_SECRET, robot.getSecretKey());
properties.put(NeatoBindingConstants.CONFIG_SERIAL, robot.getSerial());
properties.put(Thing.PROPERTY_MODEL_ID, robot.getModel());
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -97,8 +97,8 @@ protected void startBackgroundDiscovery() {
}

public void createResults(PointType location) {
ThingUID localOpenUVThing = new ThingUID(LOCATION_REPORT_THING_TYPE, LOCAL);
ThingUID bridgeUID = bridgeHandler.getThing().getUID();
ThingUID localOpenUVThing = new ThingUID(LOCATION_REPORT_THING_TYPE, bridgeUID, LOCAL);
Map<String, Object> properties = new HashMap<>();
properties.put(LOCATION, location.toString());
thingDiscovered(DiscoveryResultBuilder.create(localOpenUVThing).withLabel("Local UV Information")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -56,11 +56,12 @@ public void startScan() {
Vehicles vehicle = bridgeHandler.getURL(accountVehicle.vehicleURL, Vehicles.class);
Attributes attributes = bridgeHandler.getURL(Attributes.class, vehicle.vehicleId);

thingDiscovered(
DiscoveryResultBuilder.create(new ThingUID(VEHICLE_THING_TYPE, accountVehicle.vehicleId))
.withLabel(attributes.vehicleType + " " + attributes.registrationNumber)
.withBridge(bridgeHandler.getThing().getUID()).withProperty(VIN, attributes.vin)
.withRepresentationProperty(accountVehicle.vehicleId).build());
thingDiscovered(DiscoveryResultBuilder
.create(new ThingUID(VEHICLE_THING_TYPE, bridgeHandler.getThing().getUID(),
accountVehicle.vehicleId))
.withLabel(attributes.vehicleType + " " + attributes.registrationNumber)
.withBridge(bridgeHandler.getThing().getUID()).withProperty(VIN, attributes.vin)
.withRepresentationProperty(accountVehicle.vehicleId).build());

} catch (VolvoOnCallException e) {
logger.warn("Error while discovering vehicle: {}", e.getMessage());
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -141,7 +141,7 @@ protected void stopBackgroundDiscovery() {
}

private void createResults(PointType location, Locale locale) {
ThingUID localWeatherThing = new ThingUID(THING_TYPE_WEATHER, LOCAL);
ThingUID localWeatherThing = new ThingUID(THING_TYPE_WEATHER, bridgeUID, LOCAL);
Map<String, Object> properties = new HashMap<>(3);
properties.put(LOCATION, String.format("%s,%s", location.getLatitude(), location.getLongitude()));
String lang = WeatherUndergroundHandler.getCodeFromLanguage(locale);
Expand Down

0 comments on commit 54bb7a7

Please sign in to comment.