Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
28 commits
Select commit Hold shift + click to select a range
35e49fe
Update test creation with additional parameters for `@test:Config`
dan-niles Feb 9, 2026
ab063f9
Update eval creation with eval file path for data provider
dan-niles Feb 11, 2026
9701631
Add support for creating reusable agents
dan-niles Feb 11, 2026
d021f10
Update getTestFunction flow to retrieve test:Config parameters properly
dan-niles Feb 11, 2026
9b2251f
Add support for updating config fields in tests
dan-niles Feb 12, 2026
e531e4d
Move chat agent back to module level
dan-niles Feb 12, 2026
290214b
Update tests
dan-niles Feb 12, 2026
b634fca
Update tests
dan-niles Feb 12, 2026
883a0aa
Add check for empty string when adding groups in tests annotation
dan-niles Feb 12, 2026
a56e63d
Update tests for chat service
dan-niles Feb 12, 2026
ef283c8
Add tests for adding and updating tests with min pass rate and evalse…
dan-niles Feb 12, 2026
d08fc9a
Fix coderabbit suggestions
dan-niles Feb 12, 2026
bc7cfaa
Refactor code
dan-niles Feb 12, 2026
d17c8af
Remove unused imports
dan-niles Feb 13, 2026
562e57c
Fix checkstyle errors
dan-niles Feb 13, 2026
a6e01c1
Fix failing test
dan-niles Feb 13, 2026
a9e5ca9
Fix PR comments suggestions
dan-niles Feb 13, 2026
93fa9ac
Update agent tool search to return input parameters
dan-niles Feb 15, 2026
23b0086
Add caching for agent call builder
dan-niles Feb 15, 2026
c20ed20
Update failing tests
dan-niles Feb 15, 2026
5475b4a
Merge branch 'main' into bi-test-creation-updates
dan-niles Feb 16, 2026
067738b
Update type descriptor field name in AGENT_CALL node
dan-niles Feb 16, 2026
9cd89fd
Fix failing tests
dan-niles Feb 16, 2026
f7d9f64
Fix failing tests
dan-niles Feb 16, 2026
56bb38c
Fix failing tests
dan-niles Feb 16, 2026
9f28d6c
Merge branch 'main' into bi-test-creation-updates
dan-niles Feb 16, 2026
8db2827
Update test function return type to error?
dan-niles Feb 16, 2026
e969364
Update failing tests
dan-niles Feb 16, 2026
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -242,6 +242,50 @@ public static Property copyAsOptionalAdvanced(Property original) {
);
}

/**
* Creates a copy of a property with updated metadata label while preserving all other fields.
*
* @param original the property to copy from
* @param newLabel the new label to set in metadata
* @return the new property with updated metadata label
*/
public static Property createPropertyWithUpdatedLabel(Property original, String newLabel) {
if (original == null) {
throw new IllegalArgumentException("Original property cannot be null");
}
if (original.metadata() == null) {
throw new IllegalArgumentException("Original property metadata cannot be null");
}

Metadata updatedMetadata = new Metadata(
newLabel,
original.metadata().description(),
original.metadata().keywords(),
original.metadata().icon(),
original.metadata().functionKind(),
original.metadata().data()
);

return new Property(
updatedMetadata,
original.types(),
original.value(),
original.oldValue(),
original.placeholder(),
original.optional(),
original.editable(),
original.advanced(),
original.hidden(),
original.modified(),
original.diagnostics(),
original.codedata(),
original.advancedValue(),
original.imports(),
original.defaultValue(),
original.comment()
);
}

