Contents

require 'rubygems'
require 'eventmachine'
require 'socket'

require 'osc_to_rca_dispatcher'

module UdpServer
  
  def post_init
    CcgLogger::LOGGER.info "#{Time.now.iso8601} |  ++     ... server started"
  end

  def receive_data(data)
    puts "1"
    return unless(CcgRunner.instance.valve == :open)
    puts "2"

    ##
    #CcgLogger::LOGGER.info "#{Time.now.iso8601} |  >> raw incoming data: ----------------------"
    #CcgLogger::LOGGER.info data.inspect
    #CcgLogger::LOGGER.info " --------------------------------------------"
    ##
    
    #port, ip = Socket.unpack_sockaddr_in(get_peername)
    #CcgLogger::LOGGER.info "#{Time.now.iso8601} |  >> UdpServer:  sender: #{ip}, #{port}"
    
    # RCA
    rca_dispatching = proc {
      my_dispatcher = CanControlsGateway::OscToRcaDispatcher.new data
      #CcgLogger::LOGGER.info my_dispatcher.event.inspect
      my_dispatcher.dispatch_rca
    }
    rca_callback = proc { |result|
      #if result
      #  CcgLogger::LOGGER.info "#{Time.now.iso8601} |  >> UdpServer:  result is: #{result.inspect}"
      #end
    }
    EventMachine::defer rca_dispatching, rca_callback
  end
  
  def unbind
    CcgLogger::LOGGER.info "#{Time.now.iso8601} |  -- UdpServer stopped"
  end
  
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
tg-can-controls-gateway-0.1.0	lib/server.rb