Skip to content

Commit 575029c

Browse files
authored
Merge pull request #398 from thuva9872/merge-to-main
Merge mi-ext-v2-ls-alpha to main branch
2 parents 4253433 + cdada8d commit 575029c

File tree

939 files changed

+85696
-485
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

939 files changed

+85696
-485
lines changed

org.eclipse.lemminx/pom.xml

+34-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
<parent>
44
<groupId>org.eclipse.lemminx</groupId>
55
<artifactId>lemminx-parent</artifactId>
6-
<version>0.24.0-wso2v33-SNAPSHOT</version>
6+
<version>0.24.0-wso2v59-SNAPSHOT</version>
77
<relativePath>../pom.xml</relativePath>
88
</parent>
99
<artifactId>org.eclipse.lemminx</artifactId>
@@ -14,6 +14,7 @@
1414
<dev.build.timestamp>${maven.build.timestamp}</dev.build.timestamp>
1515
<cbi.jarsigner.skip>true</cbi.jarsigner.skip>
1616
<native.maven.plugin.version>0.9.16</native.maven.plugin.version>
17+
<mi.connector.generator.version>0.9.0</mi.connector.generator.version>
1718
<graalvm.static />
1819
</properties>
1920
<build>
@@ -346,5 +347,37 @@
346347
<groupId>org.apache.woden.wso2</groupId>
347348
<artifactId>woden</artifactId>
348349
</dependency>
350+
<dependency>
351+
<groupId>com.github.spullara.mustache.java</groupId>
352+
<artifactId>compiler</artifactId>
353+
<version>0.9.14</version>
354+
</dependency>
355+
<dependency>
356+
<groupId>org.wso2.integration.tools</groupId>
357+
<artifactId>mi-connector-generator</artifactId>
358+
<version>${mi.connector.generator.version}</version>
359+
<exclusions>
360+
<exclusion>
361+
<groupId>org.apache.axis2</groupId>
362+
<artifactId>addressing</artifactId>
363+
</exclusion>
364+
<exclusion>
365+
<groupId>com.rabbitmq</groupId>
366+
<artifactId>amqp-client</artifactId>
367+
</exclusion>
368+
</exclusions>
369+
</dependency>
370+
<dependency>
371+
<groupId>org.apache.maven.shared</groupId>
372+
<artifactId>maven-invoker</artifactId>
373+
</dependency>
374+
<dependency>
375+
<groupId>org.apache.velocity</groupId>
376+
<artifactId>velocity-engine-core</artifactId>
377+
</dependency>
378+
<dependency>
379+
<groupId>org.mockito</groupId>
380+
<artifactId>mockito-core</artifactId>
381+
</dependency>
349382
</dependencies>
350383
</project>

org.eclipse.lemminx/src/main/java/org/eclipse/lemminx/SynapseLanguageService.java

+244-32
Large diffs are not rendered by default.

org.eclipse.lemminx/src/main/java/org/eclipse/lemminx/XMLLanguageServer.java

+20-1
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,9 @@
1515

1616
import static org.eclipse.lsp4j.jsonrpc.CompletableFutures.computeAsync;
1717

18+
import java.io.IOException;
19+
import java.net.URISyntaxException;
20+
import java.nio.file.Path;
1821
import java.util.Arrays;
1922
import java.util.Collection;
2023
import java.util.Map;
@@ -24,9 +27,11 @@
2427
import java.util.concurrent.ScheduledExecutorService;
2528
import java.util.concurrent.ScheduledFuture;
2629
import java.util.concurrent.TimeUnit;
30+
import java.util.logging.Level;
2731
import java.util.logging.Logger;
2832
import java.util.stream.Collectors;
2933

