[knx] Code rework (openhab#17420)

* [knx] Code rework

Signed-off-by: Holger Friedrich <mail@holger-friedrich.de>

Author: holgerfriedrich

bundles/org.openhab.binding.knx/src/main/java/org/openhab/binding/knx/internal/channel/KNXChannel.java

@@ -131,7 +131,7 @@ public final List<GroupAddress> getWriteAddresses() {
                 return new WriteSpecImpl(entry.getValue(), dpt, command);
             }
         }
-        // if we didn't find a match, check if we find a sub-type match
+        // if we didn't find a match, check if we find a subtype match
         for (Map.Entry<String, GroupAddressConfiguration> entry : groupAddressConfigurations.entrySet()) {
             String dpt = Objects.requireNonNullElse(entry.getValue().getDPT(), getDefaultDPT(entry.getKey()));
             Set<Class<? extends Type>> expectedTypeClasses = DPTUtil.getAllowedTypes(dpt);

bundles/org.openhab.binding.knx/src/main/java/org/openhab/binding/knx/internal/channel/KNXChannelFactory.java

@@ -56,7 +56,7 @@ public static KNXChannel createKnxChannel(Channel channel) throws IllegalArgumen
                 .map(Map.Entry::getValue).findFirst()
                 .orElseThrow(() -> new IllegalArgumentException(channelTypeUID + " is not a valid channel type ID"));
 
-        // typecast to avoid warning about unsafe return type; we know that the lookup returns non null values
+        // typecast to avoid warning about unsafe return type; we know that the lookup returns non-null values
         return (KNXChannel) supplier.apply(channel);
     }
 }

bundles/org.openhab.binding.knx/src/main/java/org/openhab/binding/knx/internal/channel/TypeColor.java

@@ -46,18 +46,12 @@ class TypeColor extends KNXChannel {
 
     @Override
     protected String getDefaultDPT(String gaConfigKey) {
-        if (gaConfigKey.equals(HSB_GA)) {
-            return DPTXlatorRGB.DPT_RGB.getID();
-        }
-        if (gaConfigKey.equals(INCREASE_DECREASE_GA)) {
-            return DPTXlator3BitControlled.DPT_CONTROL_DIMMING.getID();
-        }
-        if (gaConfigKey.equals(SWITCH_GA)) {
-            return DPTXlatorBoolean.DPT_SWITCH.getID();
-        }
-        if (gaConfigKey.equals(POSITION_GA)) {
-            return DPTXlator8BitUnsigned.DPT_SCALING.getID();
-        }
-        throw new IllegalArgumentException("GA configuration '" + gaConfigKey + "' is not supported");
+        return switch (gaConfigKey) {
+            case HSB_GA -> DPTXlatorRGB.DPT_RGB.getID();
+            case INCREASE_DECREASE_GA -> DPTXlator3BitControlled.DPT_CONTROL_DIMMING.getID();
+            case SWITCH_GA -> DPTXlatorBoolean.DPT_SWITCH.getID();
+            case POSITION_GA -> DPTXlator8BitUnsigned.DPT_SCALING.getID();
+            default -> throw new IllegalArgumentException("GA configuration '" + gaConfigKey + "' is not supported");
+        };
     }
 }

bundles/org.openhab.binding.knx/src/main/java/org/openhab/binding/knx/internal/channel/TypeDimmer.java

@@ -15,7 +15,6 @@
 import static org.openhab.binding.knx.internal.KNXBindingConstants.*;
 
 import java.util.List;
-import java.util.Objects;
 import java.util.Set;
 
 import org.eclipse.jdt.annotation.NonNullByDefault;
@@ -45,15 +44,11 @@ class TypeDimmer extends KNXChannel {
 
     @Override
     protected String getDefaultDPT(String gaConfigKey) {
-        if (Objects.equals(gaConfigKey, INCREASE_DECREASE_GA)) {
-            return DPTXlator3BitControlled.DPT_CONTROL_DIMMING.getID();
-        }
-        if (Objects.equals(gaConfigKey, SWITCH_GA)) {
-            return DPTXlatorBoolean.DPT_SWITCH.getID();
-        }
-        if (Objects.equals(gaConfigKey, POSITION_GA)) {
-            return DPTXlator8BitUnsigned.DPT_SCALING.getID();
-        }
-        throw new IllegalArgumentException("GA configuration '" + gaConfigKey + "' is not supported");
+        return switch (gaConfigKey) {
+            case INCREASE_DECREASE_GA -> DPTXlator3BitControlled.DPT_CONTROL_DIMMING.getID();
+            case SWITCH_GA -> DPTXlatorBoolean.DPT_SWITCH.getID();
+            case POSITION_GA -> DPTXlator8BitUnsigned.DPT_SCALING.getID();
+            default -> throw new IllegalArgumentException("GA configuration '" + gaConfigKey + "' is not supported");
+        };
     }
 }

