667 langchain4j tools

camelBase/pom.xml

@@ -271,7 +271,23 @@
         </dependency>
         <dependency>
             <groupId>org.apache.camel</groupId>
-            <artifactId>camel-log</artifactId>
+            <artifactId>camel-langchain4j-agent</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-ai-tool</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-langchain4j-tools</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-langchain4j-web-search</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-mustache</artifactId>
         </dependency>
         <dependency>
             <groupId>org.apache.camel</groupId>

commonBase/pom.xml

@@ -307,7 +307,11 @@
             <artifactId>langchain4j-google-ai-gemini</artifactId>
             <version>${langchain4j.version}</version>
         </dependency>
-
+        <dependency>
+            <groupId>dev.langchain4j</groupId>
+            <artifactId>langchain4j-web-search-engine-tavily</artifactId>
+            <version>${langchain4j-tavily.version}</version>
+        </dependency>
         <!-- spring AI -->
         <dependency>
             <groupId>org.springframework.ai</groupId>

dil/src/main/java/org/assimbly/dil/blocks/connections/Connection.java

@@ -2,6 +2,7 @@
 
 import org.assimbly.dil.blocks.connections.ai.LangChain4jAgentConnection;
 import org.assimbly.dil.blocks.connections.ai.LangChain4jConnection;
+import org.assimbly.dil.blocks.connections.ai.LangChain4jWebSearchConnection;
 import org.assimbly.dil.blocks.connections.ai.SpringAiConnection;
 import org.assimbly.dil.blocks.connections.auth.BasicAuthentication;
 import org.assimbly.dil.blocks.connections.auth.MutualSSL;
