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, NaruMeteringService meteringService, boolean configureDefaults, NaruSessionListener sessionListener)

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)
NaruAgent	agent()
NaruSession	copy()
Instant	creationInstant()
void	deliverInput(String line)
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)
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<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)
void	log(NaruLogMode mode, net.thevpc.nuts.text.NMsg s)
NaruMeteringService	meteringService()
Map<String,NaruModelConfig>	modelAliases()
Instant	modificationInstant()
String	name()
NaruTask	newTask(NaruTaskSpec taskBuilder)
void	onInputRequested(NaruTask task)
void	onTerminated(long tid)
net.thevpc.nuts.io.NPath	projectDir()
NaruRegistry	registry()
NaruSession	reload()
void	removeModelAlias(String alias)
void	removeSessionListener(NaruSessionListener listener)
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()
NaruSession	save()
NaruSession	saveSnapshot()
NaruScheduler	scheduler()
NaruSessionManager	sessionManager()
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)
NaruSkillManager	skillManager()
void	start()
void	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()
void	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,
 NaruMeteringService meteringService,
 boolean configureDefaults,
 NaruSessionListener sessionListener)

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

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

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)

onInputRequested

public void onInputRequested(NaruTask task)

log

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

Specified by:

log 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

skillManager

public NaruSkillManager skillManager()

Specified by:

skillManager 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

sessionManager

public NaruSessionManager sessionManager()

Specified by:

sessionManager in interface NaruSession

registry

public NaruRegistry registry()

Specified by:

registry in interface NaruSession

meteringService

public NaruMeteringService meteringService()

Specified by:

meteringService 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 void start()

Specified by:

start in interface NaruSession

isRunning

public boolean isRunning()

Specified by:

isRunning in interface NaruSession

stop

public void stop()

Specified by:

stop in interface NaruSession

addSessionListener

public void addSessionListener(NaruSessionListener listener)

Specified by:

addSessionListener in interface NaruSession

removeSessionListener

public void removeSessionListener(NaruSessionListener listener)

Specified by:

removeSessionListener in interface NaruSession

waitFor

public void 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)

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

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)