(ctx context.Context, resp WebSocketResponseWriter)
| 399 | } |
| 400 | |
| 401 | func (f *CopilotWebSocketForwarder) Open(ctx context.Context, resp WebSocketResponseWriter) error { |
| 402 | f.resp = resp |
| 403 | if f.done == nil { |
| 404 | f.done = make(chan struct{}) |
| 405 | } |
| 406 | opts := &websocket.DialOptions{HTTPHeader: f.dialHeaders()} |
| 407 | conn, _, err := websocket.Dial(ctx, f.URL, opts) |
| 408 | if err != nil { |
| 409 | return err |
| 410 | } |
| 411 | conn.SetReadLimit(-1) |
| 412 | f.conn = conn |
| 413 | go f.receiveLoop(ctx) |
| 414 | return nil |
| 415 | } |
| 416 | |
| 417 | func (f *CopilotWebSocketForwarder) dialHeaders() http.Header { |
| 418 | out := http.Header{} |
nothing calls this directly
no test coverage detected