Comparar texto

Encuentra la diferencia entre dos archivos de texto

Editor live

Ocultar sin cambios

Sin ajuste de línea

Vista

Nivel de detalle

Resaltado de sintaxis

Diffchecker Desktop La forma más segura de usar Diffchecker. ¡Obtén la app de Diffchecker Desktop: tus diffs nunca salen de tu computadora!Obtener Desktop

Untitled diff

Creado hace 8 añosEl diff nunca expira

0 eliminaciones

Líneas
Total
Eliminado

Caracteres
Total
Eliminado

Para continuar usando esta función, actualice a Diffchecker Pro Ver precios

122 líneas

8 adiciones

Líneas
Total
Añadido

Caracteres
Total
Añadido

Para continuar usando esta función, actualice a Diffchecker Pro Ver precios

130 líneas

var util = require('../../core/util');

var _ = require('lodash');

var fs = require('fs');

var toml = require('toml');

var config = util.getConfig();

var dirs = util.dirs();

var log = require(dirs.core + 'log');

var CandleBatcher = require(dirs.core + 'candleBatcher');

var moment = require('moment');

var isLeecher = config.market && config.market.type === 'leech';

var Actor = function(done) {

_.bindAll(this);

this.done = done;

this.batcher = new CandleBatcher(config.tradingAdvisor.candleSize);

this.strategyName = config.tradingAdvisor.method;

this.setupStrategy();

var mode = util.gekkoMode();

// the stitcher will try to pump in historical data

// so that the strat can use this data as a "warmup period"

// the realtime "leech" market won't use the stitcher

if(mode === 'realtime' && !isLeecher) {

var Stitcher = require(dirs.tools + 'dataStitcher');

var stitcher = new Stitcher(this.batcher);

stitcher.prepareHistoricalData(done);

} else

done();

}

Actor.prototype.setupStrategy = function() {

if(!fs.existsSync(dirs.methods + this.strategyName + '.js'))

util.die('Gekko can\'t find the strategy "' + this.strategyName + '"');

log.info('\t', 'Using the strategy: ' + this.strategyName);

const strategy = require(dirs.methods + this.strategyName);

// bind all trading strategy specific functions

// to the WrappedStrategy.

const WrappedStrategy = require('./baseTradingMethod');

_.each(strategy, function(fn, name) {

WrappedStrategy.prototype[name] = fn;

});

let stratSettings;

if(config[this.strategyName]) {

stratSettings = config[this.strategyName];

}

this.strategy = new WrappedStrategy(stratSettings);

this.strategy

.on('advice', this.relayAdvice)

.on(

'stratWarmupCompleted',

e => this.deferredEmit('stratWarmupCompleted', e)

)

.on(

'stratUpdate',

e => this.deferredEmit('stratUpdate', e)

).on('stratNotification',

e => this.deferredEmit('stratNotification', e)

)

this.strategy

.on('tradeCompleted', this.processTradeCompleted);

this.batcher

.on('candle', _candle => {

const { id, ...candle } = _candle;

this.deferredEmit('stratCandle', candle);

this.emitStratCandle(candle);

// save when the next bigCandle should be.

this.nextBigCandleAt = candle.start.clone().add(4, 'hours');

});

}

// HANDLERS

// process the 1m candles

Actor.prototype.processCandle = function(candle, done) {

if(!this.nextBigCandleAt) {

// on first candle we know the next one will be in 4 hours

this.nextBigCandleAt = candle.start.clone().add(4, 'hours');

}

log.info('\t Next Candle Update:', this.nextBigCandleAt.fromNow())

this.candle = candle;

const completedBatch = this.batcher.write([candle]);

if(completedBatch) {

this.next = done;

} else {

done();

this.next = _.noop;

}

this.batcher.flush();

}

// propogate a custom sized candle to the trading strategy

Actor.prototype.emitStratCandle = function(candle) {

this.strategy.tick(candle, this.next);

}

Actor.prototype.processTradeCompleted = function(trade) {

this.strategy.processTrade(trade);

}

// pass through shutdown handler

Actor.prototype.finish = function(done) {

this.strategy.finish(done);

}

// EMITTERS

Actor.prototype.relayAdvice = function(advice) {

advice.date = this.candle.start.clone().add(1, 'minute');

this.deferredEmit('advice', advice);

}

module.exports = Actor;

Diferencias guardadas

Texto original

Abrir archivo

var util = require('../../core/util');
var _ = require('lodash');
var fs = require('fs');
var toml = require('toml');

var config = util.getConfig();
var dirs = util.dirs();
var log = require(dirs.core + 'log');
var CandleBatcher = require(dirs.core + 'candleBatcher');

var moment = require('moment');
var isLeecher = config.market && config.market.type === 'leech';

var Actor = function(done) {
  _.bindAll(this);

this.done = done;

this.batcher = new CandleBatcher(config.tradingAdvisor.candleSize);

this.strategyName = config.tradingAdvisor.method;

this.setupStrategy();

var mode = util.gekkoMode();

// the stitcher will try to pump in historical data
  // so that the strat can use this data as a "warmup period"
  //
  // the realtime "leech" market won't use the stitcher
  if(mode === 'realtime' && !isLeecher) {
    var Stitcher = require(dirs.tools + 'dataStitcher');
    var stitcher = new Stitcher(this.batcher);
    stitcher.prepareHistoricalData(done);
  } else
    done();
}

