/*
|
* Copyright (C) 2019 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.server.role;
|
|
import android.Manifest;
|
import android.annotation.MainThread;
|
import android.annotation.NonNull;
|
import android.annotation.Nullable;
|
import android.content.ComponentName;
|
import android.content.Context;
|
import android.content.Intent;
|
import android.content.ServiceConnection;
|
import android.content.pm.PackageManager;
|
import android.content.pm.ResolveInfo;
|
import android.content.pm.ServiceInfo;
|
import android.os.Binder;
|
import android.os.Bundle;
|
import android.os.IBinder;
|
import android.os.RemoteCallback;
|
import android.os.RemoteException;
|
import android.os.UserHandle;
|
import android.service.sms.FinancialSmsService;
|
import android.service.sms.IFinancialSmsService;
|
import android.util.Slog;
|
|
import com.android.internal.annotations.GuardedBy;
|
|
import java.io.PrintWriter;
|
import java.util.ArrayList;
|
|
/**
|
* This class binds to {@code FinancialSmsService}.
|
*/
|
final class FinancialSmsManager {
|
|
private static final String TAG = "FinancialSmsManager";
|
|
private final Context mContext;
|
private final Object mLock = new Object();
|
|
@GuardedBy("mLock")
|
private ServiceConnection mServiceConnection;
|
|
@GuardedBy("mLock")
|
private IFinancialSmsService mRemoteService;
|
|
@GuardedBy("mLock")
|
private ArrayList<Command> mQueuedCommands;
|
|
FinancialSmsManager(Context context) {
|
mContext = context;
|
}
|
|
@Nullable
|
ServiceInfo getServiceInfo() {
|
final String packageName =
|
mContext.getPackageManager().getServicesSystemSharedLibraryPackageName();
|
if (packageName == null) {
|
Slog.w(TAG, "no external services package!");
|
return null;
|
}
|
|
final Intent intent = new Intent(FinancialSmsService.ACTION_FINANCIAL_SERVICE_INTENT);
|
intent.setPackage(packageName);
|
final ResolveInfo resolveInfo = mContext.getPackageManager().resolveService(intent,
|
PackageManager.GET_SERVICES);
|
if (resolveInfo == null || resolveInfo.serviceInfo == null) {
|
Slog.w(TAG, "No valid components found.");
|
return null;
|
}
|
return resolveInfo.serviceInfo;
|
}
|
|
@Nullable
|
private ComponentName getServiceComponentName() {
|
final ServiceInfo serviceInfo = getServiceInfo();
|
if (serviceInfo == null) return null;
|
|
final ComponentName name = new ComponentName(serviceInfo.packageName, serviceInfo.name);
|
if (!Manifest.permission.BIND_FINANCIAL_SMS_SERVICE.equals(serviceInfo.permission)) {
|
Slog.w(TAG, name.flattenToShortString() + " does not require permission "
|
+ Manifest.permission.BIND_FINANCIAL_SMS_SERVICE);
|
return null;
|
}
|
|
return name;
|
}
|
|
void reset() {
|
synchronized (mLock) {
|
if (mServiceConnection != null) {
|
mContext.unbindService(mServiceConnection);
|
mServiceConnection = null;
|
} else {
|
Slog.d(TAG, "reset(): service is not bound. Do nothing.");
|
}
|
}
|
}
|
|
/**
|
* Run a command, starting the service connection if necessary.
|
*/
|
private void connectAndRun(@NonNull Command command) {
|
synchronized (mLock) {
|
if (mRemoteService != null) {
|
try {
|
command.run(mRemoteService);
|
} catch (RemoteException e) {
|
Slog.w(TAG, "exception calling service: " + e);
|
}
|
return;
|
} else {
|
if (mQueuedCommands == null) {
|
mQueuedCommands = new ArrayList<>(1);
|
}
|
mQueuedCommands.add(command);
|
// If we're already connected, don't create a new connection, just leave - the
|
// command will be run when the service connects
|
if (mServiceConnection != null) return;
|
}
|
|
// Create the connection
|
mServiceConnection = new ServiceConnection() {
|
@Override
|
public void onServiceConnected(ComponentName name, IBinder service) {
|
synchronized (mLock) {
|
mRemoteService = IFinancialSmsService.Stub.asInterface(service);
|
if (mQueuedCommands != null) {
|
final int size = mQueuedCommands.size();
|
for (int i = 0; i < size; i++) {
|
final Command queuedCommand = mQueuedCommands.get(i);
|
try {
|
queuedCommand.run(mRemoteService);
|
} catch (RemoteException e) {
|
Slog.w(TAG, "exception calling " + name + ": " + e);
|
}
|
}
|
mQueuedCommands = null;
|
}
|
}
|
}
|
|
@Override
|
@MainThread
|
public void onServiceDisconnected(ComponentName name) {
|
synchronized (mLock) {
|
mRemoteService = null;
|
}
|
}
|
|
@Override
|
public void onBindingDied(ComponentName name) {
|
synchronized (mLock) {
|
mRemoteService = null;
|
}
|
}
|
|
@Override
|
public void onNullBinding(ComponentName name) {
|
synchronized (mLock) {
|
mRemoteService = null;
|
}
|
}
|
};
|
|
final ComponentName component = getServiceComponentName();
|
if (component != null) {
|
final Intent intent = new Intent();
|
intent.setComponent(component);
|
final long token = Binder.clearCallingIdentity();
|
try {
|
mContext.bindServiceAsUser(intent, mServiceConnection, Context.BIND_AUTO_CREATE,
|
UserHandle.getUserHandleForUid(UserHandle.getCallingUserId()));
|
} finally {
|
Binder.restoreCallingIdentity(token);
|
}
|
}
|
}
|
}
|
|
void getSmsMessages(RemoteCallback callback, @Nullable Bundle params) {
|
connectAndRun((service) -> service.getSmsMessages(callback, params));
|
}
|
|
void dump(String prefix, PrintWriter pw) {
|
final ComponentName impl = getServiceComponentName();
|
pw.print(prefix); pw.print("User ID: "); pw.println(UserHandle.getCallingUserId());
|
pw.print(prefix); pw.print("Queued commands: ");
|
if (mQueuedCommands == null) {
|
pw.println("N/A");
|
} else {
|
pw.println(mQueuedCommands.size());
|
}
|
pw.print(prefix); pw.print("Implementation: ");
|
if (impl == null) {
|
pw.println("N/A");
|
return;
|
}
|
pw.println(impl.flattenToShortString());
|
}
|
|
private interface Command {
|
void run(IFinancialSmsService service) throws RemoteException;
|
}
|
}
|
