RSS news reader; initially copied from "all the news"

[phpeclipse.git] / archive / net.sourceforge.phpeclipse.news / src / net / sourceforge / phpeclipse / news / Channel.java

diff --git a/archive/net.sourceforge.phpeclipse.news/src/net/sourceforge/phpeclipse/news/Channel.java b/archive/net.sourceforge.phpeclipse.news/src/net/sourceforge/phpeclipse/news/Channel.java
new file mode 100644 (file)
index 0000000..8b22c55
--- /dev/null
+++ b/archive/net.sourceforge.phpeclipse.news/src/net/sourceforge/phpeclipse/news/Channel.java
@@ -0,0 +1,194 @@
+package net.sourceforge.phpeclipse.news;
+
+import java.io.InputStream;
+import java.io.PushbackInputStream;
+import java.net.URL;
+import java.net.URLConnection;
+import java.net.UnknownHostException;
+import java.util.ArrayList;
+import java.util.HashSet;
+
+import javax.xml.parsers.DocumentBuilder;
+import javax.xml.parsers.DocumentBuilderFactory;
+
+import org.eclipse.core.runtime.Preferences;
+import org.w3c.dom.Document;
+import org.w3c.dom.Element;
+import org.w3c.dom.NodeList;
+import org.xml.sax.InputSource;
+
+/**
+ * @author jnegre - http://www.jnegre.org/
+ *
+ * (c)Copyright 2002 Jérôme Nègre
+ * 
+ */
+public class Channel {
+
+    private final String url;
+    private final String title;
+
+    private boolean refreshing = false;
+    private String errorMessage = null;
+    private boolean unread = false;
+    
+    private ArrayList items = new ArrayList();
+    private HashSet readUids = null;
+
+    /**
+     * Constructor for Channel.
+     */
+    public Channel(String title, String url) {
+       this(title, url, null);
+    }
+
+    public Channel(String title, String url, HashSet readUids) {
+        this.title = title;
+        this.url = url;
+        this.readUids = readUids;
+    }
+
+
+    public void update() {
+        update(Plugin.getDefault().getPluginPreferences());
+    }
+
+
+    public void update(Preferences prefs) {
+            ArrayList newItems = new ArrayList();
+            String newErrorMessage = null;
+        try {
+            
+            URLConnection conn = new URL(url).openConnection();
+            conn.setRequestProperty("User-Agent", Plugin.userAgent);
+            if(prefs.getBoolean(Plugin.FORCE_CACHE_PREFERENCE)) {
+               conn.setRequestProperty("Pragma", "no-cache");
+                       conn.setRequestProperty("Cache-Control", "no-cache");
+            }
+            InputStream stream = conn.getInputStream();
+            
+            /* workaround a bug of crimson (it seems to ignore the encoding
+             * if it does not get it the first time it reads bytes from
+             * the stream. We use a PushbackInputStream to be sure that the
+             * encoding declaration is in the buffer)
+             */
+            PushbackInputStream pbStream = new PushbackInputStream(stream,64);
+            byte[] buffer = new byte[64];
+            int pos = 0;
+            while(pos != 64) {
+               pos += pbStream.read(buffer, pos, 64-pos);
+            }
+            pbStream.unread(buffer);
+            //end workaround
+            
+            DocumentBuilder parser = DocumentBuilderFactory.newInstance().newDocumentBuilder();
+            InputSource inputSource = new InputSource(pbStream);
+            Document doc = parser.parse(inputSource);
+            pbStream.close();
+            NodeList itemNodes = doc.getElementsByTagName("item");
+            for (int i = 0; i < itemNodes.getLength(); i++) {
+                Item aNewItem = new Item(this, (Element) itemNodes.item(i));
+                if(aNewItem.isBanned()) continue;
+                if(readUids!=null && readUids.remove(aNewItem.getUID())) {
+                       aNewItem.setReadFlag(true);
+                }
+                int indexOld = items.indexOf(aNewItem);
+                if(indexOld != -1) {
+                    newItems.add(items.get(indexOld));
+                } else {
+                    newItems.add(aNewItem);
+                }
+                
+            }
+            this.readUids = null;
+        } catch(UnknownHostException e) {
+          // no connection to internet
+        } catch(Exception e) {
+            newErrorMessage = e.toString();
+            Plugin.logInfo("Error in channel update",e);
+        }
+        
+        synchronized(this) {
+            this.errorMessage = newErrorMessage;
+            if(newErrorMessage == null) {
+                this.items = newItems;
+                computeUnRead();
+            }
+        }
+    }
+
+    /**
+     * Returns the url.
+     * @return String
+     */
+    public String getUrl() {
+        return url;
+    }
+
+    /**
+     * Returns the errorMessage.
+     * @return String
+     */
+    public synchronized String getErrorMessage() {
+        return errorMessage;
+    }
+
+    /**
+     * Returns the items.
+     * @return ArrayList
+     */
+    public synchronized ArrayList getItems() {
+        return new ArrayList(items);
+    }
+
+    /**
+     * @see java.lang.Object#toString()
+     */
+    public String toString() {
+        return "Channel at "+url;
+    }
+
+    /**
+     * Returns the title.
+     * @return String
+     */
+    public String getTitle() {
+        return title;
+    }
+
+    /**
+     * Returns the refreshing.
+     * @return boolean
+     */
+    public boolean isRefreshing() {
+        return refreshing;
+    }
+
+    /**
+     * Sets the refreshing.
+     * @param refreshing The refreshing to set
+     */
+    public void setRefreshing(boolean refreshing) {
+        this.refreshing = refreshing;
+    }
+
+    /**
+     * Returns the unread.
+     * @return boolean
+     */
+    public boolean isUnread() {
+        return unread;
+    }
+
+    public synchronized void computeUnRead() {
+        this.unread = false;
+        for (int i = 0; i < items.size(); i++) {
+            this.unread = this.unread || !((Item)items.get(i)).isReadFlag();
+        }
+    }
+    
+    public String getUID() {
+       return "CHA" + url;
+    }
+
+}