Function createUserReportData

backend/plugins/q_dev/tasks/s3_data_extractor.go:184–240

createUserReportData creates a QDevUserReport from a new-format CSV record

(logger interface {
	Debug(format string, a ...interface{})
}, headers []string, record []string, fileMeta *models.QDevS3FileMeta, identityClient UserDisplayNameResolver)

// createUserReportData creates a QDevUserReport from a new-format CSV record
func createUserReportData(logger interface {
	Debug(format string, a ...interface{})
}, headers []string, record []string, fileMeta *models.QDevS3FileMeta, identityClient UserDisplayNameResolver) (*models.QDevUserReport, errors.Error) {
	report := &models.QDevUserReport{
		ConnectionId: fileMeta.ConnectionId,
		ScopeId:      fileMeta.ScopeId,
	}

	// Build field map
	fieldMap := make(map[string]string)
	for i, header := range headers {
		if i < len(record) {
			logger.Debug("Mapping header[%d]: '%s' -> '%s'", i, header, record[i])
			fieldMap[header] = record[i]
			trimmedHeader := strings.TrimSpace(header)
			if trimmedHeader != header {
				logger.Debug("Also adding trimmed header: '%s'", trimmedHeader)
				fieldMap[trimmedHeader] = record[i]
			}
		}
	}

	// UserId (normalize to strip "d-{directoryId}." prefix if present)
	report.UserId = normalizeUserId(getStringField(fieldMap, "UserId"))
	if report.UserId == "" {
		return nil, errors.Default.New("UserId not found in CSV record")
	}

	// DisplayName
	report.DisplayName = resolveDisplayName(logger, report.UserId, identityClient)

	// Date
	dateStr := getStringField(fieldMap, "Date")
	if dateStr == "" {
		return nil, errors.Default.New("Date not found in CSV record")
	}
	var err error
	report.Date, err = parseDate(dateStr)
	if err != nil {
		return nil, errors.Default.Wrap(err, "failed to parse date")
	}

	// String fields
	report.ClientType = getStringField(fieldMap, "Client_Type")
	report.SubscriptionTier = getStringField(fieldMap, "Subscription_Tier")
	report.ProfileId = getStringField(fieldMap, "ProfileId")

	// Numeric fields
	report.ChatConversations = parseInt(fieldMap, "Chat_Conversations")
	report.CreditsUsed = parseFloat(fieldMap, "Credits_Used")
	report.OverageCap = parseFloat(fieldMap, "Overage_Cap")
	report.OverageCreditsUsed = parseFloat(fieldMap, "Overage_Credits_Used")
	report.OverageEnabled = parseBool(fieldMap, "Overage_Enabled")
	report.TotalMessages = parseInt(fieldMap, "Total_Messages")

	return report, nil
}