34+
import com.google.gson.JsonObject;
3035
import org.eclipse.lemminx.client.ExtendedClientCapabilities;
3136
import org.eclipse.lemminx.commons.ModelTextDocument;
3237
import org.eclipse.lemminx.commons.ParentProcessWatcher.ProcessLanguageServer;
@@ -38,6 +43,7 @@
3843
import org.eclipse.lemminx.customservice.SynapseLanguageClientAPI;
3944
import org.eclipse.lemminx.customservice.XMLLanguageClientAPI;
4045
import org.eclipse.lemminx.customservice.XMLLanguageServerAPI;
46+
import org.eclipse.lemminx.customservice.synapse.utils.Utils;
4147
import org.eclipse.lemminx.dom.DOMDocument;
4248
import org.eclipse.lemminx.extensions.contentmodel.settings.ContentModelSettings;
4349
import org.eclipse.lemminx.extensions.contentmodel.settings.XMLValidationRootSettings;
@@ -96,7 +102,7 @@ public class XMLLanguageServer implements ProcessLanguageServer, XMLLanguageServ
96102
private Integer parentProcessId;
97103
private XMLCapabilityManager capabilityManager;
98104
private TelemetryManager telemetryManager;
99-
public final SynapseLanguageService synapseLanguageService;
105+
private final SynapseLanguageService synapseLanguageService;
100106

