IOT-1157: Avoid too many concurrent connections to chirpstack

Author: VirtualSatai

package-lock.json

@@ -41,6 +41,7 @@
         "ajv": "^6.12.6",
         "axios-cache-adapter": "^2.5.0",
         "bcryptjs": "^2.4.3",
+        "bluebird": "^3.7.2",
         "class-transformer": "^0.3.1",
         "class-validator": "^0.12.2",
         "compression": "^1.7.4",
@@ -67,6 +68,7 @@
     "devDependencies": {
         "@nestjs/cli": "^7.5.4",
         "@nestjs/testing": "^7.6.1",
+        "@types/bluebird": "^3.5.33",
         "@types/compression": "^1.7.0",
         "@types/cookie-parser": "^1.4.2",
         "@types/cron": "^1.7.2",

package.json

@@ -7,7 +7,7 @@ import {
     NotFoundException,
 } from "@nestjs/common";
 import { AxiosResponse } from "axios";
-
+import * as BluebirdPromise from "bluebird";
 import { ChirpstackErrorResponseDto } from "@dto/chirpstack/chirpstack-error-response.dto";
 import { ChirpstackResponseStatus } from "@dto/chirpstack/chirpstack-response.dto";
 import { CreateGatewayDto } from "@dto/chirpstack/create-gateway.dto";
@@ -113,19 +113,25 @@ export class ChirpstackGatewayService extends GenericChirpstackConfigurationServ
     }
 
     private async enrichWithOrganizationId(results: GatewayResponseDto[]) {
-        await Promise.all(
-            results.map(async x => {
-                try {
-                    const gw = await this.getOne(x.id);
-                    x.internalOrganizationId = gw.gateway.internalOrganizationId;
-                } catch (err) {
-                    this.logger.error(
-                        `Failed to fetch gateway details for id ${x.id}`,
-                        err
-                    );
-                    x.internalOrganizationId = null;
+        await BluebirdPromise.all(
+            BluebirdPromise.map(
+                results,
+                async x => {
+                    try {
+                        const gw = await this.getOne(x.id);
+                        x.internalOrganizationId = gw.gateway.internalOrganizationId;
+                    } catch (err) {
+                        this.logger.error(
+                            `Failed to fetch gateway details for id ${x.id}`,
+                            err
+                        );
+                        x.internalOrganizationId = null;
+                    }
+                },
+                {
+                    concurrency: 50,
                 }
-            })
+            )
         );
     }