Cleanup stuff while I try to find a style I like..

Author: benjaminws

lib/frame.js

@@ -1,6 +1,6 @@
-require('sys');
-require('./stomp-utils');
-require('./stomp-exceptions');
+var sys = require('sys'),
+    utils = require('./stomp-utils'),
+    exceptions = require('./stomp-exceptions');
 
 
 Frame = module.exports = function(logger) {
@@ -33,9 +33,9 @@ Frame.prototype.build_frame = function(args, want_receipt) {
     var receipt_stamp = null;
 
     if (want_receipt) {
-       receipt_stamp = Math.floor(Math.random()*10000000+1);
-       this.headers['receipt'] = this.session['session'] + '-' + receipt_stamp;
-       this.stomp_log.debug(want_receipt);
+        receipt_stamp = Math.floor(Math.random()*10000000+1);
+        this.headers['receipt'] = this.session['session'] + '-' + receipt_stamp;
+        this.stomp_log.debug(want_receipt);
     }
 
     return this;
@@ -81,21 +81,18 @@ Frame.prototype.parse_frame = function(data) {
     if ('content-length' in this.headers)
         this.headers['bytes_message'] = true;
 
-    if (this.command == 'ERROR') {
+    if (this.command == 'ERROR')
         throw new BrokerErrorResponse(this.body);
-    }
 
     args['command'] = this.command;
     args['headers'] = this.headers;
     args['body'] = this.body;
 
     this_frame = new Frame(this.sock);
     return this_frame.build_frame(args);
-
 };
 
 Frame.prototype.parse_headers = function(headers_str) {
-
     var these_headers = Array(),
         one_header = Array(),
         headers_split = headers_str.split('\n');
@@ -111,18 +108,13 @@ Frame.prototype.parse_headers = function(headers_str) {
         else {
             these_headers[one_header[0]] = one_header[1];
         }
-
     }
-
     return these_headers;
-
 };
 
 Frame.prototype.parse_command = function(data) {
-
     var command,
         this_string = data.toString('ascii', start=0, end=data.length);
     command = this_string.split('\n');
     return command[0];
-
 };

lib/stomp-exceptions.js

@@ -1,6 +1,8 @@
 BrokerErrorResponse = exports.BrokerErrorResponse = function(value) {
+
     this.value = value;
     this.message = "Broker returned error: " + this.value
     console.error(this.message + this.value);
+
 };
 

lib/stomp.js

@@ -1,6 +1,7 @@
-var net = require('net');
-require('./frame');
-require('./stomp-utils');
+var net = require('net'),
+    frame = require('./frame'),
+    utils = require('./stomp-utils'),
+    exceptions = require('./stomp-exceptions');
 
 Stomp = module.exports = function(port, host, debug) {
     this.port = port;
@@ -13,7 +14,6 @@ Stomp = module.exports = function(port, host, debug) {
 };
 
 Stomp.prototype.connect = function() {
-
     this.stomp_log.debug('Connecting to ' + this.host + ':' + this.port);
     var client = net.createConnection(this.port, this.host);
     var _stomp = this;
@@ -34,5 +34,4 @@ Stomp.prototype.connect = function() {
     client.addListener('close', function (error) {
         _stomp.stomp_log.debug('disconnected');
     });
-
 };