Services.Conversation.Interrupts (fnord v0.8.83)

View Source

Queue for injecting user messages into a conversation mid-completion.

This GenServer stores a FIFO list of pending injected user messages per conversation pid. AI.Completion will drain and apply these messages at safe checkpoints before sending a model request or between tool-call rounds.

Additionally, it supports temporarily blocking interrupts for a conversation during critical phases (e.g., finalization). When blocked, attempts to interrupt should be rejected at the UI layer; this server tracks blocked state so callers can check/decide behavior.

Summary

Types

msg()
state()

Functions

block(conversation_pid)

Block interrupts for a given conversation pid.

blocked?(conversation_pid)

Return true if interrupts are currently blocked for conversation pid.

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

pending?(conversation_pid)

Returns true if any interrupts are pending for the conversation pid.

request(conversation_pid, content)

Enqueue an injected user message for the given conversation pid.

start_link(opts \\ [])

Start the interrupt queue server.

take_all(conversation_pid)

Drain all pending injected messages for a conversation. Returns an empty list if none are pending.

unblock(conversation_pid)

Unblock interrupts for a given conversation pid.

Types

msg()

@type msg() :: AI.Util.msg()

state()

@type state() :: %{queues: %{optional(pid()) => [msg()]}, blocked: MapSet.t()}

Functions

block(conversation_pid)

@spec block(pid()) :: :ok

Block interrupts for a given conversation pid.

blocked?(conversation_pid)

@spec blocked?(pid()) :: boolean()

Return true if interrupts are currently blocked for conversation pid.

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

pending?(conversation_pid)

@spec pending?(pid()) :: boolean()

Returns true if any interrupts are pending for the conversation pid.

request(conversation_pid, content)

@spec request(pid(), String.t()) :: :ok

Enqueue an injected user message for the given conversation pid.

start_link(opts \\ [])

@spec start_link(Keyword.t()) :: GenServer.on_start()

Start the interrupt queue server.

take_all(conversation_pid)

@spec take_all(pid()) :: [msg()]

Drain all pending injected messages for a conversation. Returns an empty list if none are pending.

unblock(conversation_pid)

@spec unblock(pid()) :: :ok

Unblock interrupts for a given conversation pid.