Working. Covers its tracks

Author: Aaron Gotwalt

Gemfile

@@ -1,9 +1,9 @@
 source "http://rubygems.org"
 
 ruby '2.0.0'
-
 gem 'sonos'
 gem 'rack'
+gem 'addressable'
 gem 'celluloid'
 gem 'timers'
 gem 'thor'

Gemfile.lock

@@ -1,14 +1,16 @@
 GEM
   remote: http://rubygems.org/
   specs:
+    addressable (2.3.5)
     akami (1.2.2)
       gyoku (>= 0.4.0)
       nokogiri
     builder (3.2.2)
-    celluloid (0.15.2)
-      timers (~> 1.1.0)
+    celluloid (0.14.1)
+      timers (>= 1.0.0)
     gyoku (1.1.1)
       builder (>= 2.1.2)
+    hitimes (1.2.1)
     httpclient (2.3.4.1)
     httpi (2.1.0)
       rack
@@ -38,7 +40,8 @@ GEM
       thor
     systemu (2.6.4)
     thor (0.19.1)
-    timers (1.1.0)
+    timers (2.0.0)
+      hitimes
     uuid (2.3.7)
       macaddr (~> 1.0)
     wasabi (3.3.0)
@@ -50,7 +53,9 @@ PLATFORMS
   ruby
 
 DEPENDENCIES
+  addressable
   celluloid
   rack
   sonos
   thor
+  timers

lib/ghosty/cli.rb

@@ -16,13 +16,13 @@ def start
       web.async.start
 
       # Wait for the web to start
-      sleep 2
+      sleep 1
 
       player = Ghosty::Player.new(base_uri, assets_directory)
       player.async.perform
 
       # Final sleep is to keep things alive
-      sleep
+      sleep 20
     end
 
   end

lib/ghosty/player.rb

@@ -17,31 +17,40 @@ def perform
       speaker = random_speaker
       file = ghost_url
 
+      is_paused = ['PAUSED_PLAYBACK', 'STOPPED'].include?(speaker.get_player_state[:state])
+
+      speaker.pause unless is_paused
+
       previous = speaker.now_playing
-      previous_uri = Addressable::URI.parse(previous[:uri])
-      previous_uri.query = nil
 
       puts "Playing #{file} on #{speaker.name}"
-      speaker.play(file)
-      track_info = speaker.now_playing
+      speaker.play file
+
       speaker.play
 
-      # Determine the track length, add a few extra seconds for padding
-      duration = Time.parse(track_info[:track_duration]).sec + 2
-      puts "Sleeping for #{duration}s"
-      sleep 0 # duration
+      until ['PAUSED_PLAYBACK', 'STOPPED'].include?(speaker.get_player_state[:state])
+        sleep 0.1
+      end
 
-      puts "Resetting speaker source to #{previous_uri}"
-      # reset the current track
-      speaker.play(previous_uri.to_s)
-      speaker.play
+      puts "Resetting speaker source"
+
+      # the sonos app does this. I think it tells the player to think of the master queue as active again
+      speaker.play speaker.uid.gsub('uuid', 'x-rincon-queue') + '#0'
+
+      if previous
+        speaker.select_track previous[:queue_position]
+        speaker.seek Time.parse("1/1/1970 #{previous[:current_position]} -0000" ).sec
+      end
+
+      speaker.play unless is_paused
     end
 
     private
 
+
     def random_speaker
       @system.speakers.map do |speaker|
-        speaker #speaker.get_player_state[:state] == 'PAUSED_PLAYBACK'
+        speaker if speaker.name == 'Office' #speaker.get_player_state[:state] == 'PAUSED_PLAYBACK'
       end.compact.sample
     end
 
@@ -58,3 +67,10 @@ def ghost_url
 
   end
 end
+
+module Sonos::Endpoint::AVTransport
+  def select_track(index)
+    parse_response send_transport_message('Seek', "<Unit>TRACK_NR</Unit><Target>#{index}</Target>")
+  end
+end
+