Added capability for creating mqtt clients

fisehara · Jan 11, 2012 · 8423a12 · 8423a12
1 parent 057107b
commit 8423a12
Show file tree

Hide file tree

Showing 4 changed files with 15 additions and 6 deletions.
diff --git a/connection.js → lib/connection.js b/connection.js → lib/connection.js
diff --git a/mqtt.js → lib/mqtt.js b/mqtt.js → lib/mqtt.js
@@ -3,12 +3,10 @@
 var net = require('net'),
 	util = require('util');
 
-var defaultPort = 1883;
-
-var defaultHost = '127.0.0.1';
+var Connection = require('./connection');
 
 function Server(listener) {
-	if (!(this instanceof Server)) return new Server(arguments[0], arguments[1]);
+	if (!(this instanceof Server)) return new Server(listener);
 
 	var self = this;
 
@@ -18,14 +16,26 @@ function Server(listener) {
 		self.on('client', listener);
 	}
 
-	var Connection = require('./connection');
 	self.on('connection', function(socket) {
 		self.emit('client', new Connection(socket, self));
 	});
+
+	return this;
 }
 
 util.inherits(Server, net.Server);
 
 module.exports.createServer = function(listener) {
 	return new Server(listener);
 };
+
+module.exports.createConnection = function(host, port, callback) {
+	var socket = net.createConnection(host, port),
+		client = new Connection(socket, null);
+
+	socket.on('connect', function() {
+		client.emit('connected');
+	});
+
+	return client;
+}
diff --git a/packet.js → lib/packet.js b/packet.js → lib/packet.js
diff --git a/protocol.js → lib/protocol.js b/protocol.js → lib/protocol.js
@@ -1,5 +1,4 @@
 /* Generic */
-
 var protocol = module.exports;
 
 module.exports.types = {