Method addOrgEvent

database/sql/util.go:867–911

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

}

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

	msg := OrganizationEvent{
		Message:    statusMessage,
		EventType:  event,
		EventLevel: eventLevel,
		OrgID:      org.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(&OrganizationEvent{}).Where("org_id = ?", org.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 OrganizationEvent
			if err := s.conn.Model(&OrganizationEvent{}).
				Select("id").
				Where("org_id = ?", org.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("org_id = ? and id < ?", org.ID, cutoffEvent.ID).Unscoped().Delete(&OrganizationEvent{}).Error; err != nil {
				return fmt.Errorf("error deleting old events: %w", err)
			}
		}
	}
	return nil
}

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)