| /* |
| * Copyright (C) 2014 The Android Open Source Project |
| * |
| * Licensed under the Apache License, Version 2.0 (the "License"); |
| * you may not use this file except in compliance with the License. |
| * You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| package com.android.providers.tv; |
| |
| import android.annotation.SuppressLint; |
| import android.app.AlarmManager; |
| import android.app.PendingIntent; |
| import android.content.ContentProvider; |
| import android.content.ContentProviderOperation; |
| import android.content.ContentProviderResult; |
| import android.content.ContentValues; |
| import android.content.Context; |
| import android.content.Intent; |
| import android.content.OperationApplicationException; |
| import android.content.SharedPreferences; |
| import android.content.UriMatcher; |
| import android.content.pm.PackageManager; |
| import android.database.Cursor; |
| import android.database.DatabaseUtils; |
| import android.database.SQLException; |
| import android.database.sqlite.SQLiteDatabase; |
| import android.database.sqlite.SQLiteOpenHelper; |
| import android.database.sqlite.SQLiteQueryBuilder; |
| import android.graphics.Bitmap; |
| import android.graphics.BitmapFactory; |
| import android.media.tv.TvContract; |
| import android.media.tv.TvContract.BaseTvColumns; |
| import android.media.tv.TvContract.Channels; |
| import android.media.tv.TvContract.PreviewPrograms; |
| import android.media.tv.TvContract.Programs; |
| import android.media.tv.TvContract.Programs.Genres; |
| import android.media.tv.TvContract.RecordedPrograms; |
| import android.media.tv.TvContract.WatchedPrograms; |
| import android.media.tv.TvContract.WatchNextPrograms; |
| import android.net.Uri; |
| import android.os.AsyncTask; |
| import android.os.Bundle; |
| import android.os.Handler; |
| import android.os.Message; |
| import android.os.ParcelFileDescriptor; |
| import android.os.ParcelFileDescriptor.AutoCloseInputStream; |
| import android.preference.PreferenceManager; |
| import android.provider.BaseColumns; |
| import android.text.TextUtils; |
| import android.text.format.DateUtils; |
| import android.util.Log; |
| |
| import com.android.internal.annotations.VisibleForTesting; |
| import com.android.internal.os.SomeArgs; |
| import com.android.providers.tv.util.SqlParams; |
| |
| import com.android.providers.tv.util.SqliteTokenFinder; |
| import java.util.Locale; |
| import libcore.io.IoUtils; |
| |
| import java.io.ByteArrayOutputStream; |
| import java.io.FileNotFoundException; |
| import java.io.IOException; |
| import java.util.ArrayList; |
| import java.util.HashMap; |
| import java.util.HashSet; |
| import java.util.Iterator; |
| import java.util.Map; |
| import java.util.Set; |
| import java.util.concurrent.ConcurrentHashMap; |
| |
| /** |
| * TV content provider. The contract between this provider and applications is defined in |
| * {@link android.media.tv.TvContract}. |
| */ |
| public class TvProvider extends ContentProvider { |
| private static final boolean DEBUG = false; |
| private static final String TAG = "TvProvider"; |
| |
| static final int DATABASE_VERSION = 34; |
| static final String SHARED_PREF_BLOCKED_PACKAGES_KEY = "blocked_packages"; |
| static final String CHANNELS_TABLE = "channels"; |
| static final String PROGRAMS_TABLE = "programs"; |
| static final String RECORDED_PROGRAMS_TABLE = "recorded_programs"; |
| static final String PREVIEW_PROGRAMS_TABLE = "preview_programs"; |
| static final String WATCH_NEXT_PROGRAMS_TABLE = "watch_next_programs"; |
| static final String WATCHED_PROGRAMS_TABLE = "watched_programs"; |
| static final String PROGRAMS_TABLE_PACKAGE_NAME_INDEX = "programs_package_name_index"; |
| static final String PROGRAMS_TABLE_CHANNEL_ID_INDEX = "programs_channel_id_index"; |
| static final String PROGRAMS_TABLE_START_TIME_INDEX = "programs_start_time_index"; |
| static final String PROGRAMS_TABLE_END_TIME_INDEX = "programs_end_time_index"; |
| static final String WATCHED_PROGRAMS_TABLE_CHANNEL_ID_INDEX = |
| "watched_programs_channel_id_index"; |
| // The internal column in the watched programs table to indicate whether the current log entry |
| // is consolidated or not. Unconsolidated entries may have columns with missing data. |
| static final String WATCHED_PROGRAMS_COLUMN_CONSOLIDATED = "consolidated"; |
| static final String CHANNELS_COLUMN_LOGO = "logo"; |
| private static final String DATABASE_NAME = "tv.db"; |
| private static final String DELETED_CHANNELS_TABLE = "deleted_channels"; // Deprecated |
| private static final String DEFAULT_PROGRAMS_SORT_ORDER = Programs.COLUMN_START_TIME_UTC_MILLIS |
| + " ASC"; |
| private static final String DEFAULT_WATCHED_PROGRAMS_SORT_ORDER = |
| WatchedPrograms.COLUMN_WATCH_START_TIME_UTC_MILLIS + " DESC"; |
| private static final String CHANNELS_TABLE_INNER_JOIN_PROGRAMS_TABLE = CHANNELS_TABLE |
| + " INNER JOIN " + PROGRAMS_TABLE |
| + " ON (" + CHANNELS_TABLE + "." + Channels._ID + "=" |
| + PROGRAMS_TABLE + "." + Programs.COLUMN_CHANNEL_ID + ")"; |
| |
| // Operation names for createSqlParams(). |
| private static final String OP_QUERY = "query"; |
| private static final String OP_UPDATE = "update"; |
| private static final String OP_DELETE = "delete"; |
| |
| private static final UriMatcher sUriMatcher; |
| private static final int MATCH_CHANNEL = 1; |
| private static final int MATCH_CHANNEL_ID = 2; |
| private static final int MATCH_CHANNEL_ID_LOGO = 3; |
| private static final int MATCH_PASSTHROUGH_ID = 4; |
| private static final int MATCH_PROGRAM = 5; |
| private static final int MATCH_PROGRAM_ID = 6; |
| private static final int MATCH_WATCHED_PROGRAM = 7; |
| private static final int MATCH_WATCHED_PROGRAM_ID = 8; |
| private static final int MATCH_RECORDED_PROGRAM = 9; |
| private static final int MATCH_RECORDED_PROGRAM_ID = 10; |
| private static final int MATCH_PREVIEW_PROGRAM = 11; |
| private static final int MATCH_PREVIEW_PROGRAM_ID = 12; |
| private static final int MATCH_WATCH_NEXT_PROGRAM = 13; |
| private static final int MATCH_WATCH_NEXT_PROGRAM_ID = 14; |
| |
| private static final int MAX_LOGO_IMAGE_SIZE = 256; |
| |
| private static final String EMPTY_STRING = ""; |
| |
| private static final long MAX_PROGRAM_DATA_DELAY_IN_MILLIS = 10 * 1000; // 10 seconds |
| |
| private static final Map<String, String> sChannelProjectionMap; |
| private static final Map<String, String> sProgramProjectionMap; |
| private static final Map<String, String> sWatchedProgramProjectionMap; |
| private static final Map<String, String> sRecordedProgramProjectionMap; |
| private static final Map<String, String> sPreviewProgramProjectionMap; |
| private static final Map<String, String> sWatchNextProgramProjectionMap; |
| private static boolean sInitialized; |
| |
| static { |
| sUriMatcher = new UriMatcher(UriMatcher.NO_MATCH); |
| sUriMatcher.addURI(TvContract.AUTHORITY, "channel", MATCH_CHANNEL); |
| sUriMatcher.addURI(TvContract.AUTHORITY, "channel/#", MATCH_CHANNEL_ID); |
| sUriMatcher.addURI(TvContract.AUTHORITY, "channel/#/logo", MATCH_CHANNEL_ID_LOGO); |
| sUriMatcher.addURI(TvContract.AUTHORITY, "passthrough/*", MATCH_PASSTHROUGH_ID); |
| sUriMatcher.addURI(TvContract.AUTHORITY, "program", MATCH_PROGRAM); |
| sUriMatcher.addURI(TvContract.AUTHORITY, "program/#", MATCH_PROGRAM_ID); |
| sUriMatcher.addURI(TvContract.AUTHORITY, "watched_program", MATCH_WATCHED_PROGRAM); |
| sUriMatcher.addURI(TvContract.AUTHORITY, "watched_program/#", MATCH_WATCHED_PROGRAM_ID); |
| sUriMatcher.addURI(TvContract.AUTHORITY, "recorded_program", MATCH_RECORDED_PROGRAM); |
| sUriMatcher.addURI(TvContract.AUTHORITY, "recorded_program/#", MATCH_RECORDED_PROGRAM_ID); |
| sUriMatcher.addURI(TvContract.AUTHORITY, "preview_program", MATCH_PREVIEW_PROGRAM); |
| sUriMatcher.addURI(TvContract.AUTHORITY, "preview_program/#", MATCH_PREVIEW_PROGRAM_ID); |
| sUriMatcher.addURI(TvContract.AUTHORITY, "watch_next_program", MATCH_WATCH_NEXT_PROGRAM); |
| sUriMatcher.addURI(TvContract.AUTHORITY, "watch_next_program/#", |
| MATCH_WATCH_NEXT_PROGRAM_ID); |
| |
| sChannelProjectionMap = new HashMap<>(); |
| sChannelProjectionMap.put(Channels._ID, CHANNELS_TABLE + "." + Channels._ID); |
| sChannelProjectionMap.put(Channels.COLUMN_PACKAGE_NAME, |
| CHANNELS_TABLE + "." + Channels.COLUMN_PACKAGE_NAME); |
| sChannelProjectionMap.put(Channels.COLUMN_INPUT_ID, |
| CHANNELS_TABLE + "." + Channels.COLUMN_INPUT_ID); |
| sChannelProjectionMap.put(Channels.COLUMN_TYPE, |
| CHANNELS_TABLE + "." + Channels.COLUMN_TYPE); |
| sChannelProjectionMap.put(Channels.COLUMN_SERVICE_TYPE, |
| CHANNELS_TABLE + "." + Channels.COLUMN_SERVICE_TYPE); |
| sChannelProjectionMap.put(Channels.COLUMN_ORIGINAL_NETWORK_ID, |
| CHANNELS_TABLE + "." + Channels.COLUMN_ORIGINAL_NETWORK_ID); |
| sChannelProjectionMap.put(Channels.COLUMN_TRANSPORT_STREAM_ID, |
| CHANNELS_TABLE + "." + Channels.COLUMN_TRANSPORT_STREAM_ID); |
| sChannelProjectionMap.put(Channels.COLUMN_SERVICE_ID, |
| CHANNELS_TABLE + "." + Channels.COLUMN_SERVICE_ID); |
| sChannelProjectionMap.put(Channels.COLUMN_DISPLAY_NUMBER, |
| CHANNELS_TABLE + "." + Channels.COLUMN_DISPLAY_NUMBER); |
| sChannelProjectionMap.put(Channels.COLUMN_DISPLAY_NAME, |
| CHANNELS_TABLE + "." + Channels.COLUMN_DISPLAY_NAME); |
| sChannelProjectionMap.put(Channels.COLUMN_NETWORK_AFFILIATION, |
| CHANNELS_TABLE + "." + Channels.COLUMN_NETWORK_AFFILIATION); |
| sChannelProjectionMap.put(Channels.COLUMN_DESCRIPTION, |
| CHANNELS_TABLE + "." + Channels.COLUMN_DESCRIPTION); |
| sChannelProjectionMap.put(Channels.COLUMN_VIDEO_FORMAT, |
| CHANNELS_TABLE + "." + Channels.COLUMN_VIDEO_FORMAT); |
| sChannelProjectionMap.put(Channels.COLUMN_BROWSABLE, |
| CHANNELS_TABLE + "." + Channels.COLUMN_BROWSABLE); |
| sChannelProjectionMap.put(Channels.COLUMN_SEARCHABLE, |
| CHANNELS_TABLE + "." + Channels.COLUMN_SEARCHABLE); |
| sChannelProjectionMap.put(Channels.COLUMN_LOCKED, |
| CHANNELS_TABLE + "." + Channels.COLUMN_LOCKED); |
| sChannelProjectionMap.put(Channels.COLUMN_APP_LINK_ICON_URI, |
| CHANNELS_TABLE + "." + Channels.COLUMN_APP_LINK_ICON_URI); |
| sChannelProjectionMap.put(Channels.COLUMN_APP_LINK_POSTER_ART_URI, |
| CHANNELS_TABLE + "." + Channels.COLUMN_APP_LINK_POSTER_ART_URI); |
| sChannelProjectionMap.put(Channels.COLUMN_APP_LINK_TEXT, |
| CHANNELS_TABLE + "." + Channels.COLUMN_APP_LINK_TEXT); |
| sChannelProjectionMap.put(Channels.COLUMN_APP_LINK_COLOR, |
| CHANNELS_TABLE + "." + Channels.COLUMN_APP_LINK_COLOR); |
| sChannelProjectionMap.put(Channels.COLUMN_APP_LINK_INTENT_URI, |
| CHANNELS_TABLE + "." + Channels.COLUMN_APP_LINK_INTENT_URI); |
| sChannelProjectionMap.put(Channels.COLUMN_INTERNAL_PROVIDER_DATA, |
| CHANNELS_TABLE + "." + Channels.COLUMN_INTERNAL_PROVIDER_DATA); |
| sChannelProjectionMap.put(Channels.COLUMN_INTERNAL_PROVIDER_FLAG1, |
| CHANNELS_TABLE + "." + Channels.COLUMN_INTERNAL_PROVIDER_FLAG1); |
| sChannelProjectionMap.put(Channels.COLUMN_INTERNAL_PROVIDER_FLAG2, |
| CHANNELS_TABLE + "." + Channels.COLUMN_INTERNAL_PROVIDER_FLAG2); |
| sChannelProjectionMap.put(Channels.COLUMN_INTERNAL_PROVIDER_FLAG3, |
| CHANNELS_TABLE + "." + Channels.COLUMN_INTERNAL_PROVIDER_FLAG3); |
| sChannelProjectionMap.put(Channels.COLUMN_INTERNAL_PROVIDER_FLAG4, |
| CHANNELS_TABLE + "." + Channels.COLUMN_INTERNAL_PROVIDER_FLAG4); |
| sChannelProjectionMap.put(Channels.COLUMN_VERSION_NUMBER, |
| CHANNELS_TABLE + "." + Channels.COLUMN_VERSION_NUMBER); |
| sChannelProjectionMap.put(Channels.COLUMN_TRANSIENT, |
| CHANNELS_TABLE + "." + Channels.COLUMN_TRANSIENT); |
| sChannelProjectionMap.put(Channels.COLUMN_INTERNAL_PROVIDER_ID, |
| CHANNELS_TABLE + "." + Channels.COLUMN_INTERNAL_PROVIDER_ID); |
| |
| sProgramProjectionMap = new HashMap<>(); |
| sProgramProjectionMap.put(Programs._ID, Programs._ID); |
| sProgramProjectionMap.put(Programs.COLUMN_PACKAGE_NAME, Programs.COLUMN_PACKAGE_NAME); |
| sProgramProjectionMap.put(Programs.COLUMN_CHANNEL_ID, Programs.COLUMN_CHANNEL_ID); |
| sProgramProjectionMap.put(Programs.COLUMN_TITLE, Programs.COLUMN_TITLE); |
| // COLUMN_SEASON_NUMBER is deprecated. Return COLUMN_SEASON_DISPLAY_NUMBER instead. |
| sProgramProjectionMap.put(Programs.COLUMN_SEASON_NUMBER, |
| Programs.COLUMN_SEASON_DISPLAY_NUMBER + " AS " + Programs.COLUMN_SEASON_NUMBER); |
| sProgramProjectionMap.put(Programs.COLUMN_SEASON_DISPLAY_NUMBER, |
| Programs.COLUMN_SEASON_DISPLAY_NUMBER); |
| sProgramProjectionMap.put(Programs.COLUMN_SEASON_TITLE, Programs.COLUMN_SEASON_TITLE); |
| // COLUMN_EPISODE_NUMBER is deprecated. Return COLUMN_EPISODE_DISPLAY_NUMBER instead. |
| sProgramProjectionMap.put(Programs.COLUMN_EPISODE_NUMBER, |
| Programs.COLUMN_EPISODE_DISPLAY_NUMBER + " AS " + Programs.COLUMN_EPISODE_NUMBER); |
| sProgramProjectionMap.put(Programs.COLUMN_EPISODE_DISPLAY_NUMBER, |
| Programs.COLUMN_EPISODE_DISPLAY_NUMBER); |
| sProgramProjectionMap.put(Programs.COLUMN_EPISODE_TITLE, Programs.COLUMN_EPISODE_TITLE); |
| sProgramProjectionMap.put(Programs.COLUMN_START_TIME_UTC_MILLIS, |
| Programs.COLUMN_START_TIME_UTC_MILLIS); |
| sProgramProjectionMap.put(Programs.COLUMN_END_TIME_UTC_MILLIS, |
| Programs.COLUMN_END_TIME_UTC_MILLIS); |
| sProgramProjectionMap.put(Programs.COLUMN_BROADCAST_GENRE, Programs.COLUMN_BROADCAST_GENRE); |
| sProgramProjectionMap.put(Programs.COLUMN_CANONICAL_GENRE, Programs.COLUMN_CANONICAL_GENRE); |
| sProgramProjectionMap.put(Programs.COLUMN_SHORT_DESCRIPTION, |
| Programs.COLUMN_SHORT_DESCRIPTION); |
| sProgramProjectionMap.put(Programs.COLUMN_LONG_DESCRIPTION, |
| Programs.COLUMN_LONG_DESCRIPTION); |
| sProgramProjectionMap.put(Programs.COLUMN_VIDEO_WIDTH, Programs.COLUMN_VIDEO_WIDTH); |
| sProgramProjectionMap.put(Programs.COLUMN_VIDEO_HEIGHT, Programs.COLUMN_VIDEO_HEIGHT); |
| sProgramProjectionMap.put(Programs.COLUMN_AUDIO_LANGUAGE, Programs.COLUMN_AUDIO_LANGUAGE); |
| sProgramProjectionMap.put(Programs.COLUMN_CONTENT_RATING, Programs.COLUMN_CONTENT_RATING); |
| sProgramProjectionMap.put(Programs.COLUMN_POSTER_ART_URI, Programs.COLUMN_POSTER_ART_URI); |
| sProgramProjectionMap.put(Programs.COLUMN_THUMBNAIL_URI, Programs.COLUMN_THUMBNAIL_URI); |
| sProgramProjectionMap.put(Programs.COLUMN_SEARCHABLE, Programs.COLUMN_SEARCHABLE); |
| sProgramProjectionMap.put(Programs.COLUMN_RECORDING_PROHIBITED, |
| Programs.COLUMN_RECORDING_PROHIBITED); |
| sProgramProjectionMap.put(Programs.COLUMN_INTERNAL_PROVIDER_DATA, |
| Programs.COLUMN_INTERNAL_PROVIDER_DATA); |
| sProgramProjectionMap.put(Programs.COLUMN_INTERNAL_PROVIDER_FLAG1, |
| Programs.COLUMN_INTERNAL_PROVIDER_FLAG1); |
| sProgramProjectionMap.put(Programs.COLUMN_INTERNAL_PROVIDER_FLAG2, |
| Programs.COLUMN_INTERNAL_PROVIDER_FLAG2); |
| sProgramProjectionMap.put(Programs.COLUMN_INTERNAL_PROVIDER_FLAG3, |
| Programs.COLUMN_INTERNAL_PROVIDER_FLAG3); |
| sProgramProjectionMap.put(Programs.COLUMN_INTERNAL_PROVIDER_FLAG4, |
| Programs.COLUMN_INTERNAL_PROVIDER_FLAG4); |
| sProgramProjectionMap.put(Programs.COLUMN_VERSION_NUMBER, Programs.COLUMN_VERSION_NUMBER); |
| sProgramProjectionMap.put(Programs.COLUMN_REVIEW_RATING_STYLE, |
| Programs.COLUMN_REVIEW_RATING_STYLE); |
| sProgramProjectionMap.put(Programs.COLUMN_REVIEW_RATING, |
| Programs.COLUMN_REVIEW_RATING); |
| |
| sWatchedProgramProjectionMap = new HashMap<>(); |
| sWatchedProgramProjectionMap.put(WatchedPrograms._ID, WatchedPrograms._ID); |
| sWatchedProgramProjectionMap.put(WatchedPrograms.COLUMN_WATCH_START_TIME_UTC_MILLIS, |
| WatchedPrograms.COLUMN_WATCH_START_TIME_UTC_MILLIS); |
| sWatchedProgramProjectionMap.put(WatchedPrograms.COLUMN_WATCH_END_TIME_UTC_MILLIS, |
| WatchedPrograms.COLUMN_WATCH_END_TIME_UTC_MILLIS); |
| sWatchedProgramProjectionMap.put(WatchedPrograms.COLUMN_CHANNEL_ID, |
| WatchedPrograms.COLUMN_CHANNEL_ID); |
| sWatchedProgramProjectionMap.put(WatchedPrograms.COLUMN_TITLE, |
| WatchedPrograms.COLUMN_TITLE); |
| sWatchedProgramProjectionMap.put(WatchedPrograms.COLUMN_START_TIME_UTC_MILLIS, |
| WatchedPrograms.COLUMN_START_TIME_UTC_MILLIS); |
| sWatchedProgramProjectionMap.put(WatchedPrograms.COLUMN_END_TIME_UTC_MILLIS, |
| WatchedPrograms.COLUMN_END_TIME_UTC_MILLIS); |
| sWatchedProgramProjectionMap.put(WatchedPrograms.COLUMN_DESCRIPTION, |
| WatchedPrograms.COLUMN_DESCRIPTION); |
| sWatchedProgramProjectionMap.put(WatchedPrograms.COLUMN_INTERNAL_TUNE_PARAMS, |
| WatchedPrograms.COLUMN_INTERNAL_TUNE_PARAMS); |
| sWatchedProgramProjectionMap.put(WatchedPrograms.COLUMN_INTERNAL_SESSION_TOKEN, |
| WatchedPrograms.COLUMN_INTERNAL_SESSION_TOKEN); |
| sWatchedProgramProjectionMap.put(WATCHED_PROGRAMS_COLUMN_CONSOLIDATED, |
| WATCHED_PROGRAMS_COLUMN_CONSOLIDATED); |
| |
| sRecordedProgramProjectionMap = new HashMap<>(); |
| sRecordedProgramProjectionMap.put(RecordedPrograms._ID, RecordedPrograms._ID); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_PACKAGE_NAME, |
| RecordedPrograms.COLUMN_PACKAGE_NAME); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_INPUT_ID, |
| RecordedPrograms.COLUMN_INPUT_ID); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_CHANNEL_ID, |
| RecordedPrograms.COLUMN_CHANNEL_ID); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_TITLE, |
| RecordedPrograms.COLUMN_TITLE); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_SEASON_DISPLAY_NUMBER, |
| RecordedPrograms.COLUMN_SEASON_DISPLAY_NUMBER); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_SEASON_TITLE, |
| RecordedPrograms.COLUMN_SEASON_TITLE); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_EPISODE_DISPLAY_NUMBER, |
| RecordedPrograms.COLUMN_EPISODE_DISPLAY_NUMBER); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_EPISODE_TITLE, |
| RecordedPrograms.COLUMN_EPISODE_TITLE); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_START_TIME_UTC_MILLIS, |
| RecordedPrograms.COLUMN_START_TIME_UTC_MILLIS); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_END_TIME_UTC_MILLIS, |
| RecordedPrograms.COLUMN_END_TIME_UTC_MILLIS); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_BROADCAST_GENRE, |
| RecordedPrograms.COLUMN_BROADCAST_GENRE); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_CANONICAL_GENRE, |
| RecordedPrograms.COLUMN_CANONICAL_GENRE); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_SHORT_DESCRIPTION, |
| RecordedPrograms.COLUMN_SHORT_DESCRIPTION); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_LONG_DESCRIPTION, |
| RecordedPrograms.COLUMN_LONG_DESCRIPTION); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_VIDEO_WIDTH, |
| RecordedPrograms.COLUMN_VIDEO_WIDTH); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_VIDEO_HEIGHT, |
| RecordedPrograms.COLUMN_VIDEO_HEIGHT); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_AUDIO_LANGUAGE, |
| RecordedPrograms.COLUMN_AUDIO_LANGUAGE); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_CONTENT_RATING, |
| RecordedPrograms.COLUMN_CONTENT_RATING); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_POSTER_ART_URI, |
| RecordedPrograms.COLUMN_POSTER_ART_URI); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_THUMBNAIL_URI, |
| RecordedPrograms.COLUMN_THUMBNAIL_URI); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_SEARCHABLE, |
| RecordedPrograms.COLUMN_SEARCHABLE); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_RECORDING_DATA_URI, |
| RecordedPrograms.COLUMN_RECORDING_DATA_URI); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_RECORDING_DATA_BYTES, |
| RecordedPrograms.COLUMN_RECORDING_DATA_BYTES); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_RECORDING_DURATION_MILLIS, |
| RecordedPrograms.COLUMN_RECORDING_DURATION_MILLIS); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_RECORDING_EXPIRE_TIME_UTC_MILLIS, |
| RecordedPrograms.COLUMN_RECORDING_EXPIRE_TIME_UTC_MILLIS); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_INTERNAL_PROVIDER_DATA, |
| RecordedPrograms.COLUMN_INTERNAL_PROVIDER_DATA); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_INTERNAL_PROVIDER_FLAG1, |
| RecordedPrograms.COLUMN_INTERNAL_PROVIDER_FLAG1); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_INTERNAL_PROVIDER_FLAG2, |
| RecordedPrograms.COLUMN_INTERNAL_PROVIDER_FLAG2); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_INTERNAL_PROVIDER_FLAG3, |
| RecordedPrograms.COLUMN_INTERNAL_PROVIDER_FLAG3); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_INTERNAL_PROVIDER_FLAG4, |
| RecordedPrograms.COLUMN_INTERNAL_PROVIDER_FLAG4); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_VERSION_NUMBER, |
| RecordedPrograms.COLUMN_VERSION_NUMBER); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_REVIEW_RATING_STYLE, |
| RecordedPrograms.COLUMN_REVIEW_RATING_STYLE); |
| sRecordedProgramProjectionMap.put(RecordedPrograms.COLUMN_REVIEW_RATING, |
| RecordedPrograms.COLUMN_REVIEW_RATING); |
| |
| sPreviewProgramProjectionMap = new HashMap<>(); |
| sPreviewProgramProjectionMap.put(PreviewPrograms._ID, PreviewPrograms._ID); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_PACKAGE_NAME, |
| PreviewPrograms.COLUMN_PACKAGE_NAME); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_CHANNEL_ID, |
| PreviewPrograms.COLUMN_CHANNEL_ID); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_TITLE, |
| PreviewPrograms.COLUMN_TITLE); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_SEASON_DISPLAY_NUMBER, |
| PreviewPrograms.COLUMN_SEASON_DISPLAY_NUMBER); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_SEASON_TITLE, |
| PreviewPrograms.COLUMN_SEASON_TITLE); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_EPISODE_DISPLAY_NUMBER, |
| PreviewPrograms.COLUMN_EPISODE_DISPLAY_NUMBER); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_EPISODE_TITLE, |
| PreviewPrograms.COLUMN_EPISODE_TITLE); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_CANONICAL_GENRE, |
| PreviewPrograms.COLUMN_CANONICAL_GENRE); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_SHORT_DESCRIPTION, |
| PreviewPrograms.COLUMN_SHORT_DESCRIPTION); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_LONG_DESCRIPTION, |
| PreviewPrograms.COLUMN_LONG_DESCRIPTION); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_VIDEO_WIDTH, |
| PreviewPrograms.COLUMN_VIDEO_WIDTH); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_VIDEO_HEIGHT, |
| PreviewPrograms.COLUMN_VIDEO_HEIGHT); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_AUDIO_LANGUAGE, |
| PreviewPrograms.COLUMN_AUDIO_LANGUAGE); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_CONTENT_RATING, |
| PreviewPrograms.COLUMN_CONTENT_RATING); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_POSTER_ART_URI, |
| PreviewPrograms.COLUMN_POSTER_ART_URI); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_THUMBNAIL_URI, |
| PreviewPrograms.COLUMN_THUMBNAIL_URI); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_SEARCHABLE, |
| PreviewPrograms.COLUMN_SEARCHABLE); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_INTERNAL_PROVIDER_DATA, |
| PreviewPrograms.COLUMN_INTERNAL_PROVIDER_DATA); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_INTERNAL_PROVIDER_FLAG1, |
| PreviewPrograms.COLUMN_INTERNAL_PROVIDER_FLAG1); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_INTERNAL_PROVIDER_FLAG2, |
| PreviewPrograms.COLUMN_INTERNAL_PROVIDER_FLAG2); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_INTERNAL_PROVIDER_FLAG3, |
| PreviewPrograms.COLUMN_INTERNAL_PROVIDER_FLAG3); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_INTERNAL_PROVIDER_FLAG4, |
| PreviewPrograms.COLUMN_INTERNAL_PROVIDER_FLAG4); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_VERSION_NUMBER, |
| PreviewPrograms.COLUMN_VERSION_NUMBER); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_INTERNAL_PROVIDER_ID, |
| PreviewPrograms.COLUMN_INTERNAL_PROVIDER_ID); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_PREVIEW_VIDEO_URI, |
| PreviewPrograms.COLUMN_PREVIEW_VIDEO_URI); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_LAST_PLAYBACK_POSITION_MILLIS, |
| PreviewPrograms.COLUMN_LAST_PLAYBACK_POSITION_MILLIS); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_DURATION_MILLIS, |
| PreviewPrograms.COLUMN_DURATION_MILLIS); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_INTENT_URI, |
| PreviewPrograms.COLUMN_INTENT_URI); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_WEIGHT, |
| PreviewPrograms.COLUMN_WEIGHT); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_TRANSIENT, |
| PreviewPrograms.COLUMN_TRANSIENT); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_TYPE, PreviewPrograms.COLUMN_TYPE); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_POSTER_ART_ASPECT_RATIO, |
| PreviewPrograms.COLUMN_POSTER_ART_ASPECT_RATIO); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_THUMBNAIL_ASPECT_RATIO, |
| PreviewPrograms.COLUMN_THUMBNAIL_ASPECT_RATIO); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_LOGO_URI, |
| PreviewPrograms.COLUMN_LOGO_URI); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_AVAILABILITY, |
| PreviewPrograms.COLUMN_AVAILABILITY); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_STARTING_PRICE, |
| PreviewPrograms.COLUMN_STARTING_PRICE); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_OFFER_PRICE, |
| PreviewPrograms.COLUMN_OFFER_PRICE); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_RELEASE_DATE, |
| PreviewPrograms.COLUMN_RELEASE_DATE); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_ITEM_COUNT, |
| PreviewPrograms.COLUMN_ITEM_COUNT); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_LIVE, PreviewPrograms.COLUMN_LIVE); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_INTERACTION_TYPE, |
| PreviewPrograms.COLUMN_INTERACTION_TYPE); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_INTERACTION_COUNT, |
| PreviewPrograms.COLUMN_INTERACTION_COUNT); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_AUTHOR, |
| PreviewPrograms.COLUMN_AUTHOR); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_REVIEW_RATING_STYLE, |
| PreviewPrograms.COLUMN_REVIEW_RATING_STYLE); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_REVIEW_RATING, |
| PreviewPrograms.COLUMN_REVIEW_RATING); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_BROWSABLE, |
| PreviewPrograms.COLUMN_BROWSABLE); |
| sPreviewProgramProjectionMap.put(PreviewPrograms.COLUMN_CONTENT_ID, |
| PreviewPrograms.COLUMN_CONTENT_ID); |
| |
| sWatchNextProgramProjectionMap = new HashMap<>(); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms._ID, WatchNextPrograms._ID); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_PACKAGE_NAME, |
| WatchNextPrograms.COLUMN_PACKAGE_NAME); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_TITLE, |
| WatchNextPrograms.COLUMN_TITLE); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_SEASON_DISPLAY_NUMBER, |
| WatchNextPrograms.COLUMN_SEASON_DISPLAY_NUMBER); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_SEASON_TITLE, |
| WatchNextPrograms.COLUMN_SEASON_TITLE); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_EPISODE_DISPLAY_NUMBER, |
| WatchNextPrograms.COLUMN_EPISODE_DISPLAY_NUMBER); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_EPISODE_TITLE, |
| WatchNextPrograms.COLUMN_EPISODE_TITLE); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_CANONICAL_GENRE, |
| WatchNextPrograms.COLUMN_CANONICAL_GENRE); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_SHORT_DESCRIPTION, |
| WatchNextPrograms.COLUMN_SHORT_DESCRIPTION); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_LONG_DESCRIPTION, |
| WatchNextPrograms.COLUMN_LONG_DESCRIPTION); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_VIDEO_WIDTH, |
| WatchNextPrograms.COLUMN_VIDEO_WIDTH); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_VIDEO_HEIGHT, |
| WatchNextPrograms.COLUMN_VIDEO_HEIGHT); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_AUDIO_LANGUAGE, |
| WatchNextPrograms.COLUMN_AUDIO_LANGUAGE); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_CONTENT_RATING, |
| WatchNextPrograms.COLUMN_CONTENT_RATING); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_POSTER_ART_URI, |
| WatchNextPrograms.COLUMN_POSTER_ART_URI); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_THUMBNAIL_URI, |
| WatchNextPrograms.COLUMN_THUMBNAIL_URI); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_SEARCHABLE, |
| WatchNextPrograms.COLUMN_SEARCHABLE); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_INTERNAL_PROVIDER_DATA, |
| WatchNextPrograms.COLUMN_INTERNAL_PROVIDER_DATA); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_INTERNAL_PROVIDER_FLAG1, |
| WatchNextPrograms.COLUMN_INTERNAL_PROVIDER_FLAG1); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_INTERNAL_PROVIDER_FLAG2, |
| WatchNextPrograms.COLUMN_INTERNAL_PROVIDER_FLAG2); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_INTERNAL_PROVIDER_FLAG3, |
| WatchNextPrograms.COLUMN_INTERNAL_PROVIDER_FLAG3); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_INTERNAL_PROVIDER_FLAG4, |
| WatchNextPrograms.COLUMN_INTERNAL_PROVIDER_FLAG4); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_VERSION_NUMBER, |
| WatchNextPrograms.COLUMN_VERSION_NUMBER); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_INTERNAL_PROVIDER_ID, |
| WatchNextPrograms.COLUMN_INTERNAL_PROVIDER_ID); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_PREVIEW_VIDEO_URI, |
| WatchNextPrograms.COLUMN_PREVIEW_VIDEO_URI); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_LAST_PLAYBACK_POSITION_MILLIS, |
| WatchNextPrograms.COLUMN_LAST_PLAYBACK_POSITION_MILLIS); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_DURATION_MILLIS, |
| WatchNextPrograms.COLUMN_DURATION_MILLIS); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_INTENT_URI, |
| WatchNextPrograms.COLUMN_INTENT_URI); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_TRANSIENT, |
| WatchNextPrograms.COLUMN_TRANSIENT); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_TYPE, |
| WatchNextPrograms.COLUMN_TYPE); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_WATCH_NEXT_TYPE, |
| WatchNextPrograms.COLUMN_WATCH_NEXT_TYPE); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_POSTER_ART_ASPECT_RATIO, |
| WatchNextPrograms.COLUMN_POSTER_ART_ASPECT_RATIO); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_THUMBNAIL_ASPECT_RATIO, |
| WatchNextPrograms.COLUMN_THUMBNAIL_ASPECT_RATIO); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_LOGO_URI, |
| WatchNextPrograms.COLUMN_LOGO_URI); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_AVAILABILITY, |
| WatchNextPrograms.COLUMN_AVAILABILITY); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_STARTING_PRICE, |
| WatchNextPrograms.COLUMN_STARTING_PRICE); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_OFFER_PRICE, |
| WatchNextPrograms.COLUMN_OFFER_PRICE); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_RELEASE_DATE, |
| WatchNextPrograms.COLUMN_RELEASE_DATE); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_ITEM_COUNT, |
| WatchNextPrograms.COLUMN_ITEM_COUNT); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_LIVE, |
| WatchNextPrograms.COLUMN_LIVE); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_INTERACTION_TYPE, |
| WatchNextPrograms.COLUMN_INTERACTION_TYPE); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_INTERACTION_COUNT, |
| WatchNextPrograms.COLUMN_INTERACTION_COUNT); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_AUTHOR, |
| WatchNextPrograms.COLUMN_AUTHOR); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_REVIEW_RATING_STYLE, |
| WatchNextPrograms.COLUMN_REVIEW_RATING_STYLE); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_REVIEW_RATING, |
| WatchNextPrograms.COLUMN_REVIEW_RATING); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_BROWSABLE, |
| WatchNextPrograms.COLUMN_BROWSABLE); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_CONTENT_ID, |
| WatchNextPrograms.COLUMN_CONTENT_ID); |
| sWatchNextProgramProjectionMap.put(WatchNextPrograms.COLUMN_LAST_ENGAGEMENT_TIME_UTC_MILLIS, |
| WatchNextPrograms.COLUMN_LAST_ENGAGEMENT_TIME_UTC_MILLIS); |
| } |
| |
| // Mapping from broadcast genre to canonical genre. |
| private static Map<String, String> sGenreMap; |
| |
| private static final String PERMISSION_READ_TV_LISTINGS = "android.permission.READ_TV_LISTINGS"; |
| |
| private static final String PERMISSION_ACCESS_ALL_EPG_DATA = |
| "com.android.providers.tv.permission.ACCESS_ALL_EPG_DATA"; |
| |
| private static final String PERMISSION_ACCESS_WATCHED_PROGRAMS = |
| "com.android.providers.tv.permission.ACCESS_WATCHED_PROGRAMS"; |
| |
| private static final String CREATE_RECORDED_PROGRAMS_TABLE_SQL = |
| "CREATE TABLE " + RECORDED_PROGRAMS_TABLE + " (" |
| + RecordedPrograms._ID + " INTEGER PRIMARY KEY AUTOINCREMENT," |
| + RecordedPrograms.COLUMN_PACKAGE_NAME + " TEXT NOT NULL," |
| + RecordedPrograms.COLUMN_INPUT_ID + " TEXT NOT NULL," |
| + RecordedPrograms.COLUMN_CHANNEL_ID + " INTEGER," |
| + RecordedPrograms.COLUMN_TITLE + " TEXT," |
| + RecordedPrograms.COLUMN_SEASON_DISPLAY_NUMBER + " TEXT," |
| + RecordedPrograms.COLUMN_SEASON_TITLE + " TEXT," |
| + RecordedPrograms.COLUMN_EPISODE_DISPLAY_NUMBER + " TEXT," |
| + RecordedPrograms.COLUMN_EPISODE_TITLE + " TEXT," |
| + RecordedPrograms.COLUMN_START_TIME_UTC_MILLIS + " INTEGER," |
| + RecordedPrograms.COLUMN_END_TIME_UTC_MILLIS + " INTEGER," |
| + RecordedPrograms.COLUMN_BROADCAST_GENRE + " TEXT," |
| + RecordedPrograms.COLUMN_CANONICAL_GENRE + " TEXT," |
| + RecordedPrograms.COLUMN_SHORT_DESCRIPTION + " TEXT," |
| + RecordedPrograms.COLUMN_LONG_DESCRIPTION + " TEXT," |
| + RecordedPrograms.COLUMN_VIDEO_WIDTH + " INTEGER," |
| + RecordedPrograms.COLUMN_VIDEO_HEIGHT + " INTEGER," |
| + RecordedPrograms.COLUMN_AUDIO_LANGUAGE + " TEXT," |
| + RecordedPrograms.COLUMN_CONTENT_RATING + " TEXT," |
| + RecordedPrograms.COLUMN_POSTER_ART_URI + " TEXT," |
| + RecordedPrograms.COLUMN_THUMBNAIL_URI + " TEXT," |
| + RecordedPrograms.COLUMN_SEARCHABLE + " INTEGER NOT NULL DEFAULT 1," |
| + RecordedPrograms.COLUMN_RECORDING_DATA_URI + " TEXT," |
| + RecordedPrograms.COLUMN_RECORDING_DATA_BYTES + " INTEGER," |
| + RecordedPrograms.COLUMN_RECORDING_DURATION_MILLIS + " INTEGER," |
| + RecordedPrograms.COLUMN_RECORDING_EXPIRE_TIME_UTC_MILLIS + " INTEGER," |
| + RecordedPrograms.COLUMN_INTERNAL_PROVIDER_DATA + " BLOB," |
| + RecordedPrograms.COLUMN_INTERNAL_PROVIDER_FLAG1 + " INTEGER," |
| + RecordedPrograms.COLUMN_INTERNAL_PROVIDER_FLAG2 + " INTEGER," |
| + RecordedPrograms.COLUMN_INTERNAL_PROVIDER_FLAG3 + " INTEGER," |
| + RecordedPrograms.COLUMN_INTERNAL_PROVIDER_FLAG4 + " INTEGER," |
| + RecordedPrograms.COLUMN_VERSION_NUMBER + " INTEGER," |
| + RecordedPrograms.COLUMN_REVIEW_RATING_STYLE + " INTEGER," |
| + RecordedPrograms.COLUMN_REVIEW_RATING + " TEXT," |
| + "FOREIGN KEY(" + RecordedPrograms.COLUMN_CHANNEL_ID + ") " |
| + "REFERENCES " + CHANNELS_TABLE + "(" + Channels._ID + ") " |
| + "ON UPDATE CASCADE ON DELETE SET NULL);"; |
| |
| private static final String CREATE_PREVIEW_PROGRAMS_TABLE_SQL = |
| "CREATE TABLE " + PREVIEW_PROGRAMS_TABLE + " (" |
| + PreviewPrograms._ID + " INTEGER PRIMARY KEY AUTOINCREMENT," |
| + PreviewPrograms.COLUMN_PACKAGE_NAME + " TEXT NOT NULL," |
| + PreviewPrograms.COLUMN_CHANNEL_ID + " INTEGER," |
| + PreviewPrograms.COLUMN_TITLE + " TEXT," |
| + PreviewPrograms.COLUMN_SEASON_DISPLAY_NUMBER + " TEXT," |
| + PreviewPrograms.COLUMN_SEASON_TITLE + " TEXT," |
| + PreviewPrograms.COLUMN_EPISODE_DISPLAY_NUMBER + " TEXT," |
| + PreviewPrograms.COLUMN_EPISODE_TITLE + " TEXT," |
| + PreviewPrograms.COLUMN_CANONICAL_GENRE + " TEXT," |
| + PreviewPrograms.COLUMN_SHORT_DESCRIPTION + " TEXT," |
| + PreviewPrograms.COLUMN_LONG_DESCRIPTION + " TEXT," |
| + PreviewPrograms.COLUMN_VIDEO_WIDTH + " INTEGER," |
| + PreviewPrograms.COLUMN_VIDEO_HEIGHT + " INTEGER," |
| + PreviewPrograms.COLUMN_AUDIO_LANGUAGE + " TEXT," |
| + PreviewPrograms.COLUMN_CONTENT_RATING + " TEXT," |
| + PreviewPrograms.COLUMN_POSTER_ART_URI + " TEXT," |
| + PreviewPrograms.COLUMN_THUMBNAIL_URI + " TEXT," |
| + PreviewPrograms.COLUMN_SEARCHABLE + " INTEGER NOT NULL DEFAULT 1," |
| + PreviewPrograms.COLUMN_INTERNAL_PROVIDER_DATA + " BLOB," |
| + PreviewPrograms.COLUMN_INTERNAL_PROVIDER_FLAG1 + " INTEGER," |
| + PreviewPrograms.COLUMN_INTERNAL_PROVIDER_FLAG2 + " INTEGER," |
| + PreviewPrograms.COLUMN_INTERNAL_PROVIDER_FLAG3 + " INTEGER," |
| + PreviewPrograms.COLUMN_INTERNAL_PROVIDER_FLAG4 + " INTEGER," |
| + PreviewPrograms.COLUMN_VERSION_NUMBER + " INTEGER," |
| + PreviewPrograms.COLUMN_INTERNAL_PROVIDER_ID + " TEXT," |
| + PreviewPrograms.COLUMN_PREVIEW_VIDEO_URI + " TEXT," |
| + PreviewPrograms.COLUMN_LAST_PLAYBACK_POSITION_MILLIS + " INTEGER," |
| + PreviewPrograms.COLUMN_DURATION_MILLIS + " INTEGER," |
| + PreviewPrograms.COLUMN_INTENT_URI + " TEXT," |
| + PreviewPrograms.COLUMN_WEIGHT + " INTEGER," |
| + PreviewPrograms.COLUMN_TRANSIENT + " INTEGER NOT NULL DEFAULT 0," |
| + PreviewPrograms.COLUMN_TYPE + " INTEGER NOT NULL," |
| + PreviewPrograms.COLUMN_POSTER_ART_ASPECT_RATIO + " INTEGER," |
| + PreviewPrograms.COLUMN_THUMBNAIL_ASPECT_RATIO + " INTEGER," |
| + PreviewPrograms.COLUMN_LOGO_URI + " TEXT," |
| + PreviewPrograms.COLUMN_AVAILABILITY + " INTERGER," |
| + PreviewPrograms.COLUMN_STARTING_PRICE + " TEXT," |
| + PreviewPrograms.COLUMN_OFFER_PRICE + " TEXT," |
| + PreviewPrograms.COLUMN_RELEASE_DATE + " TEXT," |
| + PreviewPrograms.COLUMN_ITEM_COUNT + " INTEGER," |
| + PreviewPrograms.COLUMN_LIVE + " INTEGER NOT NULL DEFAULT 0," |
| + PreviewPrograms.COLUMN_INTERACTION_TYPE + " INTEGER," |
| + PreviewPrograms.COLUMN_INTERACTION_COUNT + " INTEGER," |
| + PreviewPrograms.COLUMN_AUTHOR + " TEXT," |
| + PreviewPrograms.COLUMN_REVIEW_RATING_STYLE + " INTEGER," |
| + PreviewPrograms.COLUMN_REVIEW_RATING + " TEXT," |
| + PreviewPrograms.COLUMN_BROWSABLE + " INTEGER NOT NULL DEFAULT 1," |
| + PreviewPrograms.COLUMN_CONTENT_ID + " TEXT," |
| + "FOREIGN KEY(" |
| + PreviewPrograms.COLUMN_CHANNEL_ID + "," + PreviewPrograms.COLUMN_PACKAGE_NAME |
| + ") REFERENCES " + CHANNELS_TABLE + "(" |
| + Channels._ID + "," + Channels.COLUMN_PACKAGE_NAME |
| + ") ON UPDATE CASCADE ON DELETE CASCADE" |
| + ");"; |
| private static final String CREATE_PREVIEW_PROGRAMS_PACKAGE_NAME_INDEX_SQL = |
| "CREATE INDEX preview_programs_package_name_index ON " + PREVIEW_PROGRAMS_TABLE |
| + "(" + PreviewPrograms.COLUMN_PACKAGE_NAME + ");"; |
| private static final String CREATE_PREVIEW_PROGRAMS_CHANNEL_ID_INDEX_SQL = |
| "CREATE INDEX preview_programs_id_index ON " + PREVIEW_PROGRAMS_TABLE |
| + "(" + PreviewPrograms.COLUMN_CHANNEL_ID + ");"; |
| private static final String CREATE_WATCH_NEXT_PROGRAMS_TABLE_SQL = |
| "CREATE TABLE " + WATCH_NEXT_PROGRAMS_TABLE + " (" |
| + WatchNextPrograms._ID + " INTEGER PRIMARY KEY AUTOINCREMENT," |
| + WatchNextPrograms.COLUMN_PACKAGE_NAME + " TEXT NOT NULL," |
| + WatchNextPrograms.COLUMN_TITLE + " TEXT," |
| + WatchNextPrograms.COLUMN_SEASON_DISPLAY_NUMBER + " TEXT," |
| + WatchNextPrograms.COLUMN_SEASON_TITLE + " TEXT," |
| + WatchNextPrograms.COLUMN_EPISODE_DISPLAY_NUMBER + " TEXT," |
| + WatchNextPrograms.COLUMN_EPISODE_TITLE + " TEXT," |
| + WatchNextPrograms.COLUMN_CANONICAL_GENRE + " TEXT," |
| + WatchNextPrograms.COLUMN_SHORT_DESCRIPTION + " TEXT," |
| + WatchNextPrograms.COLUMN_LONG_DESCRIPTION + " TEXT," |
| + WatchNextPrograms.COLUMN_VIDEO_WIDTH + " INTEGER," |
| + WatchNextPrograms.COLUMN_VIDEO_HEIGHT + " INTEGER," |
| + WatchNextPrograms.COLUMN_AUDIO_LANGUAGE + " TEXT," |
| + WatchNextPrograms.COLUMN_CONTENT_RATING + " TEXT," |
| + WatchNextPrograms.COLUMN_POSTER_ART_URI + " TEXT," |
| + WatchNextPrograms.COLUMN_THUMBNAIL_URI + " TEXT," |
| + WatchNextPrograms.COLUMN_SEARCHABLE + " INTEGER NOT NULL DEFAULT 1," |
| + WatchNextPrograms.COLUMN_INTERNAL_PROVIDER_DATA + " BLOB," |
| + WatchNextPrograms.COLUMN_INTERNAL_PROVIDER_FLAG1 + " INTEGER," |
| + WatchNextPrograms.COLUMN_INTERNAL_PROVIDER_FLAG2 + " INTEGER," |
| + WatchNextPrograms.COLUMN_INTERNAL_PROVIDER_FLAG3 + " INTEGER," |
| + WatchNextPrograms.COLUMN_INTERNAL_PROVIDER_FLAG4 + " INTEGER," |
| + WatchNextPrograms.COLUMN_VERSION_NUMBER + " INTEGER," |
| + WatchNextPrograms.COLUMN_INTERNAL_PROVIDER_ID + " TEXT," |
| + WatchNextPrograms.COLUMN_PREVIEW_VIDEO_URI + " TEXT," |
| + WatchNextPrograms.COLUMN_LAST_PLAYBACK_POSITION_MILLIS + " INTEGER," |
| + WatchNextPrograms.COLUMN_DURATION_MILLIS + " INTEGER," |
| + WatchNextPrograms.COLUMN_INTENT_URI + " TEXT," |
| + WatchNextPrograms.COLUMN_TRANSIENT + " INTEGER NOT NULL DEFAULT 0," |
| + WatchNextPrograms.COLUMN_TYPE + " INTEGER NOT NULL," |
| + WatchNextPrograms.COLUMN_WATCH_NEXT_TYPE + " INTEGER," |
| + WatchNextPrograms.COLUMN_POSTER_ART_ASPECT_RATIO + " INTEGER," |
| + WatchNextPrograms.COLUMN_THUMBNAIL_ASPECT_RATIO + " INTEGER," |
| + WatchNextPrograms.COLUMN_LOGO_URI + " TEXT," |
| + WatchNextPrograms.COLUMN_AVAILABILITY + " INTEGER," |
| + WatchNextPrograms.COLUMN_STARTING_PRICE + " TEXT," |
| + WatchNextPrograms.COLUMN_OFFER_PRICE + " TEXT," |
| + WatchNextPrograms.COLUMN_RELEASE_DATE + " TEXT," |
| + WatchNextPrograms.COLUMN_ITEM_COUNT + " INTEGER," |
| + WatchNextPrograms.COLUMN_LIVE + " INTEGER NOT NULL DEFAULT 0," |
| + WatchNextPrograms.COLUMN_INTERACTION_TYPE + " INTEGER," |
| + WatchNextPrograms.COLUMN_INTERACTION_COUNT + " INTEGER," |
| + WatchNextPrograms.COLUMN_AUTHOR + " TEXT," |
| + WatchNextPrograms.COLUMN_REVIEW_RATING_STYLE + " INTEGER," |
| + WatchNextPrograms.COLUMN_REVIEW_RATING + " TEXT," |
| + WatchNextPrograms.COLUMN_BROWSABLE + " INTEGER NOT NULL DEFAULT 1," |
| + WatchNextPrograms.COLUMN_CONTENT_ID + " TEXT," |
| + WatchNextPrograms.COLUMN_LAST_ENGAGEMENT_TIME_UTC_MILLIS + " INTEGER" |
| + ");"; |
| private static final String CREATE_WATCH_NEXT_PROGRAMS_PACKAGE_NAME_INDEX_SQL = |
| "CREATE INDEX watch_next_programs_package_name_index ON " + WATCH_NEXT_PROGRAMS_TABLE |
| + "(" + WatchNextPrograms.COLUMN_PACKAGE_NAME + ");"; |
| |
| static class DatabaseHelper extends SQLiteOpenHelper { |
| private static DatabaseHelper sSingleton = null; |
| private static Context mContext; |
| |
| public static synchronized DatabaseHelper getInstance(Context context) { |
| if (sSingleton == null) { |
| sSingleton = new DatabaseHelper(context); |
| } |
| return sSingleton; |
| } |
| |
| private DatabaseHelper(Context context) { |
| this(context, DATABASE_NAME, DATABASE_VERSION); |
| } |
| |
| @VisibleForTesting |
| DatabaseHelper(Context context, String databaseName, int databaseVersion) { |
| super(context, databaseName, null, databaseVersion); |
| mContext = context; |
| } |
| |
| @Override |
| public void onConfigure(SQLiteDatabase db) { |
| db.setForeignKeyConstraintsEnabled(true); |
| } |
| |
| @Override |
| public void onCreate(SQLiteDatabase db) { |
| if (DEBUG) { |
| Log.d(TAG, "Creating database"); |
| } |
| // Set up the database schema. |
| db.execSQL("CREATE TABLE " + CHANNELS_TABLE + " (" |
| + Channels._ID + " INTEGER PRIMARY KEY AUTOINCREMENT," |
| + Channels.COLUMN_PACKAGE_NAME + " TEXT NOT NULL," |
| + Channels.COLUMN_INPUT_ID + " TEXT NOT NULL," |
| + Channels.COLUMN_TYPE + " TEXT NOT NULL DEFAULT '" + Channels.TYPE_OTHER + "'," |
| + Channels.COLUMN_SERVICE_TYPE + " TEXT NOT NULL DEFAULT '" |
| + Channels.SERVICE_TYPE_AUDIO_VIDEO + "'," |
| + Channels.COLUMN_ORIGINAL_NETWORK_ID + " INTEGER NOT NULL DEFAULT 0," |
| + Channels.COLUMN_TRANSPORT_STREAM_ID + " INTEGER NOT NULL DEFAULT 0," |
| + Channels.COLUMN_SERVICE_ID + " INTEGER NOT NULL DEFAULT 0," |
| + Channels.COLUMN_DISPLAY_NUMBER + " TEXT," |
| + Channels.COLUMN_DISPLAY_NAME + " TEXT," |
| + Channels.COLUMN_NETWORK_AFFILIATION + " TEXT," |
| + Channels.COLUMN_DESCRIPTION + " TEXT," |
| + Channels.COLUMN_VIDEO_FORMAT + " TEXT," |
| + Channels.COLUMN_BROWSABLE + " INTEGER NOT NULL DEFAULT 0," |
| + Channels.COLUMN_SEARCHABLE + " INTEGER NOT NULL DEFAULT 1," |
| + Channels.COLUMN_LOCKED + " INTEGER NOT NULL DEFAULT 0," |
| + Channels.COLUMN_APP_LINK_ICON_URI + " TEXT," |
| + Channels.COLUMN_APP_LINK_POSTER_ART_URI + " TEXT," |
| + Channels.COLUMN_APP_LINK_TEXT + " TEXT," |
| + Channels.COLUMN_APP_LINK_COLOR + " INTEGER," |
| + Channels.COLUMN_APP_LINK_INTENT_URI + " TEXT," |
| + Channels.COLUMN_INTERNAL_PROVIDER_DATA + " BLOB," |
| + Channels.COLUMN_INTERNAL_PROVIDER_FLAG1 + " INTEGER," |
| + Channels.COLUMN_INTERNAL_PROVIDER_FLAG2 + " INTEGER," |
| + Channels.COLUMN_INTERNAL_PROVIDER_FLAG3 + " INTEGER," |
| + Channels.COLUMN_INTERNAL_PROVIDER_FLAG4 + " INTEGER," |
| + CHANNELS_COLUMN_LOGO + " BLOB," |
| + Channels.COLUMN_VERSION_NUMBER + " INTEGER," |
| + Channels.COLUMN_TRANSIENT + " INTEGER NOT NULL DEFAULT 0," |
| + Channels.COLUMN_INTERNAL_PROVIDER_ID + " TEXT," |
| // Needed for foreign keys in other tables. |
| + "UNIQUE(" + Channels._ID + "," + Channels.COLUMN_PACKAGE_NAME + ")" |
| + ");"); |
| db.execSQL("CREATE TABLE " + PROGRAMS_TABLE + " (" |
| + Programs._ID + " INTEGER PRIMARY KEY AUTOINCREMENT," |
| + Programs.COLUMN_PACKAGE_NAME + " TEXT NOT NULL," |
| + Programs.COLUMN_CHANNEL_ID + " INTEGER," |
| + Programs.COLUMN_TITLE + " TEXT," |
| + Programs.COLUMN_SEASON_DISPLAY_NUMBER + " TEXT," |
| + Programs.COLUMN_SEASON_TITLE + " TEXT," |
| + Programs.COLUMN_EPISODE_DISPLAY_NUMBER + " TEXT," |
| + Programs.COLUMN_EPISODE_TITLE + " TEXT," |
| + Programs.COLUMN_START_TIME_UTC_MILLIS + " INTEGER," |
| + Programs.COLUMN_END_TIME_UTC_MILLIS + " INTEGER," |
| + Programs.COLUMN_BROADCAST_GENRE + " TEXT," |
| + Programs.COLUMN_CANONICAL_GENRE + " TEXT," |
| + Programs.COLUMN_SHORT_DESCRIPTION + " TEXT," |
| + Programs.COLUMN_LONG_DESCRIPTION + " TEXT," |
| + Programs.COLUMN_VIDEO_WIDTH + " INTEGER," |
| + Programs.COLUMN_VIDEO_HEIGHT + " INTEGER," |
| + Programs.COLUMN_AUDIO_LANGUAGE + " TEXT," |
| + Programs.COLUMN_CONTENT_RATING + " TEXT," |
| + Programs.COLUMN_POSTER_ART_URI + " TEXT," |
| + Programs.COLUMN_THUMBNAIL_URI + " TEXT," |
| + Programs.COLUMN_SEARCHABLE + " INTEGER NOT NULL DEFAULT 1," |
| + Programs.COLUMN_RECORDING_PROHIBITED + " INTEGER NOT NULL DEFAULT 0," |
| + Programs.COLUMN_INTERNAL_PROVIDER_DATA + " BLOB," |
| + Programs.COLUMN_INTERNAL_PROVIDER_FLAG1 + " INTEGER," |
| + Programs.COLUMN_INTERNAL_PROVIDER_FLAG2 + " INTEGER," |
| + Programs.COLUMN_INTERNAL_PROVIDER_FLAG3 + " INTEGER," |
| + Programs.COLUMN_INTERNAL_PROVIDER_FLAG4 + " INTEGER," |
| + Programs.COLUMN_REVIEW_RATING_STYLE + " INTEGER," |
| + Programs.COLUMN_REVIEW_RATING + " TEXT," |
| + Programs.COLUMN_VERSION_NUMBER + " INTEGER," |
| + "FOREIGN KEY(" |
| + Programs.COLUMN_CHANNEL_ID + "," + Programs.COLUMN_PACKAGE_NAME |
| + ") REFERENCES " + CHANNELS_TABLE + "(" |
| + Channels._ID + "," + Channels.COLUMN_PACKAGE_NAME |
| + ") ON UPDATE CASCADE ON DELETE CASCADE" |
| + ");"); |
| db.execSQL("CREATE INDEX " + PROGRAMS_TABLE_PACKAGE_NAME_INDEX + " ON " + PROGRAMS_TABLE |
| + "(" + Programs.COLUMN_PACKAGE_NAME + ");"); |
| db.execSQL("CREATE INDEX " + PROGRAMS_TABLE_CHANNEL_ID_INDEX + " ON " + PROGRAMS_TABLE |
| + "(" + Programs.COLUMN_CHANNEL_ID + ");"); |
| db.execSQL("CREATE INDEX " + PROGRAMS_TABLE_START_TIME_INDEX + " ON " + PROGRAMS_TABLE |
| + "(" + Programs.COLUMN_START_TIME_UTC_MILLIS + ");"); |
| db.execSQL("CREATE INDEX " + PROGRAMS_TABLE_END_TIME_INDEX + " ON " + PROGRAMS_TABLE |
| + "(" + Programs.COLUMN_END_TIME_UTC_MILLIS + ");"); |
| db.execSQL("CREATE TABLE " + WATCHED_PROGRAMS_TABLE + " (" |
| + WatchedPrograms._ID + " INTEGER PRIMARY KEY AUTOINCREMENT," |
| + WatchedPrograms.COLUMN_PACKAGE_NAME + " TEXT NOT NULL," |
| + WatchedPrograms.COLUMN_WATCH_START_TIME_UTC_MILLIS |
| + " INTEGER NOT NULL DEFAULT 0," |
| + WatchedPrograms.COLUMN_WATCH_END_TIME_UTC_MILLIS |
| + " INTEGER NOT NULL DEFAULT 0," |
| + WatchedPrograms.COLUMN_CHANNEL_ID + " INTEGER," |
| + WatchedPrograms.COLUMN_TITLE + " TEXT," |
| + WatchedPrograms.COLUMN_START_TIME_UTC_MILLIS + " INTEGER," |
| + WatchedPrograms.COLUMN_END_TIME_UTC_MILLIS + " INTEGER," |
| + WatchedPrograms.COLUMN_DESCRIPTION + " TEXT," |
| + WatchedPrograms.COLUMN_INTERNAL_TUNE_PARAMS + " TEXT," |
| + WatchedPrograms.COLUMN_INTERNAL_SESSION_TOKEN + " TEXT NOT NULL," |
| + WATCHED_PROGRAMS_COLUMN_CONSOLIDATED + " INTEGER NOT NULL DEFAULT 0," |
| + "FOREIGN KEY(" |
| + WatchedPrograms.COLUMN_CHANNEL_ID + "," |
| + WatchedPrograms.COLUMN_PACKAGE_NAME |
| + ") REFERENCES " + CHANNELS_TABLE + "(" |
| + Channels._ID + "," + Channels.COLUMN_PACKAGE_NAME |
| + ") ON UPDATE CASCADE ON DELETE CASCADE" |
| + ");"); |
| db.execSQL("CREATE INDEX " + WATCHED_PROGRAMS_TABLE_CHANNEL_ID_INDEX + " ON " |
| + WATCHED_PROGRAMS_TABLE + "(" + WatchedPrograms.COLUMN_CHANNEL_ID + ");"); |
| db.execSQL(CREATE_RECORDED_PROGRAMS_TABLE_SQL); |
| db.execSQL(CREATE_PREVIEW_PROGRAMS_TABLE_SQL); |
| db.execSQL(CREATE_PREVIEW_PROGRAMS_PACKAGE_NAME_INDEX_SQL); |
| db.execSQL(CREATE_PREVIEW_PROGRAMS_CHANNEL_ID_INDEX_SQL); |
| db.execSQL(CREATE_WATCH_NEXT_PROGRAMS_TABLE_SQL); |
| db.execSQL(CREATE_WATCH_NEXT_PROGRAMS_PACKAGE_NAME_INDEX_SQL); |
| } |
| |
| @Override |
| public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) { |
| if (oldVersion < 23) { |
| Log.i(TAG, "Upgrading from version " + oldVersion + " to " + newVersion |
| + ", data will be lost!"); |
| db.execSQL("DROP TABLE IF EXISTS " + DELETED_CHANNELS_TABLE); |
| db.execSQL("DROP TABLE IF EXISTS " + WATCHED_PROGRAMS_TABLE); |
| db.execSQL("DROP TABLE IF EXISTS " + PROGRAMS_TABLE); |
| db.execSQL("DROP TABLE IF EXISTS " + CHANNELS_TABLE); |
| |
| onCreate(db); |
| return; |
| } |
| |
| Log.i(TAG, "Upgrading from version " + oldVersion + " to " + newVersion + "."); |
| if (oldVersion <= 23) { |
| db.execSQL("ALTER TABLE " + CHANNELS_TABLE + " ADD " |
| + Channels.COLUMN_INTERNAL_PROVIDER_FLAG1 + " INTEGER;"); |
| db.execSQL("ALTER TABLE " + CHANNELS_TABLE + " ADD " |
| + Channels.COLUMN_INTERNAL_PROVIDER_FLAG2 + " INTEGER;"); |
| db.execSQL("ALTER TABLE " + CHANNELS_TABLE + " ADD " |
| + Channels.COLUMN_INTERNAL_PROVIDER_FLAG3 + " INTEGER;"); |
| db.execSQL("ALTER TABLE " + CHANNELS_TABLE + " ADD " |
| + Channels.COLUMN_INTERNAL_PROVIDER_FLAG4 + " INTEGER;"); |
| } |
| if (oldVersion <= 24) { |
| db.execSQL("ALTER TABLE " + PROGRAMS_TABLE + " ADD " |
| + Programs.COLUMN_INTERNAL_PROVIDER_FLAG1 + " INTEGER;"); |
| db.execSQL("ALTER TABLE " + PROGRAMS_TABLE + " ADD " |
| + Programs.COLUMN_INTERNAL_PROVIDER_FLAG2 + " INTEGER;"); |
| db.execSQL("ALTER TABLE " + PROGRAMS_TABLE + " ADD " |
| + Programs.COLUMN_INTERNAL_PROVIDER_FLAG3 + " INTEGER;"); |
| db.execSQL("ALTER TABLE " + PROGRAMS_TABLE + " ADD " |
| + Programs.COLUMN_INTERNAL_PROVIDER_FLAG4 + " INTEGER;"); |
| } |
| if (oldVersion <= 25) { |
| db.execSQL("ALTER TABLE " + CHANNELS_TABLE + " ADD " |
| + Channels.COLUMN_APP_LINK_ICON_URI + " TEXT;"); |
| db.execSQL("ALTER TABLE " + CHANNELS_TABLE + " ADD " |
| + Channels.COLUMN_APP_LINK_POSTER_ART_URI + " TEXT;"); |
| db.execSQL("ALTER TABLE " + CHANNELS_TABLE + " ADD " |
| + Channels.COLUMN_APP_LINK_TEXT + " TEXT;"); |
| db.execSQL("ALTER TABLE " + CHANNELS_TABLE + " ADD " |
| + Channels.COLUMN_APP_LINK_COLOR + " INTEGER;"); |
| db.execSQL("ALTER TABLE " + CHANNELS_TABLE + " ADD " |
| + Channels.COLUMN_APP_LINK_INTENT_URI + " TEXT;"); |
| db.execSQL("ALTER TABLE " + PROGRAMS_TABLE + " ADD " |
| + Programs.COLUMN_SEARCHABLE + " INTEGER NOT NULL DEFAULT 1;"); |
| } |
| if (oldVersion <= 28) { |
| db.execSQL("ALTER TABLE " + PROGRAMS_TABLE + " ADD " |
| + Programs.COLUMN_SEASON_TITLE + " TEXT;"); |
| migrateIntegerColumnToTextColumn(db, PROGRAMS_TABLE, Programs.COLUMN_SEASON_NUMBER, |
| Programs.COLUMN_SEASON_DISPLAY_NUMBER); |
| migrateIntegerColumnToTextColumn(db, PROGRAMS_TABLE, Programs.COLUMN_EPISODE_NUMBER, |
| Programs.COLUMN_EPISODE_DISPLAY_NUMBER); |
| } |
| if (oldVersion <= 29) { |
| db.execSQL("DROP TABLE IF EXISTS " + RECORDED_PROGRAMS_TABLE); |
| db.execSQL(CREATE_RECORDED_PROGRAMS_TABLE_SQL); |
| } |
| if (oldVersion <= 30) { |
| db.execSQL("ALTER TABLE " + PROGRAMS_TABLE + " ADD " |
| + Programs.COLUMN_RECORDING_PROHIBITED + " INTEGER NOT NULL DEFAULT 0;"); |
| } |
| if (oldVersion <= 32) { |
| db.execSQL("ALTER TABLE " + CHANNELS_TABLE + " ADD " |
| + Channels.COLUMN_TRANSIENT + " INTEGER NOT NULL DEFAULT 0;"); |
| db.execSQL("ALTER TABLE " + CHANNELS_TABLE + " ADD " |
| + Channels.COLUMN_INTERNAL_PROVIDER_ID + " TEXT;"); |
| db.execSQL("ALTER TABLE " + PROGRAMS_TABLE + " ADD " |
| + Programs.COLUMN_REVIEW_RATING_STYLE + " INTEGER;"); |
| db.execSQL("ALTER TABLE " + PROGRAMS_TABLE + " ADD " |
| + Programs.COLUMN_REVIEW_RATING + " TEXT;"); |
| if (oldVersion > 29) { |
| db.execSQL("ALTER TABLE " + RECORDED_PROGRAMS_TABLE + " ADD " |
| + RecordedPrograms.COLUMN_REVIEW_RATING_STYLE + " INTEGER;"); |
| db.execSQL("ALTER TABLE " + RECORDED_PROGRAMS_TABLE + " ADD " |
| + RecordedPrograms.COLUMN_REVIEW_RATING + " TEXT;"); |
| } |
| } |
| if (oldVersion <= 33) { |
| db.execSQL("DROP TABLE IF EXISTS " + PREVIEW_PROGRAMS_TABLE); |
| db.execSQL("DROP TABLE IF EXISTS " + WATCH_NEXT_PROGRAMS_TABLE); |
| db.execSQL(CREATE_PREVIEW_PROGRAMS_TABLE_SQL); |
| db.execSQL(CREATE_PREVIEW_PROGRAMS_PACKAGE_NAME_INDEX_SQL); |
| db.execSQL(CREATE_PREVIEW_PROGRAMS_CHANNEL_ID_INDEX_SQL); |
| db.execSQL(CREATE_WATCH_NEXT_PROGRAMS_TABLE_SQL); |
| db.execSQL(CREATE_WATCH_NEXT_PROGRAMS_PACKAGE_NAME_INDEX_SQL); |
| } |
| Log.i(TAG, "Upgrading from version " + oldVersion + " to " + newVersion + " is done."); |
| } |
| |
| @Override |
| public void onOpen(SQLiteDatabase db) { |
| // Call a static method on the TvProvider because changes to sInitialized must |
| // be guarded by a lock on the class. |
| initOnOpenIfNeeded(mContext, db); |
| } |
| |
| private static void migrateIntegerColumnToTextColumn(SQLiteDatabase db, String table, |
| String integerColumn, String textColumn) { |
| db.execSQL("ALTER TABLE " + table + " ADD " + textColumn + " TEXT;"); |
| db.execSQL("UPDATE " + table + " SET " + textColumn + " = CAST(" + integerColumn |
| + " AS TEXT);"); |
| } |
| } |
| |
| private DatabaseHelper mOpenHelper; |
| private static SharedPreferences sBlockedPackagesSharedPreference; |
| private static Map<String, Boolean> sBlockedPackages; |
| @VisibleForTesting |
| protected TransientRowHelper mTransientRowHelper; |
| |
| private final Handler mLogHandler = new WatchLogHandler(); |
| |
| @Override |
| public boolean onCreate() { |
| if (DEBUG) { |
| Log.d(TAG, "Creating TvProvider"); |
| } |
| if (mOpenHelper == null) { |
| mOpenHelper = DatabaseHelper.getInstance(getContext()); |
| } |
| mTransientRowHelper = TransientRowHelper.getInstance(getContext()); |
| scheduleEpgDataCleanup(); |
| buildGenreMap(); |
| |
| // DB operation, which may trigger upgrade, should not happen in onCreate. |
| new AsyncTask<Void, Void, Void>() { |
| @Override |
| protected Void doInBackground(Void... params) { |
| deleteUnconsolidatedWatchedProgramsRows(); |
| return null; |
| } |
| }.execute(); |
| return true; |
| } |
| |
| @VisibleForTesting |
| void scheduleEpgDataCleanup() { |
| Intent intent = new Intent(EpgDataCleanupService.ACTION_CLEAN_UP_EPG_DATA); |
| intent.setClass(getContext(), EpgDataCleanupService.class); |
| PendingIntent pendingIntent = PendingIntent.getService( |
| getContext(), 0, intent, PendingIntent.FLAG_UPDATE_CURRENT); |
| AlarmManager alarmManager = |
| (AlarmManager) getContext().getSystemService(Context.ALARM_SERVICE); |
| alarmManager.setInexactRepeating(AlarmManager.RTC, System.currentTimeMillis(), |
| AlarmManager.INTERVAL_HALF_DAY, pendingIntent); |
| } |
| |
| private void buildGenreMap() { |
| if (sGenreMap != null) { |
| return; |
| } |
| |
| sGenreMap = new HashMap<>(); |
| buildGenreMap(R.array.genre_mapping_atsc); |
| buildGenreMap(R.array.genre_mapping_dvb); |
| buildGenreMap(R.array.genre_mapping_isdb); |
| buildGenreMap(R.array.genre_mapping_isdb_br); |
| } |
| |
| @SuppressLint("DefaultLocale") |
| private void buildGenreMap(int id) { |
| String[] maps = getContext().getResources().getStringArray(id); |
| for (String map : maps) { |
| String[] arr = map.split("\\|"); |
| if (arr.length != 2) { |
| throw new IllegalArgumentException("Invalid genre mapping : " + map); |
| } |
| sGenreMap.put(arr[0].toUpperCase(), arr[1]); |
| } |
| } |
| |
| @VisibleForTesting |
| String getCallingPackage_() { |
| return getCallingPackage(); |
| } |
| |
| @VisibleForTesting |
| void setOpenHelper(DatabaseHelper helper) { |
| mOpenHelper = helper; |
| } |
| |
| @Override |
| public String getType(Uri uri) { |
| switch (sUriMatcher.match(uri)) { |
| case MATCH_CHANNEL: |
| return Channels.CONTENT_TYPE; |
| case MATCH_CHANNEL_ID: |
| return Channels.CONTENT_ITEM_TYPE; |
| case MATCH_CHANNEL_ID_LOGO: |
| return "image/png"; |
| case MATCH_PASSTHROUGH_ID: |
| return Channels.CONTENT_ITEM_TYPE; |
| case MATCH_PROGRAM: |
| return Programs.CONTENT_TYPE; |
| case MATCH_PROGRAM_ID: |
| return Programs.CONTENT_ITEM_TYPE; |
| case MATCH_WATCHED_PROGRAM: |
| return WatchedPrograms.CONTENT_TYPE; |
| case MATCH_WATCHED_PROGRAM_ID: |
| return WatchedPrograms.CONTENT_ITEM_TYPE; |
| case MATCH_RECORDED_PROGRAM: |
| return RecordedPrograms.CONTENT_TYPE; |
| case MATCH_RECORDED_PROGRAM_ID: |
| return RecordedPrograms.CONTENT_ITEM_TYPE; |
| case MATCH_PREVIEW_PROGRAM: |
| return PreviewPrograms.CONTENT_TYPE; |
| case MATCH_PREVIEW_PROGRAM_ID: |
| return PreviewPrograms.CONTENT_ITEM_TYPE; |
| case MATCH_WATCH_NEXT_PROGRAM: |
| return WatchNextPrograms.CONTENT_TYPE; |
| case MATCH_WATCH_NEXT_PROGRAM_ID: |
| return WatchNextPrograms.CONTENT_ITEM_TYPE; |
| default: |
| throw new IllegalArgumentException("Unknown URI " + uri); |
| } |
| } |
| |
| @Override |
| public Bundle call(String method, String arg, Bundle extras) { |
| if (!callerHasAccessAllEpgDataPermission()) { |
| return null; |
| } |
| ensureInitialized(); |
| Map<String, String> projectionMap; |
| switch (method) { |
| case TvContract.METHOD_GET_COLUMNS: |
| switch (sUriMatcher.match(Uri.parse(arg))) { |
| case MATCH_CHANNEL: |
| projectionMap = sChannelProjectionMap; |
| break; |
| case MATCH_PROGRAM: |
| projectionMap = sProgramProjectionMap; |
| break; |
| case MATCH_PREVIEW_PROGRAM: |
| projectionMap = sPreviewProgramProjectionMap; |
| break; |
| case MATCH_WATCH_NEXT_PROGRAM: |
| projectionMap = sWatchNextProgramProjectionMap; |
| break; |
| case MATCH_RECORDED_PROGRAM: |
| projectionMap = sRecordedProgramProjectionMap; |
| break; |
| default: |
| return null; |
| } |
| Bundle result = new Bundle(); |
| result.putStringArray(TvContract.EXTRA_EXISTING_COLUMN_NAMES, |
| projectionMap.keySet().toArray(new String[projectionMap.size()])); |
| return result; |
| case TvContract.METHOD_ADD_COLUMN: |
| CharSequence columnName = extras.getCharSequence(TvContract.EXTRA_COLUMN_NAME); |
| CharSequence dataType = extras.getCharSequence(TvContract.EXTRA_DATA_TYPE); |
| if (TextUtils.isEmpty(columnName) || TextUtils.isEmpty(dataType)) { |
| return null; |
| } |
| CharSequence defaultValue = extras.getCharSequence(TvContract.EXTRA_DEFAULT_VALUE); |
| try { |
| defaultValue = TextUtils.isEmpty(defaultValue) ? "" : generateDefaultClause( |
| dataType.toString(), defaultValue.toString()); |
| } catch (IllegalArgumentException e) { |
| return null; |
| } |
| String tableName; |
| switch (sUriMatcher.match(Uri.parse(arg))) { |
| case MATCH_CHANNEL: |
| tableName = CHANNELS_TABLE; |
| projectionMap = sChannelProjectionMap; |
| break; |
| case MATCH_PROGRAM: |
| tableName = PROGRAMS_TABLE; |
| projectionMap = sProgramProjectionMap; |
| break; |
| case MATCH_PREVIEW_PROGRAM: |
| tableName = PREVIEW_PROGRAMS_TABLE; |
| projectionMap = sPreviewProgramProjectionMap; |
| break; |
| case MATCH_WATCH_NEXT_PROGRAM: |
| tableName = WATCH_NEXT_PROGRAMS_TABLE; |
| projectionMap = sWatchNextProgramProjectionMap; |
| break; |
| case MATCH_RECORDED_PROGRAM: |
| tableName = RECORDED_PROGRAMS_TABLE; |
| projectionMap = sRecordedProgramProjectionMap; |
| break; |
| default: |
| return null; |
| } |
| try (SQLiteDatabase db = mOpenHelper.getWritableDatabase()) { |
| db.execSQL("ALTER TABLE " + tableName + " ADD " |
| + columnName + " " + dataType + defaultValue + ";"); |
| projectionMap.put(columnName.toString(), tableName + '.' + columnName); |
| Bundle returnValue = new Bundle(); |
| returnValue.putStringArray(TvContract.EXTRA_EXISTING_COLUMN_NAMES, |
| projectionMap.keySet().toArray(new String[projectionMap.size()])); |
| return returnValue; |
| } catch (SQLException e) { |
| return null; |
| } |
| case TvContract.METHOD_GET_BLOCKED_PACKAGES: |
| Bundle allBlockedPackages = new Bundle(); |
| allBlockedPackages.putStringArray(TvContract.EXTRA_BLOCKED_PACKAGES, |
| sBlockedPackages.keySet().toArray(new String[sBlockedPackages.size()])); |
| return allBlockedPackages; |
| case TvContract.METHOD_BLOCK_PACKAGE: |
| String packageNameToBlock = arg; |
| Bundle blockPackageResult = new Bundle(); |
| if (!TextUtils.isEmpty(packageNameToBlock)) { |
| sBlockedPackages.put(packageNameToBlock, true); |
| if (sBlockedPackagesSharedPreference.edit().putStringSet( |
| SHARED_PREF_BLOCKED_PACKAGES_KEY, sBlockedPackages.keySet()).commit()) { |
| String[] channelSelectionArgs = new String[] { |
| packageNameToBlock, Channels.TYPE_PREVIEW }; |
| delete(TvContract.Channels.CONTENT_URI, |
| Channels.COLUMN_PACKAGE_NAME + "=? AND " |
| + Channels.COLUMN_TYPE + "=?", |
| channelSelectionArgs); |
| String[] programsSelectionArgs = new String[] { |
| packageNameToBlock }; |
| delete(TvContract.PreviewPrograms.CONTENT_URI, |
| PreviewPrograms.COLUMN_PACKAGE_NAME + "=?", programsSelectionArgs); |
| delete(TvContract.WatchNextPrograms.CONTENT_URI, |
| WatchNextPrograms.COLUMN_PACKAGE_NAME + "=?", |
| programsSelectionArgs); |
| blockPackageResult.putInt( |
| TvContract.EXTRA_RESULT_CODE, TvContract.RESULT_OK); |
| } else { |
| Log.e(TAG, "Blocking package " + packageNameToBlock + " failed"); |
| sBlockedPackages.remove(packageNameToBlock); |
| blockPackageResult.putInt(TvContract.EXTRA_RESULT_CODE, TvContract.RESULT_ERROR_IO); |
| } |
| } else { |
| blockPackageResult.putInt( |
| TvContract.EXTRA_RESULT_CODE, TvContract.RESULT_ERROR_INVALID_ARGUMENT); |
| } |
| return blockPackageResult; |
| case TvContract.METHOD_UNBLOCK_PACKAGE: |
| String packageNameToUnblock = arg; |
| Bundle unblockPackageResult = new Bundle(); |
| if (!TextUtils.isEmpty(packageNameToUnblock)) { |
| sBlockedPackages.remove(packageNameToUnblock); |
| if (sBlockedPackagesSharedPreference.edit().putStringSet( |
| SHARED_PREF_BLOCKED_PACKAGES_KEY, sBlockedPackages.keySet()).commit()) { |
| unblockPackageResult.putInt( |
| TvContract.EXTRA_RESULT_CODE, TvContract.RESULT_OK); |
| } else { |
| Log.e(TAG, "Unblocking package " + packageNameToUnblock + " failed"); |
| sBlockedPackages.put(packageNameToUnblock, true); |
| unblockPackageResult.putInt( |
| TvContract.EXTRA_RESULT_CODE, TvContract.RESULT_ERROR_IO); |
| } |
| } else { |
| unblockPackageResult.putInt( |
| TvContract.EXTRA_RESULT_CODE, TvContract.RESULT_ERROR_INVALID_ARGUMENT); |
| } |
| return unblockPackageResult; |
| } |
| return null; |
| } |
| |
| @Override |
| public Cursor query(Uri uri, String[] projection, String selection, String[] selectionArgs, |
| String sortOrder) { |
| ensureInitialized(); |
| mTransientRowHelper.ensureOldTransientRowsDeleted(); |
| boolean needsToValidateSortOrder = !callerHasAccessAllEpgDataPermission(); |
| SqlParams params = createSqlParams(OP_QUERY, uri, selection, selectionArgs); |
| |
| SQLiteQueryBuilder queryBuilder = new SQLiteQueryBuilder(); |
| queryBuilder.setStrict(needsToValidateSortOrder); |
| queryBuilder.setTables(params.getTables()); |
| String orderBy = null; |
| Map<String, String> projectionMap; |
| switch (params.getTables()) { |
| case PROGRAMS_TABLE: |
| projectionMap = sProgramProjectionMap; |
| orderBy = DEFAULT_PROGRAMS_SORT_ORDER; |
| break; |
| case WATCHED_PROGRAMS_TABLE: |
| projectionMap = sWatchedProgramProjectionMap; |
| orderBy = DEFAULT_WATCHED_PROGRAMS_SORT_ORDER; |
| break; |
| case RECORDED_PROGRAMS_TABLE: |
| projectionMap = sRecordedProgramProjectionMap; |
| break; |
| case PREVIEW_PROGRAMS_TABLE: |
| projectionMap = sPreviewProgramProjectionMap; |
| break; |
| case WATCH_NEXT_PROGRAMS_TABLE: |
| projectionMap = sWatchNextProgramProjectionMap; |
| break; |
| default: |
| projectionMap = sChannelProjectionMap; |
| break; |
| } |
| queryBuilder.setProjectionMap(createProjectionMapForQuery(projection, projectionMap)); |
| if (needsToValidateSortOrder) { |
| validateSortOrder(sortOrder, projectionMap.keySet()); |
| } |
| |
| // Use the default sort order only if no sort order is specified. |
| if (!TextUtils.isEmpty(sortOrder)) { |
| orderBy = sortOrder; |
| } |
| |
| // Get the database and run the query. |
| SQLiteDatabase db = mOpenHelper.getReadableDatabase(); |
| Cursor c = queryBuilder.query(db, projection, params.getSelection(), |
| params.getSelectionArgs(), null, null, orderBy); |
| |
| // Tell the cursor what URI to watch, so it knows when its source data changes. |
| c.setNotificationUri(getContext().getContentResolver(), uri); |
| return c; |
| } |
| |
| @Override |
| public Uri insert(Uri uri, ContentValues values) { |
| ensureInitialized(); |
| mTransientRowHelper.ensureOldTransientRowsDeleted(); |
| switch (sUriMatcher.match(uri)) { |
| case MATCH_CHANNEL: |
| // Preview channels are not necessarily associated with TV input service. |
| // Therefore, we fill a fake ID to meet not null restriction for preview channels. |
| if (values.get(Channels.COLUMN_INPUT_ID) == null |
| && Channels.TYPE_PREVIEW.equals(values.get(Channels.COLUMN_TYPE))) { |
| values.put(Channels.COLUMN_INPUT_ID, EMPTY_STRING); |
| } |
| filterContentValues(values, sChannelProjectionMap); |
| return insertChannel(uri, values); |
| case MATCH_PROGRAM: |
| filterContentValues(values, sProgramProjectionMap); |
| return insertProgram(uri, values); |
| case MATCH_WATCHED_PROGRAM: |
| return insertWatchedProgram(uri, values); |
| case MATCH_RECORDED_PROGRAM: |
| filterContentValues(values, sRecordedProgramProjectionMap); |
| return insertRecordedProgram(uri, values); |
| case MATCH_PREVIEW_PROGRAM: |
| filterContentValues(values, sPreviewProgramProjectionMap); |
| return insertPreviewProgram(uri, values); |
| case MATCH_WATCH_NEXT_PROGRAM: |
| filterContentValues(values, sWatchNextProgramProjectionMap); |
| return insertWatchNextProgram(uri, values); |
| case MATCH_CHANNEL_ID: |
| case MATCH_CHANNEL_ID_LOGO: |
| case MATCH_PASSTHROUGH_ID: |
| case MATCH_PROGRAM_ID: |
| case MATCH_WATCHED_PROGRAM_ID: |
| case MATCH_RECORDED_PROGRAM_ID: |
| case MATCH_PREVIEW_PROGRAM_ID: |
| throw new UnsupportedOperationException("Cannot insert into that URI: " + uri); |
| default: |
| throw new IllegalArgumentException("Unknown URI " + uri); |
| } |
| } |
| |
| private Uri insertChannel(Uri uri, ContentValues values) { |
| if (TextUtils.equals(values.getAsString(Channels.COLUMN_TYPE), Channels.TYPE_PREVIEW)) { |
| blockIllegalAccessFromBlockedPackage(); |
| } |
| // Mark the owner package of this channel. |
| values.put(Channels.COLUMN_PACKAGE_NAME, getCallingPackage_()); |
| blockIllegalAccessToChannelsSystemColumns(values); |
| |
| SQLiteDatabase db = mOpenHelper.getWritableDatabase(); |
| long rowId = db.insert(CHANNELS_TABLE, null, values); |
| if (rowId > 0) { |
| Uri channelUri = TvContract.buildChannelUri(rowId); |
| notifyChange(channelUri); |
| return channelUri; |
| } |
| |
| throw new SQLException("Failed to insert row into " + uri); |
| } |
| |
| private Uri insertProgram(Uri uri, ContentValues values) { |
| if (!callerHasAccessAllEpgDataPermission() || |
| !values.containsKey(Programs.COLUMN_PACKAGE_NAME)) { |
| // Mark the owner package of this program. System app with a proper permission may |
| // change the owner of the program. |
| values.put(Programs.COLUMN_PACKAGE_NAME, getCallingPackage_()); |
| } |
| |
| checkAndConvertGenre(values); |
| checkAndConvertDeprecatedColumns(values); |
| |
| SQLiteDatabase db = mOpenHelper.getWritableDatabase(); |
| long rowId = db.insert(PROGRAMS_TABLE, null, values); |
| if (rowId > 0) { |
| Uri programUri = TvContract.buildProgramUri(rowId); |
| notifyChange(programUri); |
| return programUri; |
| } |
| |
| throw new SQLException("Failed to insert row into " + uri); |
| } |
| |
| private Uri insertWatchedProgram(Uri uri, ContentValues values) { |
| if (DEBUG) { |
| Log.d(TAG, "insertWatchedProgram(uri=" + uri + ", values={" + values + "})"); |
| } |
| Long watchStartTime = values.getAsLong(WatchedPrograms.COLUMN_WATCH_START_TIME_UTC_MILLIS); |
| Long watchEndTime = values.getAsLong(WatchedPrograms.COLUMN_WATCH_END_TIME_UTC_MILLIS); |
| // The system sends only two kinds of watch events: |
| // 1. The user tunes to a new channel. (COLUMN_WATCH_START_TIME_UTC_MILLIS) |
| // 2. The user stops watching. (COLUMN_WATCH_END_TIME_UTC_MILLIS) |
| if (watchStartTime != null && watchEndTime == null) { |
| SQLiteDatabase db = mOpenHelper.getWritableDatabase(); |
| long rowId = db.insert(WATCHED_PROGRAMS_TABLE, null, values); |
| if (rowId > 0) { |
| mLogHandler.removeMessages(WatchLogHandler.MSG_TRY_CONSOLIDATE_ALL); |
| mLogHandler.sendEmptyMessageDelayed(WatchLogHandler.MSG_TRY_CONSOLIDATE_ALL, |
| MAX_PROGRAM_DATA_DELAY_IN_MILLIS); |
| return TvContract.buildWatchedProgramUri(rowId); |
| } |
| Log.w(TAG, "Failed to insert row for " + values + ". Channel does not exist."); |
| return null; |
| } else if (watchStartTime == null && watchEndTime != null) { |
| SomeArgs args = SomeArgs.obtain(); |
| args.arg1 = values.getAsString(WatchedPrograms.COLUMN_INTERNAL_SESSION_TOKEN); |
| args.arg2 = watchEndTime; |
| Message msg = mLogHandler.obtainMessage(WatchLogHandler.MSG_CONSOLIDATE, args); |
| mLogHandler.sendMessageDelayed(msg, MAX_PROGRAM_DATA_DELAY_IN_MILLIS); |
| return null; |
| } |
| // All the other cases are invalid. |
| throw new IllegalArgumentException("Only one of COLUMN_WATCH_START_TIME_UTC_MILLIS and" |
| + " COLUMN_WATCH_END_TIME_UTC_MILLIS should be specified"); |
| } |
| |
| private Uri insertRecordedProgram(Uri uri, ContentValues values) { |
| // Mark the owner package of this program. |
| values.put(Programs.COLUMN_PACKAGE_NAME, getCallingPackage_()); |
| |
| checkAndConvertGenre(values); |
| |
| SQLiteDatabase db = mOpenHelper.getWritableDatabase(); |
| long rowId = db.insert(RECORDED_PROGRAMS_TABLE, null, values); |
| if (rowId > 0) { |
| Uri recordedProgramUri = TvContract.buildRecordedProgramUri(rowId); |
| notifyChange(recordedProgramUri); |
| return recordedProgramUri; |
| } |
| |
| throw new SQLException("Failed to insert row into " + uri); |
| } |
| |
| private Uri insertPreviewProgram(Uri uri, ContentValues values) { |
| if (!values.containsKey(PreviewPrograms.COLUMN_TYPE)) { |
| throw new IllegalArgumentException("Missing the required column: " + |
| PreviewPrograms.COLUMN_TYPE); |
| } |
| blockIllegalAccessFromBlockedPackage(); |
| // Mark the owner package of this program. |
| values.put(Programs.COLUMN_PACKAGE_NAME, getCallingPackage_()); |
| blockIllegalAccessToPreviewProgramsSystemColumns(values); |
| |
| SQLiteDatabase db = mOpenHelper.getWritableDatabase(); |
| long rowId = db.insert(PREVIEW_PROGRAMS_TABLE, null, values); |
| if (rowId > 0) { |
| Uri previewProgramUri = TvContract.buildPreviewProgramUri(rowId); |
| notifyChange(previewProgramUri); |
| return previewProgramUri; |
| } |
| |
| throw new SQLException("Failed to insert row into " + uri); |
| } |
| |
| private Uri insertWatchNextProgram(Uri uri, ContentValues values) { |
| if (!values.containsKey(WatchNextPrograms.COLUMN_TYPE)) { |
| throw new IllegalArgumentException("Missing the required column: " + |
| WatchNextPrograms.COLUMN_TYPE); |
| } |
| blockIllegalAccessFromBlockedPackage(); |
| if (!callerHasAccessAllEpgDataPermission() || |
| !values.containsKey(Programs.COLUMN_PACKAGE_NAME)) { |
| // Mark the owner package of this program. System app with a proper permission may |
| // change the owner of the program. |
| values.put(Programs.COLUMN_PACKAGE_NAME, getCallingPackage_()); |
| } |
| blockIllegalAccessToPreviewProgramsSystemColumns(values); |
| |
| SQLiteDatabase db = mOpenHelper.getWritableDatabase(); |
| long rowId = db.insert(WATCH_NEXT_PROGRAMS_TABLE, null, values); |
| if (rowId > 0) { |
| Uri watchNextProgramUri = TvContract.buildWatchNextProgramUri(rowId); |
| notifyChange(watchNextProgramUri); |
| return watchNextProgramUri; |
| } |
| |
| throw new SQLException("Failed to insert row into " + uri); |
| } |
| |
| @Override |
| public int delete(Uri uri, String selection, String[] selectionArgs) { |
| mTransientRowHelper.ensureOldTransientRowsDeleted(); |
| SqlParams params = createSqlParams(OP_DELETE, uri, selection, selectionArgs); |
| SQLiteDatabase db = mOpenHelper.getWritableDatabase(); |
| int count; |
| switch (sUriMatcher.match(uri)) { |
| case MATCH_CHANNEL_ID_LOGO: |
| ContentValues values = new ContentValues(); |
| values.putNull(CHANNELS_COLUMN_LOGO); |
| count = db.update(params.getTables(), values, params.getSelection(), |
| params.getSelectionArgs()); |
| break; |
| case MATCH_CHANNEL: |
| case MATCH_PROGRAM: |
| case MATCH_WATCHED_PROGRAM: |
| case MATCH_RECORDED_PROGRAM: |
| case MATCH_PREVIEW_PROGRAM: |
| case MATCH_WATCH_NEXT_PROGRAM: |
| case MATCH_CHANNEL_ID: |
| case MATCH_PASSTHROUGH_ID: |
| case MATCH_PROGRAM_ID: |
| case MATCH_WATCHED_PROGRAM_ID: |
| case MATCH_RECORDED_PROGRAM_ID: |
| case MATCH_PREVIEW_PROGRAM_ID: |
| case MATCH_WATCH_NEXT_PROGRAM_ID: |
| count = db.delete(params.getTables(), params.getSelection(), |
| params.getSelectionArgs()); |
| break; |
| default: |
| throw new IllegalArgumentException("Unknown URI " + uri); |
| } |
| if (count > 0) { |
| notifyChange(uri); |
| } |
| return count; |
| } |
| |
| @Override |
| public int update(Uri uri, ContentValues values, String selection, String[] selectionArgs) { |
| mTransientRowHelper.ensureOldTransientRowsDeleted(); |
| SqlParams params = createSqlParams(OP_UPDATE, uri, selection, selectionArgs); |
| blockIllegalAccessToIdAndPackageName(uri, values); |
| boolean containImmutableColumn = false; |
| if (params.getTables().equals(CHANNELS_TABLE)) { |
| filterContentValues(values, sChannelProjectionMap); |
| containImmutableColumn = disallowModifyChannelType(values, params); |
| if (containImmutableColumn && sUriMatcher.match(uri) != MATCH_CHANNEL_ID) { |
| Log.i(TAG, "Updating failed. Attempt to change immutable column for channels."); |
| return 0; |
| } |
| blockIllegalAccessToChannelsSystemColumns(values); |
| } else if (params.getTables().equals(PROGRAMS_TABLE)) { |
| filterContentValues(values, sProgramProjectionMap); |
| checkAndConvertGenre(values); |
| checkAndConvertDeprecatedColumns(values); |
| } else if (params.getTables().equals(RECORDED_PROGRAMS_TABLE)) { |
| filterContentValues(values, sRecordedProgramProjectionMap); |
| checkAndConvertGenre(values); |
| } else if (params.getTables().equals(PREVIEW_PROGRAMS_TABLE)) { |
| filterContentValues(values, sPreviewProgramProjectionMap); |
| containImmutableColumn = disallowModifyChannelId(values, params); |
| if (containImmutableColumn && PreviewPrograms.CONTENT_URI.equals(uri)) { |
| Log.i(TAG, "Updating failed. Attempt to change unmodifiable column for " |
| + "preview programs."); |
| return 0; |
| } |
| blockIllegalAccessToPreviewProgramsSystemColumns(values); |
| } else if (params.getTables().equals(WATCH_NEXT_PROGRAMS_TABLE)) { |
| filterContentValues(values, sWatchNextProgramProjectionMap); |
| blockIllegalAccessToPreviewProgramsSystemColumns(values); |
| } |
| if (values.size() == 0) { |
| // All values may be filtered out, no need to update |
| return 0; |
| } |
| SQLiteDatabase db = mOpenHelper.getWritableDatabase(); |
| int count = db.update(params.getTables(), values, params.getSelection(), |
| params.getSelectionArgs()); |
| if (count > 0) { |
| notifyChange(uri); |
| } else if (containImmutableColumn) { |
| Log.i(TAG, "Updating failed. The item may not exist or attempt to change " |
| + "immutable column."); |
| } |
| return count; |
| } |
| |
| private synchronized void ensureInitialized() { |
| if (!sInitialized) { |
| // Database is not accessed before and the projection maps and the blocked package list |
| // are not updated yet. Gets database here to make it initialized. |
| mOpenHelper.getReadableDatabase(); |
| } |
| } |
| |
| private static synchronized void initOnOpenIfNeeded(Context context, SQLiteDatabase db) { |
| if (!sInitialized) { |
| updateProjectionMap(db, CHANNELS_TABLE, sChannelProjectionMap); |
| updateProjectionMap(db, PROGRAMS_TABLE, sProgramProjectionMap); |
| updateProjectionMap(db, WATCHED_PROGRAMS_TABLE, sWatchedProgramProjectionMap); |
| updateProjectionMap(db, RECORDED_PROGRAMS_TABLE, sRecordedProgramProjectionMap); |
| updateProjectionMap(db, PREVIEW_PROGRAMS_TABLE, sPreviewProgramProjectionMap); |
| updateProjectionMap(db, WATCH_NEXT_PROGRAMS_TABLE, sWatchNextProgramProjectionMap); |
| sBlockedPackagesSharedPreference = PreferenceManager.getDefaultSharedPreferences( |
| context); |
| sBlockedPackages = new ConcurrentHashMap<>(); |
| for (String packageName : sBlockedPackagesSharedPreference.getStringSet( |
| SHARED_PREF_BLOCKED_PACKAGES_KEY, new HashSet<>())) { |
| sBlockedPackages.put(packageName, true); |
| } |
| sInitialized = true; |
| } |
| } |
| |
| private static void updateProjectionMap(SQLiteDatabase db, String tableName, |
| Map<String, String> projectionMap) { |
| try(Cursor cursor = db.rawQuery("SELECT * FROM " + tableName + " LIMIT 0", null)) { |
| for (String columnName : cursor.getColumnNames()) { |
| if (!projectionMap.containsKey(columnName)) { |
| projectionMap.put(columnName, tableName + '.' + columnName); |
| } |
| } |
| } |
| } |
| |
| private Map<String, String> createProjectionMapForQuery(String[] projection, |
| Map<String, String> projectionMap) { |
| if (projection == null) { |
| return projectionMap; |
| } |
| Map<String, String> columnProjectionMap = new HashMap<>(); |
| for (String columnName : projection) { |
| String value = projectionMap.get(columnName); |
| if (value != null) { |
| columnProjectionMap.put(columnName, value); |
| } else { |
| // Value NULL will be provided if the requested column does not exist in the |
| // database. |
| value = "NULL AS " + DatabaseUtils.sqlEscapeString(columnName); |
| columnProjectionMap.put(columnName, value); |
| |
| if (needEventLog(columnName)) { |
| android.util.EventLog.writeEvent(0x534e4554, "135269669", -1, ""); |
| } |
| } |
| } |
| return columnProjectionMap; |
| } |
| |
| private boolean needEventLog(String columnName) { |
| for (int i = 0; i < columnName.length(); i++) { |
| char c = columnName.charAt(i); |
| if (!Character.isLetterOrDigit(c) && c != '_') { |
| return true; |
| } |
| } |
| return false; |
| } |
| |
| private void filterContentValues(ContentValues values, Map<String, String> projectionMap) { |
| Iterator<String> iter = values.keySet().iterator(); |
| while (iter.hasNext()) { |
| String columnName = iter.next(); |
| if (!projectionMap.containsKey(columnName)) { |
| iter.remove(); |
| } |
| } |
| } |
| |
| private SqlParams createSqlParams(String operation, Uri uri, String selection, |
| String[] selectionArgs) { |
| int match = sUriMatcher.match(uri); |
| |
| SqliteTokenFinder.findTokens(selection, p -> { |
| if (p.first == SqliteTokenFinder.TYPE_REGULAR |
| && TextUtils.equals(p.second.toUpperCase(Locale.US), "SELECT")) { |
| // only when a keyword is not in quotes or brackets |
| // see https://www.sqlite.org/lang_keywords.html |
| android.util.EventLog.writeEvent(0x534e4554, "135269669", -1, ""); |
| throw new SecurityException( |
| "Subquery is not allowed in selection: " + selection); |
| } |
| }); |
| |
| SqlParams params = new SqlParams(null, selection, selectionArgs); |
| |
| // Control access to EPG data (excluding watched programs) when the caller doesn't have all |
| // access. |
| String prefix = match == MATCH_CHANNEL ? CHANNELS_TABLE + "." : ""; |
| if (!callerHasAccessAllEpgDataPermission() |
| && match != MATCH_WATCHED_PROGRAM && match != MATCH_WATCHED_PROGRAM_ID) { |
| if (!TextUtils.isEmpty(selection)) { |
| throw new SecurityException("Selection not allowed for " + uri); |
| } |
| // Limit the operation only to the data that the calling package owns except for when |
| // the caller tries to read TV listings and has the appropriate permission. |
| if (operation.equals(OP_QUERY) && callerHasReadTvListingsPermission()) { |
| params.setWhere(prefix + BaseTvColumns.COLUMN_PACKAGE_NAME + "=? OR " |
| + Channels.COLUMN_SEARCHABLE + "=?", getCallingPackage_(), "1"); |
| } else { |
| params.setWhere(prefix + BaseTvColumns.COLUMN_PACKAGE_NAME + "=?", |
| getCallingPackage_()); |
| } |
| } |
| String packageName = uri.getQueryParameter(TvContract.PARAM_PACKAGE); |
| if (packageName != null) { |
| params.appendWhere(prefix + BaseTvColumns.COLUMN_PACKAGE_NAME + "=?", packageName); |
| } |
| |
| switch (match) { |
| case MATCH_CHANNEL: |
| String genre = uri.getQueryParameter(TvContract.PARAM_CANONICAL_GENRE); |
| if (genre == null) { |
| params.setTables(CHANNELS_TABLE); |
| } else { |
| if (!operation.equals(OP_QUERY)) { |
| throw new SecurityException(capitalize(operation) |
| + " not allowed for " + uri); |
| } |
| if (!Genres.isCanonical(genre)) { |
| throw new IllegalArgumentException("Not a canonical genre : " + genre); |
| } |
| params.setTables(CHANNELS_TABLE_INNER_JOIN_PROGRAMS_TABLE); |
| String curTime = String.valueOf(System.currentTimeMillis()); |
| params.appendWhere("LIKE(?, " + Programs.COLUMN_CANONICAL_GENRE + ") AND " |
| + Programs.COLUMN_START_TIME_UTC_MILLIS + "<=? AND " |
| + Programs.COLUMN_END_TIME_UTC_MILLIS + ">=?", |
| "%" + genre + "%", curTime, curTime); |
| } |
| String inputId = uri.getQueryParameter(TvContract.PARAM_INPUT); |
| if (inputId != null) { |
| params.appendWhere(Channels.COLUMN_INPUT_ID + "=?", inputId); |
| } |
| boolean browsableOnly = uri.getBooleanQueryParameter( |
| TvContract.PARAM_BROWSABLE_ONLY, false); |
| if (browsableOnly) { |
| params.appendWhere(Channels.COLUMN_BROWSABLE + "=1"); |
| } |
| String preview = uri.getQueryParameter(TvContract.PARAM_PREVIEW); |
| if (preview != null) { |
| String previewSelection = Channels.COLUMN_TYPE |
| + (preview.equals(String.valueOf(true)) ? "=?" : "!=?"); |
| params.appendWhere(previewSelection, Channels.TYPE_PREVIEW); |
| } |
| break; |
| case MATCH_CHANNEL_ID: |
| params.setTables(CHANNELS_TABLE); |
| params.appendWhere(Channels._ID + "=?", uri.getLastPathSegment()); |
| break; |
| case MATCH_PROGRAM: |
| params.setTables(PROGRAMS_TABLE); |
| String paramChannelId = uri.getQueryParameter(TvContract.PARAM_CHANNEL); |
| if (paramChannelId != null) { |
| String channelId = String.valueOf(Long.parseLong(paramChannelId)); |
| params.appendWhere(Programs.COLUMN_CHANNEL_ID + "=?", channelId); |
| } |
| String paramStartTime = uri.getQueryParameter(TvContract.PARAM_START_TIME); |
| String paramEndTime = uri.getQueryParameter(TvContract.PARAM_END_TIME); |
| if (paramStartTime != null && paramEndTime != null) { |
| String startTime = String.valueOf(Long.parseLong(paramStartTime)); |
| String endTime = String.valueOf(Long.parseLong(paramEndTime)); |
| params.appendWhere(Programs.COLUMN_START_TIME_UTC_MILLIS + "<=? AND " |
| + Programs.COLUMN_END_TIME_UTC_MILLIS + ">=? AND ?<=?", endTime, |
| startTime, startTime, endTime); |
| } |
| break; |
| case MATCH_PROGRAM_ID: |
| params.setTables(PROGRAMS_TABLE); |
| params.appendWhere(Programs._ID + "=?", uri.getLastPathSegment()); |
| break; |
| case MATCH_WATCHED_PROGRAM: |
| if (!callerHasAccessWatchedProgramsPermission()) { |
| throw new SecurityException("Access not allowed for " + uri); |
| } |
| params.setTables(WATCHED_PROGRAMS_TABLE); |
| params.appendWhere(WATCHED_PROGRAMS_COLUMN_CONSOLIDATED + "=?", "1"); |
| break; |
| case MATCH_WATCHED_PROGRAM_ID: |
| if (!callerHasAccessWatchedProgramsPermission()) { |
| throw new SecurityException("Access not allowed for " + uri); |
| } |
| params.setTables(WATCHED_PROGRAMS_TABLE); |
| params.appendWhere(WatchedPrograms._ID + "=?", uri.getLastPathSegment()); |
| params.appendWhere(WATCHED_PROGRAMS_COLUMN_CONSOLIDATED + "=?", "1"); |
| break; |
| case MATCH_RECORDED_PROGRAM_ID: |
| params.appendWhere(RecordedPrograms._ID + "=?", uri.getLastPathSegment()); |
| // fall-through |
| case MATCH_RECORDED_PROGRAM: |
| params.setTables(RECORDED_PROGRAMS_TABLE); |
| paramChannelId = uri.getQueryParameter(TvContract.PARAM_CHANNEL); |
| if (paramChannelId != null) { |
| String channelId = String.valueOf(Long.parseLong(paramChannelId)); |
| params.appendWhere(Programs.COLUMN_CHANNEL_ID + "=?", channelId); |
| } |
| break; |
| case MATCH_PREVIEW_PROGRAM_ID: |
| params.appendWhere(PreviewPrograms._ID + "=?", uri.getLastPathSegment()); |
| // fall-through |
| case MATCH_PREVIEW_PROGRAM: |
| params.setTables(PREVIEW_PROGRAMS_TABLE); |
| paramChannelId = uri.getQueryParameter(TvContract.PARAM_CHANNEL); |
| if (paramChannelId != null) { |
| String channelId = String.valueOf(Long.parseLong(paramChannelId)); |
| params.appendWhere(PreviewPrograms.COLUMN_CHANNEL_ID + "=?", channelId); |
| } |
| break; |
| case MATCH_WATCH_NEXT_PROGRAM_ID: |
| params.appendWhere(WatchNextPrograms._ID + "=?", uri.getLastPathSegment()); |
| // fall-through |
| case MATCH_WATCH_NEXT_PROGRAM: |
| params.setTables(WATCH_NEXT_PROGRAMS_TABLE); |
| break; |
| case MATCH_CHANNEL_ID_LOGO: |
| if (operation.equals(OP_DELETE)) { |
| params.setTables(CHANNELS_TABLE); |
| params.appendWhere(Channels._ID + "=?", uri.getPathSegments().get(1)); |
| break; |
| } |
| // fall-through |
| case MATCH_PASSTHROUGH_ID: |
| throw new UnsupportedOperationException(operation + " not permmitted on " + uri); |
| default: |
| throw new IllegalArgumentException("Unknown URI " + uri); |
| } |
| return params; |
| } |
| |
| private static String generateDefaultClause(String dataType, String defaultValue) |
| throws IllegalArgumentException { |
| String defaultValueString = " DEFAULT "; |
| switch (dataType.toLowerCase()) { |
| case "integer": |
| return defaultValueString + Integer.parseInt(defaultValue); |
| case "real": |
| return defaultValueString + Double.parseDouble(defaultValue); |
| case "text": |
| case "blob": |
| return defaultValueString + DatabaseUtils.sqlEscapeString(defaultValue); |
| default: |
| throw new IllegalArgumentException("Illegal data type \"" + dataType |
| + "\" with default value: " + defaultValue); |
| } |
| } |
| |
| private static String capitalize(String str) { |
| return Character.toUpperCase(str.charAt(0)) + str.substring(1); |
| } |
| |
| @SuppressLint("DefaultLocale") |
| private void checkAndConvertGenre(ContentValues values) { |
| String canonicalGenres = values.getAsString(Programs.COLUMN_CANONICAL_GENRE); |
| |
| if (!TextUtils.isEmpty(canonicalGenres)) { |
| // Check if the canonical genres are valid. If not, clear them. |
| String[] genres = Genres.decode(canonicalGenres); |
| for (String genre : genres) { |
| if (!Genres.isCanonical(genre)) { |
| values.putNull(Programs.COLUMN_CANONICAL_GENRE); |
| canonicalGenres = null; |
| break; |
| } |
| } |
| } |
| |
| if (TextUtils.isEmpty(canonicalGenres)) { |
| // If the canonical genre is not set, try to map the broadcast genre to the canonical |
| // genre. |
| String broadcastGenres = values.getAsString(Programs.COLUMN_BROADCAST_GENRE); |
| if (!TextUtils.isEmpty(broadcastGenres)) { |
| Set<String> genreSet = new HashSet<>(); |
| String[] genres = Genres.decode(broadcastGenres); |
| for (String genre : genres) { |
| String canonicalGenre = sGenreMap.get(genre.toUpperCase()); |
| if (Genres.isCanonical(canonicalGenre)) { |
| genreSet.add(canonicalGenre); |
| } |
| } |
| if (genreSet.size() > 0) { |
| values.put(Programs.COLUMN_CANONICAL_GENRE, |
| Genres.encode(genreSet.toArray(new String[genreSet.size()]))); |
| } |
| } |
| } |
| } |
| |
| private void checkAndConvertDeprecatedColumns(ContentValues values) { |
| if (values.containsKey(Programs.COLUMN_SEASON_NUMBER)) { |
| if (!values.containsKey(Programs.COLUMN_SEASON_DISPLAY_NUMBER)) { |
| values.put(Programs.COLUMN_SEASON_DISPLAY_NUMBER, values.getAsInteger( |
| Programs.COLUMN_SEASON_NUMBER)); |
| } |
| values.remove(Programs.COLUMN_SEASON_NUMBER); |
| } |
| if (values.containsKey(Programs.COLUMN_EPISODE_NUMBER)) { |
| if (!values.containsKey(Programs.COLUMN_EPISODE_DISPLAY_NUMBER)) { |
| values.put(Programs.COLUMN_EPISODE_DISPLAY_NUMBER, values.getAsInteger( |
| Programs.COLUMN_EPISODE_NUMBER)); |
| } |
| values.remove(Programs.COLUMN_EPISODE_NUMBER); |
| } |
| } |
| |
| // We might have more than one thread trying to make its way through applyBatch() so the |
| // notification coalescing needs to be thread-local to work correctly. |
| private final ThreadLocal<Set<Uri>> mTLBatchNotifications = new ThreadLocal<>(); |
| |
| private Set<Uri> getBatchNotificationsSet() { |
| return mTLBatchNotifications.get(); |
| } |
| |
| private void setBatchNotificationsSet(Set<Uri> batchNotifications) { |
| mTLBatchNotifications.set(batchNotifications); |
| } |
| |
| @Override |
| public ContentProviderResult[] applyBatch(ArrayList<ContentProviderOperation> operations) |
| throws OperationApplicationException { |
| setBatchNotificationsSet(new HashSet<Uri>()); |
| Context context = getContext(); |
| SQLiteDatabase db = mOpenHelper.getWritableDatabase(); |
| db.beginTransaction(); |
| try { |
| ContentProviderResult[] results = super.applyBatch(operations); |
| db.setTransactionSuccessful(); |
| return results; |
| } finally { |
| db.endTransaction(); |
| final Set<Uri> notifications = getBatchNotificationsSet(); |
| setBatchNotificationsSet(null); |
| for (final Uri uri : notifications) { |
| context.getContentResolver().notifyChange(uri, null); |
| } |
| } |
| } |
| |
| @Override |
| public int bulkInsert(Uri uri, ContentValues[] values) { |
| setBatchNotificationsSet(new HashSet<Uri>()); |
| Context context = getContext(); |
| SQLiteDatabase db = mOpenHelper.getWritableDatabase(); |
| db.beginTransaction(); |
| try { |
| int result = super.bulkInsert(uri, values); |
| db.setTransactionSuccessful(); |
| return result; |
| } finally { |
| db.endTransaction(); |
| final Set<Uri> notifications = getBatchNotificationsSet(); |
| setBatchNotificationsSet(null); |
| for (final Uri notificationUri : notifications) { |
| context.getContentResolver().notifyChange(notificationUri, null); |
| } |
| } |
| } |
| |
| private void notifyChange(Uri uri) { |
| final Set<Uri> batchNotifications = getBatchNotificationsSet(); |
| if (batchNotifications != null) { |
| batchNotifications.add(uri); |
| } else { |
| getContext().getContentResolver().notifyChange(uri, null); |
| } |
| } |
| |
| private boolean callerHasReadTvListingsPermission() { |
| return getContext().checkCallingOrSelfPermission(PERMISSION_READ_TV_LISTINGS) |
| == PackageManager.PERMISSION_GRANTED; |
| } |
| |
| private boolean callerHasAccessAllEpgDataPermission() { |
| return getContext().checkCallingOrSelfPermission(PERMISSION_ACCESS_ALL_EPG_DATA) |
| == PackageManager.PERMISSION_GRANTED; |
| } |
| |
| private boolean callerHasAccessWatchedProgramsPermission() { |
| return getContext().checkCallingOrSelfPermission(PERMISSION_ACCESS_WATCHED_PROGRAMS) |
| == PackageManager.PERMISSION_GRANTED; |
| } |
| |
| private boolean callerHasModifyParentalControlsPermission() { |
| return getContext().checkCallingOrSelfPermission( |
| android.Manifest.permission.MODIFY_PARENTAL_CONTROLS) |
| == PackageManager.PERMISSION_GRANTED; |
| } |
| |
| private void blockIllegalAccessToIdAndPackageName(Uri uri, ContentValues values) { |
| if (values.containsKey(BaseColumns._ID)) { |
| int match = sUriMatcher.match(uri); |
| switch (match) { |
| case MATCH_CHANNEL_ID: |
| case MATCH_PROGRAM_ID: |
| case MATCH_PREVIEW_PROGRAM_ID: |
| case MATCH_RECORDED_PROGRAM_ID: |
| case MATCH_WATCH_NEXT_PROGRAM_ID: |
| case MATCH_WATCHED_PROGRAM_ID: |
| if (TextUtils.equals(values.getAsString(BaseColumns._ID), |
| uri.getLastPathSegment())) { |
| break; |
| } |
| default: |
| throw new IllegalArgumentException("Not allowed to change ID."); |
| } |
| } |
| if (values.containsKey(BaseTvColumns.COLUMN_PACKAGE_NAME) |
| && !callerHasAccessAllEpgDataPermission() && !TextUtils.equals(values.getAsString( |
| BaseTvColumns.COLUMN_PACKAGE_NAME), getCallingPackage_())) { |
| throw new SecurityException("Not allowed to change package name."); |
| } |
| } |
| |
| private void blockIllegalAccessToChannelsSystemColumns(ContentValues values) { |
| if (values.containsKey(Channels.COLUMN_LOCKED) |
| && !callerHasModifyParentalControlsPermission()) { |
| throw new SecurityException("Not allowed to access Channels.COLUMN_LOCKED"); |
| } |
| Boolean hasAccessAllEpgDataPermission = null; |
| if (values.containsKey(Channels.COLUMN_BROWSABLE)) { |
| hasAccessAllEpgDataPermission = callerHasAccessAllEpgDataPermission(); |
| if (!hasAccessAllEpgDataPermission) { |
| throw new SecurityException("Not allowed to access Channels.COLUMN_BROWSABLE"); |
| } |
| } |
| } |
| |
| private void blockIllegalAccessToPreviewProgramsSystemColumns(ContentValues values) { |
| if (values.containsKey(PreviewPrograms.COLUMN_BROWSABLE) |
| && !callerHasAccessAllEpgDataPermission()) { |
| throw new SecurityException("Not allowed to access Programs.COLUMN_BROWSABLE"); |
| } |
| } |
| |
| private void blockIllegalAccessFromBlockedPackage() { |
| String callingPackageName = getCallingPackage_(); |
| if (sBlockedPackages.containsKey(callingPackageName)) { |
| throw new SecurityException( |
| "Not allowed to access " + TvContract.AUTHORITY + ", " |
| + callingPackageName + " is blocked"); |
| } |
| } |
| |
| private boolean disallowModifyChannelType(ContentValues values, SqlParams params) { |
| if (values.containsKey(Channels.COLUMN_TYPE)) { |
| params.appendWhere(Channels.COLUMN_TYPE + "=?", |
| values.getAsString(Channels.COLUMN_TYPE)); |
| return true; |
| } |
| return false; |
| } |
| |
| private boolean disallowModifyChannelId(ContentValues values, SqlParams params) { |
| if (values.containsKey(PreviewPrograms.COLUMN_CHANNEL_ID)) { |
| params.appendWhere(PreviewPrograms.COLUMN_CHANNEL_ID + "=?", |
| values.getAsString(PreviewPrograms.COLUMN_CHANNEL_ID)); |
| return true; |
| } |
| return false; |
| } |
| |
| @Override |
| public ParcelFileDescriptor openFile(Uri uri, String mode) throws FileNotFoundException { |
| switch (sUriMatcher.match(uri)) { |
| case MATCH_CHANNEL_ID_LOGO: |
| return openLogoFile(uri, mode); |
| default: |
| throw new FileNotFoundException(uri.toString()); |
| } |
| } |
| |
| private ParcelFileDescriptor openLogoFile(Uri uri, String mode) throws FileNotFoundException { |
| long channelId = Long.parseLong(uri.getPathSegments().get(1)); |
| |
| SqlParams params = new SqlParams(CHANNELS_TABLE, Channels._ID + "=?", |
| String.valueOf(channelId)); |
| if (!callerHasAccessAllEpgDataPermission()) { |
| if (callerHasReadTvListingsPermission()) { |
| params.appendWhere(Channels.COLUMN_PACKAGE_NAME + "=? OR " |
| + Channels.COLUMN_SEARCHABLE + "=?", getCallingPackage_(), "1"); |
| } else { |
| params.appendWhere(Channels.COLUMN_PACKAGE_NAME + "=?", getCallingPackage_()); |
| } |
| } |
| |
| SQLiteQueryBuilder queryBuilder = new SQLiteQueryBuilder(); |
| queryBuilder.setTables(params.getTables()); |
| |
| // We don't write the database here. |
| SQLiteDatabase db = mOpenHelper.getReadableDatabase(); |
| if (mode.equals("r")) { |
| String sql = queryBuilder.buildQuery(new String[] { CHANNELS_COLUMN_LOGO }, |
| params.getSelection(), null, null, null, null); |
| ParcelFileDescriptor fd = DatabaseUtils.blobFileDescriptorForQuery( |
| db, sql, params.getSelectionArgs()); |
| if (fd == null) { |
| throw new FileNotFoundException(uri.toString()); |
| } |
| return fd; |
| } else { |
| try (Cursor cursor = queryBuilder.query(db, new String[] { Channels._ID }, |
| params.getSelection(), params.getSelectionArgs(), null, null, null)) { |
| if (cursor.getCount() < 1) { |
| // Fails early if corresponding channel does not exist. |
| // PipeMonitor may still fail to update DB later. |
| throw new FileNotFoundException(uri.toString()); |
| } |
| } |
| |
| try { |
| ParcelFileDescriptor[] pipeFds = ParcelFileDescriptor.createPipe(); |
| PipeMonitor pipeMonitor = new PipeMonitor(pipeFds[0], channelId, params); |
| pipeMonitor.executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR); |
| return pipeFds[1]; |
| } catch (IOException ioe) { |
| FileNotFoundException fne = new FileNotFoundException(uri.toString()); |
| fne.initCause(ioe); |
| throw fne; |
| } |
| } |
| } |
| |
| /** |
| * Validates the sort order based on the given field set. |
| * |
| * @throws IllegalArgumentException if there is any unknown field. |
| */ |
| @SuppressLint("DefaultLocale") |
| private static void validateSortOrder(String sortOrder, Set<String> possibleFields) { |
| if (TextUtils.isEmpty(sortOrder) || possibleFields.isEmpty()) { |
| return; |
| } |
| String[] orders = sortOrder.split(","); |
| for (String order : orders) { |
| String field = order.replaceAll("\\s+", " ").trim().toLowerCase().replace(" asc", "") |
| .replace(" desc", ""); |
| if (!possibleFields.contains(field)) { |
| throw new IllegalArgumentException("Illegal field in sort order " + order); |
| } |
| } |
| } |
| |
| private class PipeMonitor extends AsyncTask<Void, Void, Void> { |
| private final ParcelFileDescriptor mPfd; |
| private final long mChannelId; |
| private final SqlParams mParams; |
| |
| private PipeMonitor(ParcelFileDescriptor pfd, long channelId, SqlParams params) { |
| mPfd = pfd; |
| mChannelId = channelId; |
| mParams = params; |
| } |
| |
| @Override |
| protected Void doInBackground(Void... params) { |
| AutoCloseInputStream is = new AutoCloseInputStream(mPfd); |
| ByteArrayOutputStream baos = null; |
| int count = 0; |
| try { |
| Bitmap bitmap = BitmapFactory.decodeStream(is); |
| if (bitmap == null) { |
| Log.e(TAG, "Failed to decode logo image for channel ID " + mChannelId); |
| return null; |
| } |
| |
| float scaleFactor = Math.min(1f, ((float) MAX_LOGO_IMAGE_SIZE) / |
| Math.max(bitmap.getWidth(), bitmap.getHeight())); |
| if (scaleFactor < 1f) { |
| bitmap = Bitmap.createScaledBitmap(bitmap, |
| (int) (bitmap.getWidth() * scaleFactor), |
| (int) (bitmap.getHeight() * scaleFactor), false); |
| } |
| |
| baos = new ByteArrayOutputStream(); |
| bitmap.compress(Bitmap.CompressFormat.PNG, 100, baos); |
| byte[] bytes = baos.toByteArray(); |
| |
| ContentValues values = new ContentValues(); |
| values.put(CHANNELS_COLUMN_LOGO, bytes); |
| |
| SQLiteDatabase db = mOpenHelper.getWritableDatabase(); |
| count = db.update(mParams.getTables(), values, mParams.getSelection(), |
| mParams.getSelectionArgs()); |
| if (count > 0) { |
| Uri uri = TvContract.buildChannelLogoUri(mChannelId); |
| notifyChange(uri); |
| } |
| } finally { |
| if (count == 0) { |
| try { |
| mPfd.closeWithError("Failed to write logo for channel ID " + mChannelId); |
| } catch (IOException ioe) { |
| Log.e(TAG, "Failed to close pipe", ioe); |
| } |
| } |
| IoUtils.closeQuietly(baos); |
| IoUtils.closeQuietly(is); |
| } |
| return null; |
| } |
| } |
| |
| private void deleteUnconsolidatedWatchedProgramsRows() { |
| SQLiteDatabase db = mOpenHelper.getWritableDatabase(); |
| db.delete(WATCHED_PROGRAMS_TABLE, WATCHED_PROGRAMS_COLUMN_CONSOLIDATED + "=0", null); |
| } |
| |
| @SuppressLint("HandlerLeak") |
| private final class WatchLogHandler extends Handler { |
| private static final int MSG_CONSOLIDATE = 1; |
| private static final int MSG_TRY_CONSOLIDATE_ALL = 2; |
| |
| @Override |
| public void handleMessage(Message msg) { |
| switch (msg.what) { |
| case MSG_CONSOLIDATE: { |
| SomeArgs args = (SomeArgs) msg.obj; |
| String sessionToken = (String) args.arg1; |
| long watchEndTime = (long) args.arg2; |
| onConsolidate(sessionToken, watchEndTime); |
| args.recycle(); |
| return; |
| } |
| case MSG_TRY_CONSOLIDATE_ALL: { |
| onTryConsolidateAll(); |
| return; |
| } |
| default: { |
| Log.w(TAG, "Unhandled message code: " + msg.what); |
| return; |
| } |
| } |
| } |
| |
| // Consolidates all WatchedPrograms rows for a given session with watch end time information |
| // of the most recent log entry. After this method is called, it is guaranteed that there |
| // remain consolidated rows only for that session. |
| private void onConsolidate(String sessionToken, long watchEndTime) { |
| if (DEBUG) { |
| Log.d(TAG, "onConsolidate(sessionToken=" + sessionToken + ", watchEndTime=" |
| + watchEndTime + ")"); |
| } |
| |
| SQLiteQueryBuilder queryBuilder = new SQLiteQueryBuilder(); |
| queryBuilder.setTables(WATCHED_PROGRAMS_TABLE); |
| SQLiteDatabase db = mOpenHelper.getReadableDatabase(); |
| |
| // Pick up the last row with the same session token. |
| String[] projection = { |
| WatchedPrograms._ID, |
| WatchedPrograms.COLUMN_WATCH_START_TIME_UTC_MILLIS, |
| WatchedPrograms.COLUMN_CHANNEL_ID |
| }; |
| String selection = WATCHED_PROGRAMS_COLUMN_CONSOLIDATED + "=? AND " |
| + WatchedPrograms.COLUMN_INTERNAL_SESSION_TOKEN + "=?"; |
| String[] selectionArgs = { |
| "0", |
| sessionToken |
| }; |
| String sortOrder = WatchedPrograms.COLUMN_WATCH_START_TIME_UTC_MILLIS + " DESC"; |
| |
| int consolidatedRowCount = 0; |
| try (Cursor cursor = queryBuilder.query(db, projection, selection, selectionArgs, null, |
| null, sortOrder)) { |
| long oldWatchStartTime = watchEndTime; |
| while (cursor != null && cursor.moveToNext()) { |
| long id = cursor.getLong(0); |
| long watchStartTime = cursor.getLong(1); |
| long channelId = cursor.getLong(2); |
| consolidatedRowCount += consolidateRow(id, watchStartTime, oldWatchStartTime, |
| channelId, false); |
| oldWatchStartTime = watchStartTime; |
| } |
| } |
| if (consolidatedRowCount > 0) { |
| deleteUnsearchable(); |
| } |
| } |
| |
| // Tries to consolidate all WatchedPrograms rows regardless of the session. After this |
| // method is called, it is guaranteed that we have at most one unconsolidated log entry per |
| // session that represents the user's ongoing watch activity. |
| // Also, this method automatically schedules the next consolidation if there still remains |
| // an unconsolidated entry. |
| private void onTryConsolidateAll() { |
| if (DEBUG) { |
| Log.d(TAG, "onTryConsolidateAll()"); |
| } |
| |
| SQLiteQueryBuilder queryBuilder = new SQLiteQueryBuilder(); |
| queryBuilder.setTables(WATCHED_PROGRAMS_TABLE); |
| SQLiteDatabase db = mOpenHelper.getReadableDatabase(); |
| |
| // Pick up all unconsolidated rows grouped by session. The most recent log entry goes on |
| // top. |
| String[] projection = { |
| WatchedPrograms._ID, |
| WatchedPrograms.COLUMN_WATCH_START_TIME_UTC_MILLIS, |
| WatchedPrograms.COLUMN_CHANNEL_ID, |
| WatchedPrograms.COLUMN_INTERNAL_SESSION_TOKEN |
| }; |
| String selection = WATCHED_PROGRAMS_COLUMN_CONSOLIDATED + "=0"; |
| String sortOrder = WatchedPrograms.COLUMN_INTERNAL_SESSION_TOKEN + " DESC," |
| + WatchedPrograms.COLUMN_WATCH_START_TIME_UTC_MILLIS + " DESC"; |
| |
| int consolidatedRowCount = 0; |
| try (Cursor cursor = queryBuilder.query(db, projection, selection, null, null, null, |
| sortOrder)) { |
| long oldWatchStartTime = 0; |
| String oldSessionToken = null; |
| while (cursor != null && cursor.moveToNext()) { |
| long id = cursor.getLong(0); |
| long watchStartTime = cursor.getLong(1); |
| long channelId = cursor.getLong(2); |
| String sessionToken = cursor.getString(3); |
| |
| if (!sessionToken.equals(oldSessionToken)) { |
| // The most recent log entry for the current session, which may be still |
| // active. Just go through a dry run with the current time to see if this |
| // entry can be split into multiple rows. |
| consolidatedRowCount += consolidateRow(id, watchStartTime, |
| System.currentTimeMillis(), channelId, true); |
| oldSessionToken = sessionToken; |
| } else { |
| // The later entries after the most recent one all fall into here. We now |
| // know that this watch activity ended exactly at the same time when the |
| // next activity started. |
| consolidatedRowCount += consolidateRow(id, watchStartTime, |
| oldWatchStartTime, channelId, false); |
| } |
| oldWatchStartTime = watchStartTime; |
| } |
| } |
| if (consolidatedRowCount > 0) { |
| deleteUnsearchable(); |
| } |
| scheduleConsolidationIfNeeded(); |
| } |
| |
| // Consolidates a WatchedPrograms row. |
| // A row is 'consolidated' if and only if the following information is complete: |
| // 1. WatchedPrograms.COLUMN_CHANNEL_ID |
| // 2. WatchedPrograms.COLUMN_WATCH_START_TIME_UTC_MILLIS |
| // 3. WatchedPrograms.COLUMN_WATCH_END_TIME_UTC_MILLIS |
| // where COLUMN_WATCH_START_TIME_UTC_MILLIS <= COLUMN_WATCH_END_TIME_UTC_MILLIS. |
| // This is the minimal but useful enough set of information to comprise the user's watch |
| // history. (The program data are considered optional although we do try to fill them while |
| // consolidating the row.) It is guaranteed that the target row is either consolidated or |
| // deleted after this method is called. |
| // Set {@code dryRun} to {@code true} if you think it's necessary to split the row without |
| // consolidating the most recent row because the user stayed on the same channel for a very |
| // long time. |
| // This method returns the number of consolidated rows, which can be 0 or more. |
| private int consolidateRow( |
| long id, long watchStartTime, long watchEndTime, long channelId, boolean dryRun) { |
| if (DEBUG) { |
| Log.d(TAG, "consolidateRow(id=" + id + ", watchStartTime=" + watchStartTime |
| + ", watchEndTime=" + watchEndTime + ", channelId=" + channelId |
| + ", dryRun=" + dryRun + ")"); |
| } |
| |
| SQLiteDatabase db = mOpenHelper.getWritableDatabase(); |
| |
| if (watchStartTime > watchEndTime) { |
| Log.e(TAG, "watchEndTime cannot be less than watchStartTime"); |
| db.delete(WATCHED_PROGRAMS_TABLE, WatchedPrograms._ID + "=" + String.valueOf(id), |
| null); |
| return 0; |
| } |
| |
| ContentValues values = getProgramValues(channelId, watchStartTime); |
| Long endTime = values.getAsLong(WatchedPrograms.COLUMN_END_TIME_UTC_MILLIS); |
| boolean needsToSplit = endTime != null && endTime < watchEndTime; |
| |
| values.put(WatchedPrograms.COLUMN_WATCH_START_TIME_UTC_MILLIS, |
| String.valueOf(watchStartTime)); |
| if (!dryRun || needsToSplit) { |
| values.put(WatchedPrograms.COLUMN_WATCH_END_TIME_UTC_MILLIS, |
| String.valueOf(needsToSplit ? endTime : watchEndTime)); |
| values.put(WATCHED_PROGRAMS_COLUMN_CONSOLIDATED, "1"); |
| db.update(WATCHED_PROGRAMS_TABLE, values, |
| WatchedPrograms._ID + "=" + String.valueOf(id), null); |
| // Treat the watched program is inserted when WATCHED_PROGRAMS_COLUMN_CONSOLIDATED |
| // becomes 1. |
| notifyChange(TvContract.buildWatchedProgramUri(id)); |
| } else { |
| db.update(WATCHED_PROGRAMS_TABLE, values, |
| WatchedPrograms._ID + "=" + String.valueOf(id), null); |
| } |
| int count = dryRun ? 0 : 1; |
| if (needsToSplit) { |
| // This means that the program ended before the user stops watching the current |
| // channel. In this case we duplicate the log entry as many as the number of |
| // programs watched on the same channel. Here the end time of the current program |
| // becomes the new watch start time of the next program. |
| long duplicatedId = duplicateRow(id); |
| if (duplicatedId > 0) { |
| count += consolidateRow(duplicatedId, endTime, watchEndTime, channelId, dryRun); |
| } |
| } |
| return count; |
| } |
| |
| // Deletes the log entries from unsearchable channels. Note that only consolidated log |
| // entries are safe to delete. |
| private void deleteUnsearchable() { |
| SQLiteDatabase db = mOpenHelper.getWritableDatabase(); |
| String deleteWhere = WATCHED_PROGRAMS_COLUMN_CONSOLIDATED + "=1 AND " |
| + WatchedPrograms.COLUMN_CHANNEL_ID + " IN (SELECT " + Channels._ID |
| + " FROM " + CHANNELS_TABLE + " WHERE " + Channels.COLUMN_SEARCHABLE + "=0)"; |
| db.delete(WATCHED_PROGRAMS_TABLE, deleteWhere, null); |
| } |
| |
| private void scheduleConsolidationIfNeeded() { |
| if (DEBUG) { |
| Log.d(TAG, "scheduleConsolidationIfNeeded()"); |
| } |
| SQLiteQueryBuilder queryBuilder = new SQLiteQueryBuilder(); |
| queryBuilder.setTables(WATCHED_PROGRAMS_TABLE); |
| SQLiteDatabase db = mOpenHelper.getReadableDatabase(); |
| |
| // Pick up all unconsolidated rows. |
| String[] projection = { |
| WatchedPrograms.COLUMN_WATCH_START_TIME_UTC_MILLIS, |
| WatchedPrograms.COLUMN_CHANNEL_ID, |
| }; |
| String selection = WATCHED_PROGRAMS_COLUMN_CONSOLIDATED + "=0"; |
| |
| try (Cursor cursor = queryBuilder.query(db, projection, selection, null, null, null, |
| null)) { |
| // Find the earliest time that any of the currently watching programs ends and |
| // schedule the next consolidation at that time. |
| long minEndTime = Long.MAX_VALUE; |
| while (cursor != null && cursor.moveToNext()) { |
| long watchStartTime = cursor.getLong(0); |
| long channelId = cursor.getLong(1); |
| ContentValues values = getProgramValues(channelId, watchStartTime); |
| Long endTime = values.getAsLong(WatchedPrograms.COLUMN_END_TIME_UTC_MILLIS); |
| |
| if (endTime != null && endTime < minEndTime |
| && endTime > System.currentTimeMillis()) { |
| minEndTime = endTime; |
| } |
| } |
| if (minEndTime != Long.MAX_VALUE) { |
| sendEmptyMessageAtTime(MSG_TRY_CONSOLIDATE_ALL, minEndTime); |
| if (DEBUG) { |
| CharSequence minEndTimeStr = DateUtils.getRelativeTimeSpanString( |
| minEndTime, System.currentTimeMillis(), DateUtils.SECOND_IN_MILLIS); |
| Log.d(TAG, "onTryConsolidateAll() scheduled " + minEndTimeStr); |
| } |
| } |
| } |
| } |
| |
| // Returns non-null ContentValues of the program data that the user watched on the channel |
| // {@code channelId} at the time {@code time}. |
| private ContentValues getProgramValues(long channelId, long time) { |
| SQLiteQueryBuilder queryBuilder = new SQLiteQueryBuilder(); |
| queryBuilder.setTables(PROGRAMS_TABLE); |
| SQLiteDatabase db = mOpenHelper.getReadableDatabase(); |
| |
| String[] projection = { |
| Programs.COLUMN_TITLE, |
| Programs.COLUMN_START_TIME_UTC_MILLIS, |
| Programs.COLUMN_END_TIME_UTC_MILLIS, |
| Programs.COLUMN_SHORT_DESCRIPTION |
| }; |
| String selection = Programs.COLUMN_CHANNEL_ID + "=? AND " |
| + Programs.COLUMN_START_TIME_UTC_MILLIS + "<=? AND " |
| + Programs.COLUMN_END_TIME_UTC_MILLIS + ">?"; |
| String[] selectionArgs = { |
| String.valueOf(channelId), |
| String.valueOf(time), |
| String.valueOf(time) |
| }; |
| String sortOrder = Programs.COLUMN_START_TIME_UTC_MILLIS + " ASC"; |
| |
| try (Cursor cursor = queryBuilder.query(db, projection, selection, selectionArgs, null, |
| null, sortOrder)) { |
| ContentValues values = new ContentValues(); |
| if (cursor != null && cursor.moveToNext()) { |
| values.put(WatchedPrograms.COLUMN_TITLE, cursor.getString(0)); |
| values.put(WatchedPrograms.COLUMN_START_TIME_UTC_MILLIS, cursor.getLong(1)); |
| values.put(WatchedPrograms.COLUMN_END_TIME_UTC_MILLIS, cursor.getLong(2)); |
| values.put(WatchedPrograms.COLUMN_DESCRIPTION, cursor.getString(3)); |
| } |
| return values; |
| } |
| } |
| |
| // Duplicates the WatchedPrograms row with a given ID and returns the ID of the duplicated |
| // row. Returns -1 if failed. |
| private long duplicateRow(long id) { |
| if (DEBUG) { |
| Log.d(TAG, "duplicateRow(" + id + ")"); |
| } |
| |
| SQLiteQueryBuilder queryBuilder = new SQLiteQueryBuilder(); |
| queryBuilder.setTables(WATCHED_PROGRAMS_TABLE); |
| SQLiteDatabase db = mOpenHelper.getWritableDatabase(); |
| |
| String[] projection = { |
| WatchedPrograms.COLUMN_PACKAGE_NAME, |
| WatchedPrograms.COLUMN_CHANNEL_ID, |
| WatchedPrograms.COLUMN_INTERNAL_SESSION_TOKEN |
| }; |
| String selection = WatchedPrograms._ID + "=" + String.valueOf(id); |
| |
| try (Cursor cursor = queryBuilder.query(db, projection, selection, null, null, null, |
| null)) { |
| long rowId = -1; |
| if (cursor != null && cursor.moveToNext()) { |
| ContentValues values = new ContentValues(); |
| values.put(WatchedPrograms.COLUMN_PACKAGE_NAME, cursor.getString(0)); |
| values.put(WatchedPrograms.COLUMN_CHANNEL_ID, cursor.getLong(1)); |
| values.put(WatchedPrograms.COLUMN_INTERNAL_SESSION_TOKEN, cursor.getString(2)); |
| rowId = db.insert(WATCHED_PROGRAMS_TABLE, null, values); |
| } |
| return rowId; |
| } |
| } |
| } |
| } |
