static {

// Application::onCreate would be a better place for this

// librootjava's logger

Logger.setLogTag("librootjava");

Logger.setDebugLogging(BuildConfig.DEBUG);

// libsuperuser's logger

Debug.setDebug(BuildConfig.DEBUG);

}

private Button button = null;

private TextView textView = null;

private ImageView imageView = null;

private Shell.Interactive shell = null;

@Override

protected void onCreate(Bundle savedInstanceState) {

super.onCreate(savedInstanceState);

setContentView(R.layout.activity_main);

button = findViewById(R.id.button);

textView = findViewById(R.id.textView);

textView.setHorizontallyScrolling(true);

textView.setMovementMethod(new ScrollingMovementMethod());

imageView = findViewById(R.id.imageView);

/* As we declare and construct ipcReceiver in the class definition rather than constructing

ipcReceiver.setContext(this);

/* Cleanup leftover files from our cache directory. This is not exactly an elegant way to

(new Thread(new Runnable() {

@Override

public void run() {

RootJava.cleanupCache(MainActivity.this);

}

})).start();

}

@Override

protected void onDestroy() {

/* Disconnect and release resources. If onConnect() is still running, disconnect will occur

ipcReceiver.release();

super.onDestroy();

}

private void uiLog(final String msg) {

// Log a string to our textView, making sure the addition runs on the UI thread

runOnUiThread(new Runnable() {

@Override

public void run() {

textView.append(msg + "\n");

}

});

}

private final RootIPCReceiver<IIPC> ipcReceiver = new RootIPCReceiver<IIPC>(this, 0) {

@Override

public void onConnect(IIPC ipc) {

/* This is always called from a background thread, so you can do blocking operations

Logger.dp("IPC", "onConnect");

try {

uiLog("");

uiLog("Connected");

// Get the other end's PID

uiLog("");

uiLog(String.format(Locale.ENGLISH, "Remote pid: %d", ipc.getPid()));

uiLog("");

// This file is actually readable directly from your app, but it's a nice short

// text file that serves well as an example

uiLog("Example InputStream:");

InputStream is = RemoteInputStream.toInputStream(ipc.openFileForReading("/system/bin/am"));

if (is != null) {

try {

BufferedReader br = new BufferedReader(new InputStreamReader(is));

try {

while (br.ready()) {

uiLog(br.readLine());

}

} catch (IOException e) {

uiLog(e.getMessage());

Logger.ex(e);

}

} finally {

try {

is.close();

} catch (IOException e) {

// no action required

}

}

}

uiLog("");

// Receive an automatically reconstructed PassedObject. This is a copy of the

// object on the other end, so changing it here does not change it there.

PassedData pd = ipc.getSomeData();

uiLog(String.format(Locale.ENGLISH, "getSomeData(): %d %d %s", pd.getA(), pd.getB(), pd.getC()));

// Run a command on the root end and get the output back

List<String> output = ipc.run("ls -l /init");

if (output != null) {

for (String line : output) {

// should show the same output as exampleWork1 and exampleWork2

uiLog("exampleWorkX: " + line);

}

}

// Get our icon through root

final Bitmap bitmap = ipc.getIcon();

runOnUiThread(new Runnable() {

@Override

public void run() {

imageView.setImageBitmap(bitmap);

}

});

// Ping-pong, get some thread info through a callback

final long ipcThreadId = Thread.currentThread().getId();

runOnUiThread(new Runnable() {

@Override

public void run() {

uiLog(String.format(Locale.ENGLISH, "Ping: thisUI[%d] thisIPC[%d]", Thread.currentThread().getId(), ipcThreadId));

}

});

// Note that we implement IPingCallback.Stub rather than IPingCallback

ipc.ping(new IPingCallback.Stub() {

/* The pong callback may be executed on the same thread as the ping call is

@Override

public void pong(long rootMainThreadId, long rootCallThreadId) {

uiLog(String.format(Locale.ENGLISH, "Pong: rootMain[%d] rootCall[%d] thisCallback[%d]", rootMainThreadId, rootCallThreadId, Thread.currentThread().getId()));

}

});

try {

// give the root end some time to send pong replies

Thread.sleep(1000);

} catch (InterruptedException e) {

// no action required

}

// Our work here is done

disconnect();

} catch (RemoteException e) {

uiLog("RemoteException during IPC. Connection lost?");

Logger.ex(e);

}

}

@Override

public void onDisconnect(IIPC ipc) {

// May or may not be called from a background thread

uiLog("");

uiLog("Disconnected");

Logger.dp("IPC", "onDisconnect");

}

};

public void onRunClick(View v) {

button.setEnabled(false);

uiLog("Executing script:");

List<String> script = RootMain.getLaunchScript(this, null, null);

for (String line : script) {

Logger.d("%s", line);

uiLog(line);

}

uiLog("");

// Open a root shell if we don't have one yet

if ((shell == null) || !shell.isRunning()) {

shell = (new Shell.Builder())

.useSU()

.open(new Shell.OnCommandResultListener() {

@Override

public void onCommandResult(int commandCode, int exitCode, List<String> output) {

if (exitCode != SHELL_RUNNING) {

// we couldn't open the shell, enable the button

runOnUiThread(new Runnable() {

@Override

public void run() {

button.setEnabled(true);

}

});

}

}

});

}

// Execute the script (asynchronously)

shell.addCommand(script, 0, new Shell.OnCommandLineListener() {

@Override

public void onCommandResult(int commandCode, int exitCode) {

// execution finished, enable the button

runOnUiThread(new Runnable() {

@Override

public void run() {

button.setEnabled(true);

}

});

}

@Override

public void onLine(String line) {

// we receive the output of exampleWork1/2 here

uiLog(line);

}

});

/*

}