From 42516faa2e2aa57114e824a262396e443563a140 Mon Sep 17 00:00:00 2001
From: Andrew Dolgov <fox@madoka.volgo-balt.ru>
Date: Wed, 7 Dec 2011 14:59:30 +0300
Subject: implement offline image caching

---
 src/org/fox/ttrss/OfflineDownloadService.java | 76 +++++++++++++++++++++++----
 1 file changed, 65 insertions(+), 11 deletions(-)

(limited to 'src/org/fox/ttrss/OfflineDownloadService.java')

diff --git a/src/org/fox/ttrss/OfflineDownloadService.java b/src/org/fox/ttrss/OfflineDownloadService.java
index 7a44d48b..933cc75e 100644
--- a/src/org/fox/ttrss/OfflineDownloadService.java
+++ b/src/org/fox/ttrss/OfflineDownloadService.java
@@ -4,15 +4,25 @@ import java.lang.reflect.Type;
 import java.util.HashMap;
 import java.util.List;
 
+import org.jsoup.Jsoup;
+import org.jsoup.nodes.Document;
+import org.jsoup.nodes.Element;
+import org.jsoup.select.Elements;
+
+import android.app.ActivityManager;
+import android.app.ActivityManager.RunningServiceInfo;
 import android.app.IntentService;
 import android.app.Notification;
 import android.app.NotificationManager;
 import android.app.PendingIntent;
 import android.content.Context;
 import android.content.Intent;
+import android.content.SharedPreferences;
 import android.database.sqlite.SQLiteDatabase;
 import android.database.sqlite.SQLiteStatement;
 import android.os.Bundle;
+import android.os.Environment;
+import android.preference.PreferenceManager;
 import android.provider.BaseColumns;
 import android.util.Log;
 
@@ -37,6 +47,9 @@ public class OfflineDownloadService extends IntentService {
 	private NotificationManager m_nmgr;
 	
 	private boolean m_downloadInProgress = false;
+	private boolean m_downloadImages = false;
+	private int m_syncMax;
+	private SharedPreferences m_prefs;
 	
 	public OfflineDownloadService() {
 		super("OfflineDownloadService");
@@ -46,13 +59,15 @@ public class OfflineDownloadService extends IntentService {
 	public void onCreate() {
 		super.onCreate();
 		m_nmgr = (NotificationManager)getSystemService(NOTIFICATION_SERVICE);
+		m_prefs = PreferenceManager
+						.getDefaultSharedPreferences(getApplicationContext());
+ 
+		m_downloadImages = m_prefs.getBoolean("offline_image_cache_enabled", false);
+		m_syncMax = m_prefs.getInt("offline_sync_max", OFFLINE_SYNC_MAX);
+		
 		initDatabase();
 	}
 	
-	/* public boolean getDownloadInProgress() {
-		return m_downloadInProgress;
-	} */
-	
 	private void updateNotification(String msg) {
 		Notification notification = new Notification(R.drawable.icon, 
 				getString(R.string.notify_downloading_title), System.currentTimeMillis());
@@ -78,15 +93,30 @@ public class OfflineDownloadService extends IntentService {
         m_downloadInProgress = false;
 	}
 	
+	private boolean isCacheServiceRunning() {
+	    ActivityManager manager = (ActivityManager) getSystemService(ACTIVITY_SERVICE);
+	    for (RunningServiceInfo service : manager.getRunningServices(Integer.MAX_VALUE)) {
+	        if ("org.fox.ttrss.ImageCacheService".equals(service.service.getClassName())) {
+	            return true;
+	        }
+	    }
+	    return false;
+	}
+	
 	public void downloadComplete() {
 		m_downloadInProgress = false;
 		
-        m_nmgr.cancel(NOTIFY_DOWNLOADING);
-        
-        Intent intent = new Intent();
-        intent.setAction(INTENT_ACTION_SUCCESS);
-        intent.addCategory(Intent.CATEGORY_DEFAULT);
-        sendBroadcast(intent);
+        // if cache service is running, it will send a finished intent on its own
+        if (!isCacheServiceRunning()) {
+            m_nmgr.cancel(NOTIFY_DOWNLOADING);
+
+			Intent intent = new Intent();
+			intent.setAction(INTENT_ACTION_SUCCESS);
+			intent.addCategory(Intent.CATEGORY_DEFAULT);
+			sendBroadcast(intent);
+        } else {
+        	updateNotification("Downloading images...");
+        }
         
         m_readableDb.close();
         m_writableDb.close();
@@ -242,6 +272,28 @@ public class OfflineDownloadService extends IntentService {
 						stmtInsert.bindString(10, tagsString); // comma-separated tags
 						stmtInsert.bindString(11, article.content);
 						
+						if (m_downloadImages) {
+							Document doc = Jsoup.parse(article.content);
+							
+							if (doc != null) {
+								Elements images = doc.select("img");
+								
+								for (Element img : images) {
+									String url = img.attr("src");
+									
+									if (url.indexOf("://") != -1) {
+										if (!ImageCacheService.isUrlCached(url)) {										
+											Intent intent = new Intent(OfflineDownloadService.this,
+													ImageCacheService.class);
+										
+											intent.putExtra("url", url);
+											startService(intent);
+										}
+									}
+								}
+							}
+						}
+						
 						try {
 							stmtInsert.execute();
 						} catch (Exception e) {
@@ -257,7 +309,7 @@ public class OfflineDownloadService extends IntentService {
 	
 					Log.d(TAG, "offline: received " + articles.size() + " articles");
 					
-					if (articles.size() == OFFLINE_SYNC_SEQ && m_articleOffset < OFFLINE_SYNC_MAX) {
+					if (articles.size() == OFFLINE_SYNC_SEQ && m_articleOffset < m_syncMax) {
 						downloadArticles();
 					} else {
 						downloadComplete();
@@ -285,6 +337,8 @@ public class OfflineDownloadService extends IntentService {
 		m_sessionId = intent.getStringExtra("sessionId");
 		
 		if (!m_downloadInProgress) {
+			if (m_downloadImages) ImageCacheService.cleanupCache(false);
+			
 			updateNotification(R.string.notify_downloading_init);
 			m_downloadInProgress = true;
 		
-- 
cgit v1.2.3-54-g00ecf