/**
* Adds a property to a NodeBuilder by copying all attributes from an existing property with an optional custom
* value.
Expand All @@ -265,26 +309,25 @@ public static void addPropertyFromTemplate(NodeBuilder nodeBuilder, String key,
Object valueToUse = customValue != null ? customValue : property.value();
boolean hidden = isHidden || property.hidden();

nodeBuilder.properties().custom()
.metadata()
.label(property.metadata().label())
.description(property.metadata().description())
.stepOut()
.types(property.types())
.placeholder(property.placeholder())
.value(valueToUse)
.defaultValue(property.defaultValue())
.imports(property.imports() != null ? property.imports().toString() : null)
.optional(property.optional())
.editable(property.editable())
.advanced(property.advanced())
.hidden(hidden)
.modified(property.modified())
.codedata()
.kind(property.codedata() != null ? property.codedata().kind() : "")
.stepOut()
.stepOut()
.addProperty(key);
Property copied = new Property(
property.metadata(),
property.types(),
valueToUse,
property.oldValue(),
property.placeholder(),
property.optional(),
property.editable(),
property.advanced(),
hidden,
property.modified(),
property.diagnostics(),
property.codedata(),
property.advancedValue(),
property.imports(),
property.defaultValue(),
property.comment()
);
nodeBuilder.properties().build().put(key, copied);
}

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@
import io.ballerina.flowmodelgenerator.core.model.Metadata;
import io.ballerina.flowmodelgenerator.core.model.NodeBuilder;
import io.ballerina.flowmodelgenerator.core.model.NodeKind;
import io.ballerina.flowmodelgenerator.core.model.node.AgentBuilder;
import io.ballerina.flowmodelgenerator.core.model.node.AgentRunBuilder;
import io.ballerina.flowmodelgenerator.core.model.node.ChunkerBuilder;
import io.ballerina.flowmodelgenerator.core.model.node.DataLoaderBuilder;
import io.ballerina.flowmodelgenerator.core.model.node.EmbeddingProviderBuilder;
Expand Down Expand Up @@ -73,9 +73,10 @@
import static io.ballerina.modelgenerator.commons.CommonUtils.PERSIST;
import static io.ballerina.modelgenerator.commons.CommonUtils.PERSIST_MODEL_FILE;
import static io.ballerina.modelgenerator.commons.CommonUtils.getPersistModelFilePath;
import static io.ballerina.modelgenerator.commons.CommonUtils.isAgentClass;
import static io.ballerina.modelgenerator.commons.CommonUtils.isAiEmbeddingProvider;
import static io.ballerina.modelgenerator.commons.CommonUtils.isAiModelProvider;
import static io.ballerina.modelgenerator.commons.CommonUtils.isAiKnowledgeBase;
import static io.ballerina.modelgenerator.commons.CommonUtils.isAiModelProvider;
import static io.ballerina.modelgenerator.commons.CommonUtils.isPersistClient;

/**
Expand Down Expand Up @@ -126,6 +127,10 @@ public JsonArray getAvailableNodes(LinePosition position) {
return getAvailableNodes(true, position);
}

public JsonArray getAvailableAgents(LinePosition position) {
return this.getAvailableItemsByCategory(position, Category.Name.AGENT, this::getAgent);
}

public JsonArray getAvailableModelProviders(LinePosition position) {
return this.getAvailableItemsByCategory(position, Category.Name.MODEL_PROVIDER, this::getModelProvider);
}
Expand Down Expand Up @@ -320,16 +325,13 @@ private List<Item> getAiNodes(boolean disableBallerinaAiNodes) {
.items(List.of(knowledgeBase, dataLoaders, recursiveDocumentChunker, chunkers, augmentUserQuery,
vectorStore, embeddingProvider)).build();

AvailableNode agentCall = new AvailableNode(
new Metadata.Builder<>(null).label(AgentBuilder.LABEL)
.description(AgentBuilder.DESCRIPTION).build(),
new Codedata.Builder<>(null).node(NodeKind.AGENT_CALL).
org(disableBallerinaAiNodes ? BALLERINAX : BALLERINA).module(Ai.AI_PACKAGE)
.packageName(Ai.AI_PACKAGE).symbol(Ai.AGENT_RUN_METHOD_NAME)
.object(Ai.AGENT_TYPE_NAME).build(), true);
AvailableNode agent = new AvailableNode(
new Metadata.Builder<>(null).label(AgentRunBuilder.LABEL)
.description(AgentRunBuilder.DESCRIPTION).build(),
new Codedata.Builder<>(null).node(NodeKind.AGENTS).build(), true);

Category agentCategory = new Category.Builder(null).name(Category.Name.AGENT)
.items(List.of(agentCall)).build();
.items(List.of(agent)).build();

return List.of(directLlmCategory, ragCategory, agentCategory);
}
Expand Down Expand Up @@ -416,6 +418,8 @@ private Optional<Category> getCategory(Symbol symbol, Predicate<ClassSymbol> con
FunctionData.Kind kind = methodFunction.kind();
if (kind == FunctionData.Kind.REMOTE) {
nodeBuilder = NodeBuilder.getNodeFromKind(NodeKind.REMOTE_ACTION_CALL);
} else if (isAgentClass(classSymbol) && label.equals(Ai.AGENT_RUN_METHOD_NAME)) {
nodeBuilder = NodeBuilder.getNodeFromKind(NodeKind.AGENT_RUN);
} else if (kind == FunctionData.Kind.FUNCTION && isAiKnowledgeBase(classSymbol)) {
nodeBuilder = NodeBuilder.getNodeFromKind(NodeKind.KNOWLEDGE_BASE_CALL);
} else if (kind == FunctionData.Kind.FUNCTION) {
Expand Down Expand Up @@ -460,6 +464,16 @@ private Optional<Category> getCategory(Symbol symbol, Predicate<ClassSymbol> con
}
}

private Optional<Category> getAgent(Symbol symbol) {
return getCategory(symbol, classSymbol -> {
try {
return isAgentClass(classSymbol);
} catch (Exception e) {
return false;
}
});
}

private Optional<Category> getModelProvider(Symbol symbol) {
return getCategory(symbol, classSymbol -> classSymbol.qualifiers().contains(Qualifier.CLIENT)
&& isAiModelProvider(classSymbol)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,7 @@
import io.ballerina.flowmodelgenerator.core.DiagnosticHandler;
import io.ballerina.flowmodelgenerator.core.model.node.AgentBuilder;
import io.ballerina.flowmodelgenerator.core.model.node.AgentCallBuilder;
import io.ballerina.flowmodelgenerator.core.model.node.AgentRunBuilder;
import io.ballerina.flowmodelgenerator.core.model.node.AssignBuilder;
import io.ballerina.flowmodelgenerator.core.model.node.AutomationBuilder;
import io.ballerina.flowmodelgenerator.core.model.node.BinaryBuilder;
Expand Down Expand Up @@ -161,6 +162,7 @@ public abstract class NodeBuilder implements DiagnosticHandler.DiagnosticCapable
put(NodeKind.WAIT, WaitBuilder::new);
put(NodeKind.AGENT, AgentBuilder::new);
put(NodeKind.AGENT_CALL, AgentCallBuilder::new);
put(NodeKind.AGENT_RUN, AgentRunBuilder::new);
put(NodeKind.CLASS_INIT, ClassInitBuilder::new);
put(NodeKind.MEMORY, MemoryBuilder::new);
put(NodeKind.MEMORY_STORE, MemoryStoreBuilder::new);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -80,7 +80,9 @@ public enum NodeKind {

AGENT,
AGENT_CALL,
AGENT_RUN,
CLASS_INIT,
AGENTS,

MODEL_PROVIDER,
MODEL_PROVIDERS,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,7 @@
import io.ballerina.flowmodelgenerator.core.Constants;
import io.ballerina.flowmodelgenerator.core.model.Codedata;
import io.ballerina.flowmodelgenerator.core.model.FlowNode;
import io.ballerina.flowmodelgenerator.core.model.Metadata;
import io.ballerina.flowmodelgenerator.core.model.NodeBuilder;
import io.ballerina.flowmodelgenerator.core.model.NodeKind;
import io.ballerina.flowmodelgenerator.core.model.Property;
Expand Down Expand Up @@ -66,6 +67,7 @@
public class AgentCallBuilder extends CallBuilder {

private static final String BALLERINA = "ballerina";
private Set<String> cachedVisibleSymbolNames;

// Agent Properties
public static final String AGENT = "AGENT";
Expand Down Expand Up @@ -98,6 +100,9 @@ public class AgentCallBuilder extends CallBuilder {
// Cache for agent templates to avoid expensive repeated creation
private static final Map<String, FlowNode> agentTemplateCache = new ConcurrentHashMap<>();

// Cache for agent call function templates to avoid repeated FunctionDataBuilder.build() calls
private static final Map<String, FlowNode> agentCallFnCache = new ConcurrentHashMap<>();

@Override
protected NodeKind getFunctionNodeKind() {
return NodeKind.AGENT_CALL;
Expand All @@ -118,12 +123,61 @@ public void setConcreteConstData() {
public void setConcreteTemplateData(TemplateContext context) {
setAgentProperties(this, context, null);
setAdditionalAgentProperties(this, null);
super.setConcreteTemplateData(context);

FlowNode callTemplate = getOrCreateCallFunctionTemplate(context);
restoreFromTemplate(callTemplate);

Codedata contextCd = context.codedata();
codedata().lineRange(contextCd.lineRange()).sourceCode(contextCd.sourceCode());

// TODO: This is a temporary solution until we have a proper plan for handling all generic types.
makeInferredTypePropertyOptional();
overrideVariableName(context);
}

private FlowNode getOrCreateCallFunctionTemplate(TemplateContext context) {
Codedata cd = context.codedata();
String cacheKey = String.format("%s|%s|%s|%s|%s",
cd.org(), cd.packageName(), cd.version(), cd.symbol(), cd.object());
return agentCallFnCache.computeIfAbsent(cacheKey, k -> {
AgentCallBuilder temp = new AgentCallBuilder();
temp.defaultModuleName(moduleInfo);
temp.callSuperSetConcreteTemplateData(context);
return temp.build();
});
}

void callSuperSetConcreteTemplateData(TemplateContext context) {
super.setConcreteTemplateData(context);
}

private void restoreFromTemplate(FlowNode template) {
Metadata md = template.metadata();
if (md != null) {
metadata().label(md.label()).description(md.description());
if (md.icon() != null) {
metadata().icon(md.icon());
}
}

Codedata cd = template.codedata();
if (cd != null) {
codedata().node(cd.node()).org(cd.org()).module(cd.module())
.packageName(cd.packageName()).object(cd.object())
.version(cd.version()).symbol(cd.symbol())
.inferredReturnType(cd.inferredReturnType());
}

if (template.properties() != null) {
Map<String, Property> currentProps = properties().build();
template.properties().forEach(currentProps::put);
}

if (template.flags() != 0) {
flag(template.flags());
}
}

private void makeInferredTypePropertyOptional() {
if (formBuilder == null) {
return;
Expand All @@ -133,11 +187,32 @@ private void makeInferredTypePropertyOptional() {
Property prop = entry.getValue();
if (prop.codedata() != null &&
ParameterData.Kind.PARAM_FOR_TYPE_INFER.name().equals(prop.codedata().kind())) {
props.put(entry.getKey(), AiUtils.copyAsOptionalAdvanced(prop));
Property updatedProp = AiUtils.copyAsOptionalAdvanced(prop);
// Update the label to "Type Descriptor" for better clarity
if ("td".equals(entry.getKey()) && updatedProp.metadata() != null) {
updatedProp = AiUtils.createPropertyWithUpdatedLabel(updatedProp, "Type Descriptor");
}
props.put(entry.getKey(), updatedProp);
}
}
}

private Set<String> getVisibleSymbolNames(TemplateContext context) {
if (cachedVisibleSymbolNames == null) {
cachedVisibleSymbolNames = context.getAllVisibleSymbolNames();
}
return cachedVisibleSymbolNames;
}

@Override
protected void setReturnTypeProperties(FunctionData functionData, TemplateContext context,
String label, String doc, boolean hidden) {
properties()
.type(functionData.returnType(), false, functionData.importStatements(), hidden,
Property.RESULT_TYPE_LABEL)
.data(functionData.returnType(), getVisibleSymbolNames(context), label, doc);
}

private void overrideVariableName(TemplateContext context) {
if (formBuilder == null) {
return;
Expand All @@ -147,7 +222,7 @@ private void overrideVariableName(TemplateContext context) {
if (variableProp == null) {
return;
}
String uniqueVarName = NameUtil.generateVariableName("string", context.getAllVisibleSymbolNames());
String uniqueVarName = NameUtil.generateVariableName("string", getVisibleSymbolNames(context));
props.put(Property.VARIABLE_KEY, AiUtils.createUpdatedProperty(variableProp, uniqueVarName));
}

Expand Down
Loading
Loading