class Rock::WebApp::Syskit::RobyAppInterface

# File lib/rock/webapp/syskit/roby_app_interface.rb, line 6
def initialize (syskit_url)
    @app = Roby.app
    @app.guess_app_dir
    @app.shell
    @app.single
    @app.load_config_yaml
    
    error = Roby.display_exception do
        @app.base_setup
    
        syskit_url ||= app.droby['host']
        syskit_url ||= 'localhost'
        if syskit_url !~ /:\d+$/
            if @app.droby['host'] && @app.droby['host'] =~ /(:\d+)$/
                syskit_url << $1
            else
                syskit_url << ":#{Roby::Distributed::DEFAULT_DROBY_PORT}"
            end
        end
    
        DRb.start_service
    end
    if error
        exit(1)
    end
    
    Roby::Distributed::DRobyModel.add_anonmodel_to_names = false
    
    syskit_url =~ /^(.*):(\d+)$/
    remote_host, remote_port = $1, Integer($2)
    @appclient = AppClient.new("#{remote_host}:#{remote_port}") do
        Roby::Interface.connect_with_tcp_to(remote_host, remote_port)
    end
    
    @messages = {}
    Thread.new do
        begin
            @appclient.notification_loop(0.1) do |id, msg|
                @messages[id] = msg
            end
        rescue Exception => e
            puts e
            puts e.backtrace.join("\n")
            #@messages.clear
        end
        end
end

# File lib/rock/webapp/syskit/roby_app_interface.rb, line 54
def get_actions
    @appclient.actions
end

# File lib/rock/webapp/syskit/roby_app_interface.rb, line 58
def get_jobs
    @appclient.jobs
end

# File lib/rock/webapp/syskit/roby_app_interface.rb, line 62
def get_messages
    msgs = @messages
    #@messages.clear
    msgs
end

# File lib/rock/webapp/syskit/roby_app_interface.rb, line 91
def kill(job_id)
  puts "killing #{job_id}"
  @appclient.call Hash[:retry => true], [] , :kill_job , job_id
end

# File lib/rock/webapp/syskit/roby_app_interface.rb, line 78
def killall
    result = true
    @appclient.jobs.each do |job|
      if !kill(job[:id])
        puts"unable to kill job #{job[:id]}"
        result = false
      end
      
    end
    puts "\n"
    result
end

# File lib/rock/webapp/syskit/roby_app_interface.rb, line 68
def reload_actions
    #@appclient.reload_actions
    start_action("reload_actions",*[])
end

# File lib/rock/webapp/syskit/roby_app_interface.rb, line 73
def start_action(m, *args)
    path = []
    @appclient.call(Hash[:retry => true], path, m, *args)
end