(streampipes) branch 2976-add-missing-plc4x-datatypes updated: fix(#2976): Support PLC4X datatypes

[riemer]

This is an automated email from the ASF dual-hosted git repository.

riemer pushed a commit to branch 2976-add-missing-plc4x-datatypes
in repository https://gitbox.apache.org/repos/asf/streampipes.git


The following commit(s) were added to 
refs/heads/2976-add-missing-plc4x-datatypes by this push:
     new b6e67978e8 fix(#2976): Support PLC4X datatypes
b6e67978e8 is described below

commit b6e67978e8fc8f3cc770d9fe417e28c8be21850a
Author: Dominik Riemer <dominik.rie...@gmail.comx>
AuthorDate: Sun Jun 30 14:37:56 2024 +0200

    fix(#2976): Support PLC4X datatypes
---
 .../connectors/plc/adapter/modbus/Plc4xModbusAdapter.java           | 3 ++-
 .../connectors/plc/adapter/s7/config/ConfigurationParser.java       | 6 ++++--
 2 files changed, 6 insertions(+), 3 deletions(-)

diff --git 
a/streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/adapter/modbus/Plc4xModbusAdapter.java
 
b/streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/adapter/modbus/Plc4xModbusAdapter.java
index 6c0673797c..0e92d06e76 100644
--- 
a/streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/adapter/modbus/Plc4xModbusAdapter.java
+++ 
b/streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/adapter/modbus/Plc4xModbusAdapter.java
@@ -101,9 +101,10 @@ public class Plc4xModbusAdapter implements 
StreamPipesAdapter, IPullAdapter {
    * Connection to the PLC
    */
   private PlcConnection plcConnection;
-  private PlcConnectionManager connectionManager;
+  private final PlcConnectionManager connectionManager;
 
   public Plc4xModbusAdapter(PlcConnectionManager connectionManager) {
+    this.connectionManager = connectionManager;
   }
 
   /**
diff --git 
a/streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/adapter/s7/config/ConfigurationParser.java
 
b/streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/adapter/s7/config/ConfigurationParser.java
index f45b4dbc40..395a11115d 100644
--- 
a/streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/adapter/s7/config/ConfigurationParser.java
+++ 
b/streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/adapter/s7/config/ConfigurationParser.java
@@ -81,8 +81,10 @@ public class ConfigurationParser {
     return switch (type) {
       case "BOOL" -> Datatypes.Boolean;
       case "BYTE", "REAL" -> Datatypes.Float;
-      case "INT" -> Datatypes.Integer;
-      case "WORD", "TIME_OF_DAY", "DATE", "DATE_AND_TIME", "STRING", "CHAR" -> 
Datatypes.String;
+      case "LREAL" -> Datatypes.Double;
+      case "INT", "DINT", "UDINT", "UINT", "SINT", "USINT" -> 
Datatypes.Integer;
+      case "LINT", "ULINT" -> Datatypes.Long;
+      case "WORD", "LWORD", "TIME_OF_DAY", "DATE", "DATE_AND_TIME", "STRING", 
"CHAR", "WCHAR" -> Datatypes.String;
       default -> throw new AdapterException("Datatype " + plcType + " is not 
supported");
     };
   }