Merge pull request amqp-node#451 from jfromaniello/add_amqplain_credentials

add amqplain credentials

Author: squaremo

lib/credentials.js

@@ -9,6 +9,7 @@
 //  * EXTERNAL (assume the server will figure out who you are from
 //    context, i.e., your SSL certificate)
 var Buffer = require('safe-buffer').Buffer
+var codec = require('./codec')
 
 module.exports.plain = function(user, passwd) {
   return {
@@ -21,6 +22,19 @@ module.exports.plain = function(user, passwd) {
   }
 }
 
+module.exports.amqplain = function(user, passwd) {
+  return {
+    mechanism: 'AMQPLAIN',
+    response: function() {
+      const buffer = Buffer.alloc(16384);
+      const size = codec.encodeTable(buffer, { LOGIN: user, PASSWORD: passwd}, 0);
+      return buffer.slice(4, size);
+    },
+    username: user,
+    password: passwd
+  }
+}
+
 module.exports.external = function() {
   return {
     mechanism: 'EXTERNAL',

test/connect.js

@@ -118,6 +118,18 @@ suite("Connect API", function() {
             kCallback(succeed(done), fail(done)));
   });
 
+  test("using amqplain credentials", function(done) {
+    var url = require('url');
+    var parts = url.parse(URL, true);
+    var u = 'guest', p = 'guest';
+    if (parts.auth) {
+      var auth = parts.auth.split(":");
+      u = auth[0], p = auth[1];
+    }
+    connect(URL, {credentials: require('../lib/credentials').amqplain(u, p)},
+            kCallback(succeed(done), fail(done)));
+  });
+
   test("using unsupported mechanism", function(done) {
     var creds = {
       mechanism: 'UNSUPPORTED',