/* * Copyright (C) 2017 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.tv.testing.fakes; import android.annotation.SuppressLint; import android.content.ContentProvider; import android.content.ContentProviderOperation; import android.content.ContentProviderResult; import android.content.ContentUris; import android.content.ContentValues; import android.content.Context; 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.net.Uri; import android.os.AsyncTask; import android.os.Bundle; import android.os.ParcelFileDescriptor; import android.os.ParcelFileDescriptor.AutoCloseInputStream; import android.preference.PreferenceManager; import android.provider.BaseColumns; import android.support.annotation.VisibleForTesting; import android.text.TextUtils; import android.util.Log; import androidx.tvprovider.media.tv.TvContractCompat; import androidx.tvprovider.media.tv.TvContractCompat.BaseTvColumns; import androidx.tvprovider.media.tv.TvContractCompat.Channels; import androidx.tvprovider.media.tv.TvContractCompat.PreviewPrograms; import androidx.tvprovider.media.tv.TvContractCompat.Programs; import androidx.tvprovider.media.tv.TvContractCompat.Programs.Genres; import androidx.tvprovider.media.tv.TvContractCompat.RecordedPrograms; import androidx.tvprovider.media.tv.TvContractCompat.WatchNextPrograms; import com.android.tv.common.util.sql.SqlParams; 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; /** * Fake TV content provider suitable for unit tests. The contract between this provider and * applications is defined in {@link TvContractCompat}. */ // TODO(b/62143348): remove when error prone check fixed @SuppressWarnings({"AndroidApiChecker", "TryWithResources"}) public class FakeTvProvider extends ContentProvider { // TODO either make this a shadow or move it to the support library 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 Map sChannelProjectionMap; private static final Map sProgramProjectionMap; private static final Map sWatchedProgramProjectionMap; private static final Map sRecordedProgramProjectionMap; private static final Map sPreviewProgramProjectionMap; private static final Map sWatchNextProgramProjectionMap; // TvContract hidden private static final String PARAM_PACKAGE = "package"; private static final String PARAM_PREVIEW = "preview"; private static boolean sInitialized; static { sUriMatcher = new UriMatcher(UriMatcher.NO_MATCH); sUriMatcher.addURI(TvContractCompat.AUTHORITY, "channel", MATCH_CHANNEL); sUriMatcher.addURI(TvContractCompat.AUTHORITY, "channel/#", MATCH_CHANNEL_ID); sUriMatcher.addURI(TvContractCompat.AUTHORITY, "channel/#/logo", MATCH_CHANNEL_ID_LOGO); sUriMatcher.addURI(TvContractCompat.AUTHORITY, "passthrough/*", MATCH_PASSTHROUGH_ID); sUriMatcher.addURI(TvContractCompat.AUTHORITY, "program", MATCH_PROGRAM); sUriMatcher.addURI(TvContractCompat.AUTHORITY, "program/#", MATCH_PROGRAM_ID); sUriMatcher.addURI(TvContractCompat.AUTHORITY, "watched_program", MATCH_WATCHED_PROGRAM); sUriMatcher.addURI( TvContractCompat.AUTHORITY, "watched_program/#", MATCH_WATCHED_PROGRAM_ID); sUriMatcher.addURI(TvContractCompat.AUTHORITY, "recorded_program", MATCH_RECORDED_PROGRAM); sUriMatcher.addURI( TvContractCompat.AUTHORITY, "recorded_program/#", MATCH_RECORDED_PROGRAM_ID); sUriMatcher.addURI(TvContractCompat.AUTHORITY, "preview_program", MATCH_PREVIEW_PROGRAM); sUriMatcher.addURI( TvContractCompat.AUTHORITY, "preview_program/#", MATCH_PREVIEW_PROGRAM_ID); sUriMatcher.addURI( TvContractCompat.AUTHORITY, "watch_next_program", MATCH_WATCH_NEXT_PROGRAM); sUriMatcher.addURI( TvContractCompat.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 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 + ");"; private String mCallingPackage = "com.android.tv"; static class DatabaseHelper extends SQLiteOpenHelper { private Context mContext; public static synchronized DatabaseHelper createInstance(Context context) { return new DatabaseHelper(context); } 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 sBlockedPackages; @Override public boolean onCreate() { if (DEBUG) { Log.d(TAG, "Creating TvProvider"); } mOpenHelper = DatabaseHelper.createInstance(getContext()); return true; } @VisibleForTesting String getCallingPackage_() { return mCallingPackage; } public void setCallingPackage(String packageName) { mCallingPackage = packageName; } 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) { throw new UnsupportedOperationException(); } @Override public Cursor query( Uri uri, String[] projection, String selection, String[] selectionArgs, String sortOrder) { ensureInitialized(); 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 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(); 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 && TvContractCompat.PARAM_CHANNEL.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), TvContractCompat.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 = TvContractCompat.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 = TvContractCompat.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) { return ContentUris.withAppendedId(WatchedPrograms.CONTENT_URI, rowId); } Log.w(TAG, "Failed to insert row for " + values + ". Channel does not exist."); return null; } else if (watchStartTime == null && watchEndTime != null) { 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 = TvContractCompat.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 = TvContractCompat.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 = TvContractCompat.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) { 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) { 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 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 createProjectionMapForQuery( String[] projection, Map projectionMap) { if (projection == null) { return projectionMap; } Map columnProjectionMap = new HashMap<>(); for (String columnName : projection) { // Value NULL will be provided if the requested column does not exist in the database. columnProjectionMap.put( columnName, projectionMap.getOrDefault(columnName, "NULL as " + columnName)); } return columnProjectionMap; } private void filterContentValues(ContentValues values, Map projectionMap) { Iterator 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); 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(PARAM_PACKAGE); if (packageName != null) { params.appendWhere(prefix + BaseTvColumns.COLUMN_PACKAGE_NAME + "=?", packageName); } switch (match) { case MATCH_CHANNEL: String genre = uri.getQueryParameter(TvContractCompat.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(TvContractCompat.PARAM_INPUT); if (inputId != null) { params.appendWhere(Channels.COLUMN_INPUT_ID + "=?", inputId); } boolean browsableOnly = uri.getBooleanQueryParameter(TvContractCompat.PARAM_BROWSABLE_ONLY, false); if (browsableOnly) { params.appendWhere(Channels.COLUMN_BROWSABLE + "=1"); } String preview = uri.getQueryParameter(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(TvContractCompat.PARAM_CHANNEL); if (paramChannelId != null) { String channelId = String.valueOf(Long.parseLong(paramChannelId)); params.appendWhere(Programs.COLUMN_CHANNEL_ID + "=?", channelId); } String paramStartTime = uri.getQueryParameter(TvContractCompat.PARAM_START_TIME); String paramEndTime = uri.getQueryParameter(TvContractCompat.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(TvContractCompat.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(TvContractCompat.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 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 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> mTLBatchNotifications = new ThreadLocal<>(); private Set getBatchNotificationsSet() { return mTLBatchNotifications.get(); } private void setBatchNotificationsSet(Set batchNotifications) { mTLBatchNotifications.set(batchNotifications); } @Override public ContentProviderResult[] applyBatch(ArrayList operations) throws OperationApplicationException { setBatchNotificationsSet(new HashSet()); Context context = getContext(); SQLiteDatabase db = mOpenHelper.getWritableDatabase(); db.beginTransaction(); try { ContentProviderResult[] results = super.applyBatch(operations); db.setTransactionSuccessful(); return results; } finally { db.endTransaction(); final Set 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()); 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 notifications = getBatchNotificationsSet(); setBatchNotificationsSet(null); for (final Uri notificationUri : notifications) { context.getContentResolver().notifyChange(notificationUri, null); } } } private void notifyChange(Uri uri) { final Set 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; } // fall through 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 " + TvContractCompat.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 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 { 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) { int count = 0; try (AutoCloseInputStream is = new AutoCloseInputStream(mPfd); ByteArrayOutputStream baos = new ByteArrayOutputStream()) { 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); } 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 = TvContractCompat.buildChannelLogoUri(mChannelId); notifyChange(uri); } } catch (IOException e) { Log.e(TAG, "Failed to write logo for channel ID " + mChannelId, e); } 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); } } } return null; } } /** * Column definitions for the TV programs that the user watched. Applications do not have access * to this table. * *

