Method doRequestWithCredentialsAndClient

internal/cli/client.go:5524–5576

doRequestWithCredentialsAndClient lets SSE streams opt out of the JSON request timeout.

(
	ctx context.Context,
	method string,
	path string,
	query url.Values,
	requestBody any,
	lastEventID string,
	credentials agentidentity.Credentials,
	client *http.Client,
)

// doRequestWithCredentialsAndClient lets SSE streams opt out of the JSON request timeout.
func (c *unixSocketClient) doRequestWithCredentialsAndClient(
	ctx context.Context,
	method string,
	path string,
	query url.Values,
	requestBody any,
	lastEventID string,
	credentials agentidentity.Credentials,
	client *http.Client,
) (*http.Response, error) {
	if ctx == nil {
		return nil, errors.New("cli: context is required")
	}
	if client == nil {
		return nil, errors.New("cli: http client is required")
	}

	target := baseURL + path
	if len(query) > 0 {
		target += "?" + query.Encode()
	}

	var body io.Reader
	if requestBody != nil {
		payload, err := json.Marshal(requestBody)
		if err != nil {
			return nil, fmt.Errorf("cli: encode %s %s request: %w", method, path, err)
		}
		body = bytes.NewReader(payload)
	}

	req, err := http.NewRequestWithContext(ctx, method, target, body)
	if err != nil {
		return nil, fmt.Errorf("cli: build %s %s request: %w", method, path, err)
	}
	req.Header.Set("User-Agent", defaultUserAgentName)
	if requestBody != nil {
		req.Header.Set("Content-Type", "application/json")
	}
	if strings.TrimSpace(lastEventID) != "" {
		req.Header.Set("Last-Event-ID", strings.TrimSpace(lastEventID))
	}
	setAgentIdentityHeaders(req, credentials)

	response, err := client.Do(req)
	if err != nil {
		if isDaemonUnavailableTransportError(err) {
			return nil, newDaemonUnavailableError(c.socketPath, method, path, err)
		}
		return nil, fmt.Errorf("cli: %s %s via %s: %w", method, path, c.socketPath, err)
	}
	return response, nil
}

func newDaemonUnavailableError(socketPath string, method string, path string, err error) error {
	item := diagnosticspkg.NewItem(