New user management multiple levels

package.json

@@ -58,12 +58,14 @@
         "mqtt": "^4.2.6",
         "nestjs-pino": "^1.3.0",
         "njwt": "^1.0.0",
+        "nodemailer": "^6.7.2",
         "passport": "^0.4.1",
         "passport-headerapikey": "^1.2.2",
         "passport-jwt": "^4.0.0",
         "passport-local": "^1.0.0",
         "passport-saml": "^1.3.5",
         "pg": "^8.5.1",
+        "protobufjs": "^6.11.2",
         "reflect-metadata": "^0.1.13",
         "rimraf": "^3.0.2",
         "rxjs": "^6.6.3",
@@ -83,6 +85,7 @@
         "@types/express": "^4.17.9",
         "@types/lodash": "^4.14.165",
         "@types/node": "^14.14.14",
+        "@types/nodemailer": "^6.4.4",
         "@types/passport-jwt": "^3.0.3",
         "@types/passport-local": "^1.0.33",
         "@types/supertest": "^2.0.10",

resources/chirpstack-state.proto

@@ -0,0 +1,16 @@
+syntax = "proto3";
+
+package gw;
+
+// ConnState contains the connection state of a gateway.
+message ConnState {
+    // Gateway ID.
+    bytes gateway_id = 1 [json_name = "gatewayID"];
+
+    enum State {
+        OFFLINE = 0;
+        ONLINE = 1;
+    }
+
+    State state = 2;
+}

src/config/configuration.ts

@@ -35,5 +35,16 @@ export default (): any => {
         logLevels: process.env.LOG_LEVEL
             ? GetLogLevels(process.env.LOG_LEVEL)
             : GetLogLevels("debug"),
-    };
+        email: {
+            host: process.env.EMAIL_HOST || "smtp.ethereal.email",
+            port: process.env.EMAIL_PORT || 587,
+            user: process.env.EMAIL_USER || "[email protected]",
+            pass: process.env.EMAIL_PASS || "KzRSyYReEygpFPPZdd",
+            from: process.env.EMAIL_FROM || "[email protected]"
+        },
+        frontend: {
+            baseurl:
+                process.env.FRONTEND_BASEURL || "http://localhost:8081"
+            }
+    	};
 };

src/controllers/admin-controller/lorawan/lorawan-gateway.controller.ts

@@ -0,0 +1,50 @@
+import { ComposeAuthGuard } from "@auth/compose-auth.guard";
+import { Read } from "@auth/roles.decorator";
+import { RolesGuard } from "@auth/roles.guard";
+import {
+    GatewayGetAllStatusResponseDto,
+    ListAllGatewayStatusDto,
+} from "@dto/chirpstack/backend/gateway-all-status.dto";
+import { GatewayStatus, GetGatewayStatusQuery } from "@dto/chirpstack/backend/gateway-status.dto";
+import { AuthenticatedRequest } from "@dto/internal/authenticated-request";
+import { Controller, Get, Param, Query, Req, UseGuards } from "@nestjs/common";
+import { ApiBearerAuth, ApiOperation, ApiProduces, ApiTags } from "@nestjs/swagger";
+import { ChirpstackGatewayService } from "@services/chirpstack/chirpstack-gateway.service";
+import { GatewayStatusHistoryService } from "@services/chirpstack/gateway-status-history.service";
+import { checkIfUserHasAccessToOrganization, OrganizationAccessScope } from "@helpers/security-helper";
+
+@ApiTags("LoRaWAN gateway")
+@Controller("lorawan/gateway")
+@UseGuards(ComposeAuthGuard, RolesGuard)
+@ApiBearerAuth()
+export class LoRaWANGatewayController {
+    constructor(
+        private onlineHistoryService: GatewayStatusHistoryService,
+        private chirpstackGatewayService: ChirpstackGatewayService
+    ) {}
+
+    @Get("/status")
+    @ApiProduces("application/json")
+    @ApiOperation({ summary: "Get the status for all LoRaWAN gateways" })
+    @Read()
+    async getAllStatus(
+        @Req() req: AuthenticatedRequest,
+        @Query() query: ListAllGatewayStatusDto
+    ): Promise<GatewayGetAllStatusResponseDto> {
+        // Currently, everyone is allowed to get the status
+        return this.onlineHistoryService.findAllWithChirpstack(query);
+    }
+
+    @Get("/status/:id")
+    @ApiProduces("application/json")
+    @ApiOperation({ summary: "Get the status for a LoRaWAN gateway" })
+    async getStatus(
+        @Req() req: AuthenticatedRequest,
+        @Param("id") id: string,
+        @Query() query: GetGatewayStatusQuery
+    ): Promise<GatewayStatus> {
+        // Currently, everyone is allowed to get the status
+        const gatewayDto = await this.chirpstackGatewayService.getOne(id);
+        return this.onlineHistoryService.findOne(gatewayDto.gateway, query.timeInterval);
+    }
+}

src/controllers/admin-controller/sigfox/sigfox-group.controller.ts

@@ -68,7 +68,7 @@ export class SigfoxGroupController {
 
     @Get(":id")
     @ApiProduces("application/json")
-    @ApiOperation({ summary: "List a SigFox Groups" })
+    @ApiOperation({ summary: "Get one group by ID" })
     @Read()
     async getOne(
         @Req() req: AuthenticatedRequest,
@@ -78,7 +78,7 @@ export class SigfoxGroupController {
         try {
             group = await this.service.findOne(id);
         } catch (err) {
-            throw new NotFoundException();
+			return null;            
         }
         checkIfUserHasAccessToOrganization(req, group.belongsTo.id, OrganizationAccessScope.ApplicationRead);
         return group;

src/controllers/device-data-controller/receive-data.controller.ts

@@ -44,7 +44,7 @@ export class ReceiveDataController {
         // @HACK: Convert the 'data' back to a string.
         // NestJS / BodyParser always converts the input to an object for us.
         const dataAsString = JSON.stringify(data);
-        await this.receiveDataService.sendToKafka(
+        await this.receiveDataService.sendRawIotDeviceRequestToKafka(
             iotDevice,
             dataAsString,
             IoTDeviceType.GenericHttp.toString()

src/controllers/device-data-controller/sigfox-listener.controller.ts

@@ -49,7 +49,7 @@ export class SigFoxListenerController {
         const sigfoxDevice = await this.findSigFoxDevice(data);
 
         const dataAsString = JSON.stringify(data);
-        await this.receiveDataService.sendToKafka(
+        await this.receiveDataService.sendRawIotDeviceRequestToKafka(
             sigfoxDevice,
             dataAsString,
             IoTDeviceType.SigFox.toString(),

src/controllers/user-management/auth.controller.ts

@@ -31,7 +31,6 @@ import {
 import { JwtPayloadDto } from "@dto/internal/jwt-payload.dto";
 import { LoginDto } from "@dto/login.dto";
 import { Organization } from "@entities/organization.entity";
-import { OrganizationPermission } from "@entities/permissions/organization-permission.entity";
 import { User } from "@entities/user.entity";
 import { PermissionType } from "@enum/permission-type.enum";
 import { AuthService } from "@services/user-management/auth.service";