Package net.thevpc.naru.impl.engine.scheduler

Class NaruTaskImpl

java.lang.Object

net.thevpc.naru.impl.engine.scheduler.NaruTaskImpl

All Implemented Interfaces:

NaruTaskSchedulerView, NaruTask, net.thevpc.nuts.elem.NToElement

public class NaruTaskImpl
extends Object
implements NaruTask, NaruTaskSchedulerView

Constructor Summary

Constructors

Constructor	Description
NaruTaskImpl(long tid, long parentId, NaruSession session)
NaruTaskImpl(net.thevpc.nuts.elem.NElement element, NaruSession session)

Method Summary

Modifier and Type	Method	Description
void	_prependInitHooks()
NaruTaskImpl	_setInputBuffer(String inputBuffer)
NaruTaskImpl	_setInputMode(NAruInputMode inputMode)
NaruTaskImpl	_setLastResult(NaruMessage lastResult)
NaruTaskImpl	_setMode(NaruPromptMode mode)
NaruTaskImpl	_setModel(NaruModelConfig model)
NaruTaskImpl	_setProjectDir(net.thevpc.nuts.io.NPath projectDir)
NaruTaskImpl	_setReturnResult(Object returnResult)
NaruTaskImpl	_setSkills(Set<String> skills)
NaruTaskImpl	_setWorkingDir(net.thevpc.nuts.io.NPath workingDir)
NaruTask	acquireStepPermit()
NaruTask	addAwaitReceived(NaruEvent event)
boolean	addHistory(String m)
void	addHistory(NaruMessage assistantMsg)
NaruTask	addStatement(NaruStatement any)
NaruTask	addStatements(NaruStatement... any)
void	appendRoutineLine(int increment, String name)
NaruEventFilter	awaitFilter()
NaruTaskImpl	awaitFilter(NaruEventFilter eventFilter)
List<NaruEvent>	awaitReceived()
NaruTask	bg()
void	call(String cmdline)
NaruResponse	chat(NaruModelConfig modelKey, NaruModelRequest request)
int	clearHistory()
String	consumeInput()
NaruModelRequest	context(NaruSource... sources)
Instant	creationTime()
NaruTask	defaultAdvance(NaruStatement stmt)
void	deliverInput(String line)
void	doing(NaruStatement doing)
net.thevpc.nuts.util.NOptional<NaruRoutine>	editRoutine()
String	editRoutineName()
Object	evalExpression(String condition)
Map<String,NaruEventSubscription>	eventSubscriptions()
String	expandString(String condition)
net.thevpc.nuts.expr.NExprContextBuilder	expressionBuilder()
NaruTask	fg()
protected void	fireChanged()
NaruTask	fireEvent(String eventType, Map<String,Object> args, NaruEventTarget target, NaruRetentionPolicy retention)
NaruTaskFrame	frame()
String	getExtraContext()
NaruMessage	getLastResult()
Object	getReturnResult()
Map<String,Object>	getTaskEnv()
net.thevpc.nuts.util.NOptional<Object>	getTaskEnv(String key, boolean inherited)
boolean	hasMoreStatements()
NaruTask	held(boolean held)
NaruTask	hold()
long	id()
NaruTaskInbox	inbox()
String	inputBuffer()
NaruTask	inputBuffer(String buffer)
NAruInputMode	inputMode()
NaruTask	inputMode(NAruInputMode inputMode)
void	invokeDirective(String line)
void	invokeRoutine(String routineName)
boolean	isFg()
boolean	isHeld()
boolean	isTrace()
NaruTask	kill()
NaruTask	load(net.thevpc.nuts.elem.NElement element)
List<NaruStatement>	loadDirectivesFile(net.thevpc.nuts.io.NPath path)
NaruTask	loadFiles(net.thevpc.nuts.io.NPath... any)
NaruTask	loadLines(String... any)
boolean	loadSkill(String name)
void	log(NaruLogMode mode, net.thevpc.nuts.text.NMsg s)
NaruModelConfig	model()
String	name()
NaruTask	name(String newName)
net.thevpc.nuts.util.NOptional<NaruStatement>	nextStatement()
net.thevpc.nuts.util.NOptional<NaruTask>	parent()
long	parentId()
net.thevpc.nuts.util.NOptional<List<NaruStatement>>	parseFile(net.thevpc.nuts.io.NPath path)
net.thevpc.nuts.util.NOptional<NaruStatement>	parseStatement(String line)
int	pc()
NaruTask	pc(int nextPc)
int[]	pctrace()
NaruTaskFrame	peekFrame()
net.thevpc.nuts.util.NOptional<NaruStatement>	peekStatement()
net.thevpc.nuts.text.NMsg	pendingPrompt()
NaruTask	popFrame()
NaruTask	prependStatement(NaruStatement any)
NaruTask	prependStatements(NaruStatement... any)
net.thevpc.nuts.io.NPath	projectDir()
NaruPromptMode	promptMode()
NaruTask	promptMode(NaruPromptMode newMode)
NaruTaskFrame	pushFrame(String routine, boolean inheritVars)
NaruTask	pushStatementModelCall(String prompt)
NaruTask	releaseStepPermit()
boolean	removeHistoryAt(int index)
void	requestInput(net.thevpc.nuts.text.NMsg prompt)
void	reset()
net.thevpc.nuts.io.NPath	resolve(String path)
net.thevpc.nuts.util.NOptional<Object>	resolveVariable(String key)
NaruSchedulerMode	schedulerMode()
NaruTask	schedulerMode(NaruSchedulerMode mode)
NaruSession	session()
NaruTask	setExtraContext(String extraContext)
void	setLastResult(NaruMessage lastResult)
NaruTask	setModel(NaruModelConfig model)
NaruTask	setProjectDir(net.thevpc.nuts.io.NPath projectDir)
void	setReturnResult(Object returnResult)
void	setRoutineLine(int index, String name)
NaruTask	setTaskEnv(String key, Object value)
void	setVariable(String key, Object value)
NaruTask	setWorkingDir(net.thevpc.nuts.io.NPath workingDir)
Set<String>	skillNames()
List<NaruResourceInfo>	skills()
NaruTask	sleep(net.thevpc.nuts.time.NDuration duration)
List<NaruTaskStackFrame>	stackframes()
List<NaruTaskStackItem>	stacktrace()
NaruTaskStatus	status()
void	status(NaruTaskStatus newStatus)
NaruTask	subscribe(String eventType, NaruEventSubscription subscription)
NaruTaskMode	taskMode()
NaruTask	taskMode(NaruTaskMode newMode)
void	throwError(net.thevpc.nuts.text.NMsg nMsg)
void	tick()
net.thevpc.nuts.elem.NElement	toElement()
int	trimHistory(int count)
NaruTask	unhold()
boolean	unloadSkill(String name)
NaruTask	unsetTaskEnv(String key)
net.thevpc.nuts.util.NOptional<NaruRoutine>	useRoutine(String name)
net.thevpc.nuts.expr.NExprVarResolver	varResolver()
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

