Contents

require 'envoy/protocol'
require 'envoy/client/channel'

module Envoy
  module Client
  
    module Trunk
      include Protocol
      
      attr_reader :options
      
      def self.start options
        EM.connect options[:server_host], options[:server_port].to_i, Envoy::Client::Trunk, options
      end
      
      def initialize options
        @options = options
      end
      
      def channels
        @channels ||= {}
      end
      
      def receive_start_tls
        start_tls
      end
      
      def receive_close id
        channels[id].close_connection true
        channels.delete(id)
      end
      
      def receive_stream id, data
        channels[id].send_data data
      end
      
      def receive_connection id
        channels[id] = EM.connect(options[:local_host] || '127.0.0.1',
                                  options[:local_port], Channel, id, self)
      end
      
      def receive_keepalive
      end
      
      def receive_message message
        STDERR.puts message
      end
      
      def receive_halt
        EventMachine.stop_event_loop
      end
      
      def unbind
        if @options[:reconnect]
          STDERR.puts "No connection. Reconnecting in #{@options[:reconnect]}s."
          EM.add_timer @options[:reconnect] do
            @options[:reconnect] *= 2
            Trunk.start @options
          end
        else
          if options[:did_connect]
            STDERR.puts "Connection lost. Not point reconnecting because the host is randomly generated."
          else
            STDERR.puts "Couldn't connect. Abandoning ship."
          end
          receive_halt
        end
      end
      
      def ssl_handshake_completed
        options[:did_connect] = true
        options[:reconnect] = 1 if options[:hosts]
        o = options.dup
        o.delete(:local_host)
        send_object :options, o
      end
      
      def post_init
        send_object :start_tls
      end
      
    end
  
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
envoy-proxy-0.0.8	lib/envoy/client/trunk.rb