(streampipes) branch fix-adapter-script-migration-for-file-stream-adapter updated: Add default transformation config for new adapters

[oehler]

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

SvenO3 pushed a commit to branch 
fix-adapter-script-migration-for-file-stream-adapter
in repository https://gitbox.apache.org/repos/asf/streampipes.git


The following commit(s) were added to 
refs/heads/fix-adapter-script-migration-for-file-stream-adapter by this push:
     new 570521f328 Add default transformation config for new adapters
570521f328 is described below

commit 570521f328ff4e2ba9610378edd130b4facbb39e
Author: Sven Oehler <oehler.s...@web.de>
AuthorDate: Thu Jul 23 15:13:14 2026 +0200

    Add default transformation config for new adapters
---
 .../management/AdapterMasterManagement.java        |  1 +
 .../AdapterTransformationConfigDefaults.java       | 37 ++++++++++++++++++++++
 .../management/AdapterUpdateManagement.java        |  1 +
 3 files changed, 39 insertions(+)

diff --git 
a/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/AdapterMasterManagement.java
 
b/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/AdapterMasterManagement.java
index 8e87a97401..cee9cc2f7b 100644
--- 
a/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/AdapterMasterManagement.java
+++ 
b/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/AdapterMasterManagement.java
@@ -85,6 +85,7 @@ public class AdapterMasterManagement {
     var eventGrounding = GroundingUtils.createEventGrounding();
     adapterDescription.setEventGrounding(eventGrounding);
 
+    AdapterTransformationConfigDefaults.applyTo(adapterDescription);
     adapterResourceManager.encryptAndCreate(adapterDescription);
 
     // Stream is only created if the adpater is successfully stored
diff --git 
a/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/AdapterTransformationConfigDefaults.java
 
b/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/AdapterTransformationConfigDefaults.java
new file mode 100644
index 0000000000..fafde63318
--- /dev/null
+++ 
b/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/AdapterTransformationConfigDefaults.java
@@ -0,0 +1,37 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package org.apache.streampipes.connect.management.management;
+
+import org.apache.streampipes.model.connect.TransformationConfig;
+import org.apache.streampipes.model.connect.adapter.AdapterDescription;
+
+class AdapterTransformationConfigDefaults {
+
+  private AdapterTransformationConfigDefaults() {
+  }
+
+  static void applyTo(AdapterDescription adapterDescription) {
+    if (adapterDescription.getTransformationConfig() == null) {
+      
adapterDescription.setTransformationConfig(TransformationConfig.withDefaultScript());
+    } else {
+      adapterDescription.getTransformationConfig()
+                        .applyScriptDefaults();
+    }
+  }
+}
diff --git 
a/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/AdapterUpdateManagement.java
 
b/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/AdapterUpdateManagement.java
index 2c3d9f2504..66512001d3 100644
--- 
a/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/AdapterUpdateManagement.java
+++ 
b/streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/AdapterUpdateManagement.java
@@ -48,6 +48,7 @@ public class AdapterUpdateManagement {
   public void updateAdapter(AdapterDescription ad)
       throws AdapterException {
     // update adapter in database 
+    AdapterTransformationConfigDefaults.applyTo(ad);
     this.adapterResourceManager.encryptAndUpdate(ad);
     boolean shouldRestart = ad.isRunning();