genericized music playing, made transitioning from any music type to any

other clean and good.


git-svn-id: svn+ssh://src.earth.threerings.net/narya/trunk@1983 542714f4-19e9-0310-aa3c-eee0fc999fb1

src/java/com/threerings/media/sound/Mp3Player.java

@@ -0,0 +1,126 @@
+//
+// $Id: Mp3Player.java,v 1.1 2002/11/22 04:23:31 ray Exp $
+
+package com.threerings.media;
+
+import java.io.BufferedInputStream;
+import java.io.ByteArrayInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+
+import javax.sound.sampled.AudioFormat;
+import javax.sound.sampled.AudioInputStream;
+import javax.sound.sampled.AudioSystem;
+import javax.sound.sampled.DataLine.Info;
+import javax.sound.sampled.DataLine;
+import javax.sound.sampled.Line;
+import javax.sound.sampled.LineUnavailableException;
+import javax.sound.sampled.SourceDataLine;
+
+import org.apache.commons.io.StreamUtils;
+
+import com.threerings.resource.ResourceManager;
+
+/**
+ * Does something extraordinary.
+ */
+public class Mp3Player extends MusicPlayer
+{
+    // documentation inherited
+    public void init ()
+    {
+    }
+
+    // documentation inherited
+    public void shutdown ()
+    {
+    }
+
+    // documentation inherited
+    public void start (final String set, final String path)
+        throws Exception
+    {
+        // TODO: some stuff needs to come out of here and into init/shutdown
+        // but we'll deal with all that later, d00d.
+        _player = new Thread("narya mp3 relay") {
+            public void run () {
+                AudioInputStream inStream = null;
+                try {
+                    inStream = AudioSystem.getAudioInputStream(
+//                       new ByteArrayInputStream(StreamUtils.streamAsBytes(
+//                               _rmgr.getResource(path), 8192)));
+                        // TODO: use the fucking resource sets
+                        new BufferedInputStream(
+                            _rmgr.getResource(set, path), 4096));
+                } catch (Exception e) {
+                    Log.warning("MP3 fuckola [path=" + path +
+                        ", e=" + e + "].");
+                    return;
+                }
+
+                AudioFormat sourceFormat = inStream.getFormat();
+                AudioFormat.Encoding targetEnc =
+                    AudioFormat.Encoding.PCM_SIGNED;
+
+                inStream = AudioSystem.getAudioInputStream(
+                    targetEnc, inStream);
+                AudioFormat format = inStream.getFormat();
+
+                SourceDataLine line = null;
+                DataLine.Info info = new DataLine.Info(
+                    SourceDataLine.class, format);
+
+                try {
+                    line = (SourceDataLine) AudioSystem.getLine(info);
+                    line.open(format);
+                } catch (LineUnavailableException lue) {
+                    Log.warning("MP3 line unavailable: " + lue);
+                    return;
+                }
+
+                line.start();
+
+                byte[] data = new byte[BUFFER_SIZE];
+                int count = 0;
+                while (count >= 0) {
+                    try {
+                        count = inStream.read(data, 0, data.length);
+                    } catch (IOException ioe) {
+                        Log.warning("Error reading MP3: " + ioe);
+                        break;
+                    }
+                    if (count >= 0) {
+                        line.write(data, 0, count);
+                    }
+                    if (_player != Thread.currentThread()) {
+                        return;
+                    }
+                }
+
+                line.drain();
+                line.close();
+                _musicListener.musicStopped();
+            }
+        };
+
+        _player.setDaemon(true);
+        _player.setPriority(_player.getPriority() + 1);
+        _player.start();
+    }
+
+    // documentation inherited
+    public void stop ()
+    {
+        _player = null;
+    }
+
+    // documentation inherited
+    public void setVolume (float volume)
+    {
+        // TODO
+    }
+
+    protected Thread _player;
+
+    protected static final int BUFFER_SIZE = 8192;
+}