Contents

module RUPNP

  # Searcher class for searching devices
  # @author Sylvain Daubert
  class SSDP::Searcher < SSDP::MulticastConnection
    include HTTP

    # Number of SEARCH datagrams to send
    DEFAULT_M_SEARCH_TRY = 2

    # Channel to receive discovery responses
    # @return [EM::Channel]
    attr_reader :discovery_responses


    # @param [Hash] options
    # @option options [String] :search_target
    # @option options [Integer] :response_wait_time
    # @option options [Integer] :try_number
    # @option options [Integer] :ttl
    def initialize(options={})
      @options = options
      @options[:try_number] ||= DEFAULT_M_SEARCH_TRY
      @discovery_responses = EM::Channel.new

      super options[:ttl]
    end

    # @private
    def post_init
      search = search_request
      @options[:try_number].times do
        send_datagram search, MULTICAST_IP, DISCOVERY_PORT
        log :debug, "send datagram:\n#{search}"
      end
    end

    # @private
    def receive_data(data)
      port, ip = peer_info
      log :debug, "Response from #{ip}:#{port}:"
      log :debug, data

      response = StringIO.new(data)
      if !is_http_status_ok?(response)
        log :error, "bad HTTP response:\n #{data}"
        return
      end

      @discovery_responses << get_http_headers(response)
    end


    private

    def search_request
      <<EOR
M-SEARCH * HTTP/1.1\r
HOST: #{MULTICAST_IP}:#{DISCOVERY_PORT}\r
MAN: "ssdp:discover"\r
MX: #{@options[:response_wait_time]}\r
ST: #{@options[:search_target]}\r
USER-AGENT: #{USER_AGENT}\r
\r
EOR
    end

  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
rupnp-0.3.0	lib/rupnp/ssdp/searcher.rb
rupnp-0.2.2	lib/rupnp/ssdp/searcher.rb