Module agentforge4j.config.loader

Package com.agentforge4j.config.loader.workflow

Class BaseWorkflowBundleLoader

java.lang.Object

com.agentforge4j.config.loader.workflow.BaseWorkflowBundleLoader

Direct Known Subclasses:

ClasspathWorkflowLoader, FileSystemWorkflowLoader

public abstract class BaseWorkflowBundleLoader
extends Object

Loads workflow definitions from a backing source.

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String	AGENTS_DIR
protected static final String	ARTIFACT_SUFFIX
protected static final String	BLUEPRINT_SUFFIX
protected static final String	SCHEMA_VERSION_FIELD
protected static final String	STEP_PROMPT_SUFFIX
protected static final String	WORKFLOW_DEFINITION_FILE
protected static final String	WORKFLOW_DIR_SUFFIX

Constructor Summary

Constructors

Constructor	Description
BaseWorkflowBundleLoader()

Method Summary

Modifier and Type	Method	Description
protected abstract List<String>	getWorkflowIdList(WorkflowBundleLoadContext context)
protected abstract Map<String,AgentDefinition>	loadBundledAgentsFromBundle(WorkflowBundleLoadContext context, String workflowId, List<String> bundleFiles)
protected abstract <T> T	loadItem(WorkflowBundleLoadContext context, String path, String workflowId, String derivedId, String type, Class<T> typeClass)
protected abstract String	loadRawContent(WorkflowBundleLoadContext context, String classpathPath, String workflowId)
protected WorkflowDirectoryLoad	loadWorkflows(WorkflowBundleLoadContext context)
WorkflowDirectoryLoad	loadWorkflows(Path root)
protected abstract void	log(System.Logger.Level level, String message, Object... args)
protected WorkflowDefinition	readWorkflow(WorkflowBundleLoadContext context, String workflowId, Map<String,AgentDefinition> bundledAgents)
protected abstract List<String>	retrieveFilesFromIndex(WorkflowBundleLoadContext context, String workflowId)
protected abstract WorkflowDefinition	retrieveWorkflowDefinition(WorkflowBundleLoadContext context, String workflowId, Map<String,AgentDefinition> bundledAgents)
protected final WorkflowDefinition	toWorkflowDefinition(com.fasterxml.jackson.databind.JsonNode document, String source)	Converts a parsed workflow document tree into a WorkflowDefinition, enforcing the wire-format version envelope first.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

WORKFLOW_DEFINITION_FILE

protected static final String WORKFLOW_DEFINITION_FILE

See Also:

• Constant Field Values

SCHEMA_VERSION_FIELD

protected static final String SCHEMA_VERSION_FIELD

See Also:

• Constant Field Values

WORKFLOW_DIR_SUFFIX

protected static final String WORKFLOW_DIR_SUFFIX

See Also:

• Constant Field Values

BLUEPRINT_SUFFIX

protected static final String BLUEPRINT_SUFFIX

See Also:

• Constant Field Values

ARTIFACT_SUFFIX

protected static final String ARTIFACT_SUFFIX

See Also:

• Constant Field Values

STEP_PROMPT_SUFFIX

protected static final String STEP_PROMPT_SUFFIX

See Also:

• Constant Field Values

AGENTS_DIR

protected static final String AGENTS_DIR

See Also:

• Constant Field Values

Constructor Details

BaseWorkflowBundleLoader

public BaseWorkflowBundleLoader()

Method Details

log

protected abstract void log(System.Logger.Level level,
 String message,
 Object... args)

getWorkflowIdList

protected abstract List<String> getWorkflowIdList(WorkflowBundleLoadContext context)

retrieveWorkflowDefinition

protected abstract WorkflowDefinition retrieveWorkflowDefinition(WorkflowBundleLoadContext context,
 String workflowId,
 Map<String,AgentDefinition> bundledAgents)

retrieveFilesFromIndex

protected abstract List<String> retrieveFilesFromIndex(WorkflowBundleLoadContext context,
 String workflowId)

loadItem

protected abstract <T> T loadItem(WorkflowBundleLoadContext context,
 String path,
 String workflowId,
 String derivedId,
 String type,
 Class<T> typeClass)

loadRawContent

protected abstract String loadRawContent(WorkflowBundleLoadContext context,
 String classpathPath,
 String workflowId)

loadBundledAgentsFromBundle

protected abstract Map<String,AgentDefinition> loadBundledAgentsFromBundle(WorkflowBundleLoadContext context,
 String workflowId,
 List<String> bundleFiles)

loadWorkflows

public WorkflowDirectoryLoad loadWorkflows(Path root)

loadWorkflows

protected WorkflowDirectoryLoad loadWorkflows(WorkflowBundleLoadContext context)

readWorkflow

protected WorkflowDefinition readWorkflow(WorkflowBundleLoadContext context,
 String workflowId,
 Map<String,AgentDefinition> bundledAgents)

toWorkflowDefinition

protected final WorkflowDefinition toWorkflowDefinition(com.fasterxml.jackson.databind.JsonNode document,
 String source)
                                                 throws com.fasterxml.jackson.core.JsonProcessingException

Converts a parsed workflow document tree into a WorkflowDefinition, enforcing the wire-format version envelope first.

Every workflow.json document must declare the required schemaVersion field matching WorkflowSchemaVersion.SUPPORTED_WORKFLOW_SCHEMA_VERSION; a missing, non-integer, or unsupported version fails closed with an error naming both the declared and the supported version. The field is a wire-envelope concern consumed here — it is stripped before Jackson mapping, so the domain model never carries it and strict mappers never see it as an unknown property.

Parameters:

document - parsed workflow document tree

source - human-readable document source (file path or URL) for error messages

Returns:

the mapped workflow definition

Throws:

com.fasterxml.jackson.core.JsonProcessingException - if the document tree cannot be mapped to the model