bump github.com/anthropics/anthropic-sdk-go from v1.26.0 to v1.27.1

Assisted-By: docker-agent

Author: dgageot

go.mod

@@ -12,7 +12,7 @@ require (
 	github.com/a2aproject/a2a-go v0.3.10
 	github.com/alecthomas/chroma/v2 v2.23.1
 	github.com/alpkeskin/gotoon v0.1.1
-	github.com/anthropics/anthropic-sdk-go v1.26.0
+	github.com/anthropics/anthropic-sdk-go v1.27.1
 	github.com/atotto/clipboard v0.1.4
 	github.com/aws/aws-sdk-go-v2 v1.41.4
 	github.com/aws/aws-sdk-go-v2/config v1.32.12

go.sum

@@ -45,8 +45,8 @@ github.com/alpkeskin/gotoon v0.1.1 h1:GQOVwMfWKINnfEA6slrXHJaJYDwnUFmrPlXOtnuja1
 github.com/alpkeskin/gotoon v0.1.1/go.mod h1:XRTz8RM4tz8M2nB37MNRN8rHF4YgeYd8nIXmoU0B0+M=
 github.com/anmitsu/go-shlex v0.0.0-20200514113438-38f4b401e2be h1:9AeTilPcZAjCFIImctFaOjnTIavg87rW78vTPkQqLI8=
 github.com/anmitsu/go-shlex v0.0.0-20200514113438-38f4b401e2be/go.mod h1:ySMOLuWl6zY27l47sB3qLNK6tF2fkHG55UZxx8oIVo4=
-github.com/anthropics/anthropic-sdk-go v1.26.0 h1:oUTzFaUpAevfuELAP1sjL6CQJ9HHAfT7CoSYSac11PY=
-github.com/anthropics/anthropic-sdk-go v1.26.0/go.mod h1:qUKmaW+uuPB64iy1l+4kOSvaLqPXnHTTBKH6RVZ7q5Q=
+github.com/anthropics/anthropic-sdk-go v1.27.1 h1:7DgMZ2Ng3C2mPzJGHA30NXQTZolcF07mHd0tGaLwfzk=
+github.com/anthropics/anthropic-sdk-go v1.27.1/go.mod h1:qUKmaW+uuPB64iy1l+4kOSvaLqPXnHTTBKH6RVZ7q5Q=
 github.com/armon/go-socks5 v0.0.0-20160902184237-e75332964ef5 h1:0CwZNZbxp69SHPdPJAN/hZIm0C4OItdklCFmMRWYpio=
 github.com/armon/go-socks5 v0.0.0-20160902184237-e75332964ef5/go.mod h1:wHh0iHkYZB8zMSxRWpUBQtwG5a7fFgvEO+odwuTv2gs=
 github.com/atotto/clipboard v0.1.4 h1:EH0zSVneZPSuFR11BlR9YppQTVDbh5+16AmcJi4g1z4=

pkg/model/provider/anthropic/adapter.go

@@ -78,7 +78,7 @@ func (a *streamAdapter) Recv() (chat.MessageStreamResponse, error) {
 	response := chat.MessageStreamResponse{
 		ID:     event.Message.ID,
 		Object: "chat.completion.chunk",
-		Model:  string(event.Message.Model),
+		Model:  event.Message.Model,
 		Choices: []chat.MessageStreamChoice{
 			{
 				Index: 0,

pkg/model/provider/anthropic/beta_adapter.go

@@ -42,7 +42,7 @@ func (a *betaStreamAdapter) Recv() (chat.MessageStreamResponse, error) {
 	response := chat.MessageStreamResponse{
 		ID:     event.Message.ID,
 		Object: "chat.completion.chunk",
-		Model:  string(event.Message.Model),
+		Model:  event.Message.Model,
 		Choices: []chat.MessageStreamChoice{
 			{
 				Index: 0,

pkg/model/provider/anthropic/beta_client.go

@@ -70,7 +70,7 @@ func (c *Client) createBetaStream(
 	}
 
 	params := anthropic.BetaMessageNewParams{
-		Model:     anthropic.Model(c.ModelConfig.Model),
+		Model:     c.ModelConfig.Model,
 		MaxTokens: maxTokens,
 		System:    sys,
 		Messages:  converted,
@@ -96,7 +96,7 @@ func (c *Client) createBetaStream(
 	// which don't require thinking.
 	if budget := c.ModelConfig.ThinkingBudget; budget != nil {
 		if effort, ok := anthropicThinkingEffort(budget); ok {
-			adaptive := anthropic.NewBetaThinkingConfigAdaptiveParam()
+			adaptive := anthropic.BetaThinkingConfigAdaptiveParam{}
 			params.Thinking = anthropic.BetaThinkingConfigParamUnion{OfAdaptive: &adaptive}
 			params.OutputConfig.Effort = anthropic.BetaOutputConfigEffort(effort)
 			slog.Debug("Anthropic Beta API using adaptive thinking", "effort", effort)
@@ -121,7 +121,7 @@ func (c *Client) createBetaStream(
 
 	// Set up single retry for context length errors
 	ad.retryFn = func() *ssestream.Stream[anthropic.BetaRawMessageStreamEventUnion] {
-		used, err := countAnthropicTokensBeta(ctx, client, anthropic.Model(c.ModelConfig.Model), converted, sys, allTools)
+		used, err := countAnthropicTokensBeta(ctx, client, c.ModelConfig.Model, converted, sys, allTools)
 		if err != nil {
 			slog.Warn("Failed to count tokens for retry, skipping", "error", err)
 			return nil
@@ -271,7 +271,7 @@ func (c *Client) Rerank(ctx context.Context, query string, documents []types.Doc
 		maxTokens = 8192
 	}
 	params := anthropic.BetaMessageNewParams{
-		Model:     anthropic.Model(c.ModelConfig.Model),
+		Model:     c.ModelConfig.Model,
 		MaxTokens: maxTokens,
 		Messages:  msgs,
 		// Enable structured outputs beta.
@@ -421,7 +421,7 @@ func accumulateBetaStreamResponse(stream *ssestream.Stream[anthropic.BetaRawMess
 		// Initialize the message metadata from the first event
 		if messageID == "" {
 			messageID = event.Message.ID
-			model = string(event.Message.Model)
+			model = event.Message.Model
 			role = string(event.Message.Role)
 			messageType = string(event.Message.Type)
 		}

pkg/model/provider/anthropic/client.go

@@ -300,7 +300,7 @@ func (c *Client) CreateChatCompletionStream(
 	sys := extractSystemBlocks(messages)
 
 	params := anthropic.MessageNewParams{
-		Model:     anthropic.Model(c.ModelConfig.Model),
+		Model:     c.ModelConfig.Model,
 		MaxTokens: maxTokens,
 		System:    sys,
 		Messages:  converted,
@@ -311,7 +311,7 @@ func (c *Client) CreateChatCompletionStream(
 	thinkingEnabled := false
 	if budget := c.ModelConfig.ThinkingBudget; budget != nil {
 		if effortStr, ok := anthropicThinkingEffort(budget); ok {
-			adaptive := anthropic.NewThinkingConfigAdaptiveParam()
+			adaptive := anthropic.ThinkingConfigAdaptiveParam{}
 			params.Thinking = anthropic.ThinkingConfigParamUnion{OfAdaptive: &adaptive}
 			params.OutputConfig.Effort = anthropic.OutputConfigEffort(effortStr)
 			thinkingEnabled = true
@@ -363,7 +363,7 @@ func (c *Client) CreateChatCompletionStream(
 
 	// Set up single retry for context length errors
 	ad.retryFn = func() *ssestream.Stream[anthropic.MessageStreamEventUnion] {
-		used, err := countAnthropicTokens(ctx, client, anthropic.Model(c.ModelConfig.Model), converted, sys, allTools)
+		used, err := countAnthropicTokens(ctx, client, c.ModelConfig.Model, converted, sys, allTools)
 		if err != nil {
 			slog.Warn("Failed to count tokens for retry, skipping", "error", err)
 			return nil