Class AnthropicMessage

java.lang.Object

uno.anahata.asi.agi.event.BasicPropertyChangeSource

uno.anahata.asi.agi.message.AbstractMessage

uno.anahata.asi.agi.message.AbstractModelMessage<AnthropicResponse>

uno.anahata.asi.anthropic.AnthropicMessage

All Implemented Interfaces:

PropertyChangeSource, Rebindable

public class AnthropicMessage
extends AbstractModelMessage<AnthropicResponse>

Message implementation for Anthropic's Claude.

Author:

anahata

Field Summary

Fields

Modifier and Type	Field	Description
private Map<Integer, StringBuilder>	toolArgBuffers	Buffers for accumulating streaming tool call arguments, keyed by their index in the content block array.
private Map<Integer,String>	toolIds	Maps content block indices to their stable API-provided unique tool use IDs.
private Map<Integer,String>	toolNames	Maps content block indices to the requested tool name.

Fields inherited from class BasicPropertyChangeSource

propertyChangeSupport

Constructor Summary

Constructors

Constructor	Description
AnthropicMessage(Agi agi, String modelId)	Constructs a new Anthropic message.

Method Summary

Modifier and Type	Method	Description
void	appendContent(String text)	Appends text to the last message part if it is a text part, otherwise creates a new one.
void	appendThoughts(String text)	Appends text to the reasoning/thought part or creates a new one.
private void	flushToolCall(int index)	Finalizes a tool call by parsing its buffered JSON arguments and registering it with the tool manager.
void	handleEvent(String eventType, com.fasterxml.jackson.databind.JsonNode data)	Processes a single streaming event from the Anthropic API.
void	parseFinalContent(com.fasterxml.jackson.databind.JsonNode contentArray)	Parses the final (non-streaming) content array from an Anthropic response.
void	setFinishReasonFromAnthropic(String reason)	Maps an Anthropic stop reason to the unified Anahata finish reason.
void	setThoughtSignatureOnLastPart(byte[] sig)	Sets the thought signature on the last thought part.

Methods inherited from class AbstractModelMessage

addBlobPart, addBlobPart, addBlobPart, addTextPart, addTextPart, appendMetadata, appendRawJson, declineAllPending, executeAllPending, getDevice, getFrom, getRole, getToolCalls, getToolResponses, hasPendingTools, isAutoRunnable, isEffectivelyPruned, isToolPromptMessage, processPendingTools, remove, removePart, setBilledCompletionTokens, setBilledPromptTokens, setFinishReason, setGroundingMetadata, setRawJson

Methods inherited from class AbstractMessage

addPart, asText, createMetadataHeader, getDepth, getEffectiveTokenCount, getIdentityLabel, getParts, getParts, getRemainingDepth, getTokenCount, isAllPinned, isAllPruned, isAnyPinned, isEmpty, isGarbageCollectable, isPrunnableOrRemovable, pinAllParts, pruneAllParts, resetTokenCounts, setAutoAllParts, shouldCreateMetadata

Methods inherited from class BasicPropertyChangeSource

addPropertyChangeListener, addPropertyChangeListener, rebind, removePropertyChangeListener, removePropertyChangeListener

Methods inherited from class Object

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

Methods inherited from interface PropertyChangeSource

getPropertyChangeSupport

Field Details

toolArgBuffers

private transient Map<Integer, StringBuilder> toolArgBuffers

Buffers for accumulating streaming tool call arguments, keyed by their index in the content block array.

toolIds

private transient Map<Integer,String> toolIds

Maps content block indices to their stable API-provided unique tool use IDs.

toolNames

private transient Map<Integer,String> toolNames

Maps content block indices to the requested tool name.

Constructor Details

AnthropicMessage

public AnthropicMessage(Agi agi,
 String modelId)

Constructs a new Anthropic message.

Parameters:

agi - The parent session.

modelId - The model ID.

Method Details

parseFinalContent

public void parseFinalContent(com.fasterxml.jackson.databind.JsonNode contentArray)

Parses the final (non-streaming) content array from an Anthropic response. Handles text, thinking, and tool_use blocks.

Parameters:

contentArray - The JSON array of content blocks.

handleEvent

public void handleEvent(String eventType,
 com.fasterxml.jackson.databind.JsonNode data)

Processes a single streaming event from the Anthropic API.

Parameters:

eventType - The type of event (e.g., 'message_start', 'content_block_delta').

data - The JSON payload associated with the event.

flushToolCall

private void flushToolCall(int index)

Finalizes a tool call by parsing its buffered JSON arguments and registering it with the tool manager.

Parameters:

index - The content block index for the tool.

appendContent

public void appendContent(String text)

Appends text to the last message part if it is a text part, otherwise creates a new one.

Parameters:

text - The text to append.

appendThoughts

public void appendThoughts(String text)

Appends text to the reasoning/thought part or creates a new one.

Parameters:

text - The thought text to append.

setThoughtSignatureOnLastPart

public void setThoughtSignatureOnLastPart(byte[] sig)

Sets the thought signature on the last thought part.

Parameters:

sig - The signature byte array.

setFinishReasonFromAnthropic

public void setFinishReasonFromAnthropic(String reason)

Maps an Anthropic stop reason to the unified Anahata finish reason.

Parameters:

reason - The raw string from the API.