Package net.thevpc.naru.impl.engine

Class NaruSessionImpl

java.lang.Object

net.thevpc.naru.impl.engine.NaruSessionImpl

All Implemented Interfaces:

NaruSession, net.thevpc.nuts.elem.NToElement

public class NaruSessionImpl
extends Object
implements NaruSession, net.thevpc.nuts.elem.NToElement

Constructor Summary

Constructors

Constructor	Description
NaruSessionImpl(NaruAgent agent, net.thevpc.nuts.io.NPath projectDir, NaruInteraction interaction, boolean configureDefaults, NaruSessionListener sessionListener, Predicate<NaruDirective> directiveFilter, Predicate<NaruTool> toolFilter, Predicate<NaruToolTag> tagFilter)

Method Summary

Modifier and Type	Method	Description
void	_reportUsing(net.thevpc.nuts.io.NPath source)
void	addModelAlias(String alias, NaruModelConfig model)
void	addSessionListener(NaruSessionListener listener)
void	addUsageListener(NaruSessionUsageListener listener)
NaruAgent	agent()
NaruSession	copy()
Instant	creationInstant()
void	deliverInput(String line)	Pushes a line of user input into the session.
NaruSessionEventLog	eventLog()
net.thevpc.nuts.util.NOptional<NaruModelConfig>	findModel(String keyOrName)
net.thevpc.nuts.util.NOptional<NaruModelConfig>	findModel(NaruModelConfig keyOrName)
net.thevpc.nuts.util.NOptional<NaruModelConfig>	findModelAlias(String alias)
net.thevpc.nuts.util.NOptional<NaruTask>	findTask(long tid)
long[]	findTaskIdsByParent(long taskId)
void	fireChanged()
void	fireChangedTask(long id)
void	fireModelCallUsage(NaruModelKey model, long promptTokens, long completionTokens, long cacheWriteTokens, long cacheReadTokens, net.thevpc.nuts.time.NDuration duration)	Announces a completed model call to every usage listener.
long	foregroundTaskId()
NaruSession	foregroundTaskId(long taskId)
net.thevpc.nuts.util.NOptional<net.thevpc.nuts.elem.NElement>	getProjectEnv(String key)
int	getSchedulerThreadCount()
long	getSchedulerThrottleDelayMs()
Map<String,Object>	getSessionEnv()
net.thevpc.nuts.util.NOptional<Object>	getSessionEnv(String key)
NaruVisibility	getVisibility()
boolean	hasMoreStatements()
boolean	isRunning()
List<NaruModelKey>	listedModels()
List<net.thevpc.nuts.io.NPath>	listOverridablePaths(net.thevpc.nuts.io.NPath publicPath, net.thevpc.nuts.io.NPath privatePath, Predicate<String> nameFilter)
NaruSession	load(String otherUuid)
net.thevpc.nuts.util.NOptional<NaruModelConfig>	loadModelConfig(String modelName)
void	log(NaruLogMode mode, net.thevpc.nuts.text.NMsg s)
void	logStream(NaruLogMode mode, net.thevpc.nuts.text.NMsg fragment, boolean end)
Map<String,NaruModelConfig>	modelAliases()
Instant	modificationInstant()
String	name()
NaruTask	newTask(NaruTaskSpec taskBuilder)
void	onInputRequested(NaruTask task)	Called by the scheduler when a task becomes BLOCKED_ON_INPUT.
void	onTaskStatusChanged(NaruTask task, NaruTaskStatus oldStatus, NaruTaskStatus newStatus)	Dispatches a task status transition to session listeners.
void	onTerminated(long tid)
net.thevpc.nuts.io.NPath	projectDir()
NaruRegistry	registry()
NaruSession	reload()
void	removeModelAlias(String alias)
void	removeSessionListener(NaruSessionListener listener)
void	removeUsageListener(NaruSessionUsageListener listener)
void	reportProviderRateLimits(NaruProviderRateLimitInfo info)
NaruSession	reset(boolean preserveIdentity)
NaruSession	restoreSnapshot()
Map<NaruModelConfig,List<String>>	reversedModelAliases()
net.thevpc.nuts.util.NOptional<NaruRoutine>	routine(String nameOrPath, NaruTask task, boolean orCreate)
List<NaruResourceInfo>	routines()
NaruTask	run()
NaruTask	run(NaruTaskSpec spec)
Executor	runCallbackExecutor()
NaruSession	save()
void	saveModelConfig(String modelName, NaruModelConfig config)
NaruSession	saveSnapshot()
NaruScheduler	scheduler()
NaruSessionStoreManager	sessionStoreManager()
NaruSession	setListedModels(List<NaruModelKey> models)
NaruSession	setName(String name)
void	setProjectEnv(String key, net.thevpc.nuts.elem.NElement value, NaruVisibility visibility)
NaruSessionImpl	setSchedulerThreadCount(int schedulerThreadCount)
NaruSessionImpl	setSchedulerThrottleDelayMs(long schedulerThrottleDelayMs)
NaruSession	setSessionEnv(String key, Object value)
NaruSession	setVisibility(NaruVisibility visibility)
NaruSession	setWorkingDir(net.thevpc.nuts.io.NPath workingDir)
NaruSession	start()
NaruSession	stop()
String	systemPrompt()
NaruSession	systemPrompt(String systemPrompt)
List<NaruTask>	tasks()
NaruSession	terminate()
NaruSession	throttleDelay(long ms)
net.thevpc.nuts.elem.NElement	toElement()
NaruSession	unsetSessionEnv(String key)
String	uuid()
NaruSession	waitFor()
net.thevpc.nuts.io.NPath	workingDir()

