Function parseCompletionRecord

backend/plugins/q_dev/tasks/s3_logging_extractor.go:402–432

(raw json.RawMessage, fileMeta *models.QDevS3FileMeta, identityClient UserDisplayNameResolver, cache *sync.Map)

}

func parseCompletionRecord(raw json.RawMessage, fileMeta *models.QDevS3FileMeta, identityClient UserDisplayNameResolver, cache *sync.Map) (*models.QDevCompletionLog, error) {
	var record completionLogRecord
	if err := json.Unmarshal(raw, &record); err != nil {
		return nil, err
	}

	if record.Request == nil || record.Response == nil {
		return nil, nil
	}

	ts, err := time.Parse(time.RFC3339Nano, record.Request.Timestamp)
	if err != nil {
		ts = time.Now()
	}

	userId := normalizeUserId(record.Request.UserID)
	return &models.QDevCompletionLog{
		ConnectionId:       fileMeta.ConnectionId,
		ScopeId:            fileMeta.ScopeId,
		RequestId:          record.Response.RequestID,
		UserId:             userId,
		DisplayName:        cachedResolveDisplayName(userId, identityClient, cache),
		Timestamp:          ts,
		FileName:           record.Request.FileName,
		FileExtension:      filepath.Ext(record.Request.FileName),
		HasCustomization:   record.Request.CustomizationArn != nil && *record.Request.CustomizationArn != "",
		CompletionsCount:   len(record.Response.Completions),
		LeftContextLength:  len(record.Request.LeftContext),
		RightContextLength: len(record.Request.RightContext),
	}, nil
}

// normalizeUserId strips the "d-{directoryId}." prefix from Identity Center user IDs
// so that logging user IDs match the short UUID format used in user-report CSVs.