Contents

require 'ipaddr'

module Bitcoin
  module Message

    # addr message
    # https://bitcoin.org/en/developer-reference#addr
    class Addr < Base

      COMMAND = 'addr'

      attr_reader :addrs

      def initialize(addrs = [])
        @addrs = addrs
      end

      def self.parse_from_payload(payload)
        buf = StringIO.new(payload)
        addr_count = Bitcoin.unpack_var_int_from_io(buf)
        addr = new
        addr_count.times do
          addr.addrs << NetworkAddr.parse_from_payload(buf)
        end
        addr
      end

      def to_payload
        Bitcoin.pack_var_int(addrs.length) << addrs.map(&:to_payload).join
      end

    end

    class NetworkAddr

      # unix time.
      # Nodes advertising their own IP address set this to the current time.
      # Nodes advertising IP addresses they’ve connected to set this to the last time they connected to that node.
      # Other nodes just relaying the IP address should not change the time. Nodes can use the time field to avoid relaying old addr messages.
      attr_accessor :time

      # The services the node advertised in its version message.
      attr_accessor :services

      attr_accessor :ip

      attr_accessor :port

      def initialize
        @time = Time.now.to_i
        @services = Bitcoin::Message::SERVICE_FLAGS[:network]
      end

      def self.parse_from_payload(payload)
        buf = payload.is_a?(String) ? StringIO.new(payload) : payload
        addr = new
        addr.time = buf.read(4).unpack('V').first
        addr.services = buf.read(8).unpack('Q').first
        ip = IPAddr::new_ntoh(buf.read(16))
        addr.ip = ip.ipv4_mapped? ? ip.native : ip.to_s
        addr.port = buf.read(2).unpack('n').first
        addr
      end

      def to_payload
        ip_addr = IPAddr.new (ip)
        ip_addr = ip_addr.ipv4_mapped if ip_addr.ipv4?
        [time, services].pack('VQ') << ip_addr.hton << [port].pack('n')
      end

    end

  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
bitcoinrb-0.1.3	lib/bitcoin/message/addr.rb
bitcoinrb-0.1.2	lib/bitcoin/message/addr.rb
bitcoinrb-0.1.1	lib/bitcoin/message/addr.rb
bitcoinrb-0.0.1	lib/bitcoin/message/addr.rb