Methods inherited from class java.lang.Object

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

Constructor Details

NaruSessionImpl

public NaruSessionImpl(NaruAgent agent,
 net.thevpc.nuts.io.NPath projectDir,
 NaruInteraction interaction,
 boolean configureDefaults,
 NaruSessionListener sessionListener,
 Predicate<NaruDirective> directiveFilter,
 Predicate<NaruTool> toolFilter,
 Predicate<NaruToolTag> tagFilter)

Method Details

throttleDelay

public NaruSession throttleDelay(long ms)

Specified by:

throttleDelay in interface NaruSession

getSchedulerThreadCount

public int getSchedulerThreadCount()

setSchedulerThreadCount

public NaruSessionImpl setSchedulerThreadCount(int schedulerThreadCount)

getSchedulerThrottleDelayMs

public long getSchedulerThrottleDelayMs()

setSchedulerThrottleDelayMs

public NaruSessionImpl setSchedulerThrottleDelayMs(long schedulerThrottleDelayMs)

scheduler

public NaruScheduler scheduler()

Specified by:

scheduler in interface NaruSession

getVisibility

public NaruVisibility getVisibility()

Specified by:

getVisibility in interface NaruSession

setVisibility

public NaruSession setVisibility(NaruVisibility visibility)

Specified by:

setVisibility in interface NaruSession

unsetSessionEnv

public NaruSession unsetSessionEnv(String key)

Specified by:

unsetSessionEnv in interface NaruSession

tasks

public List<NaruTask> tasks()

Specified by:

tasks in interface NaruSession

newTask

public NaruTask newTask(NaruTaskSpec taskBuilder)

Specified by:

newTask in interface NaruSession

run

public NaruTask run(NaruTaskSpec spec)

Specified by:

run in interface NaruSession

run

public NaruTask run()

Specified by:

run in interface NaruSession

runCallbackExecutor

public Executor runCallbackExecutor()

findTask

public net.thevpc.nuts.util.NOptional<NaruTask> findTask(long tid)

Specified by:

findTask in interface NaruSession

setSessionEnv

public NaruSession setSessionEnv(String key,
 Object value)

Specified by:

setSessionEnv in interface NaruSession

getSessionEnv

public net.thevpc.nuts.util.NOptional<Object> getSessionEnv(String key)

Specified by:

getSessionEnv in interface NaruSession

getProjectEnv

