embark/lib/modules/whisper/js/embarkjs_old_web3.js

/*global EmbarkJS, Web3, __MessageEvents */

// for the old version of whisper and web3.js
let __embarkWhisperOld = {};

__embarkWhisperOld.setProvider = function (options) {
  const self = this;
  let provider;
  if (options === undefined) {
    provider = "localhost:8546";
  } else {
    provider = options.server + ':' + options.port;
  }
  self.web3 = new Web3(new Web3.providers.HttpProvider("http://" + provider));
  self.getWhisperVersion(function (err, version) {
    if (err) {
      console.log("whisper not available");
    } else if (version >= 5) {
      throw new Error("whisper 5 not supported with this version of web3.js");
    } else {
      self.identity = self.web3.shh.newIdentity();
    }
    self.whisperVersion = self.web3.version.whisper;
  });
};

__embarkWhisperOld.sendMessage = function (options) {
  var topics, data, ttl, priority, payload;
  topics = options.topic || options.topics;
  data = options.data || options.payload;
  ttl = options.ttl || 100;
  priority = options.priority || 1000;
  var identity = options.identity || this.identity || this.web3.shh.newIdentity();
  var _topics;

  if (topics === undefined) {
    throw new Error("missing option: topic");
  }

  if (data === undefined) {
    throw new Error("missing option: data");
  }

  if (typeof topics === 'string') {
    _topics = [EmbarkJS.Utils.fromAscii(topics)];
  } else {
    _topics = topics.map((t) => EmbarkJS.Utils.fromAscii(t));
  }
  topics = _topics;

  payload = JSON.stringify(data);

  var message;
  message = {
    from: identity,
    topics: topics,
    payload: EmbarkJS.Utils.fromAscii(payload),
    ttl: ttl,
    priority: priority
  };

  return this.web3.shh.post(message, function () {
  });
};

__embarkWhisperOld.listenTo = function (options) {
  var topics, _topics;
  topics = options.topic || options.topics;
  _topics = [];

  if (typeof topics === 'string') {
    _topics = [topics];
  } else {
    _topics = topics.map((t) => EmbarkJS.Utils.fromAscii(t));
  }
  topics = _topics;

  var filterOptions = {
    topics: topics
  };

  let promise = new __MessageEvents();

  let filter = this.web3.shh.filter(filterOptions, function (err, result) {
    var payload = JSON.parse(EmbarkJS.Utils.toAscii(result.payload));
    var data;
    if (err) {
      promise.error(err);
    } else {
      data = {
        topic: topics,
        data: payload,
        from: result.from,
        time: (new Date(result.sent * 1000))
      };
      promise.cb(payload, data, result);
    }
  });

  promise.filter = filter;

  return promise;
};

__embarkWhisperOld.getWhisperVersion = function (cb) {
  this.web3.version.getWhisper(function (err, _res) {
    cb(err, self.web3.version.whisper);
  });
};

__embarkWhisperOld.isAvailable = function () {
  return new Promise((resolve, reject) => {
    if (!this.web3) {
      return resolve(false);
    }
    try {
      this.getWhisperVersion((err) => {
        resolve(Boolean(!err));
      });
    }
    catch (err) {
      reject(err);
    }
  });
};