fix: buffer is not defined in browser (#1420)

mqttjs · Feb 17, 2022 · f5ab1b5 · f5ab1b5
1 parent fad8ad6
commit f5ab1b5
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 11 deletions.
diff --git a/lib/connect/ali.js b/lib/connect/ali.js
@@ -1,5 +1,6 @@
 'use strict'
 
+const { Buffer } = require('buffer')
 const Transform = require('readable-stream').Transform
 const duplexify = require('duplexify')
 

diff --git a/lib/connect/ws.js b/lib/connect/ws.js
@@ -1,5 +1,6 @@
 'use strict'
 
+const { Buffer } = require('buffer')
 const WS = require('ws')
 const debug = require('debug')('mqttjs:ws')
 const duplexify = require('duplexify')

diff --git a/lib/connect/wx.js b/lib/connect/wx.js
@@ -1,5 +1,6 @@
 'use strict'
 
+const { Buffer } = require('buffer')
 const Transform = require('readable-stream').Transform
 const duplexify = require('duplexify')
 

diff --git a/types/lib/connect/index.d.ts b/types/lib/connect/index.d.ts
@@ -1,25 +1,19 @@
-import { IClientOptions, MqttClient } from "../client";
-/**
- * connect - connect to an MQTT broker.
- *
- * @param {String} brokerUrl - url of the broker
- */
-declare function connect(brokerUrl: string): MqttClient;
+import { IClientOptions, MqttClient } from '../client'
 
 /**
  * connect - connect to an MQTT broker.
  *
  * @param {Object} opts - see MqttClient#constructor
  */
-declare function connect(opts: IClientOptions): MqttClient;
+declare function connect (opts: IClientOptions): MqttClient
 
 /**
  * connect - connect to an MQTT broker.
  *
  * @param {String} brokerUrl - url of the broker
  * @param {Object} opts - see MqttClient#constructor
  */
-declare function connect(brokerUrl: string, opts: IClientOptions): MqttClient;
+declare function connect (brokerUrl: string, opts?: IClientOptions): MqttClient
 
-export { connect };
-export { MqttClient };
+export { connect }
+export { MqttClient }