bundles/org.openhab.binding.knx/src/main/java/org/openhab/binding/knx/internal/channel/TypeRollershutter.java

@@ -15,7 +15,6 @@
 import static org.openhab.binding.knx.internal.KNXBindingConstants.*;
 
 import java.util.List;
-import java.util.Objects;
 import java.util.Set;
 
 import org.eclipse.jdt.annotation.NonNullByDefault;
@@ -45,15 +44,11 @@ class TypeRollershutter extends KNXChannel {
 
     @Override
     protected String getDefaultDPT(String gaConfigKey) {
-        if (Objects.equals(gaConfigKey, UP_DOWN_GA)) {
-            return DPTXlatorBoolean.DPT_UPDOWN.getID();
-        }
-        if (Objects.equals(gaConfigKey, STOP_MOVE_GA)) {
-            return DPTXlatorBoolean.DPT_START.getID();
-        }
-        if (Objects.equals(gaConfigKey, POSITION_GA)) {
-            return DPTXlator8BitUnsigned.DPT_SCALING.getID();
-        }
-        throw new IllegalArgumentException("GA configuration '" + gaConfigKey + "' is not supported");
+        return switch (gaConfigKey) {
+            case UP_DOWN_GA -> DPTXlatorBoolean.DPT_UPDOWN.getID();
+            case STOP_MOVE_GA -> DPTXlatorBoolean.DPT_START.getID();
+            case POSITION_GA -> DPTXlator8BitUnsigned.DPT_SCALING.getID();
+            default -> throw new IllegalArgumentException("GA configuration '" + gaConfigKey + "' is not supported");
+        };
     }
 }

bundles/org.openhab.binding.knx/src/main/java/org/openhab/binding/knx/internal/client/AbstractKNXClient.java

