luvcraft/agent/tests/opening.lisp
in-package#:luvcraft.agent.tests
defclassscripted-opening-mixin
opening-started:initform
sb-thread:make-semaphore:count0
:readeropening-startedopening-finish:initform
sb-thread:make-semaphore:count0
:readeropening-finishturn-finished:initform
sb-thread:make-semaphore:count0
:readerscripted-turn-finishedscript-lock:initform
sb-thread:make-mutex:name"agent opening test"
:readerscripted-opening-lockopening-count:initform0:accessoropening-count
close-count:initform0:accessorclose-count
opened-thread-name:initformnil:accessoropened-thread-name
opened-candidate:initformnil:accessoropened-candidate
received-prompts:initform':accessorreceived-prompts
opening-failure-p:initarg:opening-failure-p:initformnil:readeropening-failure-p
deftestagent-hud-respects-the-global-top-status-inset
let*
session
make-instance'luvcraft:luvcraft-session
status
setf
luvcraft:luvcraft-session-overlayssession
liststatus
ok
defunmake-opening-test-presence
class&restinitargs
defunscripted-agent-response
make-instance'openai:agent-response:text"done":reasoning"":id"test":usagenil
defunmake-scripted-world-agent
presence
make-instance'agent:world-agent:applicationpresence:model"test":socketnil:turn-function
lambda
:close-functionproviderprompt
declare
ignoreprovider
sb-thread:with-mutex
scripted-opening-lockpresence
pushprompt
received-promptspresence
sb-thread:signal-semaphore
scripted-turn-finishedpresence
lambda
:observer-failure-functionprovider
declare
ignoreprovider
sb-thread:with-mutex
scripted-opening-lockpresence
incf
close-countpresence
lambda
failure
declare
ignorefailure
defunperform-scripted-opening
presence
sb-thread:with-mutex
scripted-opening-lockpresence
incf
opening-countpresence
setf
opened-thread-namepresence
sb-thread:thread-namesb-thread:*current-thread*
sb-thread:signal-semaphore
opening-startedpresence
sb-thread:wait-on-semaphore
opening-finishpresence
when
opening-failure-ppresence
error"scripted provider opening failure"
defmethodagent::open-embodied-agent-agent
presenceopening-test-gnome
perform-scripted-openingpresence
defmethodagent::open-embodied-agent-agent
presenceopening-test-cat
perform-scripted-openingpresence
defunjoin-opening-thread
presencethread
declare
ignorepresence
whenthread
sb-thread:join-threadthread:default:timeout:timeout1.0
defunjoin-agent-turns
provider
dolist
turn
agent:world-agent-turnsprovider
deftestfirst-contact-is-one-named-opening-and-never-blocks-the-canvas
dolist
let
presence
unwind-protect
let*
before
get-internal-real-time
answer
ok
eqpresenceanswer
ok
sb-thread:wait-on-semaphore
opening-startedpresence
:timeout1.0let
worker
agent::embodied-agent-agent-opening-threadpresence
ok
search"agent opening"
opened-thread-namepresence
:test#'char-equalok
ok
ok
sb-thread:signal-semaphore
opening-finishpresence
ok
not
eq:timeout
ok
sb-thread:wait-on-semaphore
scripted-turn-finishedpresence
:timeout1.0ok
sb-thread:wait-on-semaphore
scripted-turn-finishedpresence
:timeout1.0let
provider
agent:gnome-agentpresence
ok
join-agent-turnsprovider
ok
equal'
"first""second"
nreverse
received-promptspresence
sb-thread:signal-semaphore
opening-finishpresence
let
provider
agent:gnome-agentpresence
whenprovider
deftestopening-failure-is-published-only-through-the-canvas-mailbox
let
presence
unwind-protect
progn
ok
ok
sb-thread:wait-on-semaphore
opening-startedpresence
:timeout1.0let
worker
agent::embodied-agent-agent-opening-threadpresence
sb-thread:signal-semaphore
opening-finishpresence
ok
not
eq:timeout
multiple-value-bind
notereceived-p
sb-concurrency:receive-message
agent::gnome-notespresence
:timeout1.0okreceived-p
ok
eq:agent-failed
firstnote
ok
ok
null
"the provider worker never mutates canvas presentation"agent::gnome-saidpresence
deftestrelease-during-opening-detaches-now-and-closes-the-late-candidate
let
ok
ok
sb-thread:wait-on-semaphore
opening-startedpresence
:timeout1.0let
worker
agent::embodied-agent-agent-opening-threadpresence
ok
ok
null
agent:gnome-agentpresence
ok
null
sb-thread:signal-semaphore
opening-finishpresence
ok
not
eq:timeout
ok
ok
ok
ok
eq:released
luv.application-agent:application-agent-state
opened-candidatepresence
multiple-value-bind
notereceived-p
sb-concurrency:receive-message-no-hang
agent::gnome-notespresence
declare
ignorenote
ngreceived-p"teardown suppresses stale opening failures"
defclass gnome
A small SDF-rendered garden gnome carrying a WORLD-AGENT.
defclass cat
A sitting SDF-rendered cat carrying the shared embodied WORLD-AGENT surface.
define-arithmetic-operator =
Test whether two compatible scalars are equal.
defun agent-hud-top-margin
(session)defun make-opening-test-presence
(class &rest initargs)defun make-vec3
(x y z)defun make-scripted-world-agent
(presence)defun perform-scripted-opening
(presence)defgeneric open-embodied-agent-agent
(agent)Perform the blocking provider setup for AGENT and return a fresh WORLD-AGENT. Methods construct candidates only. The common opening protocol installs one winner, attaches its observer, and releases candidates that lose to teardown.
defun join-opening-thread
(presence thread)defun join-agent-turns
(provider)defun world-agent-turns
(agent)defun wait-for-turn
(turn &key timeout)defun gnome-ask
(gnome text)Start TEXT now, or queue it behind one asynchronous provider opening. In particular, first contact never performs DNS, TLS, or a WebSocket handshake on the canvas thread. It returns GNOME while opening, and a TURN when the provider was already installed.
define-arithmetic-operator /
Division of two represented quantities.
define-arithmetic-operator -
Subtraction or unary negation.
define-shader-operator float
Convert one scalar float or unsigned value to a 32-bit float.
define-arithmetic-operator <
Test whether one compatible scalar is less than another.
define-arithmetic-operator not
Logical negation of one test or raw truth value.
defun release-embodied-agent-harness
(presence)defun wait-for-application-agent-release
(agent &key timeout)Wait for AGENT's close path and FIFO worker, returning NIL on timeout. Release state and application detachment do not wait for this join point. A finite TIMEOUT therefore remains safe even when a provider-specific close function stalls or fails to wake its active receive.