DAAPClient/src/daap/DAAPLackey.java

   1 package daap;
   2
   3 import interfaces.Library;
   4 import interfaces.Track;
   5
   6 import java.io.IOException;
   7 import java.util.ArrayList;
   8 import java.util.HashMap;
   9 import java.util.HashSet;
  10 import java.util.List;
  11 import java.util.Map;
  12 import java.util.Set;
  13
  14 import spi.SourceProvider;
  15 import stereo.dnssd.DNSSD;
  16 import stereo.dnssd.DNSSDProvider;
  17 import stereo.dnssd.DNSSDProvider.Service;
  18
  19 /**
  20  * DAAPLackey polls DAAP libraries for changes and updates the DJ's library.
  21  */
  22 public class DAAPLackey implements SourceProvider {
  23
  24         private Set<String> hosts;
  25         private Map<DAAPClient, String> clients;
  26
  27         private Library<? extends Track> library;
  28
  29         public void create(Library<? extends Track> library) {
  30                 this.library = library;
  31                 this.hosts = new HashSet<String>();
  32                 this.clients = new HashMap<DAAPClient, String>();
  33
  34                 new PollThread().start();
  35
  36                 DNSSD.impl().registerListener(new DNSSDProvider.ServiceListener() {
  37
  38                         public void serviceAvailable(Service service) {
  39                                 connect(service.name, "daap://"+service.host+":"+service.port);
  40                         }
  41
  42                         public void serviceUnavailable(Service service) {}
  43
  44                         public String type() {
  45                                 return "_daap._tcp";
  46                         }
  47
  48                 });
  49         }
  50
  51         public void connect(final String path) {
  52
  53                 connect(path, path);
  54
  55         }
  56
  57         public synchronized void connect(final String name, final String path) {
  58
  59                 if (hosts.contains(name)) return;
  60                 else hosts.add(name);
  61
  62                 if (!path.substring(0, 4).equals("daap")) return;
  63
  64                 final String pth = "http"+path.substring(4);
  65
  66                 new Thread("DAAP Connection Thread") {
  67                         public void run() {
  68
  69                                 try {
  70                                         List<DAAPClient> pls =  DAAPClient.create(pth, library.nextCollectionId());
  71
  72                                         for (DAAPClient c: pls) {
  73                                                 add(name, c);
  74                                         }
  75                                 }
  76                                 catch (IOException ex) {}
  77                         }
  78                 }.start();
  79         }
  80
  81         private synchronized void add(String name, DAAPClient client) {
  82                 hosts.add(name);
  83                 clients.put(client, name);
  84                 library.addSource(client);
  85                 library.addCollection(client.collection());
  86         }
  87
  88         private synchronized void remove(DAAPClient client) {
  89                 library.removeCollection(client.collection());
  90                 library.removeSource(client);
  91                 clients.remove(client);
  92                 hosts.remove(client);
  93         }
  94
  95         private synchronized List<DAAPClient> clients() {
  96                 return new ArrayList<DAAPClient>(clients.keySet());
  97         }
  98
  99         private class PollThread extends Thread {
 100                 public void run() {
 101                         while (true) {
 102
 103                                 List<DAAPClient> clients = clients();
 104
 105                                 for (DAAPClient client: clients) {
 106                                         try {
 107                                                 client.update();
 108                                         }
 109                                         catch (IOException ex) {
 110                                                 System.err.println("Unable to update client, closing (" + client.collection().name() + ")");
 111                                                 ex.printStackTrace();
 112
 113                                                 client.close();
 114                                                 remove(client);
 115                                         }
 116                                 }
 117
 118                                 try {
 119                                         Thread.sleep(10000);
 120                                 } catch (InterruptedException e) {
 121                                         //swallow
 122                                 }
 123                         }
 124                 }
 125         }
 126
 127 }