diff options
Diffstat (limited to 'src/org/fox/ttrss/MainActivity.java')
-rw-r--r-- | src/org/fox/ttrss/MainActivity.java | 416 |
1 files changed, 3 insertions, 413 deletions
diff --git a/src/org/fox/ttrss/MainActivity.java b/src/org/fox/ttrss/MainActivity.java index 7b57b366..1525a439 100644 --- a/src/org/fox/ttrss/MainActivity.java +++ b/src/org/fox/ttrss/MainActivity.java @@ -33,37 +33,12 @@ import com.google.gson.reflect.TypeToken; public class MainActivity extends Activity { private final String TAG = this.getClass().getSimpleName(); - private final static int UPDATE_INITIAL = 1; - private final static int UPDATE_SEQUENTIAL = 2; - private final static int UPDATE_OFFLINE = 3; - - private final static int OFFSET_MAX = 100; - private SharedPreferences m_prefs; private String m_themeName = ""; - private boolean m_feedsOpened = false; - private boolean m_splashDisabled = false; protected String m_sessionId; - protected int m_offset = 0; - protected int m_limit = 30; - protected int m_maxId = 0; - protected int m_updateMode = UPDATE_INITIAL; - - private SQLiteDatabase m_readableDb; - private SQLiteDatabase m_writableDb; - - protected enum SyncStatus { SYNC_INITIAL, SYNC_ONLINE, SYNC_OFFLINE }; protected MenuItem m_syncStatus; - protected synchronized SQLiteDatabase getReadableDb() { - return m_readableDb; - } - - protected synchronized SQLiteDatabase getWritableDb() { - return m_writableDb; - } - protected String getSessionId() { return m_sessionId; } @@ -76,25 +51,6 @@ public class MainActivity extends Activity { editor.commit(); } - private Timer m_articlesTimer; - private Timer m_feedsTimer; - private ArticlesTask m_articlesTask; - private FeedsTask m_feedsTask; - - private class ArticlesTask extends TimerTask { - @Override - public void run() { - downloadArticles(); - } - }; - - private class FeedsTask extends TimerTask { - @Override - public void run() { - downloadFeeds(); - } - }; - /** Called when the activity is first created. */ @Override public void onCreate(Bundle savedInstanceState) { @@ -109,87 +65,26 @@ public class MainActivity extends Activity { } m_themeName = m_prefs.getString("theme", "THEME_DARK"); - m_sessionId = m_prefs.getString("last_session_id", null); if (savedInstanceState != null) { - m_feedsOpened = savedInstanceState.getBoolean("feedsOpened"); m_sessionId = savedInstanceState.getString("sessionId"); - m_offset = savedInstanceState.getInt("offset"); - m_limit = savedInstanceState.getInt("limit"); - m_updateMode = savedInstanceState.getInt("updateMode"); - m_maxId = savedInstanceState.getInt("maxId"); - m_splashDisabled = savedInstanceState.getBoolean("splashDisabled"); - } - - // allow database to upgrade before we do anything else - DatabaseHelper dh = new DatabaseHelper(getApplicationContext()); - m_writableDb = dh.getWritableDatabase(); - m_readableDb = dh.getReadableDatabase(); - - if (m_updateMode == UPDATE_INITIAL && !m_splashDisabled) { - m_writableDb.execSQL("DELETE FROM feeds;"); - //db.execSQL("DELETE FROM articles;"); - - if (m_maxId == 0) { - Cursor c = m_readableDb.query("articles", new String[] { BaseColumns._ID } , null, null, null, null, BaseColumns._ID + " DESC LIMIT 1"); - if (c.getCount() == 1) { - c.moveToFirst(); - //Log.i(TAG, "Last article # " + c.getInt(c.getColumnIndex(BaseColumns._ID))); - m_maxId = c.getInt(c.getColumnIndex(BaseColumns._ID)); - } - c.close(); - } } setContentView(R.layout.main); - LinearLayout wrapper = (LinearLayout) findViewById(R.id.headlines_wrapper); + ViewFlipper vf = (ViewFlipper) findViewById(R.id.main_flipper); - LayoutTransition transitioner = new LayoutTransition(); - wrapper.setLayoutTransition(transitioner); - - if (!m_feedsOpened) { - Log.d(TAG, "Opening feeds fragment..."); - - FragmentTransaction ft = getFragmentManager().beginTransaction(); - FeedsFragment frag = new FeedsFragment(); - - ft.setCustomAnimations(android.R.animator.fade_in, android.R.animator.fade_out); - ft.replace(R.id.feeds_container, frag, "FEEDLIST"); - ft.commit(); - - m_feedsOpened = true; - + if (vf != null) { + vf.showNext(); } - - if (m_splashDisabled) { - ViewFlipper vf = (ViewFlipper) findViewById(R.id.main_flipper); - - if (vf != null && vf.getDisplayedChild() == 0) - vf.showNext(); - - scheduleNextUpdate(); - } else { - m_feedsTask = new FeedsTask(); - m_feedsTimer = new Timer("UpdateFeeds"); - m_feedsTimer.schedule(m_feedsTask, 1000L, 60*1000L); - } - - //scheduleNextUpdate(); } @Override public void onSaveInstanceState (Bundle out) { super.onSaveInstanceState(out); - out.putBoolean("feedsOpened", m_feedsOpened); out.putString("sessionId", m_sessionId); - out.putInt("offset", m_offset); - out.putInt("limit", m_limit); - out.putInt("updateMode", m_updateMode); - out.putInt("maxId", m_maxId); - out.putBoolean("splashDisabled", m_splashDisabled); } @Override @@ -207,17 +102,6 @@ public class MainActivity extends Activity { public void onDestroy() { super.onDestroy(); - m_writableDb.close(); - m_readableDb.close(); - - if (m_feedsTask != null) m_feedsTask.cancel(); - if (m_articlesTask != null) m_articlesTask.cancel(); - - if (m_feedsTimer != null) m_feedsTimer.cancel(); - m_feedsTimer = null; - - if (m_articlesTimer != null) m_articlesTimer.cancel(); - m_articlesTimer = null; } @Override @@ -225,39 +109,9 @@ public class MainActivity extends Activity { MenuInflater inflater = getMenuInflater(); inflater.inflate(R.menu.main_menu, menu); - m_syncStatus = menu.findItem(R.id.sync_status); - - switch (m_updateMode) { - case UPDATE_INITIAL: - setSyncStatus(SyncStatus.SYNC_INITIAL); - break; - case UPDATE_SEQUENTIAL: - setSyncStatus(SyncStatus.SYNC_ONLINE); - break; - default: - setSyncStatus(SyncStatus.SYNC_OFFLINE); - } - return true; } - public void setSyncStatus(SyncStatus status) { - switch (status) { - case SYNC_INITIAL: - m_syncStatus.setTitle(R.string.synchronizing); - m_syncStatus.setIcon(android.R.drawable.presence_online); - break; - case SYNC_ONLINE: - m_syncStatus.setTitle(R.string.online); - m_syncStatus.setIcon(android.R.drawable.presence_online); - break; - case SYNC_OFFLINE: - m_syncStatus.setTitle(R.string.offline); - m_syncStatus.setIcon(android.R.drawable.presence_offline); - break; - } - } - @Override public boolean onOptionsItemSelected(MenuItem item) { switch (item.getItemId()) { @@ -269,268 +123,4 @@ public class MainActivity extends Activity { return super.onOptionsItemSelected(item); } } - - private synchronized void downloadArticles() { - ApiRequest api = new ApiRequest(m_sessionId, - m_prefs.getString("ttrss_url", null), - m_prefs.getString("login", null), - m_prefs.getString("password", null)); - - JsonElement result = api.sendRequest(new HashMap<String,String>() { - { - put("sid", m_sessionId); - put("op", "getHeadlines"); - put("feed_id", "-4"); - put("show_content", "1"); - put("limit", String.valueOf(m_limit)); - put("skip", String.valueOf(m_offset)); - put("view_mode", "unread"); - - if (m_offset == 0) { - put("since_id", String.valueOf(m_maxId)); - } - } - }); - - if (result != null && api.getAuthStatus() == ApiRequest.STATUS_OK) { - try { - setSessionId(api.getSessionId()); - - int articlesFound = 0; - - try { - JsonArray feeds_object = (JsonArray) result.getAsJsonArray(); - - Type listType = new TypeToken<List<Article>>() {}.getType(); - List<Article> articles = api.m_gson.fromJson(feeds_object, listType); - - /* db.execSQL("DELETE FROM articles"); */ - - SQLiteStatement stmtInsert = getWritableDb().compileStatement("INSERT INTO articles " + - "("+BaseColumns._ID+", unread, marked, published, updated, is_updated, title, link, feed_id, tags, content, excerpt) " + - "VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?);"); - - SQLiteStatement stmtUpdate = getWritableDb().compileStatement("UPDATE articles SET " + - "unread = ?, marked = ?, published = ?, updated = ?, is_updated = ?, title = ?, link = ?, feed_id = ?, " + - "tags = ?, content = ?, excerpt = ? WHERE " + BaseColumns._ID + " = ?"); - - for (Article article : articles) { - //Log.d(TAG, "Processing article #" + article.id); - - m_maxId = Math.max(m_maxId, article.id); - - ++articlesFound; - - Cursor c = getReadableDb().query("articles", new String[] { BaseColumns._ID } , BaseColumns._ID + "=?", - new String[] { String.valueOf(article.id) }, null, null, null); - - String excerpt = Jsoup.parse(article.content).text(); - - if (excerpt.length() > 250) { - excerpt = excerpt.substring(0, 250) + "..."; - } - - if (c.getCount() != 0) { - stmtUpdate.bindLong(1, article.unread ? 1 : 0); - stmtUpdate.bindLong(2, article.marked ? 1 : 0); - stmtUpdate.bindLong(3, article.published ? 1 : 0); - stmtUpdate.bindLong(4, article.updated); - stmtUpdate.bindLong(5, article.is_updated ? 1 : 0); - stmtUpdate.bindString(6, article.title); - stmtUpdate.bindString(7, article.link); - stmtUpdate.bindLong(8, article.feed_id); - stmtUpdate.bindString(9, ""); // comma-separated tags - stmtUpdate.bindString(10, article.content); - stmtUpdate.bindString(11, excerpt); - stmtUpdate.bindLong(12, article.id); - stmtUpdate.execute(); - - } else { - //Log.d(TAG, "article not found"); - - stmtInsert.bindLong(1, article.id); - stmtInsert.bindLong(2, article.unread ? 1 : 0); - stmtInsert.bindLong(3, article.marked ? 1 : 0); - stmtInsert.bindLong(4, article.published ? 1 : 0); - stmtInsert.bindLong(5, article.updated); - stmtInsert.bindLong(6, article.is_updated ? 1 : 0); - stmtInsert.bindString(7, article.title); - stmtInsert.bindString(8, article.link); - stmtInsert.bindLong(9, article.feed_id); - stmtInsert.bindString(10, ""); // comma-separated tags - stmtInsert.bindString(11, article.content); - stmtInsert.bindString(12, excerpt); - stmtInsert.execute(); - } - - c.close(); - } - - runOnUiThread(new Runnable() { - @Override - public void run() { - FeedsFragment ff = (FeedsFragment) getFragmentManager().findFragmentByTag("FEEDLIST"); - if (ff != null) ff.updateListView(); - } - }); - - } catch (Exception e) { - e.printStackTrace(); - } - - Log.d(TAG, articlesFound + " articles processed"); - - if (articlesFound == m_limit && m_offset < OFFSET_MAX) { - - m_offset += m_limit; - - } else { - m_offset = 0; - - if (m_updateMode == UPDATE_INITIAL) { - Log.i(TAG, "Switching to sequential mode..."); - - runOnUiThread(new Runnable() { - @Override - public void run() { - setSyncStatus(SyncStatus.SYNC_ONLINE); - } - }); - m_updateMode = UPDATE_SEQUENTIAL; - } - } - - m_splashDisabled = true; - - runOnUiThread(new Runnable() { - @Override - public void run() { - ViewFlipper vf = (ViewFlipper) findViewById(R.id.main_flipper); - - if (vf != null && vf.getDisplayedChild() == 0) { - vf.showNext(); - } - } - }); - - scheduleNextUpdate(); - - } catch (Exception e) { - e.printStackTrace(); - } - } else if (result != null && api.getAuthStatus() != ApiRequest.STATUS_OK) { - // TODO handle error, e.g auth failed - } else if (result == null) { - // TODO could not parse result, server/network error? - } - } - - private synchronized void downloadFeeds() { - ApiRequest api = new ApiRequest(m_sessionId, - m_prefs.getString("ttrss_url", null), - m_prefs.getString("login", null), - m_prefs.getString("password", null)); - - JsonElement result = api.sendRequest(new HashMap<String,String>() { - { - put("sid", m_sessionId); - put("op", "getFeeds"); - put("cat_id", "-3"); - put("unread_only", "1"); - } - }); - - if (result != null && api.getAuthStatus() == ApiRequest.STATUS_OK) { - try { - try { - setSessionId(api.getSessionId()); - } catch (NullPointerException e) { - // - } - - JsonArray feeds_object = (JsonArray) result.getAsJsonArray(); - - Type listType = new TypeToken<List<Feed>>() {}.getType(); - List<Feed> feeds = api.m_gson.fromJson(feeds_object, listType); - - SQLiteStatement stmtUpdate = getWritableDb().compileStatement("UPDATE feeds SET " + - "title = ?, feed_url = ?, has_icon = ?, cat_id = ?, last_updated = ? WHERE " + - BaseColumns._ID + " = ?"); - - SQLiteStatement stmtInsert = getWritableDb().compileStatement("INSERT INTO feeds " + - "("+BaseColumns._ID+", title, feed_url, has_icon, cat_id, last_updated) " + - "VALUES (?, ?, ?, ?, ?, ?);"); - - for (Feed feed : feeds) { - Cursor c = getReadableDb().query("feeds", new String[] { BaseColumns._ID } , BaseColumns._ID + "=?", - new String[] { String.valueOf(feed.id) }, null, null, null); - - if (c.getCount() != 0) { - stmtUpdate.bindString(1, feed.title); - stmtUpdate.bindString(2, feed.feed_url); - stmtUpdate.bindLong(3, feed.has_icon ? 1 : 0); - stmtUpdate.bindLong(4, feed.cat_id); - stmtUpdate.bindLong(5, feed.last_updated); - stmtUpdate.bindLong(6, feed.id); - stmtUpdate.execute(); - - } else { - stmtInsert.bindLong(1, feed.id); - stmtInsert.bindString(2, feed.title); - stmtInsert.bindString(3, feed.feed_url); - stmtInsert.bindLong(4, feed.has_icon ? 1 : 0); - stmtInsert.bindLong(5, feed.cat_id); - stmtInsert.bindLong(6, feed.last_updated); - stmtInsert.execute(); - } - - c.close(); - } - - // TODO delete not returned feeds which has no data here - - runOnUiThread(new Runnable() { - @Override - public void run() { - /* View pb = findViewById(R.id.loading_progress); - if (pb != null) pb.setVisibility(View.INVISIBLE); */ - - FeedsFragment frag = (FeedsFragment)getFragmentManager().findFragmentByTag("FEEDLIST"); - - if (frag != null) { - frag.updateListView(); - } - } - }); - - scheduleNextUpdate(); - - } catch (Exception e) { - e.printStackTrace(); - } - } else if (result != null && api.getAuthStatus() != ApiRequest.STATUS_OK) { - // TODO handle error, e.g auth failed - } else if (result == null) { - // TODO could not parse result, server/network error? - } - - } - - protected void scheduleNextUpdate() { - - if (m_articlesTask != null) m_articlesTask.cancel(); - - m_articlesTask = new ArticlesTask(); - - if (m_updateMode == UPDATE_INITIAL) { - Log.i(TAG, "Scheduling initial update..."); - m_articlesTimer = new Timer("DownloadInitial"); - m_articlesTimer.schedule(m_articlesTask, 1000L); - } else { - Log.i(TAG, "Scheduling sequential update..."); - m_articlesTimer = new Timer("DownloadSequential"); - m_articlesTimer.schedule(m_articlesTask, 60*1000L); - } - } - }
\ No newline at end of file |