Method AddMessage

pkg/session/store.go:1025–1051

AddMessage adds a message to a session at the next position. Returns the ID of the created message item.

(ctx context.Context, sessionID string, msg *Message)

// AddMessage adds a message to a session at the next position.
// Returns the ID of the created message item.
func (s *SQLiteSessionStore) AddMessage(ctx context.Context, sessionID string, msg *Message) (int64, error) {
	if sessionID == "" {
		return 0, ErrEmptyID
	}

	msgJSON, err := json.Marshal(msg.Message)
	if err != nil {
		return 0, fmt.Errorf("marshaling message: %w", err)
	}

	// Insert a new message at the next position
	result, err := s.db.ExecContext(ctx,
		`INSERT INTO session_items (session_id, position, item_type, agent_name, message_json, implicit)
		 VALUES (?, (SELECT COALESCE(MAX(position), -1) + 1 FROM session_items WHERE session_id = ?), 'message', ?, ?, ?)`,
		sessionID, sessionID, msg.AgentName, string(msgJSON), msg.Implicit)
	if err != nil {
		return 0, fmt.Errorf("inserting message: %w", err)
	}

	id, err := result.LastInsertId()
	if err != nil {
		return 0, fmt.Errorf("getting last insert id: %w", err)
	}

	slog.DebugContext(ctx, "[STORE] AddMessage", "session_id", sessionID, "message_id", id, "role", msg.Message.Role, "agent", msg.AgentName)
	return id, nil
}

// UpdateMessage updates an existing message by its ID.
func (s *SQLiteSessionStore) UpdateMessage(ctx context.Context, messageID int64, msg *Message) error {