AI rule node: add force ack configuration option to rule node

rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/ai/TbAiNode.java

@@ -98,6 +98,7 @@ public final class TbAiNode extends TbAbstractExternalNode implements TbNode {
         userPrompt = config.getUserPrompt();
         timeoutSeconds = config.getTimeoutSeconds();
         modelId = config.getModelId();
+        super.forceAck = config.isForceAck() || super.forceAck; // force ack if node config says so, or if env variable (super.forceAck) says so
 
         Optional<AiModel> model = ctx.getAiModelService().findAiModelByTenantIdAndId(ctx.getTenantId(), modelId);
         if (model.isEmpty()) {

rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/ai/TbAiNodeConfiguration.java

@@ -50,6 +50,8 @@ public class TbAiNodeConfiguration implements NodeConfiguration<TbAiNodeConfigur
     @Max(value = 600, message = "cannot exceed 600 seconds (10 minutes)")
     private int timeoutSeconds;
 
+    private boolean forceAck;
+
     @Override
     public TbAiNodeConfiguration defaultConfiguration() {
         var configuration = new TbAiNodeConfiguration();

rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/external/TbAbstractExternalNode.java

@@ -22,7 +22,7 @@ import org.thingsboard.server.common.msg.TbMsg;
 
 public abstract class TbAbstractExternalNode implements TbNode {
 
-    private boolean forceAck;
+    protected boolean forceAck;
 
     public void init(TbContext ctx) {
         this.forceAck = ctx.isExternalNodeForceAck();