public net.thevpc.nuts.util.NOptional<net.thevpc.nuts.elem.NElement> getProjectEnv(String key)

Specified by:

getProjectEnv in interface NaruSession

setProjectEnv

public void setProjectEnv(String key,
 net.thevpc.nuts.elem.NElement value,
 NaruVisibility visibility)

Specified by:

setProjectEnv in interface NaruSession

name

public String name()

Specified by:

name in interface NaruSession

setName

public NaruSession setName(String name)

Specified by:

setName in interface NaruSession

modelAliases

public Map<String,NaruModelConfig> modelAliases()

Specified by:

modelAliases in interface NaruSession

reversedModelAliases

public Map<NaruModelConfig,List<String>> reversedModelAliases()

Specified by:

reversedModelAliases in interface NaruSession

findModel

public net.thevpc.nuts.util.NOptional<NaruModelConfig> findModel(NaruModelConfig keyOrName)

findModel

public net.thevpc.nuts.util.NOptional<NaruModelConfig> findModel(String keyOrName)

Specified by:

findModel in interface NaruSession

listedModels

public List<NaruModelKey> listedModels()

Specified by:

listedModels in interface NaruSession

setListedModels

public NaruSession setListedModels(List<NaruModelKey> models)

Specified by:

setListedModels in interface NaruSession

removeModelAlias

public void removeModelAlias(String alias)

Specified by:

removeModelAlias in interface NaruSession

addModelAlias

public void addModelAlias(String alias,
 NaruModelConfig model)

Specified by:

addModelAlias in interface NaruSession

findModelAlias

public net.thevpc.nuts.util.NOptional<NaruModelConfig> findModelAlias(String alias)

Specified by:

findModelAlias in interface NaruSession

creationInstant

public Instant creationInstant()

Specified by:

creationInstant in interface NaruSession

modificationInstant

public Instant modificationInstant()

Specified by:

modificationInstant in interface NaruSession

uuid

public String uuid()

Specified by:

uuid in interface NaruSession

fireChanged

public void fireChanged()

copy

public NaruSession copy()

Specified by:

copy in interface NaruSession

reset

public NaruSession reset(boolean preserveIdentity)

Specified by:

reset in interface NaruSession

saveSnapshot

public NaruSession saveSnapshot()

Specified by:

saveSnapshot in interface NaruSession

save

public NaruSession save()

Specified by:

save in interface NaruSession

load

public NaruSession load(String otherUuid)

Specified by:

load in interface NaruSession

reload

public NaruSession reload()

Specified by:

reload in interface NaruSession

restoreSnapshot

public NaruSession restoreSnapshot()

Specified by:

restoreSnapshot in interface NaruSession

toElement

public net.thevpc.nuts.elem.NElement toElement()

Specified by:

toElement in interface NaruSession

Specified by:

toElement in interface net.thevpc.nuts.elem.NToElement

deliverInput

public void deliverInput(String line)

Pushes a line of user input into the session. This is how a headless host answers a question: it hands the text over whenever it arrives, from any thread, and the task that asked resumes.

Specified by:

deliverInput in interface NaruSession

onInputRequested

public void onInputRequested(NaruTask task)

Called by the scheduler when a task becomes BLOCKED_ON_INPUT. The question is handed to the interaction, which decides whether that means blocking a terminal thread or pushing it to a browser.

log

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

Specified by:

log in interface NaruSession

logStream

public void logStream(NaruLogMode mode,
 net.thevpc.nuts.text.NMsg fragment,
 boolean end)

Specified by:

logStream in interface NaruSession

_reportUsing

public void _reportUsing(net.thevpc.nuts.io.NPath source)

listOverridablePaths

public List<net.thevpc.nuts.io.NPath> listOverridablePaths(net.thevpc.nuts.io.NPath publicPath,
 net.thevpc.nuts.io.NPath privatePath,
 Predicate<String> nameFilter)

workingDir

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

Specified by:

workingDir in interface NaruSession

setWorkingDir

public NaruSession setWorkingDir(net.thevpc.nuts.io.NPath workingDir)

