feat(origin-device-registry-irec-form-api): added validate device own…

…ership hander

packages/devices/origin-device-registry-irec-form-api/src/device/device.module.ts

@@ -7,6 +7,7 @@ import { TypeOrmModule } from '@nestjs/typeorm';
 import { DeviceController } from './device.controller';
 import { Device } from './device.entity';
 import { DeviceService, SM_READS_ADAPTER } from './device.service';
+import { ValidateDeviceOwnershipQueryHandler } from './handlers/validate-device-ownership.handler';
 
 @Module({})
 export class DeviceModule {
@@ -19,7 +20,8 @@ export class DeviceModule {
                     provide: SM_READS_ADAPTER,
                     useValue: smartMeterReadingsAdapter
                 },
-                DeviceService
+                DeviceService,
+                ValidateDeviceOwnershipQueryHandler
             ],
             controllers: [DeviceController],
             exports: [DeviceService]

packages/devices/origin-device-registry-irec-form-api/src/device/handlers/validate-device-ownership.handler.ts

@@ -0,0 +1,26 @@
+import { ValidateDeviceOwnershipQuery } from '@energyweb/origin-backend-core';
+import { ConfigService } from '@nestjs/config';
+import { IQueryHandler, QueryHandler } from '@nestjs/cqrs';
+import { DeviceService } from '../device.service';
+
+@QueryHandler(ValidateDeviceOwnershipQuery)
+export class ValidateDeviceOwnershipQueryHandler
+    implements IQueryHandler<ValidateDeviceOwnershipQuery> {
+    private issuerTypeId: string;
+
+    constructor(private readonly deviceService: DeviceService, configService: ConfigService) {
+        this.issuerTypeId = configService.get<string>('ISSUER_ID');
+    }
+
+    public async execute({
+        ownerId,
+        externalRegistryId
+    }: ValidateDeviceOwnershipQuery): Promise<boolean> {
+        const device = await this.deviceService.findByExternalId({
+            id: externalRegistryId,
+            type: this.issuerTypeId
+        });
+
+        return device?.organizationId === parseInt(ownerId, 10);
+    }
+}