Initial implementation

Author: RangerMauve

README.md

@@ -1,2 +1,14 @@
 # async-mqtt
+
 Promise wrapper over MQTT.js
+
+**IMPORANT: Make sure you handle rejections from returned promises because otherwise you might not see them**
+
+## API
+
+The API is the same as [MQTT.js](https://github.com/mqttjs/MQTT.js#api), except the following functions now return promises instead of taking callbacks
+
+- publish
+- subscribe
+- unsubscribe
+- end

index.js

@@ -0,0 +1,70 @@
+"use strict";
+var mqtt = require("mqtt");
+var inArray = require("in-array");
+
+var RegularClientPrototype = mqtt.client;
+
+var ASYNC_METHODS = ["publish", "subscribe", "unsubscribe", "unsubscribe", "end"];
+
+module.exports = {
+	connect: connect,
+	AsyncClient: AsyncClient
+};
+
+function connect(brokerURL, opts) {
+	var client = mqtt.connect(brokerURL, opts);
+
+	var asyncClient = new AsyncClient(client);
+
+	return asyncClient;
+}
+
+function AsyncClient(client) {
+	this._client = client;
+}
+
+AsyncClient.prototype = {
+	set handleMessage(newHandler) {
+		this._client.handleMessage = newHandler;
+	},
+	get handleMessage() {
+		return this._client.handleMessage;
+	}
+};
+
+for (var name in RegularClientPrototype) {
+	if (inArray(ASYNC_METHODS, name))
+		defineAsync(name);
+	else definePassthrough(name);
+}
+
+function definePassthrough(name) {
+	AsyncClient.prototype[name] = function() {
+		var client = this._client;
+		return client[name].apply(client, arguments);
+	};
+}
+
+function defineAsync(name) {
+	AsyncClient.prototype[name] = function asyncMethod() {
+		var client = this._client;
+		var args = [];
+		var length = arguments.length;
+		var i = 0;
+		for (i; i < length; i++)
+			args.push(arguments[i]);
+
+		return new Promise(function(resolve, reject) {
+			args.push(makeCallback(resolve, reject));
+			client.apply(client, args);
+		});
+	};
+}
+
+function makeCallback(resolve, reject) {
+	return function(err, data) {
+		if (err)
+			reject(err);
+		else resolve(data);
+	};
+}

package.json

@@ -0,0 +1,30 @@
+{
+  "name": "async-mqtt",
+  "version": "1.0.0",
+  "description": "Promise wrapper over MQTT.js",
+  "main": "index.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/RangerMauve/async-mqtt.git"
+  },
+  "keywords": [
+    "mqtt",
+    "promise",
+    "async",
+    "publish",
+    "subscribe"
+  ],
+  "author": "rangermauve",
+  "license": "MIT",
+  "bugs": {
+    "url": "https://github.com/RangerMauve/async-mqtt/issues"
+  },
+  "homepage": "https://github.com/RangerMauve/async-mqtt#readme",
+  "dependencies": {
+    "in-array": "^0.1.2",
+    "mqtt": "^2.3.1"
+  }
+}