Start of the thread watcher.

Chan/AndroidManifest.xml

@@ -86,13 +86,8 @@
         
         <service
         	android:name="org.floens.chan.service.PinnedService"
-        	android:exported="false"
+        	android:exported="false" >
-        ></service>
+        </service>
     </application>
-
 </manifest>
 
-
-
-
-

Chan/res/drawable/pin_icon.xml

@@ -0,0 +1,16 @@
+<?xml version="1.0" encoding="utf-8"?>
+<inset xmlns:android="http://schemas.android.com/apk/res/android"
+    android:insetLeft="8dp"
+    android:insetTop="8dp"
+    android:insetRight="8dp"
+    android:insetBottom="8dp" >
+    <shape>
+	    <solid 
+	        android:color="#FF0099CC" />
+	    
+	    <corners 
+	        android:radius="4dp" />
+	    
+    </shape>
+    
+</inset>

Chan/res/layout/drawer_item.xml

@@ -1,23 +0,0 @@
-<?xml version="1.0" encoding="utf-8"?>
-<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
-    android:layout_width="match_parent"
-    android:layout_height="wrap_content" >
-    <TextView 
-	    android:id="@+id/drawer_item_text"
-	    android:layout_width="match_parent"
-	    android:layout_height="wrap_content"
-	    android:minHeight="48dp"
-	    android:paddingTop="8dp"
-	    android:paddingBottom="8dp"
-	    android:paddingLeft="16dp"
-	    android:paddingRight="56dp"
-	    android:textSize="19sp"
-	    android:textColor="#fff"
-	    android:gravity="center_vertical"
-	    android:ellipsize="end"
-		android:lines="1"
-		android:singleLine="true"
-	    android:orientation="vertical" >
-</TextView>
-</LinearLayout>
-

Chan/res/layout/pin_item.xml

@@ -0,0 +1,41 @@
+<?xml version="1.0" encoding="utf-8"?>
+<LinearLayout 
+    xmlns:android="http://schemas.android.com/apk/res/android"
+    android:layout_width="match_parent"
+    android:layout_height="48dp"
+    android:orientation="horizontal" >
+    
+	<TextView
+		android:id="@+id/drawer_item_text"
+		android:layout_width="0dp"
+		android:layout_height="48dp"
+		android:layout_weight="1"
+		android:paddingTop="8dp"
+		android:paddingBottom="8dp"
+		android:paddingLeft="16dp"
+		android:paddingRight="8dp"
+		android:textSize="19sp"
+		android:textColor="#fff"
+		android:gravity="center_vertical"
+		android:ellipsize="end"
+		android:lines="1"
+		android:singleLine="true">
+	</TextView>
+	
+	<FrameLayout
+	    android:background="@drawable/pin_icon"
+	    android:layout_width="48dp"
+	    android:layout_height="48dp" >
+	    
+		<TextView
+		    android:id="@+id/drawer_item_count"
+		    android:layout_width="match_parent"
+		    android:layout_height="match_parent"
+		    android:gravity="center"
+		    android:textSize="16dp"
+		    android:textColor="#fff"
+	        android:text="99+" />
+		
+	</FrameLayout>
+	
+</LinearLayout>

Chan/src/org/floens/chan/ChanApplication.java

@@ -4,9 +4,11 @@ import org.floens.chan.database.DatabaseManager;
 import org.floens.chan.manager.BoardManager;
 import org.floens.chan.manager.PinnedManager;
 import org.floens.chan.manager.ReplyManager;
+import org.floens.chan.service.PinnedService;
 import org.floens.chan.utils.IconCache;
 
 import android.app.Application;
+import android.content.Intent;
 import android.content.SharedPreferences;
 import android.os.StrictMode;
 import android.preference.PreferenceManager;
@@ -62,8 +64,6 @@ public class ChanApplication extends Application {
                 .build());
         }
         
-        // startService(new Intent(this, PinnedService.class));
-        
         // VolleyLog.setTag(getPackageName());
         
         IconCache.createIcons(this);
@@ -73,13 +73,14 @@ public class ChanApplication extends Application {
         
         // These manager need a Context
         new DatabaseManager(this);
+        
         new BoardManager(this);
         new PinnedManager(this);
         new ReplyManager(this);
+        
+        startService(new Intent(this, PinnedService.class));
     }
 }
 
 
 
-
-

Chan/src/org/floens/chan/adapter/PinnedAdapter.java

