chore: configurable event name trimming for reporting (#6394)

Author: satishrudderstack

enterprise/reporting/reporting.go

@@ -82,6 +82,10 @@ type DefaultReporter struct {
 	eventSamplingDuration config.ValueLoader[time.Duration]
 	eventSampler          event_sampler.EventSampler
 
+	eventNameMaxLength    config.ValueLoader[int]
+	eventNamePrefixLength config.ValueLoader[int]
+	eventNameSuffixLength config.ValueLoader[int]
+
 	useCommonClient config.ValueLoader[bool]
 	commonClient    *client.Client
 }
@@ -106,6 +110,9 @@ func NewDefaultReporter(ctx context.Context, conf *config.Config, log logger.Log
 	eventSamplingDuration := conf.GetReloadableDurationVar(60, time.Minute, "Reporting.eventSampling.durationInMinutes")
 	eventSamplerType := conf.GetReloadableStringVar("badger", "Reporting.eventSampling.type")
 	eventSamplingCardinality := conf.GetReloadableIntVar(100000, 1, "Reporting.eventSampling.cardinality")
+	eventNameMaxLength := conf.GetReloadableIntVar(50, 1, "Reporting.eventNameTrimming.maxLength")
+	eventNamePrefixLength := conf.GetReloadableIntVar(40, 1, "Reporting.eventNameTrimming.prefixLength")
+	eventNameSuffixLength := conf.GetReloadableIntVar(10, 1, "Reporting.eventNameTrimming.suffixLength")
 	// only send reports for wh actions sources if whActionsOnly is configured
 	whActionsOnly := config.GetBool("REPORTING_WH_ACTIONS_ONLY", false)
 	if whActionsOnly {
@@ -145,6 +152,9 @@ func NewDefaultReporter(ctx context.Context, conf *config.Config, log logger.Log
 		eventSamplingEnabled:                 eventSamplingEnabled,
 		eventSamplingDuration:                eventSamplingDuration,
 		eventSampler:                         eventSampler,
+		eventNameMaxLength:                   eventNameMaxLength,
+		eventNamePrefixLength:                eventNamePrefixLength,
+		eventNameSuffixLength:                eventNameSuffixLength,
 		useCommonClient:                      useCommonClient,
 		commonClient:                         client.New(client.RouteMetrics, conf, log, stats),
 	}
@@ -668,6 +678,15 @@ func (r *DefaultReporter) Report(ctx context.Context, metrics []*types.PUReporte
 		return nil
 	}
 
+	maxLength := r.eventNameMaxLength.Load()
+	prefixLength := r.eventNamePrefixLength.Load()
+	suffixLength := r.eventNameSuffixLength.Load()
+	if prefixLength <= 0 || suffixLength <= 0 || prefixLength >= maxLength || suffixLength >= maxLength || prefixLength+suffixLength != maxLength {
+		err := fmt.Errorf("invalid event name trimming configuration: prefixLength=%d, suffixLength=%d, maxLength=%d. prefixLength and suffixLength must be > 0, prefixLength < maxLength, suffixLength < maxLength, and prefixLength + suffixLength = maxLength", prefixLength, suffixLength, maxLength)
+		r.log.Errorn(`[ Reporting ]: Invalid event name trimming configuration`, obskit.Error(err))
+		return err
+	}
+
 	stmt, err := txn.PrepareContext(ctx, pq.CopyIn(ReportsTable,
 		"workspace_id", "namespace", "instance_id",
 		"source_definition_id",
@@ -716,8 +735,8 @@ func (r *DefaultReporter) Report(ctx context.Context, metrics []*types.PUReporte
 		}
 
 		runeEventName := []rune(metric.StatusDetail.EventName)
-		if len(runeEventName) > 50 {
-			metric.StatusDetail.EventName = fmt.Sprintf("%s...%s", string(runeEventName[:40]), string(runeEventName[len(runeEventName)-10:]))
+		if len(runeEventName) > maxLength {
+			metric.StatusDetail.EventName = fmt.Sprintf("%s...%s", string(runeEventName[:prefixLength]), string(runeEventName[len(runeEventName)-suffixLength:]))
 		}
 
 		_, err = stmt.Exec(