Package net.thevpc.naru.impl.engine

Class NaruAgentImpl

java.lang.Object

net.thevpc.naru.impl.engine.NaruAgentImpl

All Implemented Interfaces:

NaruAgent

public class NaruAgentImpl
extends Object
implements NaruAgent

The core agent loop.

1. Adds a system prompt + user task to the conversation history.
2. Calls the model.
3. If the model returns tool_calls: dispatches each call via NaruRegistry, appends the results, and loops.
4. If the model returns plain text: that is the final answer.
5. Stops after maxSteps iterations regardless.

This class is pure Java — no Nuts dependency — so it can be extracted into a standalone library later.

Constructor Summary

Constructors

Constructor	Description
NaruAgentImpl()

Method Summary

Modifier and Type	Method	Description
Predicate<NaruDirective>	directiveFilter()
NaruAgent	directiveFilter(Predicate<NaruDirective> directiveFilter)
NaruProjectEnv	env()
StoredStringMap<NaruModelConfig>	getModelAliases()
void	log(NaruLogMode mode, net.thevpc.nuts.text.NMsg message)
NaruAgent	logger(net.thevpc.nuts.log.NLogger logger)
NaruSessionBuilder	newSession()
<T> Future<T>	postAction(net.thevpc.nuts.concurrent.NCallable<T> action)
net.thevpc.nuts.io.NPath	projectDirectory()
NaruAgent	projectDirectory(net.thevpc.nuts.io.NPath projectDirectory)
net.thevpc.nuts.util.NOptional<NaruSession>	session(String id)
List<NaruSession>	sessions()	A snapshot, not a window: a host iterating the result cannot be broken by, or break, a session starting at the same moment.
Predicate<NaruToolTag>	tagFilter()
NaruAgentImpl	tagFilter(Predicate<NaruToolTag> tagFilter)
Predicate<NaruTool>	toolFilter()
NaruAgentImpl	toolFilter(Predicate<NaruTool> toolFilter)

Methods inherited from class java.lang.Object

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

Constructor Details

NaruAgentImpl

public NaruAgentImpl()

Method Details

directiveFilter

public Predicate<NaruDirective> directiveFilter()

Specified by:

directiveFilter in interface NaruAgent

directiveFilter

public NaruAgent directiveFilter(Predicate<NaruDirective> directiveFilter)

Specified by:

directiveFilter in interface NaruAgent

toolFilter

public Predicate<NaruTool> toolFilter()

Specified by:

toolFilter in interface NaruAgent

toolFilter

public NaruAgentImpl toolFilter(Predicate<NaruTool> toolFilter)

Specified by:

toolFilter in interface NaruAgent

tagFilter

public Predicate<NaruToolTag> tagFilter()

Specified by:

tagFilter in interface NaruAgent

tagFilter

public NaruAgentImpl tagFilter(Predicate<NaruToolTag> tagFilter)

Specified by:

tagFilter in interface NaruAgent

postAction

public <T> Future<T> postAction(net.thevpc.nuts.concurrent.NCallable<T> action)

projectDirectory

public net.thevpc.nuts.io.NPath projectDirectory()

Specified by:

projectDirectory in interface NaruAgent

projectDirectory

public NaruAgent projectDirectory(net.thevpc.nuts.io.NPath projectDirectory)

Specified by:

projectDirectory in interface NaruAgent

env

public NaruProjectEnv env()

Specified by:

env in interface NaruAgent

getModelAliases

public StoredStringMap<NaruModelConfig> getModelAliases()

logger

public NaruAgent logger(net.thevpc.nuts.log.NLogger logger)

newSession

public NaruSessionBuilder newSession()

Specified by:

newSession in interface NaruAgent

sessions

public List<NaruSession> sessions()

A snapshot, not a window: a host iterating the result cannot be broken by, or break, a session starting at the same moment.

Specified by:

sessions in interface NaruAgent

session

public net.thevpc.nuts.util.NOptional<NaruSession> session(String id)

Specified by:

session in interface NaruAgent

log

public void log(NaruLogMode mode,
 net.thevpc.nuts.text.NMsg message)

Specified by:

log in interface NaruAgent