Contents

module Tapyrus
  module Node

    # SPV class
    class SPV

      attr_reader :chain
      attr_reader :pool
      attr_reader :logger
      attr_accessor :running
      attr_reader :configuration
      attr_accessor :server
      attr_accessor :wallet
      attr_accessor :bloom

      def initialize(configuration)
        @chain = Tapyrus::Store::SPVChain.new
        @configuration = configuration
        @pool = Tapyrus::Network::Pool.new(self, @chain, @configuration)
        @logger = Tapyrus::Logger.create(:debug)
        @running = false
        @wallet = Tapyrus::Wallet::Base.current_wallet
        # TODO : optimize bloom filter parameters
        setup_filter
      end

      # open the node.
      def run
        # TODO need process running check.
        return if running
        logger.debug 'SPV node start running.'
        EM.run do
          # EM.start_server('0.0.0.0', Tapyrus.chain_params.default_port, Tapyrus::Network::InboundConnector, self)
          pool.start
          @server = Tapyrus::RPC::HttpServer.run(self, configuration.port)
        end
      end

      # close the node.
      def shutdown
        pool.terminate
        logger.debug 'SPV node shutdown.'
      end

      # broadcast a transaction
      def broadcast(tx)
        pool.broadcast(tx)
        logger.debug "broadcast tx: #{tx.to_hex}"
      end

      # add filter element to bloom filter.
      # [String] element. the hex string of txid, public key, public key hash or outpoint.
      def filter_add(element)
        bloom.add(element)
        pool.filter_add(element)
      end

      # clear bloom filter.
      def filter_clear
        pool.filter_clear
      end

      def add_observer(observer)
        pool.add_observer(observer)
      end

      def delete_observer(observer)
        pool.delete_observer(observer)
      end

      private

      def setup_filter
        @bloom = Tapyrus::BloomFilter.create_filter(512, 0.01)
        wallet.watch_targets.each{|t|bloom.add(t.htb)} if wallet
      end
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
tapyrus-0.2.7	lib/tapyrus/node/spv.rb
tapyrus-0.2.6	lib/tapyrus/node/spv.rb
tapyrus-0.2.5	lib/tapyrus/node/spv.rb
tapyrus-0.2.4	lib/tapyrus/node/spv.rb
tapyrus-0.2.3	lib/tapyrus/node/spv.rb
tapyrus-0.2.2	lib/tapyrus/node/spv.rb
tapyrus-0.2.1	lib/tapyrus/node/spv.rb
tapyrus-0.2.0	lib/tapyrus/node/spv.rb