Setup SBS search

xwz · Sep 16, 2015 · 8ec74c0 · 8ec74c0
1 parent ba1be4c
commit 8ec74c0
Show file tree

Hide file tree

Showing 10 changed files with 326 additions and 305 deletions.
diff --git a/base/src/main/java/io/github/xwz/base/content/ContentManagerBase.java b/base/src/main/java/io/github/xwz/base/content/ContentManagerBase.java
@@ -0,0 +1,174 @@
+package io.github.xwz.base.content;
+
+import android.content.Context;
+import android.content.Intent;
+import android.database.Cursor;
+import android.database.MatrixCursor;
+import android.net.Uri;
+import android.provider.BaseColumns;
+import android.util.Log;
+
+import java.util.ArrayList;
+import java.util.LinkedHashMap;
+import java.util.List;
+
+import io.github.xwz.base.models.IEpisodeModel;
+
+public abstract class ContentManagerBase implements IContentManager {
+
+    private static final String TAG = "ContentManagerBase";
+
+    private static ContentManagerBase instance = null;
+
+    private Context mContext = null;
+    private ContentCacheManager mCache = null;
+
+    public enum RecommendationPosition {
+        FIRST(0), SECOND(1);
+        private final int id;
+
+        private RecommendationPosition(int id) {
+            this.id = id;
+        }
+
+        public int getId() {
+            return id;
+        }
+    }
+
+    public ContentManagerBase(Context context) {
+        instance = this;
+        mContext = context;
+        mCache = new ContentCacheManager(context);
+    }
+
+    public static ContentManagerBase getInstance() {
+        return instance;
+    }
+
+    public static ContentCacheManager cache() {
+        return getInstance().mCache;
+    }
+
+    protected Context getContext() {
+        return mContext;
+    }
+
+    public void broadcastChange(String change, String tag, String id) {
+        mCache.broadcastChange(change, tag, id);
+    }
+
+    public void broadcastChange(String change, String tag) {
+        mCache.broadcastChange(change, tag);
+    }
+
+    public void broadcastChange(String change) {
+        mCache.broadcastChange(change);
+    }
+
+    public List<IEpisodeModel> searchShows(String query) {
+        List<IEpisodeModel> results = new ArrayList<>();
+        query = query.toLowerCase();
+        for (IEpisodeModel episode : mCache.getAllShows()) {
+            if (episode.matches(query)) {
+                results.add(episode);
+            }
+        }
+        Log.d(TAG, "Search: '" + query + "' found : " + results.size());
+        return results;
+    }
+
+    public Cursor searchShowsCursor(String query) {
+        String[] columns = new String[]{
+                BaseColumns._ID,
+                KEY_SERIES_TITLE,
+                KEY_TITLE,
+                KEY_IMAGE,
+                KEY_DATA_TYPE,
+                KEY_IS_LIVE,
+                KEY_VIDEO_WIDTH,
+                KEY_VIDEO_HEIGHT,
+                KEY_PRODUCTION_YEAR,
+                KEY_COLUMN_DURATION,
+                KEY_ACTION,
+                KEY_EXTRA_DATA,
+                KEY_EXTRA_NAME
+        };
+        MatrixCursor cursor = new MatrixCursor(columns);
+        for (IEpisodeModel ep : searchShows(query)) {
+            LinkedHashMap row = new LinkedHashMap();
+            row.put(BaseColumns._ID, ep.getHref());
+            row.put(KEY_SERIES_TITLE, ep.getSeriesTitle());
+            row.put(KEY_TITLE, ep.getTitle());
+            row.put(KEY_IMAGE, ep.getThumbnail());
+            row.put(KEY_DATA_TYPE, "video/mp4");
+            row.put(KEY_IS_LIVE, ep.getLivestream());
+            row.put(KEY_VIDEO_WIDTH, 1280);
+            row.put(KEY_VIDEO_HEIGHT, 720);
+            row.put(KEY_PRODUCTION_YEAR, 2015);
+            row.put(KEY_COLUMN_DURATION, ep.getDuration() * 1000);
+            row.put(KEY_ACTION, GLOBAL_SEARCH_INTENT);
+            row.put(KEY_EXTRA_DATA, ep.getHref());
+            row.put(KEY_EXTRA_NAME, KEY_EXTRA_DATA);
+            cursor.addRow(row.values());
+        }
+        return cursor;
+    }
+
+    public List<String> suggestions(String query) {
+        return mCache.getSuggestions(query);
+    }
+
+    public List<IEpisodeModel> getAllShows() {
+        return mCache.getAllShows();
+    }
+
+    public IEpisodeModel getEpisode(String href) {
+        return mCache.getEpisode(href);
+    }
+
+    public Uri getEpisodeStreamUrl(IEpisodeModel episode) {
+        return mCache.getEpisodeStreamUrl(episode.getHref());
+    }
+
+    public LinkedHashMap<String, List<IEpisodeModel>> getAllShowsByCategories() {
+        return cache().getCollections();
+    }
+
+    public IEpisodeModel findNextEpisode(List<String> urls, String current) {
+        String next = null;
+        boolean found = false;
+        for (String href : urls) {
+            if (found) {
+                next = href;
+                break;
+            }
+            found = href.equals(current);
+        }
+        if (!found && next == null && urls.size() > 0) {
+            next = urls.get(0);
+        }
+        if (next != null) {
+            return getEpisode(next);
+        }
+        return null;
+    }
+
+    public void recommendEpisode(Context context, IEpisodeModel ep, RecommendationPosition position) {
+        Intent intent = new Intent(context, getRecommendationServiceClass());
+        intent.putExtra(IContentManager.CONTENT_ID, ep);
+        intent.putExtra(IContentManager.CONTENT_TAG, position.getId());
+        context.startService(intent);
+    }
+
+    public void updateRecommendations(Context context) {
+        List<IEpisodeModel> shows = getRecommendations();
+        int i = 0;
+        for (IEpisodeModel show : shows) {
+            Log.d(TAG, "Recommendation: " + i + ", " + show);
+            if (i < 2) {
+                recommendEpisode(context, show, RecommendationPosition.values()[i++]);
+            }
+        }
+    }
+}
diff --git a/base/src/main/java/io/github/xwz/base/content/IContentManager.java b/base/src/main/java/io/github/xwz/base/content/IContentManager.java
@@ -53,7 +53,6 @@ public interface IContentManager {
     String KEY_EXTRA_DATA = SearchManager.SUGGEST_COLUMN_INTENT_EXTRA_DATA;
     String KEY_EXTRA_NAME = SearchManager.EXTRA_DATA_KEY;
 
-    void updateRecommendations(Context context);
     LinkedHashMap<String, List<IEpisodeModel>> getAllShowsByCategories();
     void fetchShowList(boolean force);
     IEpisodeModel getEpisode(String href);
@@ -63,4 +62,8 @@ public interface IContentManager {
     void fetchAuthToken(IEpisodeModel episode);
     Uri getEpisodeStreamUrl(IEpisodeModel episode);
     IEpisodeModel findNextEpisode(List<String> urls, String current);
+    List<IEpisodeModel> getAllShows();
+    List<IEpisodeModel> getRecommendations();
+    void updateRecommendations(Context context);
+    Class getRecommendationServiceClass();
 }
diff --git a/base/src/main/java/io/github/xwz/base/content/SearchProviderBase.java b/base/src/main/java/io/github/xwz/base/content/SearchProviderBase.java
@@ -0,0 +1,76 @@
+package io.github.xwz.base.content;
+
+import android.app.SearchManager;
+import android.content.ContentProvider;
+import android.content.ContentValues;
+import android.content.UriMatcher;
+import android.database.Cursor;
+import android.net.Uri;
+import android.util.Log;
+
+public abstract class SearchProviderBase extends ContentProvider {
+
+    private static String TAG = "SearchProviderBase";
+    private static final int SEARCH_SUGGEST = 0;
+    private static final int REFRESH_SHORTCUT = 1;
+
+    protected abstract String getAuthority();
+    protected abstract Cursor getSuggestions(String query);
+
+    @Override
+    public boolean onCreate() {
+        Log.d(TAG, "onCreate");
+        return false;
+    }
+
+    private UriMatcher getUriMatcher() {
+        UriMatcher matcher = new UriMatcher(UriMatcher.NO_MATCH);
+        // to get suggestions...
+        Log.d(TAG, "suggest_uri_path_query: " + SearchManager.SUGGEST_URI_PATH_QUERY);
+        matcher.addURI(getAuthority(), SearchManager.SUGGEST_URI_PATH_QUERY, SEARCH_SUGGEST);
+        matcher.addURI(getAuthority(), SearchManager.SUGGEST_URI_PATH_QUERY + "/*", SEARCH_SUGGEST);
+        return matcher;
+    }
+
+    @Override
+    public Cursor query(Uri uri, String[] projection, String selection, String[] selectionArgs, String sortOrder) {
+        switch (getUriMatcher().match(uri)) {
+            case SEARCH_SUGGEST:
+                Log.d(TAG, "search suggest: " + selectionArgs[0] + " URI: " + uri);
+                if (selectionArgs == null) {
+                    throw new IllegalArgumentException(
+                            "selectionArgs must be provided for the Uri: " + uri);
+                }
+                return getSuggestions(selectionArgs[0]);
+            default:
+                throw new IllegalArgumentException("Unknown Uri: " + uri+" authority: " + getAuthority());
+        }
+    }
+
+    @Override
+    public String getType(Uri uri) {
+        switch (getUriMatcher().match(uri)) {
+            case SEARCH_SUGGEST:
+                return SearchManager.SUGGEST_MIME_TYPE;
+            case REFRESH_SHORTCUT:
+                return SearchManager.SHORTCUT_MIME_TYPE;
+            default:
+                throw new IllegalArgumentException("Unknown URL " + uri);
+        }
+    }
+
+    @Override
+    public Uri insert(Uri uri, ContentValues values) {
+        return null;
+    }
+
+    @Override
+    public int delete(Uri uri, String selection, String[] selectionArgs) {
+        return 0;
+    }
+
+    @Override
+    public int update(Uri uri, ContentValues values, String selection, String[] selectionArgs) {
+        return 0;
+    }
+}
diff --git a/base/src/main/java/io/github/xwz/base/fragments/SearchFragment.java b/base/src/main/java/io/github/xwz/base/fragments/SearchFragment.java
@@ -97,6 +97,7 @@ public void setQuery(String str) {
 
         @Override
         public void run() {
+            Log.d(TAG, "Searching: " + query);
             List<IEpisodeModel> results = getContentManger().searchShows(query);
             EpisodePresenter card = new EpisodePresenter();
             ArrayObjectAdapter row = new ArrayObjectAdapter(card);