android/telephony/mbms/MbmsDownloadReceiver.java - platform/prebuilts/fullsdk/sources/android-28 - Git at Google

 /*
  * 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 android.telephony.mbms;

 import android.annotation.SystemApi;
 import android.content.BroadcastReceiver;
 import android.content.ContentResolver;
 import android.content.Context;
 import android.content.Intent;
 import android.content.pm.ApplicationInfo;
 import android.content.pm.PackageManager;
 import android.net.Uri;
 import android.os.Bundle;
 import android.telephony.MbmsDownloadSession;
 import android.telephony.mbms.vendor.VendorUtils;
 import android.util.Log;

 import java.io.File;
 import java.io.FileFilter;
 import java.io.FileInputStream;
 import java.io.FileOutputStream;
 import java.io.IOException;
 import java.io.InputStream;
 import java.io.OutputStream;
 import java.nio.file.FileSystems;
 import java.nio.file.Files;
 import java.nio.file.Path;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Objects;
 import java.util.UUID;

 /**
  * The {@link BroadcastReceiver} responsible for handling intents sent from the middleware. Apps
  * that wish to download using MBMS APIs should declare this class in their AndroidManifest.xml as
  * follows:
 <pre>{@code
 <receiver
     android:name="android.telephony.mbms.MbmsDownloadReceiver"
     android:permission="android.permission.SEND_EMBMS_INTENTS"
     android:enabled="true"
     android:exported="true">
 </receiver>}</pre>
  */
 public class MbmsDownloadReceiver extends BroadcastReceiver {
     /** @hide */
     public static final String DOWNLOAD_TOKEN_SUFFIX = ".download_token";
     /** @hide */
     public static final String MBMS_FILE_PROVIDER_META_DATA_KEY = "mbms-file-provider-authority";

     /**
      * Indicates that the requested operation completed without error.
      * @hide
      */
     @SystemApi
     public static final int RESULT_OK = 0;

     /**
      * Indicates that the intent sent had an invalid action. This will be the result if
      * {@link Intent#getAction()} returns anything other than
      * {@link VendorUtils#ACTION_DOWNLOAD_RESULT_INTERNAL},
      * {@link VendorUtils#ACTION_FILE_DESCRIPTOR_REQUEST}, or
      * {@link VendorUtils#ACTION_CLEANUP}.
      * This is a fatal result code and no result extras should be expected.
      * @hide
      */
     @SystemApi
     public static final int RESULT_INVALID_ACTION = 1;

     /**
      * Indicates that the intent was missing some required extras.
      * This is a fatal result code and no result extras should be expected.
      * @hide
      */
     @SystemApi
     public static final int RESULT_MALFORMED_INTENT = 2;

     /**
      * Indicates that the supplied value for {@link VendorUtils#EXTRA_TEMP_FILE_ROOT}
      * does not match what the app has stored.
      * This is a fatal result code and no result extras should be expected.
      * @hide
      */
     @SystemApi
     public static final int RESULT_BAD_TEMP_FILE_ROOT = 3;

     /**
      * Indicates that the manager was unable to move the completed download to its final location.
      * This is a fatal result code and no result extras should be expected.
      * @hide
      */
     @SystemApi
     public static final int RESULT_DOWNLOAD_FINALIZATION_ERROR = 4;

     /**
      * Indicates that the manager was unable to generate one or more of the requested file
      * descriptors.
      * This is a non-fatal result code -- some file descriptors may still be generated, but there
      * is no guarantee that they will be the same number as requested.
      * @hide
      */
     @SystemApi
     public static final int RESULT_TEMP_FILE_GENERATION_ERROR = 5;

     /**
      * Indicates that the manager was unable to notify the app of the completed download.
      * This is a fatal result code and no result extras should be expected.
      * @hide
      */
     @SystemApi
     public static final int RESULT_APP_NOTIFICATION_ERROR = 6;


     private static final String LOG_TAG = "MbmsDownloadReceiver";
     private static final String TEMP_FILE_SUFFIX = ".embms.temp";
     private static final String TEMP_FILE_STAGING_LOCATION = "staged_completed_files";

     private static final int MAX_TEMP_FILE_RETRIES = 5;

     private String mFileProviderAuthorityCache = null;
     private String mMiddlewarePackageNameCache = null;

     /** @hide */
     @Override
     public void onReceive(Context context, Intent intent) {
         if (!verifyIntentContents(context, intent)) {
             setResultCode(RESULT_MALFORMED_INTENT);
             return;
         }
         if (!Objects.equals(intent.getStringExtra(VendorUtils.EXTRA_TEMP_FILE_ROOT),
                 MbmsTempFileProvider.getEmbmsTempFileDir(context).getPath())) {
             setResultCode(RESULT_BAD_TEMP_FILE_ROOT);
             return;
         }

         if (VendorUtils.ACTION_DOWNLOAD_RESULT_INTERNAL.equals(intent.getAction())) {
             moveDownloadedFile(context, intent);
             cleanupPostMove(context, intent);
         } else if (VendorUtils.ACTION_FILE_DESCRIPTOR_REQUEST.equals(intent.getAction())) {
             generateTempFiles(context, intent);
         } else if (VendorUtils.ACTION_CLEANUP.equals(intent.getAction())) {
             cleanupTempFiles(context, intent);
         } else {
             setResultCode(RESULT_INVALID_ACTION);
         }
     }

     private boolean verifyIntentContents(Context context, Intent intent) {
         if (VendorUtils.ACTION_DOWNLOAD_RESULT_INTERNAL.equals(intent.getAction())) {
             if (!intent.hasExtra(MbmsDownloadSession.EXTRA_MBMS_DOWNLOAD_RESULT)) {
                 Log.w(LOG_TAG, "Download result did not include a result code. Ignoring.");
                 return false;
             }
             if (!intent.hasExtra(MbmsDownloadSession.EXTRA_MBMS_DOWNLOAD_REQUEST)) {
                 Log.w(LOG_TAG, "Download result did not include the associated request. Ignoring.");
                 return false;
             }
             // We do not need to verify below extras if the result is not success.
             if (MbmsDownloadSession.RESULT_SUCCESSFUL !=
                     intent.getIntExtra(MbmsDownloadSession.EXTRA_MBMS_DOWNLOAD_RESULT,
                     MbmsDownloadSession.RESULT_CANCELLED)) {
                 return true;
             }
             if (!intent.hasExtra(VendorUtils.EXTRA_TEMP_FILE_ROOT)) {
                 Log.w(LOG_TAG, "Download result did not include the temp file root. Ignoring.");
                 return false;
             }
             if (!intent.hasExtra(MbmsDownloadSession.EXTRA_MBMS_FILE_INFO)) {
                 Log.w(LOG_TAG, "Download result did not include the associated file info. " +
                         "Ignoring.");
                 return false;
             }
             if (!intent.hasExtra(VendorUtils.EXTRA_FINAL_URI)) {
                 Log.w(LOG_TAG, "Download result did not include the path to the final " +
                         "temp file. Ignoring.");
                 return false;
             }
             DownloadRequest request = intent.getParcelableExtra(
                     MbmsDownloadSession.EXTRA_MBMS_DOWNLOAD_REQUEST);
             String expectedTokenFileName = request.getHash() + DOWNLOAD_TOKEN_SUFFIX;
             File expectedTokenFile = new File(
                     MbmsUtils.getEmbmsTempFileDirForService(context, request.getFileServiceId()),
                     expectedTokenFileName);
             if (!expectedTokenFile.exists()) {
                 Log.w(LOG_TAG, "Supplied download request does not match a token that we have. " +
                         "Expected " + expectedTokenFile);
                 return false;
             }
         } else if (VendorUtils.ACTION_FILE_DESCRIPTOR_REQUEST.equals(intent.getAction())) {
             if (!intent.hasExtra(VendorUtils.EXTRA_SERVICE_ID)) {
                 Log.w(LOG_TAG, "Temp file request did not include the associated service id." +
                         " Ignoring.");
                 return false;
             }
             if (!intent.hasExtra(VendorUtils.EXTRA_TEMP_FILE_ROOT)) {
                 Log.w(LOG_TAG, "Download result did not include the temp file root. Ignoring.");
                 return false;
             }
         } else if (VendorUtils.ACTION_CLEANUP.equals(intent.getAction())) {
             if (!intent.hasExtra(VendorUtils.EXTRA_SERVICE_ID)) {
                 Log.w(LOG_TAG, "Cleanup request did not include the associated service id." +
                         " Ignoring.");
                 return false;
             }
             if (!intent.hasExtra(VendorUtils.EXTRA_TEMP_FILE_ROOT)) {
                 Log.w(LOG_TAG, "Cleanup request did not include the temp file root. Ignoring.");
                 return false;
             }
             if (!intent.hasExtra(VendorUtils.EXTRA_TEMP_FILES_IN_USE)) {
                 Log.w(LOG_TAG, "Cleanup request did not include the list of temp files in use. " +
                         "Ignoring.");
                 return false;
             }
         }
         return true;
     }

     private void moveDownloadedFile(Context context, Intent intent) {
         DownloadRequest request = intent.getParcelableExtra(
                 MbmsDownloadSession.EXTRA_MBMS_DOWNLOAD_REQUEST);
         Intent intentForApp = request.getIntentForApp();
         if (intentForApp == null) {
             Log.i(LOG_TAG, "Malformed app notification intent");
             setResultCode(RESULT_APP_NOTIFICATION_ERROR);
             return;
         }

         int result = intent.getIntExtra(MbmsDownloadSession.EXTRA_MBMS_DOWNLOAD_RESULT,
                 MbmsDownloadSession.RESULT_CANCELLED);
         intentForApp.putExtra(MbmsDownloadSession.EXTRA_MBMS_DOWNLOAD_RESULT, result);
         intentForApp.putExtra(MbmsDownloadSession.EXTRA_MBMS_DOWNLOAD_REQUEST, request);

         if (result != MbmsDownloadSession.RESULT_SUCCESSFUL) {
             Log.i(LOG_TAG, "Download request indicated a failed download. Aborting.");
             context.sendBroadcast(intentForApp);
             setResultCode(RESULT_OK);
             return;
         }

         Uri finalTempFile = intent.getParcelableExtra(VendorUtils.EXTRA_FINAL_URI);
         if (!verifyTempFilePath(context, request.getFileServiceId(), finalTempFile)) {
             Log.w(LOG_TAG, "Download result specified an invalid temp file " + finalTempFile);
             setResultCode(RESULT_DOWNLOAD_FINALIZATION_ERROR);
             return;
         }

         FileInfo completedFileInfo =
                 (FileInfo) intent.getParcelableExtra(MbmsDownloadSession.EXTRA_MBMS_FILE_INFO);
         Path stagingDirectory = FileSystems.getDefault().getPath(
                 MbmsTempFileProvider.getEmbmsTempFileDir(context).getPath(),
                 TEMP_FILE_STAGING_LOCATION);

         Uri stagedFileLocation;
         try {
             stagedFileLocation = stageTempFile(finalTempFile, stagingDirectory);
         } catch (IOException e) {
             Log.w(LOG_TAG, "Failed to move temp file to final destination");
             setResultCode(RESULT_DOWNLOAD_FINALIZATION_ERROR);
             return;
         }
         intentForApp.putExtra(MbmsDownloadSession.EXTRA_MBMS_COMPLETED_FILE_URI,
                 stagedFileLocation);
         intentForApp.putExtra(MbmsDownloadSession.EXTRA_MBMS_FILE_INFO, completedFileInfo);

         context.sendBroadcast(intentForApp);
         setResultCode(RESULT_OK);
     }

     private void cleanupPostMove(Context context, Intent intent) {
         DownloadRequest request = intent.getParcelableExtra(
                 MbmsDownloadSession.EXTRA_MBMS_DOWNLOAD_REQUEST);
         if (request == null) {
             Log.w(LOG_TAG, "Intent does not include a DownloadRequest. Ignoring.");
             return;
         }

         List<Uri> tempFiles = intent.getParcelableArrayListExtra(VendorUtils.EXTRA_TEMP_LIST);
         if (tempFiles == null) {
             return;
         }

         for (Uri tempFileUri : tempFiles) {
             if (verifyTempFilePath(context, request.getFileServiceId(), tempFileUri)) {
                 File tempFile = new File(tempFileUri.getSchemeSpecificPart());
                 tempFile.delete();
             }
         }
     }

     private void generateTempFiles(Context context, Intent intent) {
         String serviceId = intent.getStringExtra(VendorUtils.EXTRA_SERVICE_ID);
         if (serviceId == null) {
             Log.w(LOG_TAG, "Temp file request did not include the associated service id. " +
                     "Ignoring.");
             setResultCode(RESULT_MALFORMED_INTENT);
             return;
         }
         int fdCount = intent.getIntExtra(VendorUtils.EXTRA_FD_COUNT, 0);
         List<Uri> pausedList = intent.getParcelableArrayListExtra(VendorUtils.EXTRA_PAUSED_LIST);

         if (fdCount == 0 && (pausedList == null || pausedList.size() == 0)) {
             Log.i(LOG_TAG, "No temp files actually requested. Ending.");
             setResultCode(RESULT_OK);
             setResultExtras(Bundle.EMPTY);
             return;
         }

         ArrayList<UriPathPair> freshTempFiles =
                 generateFreshTempFiles(context, serviceId, fdCount);
         ArrayList<UriPathPair> pausedFiles =
                 generateUrisForPausedFiles(context, serviceId, pausedList);

         Bundle result = new Bundle();
         result.putParcelableArrayList(VendorUtils.EXTRA_FREE_URI_LIST, freshTempFiles);
         result.putParcelableArrayList(VendorUtils.EXTRA_PAUSED_URI_LIST, pausedFiles);
         setResultCode(RESULT_OK);
         setResultExtras(result);
     }

     private ArrayList<UriPathPair> generateFreshTempFiles(Context context, String serviceId,
             int freshFdCount) {
         File tempFileDir = MbmsUtils.getEmbmsTempFileDirForService(context, serviceId);
         if (!tempFileDir.exists()) {
             tempFileDir.mkdirs();
         }

         // Name the files with the template "N-UUID", where N is the request ID and UUID is a
         // random uuid.
         ArrayList<UriPathPair> result = new ArrayList<>(freshFdCount);
         for (int i = 0; i < freshFdCount; i++) {
             File tempFile = generateSingleTempFile(tempFileDir);
             if (tempFile == null) {
                 setResultCode(RESULT_TEMP_FILE_GENERATION_ERROR);
                 Log.w(LOG_TAG, "Failed to generate a temp file. Moving on.");
                 continue;
             }
             Uri fileUri = Uri.fromFile(tempFile);
             Uri contentUri = MbmsTempFileProvider.getUriForFile(
                     context, getFileProviderAuthorityCached(context), tempFile);
             context.grantUriPermission(getMiddlewarePackageCached(context), contentUri,
                     Intent.FLAG_GRANT_READ_URI_PERMISSION | Intent.FLAG_GRANT_WRITE_URI_PERMISSION);
             result.add(new UriPathPair(fileUri, contentUri));
         }

         return result;
     }

     private static File generateSingleTempFile(File tempFileDir) {
         int numTries = 0;
         while (numTries < MAX_TEMP_FILE_RETRIES) {
             numTries++;
             String fileName =  UUID.randomUUID() + TEMP_FILE_SUFFIX;
             File tempFile = new File(tempFileDir, fileName);
             try {
                 if (tempFile.createNewFile()) {
                     return tempFile.getCanonicalFile();
                 }
             } catch (IOException e) {
                 continue;
             }
         }
         return null;
     }

     private ArrayList<UriPathPair> generateUrisForPausedFiles(Context context,
             String serviceId, List<Uri> pausedFiles) {
         if (pausedFiles == null) {
             return new ArrayList<>(0);
         }
         ArrayList<UriPathPair> result = new ArrayList<>(pausedFiles.size());

         for (Uri fileUri : pausedFiles) {
             if (!verifyTempFilePath(context, serviceId, fileUri)) {
                 Log.w(LOG_TAG, "Supplied file " + fileUri + " is not a valid temp file to resume");
                 setResultCode(RESULT_TEMP_FILE_GENERATION_ERROR);
                 continue;
             }
             File tempFile = new File(fileUri.getSchemeSpecificPart());
             if (!tempFile.exists()) {
                 Log.w(LOG_TAG, "Supplied file " + fileUri + " does not exist.");
                 setResultCode(RESULT_TEMP_FILE_GENERATION_ERROR);
                 continue;
             }
             Uri contentUri = MbmsTempFileProvider.getUriForFile(
                     context, getFileProviderAuthorityCached(context), tempFile);
             context.grantUriPermission(getMiddlewarePackageCached(context), contentUri,
                     Intent.FLAG_GRANT_READ_URI_PERMISSION | Intent.FLAG_GRANT_WRITE_URI_PERMISSION);

             result.add(new UriPathPair(fileUri, contentUri));
         }
         return result;
     }

     private void cleanupTempFiles(Context context, Intent intent) {
         String serviceId = intent.getStringExtra(VendorUtils.EXTRA_SERVICE_ID);
         File tempFileDir = MbmsUtils.getEmbmsTempFileDirForService(context, serviceId);
         final List<Uri> filesInUse =
                 intent.getParcelableArrayListExtra(VendorUtils.EXTRA_TEMP_FILES_IN_USE);
         File[] filesToDelete = tempFileDir.listFiles(new FileFilter() {
             @Override
             public boolean accept(File file) {
                 File canonicalFile;
                 try {
                     canonicalFile = file.getCanonicalFile();
                 } catch (IOException e) {
                     Log.w(LOG_TAG, "Got IOException canonicalizing " + file + ", not deleting.");
                     return false;
                 }
                 // Reject all files that don't match what we think a temp file should look like
                 // e.g. download tokens
                 if (!canonicalFile.getName().endsWith(TEMP_FILE_SUFFIX)) {
                     return false;
                 }
                 // If any of the files in use match the uri, return false to reject it from the
                 // list to delete.
                 Uri fileInUseUri = Uri.fromFile(canonicalFile);
                 return !filesInUse.contains(fileInUseUri);
             }
         });
         for (File fileToDelete : filesToDelete) {
             fileToDelete.delete();
         }
     }

     /*
      * Moves a tempfile located at fromPath to a new location in the staging directory.
      */
     private static Uri stageTempFile(Uri fromPath, Path stagingDirectory) throws IOException {
         if (!ContentResolver.SCHEME_FILE.equals(fromPath.getScheme())) {
             Log.w(LOG_TAG, "Moving source uri " + fromPath+ " does not have a file scheme");
             return null;
         }

         Path fromFile = FileSystems.getDefault().getPath(fromPath.getPath());
         if (!Files.isDirectory(stagingDirectory)) {
             Files.createDirectory(stagingDirectory);
         }
         Path result = Files.move(fromFile, stagingDirectory.resolve(fromFile.getFileName()));

         return Uri.fromFile(result.toFile());
     }

     private static boolean verifyTempFilePath(Context context, String serviceId,
             Uri filePath) {
         if (!ContentResolver.SCHEME_FILE.equals(filePath.getScheme())) {
             Log.w(LOG_TAG, "Uri " + filePath + " does not have a file scheme");
             return false;
         }

         String path = filePath.getSchemeSpecificPart();
         File tempFile = new File(path);
         if (!tempFile.exists()) {
             Log.w(LOG_TAG, "File at " + path + " does not exist.");
             return false;
         }

         if (!MbmsUtils.isContainedIn(
                 MbmsUtils.getEmbmsTempFileDirForService(context, serviceId), tempFile)) {
             return false;
         }

         return true;
     }

     private String getFileProviderAuthorityCached(Context context) {
         if (mFileProviderAuthorityCache != null) {
             return mFileProviderAuthorityCache;
         }

         mFileProviderAuthorityCache = getFileProviderAuthority(context);
         return mFileProviderAuthorityCache;
     }

     private static String getFileProviderAuthority(Context context) {
         ApplicationInfo appInfo;
         try {
             appInfo = context.getPackageManager()
                     .getApplicationInfo(context.getPackageName(), PackageManager.GET_META_DATA);
         } catch (PackageManager.NameNotFoundException e) {
             throw new RuntimeException("Package manager couldn't find " + context.getPackageName());
         }
         if (appInfo.metaData == null) {
             throw new RuntimeException("App must declare the file provider authority as metadata " +
                     "in the manifest.");
         }
         String authority = appInfo.metaData.getString(MBMS_FILE_PROVIDER_META_DATA_KEY);
         if (authority == null) {
             throw new RuntimeException("App must declare the file provider authority as metadata " +
                     "in the manifest.");
         }
         return authority;
     }

     private String getMiddlewarePackageCached(Context context) {
         if (mMiddlewarePackageNameCache == null) {
             mMiddlewarePackageNameCache = MbmsUtils.getMiddlewareServiceInfo(context,
                     MbmsDownloadSession.MBMS_DOWNLOAD_SERVICE_ACTION).packageName;
         }
         return mMiddlewarePackageNameCache;
     }

     private static boolean manualMove(File src, File dst) {
         InputStream in = null;
         OutputStream out = null;
         try {
             if (!dst.exists()) {
                 dst.createNewFile();
             }
             in = new FileInputStream(src);
             out = new FileOutputStream(dst);
             byte[] buffer = new byte[2048];
             int len;
             do {
                 len = in.read(buffer);
                 out.write(buffer, 0, len);
             } while (len > 0);
         } catch (IOException e) {
             Log.w(LOG_TAG, "Manual file move failed due to exception "  + e);
             if (dst.exists()) {
                 dst.delete();
             }
             return false;
         } finally {
             try {
                 if (in != null) {
                     in.close();
                 }
                 if (out != null) {
                     out.close();
                 }
             } catch (IOException e) {
                 Log.w(LOG_TAG, "Error closing streams: " + e);
             }
         }
         return true;
     }
 }
	/*
	* 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 android.telephony.mbms;

	import android.annotation.SystemApi;
	import android.content.BroadcastReceiver;
	import android.content.ContentResolver;
	import android.content.Context;
	import android.content.Intent;
	import android.content.pm.ApplicationInfo;
	import android.content.pm.PackageManager;
	import android.net.Uri;
	import android.os.Bundle;
	import android.telephony.MbmsDownloadSession;
	import android.telephony.mbms.vendor.VendorUtils;
	import android.util.Log;

	import java.io.File;
	import java.io.FileFilter;
	import java.io.FileInputStream;
	import java.io.FileOutputStream;
	import java.io.IOException;
	import java.io.InputStream;
	import java.io.OutputStream;
	import java.nio.file.FileSystems;
	import java.nio.file.Files;
	import java.nio.file.Path;
	import java.util.ArrayList;
	import java.util.List;
	import java.util.Objects;
	import java.util.UUID;

	/**
	* The {@link BroadcastReceiver} responsible for handling intents sent from the middleware. Apps
	* that wish to download using MBMS APIs should declare this class in their AndroidManifest.xml as
	* follows:
	<pre>{@code
	<receiver
	android:name="android.telephony.mbms.MbmsDownloadReceiver"
	android:permission="android.permission.SEND_EMBMS_INTENTS"
	android:enabled="true"
	android:exported="true">
	</receiver>}</pre>
	*/
	public class MbmsDownloadReceiver extends BroadcastReceiver {
	/** @hide */
	public static final String DOWNLOAD_TOKEN_SUFFIX = ".download_token";
	/** @hide */
	public static final String MBMS_FILE_PROVIDER_META_DATA_KEY = "mbms-file-provider-authority";

	/**
	* Indicates that the requested operation completed without error.
	* @hide
	*/
	@SystemApi
	public static final int RESULT_OK = 0;

	/**
	* Indicates that the intent sent had an invalid action. This will be the result if
	* {@link Intent#getAction()} returns anything other than
	* {@link VendorUtils#ACTION_DOWNLOAD_RESULT_INTERNAL},
	* {@link VendorUtils#ACTION_FILE_DESCRIPTOR_REQUEST}, or
	* {@link VendorUtils#ACTION_CLEANUP}.
	* This is a fatal result code and no result extras should be expected.
	* @hide
	*/
	@SystemApi
	public static final int RESULT_INVALID_ACTION = 1;

	/**
	* Indicates that the intent was missing some required extras.
	* This is a fatal result code and no result extras should be expected.
	* @hide
	*/
	@SystemApi
	public static final int RESULT_MALFORMED_INTENT = 2;

	/**
	* Indicates that the supplied value for {@link VendorUtils#EXTRA_TEMP_FILE_ROOT}
	* does not match what the app has stored.
	* This is a fatal result code and no result extras should be expected.
	* @hide
	*/
	@SystemApi
	public static final int RESULT_BAD_TEMP_FILE_ROOT = 3;

	/**
	* Indicates that the manager was unable to move the completed download to its final location.
	* This is a fatal result code and no result extras should be expected.
	* @hide
	*/
	@SystemApi
	public static final int RESULT_DOWNLOAD_FINALIZATION_ERROR = 4;

	/**
	* Indicates that the manager was unable to generate one or more of the requested file
	* descriptors.
	* This is a non-fatal result code -- some file descriptors may still be generated, but there
	* is no guarantee that they will be the same number as requested.
	* @hide
	*/
	@SystemApi
	public static final int RESULT_TEMP_FILE_GENERATION_ERROR = 5;

	/**
	* Indicates that the manager was unable to notify the app of the completed download.
	* This is a fatal result code and no result extras should be expected.
	* @hide
	*/
	@SystemApi
	public static final int RESULT_APP_NOTIFICATION_ERROR = 6;


	private static final String LOG_TAG = "MbmsDownloadReceiver";
	private static final String TEMP_FILE_SUFFIX = ".embms.temp";
	private static final String TEMP_FILE_STAGING_LOCATION = "staged_completed_files";

	private static final int MAX_TEMP_FILE_RETRIES = 5;

	private String mFileProviderAuthorityCache = null;
	private String mMiddlewarePackageNameCache = null;

	/** @hide */
	@Override
	public void onReceive(Context context, Intent intent) {
	if (!verifyIntentContents(context, intent)) {
	setResultCode(RESULT_MALFORMED_INTENT);
	return;
	}
	if (!Objects.equals(intent.getStringExtra(VendorUtils.EXTRA_TEMP_FILE_ROOT),
	MbmsTempFileProvider.getEmbmsTempFileDir(context).getPath())) {
	setResultCode(RESULT_BAD_TEMP_FILE_ROOT);
	return;
	}

	if (VendorUtils.ACTION_DOWNLOAD_RESULT_INTERNAL.equals(intent.getAction())) {
	moveDownloadedFile(context, intent);
	cleanupPostMove(context, intent);
	} else if (VendorUtils.ACTION_FILE_DESCRIPTOR_REQUEST.equals(intent.getAction())) {
	generateTempFiles(context, intent);
	} else if (VendorUtils.ACTION_CLEANUP.equals(intent.getAction())) {
	cleanupTempFiles(context, intent);
	} else {
	setResultCode(RESULT_INVALID_ACTION);
	}
	}

	private boolean verifyIntentContents(Context context, Intent intent) {
	if (VendorUtils.ACTION_DOWNLOAD_RESULT_INTERNAL.equals(intent.getAction())) {
	if (!intent.hasExtra(MbmsDownloadSession.EXTRA_MBMS_DOWNLOAD_RESULT)) {
	Log.w(LOG_TAG, "Download result did not include a result code. Ignoring.");
	return false;
	}
	if (!intent.hasExtra(MbmsDownloadSession.EXTRA_MBMS_DOWNLOAD_REQUEST)) {
	Log.w(LOG_TAG, "Download result did not include the associated request. Ignoring.");
	return false;
	}
	// We do not need to verify below extras if the result is not success.
	if (MbmsDownloadSession.RESULT_SUCCESSFUL !=
	intent.getIntExtra(MbmsDownloadSession.EXTRA_MBMS_DOWNLOAD_RESULT,
	MbmsDownloadSession.RESULT_CANCELLED)) {
	return true;
	}
	if (!intent.hasExtra(VendorUtils.EXTRA_TEMP_FILE_ROOT)) {
	Log.w(LOG_TAG, "Download result did not include the temp file root. Ignoring.");
	return false;
	}
	if (!intent.hasExtra(MbmsDownloadSession.EXTRA_MBMS_FILE_INFO)) {
	Log.w(LOG_TAG, "Download result did not include the associated file info. " +
	"Ignoring.");
	return false;
	}
	if (!intent.hasExtra(VendorUtils.EXTRA_FINAL_URI)) {
	Log.w(LOG_TAG, "Download result did not include the path to the final " +
	"temp file. Ignoring.");
	return false;
	}
	DownloadRequest request = intent.getParcelableExtra(
	MbmsDownloadSession.EXTRA_MBMS_DOWNLOAD_REQUEST);
	String expectedTokenFileName = request.getHash() + DOWNLOAD_TOKEN_SUFFIX;
	File expectedTokenFile = new File(
	MbmsUtils.getEmbmsTempFileDirForService(context, request.getFileServiceId()),
	expectedTokenFileName);
	if (!expectedTokenFile.exists()) {
	Log.w(LOG_TAG, "Supplied download request does not match a token that we have. " +
	"Expected " + expectedTokenFile);
	return false;
	}
	} else if (VendorUtils.ACTION_FILE_DESCRIPTOR_REQUEST.equals(intent.getAction())) {
	if (!intent.hasExtra(VendorUtils.EXTRA_SERVICE_ID)) {
	Log.w(LOG_TAG, "Temp file request did not include the associated service id." +
	" Ignoring.");
	return false;
	}
	if (!intent.hasExtra(VendorUtils.EXTRA_TEMP_FILE_ROOT)) {
	Log.w(LOG_TAG, "Download result did not include the temp file root. Ignoring.");
	return false;
	}
	} else if (VendorUtils.ACTION_CLEANUP.equals(intent.getAction())) {
	if (!intent.hasExtra(VendorUtils.EXTRA_SERVICE_ID)) {
	Log.w(LOG_TAG, "Cleanup request did not include the associated service id." +
	" Ignoring.");
	return false;
	}
	if (!intent.hasExtra(VendorUtils.EXTRA_TEMP_FILE_ROOT)) {
	Log.w(LOG_TAG, "Cleanup request did not include the temp file root. Ignoring.");
	return false;
	}
	if (!intent.hasExtra(VendorUtils.EXTRA_TEMP_FILES_IN_USE)) {
	Log.w(LOG_TAG, "Cleanup request did not include the list of temp files in use. " +
	"Ignoring.");
	return false;
	}
	}
	return true;
	}

	private void moveDownloadedFile(Context context, Intent intent) {
	DownloadRequest request = intent.getParcelableExtra(
	MbmsDownloadSession.EXTRA_MBMS_DOWNLOAD_REQUEST);
	Intent intentForApp = request.getIntentForApp();
	if (intentForApp == null) {
	Log.i(LOG_TAG, "Malformed app notification intent");
	setResultCode(RESULT_APP_NOTIFICATION_ERROR);
	return;
	}

	int result = intent.getIntExtra(MbmsDownloadSession.EXTRA_MBMS_DOWNLOAD_RESULT,
	MbmsDownloadSession.RESULT_CANCELLED);
	intentForApp.putExtra(MbmsDownloadSession.EXTRA_MBMS_DOWNLOAD_RESULT, result);
	intentForApp.putExtra(MbmsDownloadSession.EXTRA_MBMS_DOWNLOAD_REQUEST, request);

	if (result != MbmsDownloadSession.RESULT_SUCCESSFUL) {
	Log.i(LOG_TAG, "Download request indicated a failed download. Aborting.");
	context.sendBroadcast(intentForApp);
	setResultCode(RESULT_OK);
	return;
	}

	Uri finalTempFile = intent.getParcelableExtra(VendorUtils.EXTRA_FINAL_URI);
	if (!verifyTempFilePath(context, request.getFileServiceId(), finalTempFile)) {
	Log.w(LOG_TAG, "Download result specified an invalid temp file " + finalTempFile);
	setResultCode(RESULT_DOWNLOAD_FINALIZATION_ERROR);
	return;
	}

	FileInfo completedFileInfo =
	(FileInfo) intent.getParcelableExtra(MbmsDownloadSession.EXTRA_MBMS_FILE_INFO);
	Path stagingDirectory = FileSystems.getDefault().getPath(
	MbmsTempFileProvider.getEmbmsTempFileDir(context).getPath(),
	TEMP_FILE_STAGING_LOCATION);

	Uri stagedFileLocation;
	try {
	stagedFileLocation = stageTempFile(finalTempFile, stagingDirectory);
	} catch (IOException e) {
	Log.w(LOG_TAG, "Failed to move temp file to final destination");
	setResultCode(RESULT_DOWNLOAD_FINALIZATION_ERROR);
	return;
	}
	intentForApp.putExtra(MbmsDownloadSession.EXTRA_MBMS_COMPLETED_FILE_URI,
	stagedFileLocation);
	intentForApp.putExtra(MbmsDownloadSession.EXTRA_MBMS_FILE_INFO, completedFileInfo);

	context.sendBroadcast(intentForApp);
	setResultCode(RESULT_OK);
	}

	private void cleanupPostMove(Context context, Intent intent) {
	DownloadRequest request = intent.getParcelableExtra(
	MbmsDownloadSession.EXTRA_MBMS_DOWNLOAD_REQUEST);
	if (request == null) {
	Log.w(LOG_TAG, "Intent does not include a DownloadRequest. Ignoring.");
	return;
	}

	List<Uri> tempFiles = intent.getParcelableArrayListExtra(VendorUtils.EXTRA_TEMP_LIST);
	if (tempFiles == null) {
	return;
	}

	for (Uri tempFileUri : tempFiles) {
	if (verifyTempFilePath(context, request.getFileServiceId(), tempFileUri)) {
	File tempFile = new File(tempFileUri.getSchemeSpecificPart());
	tempFile.delete();
	}
	}
	}

	private void generateTempFiles(Context context, Intent intent) {
	String serviceId = intent.getStringExtra(VendorUtils.EXTRA_SERVICE_ID);
	if (serviceId == null) {
	Log.w(LOG_TAG, "Temp file request did not include the associated service id. " +
	"Ignoring.");
	setResultCode(RESULT_MALFORMED_INTENT);
	return;
	}
	int fdCount = intent.getIntExtra(VendorUtils.EXTRA_FD_COUNT, 0);
	List<Uri> pausedList = intent.getParcelableArrayListExtra(VendorUtils.EXTRA_PAUSED_LIST);

	if (fdCount == 0 && (pausedList == null \|\| pausedList.size() == 0)) {
	Log.i(LOG_TAG, "No temp files actually requested. Ending.");
	setResultCode(RESULT_OK);
	setResultExtras(Bundle.EMPTY);
	return;
	}

	ArrayList<UriPathPair> freshTempFiles =
	generateFreshTempFiles(context, serviceId, fdCount);
	ArrayList<UriPathPair> pausedFiles =
	generateUrisForPausedFiles(context, serviceId, pausedList);

	Bundle result = new Bundle();
	result.putParcelableArrayList(VendorUtils.EXTRA_FREE_URI_LIST, freshTempFiles);
	result.putParcelableArrayList(VendorUtils.EXTRA_PAUSED_URI_LIST, pausedFiles);
	setResultCode(RESULT_OK);
	setResultExtras(result);
	}

	private ArrayList<UriPathPair> generateFreshTempFiles(Context context, String serviceId,
	int freshFdCount) {
	File tempFileDir = MbmsUtils.getEmbmsTempFileDirForService(context, serviceId);
	if (!tempFileDir.exists()) {
	tempFileDir.mkdirs();
	}

	// Name the files with the template "N-UUID", where N is the request ID and UUID is a
	// random uuid.
	ArrayList<UriPathPair> result = new ArrayList<>(freshFdCount);
	for (int i = 0; i < freshFdCount; i++) {
	File tempFile = generateSingleTempFile(tempFileDir);
	if (tempFile == null) {
	setResultCode(RESULT_TEMP_FILE_GENERATION_ERROR);
	Log.w(LOG_TAG, "Failed to generate a temp file. Moving on.");
	continue;
	}
	Uri fileUri = Uri.fromFile(tempFile);
	Uri contentUri = MbmsTempFileProvider.getUriForFile(
	context, getFileProviderAuthorityCached(context), tempFile);
	context.grantUriPermission(getMiddlewarePackageCached(context), contentUri,
	Intent.FLAG_GRANT_READ_URI_PERMISSION \| Intent.FLAG_GRANT_WRITE_URI_PERMISSION);
	result.add(new UriPathPair(fileUri, contentUri));
	}

	return result;
	}

	private static File generateSingleTempFile(File tempFileDir) {
	int numTries = 0;
	while (numTries < MAX_TEMP_FILE_RETRIES) {
	numTries++;
	String fileName = UUID.randomUUID() + TEMP_FILE_SUFFIX;
	File tempFile = new File(tempFileDir, fileName);
	try {
	if (tempFile.createNewFile()) {
	return tempFile.getCanonicalFile();
	}
	} catch (IOException e) {
	continue;
	}
	}
	return null;
	}

	private ArrayList<UriPathPair> generateUrisForPausedFiles(Context context,
	String serviceId, List<Uri> pausedFiles) {
	if (pausedFiles == null) {
	return new ArrayList<>(0);
	}
	ArrayList<UriPathPair> result = new ArrayList<>(pausedFiles.size());

	for (Uri fileUri : pausedFiles) {
	if (!verifyTempFilePath(context, serviceId, fileUri)) {
	Log.w(LOG_TAG, "Supplied file " + fileUri + " is not a valid temp file to resume");
	setResultCode(RESULT_TEMP_FILE_GENERATION_ERROR);
	continue;
	}
	File tempFile = new File(fileUri.getSchemeSpecificPart());
	if (!tempFile.exists()) {
	Log.w(LOG_TAG, "Supplied file " + fileUri + " does not exist.");
	setResultCode(RESULT_TEMP_FILE_GENERATION_ERROR);
	continue;
	}
	Uri contentUri = MbmsTempFileProvider.getUriForFile(
	context, getFileProviderAuthorityCached(context), tempFile);
	context.grantUriPermission(getMiddlewarePackageCached(context), contentUri,
	Intent.FLAG_GRANT_READ_URI_PERMISSION \| Intent.FLAG_GRANT_WRITE_URI_PERMISSION);

	result.add(new UriPathPair(fileUri, contentUri));
	}
	return result;
	}

	private void cleanupTempFiles(Context context, Intent intent) {
	String serviceId = intent.getStringExtra(VendorUtils.EXTRA_SERVICE_ID);
	File tempFileDir = MbmsUtils.getEmbmsTempFileDirForService(context, serviceId);
	final List<Uri> filesInUse =
	intent.getParcelableArrayListExtra(VendorUtils.EXTRA_TEMP_FILES_IN_USE);
	File[] filesToDelete = tempFileDir.listFiles(new FileFilter() {
	@Override
	public boolean accept(File file) {
	File canonicalFile;
	try {
	canonicalFile = file.getCanonicalFile();
	} catch (IOException e) {
	Log.w(LOG_TAG, "Got IOException canonicalizing " + file + ", not deleting.");
	return false;
	}
	// Reject all files that don't match what we think a temp file should look like
	// e.g. download tokens
	if (!canonicalFile.getName().endsWith(TEMP_FILE_SUFFIX)) {
	return false;
	}
	// If any of the files in use match the uri, return false to reject it from the
	// list to delete.
	Uri fileInUseUri = Uri.fromFile(canonicalFile);
	return !filesInUse.contains(fileInUseUri);
	}
	});
	for (File fileToDelete : filesToDelete) {
	fileToDelete.delete();
	}
	}

	/*
	* Moves a tempfile located at fromPath to a new location in the staging directory.
	*/
	private static Uri stageTempFile(Uri fromPath, Path stagingDirectory) throws IOException {
	if (!ContentResolver.SCHEME_FILE.equals(fromPath.getScheme())) {
	Log.w(LOG_TAG, "Moving source uri " + fromPath+ " does not have a file scheme");
	return null;
	}

	Path fromFile = FileSystems.getDefault().getPath(fromPath.getPath());
	if (!Files.isDirectory(stagingDirectory)) {
	Files.createDirectory(stagingDirectory);
	}
	Path result = Files.move(fromFile, stagingDirectory.resolve(fromFile.getFileName()));

	return Uri.fromFile(result.toFile());
	}

	private static boolean verifyTempFilePath(Context context, String serviceId,
	Uri filePath) {
	if (!ContentResolver.SCHEME_FILE.equals(filePath.getScheme())) {
	Log.w(LOG_TAG, "Uri " + filePath + " does not have a file scheme");
	return false;
	}

	String path = filePath.getSchemeSpecificPart();
	File tempFile = new File(path);
	if (!tempFile.exists()) {
	Log.w(LOG_TAG, "File at " + path + " does not exist.");
	return false;
	}

	if (!MbmsUtils.isContainedIn(
	MbmsUtils.getEmbmsTempFileDirForService(context, serviceId), tempFile)) {
	return false;
	}

	return true;
	}

	private String getFileProviderAuthorityCached(Context context) {
	if (mFileProviderAuthorityCache != null) {
	return mFileProviderAuthorityCache;
	}

	mFileProviderAuthorityCache = getFileProviderAuthority(context);
	return mFileProviderAuthorityCache;
	}

	private static String getFileProviderAuthority(Context context) {
	ApplicationInfo appInfo;
	try {
	appInfo = context.getPackageManager()
	.getApplicationInfo(context.getPackageName(), PackageManager.GET_META_DATA);
	} catch (PackageManager.NameNotFoundException e) {
	throw new RuntimeException("Package manager couldn't find " + context.getPackageName());
	}
	if (appInfo.metaData == null) {
	throw new RuntimeException("App must declare the file provider authority as metadata " +
	"in the manifest.");
	}
	String authority = appInfo.metaData.getString(MBMS_FILE_PROVIDER_META_DATA_KEY);
	if (authority == null) {
	throw new RuntimeException("App must declare the file provider authority as metadata " +
	"in the manifest.");
	}
	return authority;
	}

	private String getMiddlewarePackageCached(Context context) {
	if (mMiddlewarePackageNameCache == null) {
	mMiddlewarePackageNameCache = MbmsUtils.getMiddlewareServiceInfo(context,
	MbmsDownloadSession.MBMS_DOWNLOAD_SERVICE_ACTION).packageName;
	}
	return mMiddlewarePackageNameCache;
	}

	private static boolean manualMove(File src, File dst) {
	InputStream in = null;
	OutputStream out = null;
	try {
	if (!dst.exists()) {
	dst.createNewFile();
	}
	in = new FileInputStream(src);
	out = new FileOutputStream(dst);
	byte[] buffer = new byte[2048];
	int len;
	do {
	len = in.read(buffer);
	out.write(buffer, 0, len);
	} while (len > 0);
	} catch (IOException e) {
	Log.w(LOG_TAG, "Manual file move failed due to exception " + e);
	if (dst.exists()) {
	dst.delete();
	}
	return false;
	} finally {
	try {
	if (in != null) {
	in.close();
	}
	if (out != null) {
	out.close();
	}
	} catch (IOException e) {
	Log.w(LOG_TAG, "Error closing streams: " + e);
	}
	}
	return true;
	}
	}