Upgraded mqtt version to ^3. Added object.omit as dependency.

package.json

@@ -1,6 +1,6 @@
 {
   "name": "mqtt-react",
-  "version": "0.0.2",
+  "version": "0.0.3",
   "description": "Connecting MQQT to React Components",
   "main": "./lib/index.js",
   "scripts": {
@@ -33,12 +33,13 @@
     "babel": "inherit"
   },
   "dependencies": {
-    "mqtt": "^2.7.0"
+    "mqtt": "^3.0.0",
+    "object.omit": "^3.0.0"
   },
   "peerDependencies": {
+    "prop-types": "^15.5.8",
     "react": "^15.5.0",
-    "react-dom": "^15.5.0",
-    "prop-types": "^15.5.8"
+    "react-dom": "^15.5.0"
   },
   "devDependencies": {
     "ava": "^0.19.1",
@@ -51,9 +52,9 @@
     "babel-preset-stage-0": "^6.24.1",
     "cross-env": "^4.0.0",
     "enzyme": "^2.8.2",
+    "prop-types": "^15.5.8",
     "react": "^15.5.0",
     "react-dom": "^15.5.0",
-    "prop-types": "^15.5.8",
     "react-test-renderer": "^15.5.4",
     "sinon": "^2.2.0",
     "webpack": "^2.4.1"

src/connector.js

@@ -38,8 +38,6 @@ export default class Connector extends Component {
         this.mqtt.on('close',  this._makeStatusHandler('closed'));
         this.mqtt.on('offline', this._makeStatusHandler('offline'));
         this.mqtt.on('error', console.error);
-
-
     }
 
     componentWillUnmount(){
@@ -59,6 +57,4 @@ export default class Connector extends Component {
     renderConnected() {
         return Children.only(this.props.children);
     }
-
-
 }

src/subscribe.js

@@ -2,7 +2,6 @@ import {Component, createElement} from "react";
 import PropTypes from "prop-types";
 import omit from "object.omit";
 
-
 function parse(message) {
     try {
         const item = JSON.parse(message);
@@ -22,7 +21,6 @@ function defaultDispatch(topic, message, packet) {
     this.setState({ data: newData });
 };
 
-
 export default function subscribe(opts = { dispatch: defaultDispatch }) {
     const { topic } = opts;
     const dispatch = (opts.dispatch) ? opts.dispatch : defaultDispatch;
@@ -48,7 +46,6 @@ export default function subscribe(opts = { dispatch: defaultDispatch }) {
                 this.client.on('message', this.handler);
             }
 
-
             componentWillMount() {
                 this.subscribe();
             }

test/connector.spec.js

@@ -4,7 +4,6 @@ import {shallow} from "enzyme";
 import {EventEmitter} from "events";
 import Connector from "../src/connector";
 
-
 describe('Connector', (test) => {
     const DIV_ID = 'content';
     test('should render children', (t) => {
@@ -16,5 +15,4 @@ describe('Connector', (test) => {
         )
         t.true(mounted.find(`div#${DIV_ID}`).length === 1);
     })
-
-});
+});

test/subscribe.spec.js

@@ -6,7 +6,6 @@ import Sinon from 'sinon';
 import subscribe from '../src/subscribe';
 import {EventEmitter} from 'events';
 
-
 class mockClient extends EventEmitter {
     subscribe = Sinon.spy();
     publish = Sinon.spy((topic, message) => {
@@ -61,6 +60,4 @@ describe('Subscribe', (test) => {
         t.truthy(data[0]);
         t.true(data[0].value === demoMessage.value);
     })
-
-
-});
+});