write

type Handler struct{}

type Input struct {
	Messages []*Message `parameter:",kind=body,in=data"`

	CurMessagesId *struct{ Values []string } `parameter:",kind=param,in=Messages,dataType=message/write.Messages" codec:"structql,uri=sql/cur_messages_id.sql"`

	CurMessage []*Message `parameter:",kind=view,in=CurMessage" view:"CurMessage" sql:"uri=sql/cur_message.sql"`

	CurMessageById map[string]*Message
}

type Message struct {
	Id              string     `sqlx:"id,primaryKey" validate:"required"`
	Archived        *int       `sqlx:"archived" json:",omitempty"`
	ConversationID  string     `sqlx:"conversation_id" validate:"required"`
	TurnID          *string    `sqlx:"turn_id" json:",omitempty"`
	Sequence        *int       `sqlx:"sequence" json:",omitempty"`
	CreatedAt       *time.Time `sqlx:"created_at" json:",omitempty"`
	UpdatedAt       *time.Time `sqlx:"updated_at" json:",omitempty"`
	CreatedByUserID *string    `sqlx:"created_by_user_id" json:",omitempty"`
	Mode            string     `sqlx:"mode" json:",omitempty"`
	Role            string     `sqlx:"role" validate:"required"`
	Status          string     `sqlx:"status" `
	Type            string     `sqlx:"type" validate:"required"`
	Content         string     `sqlx:"content"`
	RawContent      *string    `sqlx:"raw_content" json:",omitempty"`
	// Summary holds a compact retained summary for this message.
	Summary        *string `sqlx:"summary" json:",omitempty"`
	ContextSummary *string `sqlx:"context_summary" json:",omitempty"`
	// EmbeddingIndex stores a serialized vector index used for semantic match.
	EmbeddingIndex       *[]byte `sqlx:"embedding_index" json:",omitempty"`
	Tags                 *string `sqlx:"tags" json:",omitempty"`
	Interim              *int    `sqlx:"interim" json:",omitempty"`
	ElicitationID        *string `sqlx:"elicitation_id" json:",omitempty"`
	ParentMessageID      *string `sqlx:"parent_message_id" json:",omitempty"`
	SupersededBy         *string `sqlx:"superseded_by" json:",omitempty"`
	LinkedConversationID *string `sqlx:"linked_conversation_id" json:",omitempty"`
	ToolName             *string `sqlx:"tool_name" json:",omitempty"`
	// AttachmentPayloadID links a message to an uploaded/staged attachment payload.
	AttachmentPayloadID *string `sqlx:"attachment_payload_id" json:",omitempty"`
	// ElicitationPayloadID links a message to an elicitation response payload.
	ElicitationPayloadID *string     `sqlx:"elicitation_payload_id" json:",omitempty"`
	Has                  *MessageHas `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-"`
}

type MessageHas struct {
	Id                   bool
	Archived             bool
	ConversationID       bool
	TurnID               bool
	Sequence             bool
	CreatedAt            bool
	UpdatedAt            bool
	CreatedByUserID      bool
	Mode                 bool
	Role                 bool
	Status               bool
	Type                 bool
	Content              bool
	RawContent           bool
	Summary              bool
	ContextSummary       bool
	EmbeddingIndex       bool
	Tags                 bool
	Interim              bool
	ElicitationID        bool
	ParentMessageID      bool
	SupersededBy         bool
	LinkedConversationID bool
	ToolName             bool
	AttachmentPayloadID  bool
	ElicitationPayloadID bool
}

type Output struct {
	response.Status `parameter:",kind=output,in=status" anonymous:"true"`
	Data            []*Message             `parameter:",kind=body"`
	Violations      []*validator.Violation `parameter:",kind=transient"`
}