Actor.prototype.setupStrategy = function() {

if(!fs.existsSync(dirs.methods + this.strategyName + '.js'))
    util.die('Gekko can\'t find the strategy "' + this.strategyName + '"');

log.info('\t', 'Using the strategy: ' + this.strategyName);

const strategy = require(dirs.methods + this.strategyName);

// bind all trading strategy specific functions
  // to the WrappedStrategy.
  const WrappedStrategy = require('./baseTradingMethod');

_.each(strategy, function(fn, name) {
    WrappedStrategy.prototype[name] = fn;
  });

let stratSettings;
  if(config[this.strategyName]) {
    stratSettings = config[this.strategyName];
  }

this.strategy = new WrappedStrategy(stratSettings);
  this.strategy
    .on('advice', this.relayAdvice)
    .on(
      'stratWarmupCompleted',
      e => this.deferredEmit('stratWarmupCompleted', e)
    )
    .on(
      'stratUpdate',
      e => this.deferredEmit('stratUpdate', e)
    ).on('stratNotification',
      e => this.deferredEmit('stratNotification', e)
    )

this.strategy
    .on('tradeCompleted', this.processTradeCompleted);

this.batcher
    .on('candle', _candle => {
      const { id, ...candle } = _candle;
      this.deferredEmit('stratCandle', candle);
      this.emitStratCandle(candle);
    });
}

// HANDLERS
// process the 1m candles
Actor.prototype.processCandle = function(candle, done) {
  this.candle = candle;
  const completedBatch = this.batcher.write([candle]);
  if(completedBatch) {
    this.next = done;
  } else {
    done();
    this.next = _.noop;
  }
  this.batcher.flush();
}

// propogate a custom sized candle to the trading strategy
Actor.prototype.emitStratCandle = function(candle) {
  this.strategy.tick(candle, this.next);
}

Actor.prototype.processTradeCompleted = function(trade) {
  this.strategy.processTrade(trade);
}

// pass through shutdown handler
Actor.prototype.finish = function(done) {
  this.strategy.finish(done);
}

// EMITTERS
Actor.prototype.relayAdvice = function(advice) {
  advice.date = this.candle.start.clone().add(1, 'minute');
  this.deferredEmit('advice', advice);
}

module.exports = Actor;

Texto modificado

Abrir archivo

var util = require('../../core/util');
var _ = require('lodash');
var fs = require('fs');
var toml = require('toml');

var config = util.getConfig();
var dirs = util.dirs();
var log = require(dirs.core + 'log');
var CandleBatcher = require(dirs.core + 'candleBatcher');

var moment = require('moment');
var isLeecher = config.market && config.market.type === 'leech';

var Actor = function(done) {
  _.bindAll(this);

this.done = done;

this.batcher = new CandleBatcher(config.tradingAdvisor.candleSize);

this.strategyName = config.tradingAdvisor.method;

this.setupStrategy();

var mode = util.gekkoMode();

Actor.prototype.setupStrategy = function() {

if(!fs.existsSync(dirs.methods + this.strategyName + '.js'))
    util.die('Gekko can\'t find the strategy "' + this.strategyName + '"');

log.info('\t', 'Using the strategy: ' + this.strategyName);

const strategy = require(dirs.methods + this.strategyName);

// bind all trading strategy specific functions
  // to the WrappedStrategy.
  const WrappedStrategy = require('./baseTradingMethod');

_.each(strategy, function(fn, name) {
    WrappedStrategy.prototype[name] = fn;
  });

let stratSettings;
  if(config[this.strategyName]) {
    stratSettings = config[this.strategyName];
  }

this.strategy
    .on('tradeCompleted', this.processTradeCompleted);

this.batcher
    .on('candle', _candle => {
      const { id, ...candle } = _candle;
      this.deferredEmit('stratCandle', candle);
      this.emitStratCandle(candle);
      // save when the next bigCandle should be.
      this.nextBigCandleAt = candle.start.clone().add(4, 'hours');
    });
}

// HANDLERS
// process the 1m candles
Actor.prototype.processCandle = function(candle, done) {
  if(!this.nextBigCandleAt) {
    // on first candle we know the next one will be in 4 hours
	this.nextBigCandleAt = candle.start.clone().add(4, 'hours');
  }
  log.info('\t Next Candle Update:', this.nextBigCandleAt.fromNow())

this.candle = candle;
  const completedBatch = this.batcher.write([candle]);
  if(completedBatch) {
    this.next = done;
  } else {
    done();
    this.next = _.noop;
  }
  this.batcher.flush();
}

// propogate a custom sized candle to the trading strategy
Actor.prototype.emitStratCandle = function(candle) {
  this.strategy.tick(candle, this.next);
}

Actor.prototype.processTradeCompleted = function(trade) {
  this.strategy.processTrade(trade);
}

// pass through shutdown handler
Actor.prototype.finish = function(done) {
  this.strategy.finish(done);
}

// EMITTERS
Actor.prototype.relayAdvice = function(advice) {
  advice.date = this.candle.start.clone().add(1, 'minute');
  this.deferredEmit('advice', advice);
}

module.exports = Actor;