(ws, code, reason, reasonByteLength)
| 17608 | const requestURL = url; |
| 17609 | requestURL.protocol = url.protocol === "ws:" ? "http:" : "https:"; |
| 17610 | const request = makeRequest({ |
| 17611 | urlList: [requestURL], |
| 17612 | client, |
| 17613 | serviceWorkers: "none", |
| 17614 | referrer: "no-referrer", |
| 17615 | mode: "websocket", |
| 17616 | credentials: "include", |
| 17617 | cache: "no-store", |
| 17618 | redirect: "error" |
| 17619 | }); |
| 17620 | if (options.headers) { |
| 17621 | const headersList = getHeadersList(new Headers2(options.headers)); |
| 17622 | request.headersList = headersList; |
| 17623 | } |
| 17624 | const keyValue = crypto2.randomBytes(16).toString("base64"); |
| 17625 | request.headersList.append("sec-websocket-key", keyValue); |
| 17626 | request.headersList.append("sec-websocket-version", "13"); |
| 17627 | for (const protocol of protocols) { |
| 17628 | request.headersList.append("sec-websocket-protocol", protocol); |
| 17629 | } |
| 17630 | const permessageDeflate = "permessage-deflate; client_max_window_bits"; |
| 17631 | request.headersList.append("sec-websocket-extensions", permessageDeflate); |
| 17632 | const controller = fetching({ |
| 17633 | request, |
| 17634 | useParallelQueue: true, |
| 17635 | dispatcher: options.dispatcher, |
| 17636 | processResponse(response) { |
| 17637 | var _a, _b; |
| 17638 | if (response.type === "error" || response.status !== 101) { |
no test coverage detected