DACPlib/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.HashSet;
   9 import java.util.List;
  10 import java.util.Set;
  11
  12 /**
  13  * DAAPLackey polls DAAP libraries for changes and updates the DJ's library.
  14  */
  15 public class DAAPLackey {
  16
  17         private final Set<DAAPClient> clients;
  18
  19         private final Library<? extends Track> library;
  20
  21         private static DAAPLackey lackey;
  22         public static DAAPLackey lackey() {
  23                 return lackey;
  24         }
  25
  26         public DAAPLackey(Library<? extends Track> library) {
  27
  28                 lackey = this;
  29
  30                 this.library = library;
  31                 this.clients = new HashSet<DAAPClient>();
  32
  33                 new PollThread().start();
  34         }
  35
  36         public void request(final String host, final int port) {
  37
  38                 new Thread("DAAP Connection Thread") {
  39                         public void run() {
  40
  41                                 try {
  42                                         List<DAAPClient> pls =  DAAPClient.create(host, port, library.nextCollectionId());
  43
  44                                         for (DAAPClient c: pls) {
  45                                                 add(c);
  46                                         }
  47                                 }
  48                                 catch (IOException ex) {
  49                                         System.err.println("Error connecting to daap server: " + ex.getMessage());
  50                                 }
  51
  52                         }
  53                 }.start();
  54         }
  55
  56         private synchronized void add(DAAPClient client) {
  57                 clients.add(client);
  58                 library.addSource(client);
  59                 library.addCollection(client.collection());
  60         }
  61
  62         private synchronized void remove(DAAPClient client) {
  63                 library.removeCollection(client.collection());
  64                 library.removeSource(client);
  65                 clients.remove(client);
  66         }
  67
  68         private synchronized List<DAAPClient> clients() {
  69                 return new ArrayList<DAAPClient>(clients);
  70         }
  71
  72         private class PollThread extends Thread {
  73                 public void run() {
  74                         while (true) {
  75
  76                                 List<DAAPClient> clients = clients();
  77
  78                                 for (DAAPClient client: clients) {
  79                                         try {
  80                                                 client.update();
  81                                         }
  82                                         catch (IOException ex) {
  83                                                 System.err.println("Unable to update client, closing (" + client.collection().name() + ")");
  84                                                 ex.printStackTrace();
  85
  86                                                 client.close();
  87                                                 remove(client);
  88                                         }
  89                                 }
  90
  91                                 try {
  92                                         Thread.sleep(10000);
  93                                 } catch (InterruptedException e) {
  94                                         //swallow
  95                                 }
  96                         }
  97                 }
  98         }
  99
 100 }