bramqp - npm Package Compare versions

Comparing version 0.1.3 to 0.1.5

lib/connectionHandle.js

@@ -47,3 +47,3 @@ var util = require('util');
 				var error = new Error(errorMessage);
-				self.emit('error',error);
+				self.emit('error', error);
 			} else {
@@ -255,5 +255,5 @@ self.frameParser.parse(data);
 		contentBuffer = new Buffer(content);
-	} else if(content instanceof Buffer) {
+	} else if (content instanceof Buffer) {
 		contentBuffer = content;
-	}else{
+	} else {
 		return callback(new Error("content must be of type string or buffer"));
@@ -260,0 +260,0 @@ }

lib/frameParser.js

@@ -298,3 +298,3 @@ /* jshint bitwise:false */
 	for ( var i in propertyFlags) {
-		for ( var j = 15; j > 0; j--) {
+		for (var j = 15; j > 0; j--) {
 			var mask = 1 << j;
@@ -414,3 +414,3 @@ propertiesPresent.push(propertyFlags[i] & mask ? true : false);
 		if (!this.constantLookup[endCheck] || this.constantLookup[endCheck].name !== 'frame-end') {
-			this.emit('error',new Error('frame end octet does not match the specification'));
+			this.emit('error', new Error('frame end octet does not match the specification'));
 		}
@@ -417,0 +417,0 @@

lib/frameSerializer.js

@@ -169,3 +169,3 @@ /* jshint bitwise:false */
 			this.serializeLongLong(buffer, longLongString);
-			for ( var i = 0; i < 8; i++) {
+			for (var i = 0; i < 8; i++) {
 				buffer[start + i] = (~buffer[start + i]) & 0xff;
@@ -373,2 +373,3 @@ }
 FrameSerializer.prototype.serializeFrameContentHeader = function(buffer, channel, className, bodySize, fieldData) {
+
 	var headerPayload = new Buffer(this.frameMax);
@@ -399,3 +400,3 @@ headerPayload.used = 0;
 		var localIndex = i % 15;
-		var propertyIndex = i / 15;
+		var propertyIndex = (i - localIndex) / 15;
 		if (localIndex === 0) {
@@ -402,0 +403,0 @@ propertyFlags[propertyIndex] = 0;

lib/specification.js

@@ -57,3 +57,3 @@ var fs = require('fs');
 		xml2jsParser.parseString(data, function(err, result) {
-			if (err){
+			if (err) {
 				return callback(err);
@@ -60,0 +60,0 @@ }

package.json

 {
 	"name" : "bramqp",
-	"version" : "0.1.3",
-	"description" : "bakkerthehacker's rectangular AMQP library",
+	"version" : "0.1.5",
+	"description" : "bakkerthehacker's rapid AMQP library",
 	"keywords" : [ "amqp", "bramqp" ],
@@ -6,0 +6,0 @@ "homepage" : "http://github.com/bakkerthehacker/bramqp",

README.md

@@ -1,2 +0,2 @@
-# bakkerthehacker's rectangular AMQP library
+# bakkerthehacker's rapid AMQP library
 
@@ -160,2 +160,37 @@ A radical, raw, robust, remarkable AMQP library for node.js
 
+Sending and receiving methods can also use a more general interface.
+The previous specific interface simply calls this general interface and both function identically.
+This interface is provided for convenience and should only be used in special circumstances, such as logging all incoming methods.
+
+#### handle.method(channel, className, methodName, data, [callback(error)])
+
+- `channel` The AMQP channel to send the method on.
+The channel MUST be `0` when the class is `connection` and MUST NOT be `0` otherwise.
+- `className` The name of the class that the method belongs to.
+- `methodName` The name of the method being called.
+- `data` An object containing the arguments as specified by the AMQP method. 
+- `callback(error)` Called once the method has been written to the socket.
+
+#### Event: 'method'
+
+- `channel` The channel the method was received on.
+- `className` The name of the class that the method belongs to.
+- `method` An object containing information about the method called. This is essentially a javascript version of the method as it appears in the xml specification.
+- `data` An object containing the argument values.
+
+Example:
+
+```javascript
+handle.method(1, 'exchange', 'declare', {'exchange-name' : 'exchange-name', 'type' : 'topic'}, function(methodError){
+	if (methodError) {
+		console.log(methodError);
+	}
+	console.log('declare method sent');
+});
+
+handle.on('method', function(channel, className, method, data) {
+	console.log('incoming method: ' + className + '.' + method.name);
+});
+```
+
 ### Content
@@ -231,3 +266,3 @@
 
-Heartbeats can be send by calling `heartbeat`.
+Heartbeats can be sent by calling `heartbeat`.
 
@@ -234,0 +269,0 @@ #### handle.heartbeat(callback(error))

test/frameParser-test.js

@@ -387,3 +387,3 @@ var vows = require('vows');
 						var value = [];
-						for ( var i = 0; i < 8; i++) {
+						for (var i = 0; i < 8; i++) {
 							value[i] = parse(buffer, i);
@@ -397,3 +397,3 @@ }
 						var value = [];
-						for ( var i = 0; i < 8; i++) {
+						for (var i = 0; i < 8; i++) {
 							value[i] = parse(buffer, i);
@@ -407,3 +407,3 @@ }
 						var value = [];
-						for ( var i = 0; i < 8; i++) {
+						for (var i = 0; i < 8; i++) {
 							value[i] = parse(buffer, i);
@@ -417,3 +417,3 @@ }
 						var value = [];
-						for ( var i = 0; i < 10; i++) {
+						for (var i = 0; i < 10; i++) {
 							value[i] = parse(buffer, i);
@@ -428,3 +428,3 @@ }
 						var value = [];
-						for ( var i = 0; i < 16; i++) {
+						for (var i = 0; i < 16; i++) {
 							value[i] = parse(buffer, i);
@@ -726,3 +726,3 @@ }
 						assert.strictEqual(value.length, testValue.length);
-						for ( var i = 0; i < 8; i++) {
+						for (var i = 0; i < 8; i++) {
 							assert.strictEqual(value[i], testValue[i]);
@@ -733,2 +733,2 @@ }
 			}
-		}).export(module);
+		}).export(module);

test/frameSerializer-test.js

@@ -543,3 +543,3 @@ var vows = require('vows');
 								buffer.used = 0;
-								for ( var i = 0; i < 8; i++) {
+								for (var i = 0; i < 8; i++) {
 									serialize(buffer, value[i], i);
@@ -553,3 +553,3 @@ }
 								buffer.used = 0;
-								for ( var i = 0; i < 8; i++) {
+								for (var i = 0; i < 8; i++) {
 									serialize(buffer, value[i], i);
@@ -563,3 +563,3 @@ }
 								buffer.used = 0;
-								for ( var i = 0; i < 8; i++) {
+								for (var i = 0; i < 8; i++) {
 									serialize(buffer, value[i], i);
@@ -573,3 +573,3 @@ }
 								buffer.used = 0;
-								for ( var i = 0; i < 10; i++) {
+								for (var i = 0; i < 10; i++) {
 									serialize(buffer, value[i], i);
@@ -584,3 +584,3 @@ }
 								buffer.used = 0;
-								for ( var i = 0; i < 16; i++) {
+								for (var i = 0; i < 16; i++) {
 									serialize(buffer, value[i], i);
@@ -587,0 +587,0 @@ }

tutorial/TUTORIAL.md

@@ -9,2 +9,3 @@ # Tutorials
 4. [Routing](4 Routing)
-5. [Topics](5 Topics)
+5. [Topics](5 Topics)
+6. [RPC](6 RPC)

No alert changes

Improved metrics

Total package byte prevSize

247742

increased by2.57%

Number of package files

31

increased by6.9%

Lines of code

3453

increased by4.38%

Number of lines in readme file

363

increased by10.67%

Worsened metrics

Number of medium supply chain risk alerts

12

increased by20%

No dependency changes