@@ -73,10 +74,10 @@ private void startConnection() throws Exception{
             case "rabbitmq", "spring-rabbitmq" ->
                     new RabbitMQConnection(context, decryptedProperties, connectionId, "spring-rabbitmq").start();
 
-            case "springai" ->
+            case "springaichat" ->
                     new SpringAiConnection(context, decryptedProperties, connectionId).start();
 
-            case "langchain4j" ->
+            case "langchain4jchat" ->
                     new LangChain4jConnection(context, decryptedProperties, connectionId).start();
 
             case "ibmq" ->
@@ -94,9 +95,12 @@ private void startConnection() throws Exception{
             case "imaps" ->
                     log.debug("Imaps connection will be configured on the component");
 
-            case "langchain4j-agent" ->
+            case "langchain4jagent" ->
                     new LangChain4jAgentConnection(context, decryptedProperties, connectionId).start();
 
+            case "langchain4j-web-search" ->
+                    new LangChain4jWebSearchConnection(context, decryptedProperties, connectionId).start();
+
             default -> throw new IllegalArgumentException("Connection parameters for connection " + connectionType + " are not implemented");
 
         }

dil/src/main/java/org/assimbly/dil/blocks/connections/ai/LangChain4jAgentConnection.java

@@ -12,7 +12,11 @@
 import dev.langchain4j.memory.chat.ChatMemoryProvider;
 import dev.langchain4j.memory.chat.MessageWindowChatMemory;
 import dev.langchain4j.store.memory.chat.InMemoryChatMemoryStore;
+import dev.langchain4j.web.search.WebSearchEngine;
+import dev.langchain4j.web.search.WebSearchTool;
+import dev.langchain4j.web.search.tavily.TavilyWebSearchEngine;
 import java.time.Duration;
+import java.util.List;
 
 public class LangChain4jAgentConnection {
 
@@ -25,6 +29,8 @@ public class LangChain4jAgentConnection {
     private String apiKey;
     private String modelName;
     private String timeout;
+    private String webSearchApiKey;
+    private String maxMessages;
 
     public LangChain4jAgentConnection(CamelContext context, EncryptableProperties properties, String connectionId) {
         this.context = context;
@@ -47,6 +53,11 @@ private void setFields() {
         apiKey = properties.getProperty("connection." + connectionId + ".apikey");
         modelName = properties.getProperty("connection." + connectionId + ".modelname");
         timeout = properties.getProperty("connection." + connectionId + ".timeout");
+        webSearchApiKey = properties.getProperty("connection." + connectionId + ".websearchapikey");
+        if (webSearchApiKey == null || webSearchApiKey.isEmpty()) {
+            webSearchApiKey = properties.getProperty("connection." + connectionId + ".tavilyapikey");
+        }
+        maxMessages = properties.getProperty("connection." + connectionId + ".maxmessages");
     }
 
     private boolean checkConnection() {
@@ -67,7 +78,7 @@ private void setConnection() {
                 apiKey != null ? apiKey.length() : 0,
                 apiKey != null && apiKey.length() >= 5 ? apiKey.substring(0, 5) : "N/A");
 
-        String resolvedModel = (modelName != null && !modelName.isEmpty()) ? modelName : "gemini-2.5-flash";
+        String resolvedModel = (modelName != null && !modelName.isEmpty()) ? modelName : "gemini-3.6-flash";
         long resolvedTimeout = 10;
         if (timeout != null && !timeout.isEmpty()) {
             try {
@@ -77,23 +88,58 @@ private void setConnection() {
             }
         }
 
+        int resolvedMaxMessages = 100;
+        if (maxMessages != null && !maxMessages.isEmpty()) {
+            try {
+                resolvedMaxMessages = Integer.parseInt(maxMessages);
+            } catch (NumberFormatException e) {
+                log.warn("Invalid maxMessages value '{}', using default 100", maxMessages);
+            }
+        }
+
         ChatModel chatModel = GoogleAiGeminiChatModel.builder()
                 .apiKey(apiKey)
                 .modelName(resolvedModel)
                 .timeout(Duration.ofSeconds(resolvedTimeout))
+                .returnThinking(true)
+                .sendThinking(true)
                 .build();
 
+        final int finalMaxMessages = resolvedMaxMessages;
         InMemoryChatMemoryStore chatMemoryStore = new InMemoryChatMemoryStore();
-        ChatMemoryProvider chatMemoryProvider = memoryId -> MessageWindowChatMemory.builder()
-                .id(memoryId)
-                .maxMessages(100)
-                .chatMemoryStore(chatMemoryStore)
-                .build();
+        java.util.Map<Object, dev.langchain4j.memory.ChatMemory> memories = java.util.Collections.synchronizedMap(
+                new java.util.LinkedHashMap<Object, dev.langchain4j.memory.ChatMemory>(100, 0.75f, true) {
+                    @Override
+                    protected boolean removeEldestEntry(java.util.Map.Entry<Object, dev.langchain4j.memory.ChatMemory> eldest) {
+                        return size() > 1000;
+                    }
+                }
+        );
+        ChatMemoryProvider chatMemoryProvider = memoryId -> {
+            synchronized (memories) {
+                return memories.computeIfAbsent(memoryId, id ->
+                        MessageWindowChatMemory.builder()
+                                .id(id)
+                                .maxMessages(finalMaxMessages)
+                                .chatMemoryStore(chatMemoryStore)
+                                .build()
+                );
+            }
+        };
 
         AgentConfiguration config = new AgentConfiguration()
                 .withChatModel(chatModel)
                 .withChatMemoryProvider(chatMemoryProvider);
 
+        if (webSearchApiKey != null && !webSearchApiKey.isEmpty()) {
+            log.info("Attaching Tavily WebSearchTool to LangChain4j Agent with connection id={}", connectionId);
+            WebSearchEngine webSearchEngine = TavilyWebSearchEngine.builder()
+                    .apiKey(webSearchApiKey)
+            		.build();
+            WebSearchTool webSearchTool = WebSearchTool.from(webSearchEngine);
+            config.withCustomTools(List.of(webSearchTool));
+        }
+
         Agent agent = new AgentWithMemory(config);
 
         context.getRegistry().bind(connectionId, agent);

dil/src/main/java/org/assimbly/dil/blocks/connections/ai/LangChain4jWebSearchConnection.java

@@ -0,0 +1,64 @@
+package org.assimbly.dil.blocks.connections.ai;
+
+import org.apache.camel.CamelContext;
+import org.jasypt.properties.EncryptableProperties;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import dev.langchain4j.web.search.WebSearchEngine;
+import dev.langchain4j.web.search.tavily.TavilyWebSearchEngine;
+
+public class LangChain4jWebSearchConnection {
+
+    protected Logger log = LoggerFactory.getLogger(getClass());
+
+    private final CamelContext context;
+    private final EncryptableProperties properties;
+    private final String connectionId;
+
+    private String apiKey;
+
+    public LangChain4jWebSearchConnection(CamelContext context, EncryptableProperties properties, String connectionId) {
+        this.context = context;
+        this.properties = properties;
+        this.connectionId = connectionId;
+    }
+
+    public void start() {
+        setFields();
+
+        if (checkConnection()) {
+            log.info("Creating new LangChain4j Web Search connection with id={}", connectionId);
+            setConnection();
+        } else {
+            log.info("Reuse LangChain4j Web Search connection with id={}", connectionId);
+        }
+    }
+
+    private void setFields() {
+        apiKey = properties.getProperty("connection." + connectionId + ".apikey");
+    }
+
+    private boolean checkConnection() {
+        Object isRegistered = context.getRegistry().lookupByName(connectionId);
+        if (isRegistered != null) {
+            return false;
+        }
+
+        if (apiKey == null || apiKey.isEmpty()) {
+            throw new IllegalArgumentException("LangChain4j Web Search connection parameters are invalid. apikey is required");
+        }
+
+        return true;
+    }
+
+    private void setConnection() {
+        log.info("Setting up Tavily WebSearchEngine connection with id={}", connectionId);
+
+        WebSearchEngine webSearchEngine = TavilyWebSearchEngine.builder()
+                .apiKey(apiKey)
+                .build();
+
+        context.getRegistry().bind(connectionId, webSearchEngine);
+        log.info("Successfully bound WebSearchEngine bean with id={} to the Camel registry", connectionId);
+    }
+}

dil/src/main/java/org/assimbly/dil/transpiler/marshalling/core/RouteTemplate.java

@@ -459,7 +459,7 @@ private void createTemplateId(String uri,String type){
             }
 
             if(templateExists(templateName)){
-                templateId = templateName;
+                templateId = resolveTemplateName(templateName);
             }else if(uri.startsWith("block")){
                 String componentName = path;
                 componentName = componentName.toLowerCase();
@@ -474,7 +474,30 @@ private void createTemplateId(String uri,String type){
 
     private boolean templateExists(String templateName) {
         String fullTemplateName = templateName + ".kamelet.yaml";
-        return CustomKameletCatalog.getNames().contains(fullTemplateName);
+        if (CustomKameletCatalog.getNames().contains(fullTemplateName)) {
+            return true;
+        }
+        String targetStripped = fullTemplateName.replace("-", "");
+        for (String name : CustomKameletCatalog.getNames()) {
+            if (name.replace("-", "").equalsIgnoreCase(targetStripped)) {
+                return true;
+            }
+        }
+        return false;
+    }
+
+    private String resolveTemplateName(String templateName) {
+        String fullTemplateName = templateName + ".kamelet.yaml";
+        if (CustomKameletCatalog.getNames().contains(fullTemplateName)) {
+            return templateName;
+        }
+        String targetStripped = fullTemplateName.replace("-", "");
+        for (String name : CustomKameletCatalog.getNames()) {
+            if (name.replace("-", "").equalsIgnoreCase(targetStripped)) {
+                return name.substring(0, name.indexOf(".kamelet.yaml"));
+            }
+        }
+        return templateName;
     }
 
 

dil/src/main/resources/kamelets/langchain4j-tool-weather-source.kamelet.yaml

@@ -0,0 +1,26 @@
+apiVersion: "camel.apache.org/v1"
+kind: "Kamelet"
+metadata:
+  name: "langchain4j-tool-weather-source"
+  labels:
+    camel.apache.org/kamelet.type: "source"
+spec:
+  definition:
+    title: "LangChain4j Weather Tool"
+    description: "Returns a placeholder weather forecast for a given city."
+    type: "object"
+    properties:
+      city:
+        title: "City"
+        description: "Name of the city to get weather for"
+        type: "string"
+        default: ""
+  dependencies:
+    - "camel:ai-tool"
+  template:
+    route:
+      from:
+        uri: "ai-tool:weather?description=Returns+a+placeholder+weather+forecast+for+a+given+city&tags=weather"
+        steps:
+          - setBody:
+              simple: "Weather for ${header.city} is sunny with 25°C temperature."

dil/src/main/resources/kamelets/langchain4j-web-search-action.kamelet.yaml

@@ -0,0 +1,73 @@
+apiVersion: "camel.apache.org/v1"
+kind: "Kamelet"
+metadata:
+  name: "langchain4j-web-search-action"
+  labels:
+    camel.apache.org/kamelet.type: "action"
+
+spec:
+  definition:
+    title: "langchain4j-web-search action"
+    description: "Web Search component for LangChain4j"
+    type: "object"
+    properties:
+      in:
+        title: "Source Endpoint"
+        type: "string"
+        default: "kamelet:source"
+      out:
+        title: "Sink Endpoint"
+        type: "string"
+        default: "kamelet:sink"
+      sink:
+        title: "Sink"
+        type: "boolean"
+        default: false
+      routeId:
+        title: "Route ID"
+        type: "string"
+      routeConfigurationId:
+        title: "Route Configuration ID"
+        type: "string"
+        default: "0"
+      searchId:
+        title: "Search ID"
+        type: "string"
+        default: "search"
+      webSearchEngine:
+        title: "Web Search Engine Bean Name"
+        description: "Name of the WebSearchEngine bean in the Camel registry (e.g. #webSearchEngine)"
+        type: "string"
+        default: "#webSearchEngine"
+      maxResults:
+        title: "Max Results"
+        description: "Maximum number of search results to return"
+        type: "integer"
+        default: 1
+      resultType:
+        title: "Result Type"
+        description: "Result type (CONTENT, SNIPPET, or LANGCHAIN4J_WEB_SEARCH_ORGANIC_RESULT)"
+        type: "string"
+        default: "SNIPPET"
+
+  dependencies:
+    - "camel:kamelet"
+    - "camel:langchain4j-web-search"
+
+  template:
+    route:
+      routeConfigurationId: "{{routeConfigurationId}}"
+      from:
+        uri: "{{in}}"
+        steps:
+          - step:
+              id: "{{routeId}}"
+              steps:
+                - convertBodyTo:
+                    type: String
+                - to:
+                    uri: "langchain4j-web-search:{{searchId}}?webSearchEngine={{webSearchEngine}}&maxResults={{maxResults}}&resultType={{resultType}}"
+          - to:
+              disabled: "{{sink}}"
+              uri: "{{out}}"
+