Method addRepositoryEvent

database/sql/util.go:821–865

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

}

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

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

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)