Specified by:

setWorkingDir in interface NaruSession

projectDir

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

Specified by:

projectDir in interface NaruSession

terminate

public NaruSession terminate()

Specified by:

terminate in interface NaruSession

hasMoreStatements

public boolean hasMoreStatements()

Specified by:

hasMoreStatements in interface NaruSession

agent

public NaruAgent agent()

Specified by:

agent in interface NaruSession

sessionStoreManager

public NaruSessionStoreManager sessionStoreManager()

Specified by:

sessionStoreManager in interface NaruSession

registry

public NaruRegistry registry()

Specified by:

registry in interface NaruSession

foregroundTaskId

public long foregroundTaskId()

Specified by:

foregroundTaskId in interface NaruSession

foregroundTaskId

public NaruSession foregroundTaskId(long taskId)

Specified by:

foregroundTaskId in interface NaruSession

start

public NaruSession start()

Specified by:

start in interface NaruSession

isRunning

public boolean isRunning()

Specified by:

isRunning in interface NaruSession

stop

public NaruSession stop()

Specified by:

stop in interface NaruSession

addSessionListener

public void addSessionListener(NaruSessionListener listener)

Specified by:

addSessionListener in interface NaruSession

addUsageListener

public void addUsageListener(NaruSessionUsageListener listener)

Specified by:

addUsageListener in interface NaruSession

removeUsageListener

public void removeUsageListener(NaruSessionUsageListener listener)

Specified by:

removeUsageListener in interface NaruSession

fireModelCallUsage

public void fireModelCallUsage(NaruModelKey model,
 long promptTokens,
 long completionTokens,
 long cacheWriteTokens,
 long cacheReadTokens,
 net.thevpc.nuts.time.NDuration duration)

Announces a completed model call to every usage listener.

A listener that throws is skipped rather than allowed to fail the call it is only observing: metering and rate-limit reporting are side channels, and a broken one must not cost the user their answer.

reportProviderRateLimits

public void reportProviderRateLimits(NaruProviderRateLimitInfo info)

Specified by:

reportProviderRateLimits in interface NaruSession

removeSessionListener

public void removeSessionListener(NaruSessionListener listener)

Specified by:

removeSessionListener in interface NaruSession

waitFor

public NaruSession waitFor()

Specified by:

waitFor in interface NaruSession

systemPrompt

public String systemPrompt()

Specified by:

systemPrompt in interface NaruSession

systemPrompt

public NaruSession systemPrompt(String systemPrompt)

Specified by:

systemPrompt in interface NaruSession

onTerminated

public void onTerminated(long tid)

onTaskStatusChanged

public void onTaskStatusChanged(NaruTask task,
 NaruTaskStatus oldStatus,
 NaruTaskStatus newStatus)

Dispatches a task status transition to session listeners.

Note that onTerminated(long) runs first for terminal states and unregisters the task, so a listener must use the task argument rather than findTask(id) — by the time it is called the lookup already returns empty.

eventLog

public NaruSessionEventLog eventLog()

Specified by:

eventLog in interface NaruSession

findTaskIdsByParent

public long[] findTaskIdsByParent(long taskId)

Specified by:

findTaskIdsByParent in interface NaruSession

routines

public List<NaruResourceInfo> routines()

Specified by:

routines in interface NaruSession

getSessionEnv

public Map<String,Object> getSessionEnv()

Specified by:

getSessionEnv in interface NaruSession

loadModelConfig

public net.thevpc.nuts.util.NOptional<NaruModelConfig> loadModelConfig(String modelName)

Specified by:

loadModelConfig in interface NaruSession

saveModelConfig

public void saveModelConfig(String modelName,
 NaruModelConfig config)

Specified by:

saveModelConfig in interface NaruSession

routine

public net.thevpc.nuts.util.NOptional<NaruRoutine> routine(String nameOrPath,
 NaruTask task,
 boolean orCreate)

Specified by:

routine in interface NaruSession

fireChangedTask

public void fireChangedTask(long id)