#!/usr/bin/env ruby -rubygems

require 'switchboard'
require 'xmpp4r/client'
include Jabber

# This Ruby script runs on OSX, and links the output of ./iremoted_buttons to the XMPP/Jabber network, streaming Apple Remote events.
# 
# See blog post: http://danbri.org/words/2009/10/19/483
# see also: http://www.bbc.co.uk/music/artists/2339bc21-aa92-4850-86f0-4bb9433910c8.rdf
#   http://www.rubycocoa.com/appleremote/1
# 
# Author: Dan Brickley <danbri@danbri.org>
#
# License: 
# Do what you like but don't blame me. Acks by link appreciated. Note that the real OSX smarts are in iremoted which I didn't write.
#
# This is a contribution to the FOAF Buttons project and was initiated as part of the NoTube EU project (http://www.notube.tv/)

#  External program to monitor:

IR="./iremoted_buttons" # you can compile this with gcc -Wall -o iremoted_buttons iremoted_buttons.c -framework IOKit -framework Carbon

# Local (non-standard) nicknames for the 6 USB codes:

APIR= { '0x1d' 		=> 'PLUS', 	# up 	(immediate events)
        '0x1e'	 	=> 'MINU', 	# down  (immediate events)
       	'0x17' 		=> 'LEFT', 	# left  (buffered events, all other buttons)
	'0x16'		=> 'RIGH', 	# right
	'0x15'		=> 'PLPZ', 	# fire (play/pause)
	'0x14'		=> 'MENU' } 	# menu


class ButtonEvent
  attr_accessor :name, :event
  def initialize(name = "NOPE")
    @name = name
  end
  def label
    return APIR[@name] # optimistic, should error check!
  end
end

class ButtonDownEvent < ButtonEvent
  def initialize(i)
    super(i)
  end
end

class ButtonUpEvent < ButtonEvent
  def initialize(i)
    super(i)
  end
end

def eventLoop(sb=nil)
  f = IO.popen( IR + " 2>&1 ","r") do |pipe|
    pipe.each do |line|
      sleep 0.01
      relay(line, sb)
    end
  end
end

def relay(line,sb)
  line.gsub!(/\s*/,"")
  if line =~ /<pressed>([^<]+)<\/pressed>/
    ev = ButtonDownEvent.new($1) 
    bubbleEvent(ev,sb)
  elsif line =~ /<depressed>([^<]+)<\/depressed>/
    ev = ButtonUpEvent.new($1) 
    bubbleEvent(ev,sb)
  elsif
    puts "UNKNOWN event, ignoring." 
  end
end


# Switchboard is essentially a wrapper around xmpp4r, so `switchboard.client` will give you access to a `Jabber::Client`
# Docs for that are here: http://home.gna.org/xmpp4r/rdoc/  http://home.gna.org/xmpp4r/rdoc/classes/Jabber/Client.html
# http://devblog.famundo.com/articles/2006/10/14/ruby-and-xmpp-jabber-part-2-logging-in-and-sending-simple-messages

def bubbleEvent(e,sb)
  msg = "#{e.class}: #{e.label} (#{e.name})"
  puts msg
#  to = "alice.notube@gmail.com"
  to = "buttons@foaf.tv/gumboviListener"
  subject = "Apple Remote Event"
  begin 
#    m = Message::new(to, msg).set_type(:normal).set_id('1').set_subject(subject)
    m = Message::new(to, msg).set_type(:chat).set_id('1').set_subject(subject)
    sb.client.send(m)
  rescue Exception => e
    puts "Rescued: #{e}"
  end
end



# Main:

switchboard = Switchboard::Client.new
switchboard.plug!(AutoAcceptJack, NotifyJack) # sample addons

t1 = Thread.new {

begin
    switchboard.on_message do |message|
      txt = message.body.to_s
      puts "Message body was: '#{txt}'" # handles replies
      if (txt =~ /pause/)
        puts "replied with pause toggle." # useless here, but for example
        stream.send("toggled pause")
      else
        stream.send(message.answer)
      end
    end
    switchboard.on_iq do |message|
      p "Got message iq: "
      p message
    end
    switchboard.run!
  rescue Exception => e
    put "Exception: #{e} in our Switchboard thread"
  end
} 

print "starting event loop.\n\n"

eventLoop(switchboard) # loop around, listening to IR events and eventually relaying them to XMPP listeners