NaruTaskImpl

public NaruTaskImpl(net.thevpc.nuts.elem.NElement element,
 NaruSession session)

NaruTaskImpl

public NaruTaskImpl(long tid,
 long parentId,
 NaruSession session)

Method Details

inbox

public NaruTaskInbox inbox()

Specified by:

inbox in interface NaruTask

taskMode

public NaruTaskMode taskMode()

Specified by:

taskMode in interface NaruTask

taskMode

public NaruTask taskMode(NaruTaskMode newMode)

Specified by:

taskMode in interface NaruTask

creationTime

public Instant creationTime()

Specified by:

creationTime in interface NaruTask

name

public String name()

Specified by:

name in interface NaruTask

name

public NaruTask name(String newName)

Specified by:

name in interface NaruTask

requestInput

public void requestInput(net.thevpc.nuts.text.NMsg prompt)

Specified by:

requestInput in interface NaruTask

consumeInput

public String consumeInput()

Specified by:

consumeInput in interface NaruTask

deliverInput

public void deliverInput(String line)

Specified by:

deliverInput in interface NaruTaskSchedulerView

parentId

public long parentId()

Specified by:

parentId in interface NaruTask

kill

public NaruTask kill()

Specified by:

kill in interface NaruTask

parent

public net.thevpc.nuts.util.NOptional<NaruTask> parent()

