@@ -90,9 +90,9 @@ function address(port: number) {
90
90
91
91
describe ( "#createProxyServer.web() using own http server" , ( ) => {
92
92
it ( "gets some ports" , async ( ) => {
93
- ports [ "8080" ] = await getPort ( ) ;
94
- ports [ "8081" ] = await getPort ( ) ;
95
- ports [ "8082" ] = await getPort ( ) ;
93
+ for ( let n = 8080 ; n < 8090 ; n ++ ) {
94
+ ports [ ` ${ n } ` ] = await getPort ( ) ;
95
+ }
96
96
} ) ;
97
97
98
98
it ( "should proxy the request using the web proxy handler" , ( done ) => {
@@ -227,19 +227,17 @@ describe("#createProxyServer.web() using own http server", () => {
227
227
client . end ( ) ;
228
228
} ) ;
229
229
230
- /*
231
-
232
230
it ( "should proxy the request and handle error via event listener" , ( done ) => {
233
231
const proxy = httpProxy . createProxyServer ( {
234
232
target : address ( 8080 ) ,
233
+ timeout : 100 ,
235
234
} ) ;
236
235
237
236
const proxyServer = http . createServer ( requestHandler ) ;
238
237
239
238
function requestHandler ( req , res ) {
240
239
proxy . once ( "error" , ( err , errReq , errRes ) => {
241
240
proxyServer . close ( ) ;
242
- expect(err).toBeInstanceOf(Error);
243
241
expect ( errReq ) . toEqual ( req ) ;
244
242
expect ( errRes ) . toEqual ( res ) ;
245
243
expect ( err . code ) . toEqual ( "ECONNREFUSED" ) ;
@@ -249,31 +247,31 @@ describe("#createProxyServer.web() using own http server", () => {
249
247
proxy . web ( req , res ) ;
250
248
}
251
249
252
- proxyServer.listen("8083");
250
+ proxyServer . listen ( ports [ "8083" ] ) ;
253
251
254
- http
255
- .request(
256
- {
257
- hostname: "127.0.0.1" ,
258
- port : "8083 ",
259
- method: "GET" ,
260
- },
261
- () => {},
262
- )
263
- .end();
252
+ const client = http . request (
253
+ {
254
+ hostname : "127.0.0.1" ,
255
+ port : ports [ "8083" ] ,
256
+ method : "GET " ,
257
+ } ,
258
+ ( ) => { } ,
259
+ ) ;
260
+ client . on ( "error" , ( ) => { } ) ;
261
+ client . end ( ) ;
264
262
} ) ;
265
263
266
264
it ( "should forward the request and handle error via event listener" , ( done ) => {
267
265
const proxy = httpProxy . createProxyServer ( {
268
266
forward : "http://127.0.0.1:8080" ,
267
+ timeout : 100 ,
269
268
} ) ;
270
269
271
270
const proxyServer = http . createServer ( requestHandler ) ;
272
271
273
272
function requestHandler ( req , res ) {
274
273
proxy . once ( "error" , ( err , errReq , errRes ) => {
275
274
proxyServer . close ( ) ;
276
- expect(err).toBeInstanceOf(Error);
277
275
expect ( errReq ) . toEqual ( req ) ;
278
276
expect ( errRes ) . toEqual ( res ) ;
279
277
expect ( err . code ) . toEqual ( "ECONNREFUSED" ) ;
@@ -283,66 +281,66 @@ describe("#createProxyServer.web() using own http server", () => {
283
281
proxy . web ( req , res ) ;
284
282
}
285
283
286
- proxyServer.listen("8083");
284
+ proxyServer . listen ( ports [ "8083" ] ) ;
287
285
288
- http
289
- .request(
290
- {
291
- hostname: "127.0.0.1" ,
292
- port : "8083 ",
293
- method: "GET" ,
294
- },
295
- () => {},
296
- )
297
- .end();
286
+ const client = http . request (
287
+ {
288
+ hostname : "127.0.0.1" ,
289
+ port : ports [ "8083" ] ,
290
+ method : "GET " ,
291
+ } ,
292
+ ( ) => { } ,
293
+ ) ;
294
+ client . on ( "error" , ( ) => { } ) ;
295
+ client . end ( ) ;
298
296
} ) ;
299
297
300
298
it ( "should proxy the request and handle timeout error (proxyTimeout)" , ( done ) => {
301
299
const proxy = httpProxy . createProxyServer ( {
302
- target: "http://127.0.0.1:45000" ,
300
+ target : address ( 8083 ) ,
303
301
proxyTimeout : 100 ,
302
+ timeout : 150 , // so client exits and isn't left handing the test.
304
303
} ) ;
305
304
306
- require("net").createServer().listen(45000 );
305
+ const server = require ( "net" ) . createServer ( ) . listen ( ports [ "8083" ] ) ;
307
306
308
- const proxyServer = http.createServer(requestHandler);
309
-
310
- const started = new Date().getTime();
307
+ const started = Date . now ( ) ;
311
308
function requestHandler ( req , res ) {
312
309
proxy . once ( "error" , ( err , errReq , errRes ) => {
313
310
proxyServer . close ( ) ;
314
- expect(err).toBeInstanceOf(Error );
311
+ server . close ( ) ;
315
312
expect ( errReq ) . toEqual ( req ) ;
316
313
expect ( errRes ) . toEqual ( res ) ;
317
- expect(new Date().getTime () - started).toBeGreaterThan(99);
314
+ expect ( Date . now ( ) - started ) . toBeGreaterThan ( 99 ) ;
318
315
expect ( err . code ) . toEqual ( "ECONNRESET" ) ;
319
316
done ( ) ;
320
317
} ) ;
321
318
322
319
proxy . web ( req , res ) ;
323
320
}
324
321
325
- proxyServer.listen("8084");
322
+ const proxyServer = http . createServer ( requestHandler ) ;
323
+ proxyServer . listen ( ports [ "8084" ] ) ;
326
324
327
- http
328
- .request(
329
- {
330
- hostname: "127.0.0.1" ,
331
- port : "8084 ",
332
- method: "GET" ,
333
- },
334
- () => {},
335
- )
336
- .end();
325
+ const client = http . request (
326
+ {
327
+ hostname : "127.0.0.1" ,
328
+ port : ports [ "8084" ] ,
329
+ method : "GET " ,
330
+ } ,
331
+ ( ) => { } ,
332
+ ) ;
333
+ client . on ( "error" , ( ) => { } ) ;
334
+ client . end ( ) ;
337
335
} ) ;
338
336
339
337
it ( "should proxy the request and handle timeout error" , ( done ) => {
340
338
const proxy = httpProxy . createProxyServer ( {
341
- target: "http://127.0.0.1:45001" ,
339
+ target : address ( 8083 ) ,
342
340
timeout : 100 ,
343
341
} ) ;
344
342
345
- require("net").createServer().listen(45001 );
343
+ const server = require ( "net" ) . createServer ( ) . listen ( ports [ "8083" ] ) ;
346
344
347
345
const proxyServer = http . createServer ( requestHandler ) ;
348
346
@@ -352,11 +350,11 @@ describe("#createProxyServer.web() using own http server", () => {
352
350
if ( cnt === 2 ) done ( ) ;
353
351
} ;
354
352
355
- const started = new Date().getTime ();
353
+ const started = Date . now ( ) ;
356
354
function requestHandler ( req , res ) {
357
355
proxy . once ( "econnreset" , ( err , errReq , errRes ) => {
358
356
proxyServer . close ( ) ;
359
- expect(err).toBeInstanceOf(Error );
357
+ server . close ( ) ;
360
358
expect ( errReq ) . toEqual ( req ) ;
361
359
expect ( errRes ) . toEqual ( res ) ;
362
360
expect ( err . code ) . toEqual ( "ECONNRESET" ) ;
@@ -366,26 +364,26 @@ describe("#createProxyServer.web() using own http server", () => {
366
364
proxy . web ( req , res ) ;
367
365
}
368
366
369
- proxyServer.listen("8085");
367
+ proxyServer . listen ( ports [ "8085" ] ) ;
370
368
371
369
const req = http . request (
372
370
{
373
371
hostname : "127.0.0.1" ,
374
- port: "8085",
372
+ port : ports [ "8085" ] ,
375
373
method : "GET" ,
376
374
} ,
377
375
( ) => { } ,
378
376
) ;
379
377
380
378
req . on ( "error" , ( err ) => {
381
- expect(err).toBeInstanceOf(Error);
382
379
// @ts -ignore
383
380
expect ( err . code ) . toEqual ( "ECONNRESET" ) ;
384
- expect(new Date().getTime () - started).toBeGreaterThan(99);
381
+ expect ( Date . now ( ) - started ) . toBeGreaterThan ( 99 ) ;
385
382
doneOne ( ) ;
386
383
} ) ;
387
384
req . end ( ) ;
388
385
} ) ;
386
+ /*
389
387
390
388
it("should proxy the request and provide a proxyRes event with the request and response parameters", (done) => {
391
389
const proxy = httpProxy.createProxyServer({
@@ -788,7 +786,6 @@ describe("#createProxyServer.web() using own http server", () => {
788
786
function requestHandler(req, res) {
789
787
proxy.web(req, res, function (err) {
790
788
proxyServer.close();
791
- expect(err).toBeInstanceOf(Error);
792
789
expect(err.code).toEqual("ECONNREFUSED");
793
790
done();
794
791
});
@@ -818,7 +815,6 @@ describe("#createProxyServer.web() using own http server", () => {
818
815
function requestHandler(req, res) {
819
816
proxy.once("error", function (err, errReq, errRes) {
820
817
proxyServer.close();
821
- expect(err).toBeInstanceOf(Error);
822
818
expect(errReq).toEqual(req);
823
819
expect(errRes).toEqual(res);
824
820
expect(err.code).toEqual("ECONNREFUSED");
@@ -852,7 +848,6 @@ describe("#createProxyServer.web() using own http server", () => {
852
848
function requestHandler(req, res) {
853
849
proxy.once("error", function (err, errReq, errRes) {
854
850
proxyServer.close();
855
- expect(err).toBeInstanceOf(Error);
856
851
expect(errReq).toEqual(req);
857
852
expect(errRes).toEqual(res);
858
853
expect(err.code).toEqual("ECONNREFUSED");
@@ -886,14 +881,13 @@ describe("#createProxyServer.web() using own http server", () => {
886
881
887
882
const proxyServer = http.createServer(requestHandler);
888
883
889
- const started = new Date().getTime ();
884
+ const started = Date.now ();
890
885
function requestHandler(req, res) {
891
886
proxy.once("error", function (err, errReq, errRes) {
892
887
proxyServer.close();
893
- expect(err).toBeInstanceOf(Error);
894
888
expect(errReq).toEqual(req);
895
889
expect(errRes).toEqual(res);
896
- expect(new Date().getTime () - started).to.be.greaterThan(99);
890
+ expect(Date.now () - started).to.be.greaterThan(99);
897
891
expect(err.code).toEqual("ECONNRESET");
898
892
done();
899
893
});
@@ -931,11 +925,10 @@ describe("#createProxyServer.web() using own http server", () => {
931
925
if (cnt === 2) done();
932
926
};
933
927
934
- const started = new Date().getTime ();
928
+ const started = Date.now ();
935
929
function requestHandler(req, res) {
936
930
proxy.once("econnreset", function (err, errReq, errRes) {
937
931
proxyServer.close();
938
- expect(err).toBeInstanceOf(Error);
939
932
expect(errReq).toEqual(req);
940
933
expect(errRes).toEqual(res);
941
934
expect(err.code).toEqual("ECONNRESET");
@@ -957,9 +950,8 @@ describe("#createProxyServer.web() using own http server", () => {
957
950
);
958
951
959
952
req.on("error", function (err) {
960
- expect(err).toBeInstanceOf(Error);
961
953
expect(err.code).toEqual("ECONNRESET");
962
- expect(new Date().getTime () - started).to.be.greaterThan(99);
954
+ expect(Date.now () - started).to.be.greaterThan(99);
963
955
doneOne();
964
956
});
965
957
req.end();
0 commit comments