Method buildAttemptLocked

coderd/x/chatd/chatdebug/transport.go:463–499

buildAttemptLocked materializes the final Attempt from the current buffered response data plus err. Callers use this from both the record-once append path and the provisional-upgrade replace path so both sites apply the same redaction and status rules. The caller must hold r.mu for the duration of t

(err error)

// both sites apply the same redaction and status rules. The caller
// must hold r.mu for the duration of the call.
func (r *recordingBody) buildAttemptLocked(err error) Attempt {
	finishedAt := time.Now()

	truncated := r.truncated
	responseBody := append([]byte(nil), r.buf.Bytes()...)
	base := r.base
	startedAt := r.startedAt

	contentType := r.contentType
	switch {
	case truncated:
		base.ResponseBody = []byte("[TRUNCATED]")
	case isNDJSONContentType(contentType):
		base.ResponseBody = RedactNDJSONSecrets(responseBody)
	case contentType == "" || isJSONLikeContentType(contentType):
		// Redact JSON secrets when the content type is JSON-like
		// or absent (unknown). For unknown types, RedactJSONSecrets
		// fails closed by replacing non-JSON payloads with a
		// diagnostic message.
		base.ResponseBody = RedactJSONSecrets(responseBody)
	default:
		// Non-JSON content types (SSE, text/plain, HTML, etc.)
		// are preserved as-is to avoid losing debug content.
		base.ResponseBody = responseBody
	}
	base.StartedAt = startedAt.UTC().Format(time.RFC3339Nano)
	base.FinishedAt = finishedAt.UTC().Format(time.RFC3339Nano)
	// Recompute duration to include body read time.
	base.DurationMs = finishedAt.Sub(startedAt).Milliseconds()
	if err != nil && !errors.Is(err, io.EOF) {
		base.Error = sanitizeErrorString(err.Error())
		base.Status = attemptStatusFailed
	} else {
		base.Status = attemptStatusCompleted
	}
	return base
}

// record acquires r.mu before entering recordOnce.Do so it shares a
// single lock-acquisition order with recordProvisional. Without this,