Specified by:

parent in interface NaruTask

schedulerMode

public NaruSchedulerMode schedulerMode()

Specified by:

schedulerMode in interface NaruTask

schedulerMode

public NaruTask schedulerMode(NaruSchedulerMode mode)

Specified by:

schedulerMode in interface NaruTask

stacktrace

public List<NaruTaskStackItem> stacktrace()

Specified by:

stacktrace in interface NaruTask

stackframes

public List<NaruTaskStackFrame> stackframes()

Specified by:

stackframes in interface NaruTask

defaultAdvance

public NaruTask defaultAdvance(NaruStatement stmt)

Specified by:

defaultAdvance in interface NaruTask

awaitReceived

public List<NaruEvent> awaitReceived()

Specified by:

awaitReceived in interface NaruTask

isHeld

public boolean isHeld()

Specified by:

isHeld in interface NaruTask

held

public NaruTask held(boolean held)

hold

public NaruTask hold()

Specified by:

hold in interface NaruTask

unhold

public NaruTask unhold()

Specified by:

unhold in interface NaruTask

eventSubscriptions

public Map<String,NaruEventSubscription> eventSubscriptions()

Specified by:

eventSubscriptions in interface NaruTask

awaitFilter

public NaruEventFilter awaitFilter()

Specified by:

awaitFilter in interface NaruTask

awaitFilter

public NaruTaskImpl awaitFilter(NaruEventFilter eventFilter)

Specified by:

awaitFilter in interface NaruTask

status

public NaruTaskStatus status()

Specified by:

status in interface NaruTask

fg

public NaruTask fg()

Specified by:

fg in interface NaruTask

bg

public NaruTask bg()

Specified by:

bg in interface NaruTask

doing

public void doing(NaruStatement doing)

Specified by:

doing in interface NaruTaskSchedulerView

status

public void status(NaruTaskStatus newStatus)

Specified by:

status in interface NaruTaskSchedulerView

reset

public void reset()

Specified by:

reset in interface NaruTask

toElement

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

Specified by:

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

load

public NaruTask load(net.thevpc.nuts.elem.NElement element)

Specified by:

load in interface NaruTask

id

public long id()

Specified by:

id in interface NaruTask

isFg

public boolean isFg()

Specified by:

isFg in interface NaruTask

projectDir

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

Specified by:

projectDir in interface NaruTask

workingDir

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

Specified by:

workingDir in interface NaruTask

_setSkills

public NaruTaskImpl _setSkills(Set<String> skills)

_setInputMode

public NaruTaskImpl _setInputMode(NAruInputMode inputMode)

_setWorkingDir

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

_setProjectDir

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

_setMode

public NaruTaskImpl _setMode(NaruPromptMode mode)

_setInputBuffer

public NaruTaskImpl _setInputBuffer(String inputBuffer)

_setLastResult

public NaruTaskImpl _setLastResult(NaruMessage lastResult)

_setReturnResult

public NaruTaskImpl _setReturnResult(Object returnResult)

_setModel

public NaruTaskImpl _setModel(NaruModelConfig model)

setProjectDir

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

Specified by:

setProjectDir in interface NaruTask

inputMode

public NAruInputMode inputMode()

Specified by:

inputMode in interface NaruTask

inputMode

public NaruTask inputMode(NAruInputMode inputMode)

Specified by:

inputMode in interface NaruTask

fireChanged

protected void fireChanged()

session

public NaruSession session()

Specified by:

session in interface NaruTask

promptMode

public NaruPromptMode promptMode()

Specified by:

promptMode in interface NaruTask

promptMode

public NaruTask promptMode(NaruPromptMode newMode)

Specified by:

promptMode in interface NaruTask

getExtraContext

public String getExtraContext()

Specified by:

getExtraContext in interface NaruTask

setExtraContext

