12v0.9 的 AgenticMessage 与泛型化

type AgenticMessage struct {
  // Role is the message role.
  Role AgenticRoleType `json:"role"`

  // ContentBlocks is the list of content blocks.
  ContentBlocks []*ContentBlock `json:"content_blocks,omitempty"`

  // ResponseMeta is the response metadata.
  ResponseMeta *AgenticResponseMeta `json:"response_meta,omitempty"`

  // Extra is the additional information.
  Extra map[string]any `json:"extra,omitempty"`
}

const (
  AgenticRoleTypeSystem    AgenticRoleType = "system"
  AgenticRoleTypeUser      AgenticRoleType = "user"
  AgenticRoleTypeAssistant AgenticRoleType = "assistant"
)

type ContentBlock struct {
  Type ContentBlockType `json:"type"`

  // Reasoning contains the reasoning content generated by the model.
  Reasoning *Reasoning `json:"reasoning,omitempty"`

  // UserInputText contains the text content provided by the user.
  UserInputText *UserInputText `json:"user_input_text,omitempty"`

  // UserInputImage contains the image content provided by the user.
  UserInputImage *UserInputImage `json:"user_input_image,omitempty"`

  // UserInputAudio contains the audio content provided by the user.
  UserInputAudio *UserInputAudio `json:"user_input_audio,omitempty"`

  // UserInputVideo contains the video content provided by the user.
  UserInputVideo *UserInputVideo `json:"user_input_video,omitempty"`

  // UserInputFile contains the file content provided by the user.
  UserInputFile *UserInputFile `json:"user_input_file,omitempty"`

  // AssistantGenText contains the text content generated by the model.
  AssistantGenText *AssistantGenText `json:"assistant_gen_text,omitempty"`

  // AssistantGenImage contains the image content generated by the model.
  AssistantGenImage *AssistantGenImage `json:"assistant_gen_image,omitempty"`

  // AssistantGenAudio contains the audio content generated by the model.
  AssistantGenAudio *AssistantGenAudio `json:"assistant_gen_audio,omitempty"`

  // AssistantGenVideo contains the video content generated by the model.
  AssistantGenVideo *AssistantGenVideo `json:"assistant_gen_video,omitempty"`

  // FunctionToolCall contains the invocation details for a user-defined tool.
  FunctionToolCall *FunctionToolCall `json:"function_tool_call,omitempty"`

  // FunctionToolResult contains the result returned from a user-defined tool call.
  FunctionToolResult *FunctionToolResult `json:"function_tool_result,omitempty"`

  // ToolSearchFunctionToolResult contains the result of a client-side custom tool search tool call.
  // It carries the full definitions of newly discovered tools so that the model can
  // recognize which tools have been added and are now available for invocation.
  ToolSearchFunctionToolResult *ToolSearchFunctionToolResult `json:"tool_search_function_tool_result,omitempty"`

  // ServerToolCall contains the invocation details for a provider built-in tool executed on the model server.
  ServerToolCall *ServerToolCall `json:"server_tool_call,omitempty"`

  // ServerToolResult contains the result returned from a provider built-in tool executed on the model server.
// … 省略 24 行；完整声明 L102–173，点击上方「浏览完整文件」

const (
  ContentBlockTypeReasoning               ContentBlockType = "reasoning"
  ContentBlockTypeUserInputText           ContentBlockType = "user_input_text"
  ContentBlockTypeUserInputImage          ContentBlockType = "user_input_image"
  ContentBlockTypeUserInputAudio          ContentBlockType = "user_input_audio"
  ContentBlockTypeUserInputVideo          ContentBlockType = "user_input_video"
  ContentBlockTypeUserInputFile           ContentBlockType = "user_input_file"
  ContentBlockTypeToolSearchResult        ContentBlockType = "tool_search_result"
  ContentBlockTypeAssistantGenText        ContentBlockType = "assistant_gen_text"
  ContentBlockTypeAssistantGenImage       ContentBlockType = "assistant_gen_image"
  ContentBlockTypeAssistantGenAudio       ContentBlockType = "assistant_gen_audio"
  ContentBlockTypeAssistantGenVideo       ContentBlockType = "assistant_gen_video"
  ContentBlockTypeFunctionToolCall        ContentBlockType = "function_tool_call"
  ContentBlockTypeFunctionToolResult      ContentBlockType = "function_tool_result"
  ContentBlockTypeServerToolCall          ContentBlockType = "server_tool_call"
  ContentBlockTypeServerToolResult        ContentBlockType = "server_tool_result"
  ContentBlockTypeMCPToolCall             ContentBlockType = "mcp_tool_call"
  ContentBlockTypeMCPToolResult           ContentBlockType = "mcp_tool_result"
  ContentBlockTypeMCPListToolsResult      ContentBlockType = "mcp_list_tools_result"
  ContentBlockTypeMCPToolApprovalRequest  ContentBlockType = "mcp_tool_approval_request"
  ContentBlockTypeMCPToolApprovalResponse ContentBlockType = "mcp_tool_approval_response"
)

type BaseModel[M messageType] interface {
    Generate(ctx context.Context, input []M, opts ...Option) (M, error)
    Stream(ctx context.Context, input []M, opts ...Option) (*schema.StreamReader[M], error)
}

type MessageType interface {
    *schema.Message | *schema.AgenticMessage
}

// ConcatAgenticMessages concatenates a list of AgenticMessage chunks into a single AgenticMessage.
func ConcatAgenticMessages(msgs []*AgenticMessage) (*AgenticMessage, error) {
  var (
    role          AgenticRoleType
    blocks        []*ContentBlock
    metas         []*AgenticResponseMeta
    extra         map[string]any
    blockIndices  []int
    indexToBlocks = map[int][]*ContentBlock{}
    extraList     = make([]map[string]any, 0, len(msgs))
  )

  if len(msgs) == 1 {
    return msgs[0], nil
  }

  for idx, msg := range msgs {
    if msg == nil {
      return nil, fmt.Errorf("message at index %d is nil", idx)
    }

    if msg.Role != "" {
      if role == "" {
        role = msg.Role
      } else if role != msg.Role {
        return nil, fmt.Errorf("cannot concat messages with different roles: got '%s' and '%s'", role, msg.Role)
      }
    }

    for _, block := range msg.ContentBlocks {
      if block == nil {
        continue
      }
      if block.StreamingMeta == nil {
        // Non-streaming block
        if len(blockIndices) > 0 {
          // Cannot mix streaming and non-streaming blocks
          return nil, fmt.Errorf("found non-streaming block after streaming blocks")
        }
        // Collect non-streaming block
        blocks = append(blocks, block)
      } else {
        // Streaming block
        if len(blocks) > 0 {
          // Cannot mix non-streaming and streaming blocks
          return nil, fmt.Errorf("found streaming block after non-streaming blocks")
        }
        // Collect streaming block by index
// … 省略 57 行；完整声明 L900–1004，点击上方「浏览完整文件」