Skip to content

Commit 99291ad

Browse files
committed
refactor: kRes
1 parent 81027c4 commit 99291ad

File tree

1 file changed

+17
-13
lines changed

1 file changed

+17
-13
lines changed

index.js

Lines changed: 17 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -212,33 +212,35 @@ function onProxyResponse (proxyRes) {
212212
return
213213
}
214214

215-
this[kRes][kProxyRes] = proxyRes
215+
const res = this[kRes]
216+
217+
res[kProxyRes] = proxyRes
216218

217-
proxyRes[kRes] = this[kRes]
219+
proxyRes[kRes] = res
218220

219221
proxyRes.on('aborted', onProxyAborted)
220222

221-
if (this[kRes] instanceof net.Socket) {
223+
if (res instanceof net.Socket) {
222224
if (!proxyRes.upgrade) {
223-
this[kRes].end()
225+
res.end()
224226
}
225227
} else {
226228
setupHeaders(proxyRes.headers)
227229

228-
this[kRes].statusCode = proxyRes.statusCode
230+
res.statusCode = proxyRes.statusCode
229231
for (const key of Object.keys(proxyRes.headers)) {
230-
this[kRes].setHeader(key, proxyRes.headers[key])
232+
res.setHeader(key, proxyRes.headers[key])
231233
}
232234

233235
if (this[kOnProxyRes]) {
234-
this[kOnProxyRes](this[kReq], this[kRes])
236+
this[kOnProxyRes](this[kReq], res)
235237
}
236238

237-
this[kRes].writeHead(this[kRes].statusCode)
239+
res.writeHead(res.statusCode)
238240
proxyRes
239241
.on('end', onProxyTrailers)
240242
.on('error', onFinish)
241-
.pipe(this[kRes])
243+
.pipe(res)
242244
}
243245
}
244246

@@ -255,11 +257,13 @@ function onProxyUpgrade (proxyRes, proxySocket, proxyHead) {
255257
return
256258
}
257259

258-
this[kRes][kProxySocket] = proxySocket
259-
this[kRes][kProxyRes] = proxyRes
260+
const res = this[kRes]
261+
262+
res[kProxySocket] = proxySocket
263+
res[kProxyRes] = proxyRes
260264

261-
proxyRes[kRes] = this[kRes]
262-
proxySocket[kRes] = this[kRes]
265+
proxyRes[kRes] = res
266+
proxySocket[kRes] = res
263267

264268
setupSocket(proxySocket)
265269

0 commit comments

Comments
 (0)