Contents

# encoding: utf-8

require 'ruby_fs'

module Punchblock
  module Connection
    class Freeswitch < GenericConnection
      attr_reader :translator, :stream
      attr_accessor :event_handler

      def initialize(options = {})
        @translator = Translator::Freeswitch.new self, options[:media_engine], options[:default_voice]
        @stream_options = options.values_at(:host, :port, :password)
        @stream = new_fs_stream
        super()
      end

      def run
        pb_logger.debug "Starting the RubyFS stream"
        start_stream
        raise DisconnectedError
      end

      def stop
        stream.shutdown
        translator.terminate
      end

      def write(command, options)
        translator.execute_command! command, options
      end

      def handle_event(event)
        event_handler.call event if event_handler.respond_to?(:call)
      end

      private

      def new_fs_stream
        RubyFS::Stream.new(*@stream_options, lambda { |e| translator.handle_es_event! e })
      end

      def start_stream
        @stream = new_fs_stream unless @stream.alive?
        @stream.run
      end
    end
  end
end

Version data entries

11 entries across 11 versions & 1 rubygems

Version	Path
punchblock-1.8.0	lib/punchblock/connection/freeswitch.rb
punchblock-1.7.1	lib/punchblock/connection/freeswitch.rb
punchblock-1.7.0	lib/punchblock/connection/freeswitch.rb
punchblock-1.6.1	lib/punchblock/connection/freeswitch.rb
punchblock-1.6.0	lib/punchblock/connection/freeswitch.rb
punchblock-1.5.3	lib/punchblock/connection/freeswitch.rb
punchblock-1.5.2	lib/punchblock/connection/freeswitch.rb
punchblock-1.5.1	lib/punchblock/connection/freeswitch.rb
punchblock-1.5.0	lib/punchblock/connection/freeswitch.rb
punchblock-1.4.1	lib/punchblock/connection/freeswitch.rb
punchblock-1.4.0	lib/punchblock/connection/freeswitch.rb