Add support to validate self-signed certificates

2019-03-26 14:42:28 +01:00
parent 89d363fbaa
commit c1bc96da01
5 changed files with 115 additions and 6 deletions
--- a/backend/src/DataSource/MqttSource.ts
+++ b/backend/src/DataSource/MqttSource.ts
@@ -12,6 +12,7 @@ export interface MqttOptions {
  certValidation: boolean
  clientId?: string
  subscriptions: string[]
+  certificateAuthority?: string
 }

 export class MqttSource implements DataSource<MqttOptions> {
@@ -42,6 +43,7 @@ export class MqttSource implements DataSource<MqttOptions> {
      username: options.username,
      password: options.password,
      clientId: options.clientId,
+      ca: options.certificateAuthority ? Buffer.from(options.certificateAuthority, 'base64') : undefined,
    })

    this.client = client