Tests for mqtt.js against mosquitto

client_test.js

var mqtt = require('mqtt');

mqtt.createConnection(1883, 'localhost', function(err, client) {
  if (err) {
    console.dir(err);
    return process.exit(-1);
  }

  var events = ['connack', 'puback', 'pubrec', 'pubcomp'];

  for (var i = 0; i < events.length; i++) {
    client.on(events[i], function(packet) {
      console.dir(packet);
    });
  };

  client.connect({keepalive: 1000});

  client.on('connack', function(packet) {
    setInterval(function() {
      client.publish({
        topic: 'test0'
      , payload: 'test'
      , qos: 0
      });

      client.publish({
        topic: 'test1'
      , payload: 'test'
      , qos: 1
      , messageId: 1
      });
      client.publish({
        topic: 'test2'
      , payload: 'test'
      , qos: 2
      , messageId: 2
      });
    }, 10000);

    setInterval(function() {
      client.pingreq();
    }, 1000);
  });

  client.on('pubrec', function(packet) {
    client.pubrel({messageId: 2});
  });
});

server_test.js

var mqtt = require('mqtt');

mqtt.createConnection(function(client) {
  var events = ['connect', 'publish', 'pubrel', 'subscribe', 'disconnect'];

  for (var i = 0; i < events.length; i++) {
    client.on(events[i], function(packet) {
      console.dir(packet);
    });
  };

  client.on('connect', function(packet) {
    client.connack(0);
  });

  client.on('publish', function(packet) {
    switch(packet.qos) {
      case 1:
        client.puback({messageId: packet.messageId});
        break;
      case 2:
        client.pubrec({messageId: packet.messageId});
        break;
      default:
        console.log('errors?');
    }
  });

  client.on('pubrel', function(packet) {
    client.pubcomp({messageId: packet.messageId});
  });

  client.on('pingreq', function(packet) {
    client.pingresp();
  });
  
  client.on('disconnect', function(packet) {
    client.stream.end();
  });
}).listen(1882);

I am confused. Are the apis called here a part of the original github repo and it is just that the wiki isnt updated yet ?

Hello,
I tried sending pubrec after receiving the message using
client.pubrec(..)
but I'm getting the error client.pubrec is not a function.
any suggestion?