Accept mqtts:// and self-signed brokers

Author: AramAlsabti

src/entities/dto/create-data-target.dto.ts

@@ -44,7 +44,11 @@ export class CreateDataTargetDto {
     @IsString()
     @MaxLength(1024)
     @IsNotBlank("url")
-    @IsUrl({ require_tld: false, require_protocol: true })
+    @IsUrl({
+        require_tld: false,
+        require_protocol: true,
+        protocols: ["http", "https", "mqtt", "mqtts"],
+    })
     url: string;
 
     @ApiProperty({ required: true, example: 30000 })

src/services/data-targets/mqtt-data-target.service.ts

@@ -32,6 +32,8 @@ export class MqttDataTargetService extends BaseDataTargetService {
             password: config.password,
             port: config.port,
             connectTimeout: config.timeout,
+            // Accept connection to servers with self-signed certificates
+            rejectUnauthorized: false,
         });
         const targetForLogging = `MqttDataTarget(URL '${config.url}', topic '${config.topic}')`;