Method nohup has a Cognitive Complexity of 19 (exceeds 5 allowed). Consider refactoring.

Open

    def nohup(opts)
      pid = fork do
        nohup_log = NohupLog.new(opts['nohup-log'], opts['nohup-log-truncate'])
        Signal.trap('HUP') do
          nohup_log.print("Received HUP, ignoring...\n")

• Read up
  Read up

Method iterate has a Cognitive Complexity of 19 (exceeds 5 allowed). Consider refactoring.

Open

    def iterate(log, farm: Farm::Empty.new, threads: 1)
      raise 'Log can\'t be nil' if log.nil?
      raise 'Farm can\'t be nil' if farm.nil?
      Hands.exec(threads, all) do |r, idx|
        Thread.current.name = "remotes-#{idx}@#{r[:host]}:#{r[:port]}"

• Read up
  Read up

Method up has a Cognitive Complexity of 19 (exceeds 5 allowed). Consider refactoring.

Open

      def up(score)
        start = Time.now
        bin = File.expand_path(File.join(File.dirname(__FILE__), '../../../bin/zold'))
        raise "Zold binary not found at #{bin}" unless File.exist?(bin)
        cmd = [

• Read up
  Read up

Method fetch has a Cognitive Complexity of 17 (exceeds 5 allowed). Consider refactoring.

Open

    def fetch(id, cps, opts)
      if @remotes.all.empty?
        return if opts['quiet-if-absent']
        raise "There are no remote nodes, run 'zold remote reset'"
      end

• Read up
  Read up

Method add has a Cognitive Complexity of 17 (exceeds 5 allowed). Consider refactoring.

Open

    def add(content, host, port, score, time: Time.now, master: false)
      raise "Content can't be empty" if content.empty?
      raise 'TCP port must be of type Integer' unless port.is_a?(Integer)
      raise "TCP port can't be negative: #{port}" if port.negative?
      raise 'Time must be of type Time' unless time.is_a?(Time)

• Read up
  Read up

Method taxes has a Cognitive Complexity of 17 (exceeds 5 allowed). Consider refactoring.

Open

    def taxes(id, opts)
      debt = @wallets.acq(id) do |wallet|
        raise "Wallet #{id} doesn't exist, do 'zold pull' first" unless wallet.exists?
        Tax.new(wallet).in_debt? && !opts['dont-pay-taxes']
      end

• Read up
  Read up

Method run has 55 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def run(args = [])
      opts = Slop.parse(args, help: true, suppress_errors: true) do |o|
        o.banner = "Usage: zold taxes command [options]
Available commands:
    #{Rainbow('taxes pay').green} wallet

Method clean has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

    def clean(max: 24 * 60 * 60)
      Futex.new(file, log: @log).open do
        list = load
        list.reject! do |s|
          if s[:time] >= Time.now - max

• Read up
  Read up

Method push has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

    def push(id, opts)
      raise "There are no remote nodes, run 'zold remote reset'" if @remotes.all.empty?
      @wallets.acq(id) do |wallet|
        raise "The wallet #{id} is absent at #{wallet.path}" unless wallet.exists?
      end

• Read up
  Read up

File remotes.rb has 251 lines of code (exceeds 250 allowed). Consider refactoring.

Open

require 'concurrent'
require 'csv'
require 'uri'
require 'net/http'
require 'time'

Method run has 49 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def run(args = [])
      opts = Slop.parse(args, help: true, suppress_errors: true) do |o|
        o.banner = "Usage: zold merge [ID...] [options]
Available options:"
        o.bool '--skip-propagate',

Method cycle has a Cognitive Complexity of 15 (exceeds 5 allowed). Consider refactoring.

Open

    def cycle(host, port, threads)
      s = []
      loop do
        begin
          s << @pipeline.pop(true)

• Read up
  Read up

Method calculate has a Cognitive Complexity of 15 (exceeds 5 allowed). Consider refactoring.

Open

    def calculate(opts)
      start = Time.now
      mstart = Time.now
      strength = opts[:strength]
      raise "Invalid strength: #{strength}" if strength <= 0 || strength > 8

• Read up
  Read up

Method save has a Cognitive Complexity of 15 (exceeds 5 allowed). Consider refactoring.

Open

    def save(file, overwrite: false, allow_negative_balance: false)
      raise 'You have to join at least one wallet in' if empty?
      before = ''
      wallet = Wallet.new(file)
      before = wallet.digest if wallet.exists?

• Read up
  Read up

Method push has a Cognitive Complexity of 15 (exceeds 5 allowed). Consider refactoring.

Open

    def push(id, body)
      raise 'Id can\'t be nil' if id.nil?
      raise 'Id must be of type Id' unless id.is_a?(Id)
      raise 'Body can\'t be nil' if body.nil?
      Tempfile.open(['', Wallet::EXT]) do |f|

• Read up
  Read up

Method up has 46 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def up(score)
        start = Time.now
        bin = File.expand_path(File.join(File.dirname(__FILE__), '../../../bin/zold'))
        raise "Zold binary not found at #{bin}" unless File.exist?(bin)
        cmd = [

Method merge has 45 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def merge(id, cps, opts)
      start = Time.now
      cps = cps.all(masters_first: !opts['edge-baseline'])
      patch = Patch.new(@wallets, log: @log)
      score = 0

Method pay has 42 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def pay(wallet, opts)
      raise 'The wallet is absent' unless wallet.exists?
      tax = Tax.new(wallet)
      debt = total = tax.debt
      @log.info("The current debt of #{wallet.mnemo} is #{debt} (#{debt.to_i} zents), \

Method start has a Cognitive Complexity of 13 (exceeds 5 allowed). Consider refactoring.

Open

    def start(host, port, threads: Concurrent.processor_count)
      raise 'Block is required for the farm to start' unless block_given?
      @log.info('Zero-threads farm won\'t score anything!') if threads.zero?
      if best.empty?
        @log.info("No scores found in the cache at #{@cache}")

• Read up
  Read up

Method fetch has a Cognitive Complexity of 13 (exceeds 5 allowed). Consider refactoring.

Open

    def fetch
      raise "Wallet file '#{@file}' is absent" unless File.exist?(@file)
      txns = []
      i = 0
      File.open(@file) do |f|

• Read up
  Read up