blob: 81a8700f828342e51399b2f0e92f86c2b573c70f [file] [log] [blame]
/*
* Copyright (C) 2014 The Android Open Source Project
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.android.cts.devicepolicy;
import com.android.compatibility.common.tradefed.build.CompatibilityBuildHelper;
import com.android.ddmlib.testrunner.RemoteAndroidTestRunner;
import com.android.ddmlib.testrunner.TestResult.TestStatus;
import com.android.tradefed.build.IBuildInfo;
import com.android.tradefed.config.Option;
import com.android.tradefed.device.CollectingOutputReceiver;
import com.android.tradefed.device.DeviceNotAvailableException;
import com.android.tradefed.log.LogUtil.CLog;
import com.android.tradefed.result.CollectingTestListener;
import com.android.tradefed.result.FileInputStreamSource;
import com.android.tradefed.result.LogDataType;
import com.android.tradefed.result.TestDescription;
import com.android.tradefed.result.TestResult;
import com.android.tradefed.result.TestRunResult;
import com.android.tradefed.testtype.DeviceTestCase;
import com.android.tradefed.testtype.IBuildReceiver;
import com.android.tradefed.util.FileUtil;
import com.android.tradefed.util.TarUtil;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.HashSet;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.TimeUnit;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import javax.annotation.Nullable;
/**
* Base class for device policy tests. It offers utility methods to run tests, set device or profile
* owner, etc.
*/
public class BaseDevicePolicyTest extends DeviceTestCase implements IBuildReceiver {
@Option(
name = "skip-device-admin-feature-check",
description = "Flag that allows to skip the check for android.software.device_admin "
+ "and run the tests no matter what. This is useful for system that do not what "
+ "to expose that feature publicly."
)
private boolean mSkipDeviceAdminFeatureCheck = false;
private static final String RUNNER = "androidx.test.runner.AndroidJUnitRunner";
protected static final int USER_SYSTEM = 0; // From the UserHandle class.
protected static final int USER_OWNER = 0;
private static final long TIMEOUT_USER_REMOVED_MILLIS = TimeUnit.SECONDS.toMillis(15);
private static final long WAIT_SAMPLE_INTERVAL_MILLIS = 200;
/**
* The defined timeout (in milliseconds) is used as a maximum waiting time when expecting the
* command output from the device. At any time, if the shell command does not output anything
* for a period longer than defined timeout the Tradefed run terminates.
*/
private static final long DEFAULT_SHELL_TIMEOUT_MILLIS = TimeUnit.MINUTES.toMillis(20);
/** instrumentation test runner argument key used for individual test timeout */
protected static final String TEST_TIMEOUT_INST_ARGS_KEY = "timeout_msec";
/**
* Sets timeout (in milliseconds) that will be applied to each test. In the
* event of a test timeout it will log the results and proceed with executing the next test.
*/
private static final long DEFAULT_TEST_TIMEOUT_MILLIS = TimeUnit.MINUTES.toMillis(10);
/**
* The amount of milliseconds to wait for the remove user calls in {@link #tearDown}.
* This is a temporary measure until b/114057686 is fixed.
*/
private static final long USER_REMOVE_WAIT = TimeUnit.SECONDS.toMillis(5);
/**
* The amount of milliseconds to wait for the switch user calls in {@link #tearDown}.
*/
private static final long USER_SWITCH_WAIT = TimeUnit.SECONDS.toMillis(5);
// From the UserInfo class
protected static final int FLAG_PRIMARY = 0x00000001;
protected static final int FLAG_GUEST = 0x00000004;
protected static final int FLAG_EPHEMERAL = 0x00000100;
protected static final int FLAG_MANAGED_PROFILE = 0x00000020;
/**
* The {@link android.os.BatteryManager} flags value representing all charging types; {@link
* android.os.BatteryManager#BATTERY_PLUGGED_AC}, {@link
* android.os.BatteryManager#BATTERY_PLUGGED_USB}, and {@link
* android.os.BatteryManager#BATTERY_PLUGGED_WIRELESS}.
*/
private static final int STAY_ON_WHILE_PLUGGED_IN_FLAGS = 7;
/**
* User ID for all users.
* The value is from the UserHandle class.
*/
protected static final int USER_ALL = -1;
protected static interface Settings {
public static final String GLOBAL_NAMESPACE = "global";
public static interface Global {
public static final String DEVICE_PROVISIONED = "device_provisioned";
}
}
protected IBuildInfo mCtsBuild;
protected CompatibilityBuildHelper mBuildHelper;
private String mPackageVerifier;
private HashSet<String> mAvailableFeatures;
/** Packages installed as part of the tests */
private Set<String> mFixedPackages;
/** Whether DPM is supported. */
protected boolean mHasFeature;
protected int mPrimaryUserId;
/** Record the initial user ID. */
protected int mInitialUserId;
/** Whether multi-user is supported. */
protected boolean mSupportsMultiUser;
/** Whether file-based encryption (FBE) is supported. */
protected boolean mSupportsFbe;
/** Whether the device has a lock screen.*/
protected boolean mHasSecureLockScreen;
/** Whether the device supports telephony. */
protected boolean mHasTelephony;
/** Users we shouldn't delete in the tests */
private ArrayList<Integer> mFixedUsers;
private static final String VERIFY_CREDENTIAL_CONFIRMATION = "Lock credential verified";
@Override
public void setBuild(IBuildInfo buildInfo) {
mCtsBuild = buildInfo;
}
@Override
protected void setUp() throws Exception {
super.setUp();
assertNotNull(mCtsBuild); // ensure build has been set before test is run.
mHasFeature = getDevice().getApiLevel() >= 21; /* Build.VERSION_CODES.L */
if (!mSkipDeviceAdminFeatureCheck) {
mHasFeature = mHasFeature && hasDeviceFeature("android.software.device_admin");
}
mSupportsMultiUser = getMaxNumberOfUsersSupported() > 1;
mSupportsFbe = hasDeviceFeature("android.software.file_based_encryption");
mHasTelephony = hasDeviceFeature("android.hardware.telephony");
mFixedPackages = getDevice().getInstalledPackageNames();
mBuildHelper = new CompatibilityBuildHelper(mCtsBuild);
mHasSecureLockScreen = hasDeviceFeature("android.software.secure_lock_screen");
// disable the package verifier to avoid the dialog when installing an app
mPackageVerifier = getDevice().executeShellCommand(
"settings get global package_verifier_enable");
getDevice().executeShellCommand("settings put global package_verifier_enable 0");
mFixedUsers = new ArrayList<>();
mPrimaryUserId = getPrimaryUser();
// Set the value of initial user ID calls in {@link #setUp}.
if(mSupportsMultiUser) {
mInitialUserId = getDevice().getCurrentUser();
}
mFixedUsers.add(mPrimaryUserId);
if (mPrimaryUserId != USER_SYSTEM) {
mFixedUsers.add(USER_SYSTEM);
}
if (mHasFeature) {
// Switching to primary is only needed when we're testing device admin features.
switchUser(mPrimaryUserId);
} else {
// Otherwise, all the tests can be executed in any of the Android users, so remain in
// current user, and don't delete it. This enables testing in secondary users.
if (getDevice().getCurrentUser() != mPrimaryUserId) {
mFixedUsers.add(getDevice().getCurrentUser());
}
}
removeOwners();
switchUser(USER_SYSTEM);
removeTestUsers();
// Unlock keyguard before test
wakeupAndDismissKeyguard();
stayAwake();
// Go to home.
executeShellCommand("input keyevent KEYCODE_HOME");
}
@Override
protected void tearDown() throws Exception {
// reset the package verifier setting to its original value
getDevice().executeShellCommand("settings put global package_verifier_enable "
+ mPackageVerifier);
removeOwners();
// Switch back to initial user.
if (mSupportsMultiUser && getDevice().getCurrentUser() != mInitialUserId) {
switchUser(mInitialUserId);
}
removeTestUsers();
removeTestPackages();
super.tearDown();
}
protected void installAppAsUser(String appFileName, int userId) throws FileNotFoundException,
DeviceNotAvailableException {
installAppAsUser(appFileName, true, userId);
}
protected void installAppAsUser(String appFileName, boolean grantPermissions, int userId)
throws FileNotFoundException, DeviceNotAvailableException {
installAppAsUser(appFileName, grantPermissions, /* dontKillApp */ false, userId);
}
protected void installAppAsUser(String appFileName, boolean grantPermissions,
boolean dontKillApp, int userId)
throws FileNotFoundException, DeviceNotAvailableException {
CLog.d("Installing app " + appFileName + " for user " + userId);
CompatibilityBuildHelper buildHelper = new CompatibilityBuildHelper(mCtsBuild);
List<String> extraArgs = new LinkedList<>();
extraArgs.add("-t");
if (dontKillApp) extraArgs.add("--dont-kill");
String result = getDevice().installPackageForUser(
buildHelper.getTestFile(appFileName), true, grantPermissions, userId,
extraArgs.toArray(new String[extraArgs.size()]));
assertNull("Failed to install " + appFileName + " for user " + userId + ": " + result,
result);
}
protected void forceStopPackageForUser(String packageName, int userId) throws Exception {
// TODO Move this logic to ITestDevice
executeShellCommand("am force-stop --user " + userId + " " + packageName);
}
protected void executeShellCommand(final String command) throws Exception {
CLog.d("Starting command " + command);
String commandOutput = getDevice().executeShellCommand(command);
CLog.d("Output for command " + command + ": " + commandOutput);
}
/** Initializes the user with the given id. This is required so that apps can run on it. */
protected void startUser(int userId) throws Exception {
getDevice().startUser(userId);
}
/** Initializes the user with waitFlag. This is required so that apps can run on it. */
protected void startUserAndWait(int userId) throws Exception {
getDevice().startUser(userId, /* waitFlag= */ true);
}
/**
* Initializes the user with the given id, and waits until the user has started and unlocked
* before continuing.
*
* <p>This is required so that apps can run on it.
*/
protected void startUser(int userId, boolean waitFlag) throws Exception {
getDevice().startUser(userId, waitFlag);
}
/**
* Starts switching to the user with the given ID.
*
* <p>This is not blocking. Some operations will be flaky if called immediately afterwards, such
* as {@link #wakeupAndDismissKeyguard()}. Call {@link #waitForBroadcastIdle()} between this
* method and those operations to ensure that switching the user has finished.
*/
protected void switchUser(int userId) throws Exception {
// TODO Move this logic to ITestDevice
int retries = 10;
executeShellCommand("am switch-user " + userId);
while (getDevice().getCurrentUser() != userId && (--retries) >= 0) {
// am switch-user can be ignored if a previous user-switching operation
// is still in progress. In this case, sleep a bit and then retry
Thread.sleep(USER_SWITCH_WAIT);
executeShellCommand("am switch-user " + userId);
}
assertTrue("Failed to switch user after multiple retries", getDevice().getCurrentUser() == userId);
}
protected int getMaxNumberOfUsersSupported() throws DeviceNotAvailableException {
return getDevice().getMaxNumberOfUsersSupported();
}
protected int getMaxNumberOfRunningUsersSupported() throws DeviceNotAvailableException {
return getDevice().getMaxNumberOfRunningUsersSupported();
}
protected int getUserFlags(int userId) throws DeviceNotAvailableException {
String command = "pm list users";
String commandOutput = getDevice().executeShellCommand(command);
CLog.i("Output for command " + command + ": " + commandOutput);
String[] lines = commandOutput.split("\\r?\\n");
assertTrue(commandOutput + " should contain at least one line", lines.length >= 1);
for (int i = 1; i < lines.length; i++) {
// Individual user is printed out like this:
// \tUserInfo{$id$:$name$:$Integer.toHexString(flags)$} [running]
String[] tokens = lines[i].split("\\{|\\}|:");
assertTrue(lines[i] + " doesn't contain 4 or 5 tokens",
tokens.length == 4 || tokens.length == 5);
// If the user IDs match, return the flags.
if (Integer.parseInt(tokens[1]) == userId) {
return Integer.parseInt(tokens[3], 16);
}
}
fail("User not found");
return 0;
}
protected ArrayList<Integer> listUsers() throws DeviceNotAvailableException {
return getDevice().listUsers();
}
protected ArrayList<Integer> listRunningUsers() throws DeviceNotAvailableException {
ArrayList<Integer> runningUsers = new ArrayList<>();
for (int userId : listUsers()) {
if (getDevice().isUserRunning(userId)) {
runningUsers.add(userId);
}
}
return runningUsers;
}
protected int getFirstManagedProfileUserId() throws DeviceNotAvailableException {
for (int userId : listUsers()) {
if ((getUserFlags(userId) & FLAG_MANAGED_PROFILE) != 0) {
return userId;
}
}
fail("Managed profile not found");
return 0;
}
private void stopUserAsync(int userId) throws Exception {
String stopUserCommand = "am stop-user -f " + userId;
CLog.d("starting command \"" + stopUserCommand);
CLog.d("Output for command " + stopUserCommand + ": "
+ getDevice().executeShellCommand(stopUserCommand));
}
protected void stopUser(int userId) throws Exception {
String stopUserCommand = "am stop-user -w -f " + userId;
CLog.d("starting command \"" + stopUserCommand + "\" and waiting.");
CLog.d("Output for command " + stopUserCommand + ": "
+ getDevice().executeShellCommand(stopUserCommand));
}
protected void waitForBroadcastIdle() throws DeviceNotAvailableException, IOException {
CollectingOutputReceiver receiver = new CollectingOutputReceiver();
try {
// we allow 8min for the command to complete and 4min for the command to start to
// output something
getDevice().executeShellCommand(
"am wait-for-broadcast-idle", receiver, 8, 4, TimeUnit.MINUTES, 0);
} finally {
String output = receiver.getOutput();
CLog.d("Output from 'am wait-for-broadcast-idle': %s", output);
if (!output.contains("All broadcast queues are idle!")) {
// Gather the system_server dump data for investigation.
File heapDump = getDevice().dumpHeap("system_server", "/data/local/tmp/dump.hprof");
if (heapDump != null) {
// If file is too too big, tar if with TarUtil.
String pid = getDevice().getProcessPid("system_server");
// gzip the file it's quite big
File heapDumpGz = TarUtil.gzip(heapDump);
try (FileInputStreamSource source = new FileInputStreamSource(heapDumpGz)) {
addTestLog(
String.format("system_server_dump.%s.%s.hprof",
pid, getDevice().getDeviceDate()),
LogDataType.GZIP, source);
} finally {
FileUtil.deleteFile(heapDump);
}
} else {
CLog.e("Failed to capture the dumpheap from system_server");
}
// the call most likely failed we should fail the test
fail("'am wait-for-broadcase-idle' did not complete.");
// TODO: consider adding a reboot or recovery before failing if necessary
}
}
}
protected void removeUser(int userId) throws Exception {
if (listUsers().contains(userId) && userId != USER_SYSTEM) {
// Don't log output, as tests sometimes set no debug user restriction, which
// causes this to fail, we should still continue and remove the user.
String stopUserCommand = "am stop-user -w -f " + userId;
CLog.d("stopping and removing user " + userId);
getDevice().executeShellCommand(stopUserCommand);
// TODO: Remove both sleeps and USER_REMOVE_WAIT constant when b/114057686 is fixed.
Thread.sleep(USER_REMOVE_WAIT);
// Ephemeral users may have already been removed after being stopped.
if (listUsers().contains(userId)) {
assertTrue("Couldn't remove user", getDevice().removeUser(userId));
Thread.sleep(USER_REMOVE_WAIT);
}
}
}
protected void removeTestUsers() throws Exception {
List<Integer> usersCreatedByTests = getUsersCreatedByTests();
// The time spent on stopUser is depend on how busy the broadcast queue is.
// To optimize the time to remove multiple test users, we mark all users as
// stopping first, so no more broadcasts will be sent to these users, which make the queue
// less busy.
for (int userId : usersCreatedByTests) {
stopUserAsync(userId);
}
for (int userId : usersCreatedByTests) {
removeUser(userId);
}
}
/**
* Returns the users that have been created since running this class' setUp() method.
*/
protected List<Integer> getUsersCreatedByTests() throws Exception {
List<Integer> result = listUsers();
result.removeAll(mFixedUsers);
return result;
}
/** Removes any packages that were installed during the test. */
protected void removeTestPackages() throws Exception {
for (String packageName : getDevice().getUninstallablePackageNames()) {
if (mFixedPackages.contains(packageName)) {
continue;
}
CLog.w("removing leftover package: " + packageName);
getDevice().uninstallPackage(packageName);
}
}
protected void runDeviceTestsAsUser(
String pkgName, @Nullable String testClassName, int userId)
throws DeviceNotAvailableException {
runDeviceTestsAsUser(pkgName, testClassName, null /*testMethodName*/, userId);
}
protected void runDeviceTestsAsUser(
String pkgName, @Nullable String testClassName, String testMethodName, int userId)
throws DeviceNotAvailableException {
Map<String, String> params = Collections.emptyMap();
runDeviceTestsAsUser(pkgName, testClassName, testMethodName, userId, params);
}
protected void runDeviceTests(
String pkgName, @Nullable String testClassName, String testMethodName)
throws DeviceNotAvailableException {
runDeviceTestsAsUser(pkgName, testClassName, testMethodName, mPrimaryUserId);
}
protected void runDeviceTestsAsUser(
String pkgName, @Nullable String testClassName,
@Nullable String testMethodName, int userId,
Map<String, String> params) throws DeviceNotAvailableException {
if (testClassName != null && testClassName.startsWith(".")) {
testClassName = pkgName + testClassName;
}
RemoteAndroidTestRunner testRunner = new RemoteAndroidTestRunner(
pkgName, RUNNER, getDevice().getIDevice());
testRunner.setMaxTimeToOutputResponse(DEFAULT_SHELL_TIMEOUT_MILLIS, TimeUnit.MILLISECONDS);
testRunner.addInstrumentationArg(
TEST_TIMEOUT_INST_ARGS_KEY, Long.toString(DEFAULT_TEST_TIMEOUT_MILLIS));
if (testClassName != null && testMethodName != null) {
testRunner.setMethodName(testClassName, testMethodName);
} else if (testClassName != null) {
testRunner.setClassName(testClassName);
}
for (Map.Entry<String, String> param : params.entrySet()) {
testRunner.addInstrumentationArg(param.getKey(), param.getValue());
}
CollectingTestListener listener = new CollectingTestListener();
getDevice().runInstrumentationTestsAsUser(testRunner, userId, listener);
final TestRunResult result = listener.getCurrentRunResults();
if (result.isRunFailure()) {
throw new AssertionError("Failed to successfully run device tests for "
+ result.getName() + ": " + result.getRunFailureMessage());
}
if (result.getNumTests() == 0) {
throw new AssertionError("No tests were run on the device");
}
if (result.hasFailedTests()) {
// build a meaningful error message
StringBuilder errorBuilder = new StringBuilder("On-device tests failed:\n");
for (Map.Entry<TestDescription, TestResult> resultEntry :
result.getTestResults().entrySet()) {
if (!resultEntry.getValue().getStatus().equals(TestStatus.PASSED)) {
errorBuilder.append(resultEntry.getKey().toString());
errorBuilder.append(":\n");
errorBuilder.append(resultEntry.getValue().getStackTrace());
}
}
throw new AssertionError(errorBuilder.toString());
}
}
/** Reboots the device and block until the boot complete flag is set. */
protected void rebootAndWaitUntilReady() throws DeviceNotAvailableException {
getDevice().rebootUntilOnline();
assertTrue("Device failed to boot", getDevice().waitForBootComplete(120000));
}
/** Returns true if the system supports the split between system and primary user. */
protected boolean hasUserSplit() throws DeviceNotAvailableException {
return getBooleanSystemProperty("ro.fw.system_user_split", false);
}
/** Returns a boolean value of the system property with the specified key. */
protected boolean getBooleanSystemProperty(String key, boolean defaultValue)
throws DeviceNotAvailableException {
final String[] positiveValues = {"1", "y", "yes", "true", "on"};
final String[] negativeValues = {"0", "n", "no", "false", "off"};
String propertyValue = getDevice().getProperty(key);
if (propertyValue == null || propertyValue.isEmpty()) {
return defaultValue;
}
if (Arrays.asList(positiveValues).contains(propertyValue)) {
return true;
}
if (Arrays.asList(negativeValues).contains(propertyValue)) {
return false;
}
fail("Unexpected value of boolean system property '" + key + "': " + propertyValue);
return false;
}
/** Checks whether it is possible to create the desired number of users. */
protected boolean canCreateAdditionalUsers(int numberOfUsers)
throws DeviceNotAvailableException {
return listUsers().size() + numberOfUsers <= getMaxNumberOfUsersSupported();
}
/** Checks whether it is possible to start the desired number of users. */
protected boolean canStartAdditionalUsers(int numberOfUsers)
throws DeviceNotAvailableException {
return listRunningUsers().size() + numberOfUsers <= getMaxNumberOfRunningUsersSupported();
}
protected boolean hasDeviceFeature(String requiredFeature) throws DeviceNotAvailableException {
if (mAvailableFeatures == null) {
// TODO: Move this logic to ITestDevice.
String command = "pm list features";
String commandOutput = getDevice().executeShellCommand(command);
CLog.i("Output for command " + command + ": " + commandOutput);
// Extract the id of the new user.
mAvailableFeatures = new HashSet<>();
for (String feature: commandOutput.split("\\s+")) {
// Each line in the output of the command has the format "feature:{FEATURE_VALUE}".
String[] tokens = feature.split(":");
assertTrue("\"" + feature + "\" expected to have format feature:{FEATURE_VALUE}",
tokens.length > 1);
assertEquals(feature, "feature", tokens[0]);
mAvailableFeatures.add(tokens[1]);
}
}
boolean result = mAvailableFeatures.contains(requiredFeature);
if (!result) {
CLog.d("Device doesn't have required feature "
+ requiredFeature + ". Test won't run.");
}
return result;
}
protected int createUser() throws Exception {
int userId = createUser(0);
// TODO remove this and audit tests so they start users as necessary
startUser(userId);
return userId;
}
protected int createUserAndWaitStart() throws Exception {
int userId = createUser(0);
startUserAndWait(userId);
return userId;
}
protected int createUser(int flags) throws Exception {
boolean guest = FLAG_GUEST == (flags & FLAG_GUEST);
boolean ephemeral = FLAG_EPHEMERAL == (flags & FLAG_EPHEMERAL);
// TODO Use ITestDevice.createUser() when guest and ephemeral is available
String command ="pm create-user " + (guest ? "--guest " : "")
+ (ephemeral ? "--ephemeral " : "") + "TestUser_" + System.currentTimeMillis();
CLog.d("Starting command " + command);
String commandOutput = getDevice().executeShellCommand(command);
CLog.d("Output for command " + command + ": " + commandOutput);
// Extract the id of the new user.
String[] tokens = commandOutput.split("\\s+");
assertTrue(tokens.length > 0);
assertEquals("Success:", tokens[0]);
return Integer.parseInt(tokens[tokens.length-1]);
}
protected int createManagedProfile(int parentUserId) throws DeviceNotAvailableException {
String commandOutput = getCreateManagedProfileCommandOutput(parentUserId);
return getUserIdFromCreateUserCommandOutput(commandOutput);
}
protected void assertCannotCreateManagedProfile(int parentUserId)
throws Exception {
String commandOutput = getCreateManagedProfileCommandOutput(parentUserId);
if (commandOutput.startsWith("Error")) {
return;
}
int userId = getUserIdFromCreateUserCommandOutput(commandOutput);
removeUser(userId);
fail("Expected not to be able to create a managed profile. Output was: " + commandOutput);
}
private int getUserIdFromCreateUserCommandOutput(String commandOutput) {
// Extract the id of the new user.
String[] tokens = commandOutput.split("\\s+");
assertTrue(commandOutput + " expected to have format \"Success: {USER_ID}\"",
tokens.length > 0);
assertEquals(commandOutput, "Success:", tokens[0]);
return Integer.parseInt(tokens[tokens.length-1]);
}
private String getCreateManagedProfileCommandOutput(int parentUserId)
throws DeviceNotAvailableException {
String command = "pm create-user --profileOf " + parentUserId + " --managed "
+ "TestProfile_" + System.currentTimeMillis();
CLog.d("Starting command " + command);
String commandOutput = getDevice().executeShellCommand(command);
CLog.d("Output for command " + command + ": " + commandOutput);
return commandOutput;
}
protected int getPrimaryUser() throws DeviceNotAvailableException {
return getDevice().getPrimaryUserId();
}
protected int getUserSerialNumber(int userId) throws DeviceNotAvailableException{
// TODO: Move this logic to ITestDevice.
// dumpsys user output contains lines like "UserInfo{0:Owner:13} serialNo=0 isPrimary=true"
final Pattern pattern =
Pattern.compile("UserInfo\\{" + userId + ":[^\\n]*\\sserialNo=(\\d+)\\s");
final String commandOutput = getDevice().executeShellCommand("dumpsys user");
final Matcher matcher = pattern.matcher(commandOutput);
if (matcher.find()) {
return Integer.parseInt(matcher.group(1));
}
fail("Couldn't find serial number for user " + userId);
return -1;
}
protected boolean setProfileOwner(String componentName, int userId, boolean expectFailure)
throws DeviceNotAvailableException {
String command = "dpm set-profile-owner --user " + userId + " '" + componentName + "'";
String commandOutput = getDevice().executeShellCommand(command);
boolean success = commandOutput.startsWith("Success:");
// If we succeeded always log, if we are expecting failure don't log failures
// as call stacks for passing tests confuse the logs.
if (success || !expectFailure) {
CLog.d("Output for command " + command + ": " + commandOutput);
} else {
CLog.d("Command Failed " + command);
}
return success;
}
protected void setProfileOwnerOrFail(String componentName, int userId)
throws Exception {
if (!setProfileOwner(componentName, userId, /*expectFailure*/ false)) {
if (userId != 0) { // don't remove system user.
removeUser(userId);
}
fail("Failed to set profile owner");
}
}
protected void setProfileOwnerExpectingFailure(String componentName, int userId)
throws Exception {
if (setProfileOwner(componentName, userId, /* expectFailure =*/ true)) {
if (userId != 0) { // don't remove system user.
removeUser(userId);
}
fail("Setting profile owner should have failed.");
}
}
private String setDeviceAdminInner(String componentName, int userId)
throws DeviceNotAvailableException {
String command = "dpm set-active-admin --user " + userId + " '" + componentName + "'";
String commandOutput = getDevice().executeShellCommand(command);
return commandOutput;
}
protected void setDeviceAdmin(String componentName, int userId)
throws DeviceNotAvailableException {
String commandOutput = setDeviceAdminInner(componentName, userId);
CLog.d("Output for command " + commandOutput
+ ": " + commandOutput);
assertTrue(commandOutput + " expected to start with \"Success:\"",
commandOutput.startsWith("Success:"));
}
protected void setDeviceAdminExpectingFailure(String componentName, int userId,
String errorMessage) throws DeviceNotAvailableException {
String commandOutput = setDeviceAdminInner(componentName, userId);
if (!commandOutput.contains(errorMessage)) {
fail(commandOutput + " expected to contain \"" + errorMessage + "\"");
}
}
protected boolean setDeviceOwner(String componentName, int userId, boolean expectFailure)
throws DeviceNotAvailableException {
String command = "dpm set-device-owner --user " + userId + " '" + componentName + "'";
String commandOutput = getDevice().executeShellCommand(command);
boolean success = commandOutput.startsWith("Success:");
// If we succeeded always log, if we are expecting failure don't log failures
// as call stacks for passing tests confuse the logs.
if (success || !expectFailure) {
CLog.d("Output for command " + command + ": " + commandOutput);
} else {
CLog.d("Command Failed " + command);
}
return success;
}
protected void setDeviceOwnerOrFail(String componentName, int userId)
throws Exception {
assertTrue(setDeviceOwner(componentName, userId, /* expectFailure =*/ false));
}
protected void setDeviceOwnerExpectingFailure(String componentName, int userId)
throws Exception {
assertFalse(setDeviceOwner(componentName, userId, /* expectFailure =*/ true));
}
protected String getSettings(String namespace, String name, int userId)
throws DeviceNotAvailableException {
String command = "settings --user " + userId + " get " + namespace + " " + name;
String commandOutput = getDevice().executeShellCommand(command);
CLog.d("Output for command " + command + ": " + commandOutput);
return commandOutput.replace("\n", "").replace("\r", "");
}
protected void putSettings(String namespace, String name, String value, int userId)
throws DeviceNotAvailableException {
String command = "settings --user " + userId + " put " + namespace + " " + name
+ " " + value;
String commandOutput = getDevice().executeShellCommand(command);
CLog.d("Output for command " + command + ": " + commandOutput);
}
protected boolean removeAdmin(String componentName, int userId)
throws DeviceNotAvailableException {
String command = "dpm remove-active-admin --user " + userId + " '" + componentName + "'";
String commandOutput = getDevice().executeShellCommand(command);
CLog.d("Output for command " + command + ": " + commandOutput);
return commandOutput.startsWith("Success:");
}
// Tries to remove and profile or device owners it finds.
protected void removeOwners() throws DeviceNotAvailableException {
String command = "dumpsys device_policy";
String commandOutput = getDevice().executeShellCommand(command);
String[] lines = commandOutput.split("\\r?\\n");
for (int i = 0; i < lines.length; ++i) {
String line = lines[i].trim();
if (line.contains("Profile Owner")) {
// Line is "Profile owner (User <id>):
String[] tokens = line.split("\\(|\\)| ");
int userId = Integer.parseInt(tokens[4]);
i++;
line = lines[i].trim();
// Line is admin=ComponentInfo{<component>}
tokens = line.split("\\{|\\}");
String componentName = tokens[1];
CLog.w("Cleaning up profile owner " + userId + " " + componentName);
removeAdmin(componentName, userId);
} else if (line.contains("Device Owner:")) {
i++;
line = lines[i].trim();
// Line is admin=ComponentInfo{<component>}
String[] tokens = line.split("\\{|\\}");
String componentName = tokens[1];
// Skip to user id line.
i += 4;
line = lines[i].trim();
// Line is User ID: <N>
tokens = line.split(":");
int userId = Integer.parseInt(tokens[1].trim());
CLog.w("Cleaning up device owner " + userId + " " + componentName);
removeAdmin(componentName, userId);
}
}
}
/**
* Runs pm enable command to enable a package or component. Returns the command result.
*/
protected String enableComponentOrPackage(int userId, String packageOrComponent)
throws DeviceNotAvailableException {
String command = "pm enable --user " + userId + " " + packageOrComponent;
String result = getDevice().executeShellCommand(command);
CLog.d("Output for command " + command + ": " + result);
return result;
}
/**
* Runs pm disable command to disable a package or component. Returns the command result.
*/
protected String disableComponentOrPackage(int userId, String packageOrComponent)
throws DeviceNotAvailableException {
String command = "pm disable --user " + userId + " " + packageOrComponent;
String result = getDevice().executeShellCommand(command);
CLog.d("Output for command " + command + ": " + result);
return result;
}
protected interface SuccessCondition {
boolean check() throws Exception;
}
protected void assertUserGetsRemoved(int userId) throws Exception {
tryWaitForSuccess(() -> !listUsers().contains(userId),
"The user " + userId + " has not been removed",
TIMEOUT_USER_REMOVED_MILLIS
);
}
protected void tryWaitForSuccess(SuccessCondition successCondition, String failureMessage,
long timeoutMillis) throws Exception {
long epoch = System.currentTimeMillis();
while (System.currentTimeMillis() - epoch <= timeoutMillis) {
Thread.sleep(WAIT_SAMPLE_INTERVAL_MILLIS);
if (successCondition.check()) {
return;
}
}
fail(failureMessage);
}
/**
* Sets a user restriction via SetPolicyActivity.
* <p>IMPORTANT: The package that contains SetPolicyActivity must have been installed prior to
* calling this method.
* @param key user restriction key
* @param value true if we should set the restriction, false if we should clear it
* @param userId userId to set/clear the user restriction on
* @param packageName package where SetPolicyActivity is installed
* @return The output of the command
* @throws DeviceNotAvailableException
*/
protected String changeUserRestriction(String key, boolean value, int userId,
String packageName) throws DeviceNotAvailableException {
return changePolicy(getUserRestrictionCommand(value),
" --es extra-restriction-key " + key, userId, packageName);
}
/**
* Same as {@link #changeUserRestriction(String, boolean, int, String)} but asserts that it
* succeeds.
*/
protected void changeUserRestrictionOrFail(String key, boolean value, int userId,
String packageName) throws DeviceNotAvailableException {
changePolicyOrFail(getUserRestrictionCommand(value), " --es extra-restriction-key " + key,
userId, packageName);
}
/**
* Sets some policy via SetPolicyActivity.
* <p>IMPORTANT: The package that contains SetPolicyActivity must have been installed prior to
* calling this method.
* @param command command to pass to SetPolicyActivity
* @param extras extras to pass to SetPolicyActivity
* @param userId the userId where we invoke SetPolicyActivity
* @param packageName where SetPolicyActivity is installed
* @return The output of the command
* @throws DeviceNotAvailableException
*/
protected String changePolicy(String command, String extras, int userId, String packageName)
throws DeviceNotAvailableException {
String adbCommand = "am start -W --user " + userId
+ " -c android.intent.category.DEFAULT "
+ " --es extra-command " + command
+ " " + extras
+ " " + packageName + "/.SetPolicyActivity";
String commandOutput = getDevice().executeShellCommand(adbCommand);
CLog.d("Output for command " + adbCommand + ": " + commandOutput);
return commandOutput;
}
/**
* Same as {@link #changePolicy(String, String, int, String)} but asserts that it succeeds.
*/
protected void changePolicyOrFail(String command, String extras, int userId,
String packageName) throws DeviceNotAvailableException {
String commandOutput = changePolicy(command, extras, userId, packageName);
assertTrue("Command was expected to succeed " + commandOutput,
commandOutput.contains("Status: ok"));
}
private String getUserRestrictionCommand(boolean setRestriction) {
if (setRestriction) {
return "add-restriction";
}
return "clear-restriction";
}
/**
* Set lockscreen password / work challenge for the given user, null or "" means clear
*/
protected void changeUserCredential(String newCredential, String oldCredential, int userId)
throws DeviceNotAvailableException {
final String oldCredentialArgument = (oldCredential == null || oldCredential.isEmpty()) ? ""
: ("--old " + oldCredential);
if (newCredential != null && !newCredential.isEmpty()) {
String commandOutput = getDevice().executeShellCommand(String.format(
"cmd lock_settings set-password --user %d %s %s", userId, oldCredentialArgument,
newCredential));
if (!commandOutput.startsWith("Password set to")) {
fail("Failed to set user credential: " + commandOutput);
}
} else {
String commandOutput = getDevice().executeShellCommand(String.format(
"cmd lock_settings clear --user %d %s", userId, oldCredentialArgument));
if (!commandOutput.startsWith("Lock credential cleared")) {
fail("Failed to clear user credential: " + commandOutput);
}
}
}
/**
* Verifies the lock credential for the given user.
*
* @param credential The credential to verify.
* @param userId The id of the user.
*/
protected void verifyUserCredential(String credential, int userId)
throws DeviceNotAvailableException {
String commandOutput = verifyUserCredentialCommandOutput(credential, userId);
if (!commandOutput.startsWith(VERIFY_CREDENTIAL_CONFIRMATION)) {
fail("Failed to verify user credential: " + commandOutput);
}
}
/**
* Verifies the lock credential for the given user, which unlocks the user, and returns
* whether it was successful or not.
*
* @param credential The credential to verify.
* @param userId The id of the user.
*/
protected boolean verifyUserCredentialIsCorrect(String credential, int userId)
throws DeviceNotAvailableException {
String commandOutput = verifyUserCredentialCommandOutput(credential, userId);
return commandOutput.startsWith(VERIFY_CREDENTIAL_CONFIRMATION);
}
/**
* Verifies the lock credential for the given user, which unlocks the user. Returns the
* commandline output, which includes whether the verification was successful.
*
* @param credential The credential to verify.
* @param userId The id of the user.
* @return The command line output.
*/
protected String verifyUserCredentialCommandOutput(String credential, int userId)
throws DeviceNotAvailableException {
final String credentialArgument = (credential == null || credential.isEmpty())
? "" : ("--old " + credential);
String commandOutput = getDevice().executeShellCommand(String.format(
"cmd lock_settings verify --user %d %s", userId, credentialArgument));
return commandOutput;
}
protected void wakeupAndDismissKeyguard() throws Exception {
executeShellCommand("input keyevent KEYCODE_WAKEUP");
executeShellCommand("wm dismiss-keyguard");
}
protected void pressPowerButton() throws Exception {
executeShellCommand("input keyevent KEYCODE_POWER");
}
private void stayAwake() throws Exception {
executeShellCommand(
"settings put global stay_on_while_plugged_in " + STAY_ON_WHILE_PLUGGED_IN_FLAGS);
}
protected void startActivityAsUser(int userId, String packageName, String activityName)
throws Exception {
wakeupAndDismissKeyguard();
String command = "am start -W --user " + userId + " " + packageName + "/" + activityName;
getDevice().executeShellCommand(command);
}
protected String getDefaultLauncher() throws Exception {
final String PREFIX = "Launcher: ComponentInfo{";
final String POSTFIX = "}";
final String commandOutput =
getDevice().executeShellCommand("cmd shortcut get-default-launcher");
if (commandOutput == null) {
return null;
}
String[] lines = commandOutput.split("\\r?\\n");
for (String line : lines) {
if (line.startsWith(PREFIX) && line.endsWith(POSTFIX)) {
return line.substring(PREFIX.length(), line.length() - POSTFIX.length());
}
}
throw new Exception("Default launcher not found");
}
}