Skip to content

Commit 54f7940

Browse files
committed
feat: pass socket to onRes for ws
1 parent 5d238a8 commit 54f7940

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

README.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -109,9 +109,9 @@ See [`upgrade`](https://nodejs.org/api/http.html#http_event_upgrade)
109109
- `onReq(req, options)`: called before proxy request
110110
- `req`: [`http.IncomingMessage`](https://nodejs.org/api/http.html#http_class_http_incomingmessage) or [`http2.Http2ServerRequest`](https://nodejs.org/api/http2.html#http2_class_http2_http2serverrequest)
111111
- `options`: options passed to [`http.request(options)`](https://nodejs.org/api/http.html#http_http_request_options_callback)
112-
- `onRes(req, res)`: called before proxy response
112+
- `onRes(req, resOrSocket)`: called before proxy response
113113
- `req`: [`http.IncomingMessage`](https://nodejs.org/api/http.html#http_class_http_incomingmessage) or [`http2.Http2ServerRequest`](https://nodejs.org/api/http2.html#http2_class_http2_http2serverrequest)
114-
- `res`: [`http.ServerResponse`](https://nodejs.org/api/http.html#http_http_request_options_callback) or [`http2.Http2ServerResponse`](https://nodejs.org/api/http2.html#http2_class_http2_http2serverresponse)
114+
- `resOrSocket`: For `web` [`http.ServerResponse`](https://nodejs.org/api/http.html#http_http_request_options_callback) or [`http2.Http2ServerResponse`](https://nodejs.org/api/http2.html#http2_class_http2_http2serverresponse) and for `ws` [`net.Socket`](https://nodejs.org/api/net.html#net_class_net_socket)
115115

116116
### License
117117

index.js

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -179,6 +179,10 @@ function proxy (req, resOrSocket, options, onRes, onError) {
179179
proxyRes.on('aborted', () => callback(createError('socket hang up', 'ECONNRESET', 502)))
180180

181181
if (resOrSocket instanceof net.Socket) {
182+
if (onRes) {
183+
onRes(req, resOrSocket)
184+
}
185+
182186
if (!proxyRes.upgrade) {
183187
resOrSocket.end()
184188
}

0 commit comments

Comments
 (0)