test: align monitor parallelization tests with new env var and default

Use SNYK_INTERNAL_REQUEST_CONCURRENCY (the internal env var the TS code
now reads) and assert the new default of 5.

Author: bgardiner

test/jest/unit/ecosystems-monitor-docker.spec.ts

@@ -287,13 +287,13 @@ describe('monitorEcosystem docker/container', () => {
   });
 
   describe('parallelization of monitor-dependencies requests', () => {
-    const ORIGINAL_CONCURRENCY = process.env.SNYK_REQUEST_CONCURRENCY;
+    const ORIGINAL_CONCURRENCY = process.env.SNYK_INTERNAL_REQUEST_CONCURRENCY;
 
     afterEach(() => {
       if (ORIGINAL_CONCURRENCY === undefined) {
-        delete process.env.SNYK_REQUEST_CONCURRENCY;
+        delete process.env.SNYK_INTERNAL_REQUEST_CONCURRENCY;
       } else {
-        process.env.SNYK_REQUEST_CONCURRENCY = ORIGINAL_CONCURRENCY;
+        process.env.SNYK_INTERNAL_REQUEST_CONCURRENCY = ORIGINAL_CONCURRENCY;
       }
     });
 
@@ -327,8 +327,8 @@ describe('monitorEcosystem docker/container', () => {
       });
     }
 
-    it('caps in-flight requests at the default concurrency (10)', async () => {
-      delete process.env.SNYK_REQUEST_CONCURRENCY;
+    it('caps in-flight requests at the default concurrency (5)', async () => {
+      delete process.env.SNYK_INTERNAL_REQUEST_CONCURRENCY;
       const scanResults = Array.from({ length: 25 }, (_, i) =>
         makeMavenScanResult(`app-${i}`),
       );
@@ -349,12 +349,12 @@ describe('monitorEcosystem docker/container', () => {
 
       await runMonitor(scanResults);
 
-      expect(peakInFlight).toBeLessThanOrEqual(10);
+      expect(peakInFlight).toBeLessThanOrEqual(5);
       expect(peakInFlight).toBeGreaterThan(1);
     });
 
-    it('respects SNYK_REQUEST_CONCURRENCY override', async () => {
-      process.env.SNYK_REQUEST_CONCURRENCY = '3';
+    it('respects SNYK_INTERNAL_REQUEST_CONCURRENCY override', async () => {
+      process.env.SNYK_INTERNAL_REQUEST_CONCURRENCY = '3';
       const scanResults = Array.from({ length: 15 }, (_, i) =>
         makeMavenScanResult(`app-${i}`),
       );
@@ -379,7 +379,7 @@ describe('monitorEcosystem docker/container', () => {
     });
 
     it('preserves result order matching input order', async () => {
-      delete process.env.SNYK_REQUEST_CONCURRENCY;
+      delete process.env.SNYK_INTERNAL_REQUEST_CONCURRENCY;
       const scanResults = ['os', 'app-1', 'app-2', 'app-3', 'app-4'].map(
         makeMavenScanResult,
       );
@@ -410,7 +410,7 @@ describe('monitorEcosystem docker/container', () => {
     });
 
     it('throws MonitorError when any request returns 4xx (fail-fast)', async () => {
-      delete process.env.SNYK_REQUEST_CONCURRENCY;
+      delete process.env.SNYK_INTERNAL_REQUEST_CONCURRENCY;
       const scanResults = ['app-1', 'app-2', 'app-3'].map(makeMavenScanResult);
 
       jest.spyOn(request, 'makeRequest').mockImplementation((payload: any) => {
@@ -425,7 +425,7 @@ describe('monitorEcosystem docker/container', () => {
     });
 
     it('accumulates 5xx errors per scan-result without aborting', async () => {
-      delete process.env.SNYK_REQUEST_CONCURRENCY;
+      delete process.env.SNYK_INTERNAL_REQUEST_CONCURRENCY;
       const scanResults = ['app-1', 'app-2', 'app-3'].map(makeMavenScanResult);
 
       jest.spyOn(request, 'makeRequest').mockImplementation((payload: any) => {