Method HttpRequestStart

go/copilot_request_handler.go:582–630

(params *rpc.LlmInferenceHTTPRequestStartRequest)

}

func (a *copilotRequestAdapter) HttpRequestStart(params *rpc.LlmInferenceHTTPRequestStartRequest) (*rpc.LlmInferenceHTTPRequestStartResult, error) {
	// Adopt any exchange a racing chunk already created — with its buffered
	// body — rather than dropping those frames.
	exchange := a.getOrCreateExchange(params.RequestID)
	ctx := exchange.ctx
	bodyCh := make(chan CopilotWebSocketMessage)

	go func() {
		defer close(bodyCh)
		for {
			m, ok := exchange.queue.pop()
			if !ok {
				return
			}
			select {
			case bodyCh <- m:
			case <-ctx.Done():
				return
			}
		}
	}()

	transport := "http"
	if params.Transport != nil {
		transport = string(*params.Transport)
	}
	sessionID := ""
	if params.SessionID != nil {
		sessionID = *params.SessionID
	}
	headers := http.Header{}
	for k, v := range params.Headers {
		headers[k] = append([]string(nil), v...)
	}

	rctx := &CopilotRequestContext{
		RequestID: params.RequestID,
		SessionID: sessionID,
		Method:    params.Method,
		URL:       params.URL,
		Headers:   headers,
		Transport: transport,
		body:      bodyCh,
		Context:   ctx,
	}
	sink := &responseSink{requestID: params.RequestID, adapter: a, exchange: exchange}
	go a.runHandler(rctx, sink, exchange)
	return &rpc.LlmInferenceHTTPRequestStartResult{}, nil
}

func (a *copilotRequestAdapter) HttpRequestChunk(params *rpc.LlmInferenceHTTPRequestChunkRequest) (*rpc.LlmInferenceHTTPRequestChunkResult, error) {
	// May arrive before the matching start frame (frames are dispatched on