Method AddInstanceEvent

database/sql/instances.go:255–300

(ctx context.Context, instanceName string, event params.EventType, eventLevel params.EventLevel, statusMessage string)

}

func (s *sqlDatabase) AddInstanceEvent(ctx context.Context, instanceName string, event params.EventType, eventLevel params.EventLevel, statusMessage string) error {
	instance, err := s.getInstance(ctx, s.conn, instanceName)
	if err != nil {
		return fmt.Errorf("error updating instance: %w", err)
	}

	msg := InstanceStatusUpdate{
		Message:    statusMessage,
		EventType:  event,
		EventLevel: eventLevel,
	}

	// Use Create instead of Association.Append to avoid loading all existing messages
	msg.InstanceID = instance.ID
	if err := s.conn.Create(&msg).Error; err != nil {
		return fmt.Errorf("error adding status message: %w", err)
	}

	// Keep only the latest 30 status messages to prevent database bloat
	const maxStatusMessages = 30
	var count int64
	if err := s.conn.Model(&InstanceStatusUpdate{}).Where("instance_id = ?", instance.ID).Count(&count).Error; err != nil {
		return fmt.Errorf("error counting status messages: %w", err)
	}

	if count > maxStatusMessages {
		// Get the ID of the 30th most recent message
		var cutoffMsg InstanceStatusUpdate
		if err := s.conn.Model(&InstanceStatusUpdate{}).
			Select("id").
			Where("instance_id = ?", instance.ID).
			Order("id desc").
			Offset(maxStatusMessages - 1).
			Limit(1).
			First(&cutoffMsg).Error; err != nil {
			return fmt.Errorf("error finding cutoff message: %w", err)
		}

		// Delete all messages older than the cutoff
		if err := s.conn.Where("instance_id = ? and id < ?", instance.ID, cutoffMsg.ID).Unscoped().Delete(&InstanceStatusUpdate{}).Error; err != nil {
			return fmt.Errorf("error deleting old status messages: %w", err)
		}
	}

	return nil
}

// validateAgentID checks agent ID consistency
func (s *sqlDatabase) validateAgentID(currentAgentID, newAgentID int64) error {