public NaruTask setExtraContext(String extraContext)

Specified by:

setExtraContext in interface NaruTask

log

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

Specified by:

log in interface NaruTask

context

public NaruModelRequest context(NaruSource... sources)

Specified by:

context in interface NaruTask

removeHistoryAt

public boolean removeHistoryAt(int index)

Specified by:

removeHistoryAt in interface NaruTask

pc

public int pc()

Specified by:

pc in interface NaruTask

pc

public NaruTask pc(int nextPc)

Specified by:

pc in interface NaruTask

clearHistory

public int clearHistory()

Specified by:

clearHistory in interface NaruTask

model

public NaruModelConfig model()

Specified by:

model in interface NaruTask

setModel

public NaruTask setModel(NaruModelConfig model)

Specified by:

setModel in interface NaruTask

trimHistory

public int trimHistory(int count)

Specified by:

trimHistory in interface NaruTask

hasMoreStatements

public boolean hasMoreStatements()

Specified by:

hasMoreStatements in interface NaruTask

addStatement

public NaruTask addStatement(NaruStatement any)

Specified by:

addStatement in interface NaruTask

prependStatement

public NaruTask prependStatement(NaruStatement any)

Specified by:

prependStatement in interface NaruTask

prependStatements

public NaruTask prependStatements(NaruStatement... any)

Specified by:

prependStatements in interface NaruTask

loadFiles

public NaruTask loadFiles(net.thevpc.nuts.io.NPath... any)

Specified by:

loadFiles in interface NaruTask

loadLines

public NaruTask loadLines(String... any)

Specified by:

loadLines in interface NaruTask

addStatements

public NaruTask addStatements(NaruStatement... any)

Specified by:

addStatements in interface NaruTask

throwError

public void throwError(net.thevpc.nuts.text.NMsg nMsg)

Specified by:

throwError in interface NaruTask

inputBuffer

public String inputBuffer()

Specified by:

inputBuffer in interface NaruTask

inputBuffer

public NaruTask inputBuffer(String buffer)

Specified by:

inputBuffer in interface NaruTask

addHistory

public boolean addHistory(String m)

Specified by:

addHistory in interface NaruTask

addHistory

public void addHistory(NaruMessage assistantMsg)

Specified by:

addHistory in interface NaruTask

setLastResult

public void setLastResult(NaruMessage lastResult)

Specified by:

setLastResult in interface NaruTask

setReturnResult

public void setReturnResult(Object returnResult)

Specified by:

setReturnResult in interface NaruTask

getReturnResult

public Object getReturnResult()

Specified by:

getReturnResult in interface NaruTask

getLastResult

public NaruMessage getLastResult()

Specified by:

getLastResult in interface NaruTask

loadSkill

public boolean loadSkill(String name)

Specified by:

loadSkill in interface NaruTask

unloadSkill

public boolean unloadSkill(String name)

Specified by:

unloadSkill in interface NaruTask

skillNames

public Set<String> skillNames()

Specified by:

skillNames in interface NaruTask

skills

public List<NaruResourceInfo> skills()

Specified by:

skills in interface NaruTask

tick

public void tick()

Specified by:

tick in interface NaruTask

isTrace

public boolean isTrace()

invokeDirective

public void invokeDirective(String line)

Specified by:

invokeDirective in interface NaruTask

invokeRoutine

public void invokeRoutine(String routineName)

Specified by:

invokeRoutine in interface NaruTask

nextStatement

public net.thevpc.nuts.util.NOptional<NaruStatement> nextStatement()

Specified by:

nextStatement in interface NaruTask

peekStatement

public net.thevpc.nuts.util.NOptional<NaruStatement> peekStatement()

Specified by:

peekStatement in interface NaruTask

peekFrame

public NaruTaskFrame peekFrame()

Specified by:

peekFrame in interface NaruTask

popFrame

public NaruTask popFrame()

Specified by:

popFrame in interface NaruTask

pushFrame

public NaruTaskFrame pushFrame(String routine,
 boolean inheritVars)

Specified by:

pushFrame in interface NaruTask

frame

public NaruTaskFrame frame()

