Function RecordTEvent

pkg/telemetry/telemetry.go:273–305

(ctx context.Context, tevent *telemetrydata.TEvent)

}

func RecordTEvent(ctx context.Context, tevent *telemetrydata.TEvent) error {
	if tevent == nil {
		return nil
	}
	if tevent.Uuid == "" {
		tevent.Uuid = uuid.New().String()
	}
	err := tevent.Validate(true)
	if err != nil {
		return err
	}
	tevent.EnsureTimestamps()

	// Set AppFirstDay if on same calendar day as TOS agreement
	tosAgreedTs := GetTosAgreedTs()
	if tosAgreedTs == 0 {
		tevent.Props.AppFirstDay = true
	} else {
		tosYear, tosMonth, tosDay := time.UnixMilli(tosAgreedTs).Date()
		nowYear, nowMonth, nowDay := time.Now().Date()
		if tosYear == nowYear && tosMonth == nowMonth && tosDay == nowDay {
			tevent.Props.AppFirstDay = true
		}
	}

	if tevent.Event == ActivityEventName {
		return updateActivityTEvent(ctx, tevent)
	}
	if tevent.Event == WshRunEventName {
		return updateWshRunTEvent(ctx, tevent)
	}
	return insertTEvent(ctx, tevent)
}

func CleanOldTEvents(ctx context.Context) error {
	daysToKeep := 7