Contents

require 'artoo/utility'

module Artoo
  # The Connection class represents the interface to 
  # a specific group of hardware devices. Examples would be an
  # Arduino, a Sphero, or an ARDrone.
  class Connection
    include Celluloid
    include Artoo::Utility

    attr_reader :parent, :name, :port, :adaptor

    def initialize(params={})
      @name = params[:name].to_s
      @port = Port.new(params[:port])
      @parent = params[:parent]

      require_adaptor(params[:adaptor] || :loopback)
    end

    def connect
      Logger.info "Connecting to '#{name}' on port '#{port}'..."
      adaptor.connect
    rescue Exception => e
      Logger.error e.message
      Logger.error e.backtrace.inspect
    end

    def disconnect
      Logger.info "Disconnecting from '#{name}' on port '#{port}'..."
      adaptor.disconnect
    end

    def connected?
      adaptor.connected?
    end

    def to_hash
      {:name => name,
       :port => port.to_s,
       :adaptor => adaptor.class.name.demodulize,
       :connected => connected?
      }
    end

    def as_json
      MultiJson.dump(to_hash)
    end

    def to_s
      "#{self.class}:0x#{self.object_id}"
    end

    def inspect
      "#<#{to_s}>"
    end

    def method_missing(method_name, *arguments, &block)
      unless adaptor.connected?
        Logger.warn "Cannot call unconnected adaptor '#{name}', attempting to reconnect..."
        adaptor.reconnect
        return nil
      end
      adaptor.send(method_name, *arguments, &block)
    rescue Exception => e
      Logger.error e.message
      Logger.error e.backtrace.inspect
      return nil
    end

    private

    def require_adaptor(type)
      require "artoo/adaptors/#{type.to_s}"
      @adaptor = constantize("Artoo::Adaptors::#{classify(type.to_s)}").new(:port => port, :parent => current_instance)
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
artoo-0.3.0	lib/artoo/connection.rb