| 771 | } |
| 772 | |
| 773 | func (nc *Conn) wsUpdateConnectionHeaders(req *http.Request) error { |
| 774 | var headers http.Header |
| 775 | var err error |
| 776 | if nc.Opts.WebSocketConnectionHeadersHandler != nil { |
| 777 | headers, err = nc.Opts.WebSocketConnectionHeadersHandler() |
| 778 | if err != nil { |
| 779 | return err |
| 780 | } |
| 781 | } else { |
| 782 | headers = nc.Opts.WebSocketConnectionHeaders |
| 783 | } |
| 784 | for key, values := range headers { |
| 785 | for _, val := range values { |
| 786 | req.Header.Add(key, val) |
| 787 | } |
| 788 | } |
| 789 | return nil |
| 790 | } |
| 791 | |
| 792 | func wsPMCExtensionSupport(header http.Header) (bool, bool) { |
| 793 | for _, extensionList := range header["Sec-Websocket-Extensions"] { |