* *

By default, the query results will be sorted by {@link * WatchedPrograms#COLUMN_WATCH_START_TIME_UTC_MILLIS} in descending order. * * @hide */ public static final class WatchedPrograms implements BaseTvColumns { /** The content:// style URI for this table. */ public static final Uri CONTENT_URI = Uri.parse("content://" + TvContract.AUTHORITY + "/watched_program"); /** The MIME type of a directory of watched programs. */ public static final String CONTENT_TYPE = "vnd.android.cursor.dir/watched_program"; /** The MIME type of a single item in this table. */ public static final String CONTENT_ITEM_TYPE = "vnd.android.cursor.item/watched_program"; /** * The UTC time that the user started watching this TV program, in milliseconds since the * epoch. * *

* *

Type: INTEGER (long) */ public static final String COLUMN_WATCH_START_TIME_UTC_MILLIS = "watch_start_time_utc_millis"; /** * The UTC time that the user stopped watching this TV program, in milliseconds since the * epoch. * *

* *

Type: INTEGER (long) */ public static final String COLUMN_WATCH_END_TIME_UTC_MILLIS = "watch_end_time_utc_millis"; /** * The ID of the TV channel that provides this TV program. * *

* *

This is a required field. * *

* *

Type: INTEGER (long) */ public static final String COLUMN_CHANNEL_ID = "channel_id"; /** * The title of this TV program. * *

* *

Type: TEXT */ public static final String COLUMN_TITLE = "title"; /** * The start time of this TV program, in milliseconds since the epoch. * *

* *

Type: INTEGER (long) */ public static final String COLUMN_START_TIME_UTC_MILLIS = "start_time_utc_millis"; /** * The end time of this TV program, in milliseconds since the epoch. * *

* *

Type: INTEGER (long) */ public static final String COLUMN_END_TIME_UTC_MILLIS = "end_time_utc_millis"; /** * The description of this TV program. * *

* *

Type: TEXT */ public static final String COLUMN_DESCRIPTION = "description"; /** * Extra parameters given to {@link TvInputService.Session#tune(Uri, android.os.Bundle) * TvInputService.Session.tune(Uri, android.os.Bundle)} when tuning to the channel that * provides this TV program. (Used internally.) * *

* *

This column contains an encoded string that represents comma-separated key-value pairs * of the tune parameters. (Ex. "[key1]=[value1], [key2]=[value2]"). '%' is used as an * escape character for '%', '=', and ','. * *

* *

Type: TEXT */ public static final String COLUMN_INTERNAL_TUNE_PARAMS = "tune_params"; /** * The session token of this TV program. (Used internally.) * *

* *

This contains a String representation of {@link IBinder} for {@link * TvInputService.Session} that provides the current TV program. It is used internally to * distinguish watched programs entries from different TV input sessions. * *

* *

Type: TEXT */ public static final String COLUMN_INTERNAL_SESSION_TOKEN = "session_token"; private WatchedPrograms() {} } }