cloudruby/mpg123player.rb at master · hterhanian/cloudruby · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
require 'open3'

class MPG123Player
  include Observable
  attr_reader :error, :paused
  attr_accessor :logger

  def initialize()
    @volume = 100
    @muted = false
    begin
      @pin, @pout, @perr = Open3.popen3 "mpg123 --keep-open --remote"
      Thread.new do watch end
      changed
      notify_observers :state => :inited
    rescue => err
      @error = err
      changed
      notify_observers :state => :error, :error => err
    end
  end

  def play(track)
    @last_track = track
    unless track.nil? || track.is_a?(Hash) && track[:error]
      mpg123puts "load #{track["mpg123url"]}"
      @pstate = 2
    end
    changed
    notify_observers :state => :load, :track => track
  rescue => err
    @error = err
    changed
    notify_observers :state => :error, :error => err
  end

  def playing?
    @pstate == 2 && !@paused
  end

  def pause()
    @paused = !@paused
    mpg123puts "pause"
  rescue => err
    @error = err
    changed
    notify_observers :state => :error, :error => err
  end

  def stop()
    mpg123puts "stop"
  rescue => err
    @error = err
    changed
    notify_observers :state => :error, :error => err
  end

  def volume= (val)
    @volume += val
    @volume = [@volume, 100].min
    @volume = [@volume, 0].max
    mpg123puts "V #{@volume}"
  rescue => err
    @error = err
    changed
    notify_observers :state => :error, :error => err
  end

  def volume()
    @volume
  end

  def mute
    @muted = !@muted
    mpg123puts "V 0" if @muted
    mpg123puts "V #{@volume}" unless @muted
  rescue => err
    @error = err
    changed
    notify_observers :state => :error, :error => err
  end

  def muted?
    @muted
  end

  def close()
    @perr.close
    @pout.close
    @pin.close
    changed
    notify_observers :state => :closed
  rescue => err
    @error = err
    changed
    notify_observers :state => :error, :error => err
  end

  def mpg123puts(out)
    @pin.puts out
    @logger.debug {">> #{out}" } #
  end

  private

  def watch
    while not @pout.closed?
      begin
        io = IO.select([@pout, @perr])
        io = io.first.first
        response = io.read_nonblock 400
        lines = response.split "\n"
        lines.each do |line|
          @logger.debug {"<< #{line}"} #
          if line =~ /@F\s(\S*)\s(\S*)\s(\S*)\s(\S*)\s*/
            changed
            notify_observers :state => :info,
              :frame => $1.to_i,
              :frameleft => $2.to_i,
              :time => $3,
              :timeleft => $4
          elsif line =~ /@P\s(\S*)\s*/
            @pstate = $1.to_i
            changed
            if @paused
              if @pstate == 2
                notify_observers :state => :resume
                @paused = false
              elsif @pstate == 1
                notify_observers :state => :pause
              end
            else
              notify_observers :state => :play if @pstate == 2
              notify_observers :state => :stop if @pstate == 1
            end
          elsif line =~ /@E.*Unfinished command:.*/
            play @last_track
          else
            #puts "don't know #{line}"
          end
        end
      rescue
      end
    end
  end
end