Amp/src/stereo/player/StereoAmp.java

   1 package stereo.player;
   2
   3 import interfaces.Constants;
   4 import interfaces.Track.TrackFactory;
   5
   6 import java.io.ByteArrayInputStream;
   7 import java.io.IOException;
   8 import java.net.UnknownHostException;
   9
  10 import javax.sound.sampled.UnsupportedAudioFileException;
  11
  12 import api.Response;
  13 import api.nodes.AlbumNode.AlbumFactory;
  14 import api.nodes.PlaylistNode.PlaylistFactory;
  15
  16 import reader.DACPResponseParser;
  17
  18 import util.command.Song;
  19 import util.response.ctrlint.PlayStatusUpdate;
  20
  21 public class StereoAmp extends Thread {
  22
  23         private final String host;
  24         private final int port;
  25         private final DACPResponseParser parser;
  26
  27         private AudioPlayer player;
  28         private int current;
  29
  30         public StereoAmp(String host, int port) {
  31
  32                 this.host = host;
  33                 this.port = port;
  34
  35                 parser = new AmpResponseParser();
  36         }
  37
  38         public void run() {
  39
  40                 int revision = -1;
  41
  42                 while (true) {
  43
  44                         PlayStatusUpdate response;
  45                         if (revision > 0) {
  46                                 response = (PlayStatusUpdate)request("/ctrl-int/1/playstatusupdate?revision-number="+revision);
  47                         }
  48                         else {
  49                                 response = (PlayStatusUpdate)request("/ctrl-int/1/playstatusupdate");
  50                         }
  51                         revision = response.revision;
  52
  53                         if (response.state == PlayStatusUpdate.Status.PLAYING) {
  54
  55                                 current = response.active().currentTrackId;
  56                                 Song song = (Song)request("/ctrl-int/1/current");
  57
  58                                 if (song != null && song.song() != null) {
  59                                         try {
  60                                                 String name = response.active().trackTitle + " by " + response.active().trackArtist;
  61                                                 player = new AudioPlayer(name, new ByteArrayInputStream(song.song()));
  62                                                 System.out.println("playing");
  63                                                 player.start(); //blocks until stream finishes playing
  64                                                 System.out.println("done");
  65
  66                                                 if (!player.stopped()) {
  67                                                         System.out.println("finished: next song");
  68                                                         request("/ctrl-int/1/nextitem?revision-number="+revision);
  69                                                 }
  70
  71                                                 player = null;
  72                                                 song = null;
  73                                         }
  74                                         catch (IOException ex) {
  75                                                 ex.printStackTrace();
  76                                         } catch (UnsupportedAudioFileException e) {
  77                                                 e.printStackTrace();
  78                                         }
  79                                 }
  80
  81                                 if (song != null) {
  82                                         if (player != null) {
  83                                                 player.stop();
  84                                                 player = null;
  85                                         }
  86
  87                                         System.out.println("error: next song");
  88                                         request("/ctrl-int/1/nextitem?revision-number="+revision);
  89                                 }
  90                         }
  91                 }
  92         }
  93
  94         public void listen() {
  95
  96                 int revision = 0;
  97                 String rev = "";
  98                 while (true) {
  99
 100                         if (revision != 0) {
 101                                 rev = "?revision-number="+revision;
 102                         }
 103                         Response response = request("/ctrl-int/1/playstatusupdate"+rev);
 104
 105                         if (response == null) break;
 106
 107                         if (response.type() == Constants.dmcp_status) {
 108                                 PlayStatusUpdate psu = (PlayStatusUpdate)response;
 109
 110                                 revision = psu.revision;
 111
 112                                 switch (psu.state) {
 113                                 case STOPPED:
 114                                         if (player != null && !player.isPlaying()) player.stop();
 115                                         break;
 116                                 case PAUSED:
 117                                         if (player != null && player.isPlaying()) player.pause();
 118                                         break;
 119                                 case PLAYING:
 120                                         if (player != null && !player.isPlaying()) player.play();
 121                                         break;
 122                                 }
 123
 124                                 if (psu.active()!=null) {
 125                                         PlayStatusUpdate.Active psua = psu.active();
 126                                         System.out.printf("Playing %s by %s\n", psua.trackTitle, psua.trackArtist);
 127                                         if (current != psua.currentTrackId) {
 128                                                 if (player != null) player.stop();
 129                                         }
 130                                 }
 131                                 else {
 132                                         System.out.println("Stopped");
 133                                 }
 134                         }
 135                         else {
 136                                 System.err.println("Unexpected reponse type: " + response.type().longName);
 137                                 break;
 138                         }
 139                 }
 140         }
 141
 142         private Response request(String request) {
 143                 try {
 144                         return parser.request(host, port, request);
 145                 } catch (UnknownHostException e) {
 146                         System.err.println("Unable to connect to " + host);
 147                         e.printStackTrace();
 148                 } catch (IOException e) {
 149                         System.err.println("Problem contacting " + host);
 150                         e.printStackTrace();
 151                 }
 152
 153                 return null;
 154         }
 155
 156         private class AmpResponseParser extends DACPResponseParser {
 157
 158                 @Override
 159                 public AlbumFactory albumFactory() {
 160                         return null;
 161                 }
 162
 163                 @Override
 164                 public PlaylistFactory playlistFactory() {
 165                         return null;
 166                 }
 167
 168                 @Override
 169                 public TrackFactory trackFactory() {
 170                         return null;
 171                 }
 172
 173         }
 174 }