common.rb

require_relative 'lirc_handler'
#require 'metar'

class Common
  # event channels
  attr_reader :events

  # cache
  attr_reader :playlist, :mpd_status

  # connections
  attr_reader :mpd, :lirc

  attr_accessor :denon


  def initialize
    @events = Struct.new(:mpd_song, :mpd_status, :mpd_volume, :denon_status, :lcd_backlight, :lcd_status, :lcd_alerts, :actions).new
    @events.mpd_status    = EM::Channel.new
    @events.mpd_volume    = EM::Channel.new
    @events.denon_status  = EM::Channel.new
    @events.lcd_backlight = EM::Channel.new
    @events.lcd_status    = EM::Channel.new
    @events.lcd_alerts    = EM::Channel.new
    @events.actions       = EM::Channel.new


    @events.mpd_status.subscribe do |status|
      @mpd_status = status
      update_playlist
    end

    @events.mpd_volume.subscribe do |vol|
      puts "vol #{vol}"
      denon.volume = vol/2
    end

    @mpd = MPD.new
    @mpd.connect
    puts "Connected to MPD"
    @mpd.async_idle

    @lirc = EventMachine.connect_unix_domain "/var/run/lirc/lircd", LIRCHandler, self

    update_status
    update_playlist
  end

  def update_playlist
    if @playlist_version != @mpd_status[:playlist]
      start = Time.now
      puts "Updating playlist #{@playlist_version} -> #{@mpd_status[:playlist]}"
      @mpd.noidle_sync do |mpd|
        @playlist = mpd.queue.to_a
      end
      @playlist_version = @mpd_status[:playlist]
      puts "Pls updated. Took #{Time.now - start} s"
    end
  end

  def update_status
    @mpd.noidle_sync do |mpd|
      @mpd_status = @mpd.status
    end
  end

  def mpd_song
    if @mpd_status[:song]
      @playlist[@mpd_status[:song]]
    else
      nil
    end
  end

  def lcd_backlight=(value)
    @events.lcd_backlight.push value
  end

  def lcd_touch
    @events.lcd_backlight.push nil
  end

  def lcd_status text
    @events.lcd_status.push text
  end

end