if (bridgeStatus == ThingStatus.ONLINE
&& getThing().getStatusInfo().getStatusDetail() == ThingStatusDetail.BRIDGE_OFFLINE) {
initDeviceState();
-
} else if (bridgeStatus == ThingStatus.OFFLINE) {
updateStatus(ThingStatus.OFFLINE, ThingStatusDetail.BRIDGE_OFFLINE);
}
this.nbeeps = Integer.parseInt(parts.get(0).substring(6, 7));
this.lower = Integer.parseInt(parts.get(0).substring(7, 17), 2);
this.status = ((upper & 0x1F) << 13) | ((nbeeps & 0x3) << 10) | lower;
-
} catch (NumberFormatException e) {
throw new IllegalArgumentException("keypad msg contains invalid number: " + e.getMessage(), e);
}
sum += toUnsignedInt((data[index] & 0xFF) << ((index & 3 ^ 3) << 3));
overflow += computeBits(sum, 32);
sum = toUnsignedInt((int) sum & (int) 4294967295L);
-
} else {
index = exclusionEnd - 1;
}
private boolean isRadoneyeDevice(BluetoothDiscoveryDevice device) {
String manufacturerMacId = device.getAddress().toString().toLowerCase().replace(":", "").substring(0, 6);
- if (manufacturerMacId.equals(RADONEYE_BLUETOOTH_COMPANY_ID.toLowerCase())) {
- return true;
- }
- return false;
+ return manufacturerMacId.equals(RADONEYE_BLUETOOTH_COMPANY_ID.toLowerCase());
}
private String getSerial(BluetoothDiscoveryDevice device) {
Map<String, Object> properties = new HashMap<>();
properties.put(BluetoothBindingConstants.CONFIGURATION_ADDRESS, device.getAddress().toString());
properties.put(Thing.PROPERTY_VENDOR, "RadonEye");
- String name = device.getName();
String serialNumber = device.getSerialNumber();
String firmwareRevision = device.getFirmwareRevision();
String model = device.getModel();
} else {
logger.error("Received a SCENE command with a non DecimalType: {}", command);
}
-
} else if (id.equals(PrgConstants.CHANNEL_SCENELOCK)) {
if (command instanceof OnOffType) {
getProtocolHandler().setSceneLock(config.getControlUnit(), command == OnOffType.ON);
} else {
logger.error("Received a SCENELOCK command with a non OnOffType: {}", command);
}
-
} else if (id.equals(PrgConstants.CHANNEL_SCENESEQ)) {
if (command instanceof OnOffType) {
getProtocolHandler().setSceneSequence(config.getControlUnit(), command == OnOffType.ON);
} else {
logger.error("Received a SCENESEQ command with a non OnOffType: {}", command);
}
-
} else if (id.equals(PrgConstants.CHANNEL_ZONELOCK)) {
if (command instanceof OnOffType) {
getProtocolHandler().setZoneLock(config.getControlUnit(), command == OnOffType.ON);
} else {
logger.error("Received a ZONELOCK command with a non OnOffType: {}", command);
}
-
} else if (id.startsWith(PrgConstants.CHANNEL_ZONELOWER)) {
final Integer zone = getTrailingNbr(id, PrgConstants.CHANNEL_ZONELOWER);
if (zone != null) {
getProtocolHandler().setZoneLower(config.getControlUnit(), zone);
}
-
} else if (id.startsWith(PrgConstants.CHANNEL_ZONERAISE)) {
final Integer zone = getTrailingNbr(id, PrgConstants.CHANNEL_ZONERAISE);
if (zone != null) {
getProtocolHandler().setZoneRaise(config.getControlUnit(), zone);
}
-
} else if (id.equals(PrgConstants.CHANNEL_ZONEFADE)) {
if (command instanceof DecimalType) {
setFade(((DecimalType) command).intValue());
} else {
logger.error("Received a ZONEFADE command with a non DecimalType: {}", command);
}
-
} else if (id.startsWith(PrgConstants.CHANNEL_ZONEINTENSITY)) {
final Integer zone = getTrailingNbr(id, PrgConstants.CHANNEL_ZONEINTENSITY);
logger.error("Received a ZONEINTENSITY command with a non DecimalType: {}", command);
}
}
-
} else if (id.startsWith(PrgConstants.CHANNEL_ZONESHADE)) {
final Integer zone = getTrailingNbr(id, PrgConstants.CHANNEL_ZONESHADE);
logger.error("Received a ZONEINTENSITY command with a non DecimalType: {}", command);
}
}
-
} else {
logger.error("Unknown/Unsupported Channel id: {}", id);
}
if (id.equals(PrgConstants.CHANNEL_SCENE)) {
getProtocolHandler().refreshScene();
-
} else if (id.equals(PrgConstants.CHANNEL_ZONEINTENSITY)) {
getProtocolHandler().refreshZoneIntensity(config.getControlUnit());
} else if (id.equals(PrgConstants.CHANNEL_ZONEFADE)) {
if (id.equals(PrgConstants.CHANNEL_ZONELOWERSTOP)) {
protocolHandler.setZoneLowerStop();
-
} else if (id.equals(PrgConstants.CHANNEL_ZONERAISESTOP)) {
protocolHandler.setZoneRaiseStop();
-
} else if (id.equals(PrgConstants.CHANNEL_TIMECLOCK)) {
if (command instanceof DateTimeType) {
final ZonedDateTime zdt = ((DateTimeType) command).getZonedDateTime();
} else {
logger.error("Received a SCHEDULE channel command with a non DecimalType: {}", command);
}
-
} else if (id.startsWith(PrgConstants.CHANNEL_SUPERSEQUENCESTART)) {
protocolHandler.startSuperSequence();
-
} else if (id.startsWith(PrgConstants.CHANNEL_SUPERSEQUENCEPAUSE)) {
protocolHandler.pauseSuperSequence();
} else if (id.startsWith(PrgConstants.CHANNEL_SUPERSEQUENCERESUME)) {
protocolHandler.resumeSuperSequence();
-
} else {
logger.error("Unknown/Unsupported Channel id: {}", id);
}
if (id.equals(PrgConstants.CHANNEL_TIMECLOCK)) {
protocolHandler.refreshTime();
-
} else if (id.equals(PrgConstants.CHANNEL_SCHEDULE)) {
protocolHandler.refreshSchedule();
-
} else if (id.equals(PrgConstants.CHANNEL_SUNRISE)) {
protocolHandler.refreshSunriseSunset();
-
} else if (id.equals(PrgConstants.CHANNEL_SUNSET)) {
protocolHandler.refreshSunriseSunset();
-
} else if (id.equals(PrgConstants.CHANNEL_SUPERSEQUENCESTATUS)) {
protocolHandler.reportSuperSequenceStatus();
} else if (id.equals(PrgConstants.CHANNEL_SUPERSEQUENCENEXTSTEP)) {
return;
}
}
-
} catch (Exception e) {
logger.error("Exception during connection attempt", e);
}
The binding allows to try/test if your new device is working with database files of older devices as well.
There are 3 ways to get unsupported devices working:
+
- by overriding the model with the model of a similar supported device. E.g. this works great for roborock vacuum devices and yeelight devices). See [Substitute model for unsupported devices](#substitute-model-for-unsupported-devices)
- by switching on the `(experimental) Create channels for new/unsupported devices (MIOT protocol)` channel, this works for most newer devices. See [Create support for new devices based on online published spec database](#create-support-for-new-devices-based-on-online-published-spec-database)
- by switching on the `(experimental) Create channels / test properties for unsupported devices (legacy protocol)` channel. This works for older / legacy devices. It test all known properties to see which are supported by your device. See [Supported property test for unsupported devices](#supported-property-test-for-unsupported-devices)
The binding allows to try/test if your new device is working with database files of older devices as well.
There are 3 ways to get unsupported devices working:
+
- by overriding the model with the model of a similar supported device. E.g. this works great for roborock vacuum devices and yeelight devices). See [Substitute model for unsupported devices](#substitute-model-for-unsupported-devices)
- by switching on the `(experimental) Create channels for new/unsupported devices (MIOT protocol)` channel, this works for most newer devices. See [Create support for new devices based on online published spec database](#create-support-for-new-devices-based-on-online-published-spec-database)
- by switching on the `(experimental) Create channels / test properties for unsupported devices (legacy protocol)` channel. This works for older / legacy devices. It test all known properties to see which are supported by your device. See [Supported property test for unsupported devices](#supported-property-test-for-unsupported-devices)
* @throws EndpointNotInitializedException
*/
public void detectModel() {
-
if (possibleAddresses.isEmpty()) {
parsingFinished();
return;
* Look for a valid model block at the current base address
*/
private void lookForModelBlock() {
-
ModbusReadRequestBlueprint request = new ModbusReadRequestBlueprint(slaveId,
ModbusReadFunctionCode.READ_MULTIPLE_REGISTERS, baseAddress, // Start address
MODEL_HEADER_SIZE, // number or words to return
createDiscoveryResult(block);
lookForModelBlock();
}
-
}
}
* Start the periodic polling
*/
private void startUp() {
-
connectEndpoint();
if (comms == null || config == null) {
@Override
public CommonModelBlock parse(ModbusRegisterArray raw) {
-
CommonModelBlock block = new CommonModelBlock();
block.sunSpecDID = extractUInt16(raw, 0, 0);
if (jsonObject.has("outputs")) {
jsonOutputs = jsonObject.get("outputs");
-
}
if (ctd != null && cmd != null) {
}
((QbusMessageListMap) message).setOutputs(outputsList);
}
-
} else {
message = new QbusMessageMap();
if (setpoint != null) {
message.setSetPoint(setpoint);
}
-
}
}
return message;
latestTime = iterTime;
latestData = iterData;
} // else - found item is older - nothing to do
-
} else {
logger.warn("One or two dates cannot be decoded 1) {} 2) {}", iterTimeStr, latestTimeStr);
}
public static synchronized @Nullable LocalDateTime toDate(String dateTime) {
try {
return LocalDateTime.from(DTF.parse(dateTime));
-
} catch (DateTimeParseException e) {
LOGGER.debug("Unable to parse date {}", dateTime);
return null;
return false;
}
- boolean updated = false;
ShellySettingsMeter sm = new ShellySettingsMeter();
ShellySettingsEMeter emeter = status.emeters.get(0);
sm.isValid = emeter.isValid = true;
try {
ShellyApiInterface api = gen2 ? new Shelly2ApiRpc(name, config, httpClient)
: new Shelly1HttpApi(name, config, httpClient);
- if (name.contains("plus1pm")) {
- int i = 1;
- }
api.initialize();
profile = api.getDeviceProfile(thingType);
api.close();
All supported values and devices were discovered while playing with my own energy manager.
## Supported devices
+
* Solarwatt Energymanager; ie. the DIN rail mounted device in your house distribution.
## Not supported by this binding
+
* Solarwatt Manager/Manager Flex; ie. the black square device that is wall mounted.
The Solarwatt Manager already contains an OpenHAB installation which can be connected to
}
}
+ @SuppressWarnings("PMD.SimplifyBooleanReturns")
private boolean arePowerMeterChannelsLinked() {
if (isLinked(CHANNELENERGYIMPORTEDSTATEPRODUCTION)) {
return true;
public void handleStandaloneElement(final @Nullable String elementName,
final @Nullable Map<String, String> attributes, final boolean minimized, final int line, final int col)
throws ParseException {
-
logger.debug("Unexpected StandaloneElement in {}:{}: {} [{}]", line, col, elementName, attributes);
}
@NonNullByDefault({})
public void handleOpenElement(final @Nullable String elementName, final @Nullable Map<String, String> attributes,
final int line, final int col) throws ParseException {
-
if (this.parserState == ParserState.INIT && "div".equals(elementName)) {
this.parserState = ParserState.DATA_ENTRY;
String classFlags;
@Override
public void handleText(final char @Nullable [] buffer, final int offset, final int len, final int line,
final int col) throws ParseException {
-
if (buffer == null) {
return;
}
@NonNullByDefault({})
public void handleStandaloneElement(final String elementName, final Map<String, String> attributes,
final boolean minimized, final int line, final int col) throws ParseException {
-
logger.debug("Error parsing options for {}: Unexpected StandaloneElement in {}{}: {} [{}]", channelName, line,
col, elementName, attributes);
}
@NonNullByDefault({})
public void handleOpenElement(final String elementName, final Map<String, String> attributes, final int line,
final int col) throws ParseException {
-
String id = attributes == null ? null : attributes.get("id");
if (this.parserState == ParserState.INIT && "input".equals(elementName) && "changeadr".equals(id)) {
@Override
public void handleText(final char @Nullable [] buffer, final int offset, final int len, final int line,
final int col) throws ParseException {
-
if (buffer == null) {
return;
}
public static TapoErrorCode fromCode(int errorCode) {
for (TapoErrorCode e : TapoErrorCode.values()) {
- if (e.code.equals(errorCode))
+ if (e.code.equals(errorCode)) {
return e;
+ }
}
return ERR_UNKNOWN;
}
import org.openhab.core.thing.type.ChannelTypeProvider;
import org.openhab.core.thing.type.ChannelTypeRegistry;
import org.openhab.core.thing.type.ChannelTypeUID;
-import org.osgi.service.http.HttpService;
import org.osgi.service.http.NamespaceException;
/**
TestChannelTypeRegistry channelTypeRegistry = new TestChannelTypeRegistry();
WundergroundUpdateReceiverDiscoveryService discoveryService = new WundergroundUpdateReceiverDiscoveryService(
true);
- HttpService httpService = mock(HttpService.class);
WundergroundUpdateReceiverServlet sut = new WundergroundUpdateReceiverServlet(discoveryService);
discoveryService.addUnhandledStationId(REQ_STATION_ID, sut.normalizeParameterMap(req.getParameterMap()));
Thing thing = ThingBuilder.create(SUPPORTED_THING_TYPES_UIDS.stream().findFirst().get(), TEST_THING_UID)
TestChannelTypeRegistry channelTypeRegistry = new TestChannelTypeRegistry();
WundergroundUpdateReceiverDiscoveryService discoveryService = new WundergroundUpdateReceiverDiscoveryService(
false);
- HttpService httpService = mock(HttpService.class);
WundergroundUpdateReceiverServlet sut = new WundergroundUpdateReceiverServlet(discoveryService);
discoveryService.addUnhandledStationId(REQ_STATION_ID, sut.normalizeParameterMap(req.getParameterMap()));
Thing thing = ThingBuilder.create(SUPPORTED_THING_TYPES_UIDS.stream().findFirst().get(), TEST_THING_UID)
TestChannelTypeRegistry channelTypeRegistry = new TestChannelTypeRegistry();
WundergroundUpdateReceiverDiscoveryService discoveryService = new WundergroundUpdateReceiverDiscoveryService(
true);
- HttpService httpService = mock(HttpService.class);
WundergroundUpdateReceiverServlet sut = new WundergroundUpdateReceiverServlet(discoveryService);
discoveryService.addUnhandledStationId(REQ_STATION_ID, sut.normalizeParameterMap(req1.getParameterMap()));
Thing thing = ThingBuilder.create(SUPPORTED_THING_TYPES_UIDS.stream().findFirst().get(), TEST_THING_UID)
TestChannelTypeRegistry channelTypeRegistry = new TestChannelTypeRegistry();
WundergroundUpdateReceiverDiscoveryService discoveryService = new WundergroundUpdateReceiverDiscoveryService(
true);
- HttpService httpService = mock(HttpService.class);
WundergroundUpdateReceiverServlet sut = new WundergroundUpdateReceiverServlet(discoveryService);
discoveryService.addUnhandledStationId(REQ_STATION_ID, sut.normalizeParameterMap(req1.getParameterMap()));
Thing thing = ThingBuilder.create(SUPPORTED_THING_TYPES_UIDS.stream().findFirst().get(), TEST_THING_UID)
UpdatingChannelTypeRegistry channelTypeRegistry = new UpdatingChannelTypeRegistry();
WundergroundUpdateReceiverDiscoveryService discoveryService = new WundergroundUpdateReceiverDiscoveryService(
true);
- HttpService httpService = mock(HttpService.class);
WundergroundUpdateReceiverServlet sut = new WundergroundUpdateReceiverServlet(discoveryService);
discoveryService.addUnhandledStationId(REQ_STATION_ID, sut.normalizeParameterMap(req1.getParameterMap()));
Thing thing = ThingBuilder.create(SUPPORTED_THING_TYPES_UIDS.stream().findFirst().get(), TEST_THING_UID)
@Test
public void testRefreshWithOldPreviousData() throws IllegalArgumentException, IllegalAccessException,
NoSuchFieldException, SecurityException, InterruptedException {
-
Configuration pollerConfig = new Configuration();
pollerConfig.put("refresh", 0L);
pollerConfig.put("start", 5);
projects / openhab-addons.git / commitdiff