diff --git a/.gitignore b/.gitignore index 58b9b3d..8b09770 100644 --- a/.gitignore +++ b/.gitignore @@ -1,2 +1,2 @@ -log +log/* .bundle diff --git a/app.rb b/app.rb index 1c11dbd..257c6a6 100644 --- a/app.rb +++ b/app.rb @@ -5,4 +5,9 @@ get '/' do erb :index -end \ No newline at end of file +end + +get '/queue/:id' do + @queue_name = params[:id] + erb :queue +end diff --git a/events.rb b/events.rb index 61f554b..f759c7b 100644 --- a/events.rb +++ b/events.rb @@ -1,12 +1,19 @@ require 'bayeux' events.asterisk.manager_interface.each do |event| + ahn_log.events "#{event.name} - - #{event.inspect}" case event.name when 'Join' Bayeux.publish('/caller/join', { :id => event.headers['Channel'], :number => event.headers['CallerIDNum'], :joinedAt => Time.now.to_i }) + + Bayeux.publish("/#{event.headers['Queue']}/join", { :id => event.headers['Channel'], + :number => event.headers['CallerIDNum'], + :joinedAt => Time.now.to_i }) when 'Leave' Bayeux.publish('/caller/leave', { :id => event.headers['Channel'] }) + + Bayeux.publish("/#{event.headers['Queue']}/leave", { :id => event.headers['Channel'] }) end end diff --git a/log/adhearsion.log b/log/adhearsion.log deleted file mode 100644 index 9c03ab5..0000000 --- a/log/adhearsion.log +++ /dev/null @@ -1,11 +0,0 @@ - INFO ahn: Adhearsion v1.2.1 initialized! - INFO agi: Adhearsion::VoIP::Asterisk::AGI::Server::RubyServer 0.0.0.0:4573 start - INFO ahn: Shutting down gracefully at 2011-10-07 22:54:42 -0400. - INFO ahn: Shutting down with 0 active calls - INFO events: Performing a graceful stop of events subsystem - INFO ahn: Adhearsion v1.2.1 initialized! - WARN ami: ACTIONS thread connection refused! Retrying in 5 seconds... - WARN ami: ACTIONS thread connection refused! Retrying in 5 seconds... - INFO ahn: Shutting down gracefully at 2011-10-09 12:45:16 -0400. - INFO ahn: Shutting down with 0 active calls - INFO events: Performing a graceful stop of events subsystem diff --git a/views/queue.erb b/views/queue.erb new file mode 100644 index 0000000..3a1c991 --- /dev/null +++ b/views/queue.erb @@ -0,0 +1,70 @@ + +
+