Add metadata json field to Message, store generation model/provider

pkg/api/conversation.go

@@ -2,6 +2,8 @@ package api
 
 import (
 	"database/sql"
+	"database/sql/driver"
+	"encoding/json"
 	"time"
 )
 
@@ -23,21 +25,36 @@ const (
 	MessageRoleToolResult MessageRole = "tool_result"
 )
 
-type Message struct {
-	ID             uint          `gorm:"primaryKey"`
-	ConversationID *uint         `gorm:"index"`
-	Conversation   *Conversation `gorm:"foreignKey:ConversationID"`
-	Content        string
-	Role           MessageRole
-	CreatedAt      time.Time
-	ToolCalls      ToolCalls   // a json array of tool calls (from the model)
-	ToolResults    ToolResults // a json array of tool results
-	ParentID       *uint
-	Parent         *Message  `gorm:"foreignKey:ParentID"`
-	Replies        []Message `gorm:"foreignKey:ParentID"`
+type MessageMeta struct {
+	GenerationProvider *string `json:"generation_provider,omitempty"`
+	GenerationModel    *string `json:"generation_model,omitempty"`
+}
 
+type Message struct {
+	ID        uint `gorm:"primaryKey"`
+	CreatedAt time.Time
+	Metadata  MessageMeta
+
+	ConversationID  *uint         `gorm:"index"`
+	Conversation    *Conversation `gorm:"foreignKey:ConversationID"`
+	ParentID        *uint
+	Parent          *Message  `gorm:"foreignKey:ParentID"`
+	Replies         []Message `gorm:"foreignKey:ParentID"`
 	SelectedReplyID *uint
 	SelectedReply   *Message `gorm:"foreignKey:SelectedReplyID"`
+
+	Role        MessageRole
+	Content     string
+	ToolCalls   ToolCalls   // a json array of tool calls (from the model)
+	ToolResults ToolResults // a json array of tool results
+}
+
+func (m *MessageMeta) Scan(value interface{}) error {
+	return json.Unmarshal(value.([]byte), m)
+}
+
+func (m MessageMeta) Value() (driver.Value, error) {
+	return json.Marshal(m)
 }
 
 func ApplySystemPrompt(m []Message, system string, force bool) []Message {

pkg/api/provider/provider.go

@@ -6,8 +6,6 @@ import (
 	"git.mlow.ca/mlow/lmcli/pkg/api"
 )
 
-type ReplyCallback func(api.Message)
-
 type Chunk struct {
 	Content    string
 	TokenCount uint
@@ -24,9 +22,8 @@ type RequestParameters struct {
 }
 
 type ChatCompletionProvider interface {
-	// CreateChatCompletion requests a response to the provided messages.
-	// Replies are appended to the given replies struct, and the
-	// complete user-facing response is returned as a string.
+	// CreateChatCompletion generates a chat completion response to the
+	// provided messages.
 	CreateChatCompletion(
 		ctx context.Context,
 		params RequestParameters,
@@ -34,7 +31,7 @@ type ChatCompletionProvider interface {
 	) (*api.Message, error)
 
 	// Like CreateChageCompletion, except the response is streamed via
-	// the output channel as it's received.
+	// the output channel.
 	CreateChatCompletionStream(
 		ctx context.Context,
 		params RequestParameters,