Contents

module Cumuli
  class App
    class SubApp
      attr_reader :parts
      attr_accessor :host

      def initialize(line)
        @parts = line.split
        @host = 'localhost'
      end

      def name
        parts.first.gsub(':', '')
      end

      def port
        if index = parts.find_index('-p')
          parts[index + 1] && parts[index + 1].to_i
        end
      end

      def waitable?
        host != 'localhost' || port
      end

      def wait_for_start(timeout)
        return unless waitable?
        Waiter.new("Application #{name} on port #{port} unavailable after #{timeout} seconds")
          .wait_until(timeout) { socket_available? }
      end

      def wait_for_stop(timeout)
        return unless waitable?
        Waiter.new("Application #{name} on port #{port} still connected after #{timeout} seconds")
          .wait_until(timeout) { !socket_available? }
      end

      def url
        "http://#{host}#{port ? ':' + port.to_s : ''}"
      end

      def socket_available?
        TCPSocket.new(host, port)
        true
      rescue Errno::ECONNREFUSED
        false
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
cumuli-0.3.4	lib/cumuli/app/sub_app.rb