ARCHIVE/xahau.js
1
0
Fork 0
mirror of https://github.com/Xahau/xahau.js.git synced 2025-11-22 05:05:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add new sjcl export for code coverage convenience

Browse Source
This commit is contained in:
wltsmrz
2013-09-10 17:15:52 -07:00
parent 40eccdb2fd
commit 068aea3ac4
1 changed files with 12 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
src/js/ripple/pathfind.js
View File

@@ -1,9 +1,7 @@
var EventEmitter = require('events').EventEmitter; var EventEmitter = require('events').EventEmitter;
var util = require('util'); var util = require('util');
var Amount = require('./amount').Amount;
var Amount = require('./amount').Amount; var extend = require('extend');
var extend = require('extend');
/** /**
* Represents a persistent path finding request. * Represents a persistent path finding request.
@@ -12,9 +10,7 @@ var extend = require('extend');
* find request is triggered it will supercede the existing one, making it emit * find request is triggered it will supercede the existing one, making it emit
* the 'end' and 'superceded' events. * the 'end' and 'superceded' events.
*/ */
var PathFind = function (remote, src_account, dst_account, function PathFind(remote, src_account, dst_account, dst_amount, src_currencies) {
dst_amount, src_currencies)
{
EventEmitter.call(this); EventEmitter.call(this);
this.remote = remote; this.remote = remote;
@@ -36,8 +32,7 @@ util.inherits(PathFind, EventEmitter);
* so you should only have to call it if the path find was closed or superceded * so you should only have to call it if the path find was closed or superceded
* and you wish to restart it. * and you wish to restart it.
*/ */
PathFind.prototype.create = function () PathFind.prototype.create = function () {
{
var self = this; var self = this;
var req = this.remote.request_path_find_create(this.src_account, var req = this.remote.request_path_find_create(this.src_account,
@@ -49,26 +44,24 @@ PathFind.prototype.create = function ()
function handleInitialPath(err, msg) { function handleInitialPath(err, msg) {
if (err) { if (err) {
self.emit('error', err); self.emit('error', err);
return; } else {
self.notify_update(msg);
} }
self.notify_update(msg);
} }
// XXX We should add ourselves to prepare_subscribe or a similar mechanism so // XXX We should add ourselves to prepare_subscribe or a similar mechanism so
// that we can resubscribe after a reconnection. // that we can resubscribe after a reconnection.
req.request(); req.request();
}; };
PathFind.prototype.close = function () PathFind.prototype.close = function () {
{
this.remote.request_path_find_close().request(); this.remote.request_path_find_close().request();
this.emit('end'); this.emit('end');
this.emit('close'); this.emit('close');
}; };
PathFind.prototype.notify_update = function (message) PathFind.prototype.notify_update = function (message) {
{
var src_account = message.source_account; var src_account = message.source_account;
var dst_account = message.destination_account; var dst_account = message.destination_account;
var dst_amount = Amount.from_json(message.destination_amount); var dst_amount = Amount.from_json(message.destination_amount);
@@ -82,10 +75,9 @@ PathFind.prototype.notify_update = function (message)
} }
}; };
PathFind.prototype.notify_superceded = function () PathFind.prototype.notify_superceded = function () {
{
// XXX If we're set to re-subscribe whenever we connect to a new server, then // XXX If we're set to re-subscribe whenever we connect to a new server, then
// we should cancel that behavior here. See PathFind#create. // we should cancel that behavior here. See PathFind#create.
this.emit('end'); this.emit('end');
this.emit('superceded'); this.emit('superceded');