Fix authentication
This commit is contained in:
@@ -3,7 +3,7 @@ import { EventDispatcher } from '../../../events'
|
||||
export interface DataSourceState {
|
||||
connecting: boolean
|
||||
connected: boolean
|
||||
error?: Error
|
||||
error?: string
|
||||
}
|
||||
|
||||
export class DataSourceStateMachine {
|
||||
@@ -25,7 +25,7 @@ export class DataSourceStateMachine {
|
||||
|
||||
public setError(error: Error) {
|
||||
this.state = {
|
||||
error,
|
||||
error: error.message,
|
||||
connected: false,
|
||||
connecting: false,
|
||||
}
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
import * as Url from 'url'
|
||||
|
||||
import { Client, connect as mqttConnect } from 'mqtt'
|
||||
import { DataSource, DataSourceStateMachine } from './'
|
||||
import * as Url from 'url'
|
||||
|
||||
export interface MqttOptions {
|
||||
url: string
|
||||
@@ -36,6 +37,8 @@ export class MqttSource implements DataSource<MqttOptions> {
|
||||
const client = mqttConnect(url, {
|
||||
resubscribe: false,
|
||||
rejectUnauthorized: !options.certValidation,
|
||||
username: options.username,
|
||||
password: options.password,
|
||||
})
|
||||
|
||||
this.client = client
|
||||
|
||||
Reference in New Issue
Block a user