@@ -38,11 +38,11 @@ public class PinnedAdapter extends ArrayAdapter<Pin> {
         Pin item = getItem(position);
         
         if (item.type == Pin.Type.HEADER) {
-            view = (LinearLayout) inflater.inflate(R.layout.drawer_item_header, null);
+            view = (LinearLayout) inflater.inflate(R.layout.pin_item_header, null);
             
             ((TextView) view.findViewById(R.id.drawer_item_header)).setText(R.string.drawer_pinned);
         } else {
-            view = (LinearLayout) inflater.inflate(R.layout.drawer_item, null);
+            view = (LinearLayout) inflater.inflate(R.layout.pin_item, null);
             
             ((TextView) view.findViewById(R.id.drawer_item_text)).setText(item.loadable.title);
         }

Chan/src/org/floens/chan/database/DatabaseManager.java

@@ -50,6 +50,20 @@ public class DatabaseManager {
         }
     }
     
+    public void updatePins(List<Pin> pins) {
+        try {
+            for (Pin pin : pins) {
+                helper.pinDao.update(pin);
+            }
+            
+            for (Pin pin : pins) {
+                helper.loadableDao.update(pin.loadable);
+            }
+        } catch(SQLException e) {
+            Logger.e("Error updating pins in db", e);
+        }
+    }
+    
     public List<Pin> getPinned() {
         List<Pin> list = null;
         try {

Chan/src/org/floens/chan/fragment/PostRepliesFragment.java

@@ -8,7 +8,6 @@ import org.floens.chan.model.Post;
 import org.floens.chan.view.PostView;
 
 import android.app.DialogFragment;
-import android.content.Context;
 import android.content.DialogInterface;
 import android.os.Bundle;
 import android.view.LayoutInflater;
@@ -21,7 +20,6 @@ import android.widget.ListView;
  * A DialogFragment that shows a list of posts. Use the newInstance method for instantiating.
  */
 public class PostRepliesFragment extends DialogFragment {
-    private Context context;
     private ListView listView;
     
     private List<Post> posts;
@@ -59,8 +57,6 @@ public class PostRepliesFragment extends DialogFragment {
     
     @Override
     public View onCreateView(LayoutInflater inflater, ViewGroup unused, Bundle savedInstanceState) {
-        context = inflater.getContext();
-        
         View container = inflater.inflate(R.layout.post_replies, null);
         
         listView = (ListView) container.findViewById(R.id.post_list);

Chan/src/org/floens/chan/manager/PinnedManager.java

@@ -53,6 +53,10 @@ public class PinnedManager {
         return null;
     }
     
+    public List<Pin> getPins() {
+        return pins;
+    }
+    
     /**
      * Add a pin
      * @param pin
@@ -91,14 +95,13 @@ public class PinnedManager {
     /**
      * Updates all the pins to the database. 
      * This will run in a new thread because it can be an expensive operation.
+     * (this will be an huge headache later on when we get concurrent problems)
      */
     public void updateAll() {
         new Thread(new Runnable() {
             @Override
             public void run() {
-                for (Pin pin : pins) {
+                DatabaseManager.getInstance().updatePins(pins);
-                    DatabaseManager.getInstance().updatePin(pin);
-                }
             }
         }).start();
     }

Chan/src/org/floens/chan/model/Pin.java

@@ -1,23 +1,58 @@
 package org.floens.chan.model;
 
+import java.util.List;
+
+import org.floens.chan.net.ThreadLoader;
+import org.floens.chan.utils.Logger;
+
+import com.android.volley.VolleyError;
 import com.j256.ormlite.field.DatabaseField;
 import com.j256.ormlite.table.DatabaseTable;
 
 @DatabaseTable
-public class Pin {
+public class Pin implements ThreadLoader.ThreadLoaderListener {
+    // Database stuff
     @DatabaseField(generatedId = true)
     private int id;
     
-    public Type type = Type.THREAD;
-    
     @DatabaseField(canBeNull = false, foreign = true)
     public Loadable loadable = new Loadable("", -1);
     
+    // ListView Stuff
     /** Header is used to display a static header in the drawer listview. */
+    public Type type = Type.THREAD;
     public static enum Type {
         HEADER, 
         THREAD
     };
+    
+    // PinnedService stuff
+    public ThreadLoader threadLoader;
+    public int lastPostCount;
+    public int newPostCount;
+    
+    public void update() {
+        Logger.test("Update in pin");
+        
+        if (threadLoader == null) {
+            threadLoader = new ThreadLoader(this);
+        }
+        
+        threadLoader.start(loadable);
+    }
+    
+    @Override
+    public void onError(VolleyError error) {
+        Logger.test("OnError in pin: ", error);
+    }
+    
+    @Override
+    public void onData(List<Post> result) {
+        Logger.test("OnData in pin: ");
+        Logger.test("Size: " + result.size());
+        
+        newPostCount = result.size();
+    }
 }
 
 

Chan/src/org/floens/chan/net/ThreadLoader.java

@@ -118,7 +118,7 @@ public class ThreadLoader {
         }
     }
     
-    public static abstract class ThreadLoaderListener {
+    public static abstract interface ThreadLoaderListener {
         public abstract void onData(List<Post> result);
         public abstract void onError(VolleyError error);
     }

Chan/src/org/floens/chan/service/PinnedService.java

@@ -1,113 +1,84 @@
 package org.floens.chan.service;
 
-import java.util.ArrayList;
+import java.util.List;
 
+import org.floens.chan.R;
 import org.floens.chan.manager.PinnedManager;
 import org.floens.chan.model.Pin;
 
-public class PinnedService /*extends Service*/ {
+import android.app.Notification;
-    /**
+import android.app.NotificationManager;
-     * Base interval when the thread wakes up
+import android.app.Service;
-     */
+import android.content.Intent;
-    private final int LOAD_BASE_INTERVAL = 20000;
+import android.os.IBinder;
 
-    private PinnedManager pinnedManager;
+public class PinnedService extends Service {
     private Thread loadThread;
-    private final boolean running = true;
+    private boolean running = true;
     
-    private final ArrayList<Pin> pinList = new ArrayList<Pin>();
-    
-    private final Runnable loadRunnable = new Runnable() {
     @Override
-        public void run() {
+    public void onCreate() {
-            while (running) {
+        super.onCreate();
-//                loadPins();
         
-                try {
+        start();
-                    Thread.sleep(LOAD_BASE_INTERVAL);
-                } catch (InterruptedException e) {
-                    e.printStackTrace();
-                }
     }
-        }
-    };
     
-    /*public PinnedService() {
+    @Override
-        pinnedManager = ChanApplication.getPinnedManager();
+    public void onDestroy() {
-    }
+        super.onDestroy();
         
-    private void loadPins() {
+        running = false;
-        organizePins();
         
-        for (Pin pin : pinList) {
+        showNotification("Stop");
-            loadPin(pin);
-        }
     }
     
-    private void loadPin(Pin pin) {
+    @Override
-        if (!pin.threadLoader.isLoading()) {
+    public IBinder onBind(Intent intent) {
-            pin.startLoading();
+        return null;
-        }
     }
     
-    /**
+    private void start() {
-     * Add not yet added pins to our list.
+        showNotification("Start");
-     * Remove old/unwatched pins from our list.
-     
-    private void organizePins() {
-        ArrayList<Pin> managerList = pinnedManager.getPinnedThreads();
         
-        for (Pin pin : managerList) {
+        loadThread = new Thread(new Runnable() {
-            if (pin.getShouldWatch() && !pinList.contains(pin)) {
+            @Override
-                // Add pin to watcher
+            public void run() {
-                pinList.add(pin);
+                while (running) {
+                    doUpdates();
                     
-                testToast("Added pin: " + pin.loadable.title);
+                    try {
-            }
+                        Thread.sleep(60000);
+                    } catch (InterruptedException e) {
+                        e.printStackTrace();
                     }
-        
-        for (Iterator<Pin> it = pinList.iterator(); it.hasNext();) {
-            Pin pin = it.next();
-            if (!pin.getShouldWatch() || !managerList.contains(pin)) {
-                // Remove pin from watcher
-                it.remove();
-                
-                testToast("Removed pin: " + pin.loadable.title);
                 }
             }
+        });
+        
+        loadThread.start();
     }
     
-    private void testToast(final String text) {
+    private void doUpdates() {
-        new Handler(Looper.getMainLooper()).post(new Runnable() {
+        List<Pin> pins = PinnedManager.getInstance().getPins();
-            @Override
+        for (Pin pin : pins) {
-            public void run() {
+//            pin.update();
-                Toast.makeText(PinnedService.this, text, Toast.LENGTH_SHORT).show();
         }
-        });
     }
     
-    @Override
+    @SuppressWarnings("deprecation")
-    public void onCreate() {
+    private void showNotification(String text) {
-        super.onCreate();
+        NotificationManager nm = (NotificationManager) getSystemService(NOTIFICATION_SERVICE);
         
-        testToast("Service started!");
+        Notification.Builder builder = new Notification.Builder(this);
+        builder.setTicker(text);
+        builder.setContentTitle(text);
+        builder.setContentText(text);
+        builder.setSmallIcon(R.drawable.ic_stat_notify);
         
-        if (loadThread == null) {
+        nm.notify(1, builder.getNotification());
-            loadThread = new Thread(loadRunnable);
-//            loadThread.start();
     }
 }
 
-    @Override
-    public void onDestroy() {
-        super.onDestroy();
 
-        testToast("Service stopped!");
-    }
 
-    @Override
-    public IBinder onBind(Intent intent) {
-        return null;
-    }*/
 
-}

Chan/src/org/floens/chan/utils/Logger.java

@@ -61,6 +61,12 @@ public class Logger {
             Log.i(TAG_TEST, message);
         }
     }
+    
+    public static void test(String message, Throwable throwable) {
+        if (ChanApplication.DEVELOPER_MODE) {
+            Log.i(TAG_TEST, message, throwable);
+        }
+    }
 }