play_thread.rb in mikeplayer-1.0.7

- old
+ new
@@ -1,14 +1,122 @@
 module MikePlayer
   class PlayThread
-    def self.run(file, volume)
+    def initialize(volume: 1.0)
+      check_system
+
+      @pid     = nil
+      @volume  = volume
+      @start_t = 0
+      @elapsed = 0
+      @paused  = false
+    end
+
+    def play(file)
+      start_position = 0
+
+      if paused?
+        start_position = @elapsed
+      else
+        @elapsed = 0
+      end
+
+      start_thread(file: file, start_position: start_position)
+
+      @start_t = Time.now.to_i
+    end
+
+    def stop
+      pause
+
+      @elapsed = 0
+      @start_t = 0
+      @paused  = false
+    end
+
+    def pause
+      kill('INT')
+
+      @elapsed += Time.now.to_i - @start_t
+      @start_t  = 0
+
+      sleep 0.2
+
+      kill('KILL')
+
+      @paused = true
+    end
+
+    def kill(signal)
+      Process.kill(signal, @pid) if alive?
+    end
+
+    def alive?
+      MikePlayer::PlayThread.alive?(@pid)
+    end
+
+    def stopped?
+      false == alive?
+    end
+
+    def paused?
+      @paused && stopped?
+    end
+
+    def playing?
+      alive?
+    end
+
+    def elapsed
+      return (@elapsed + (Time.now.to_i - @start_t)) if @start_t.positive?
+
+      @elapsed
+    end
+
+    def self.alive?(pid)
+      return system("ps -p #{pid} > /dev/null") unless pid.nil?
+
+      false
+    end
+
+    def self.cmd_exist?(cmd)
+      if (true != system('command'))
+        raise "Missing 'command' command, which is used to test compatibility."
+      end
+
+      if (true != system("command -v #{cmd} >/dev/null 2>&1"))
+        return false
+      end
+
+      return true
+    end
+
+    private
+    def start_thread(file:, start_position: )
       args = [
-        :play,
+        'play',
         '--no-show-progress',
-        '--volume', volume,
-        song
+        '--volume', @volume.to_s,
+        file,
+        'trim', start_position.to_s,
       ]
-      Open3.popen2e(*args) do |stdin, out, wait_thr|
+
+      stdin, stdother, thread_info = Open3.popen2e(*args)
+
+      @pid = thread_info.pid
+
+      sleep 0.2
+
+      raise "Failed to play #{stdother.read}" unless alive?
+
+      stdin.close
+      stdother.close
+
+      self
+    end
+
+    def check_system
+      %w[play].each do |cmd|
+        raise "#{cmd} failed, do you have sox installed?" unless MikePlayer::PlayThread.cmd_exist?(cmd)
       end
     end
   end
 end