Method addEnterpriseEvent

database/sql/util.go:913–958

(ctx context.Context, entID string, event params.EventType, eventLevel params.EventLevel, statusMessage string, maxEvents int)

}

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

	msg := EnterpriseEvent{
		Message:      statusMessage,
		EventType:    event,
		EventLevel:   eventLevel,
		EnterpriseID: ent.ID,
	}

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

	if maxEvents > 0 {
		var count int64
		if err := s.conn.Model(&EnterpriseEvent{}).Where("enterprise_id = ?", ent.ID).Count(&count).Error; err != nil {
			return fmt.Errorf("error counting events: %w", err)
		}

		if count > int64(maxEvents) {
			// Get the ID of the Nth most recent event
			var cutoffEvent EnterpriseEvent
			if err := s.conn.Model(&EnterpriseEvent{}).
				Select("id").
				Where("enterprise_id = ?", ent.ID).
				Order("id desc").
				Offset(maxEvents - 1).
				Limit(1).
				First(&cutoffEvent).Error; err != nil {
				return fmt.Errorf("error finding cutoff event: %w", err)
			}

			// Delete all events older than the cutoff
			if err := s.conn.Where("enterprise_id = ? and id < ?", ent.ID, cutoffEvent.ID).Unscoped().Delete(&EnterpriseEvent{}).Error; err != nil {
				return fmt.Errorf("error deleting old events: %w", err)
			}
		}
	}

	return nil
}

func (s *sqlDatabase) AddEntityEvent(ctx context.Context, entity params.ForgeEntity, event params.EventType, eventLevel params.EventLevel, statusMessage string, maxEvents int) error {
	if maxEvents == 0 {