101107
public XMLLanguageServer() {
102108
xmlTextDocumentService = new XMLTextDocumentService(this);
@@ -114,6 +120,12 @@ public XMLLanguageServer() {
114120

115121
@Override
116122
public CompletableFuture<InitializeResult> initialize(InitializeParams params) {
123+
try {
124+
Path synapseSchemaPath = Utils.updateSynapseCatalogSettings(params);
125+
synapseLanguageService.setSynapseXSDPath(synapseSchemaPath);
126+
} catch (IOException | URISyntaxException e) {
127+
LOGGER.log(Level.SEVERE, "Error while updating synapse catalog settings", e);
128+
}
117129
Object initOptions = InitializationOptionsSettings.getSettings(params);
118130
Object xmlSettings = AllXMLSettings.getAllXMLSettings(initOptions);
119131
XMLGeneralClientSettings settings = XMLGeneralClientSettings.getGeneralXMLSettings(xmlSettings);
@@ -178,6 +190,12 @@ private synchronized void updateSettings(Object initOptions, boolean initLogs) {
178190
if (initOptions == null) {
179191
return;
180192
}
193+
try {
194+
initOptions = Utils.updateSynapseCatalogSettings((JsonObject) initOptions,
195+
synapseLanguageService.getSynapseXSDPath());
196+
} catch (IOException | URISyntaxException e) {
197+
LOGGER.log(Level.SEVERE, "Error while updating synapse catalog settings", e);
198+
}
181199
// Update client settings
182200
Object initSettings = AllXMLSettings.getAllXMLSettings(initOptions);
183201
XMLGeneralClientSettings xmlClientSettings = XMLGeneralClientSettings.getGeneralXMLSettings(initSettings);
@@ -243,6 +261,7 @@ private synchronized void updateSettings(Object initOptions, boolean initLogs) {
243261
@Override
244262
public CompletableFuture<Object> shutdown() {
245263
xmlLanguageService.dispose();
264+
synapseLanguageService.dispose();
246265
if (capabilityManager.getClientCapabilities().shouldLanguageServerExitOnShutdown()) {
247266
delayer.schedule(() -> exit(0), 1, TimeUnit.SECONDS);
248267
}

org.eclipse.lemminx/src/main/java/org/eclipse/lemminx/XMLTextDocumentService.java

+1
Original file line numberDiff line numberDiff line change
@@ -390,6 +390,7 @@ public void didOpen(DidOpenTextDocumentParams params) {
390390
*/
391391
@Override
392392
public void didChange(DidChangeTextDocumentParams params) {
393+
xmlLanguageServer.getSynapseLanguageService();
393394
ModelTextDocument<DOMDocument> document = documents.onDidChangeTextDocument(params);
394395
triggerValidationFor(document, TriggeredBy.didChange, params.getContentChanges());
395396
}

org.eclipse.lemminx/src/main/java/org/eclipse/lemminx/XMLWorkspaceService.java

+1-2
Original file line numberDiff line numberDiff line change
@@ -94,8 +94,7 @@ public void didChangeWatchedFiles(DidChangeWatchedFilesParams params) {
9494
List<FileEvent> changes = params.getChanges();
9595
for (FileEvent change : changes) {
9696
if (change.getUri().contains("connectors") && change.getUri().contains(".zip")) {
97-
String projectUri = xmlLanguageServer.synapseLanguageService.getProjectUri();
98-
xmlLanguageServer.synapseLanguageService.updateConnectors();
97+
((SynapseLanguageService) xmlLanguageServer.getSynapseLanguageService()).updateConnectors();
9998
} else {
10099
if (!xmlTextDocumentService.documentIsOpen(change.getUri())) {
101100
xmlTextDocumentService.doSave(change.getUri());

org.eclipse.lemminx/src/main/java/org/eclipse/lemminx/customservice/ISynapseLanguageService.java

+90-5
Original file line numberDiff line numberDiff line change
@@ -18,16 +18,24 @@
1818

1919
package org.eclipse.lemminx.customservice;
2020

21+
import com.google.gson.JsonObject;
2122
import org.eclipse.lemminx.customservice.synapse.api.generator.pojo.GenerateAPIResponse;
2223
import org.eclipse.lemminx.customservice.synapse.api.generator.pojo.GenerateSwaggerParam;
2324
import org.eclipse.lemminx.customservice.synapse.api.generator.pojo.GenerateSwaggerResponse;
25+
26+
import org.eclipse.lemminx.customservice.synapse.connectors.entity.ConnectionUIParam;
2427
import org.eclipse.lemminx.customservice.synapse.connectors.entity.Connections;
2528
import org.eclipse.lemminx.customservice.synapse.connectors.entity.ConnectorParam;
2629
import org.eclipse.lemminx.customservice.synapse.connectors.entity.Connector;
2730
import org.eclipse.lemminx.customservice.synapse.api.generator.pojo.GenerateAPIParam;
28-
import org.eclipse.lemminx.customservice.synapse.connectors.ConnectorHolder;
29-
import org.eclipse.lemminx.customservice.synapse.dataService.AddDriverRequestParams;
31+
import org.eclipse.lemminx.customservice.synapse.connectors.entity.ConnectorResponse;
32+
import org.eclipse.lemminx.customservice.synapse.connectors.entity.TestConnectionRequest;
33+
import org.eclipse.lemminx.customservice.synapse.connectors.entity.TestConnectionResponse;
34+
import org.eclipse.lemminx.customservice.synapse.connectors.generate.ConnectorGenerateRequest;
35+
import org.eclipse.lemminx.customservice.synapse.connectors.generate.ConnectorGeneratorResponse;
3036
import org.eclipse.lemminx.customservice.synapse.dataService.CheckDBDriverRequestParams;
37+
import org.eclipse.lemminx.customservice.synapse.dataService.CheckDBDriverResponseParams;
38+
import org.eclipse.lemminx.customservice.synapse.dataService.ModifyDriverRequestParams;
3139
import org.eclipse.lemminx.customservice.synapse.dataService.QueryGenRequestParams;
3240
import org.eclipse.lemminx.customservice.synapse.db.DBConnectionTestParams;
3341
import org.eclipse.lemminx.customservice.synapse.db.DBConnectionTestResponse;
@@ -38,27 +46,41 @@
3846
import org.eclipse.lemminx.customservice.synapse.dependency.tree.pojo.DependencyTree;
3947
import org.eclipse.lemminx.customservice.synapse.dependency.tree.pojo.OverviewModel;
4048
import org.eclipse.lemminx.customservice.synapse.directoryTree.DirectoryMapResponse;
49+
import org.eclipse.lemminx.customservice.synapse.expression.pojo.ExpressionParam;
50+
import org.eclipse.lemminx.customservice.synapse.expression.pojo.HelperPanelData;
4151
import org.eclipse.lemminx.customservice.synapse.inbound.conector.InboundConnectorResponse;
4252
import org.eclipse.lemminx.customservice.synapse.inbound.conector.InboundConnectorParam;
53+
import org.eclipse.lemminx.customservice.synapse.mediator.tryout.pojo.MediatorTryoutRequest;
54+
import org.eclipse.lemminx.customservice.synapse.mediatorService.pojo.MediatorRequest;
55+
import org.eclipse.lemminx.customservice.synapse.mediatorService.pojo.SynapseConfigRequest;
56+
import org.eclipse.lemminx.customservice.synapse.mediatorService.pojo.SynapseConfigResponse;
57+
import org.eclipse.lemminx.customservice.synapse.mediatorService.pojo.UISchemaRequest;
4358
import org.eclipse.lemminx.customservice.synapse.parser.ConfigDetails;
4459
import org.eclipse.lemminx.customservice.synapse.parser.DependencyDetails;
4560
import org.eclipse.lemminx.customservice.synapse.parser.OverviewPageDetailsResponse;
4661
import org.eclipse.lemminx.customservice.synapse.parser.UpdateConfigRequest;
4762
import org.eclipse.lemminx.customservice.synapse.parser.UpdateDependencyRequest;
4863
import org.eclipse.lemminx.customservice.synapse.parser.UpdateResponse;
64+
import org.eclipse.lemminx.customservice.synapse.parser.config.ConfigurableEntry;
65+
import org.eclipse.lemminx.customservice.synapse.resourceFinder.ResourceUsagesRequest;
4966
import org.eclipse.lemminx.customservice.synapse.resourceFinder.pojo.ResourceParam;
5067
import org.eclipse.lemminx.customservice.synapse.resourceFinder.pojo.ResourceResponse;
5168
import org.eclipse.lemminx.customservice.synapse.schemagen.util.SchemaGenFromContentRequest;
5269
import org.eclipse.lemminx.customservice.synapse.schemagen.util.SchemaGenRequest;
5370
import org.eclipse.lemminx.customservice.synapse.schemagen.util.SchemaGenResponse;
5471
import org.eclipse.lemminx.customservice.synapse.syntaxTree.SyntaxTreeResponse;
72+
import org.eclipse.lemminx.customservice.synapse.mediator.tryout.pojo.MediatorTryoutInfo;
73+
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.ArtifactTypeResponse;
74+
import org.eclipse.lemminx.services.extensions.completion.ICompletionResponse;
5575
import org.eclipse.lsp4j.DefinitionParams;
5676
import org.eclipse.lsp4j.Location;
5777
import org.eclipse.lsp4j.PublishDiagnosticsParams;
78+
import org.eclipse.lsp4j.SignatureHelp;
5879
import org.eclipse.lsp4j.TextDocumentIdentifier;
5980
import org.eclipse.lsp4j.WorkspaceFolder;
6081
import org.eclipse.lsp4j.jsonrpc.messages.Either;
6182
import org.eclipse.lsp4j.jsonrpc.messages.Either3;
83+
import org.eclipse.lsp4j.jsonrpc.services.JsonNotification;
6284
import org.eclipse.lsp4j.jsonrpc.services.JsonRequest;
6385
import org.eclipse.lsp4j.jsonrpc.services.JsonSegment;
6486

@@ -85,11 +107,17 @@ public interface ISynapseLanguageService {
85107
CompletableFuture<ResourceResponse> availableResources(ResourceParam param);
86108

87109
@JsonRequest
88-
CompletableFuture<Either3<ConnectorHolder, Connector, Boolean>> availableConnectors(ConnectorParam param);
110+
CompletableFuture<Either3<ConnectorResponse, Connector, Boolean>> availableConnectors(ConnectorParam param);
89111

90112
@JsonRequest
91113
CompletableFuture<List<String>> getRegistryFiles(TextDocumentIdentifier param);
92114

115+
@JsonRequest
116+
CompletableFuture<List<String>> getResourceFiles();
117+
118+
@JsonRequest
119+
CompletableFuture<List<ConfigurableEntry>> getConfigurableEntries();
120+
93121
@JsonRequest
94122
CompletableFuture<List<String>> getArtifactFiles(TextDocumentIdentifier param);
95123

@@ -105,6 +133,9 @@ public interface ISynapseLanguageService {
105133
@JsonRequest
106134
CompletableFuture<Either<Connections, Map<String, Connections>>> connectorConnections(ConnectorParam param);
107135

136+
@JsonRequest
137+
public CompletableFuture<List<String>> getResourceUsages(ResourceUsagesRequest resourceUsagesRequest);
138+
108139
@JsonRequest
109140
CompletableFuture<SchemaGenResponse> generateSchema(SchemaGenRequest schemaGenRequest);
110141

@@ -126,17 +157,29 @@ public interface ISynapseLanguageService {
126157
@JsonRequest
127158
CompletableFuture<InboundConnectorResponse> getInboundConnectorSchema(InboundConnectorParam param);
128159

160+
@JsonRequest
161+
CompletableFuture<JsonObject> getLocalInboundConnectors();
162+
163+
@JsonRequest
164+
CompletableFuture<JsonObject> getConnectionUISchema(ConnectionUIParam param);
165+
129166
@JsonRequest
130167
CompletableFuture<DependencyTree> dependencyTree(TextDocumentIdentifier param);
131168

132169
@JsonRequest
133170
CompletableFuture<OverviewModel> getOverviewModel();
134171

135172
@JsonRequest
136-
CompletableFuture<Boolean> checkDBDriver(CheckDBDriverRequestParams requestParams);
173+
CompletableFuture<CheckDBDriverResponseParams> checkDBDriver(CheckDBDriverRequestParams requestParams);
137174

138175
@JsonRequest
139-
CompletableFuture<Boolean> addDBDriver(AddDriverRequestParams requestParams);
176+
CompletableFuture<Boolean> addDBDriver(ModifyDriverRequestParams requestParams);
177+
178+
@JsonRequest
179+
CompletableFuture<Boolean> removeDBDriver(ModifyDriverRequestParams requestParams);
180+
181+
@JsonRequest
182+
CompletableFuture<Boolean> modifyDBDriver(ModifyDriverRequestParams requestParams);
140183

141184
@JsonRequest
142185
CompletableFuture<String> generateQueries(QueryGenRequestParams requestParams);
@@ -147,6 +190,30 @@ public interface ISynapseLanguageService {
147190
@JsonRequest
148191
CompletableFuture<DirectoryMapResponse> getProjectExplorerModel(WorkspaceFolder param);
149192

193+
@JsonRequest
194+
CompletableFuture<List<String>> getProjectIntegrationType(WorkspaceFolder param);
195+
196+
@JsonRequest
197+
CompletableFuture<JsonObject> getMediators(MediatorRequest mediatorRequest);
198+
199+
@JsonRequest
200+
CompletableFuture<JsonObject> getMediatorUISchema(UISchemaRequest uiSchemaRequest);
201+
202+
@JsonRequest
203+
CompletableFuture<SynapseConfigResponse> generateSynapseConfig(SynapseConfigRequest synapseConfigRequest);
204+
205+
@JsonRequest
206+
CompletableFuture<JsonObject> getMediatorUISchemaWithValues(MediatorRequest mediatorRequest);
207+
208+
@JsonRequest
209+
CompletableFuture<MediatorTryoutInfo> tryOutMediator(MediatorTryoutRequest request);
210+
211+
@JsonRequest
212+
CompletableFuture<Boolean> shutDownTryoutServer();
213+
214+
@JsonRequest
215+
CompletableFuture<MediatorTryoutInfo> mediatorInputOutputSchema(MediatorTryoutRequest request);
216+
150217
@JsonRequest
151218
CompletableFuture<OverviewPageDetailsResponse> getOverviewPageDetails();
152219

@@ -158,4 +225,22 @@ public interface ISynapseLanguageService {
158225

159226
@JsonRequest
160227
CompletableFuture<String> updateConnectorDependencies();
228+
229+
@JsonRequest
230+
CompletableFuture<TestConnectionResponse> testConnectorConnection(TestConnectionRequest request);
231+
232+
@JsonRequest
233+
CompletableFuture<ICompletionResponse> expressionCompletion(ExpressionParam param);
234+
235+
@JsonRequest
236+
CompletableFuture<SignatureHelp> signatureHelp(ExpressionParam params);
237+
238+
@JsonRequest
239+
CompletableFuture<HelperPanelData> expressionHelperData(ExpressionParam param);
240+
241+
@JsonRequest
242+
CompletableFuture<ConnectorGeneratorResponse> generateConnector(ConnectorGenerateRequest schemaGenRequest);
243+
244+
@JsonRequest
245+
CompletableFuture<ArtifactTypeResponse> getArtifactType(TextDocumentIdentifier artifactIdentifier);
161246
}
Original file line numberDiff line numberDiff line change
@@ -16,9 +16,12 @@
1616
* under the License.
1717
*/
1818

19-
package org.eclipse.lemminx.customservice.synapse.debugger.visitor;
19+
package org.eclipse.lemminx.customservice.synapse;
2020

2121
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.connector.Connector;
22+
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.connector.ai.AIAgent;
23+
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.connector.ai.AIChat;
24+
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.connector.ai.KnowledgeBase;
2225
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.SequenceMediator;
2326
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.advanced.Clone.Clone;
2427
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.advanced.DataServiceCall.DataServiceCall;
@@ -37,11 +40,14 @@
3740
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.core.Respond;
3841
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.core.Send;
3942
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.core.Store;
43+
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.core.ThrowError;
44+
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.core.Variable;
4045
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.core.call.Call;
4146
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.core.callout.Callout;
4247
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.core.validate.Validate;
4348
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.eip.Foreach;
4449
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.eip.Iterate;
50+
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.eip.ScatterGather;
4551
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.eip.aggregate.Aggregate;
4652
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.extension.Bean;
4753
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.extension.Class;
@@ -63,12 +69,12 @@
6369
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.transformation.Datamapper;
6470
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.transformation.FastXSLT;
6571
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.transformation.Jsontransform;
66-
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.transformation.xquery.Xquery;
6772
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.transformation.enrich.Enrich;
6873
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.transformation.fault.Makefault;
6974
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.transformation.payload.PayloadFactory;
7075
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.transformation.rewrite.Rewrite;
7176
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.transformation.smooks.Smooks;
77+
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.transformation.xquery.Xquery;
7278
import org.eclipse.lemminx.customservice.synapse.syntaxTree.pojo.mediator.transformation.xslt.Xslt;
7379

7480
public abstract class AbstractMediatorVisitor {
@@ -152,6 +158,8 @@ public abstract class AbstractMediatorVisitor {
152158
protected abstract void visitIterate(Iterate node);
153159

154160
protected abstract void visitProperty(Property node);
161+
protected abstract void visitVariable(Variable node);
162+
protected abstract void visitScatterGather(ScatterGather node);
155163

156164
protected abstract void visitForeach(Foreach node);
157165

@@ -178,4 +186,12 @@ public abstract class AbstractMediatorVisitor {
178186
protected abstract void visitCallout(Callout node);
179187

180188
protected abstract void visitSequence(SequenceMediator node);
189+
190+
protected abstract void visitThrowError(ThrowError node);
191+
192+
protected abstract void visitAIChat(AIChat node);
193+
194+
protected abstract void visitAIAgent(AIAgent node);
195+
196+
protected abstract void visitAIKnowledgeBase(KnowledgeBase node);
181197
}

0 commit comments

Comments
 (0)