Specified by:

frame in interface NaruTask

pctrace

public int[] pctrace()

Specified by:

pctrace in interface NaruTask

_prependInitHooks

public void _prependInitHooks()

setVariable

public void setVariable(String key,
 Object value)

unsetTaskEnv

public NaruTask unsetTaskEnv(String key)

Specified by:

unsetTaskEnv in interface NaruTask

setTaskEnv

public NaruTask setTaskEnv(String key,
 Object value)

Specified by:

setTaskEnv in interface NaruTask

getTaskEnv

public net.thevpc.nuts.util.NOptional<Object> getTaskEnv(String key,
 boolean inherited)

Specified by:

getTaskEnv in interface NaruTask

resolveVariable

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

Specified by:

resolveVariable in interface NaruTask

pushStatementModelCall

public NaruTask pushStatementModelCall(String prompt)

Specified by:

pushStatementModelCall in interface NaruTask

varResolver

public net.thevpc.nuts.expr.NExprVarResolver varResolver()

Specified by:

varResolver in interface NaruTask

expressionBuilder

public net.thevpc.nuts.expr.NExprContextBuilder expressionBuilder()

Specified by:

expressionBuilder in interface NaruTask

evalExpression

public Object evalExpression(String condition)

Specified by:

evalExpression in interface NaruTask

expandString

public String expandString(String condition)

Specified by:

expandString in interface NaruTask

parseFile

public net.thevpc.nuts.util.NOptional<List<NaruStatement>> parseFile(net.thevpc.nuts.io.NPath path)

Specified by:

parseFile in interface NaruTask

parseStatement

public net.thevpc.nuts.util.NOptional<NaruStatement> parseStatement(String line)

Specified by:

parseStatement in interface NaruTask

resolve

public net.thevpc.nuts.io.NPath resolve(String path)

Specified by:

resolve in interface NaruTask

chat

public NaruResponse chat(NaruModelConfig modelKey,
 NaruModelRequest request)

Specified by:

chat in interface NaruTask

loadDirectivesFile

public List<NaruStatement> loadDirectivesFile(net.thevpc.nuts.io.NPath path)

setWorkingDir

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

Specified by:

setWorkingDir in interface NaruTask

releaseStepPermit

public NaruTask releaseStepPermit()

Specified by:

releaseStepPermit in interface NaruTask

acquireStepPermit

public NaruTask acquireStepPermit()

Specified by:

acquireStepPermit in interface NaruTask

pendingPrompt

public net.thevpc.nuts.text.NMsg pendingPrompt()

Specified by:

pendingPrompt in interface NaruTaskSchedulerView

fireEvent

public NaruTask fireEvent(String eventType,
 Map<String,Object> args,
 NaruEventTarget target,
 NaruRetentionPolicy retention)

Specified by:

fireEvent in interface NaruTask

sleep

public NaruTask sleep(net.thevpc.nuts.time.NDuration duration)

Specified by:

sleep in interface NaruTask

addAwaitReceived

public NaruTask addAwaitReceived(NaruEvent event)

Specified by:

addAwaitReceived in interface NaruTask

subscribe

public NaruTask subscribe(String eventType,
 NaruEventSubscription subscription)

Specified by:

subscribe in interface NaruTask

editRoutine

public net.thevpc.nuts.util.NOptional<NaruRoutine> editRoutine()

Specified by:

editRoutine in interface NaruTask

editRoutineName

public String editRoutineName()

Specified by:

editRoutineName in interface NaruTask

useRoutine

public net.thevpc.nuts.util.NOptional<NaruRoutine> useRoutine(String name)

Specified by:

useRoutine in interface NaruTask

setRoutineLine

public void setRoutineLine(int index,
 String name)

Specified by:

setRoutineLine in interface NaruTask

appendRoutineLine

public void appendRoutineLine(int increment,
 String name)

Specified by:

appendRoutineLine in interface NaruTask

getTaskEnv

public Map<String,Object> getTaskEnv()

Specified by:

getTaskEnv in interface NaruTask

call

public void call(String cmdline)

Specified by:

call in interface NaruTask