protocol.js

var uuid = require('uuid');

var fields = [
  'task',
  'id',
  'args',
  'kwargs',
  'retries',
  'eta',
  'expires',
  'queue',
  'taskset',
  'chord',
  'utc',
  'callbacks',
  'errbacks',
  'timeouts',
  'priority',
];

function formatDate(date) {
  return new Date(date).toISOString();
}

function createMessage(task, args, kwargs, options, id) {
  args = args || [];
  kwargs = kwargs || {};

  var message = {
    task: task,
    args: args,
    kwargs: kwargs,
  };

  message.id = id || uuid.v4();
  for (var o in options) {
    if (options.hasOwnProperty(o)) {
      if (fields.indexOf(o) === -1) {
        throw 'invalid option: ' + o;
      }
      message[o] = options[o];
    }
  }

  if (message.eta) {
    message.eta = formatDate(message.eta);
  }

  if (message.expires) {
    message.expires = formatDate(message.expires);
  }

  return JSON.stringify(message);
}

exports.createMessage = createMessage;