test: add ALS test using http agent keep alive

Add a test to verify AsyncLocalStore functionality for HTTP using a
keep alive agent.
AsyncLocalStore moves away from using async_hooks therefore relying on
async_hooks tests alone is not longer valid.
PR-URL: #58017
Refs: #55712
Refs: #13325
Reviewed-By: Luigi Pinca <luigipinca@gmail.com>
Reviewed-By: Stephen Belanger <admin@stephenbelanger.com>
Reviewed-By: James M Snell <jasnell@gmail.com>

Author: Flarna

test/parallel/test-async-local-storage-http-agent.js

@@ -0,0 +1,83 @@
+'use strict';
+constcommon=require('../common');
+constassert=require('node:assert');
+const{ AsyncLocalStorage }=require('node:async_hooks');
+consthttp=require('node:http');
+
+// Similar as test-async-hooks-http-agent added via
+// https://github.com/nodejs/node/issues/13325 but verifies
+// AsyncLocalStorage functionality instead async_hooks
+
+constcls=newAsyncLocalStorage();
+
+// Make sure a single socket is transparently reused for 2 requests.
+constagent=newhttp.Agent({
+keepAlive: true,
+keepAliveMsecs: Infinity,
+maxSockets: 1
+});
+
+constserver=http.createServer(common.mustCall((req,res)=>{
+req.once('data',common.mustCallAtLeast(()=>{
+res.writeHead(200,{'Content-Type': 'text/plain'});
+res.write('foo');
+}));
+req.on('end',common.mustCall(()=>{
+res.end('bar');
+}));
+},2)).listen(0,common.mustCall(()=>{
+constport=server.address().port;
+constpayload='hello world';
+
+// First request. This is useless except for adding a socket to the
+// agent’s pool for reuse.
+cls.run('first',common.mustCall(()=>{
+assert.strictEqual(cls.getStore(),'first');
+constr1=http.request({
+ agent, port,method: 'POST'
+},common.mustCall((res)=>{
+assert.strictEqual(cls.getStore(),'first');
+res.on('data',common.mustCallAtLeast(()=>{
+assert.strictEqual(cls.getStore(),'first');
+}));
+res.on('end',common.mustCall(()=>{
+assert.strictEqual(cls.getStore(),'first');
+// setImmediate() to give the agent time to register the freed socket.
+setImmediate(common.mustCall(()=>{
+assert.strictEqual(cls.getStore(),'first');
+
+cls.run('second',common.mustCall(()=>{
+// Second request. To re-create the exact conditions from the
+// referenced issue, we use a POST request without chunked encoding
+// (hence the Content-Length header) and call .end() after the
+// response header has already been received.
+constr2=http.request({
+ agent, port,method: 'POST',headers: {
+'Content-Length': payload.length
+}
+},common.mustCall((res)=>{
+assert.strictEqual(cls.getStore(),'second');
+// Empty payload, to hit the “right” code path.
+r2.end('');
+
+res.on('data',common.mustCallAtLeast(()=>{
+assert.strictEqual(cls.getStore(),'second');
+}));
+res.on('end',common.mustCall(()=>{
+assert.strictEqual(cls.getStore(),'second');
+// Clean up to let the event loop stop.
+server.close();
+agent.destroy();
+}));
+}));
+
+// Schedule a payload to be written immediately, but do not end the
+// request just yet.
+r2.write(payload);
+}));
+}));
+}));
+}));
+r1.end(payload);
+}));
+}));