@@ -234,7 +234,7 @@ private synchronized boolean connect() {
             // Protected ctor using given ManagementClientImpl is available (custom class to be inherited)
             managementProcedures = new CustomManagementProceduresImpl(managementClient, tl);
 
-            // OH helper for reading device info, based on managementClient above
+            // OpenHab helper for reading device info, based on managementClient above
             deviceInfoClient = new DeviceInfoClientImpl(managementClient);
 
             // ProcessCommunicator provides main KNX communication (Calimero).

bundles/org.openhab.binding.knx/src/main/java/org/openhab/binding/knx/internal/client/DeviceInspector.java

@@ -51,23 +51,7 @@ public class DeviceInspector {
     private final DeviceInfoClient client;
     private final IndividualAddress address;
 
-    public static class Result {
-        private final Map<String, String> properties;
-        private final Set<GroupAddress> groupAddresses;
-
-        public Result(Map<String, String> properties, Set<GroupAddress> groupAddresses) {
-            super();
-            this.properties = properties;
-            this.groupAddresses = groupAddresses;
-        }
-
-        public Map<String, String> getProperties() {
-            return properties;
-        }
-
-        public Set<GroupAddress> getGroupAddresses() {
-            return groupAddresses;
-        }
+    public record Result(Map<String, String> properties, Set<GroupAddress> groupAddresses) {
     }
 
     public DeviceInspector(DeviceInfoClient client, IndividualAddress address) {
@@ -114,7 +98,7 @@ public Result readDeviceInfo() {
      *           task immediately on connection loss or thing deconstruction.
      *
      * @param address Individual address of KNX device
-     * @return List of device properties
+     * @return Map of device properties
      * @throws InterruptedException
      */
     private Map<String, String> readDeviceProperties(IndividualAddress address) throws InterruptedException {
@@ -179,7 +163,7 @@ private Map<String, String> readDeviceProperties(IndividualAddress address) thro
             if (!maxApdu.isEmpty()) {
                 logger.trace("Max APDU of device {} is {} bytes (routing)", address, maxApdu);
             } else {
-                // fallback: MAX_APDU_LENGTH; if availble set the default is 14 according to spec
+                // fallback: MAX_APDU_LENGTH; if available set the default is 14 according to spec
                 Thread.sleep(OPERATION_INTERVAL);
                 try {
                     byte[] result = getClient().readDeviceProperties(address, ADDRESS_TABLE_OBJECT,
@@ -247,7 +231,7 @@ private Map<String, String> readDeviceProperties(IndividualAddress address) thro
                         logger.debug("Identified device {} as \"{}\"", address, result);
                         ret.put(FRIENDLY_NAME, result);
                     } else {
-                        // this is due to devices which have a buggy implememtation (and show a broken string also
+                        // this is due to devices which have a buggy implementation (and show a broken string also
                         // in ETS tool)
                         logger.debug("Ignoring FRIENDLY_NAME of device {} as it contains non-printable characters",
                                 address);
@@ -288,7 +272,7 @@ private Map<String, String> readDeviceProperties(IndividualAddress address) thro
      *           Currently only data from DD0 is returned; DD2 is just logged in debug mode.
      *
      * @param address Individual address of KNX device
-     * @return List of device properties
+     * @return Map of device properties
      * @throws InterruptedException
      */
     private Map<String, String> readDeviceDescription(IndividualAddress address) throws InterruptedException {
@@ -315,7 +299,7 @@ private Map<String, String> readDeviceDescription(IndividualAddress address) thr
             if (data != null) {
                 try {
                     final DD2 dd = DeviceDescriptor.DD2.from(data);
-                    logger.debug("The device with address {} is has DD2 {}", address, dd.toString());
+                    logger.debug("The device with address {} is has DD2 {}", address, dd);
                 } catch (KNXIllegalArgumentException e) {
                     logger.warn("Can not parse device descriptor 2 of device with address {}: {}", address,
                             e.getMessage());
@@ -342,21 +326,14 @@ private int toUnsigned(final byte @Nullable [] data) {
     }
 
     private static String getMediumType(int type) {
-        switch (type) {
-            case 0:
-                return "TP";
-            case 1:
-                return "PL";
-            case 2:
-                return "RF";
-            case 3:
-                return "TP0 (deprecated)";
-            case 4:
-                return "PL123 (deprecated)";
-            case 5:
-                return "IP";
-            default:
-                return "unknown (" + type + ")";
-        }
+        return switch (type) {
+            case 0 -> "TP";
+            case 1 -> "PL";
+            case 2 -> "RF";
+            case 3 -> "TP0 (deprecated)";
+            case 4 -> "PL123 (deprecated)";
+            case 5 -> "IP";
+            default -> "unknown (" + type + ")";
+        };
     }
 }

bundles/org.openhab.binding.knx/src/main/java/org/openhab/binding/knx/internal/client/InboundSpec.java

@@ -37,7 +37,7 @@ public interface InboundSpec {
     /**
      * Get the affected group addresses.
      *
-     * @return a list of group addresses.
+     * @return a Set of group addresses.
      */
     Set<GroupAddress> getGroupAddresses();
 }

bundles/org.openhab.binding.knx/src/main/java/org/openhab/binding/knx/internal/client/SerialClient.java

@@ -66,7 +66,7 @@ public SerialClient(int autoReconnectPeriod, ThingUID thingUID, int responseTime
     /**
      * try automatic detection of cEMI devices via the PEI identification frame
      *
-     * @implNote This is based on an vendor specific extension and may not work for other devices.
+     * @implNote This is based on a vendor specific extension and may not work for other devices.
      */
     protected boolean detectCemi() throws InterruptedException {
         final byte[] peiIdentifyReqFrame = { (byte) 0xa7 };

bundles/org.openhab.binding.knx/src/main/java/org/openhab/binding/knx/internal/client/SerialTransportAdapter.java

@@ -42,7 +42,7 @@
  * {@literal @}ServiceProvider annotation (biz.aQute.bnd.annotation) automatically creates the file
  * /META-INF/services/tuwien.auto.calimero.serial.spi.SerialCom
  * to register SerialTransportAdapter to the service loader.
- * Additional attributes for SerialTansportAdapter can be specified as well, e.g.
+ * Additional attributes for SerialTransportAdapter can be specified as well, e.g.
  * attribute = { "position=1" }
  * and will be part of MANIFEST.MF
  *