Method doSessionPrompt

internal/cli/client.go:5429–5482

(
	ctx context.Context,
	method string,
	path string,
	query url.Values,
	requestBody any,
)

}

func (c *unixSocketClient) doSessionPrompt(
	ctx context.Context,
	method string,
	path string,
	query url.Values,
	requestBody any,
) (SessionPromptRecord, error) {
	response, err := c.doRequestWithCredentialsAndClient(
		ctx,
		method,
		path,
		query,
		requestBody,
		"",
		agentidentity.Credentials{},
		c.streamHTTPClient(),
	)
	if err != nil {
		return SessionPromptRecord{}, err
	}
	defer func() {
		_ = response.Body.Close()
	}()

	if response.StatusCode < 200 || response.StatusCode >= 300 {
		return SessionPromptRecord{}, readAPIError(response)
	}

	if strings.Contains(strings.ToLower(response.Header.Get("Content-Type")), "text/event-stream") {
		var events []AgentEventRecord
		if err := decodeSSE(ctx, response.Body, func(event SSEEvent) error {
			var payload AgentEventRecord
			if len(event.Data) > 0 {
				if err := json.Unmarshal(event.Data, &payload); err != nil {
					return fmt.Errorf("cli: decode prompt event: %w", err)
				}
			}
			if payload.Type == "" {
				payload.Type = event.Event
			}
			events = append(events, payload)
			return nil
		}); err != nil {
			return SessionPromptRecord{}, err
		}
		return SessionPromptRecord{Events: events}, nil
	}

	var responseBody contract.SendPromptResultResponse
	if err := json.NewDecoder(response.Body).Decode(&responseBody); err != nil {
		return SessionPromptRecord{}, fmt.Errorf("cli: decode %s %s response: %w", method, path, err)
	}
	return SessionPromptRecord{Prompt: responseBody.Prompt}, nil
}

func (c *unixSocketClient) doRequest(
	ctx context.Context,