Properly Tested Example
If need any help just mail @ rajeshsaini890@gmail.com
first you need to download rsyncdroid project from google project by svn
http://code.google.com/p/rsyncdroid/source/checkout
type command in terminal sudo apt-get install subversion
to install svn then copy svn command from project page and paste to terminal
then import the downloaded project to eclipse
now
first replace the complete code given in Rsyncdroid.class file with the give below
and now copy rsync binary file form R.raw.rsync and paste it to device folder /system/xbin/rsync you can use rootexplorer.apk to do this
now
you need to generate dss_key and dss_key.pub by using dropbearkey
then put dss_key and dss_key.pub file in sdcard.
then copy contents of dss_key.pub and paste to the server or your computers folder Home/.ssh/ AuthorizedKeys file.
This is posswordless authentication.
now put your host username in rsync command source directory and resource directory and path of dss_key file in sdcard as given below
and run program.
import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.Writer;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.util.ArrayList;
import java.util.List;
import android.util.Log;
import android.app.Activity;
import android.content.Context;
import android.content.ContextWrapper;
import android.os.Bundle;
import android.view.View;
import android.view.View.OnClickListener;
import android.widget.Button;
import android.widget.CheckBox;
import android.widget.EditText;
import android.widget.TextView;
import android.widget.Toast;
public class RsyncDroid extends Activity {
private static final String LOG_TAG = "RsyncDro";
private static final String RSYNCD_DIR = "/sdcard/rsyncdroid/";
private static final String RSYNCD_CONF = "/sdcard/rsyncdroid/rsyncd.conf";
private String RSYNCD_BIN = "/system/xbin/rsync";
private String RSYNC_PATH = "";
private String RSYNC_BIN = "rsync";
private Process process;
private Boolean USE_ROOT = true;
// private String MY_USERNAME = "";
private static final String[] DEFAULT_CONF = { "uid=0", "gid=0",
"read only = yes", "use chroot = no", "", "[sdcard]",
" path = /sdcard/Urotab/", " comment = SD Card" };
OutputStream os;
CheckBox CheckboxRunning;
Button btnStart;
Button btnStop;
EditText txtBox;
TextView conftxt;
Boolean bool1 = true;
/** Called when the activity is first created. */
@Override
public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.main);
CheckboxRunning = (CheckBox) findViewById(R.id.Running);
txtBox = (EditText) findViewById(R.id.RsyncdConf);
conftxt = (TextView) findViewById(R.id.ConfText);
btnStart = (Button) findViewById(R.id.ButtonStart);
btnStart.setOnClickListener(new OnClickListener() {
public void onClick(View v) {
// save conf in file
saveConf();
startRsync();
Log.d(LOG_TAG, "onCreate() rsync started...");
changeStatus();
if (statusRsync()) {
showMsg("rsync started");
}
setResult(android.app.Activity.RESULT_OK);
}
});
btnStop = (Button) findViewById(R.id.ButtonStop);
btnStop.setOnClickListener(new OnClickListener() {
public void onClick(View v) {
if (stopRsync()) {
showMsg("rsync stopped");
setResult(android.app.Activity.RESULT_OK);
}
changeStatus();
}
});
// load configuration in txtBox
txtBox.setText(loadConf().toString());
// MY_USERNAME=getUsername();
// change checkbox status
changeStatus();
RSYNC_PATH = rsync_path();
RSYNCD_BIN = RSYNC_PATH + RSYNC_BIN;
if (!new File(RSYNCD_BIN).exists()) {
installRsync(RSYNCD_BIN, R.raw.rsync);
showMsg("rsync installed on " + RSYNCD_BIN);
}
}
public void changeStatus() {
if (statusRsync()) {
CheckboxRunning.setChecked(true);
txtBox.setVisibility(View.INVISIBLE);
conftxt.setVisibility(View.INVISIBLE);
} else {
CheckboxRunning.setChecked(false);
txtBox.setVisibility(View.VISIBLE);
conftxt.setVisibility(View.VISIBLE);
}
}
@SuppressWarnings("static-access")
public void startRsync() {
if (!new File(RSYNCD_BIN).exists()) {
showMsg("rsync not installed");
return;
}
Thread thread = new Thread() {
@Override
public void run() {
try {
List<String> commands = new ArrayList<String>();
int i = 1, j = 1;
commands.add("/rsync".substring(i));
commands.add("-vvvrHrltD");
commands.add("--chmod=Du+rwx,go-rwx,Fu+rw,go-rw");
commands.add("--no-perms");
commands.add("-e");
commands.add("/ssh".substring(j) + " -y -p "
+ Integer.valueOf(22)
+ " -i '/sdcard/dss_key' ");
commands.add("/sdcard/Urotab/");
commands.add(("root") + "@" + "YOUR IP"
+ ":" + "Desktop/urosecure/");
ProcessBuilder pb = new ProcessBuilder(commands);
try {
Process prs = pb.start();
InputStream stderr = prs.getErrorStream();
InputStream stdout = prs.getInputStream();
BufferedReader stdoutReader = new BufferedReader(
new InputStreamReader(stdout));
BufferedReader stderrReader = new BufferedReader(
new InputStreamReader(stderr));
System.out
.println("Here is the output from stdout:");
while (true) {
String line = stdoutReader.readLine();
if (line == null) {
stdoutReader.close();
break;
}
System.out.println(line);
}
System.out
.println("Here is the output from stderr:");
while (true) {
String line = stderrReader.readLine();
if (line == null) {
stderrReader.close();
break;
}
System.out.println(line);
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
} catch (Exception e) {
e.printStackTrace();
}
}
};
thread.start();
try {
Thread.currentThread().sleep(2000);// sleep for 2000 ms
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public boolean stopRsync() {
String pid;
String temp;
pid = "";
int i;
try {
Process p = Runtime.getRuntime().exec("ps");
p.waitFor();
BufferedReader stdInput = new BufferedReader(new InputStreamReader(
p.getInputStream()));
while ((temp = stdInput.readLine()) != null) {
// Log.d(LOG_TAG, "stopRsync() temp='"+temp+"'");
if (temp.contains(RSYNCD_BIN)) {
// Log.d(LOG_TAG, "statusRsync() temp='"+temp+"'");
String[] cmdArray = temp.split(" +");
for (i = 0; i < cmdArray.length; i++) {
Log.d(LOG_TAG, "loop i=" + i + " => " + cmdArray[i]);
}
pid = cmdArray[1];
}
}
} catch (IOException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
Log.d(LOG_TAG, "statusRsync() pid='" + pid + "'");
// if pid
if (pid != "") {
Log.d(LOG_TAG, "statusRsync() killing='" + pid + "' ...");
try {
if (USE_ROOT) {
process = Runtime.getRuntime().exec("su -c sh");
OutputStream os = process.getOutputStream();
writeLine(os, "kill -9 " + pid);
os.flush();
writeLine(os, "exit \n");
os.flush();
process.waitFor();
return true;
} else {
process = Runtime.getRuntime().exec("sh");
OutputStream os = process.getOutputStream();
writeLine(os, "kill -9 " + pid);
os.flush();
writeLine(os, "exit \n");
os.flush();
process.waitFor();
return true;
}
} catch (IOException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
Log.d(LOG_TAG, "statusRsync() pid empty='" + pid + "'");
return false;
}
public boolean statusRsync() {
boolean run;
String temp;
run = false;
Log.d(LOG_TAG, "statusRsync() init");
try {
Process p = Runtime.getRuntime().exec("ps");
p.waitFor();
BufferedReader stdInput = new BufferedReader(new InputStreamReader(
p.getInputStream()));
while ((temp = stdInput.readLine()) != null) {
// Log.d(LOG_TAG, "statusRsync() temp='"+temp+"'");
if (temp.contains("app_bin/rsync")) {
Log.d(LOG_TAG, "statusRsync() FOUND temp='" + temp + "'");
run = true;
}
}
} catch (IOException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
return run;
}
public String loadConf() {
String Script = "";
File rsyncd_conf_folder = new File(RSYNCD_DIR);
if (!rsyncd_conf_folder.exists()) {
Log.d(LOG_TAG, "Creating " + RSYNCD_DIR + " folder");
rsyncd_conf_folder.mkdir();
showMsg("Created " + RSYNCD_DIR + " folder");
} else {
Log.d(LOG_TAG, RSYNCD_DIR + " exists");
}
// create rsyncd.conf
if (!new File(RSYNCD_CONF).exists()) {
showMsg("rsyncd.conf no exists");
for (int i = 0; i < DEFAULT_CONF.length; i++) {
Script += DEFAULT_CONF[i] + "\n";
}
return Script;
}
try {
BufferedReader in = new BufferedReader(new FileReader(RSYNCD_CONF));
String str;
while ((str = in.readLine()) != null) {
Script += str + "\n";
}
in.close();
} catch (Exception ex) {
showMsg("Can't read rsyncd.conf");
return Script;
}
return Script;
}
public void saveConf() {
Writer output = null;
Log.d(LOG_TAG, "saveConf() init");
try {
output = new BufferedWriter(new FileWriter(RSYNCD_CONF));
output.write(txtBox.getText().toString());
output.close();
Log.d(LOG_TAG, "saveConf() saved and closed");
} catch (IOException e) {
e.printStackTrace();
}
}
public void showMsg(String txt) {
CharSequence text = txt;
int duration = Toast.LENGTH_LONG;
Toast toast = Toast.makeText(this, text, duration);
toast.show();
Log.d(LOG_TAG, "showMsg() txt='" + txt + "'");
}
public static void writeLine(OutputStream os, String value)
throws IOException {
String line = value + "\n";
os.write(line.getBytes());
}
private void installRsync(String ff_file, int rawid) {
Log.d(LOG_TAG, "installRsync() **rsync_abspath=" + ff_file + "**");
if (!new File(ff_file).exists()) {
InputStream rsyncraw;
Log.d(LOG_TAG, "installRsync() **no exists, copy...**");
try {
rsyncraw = getResources().openRawResource(rawid);
} catch (Exception e) {
e.printStackTrace();
Log.d(LOG_TAG, "installRsync() **Exception**");
return;
} finally {
Log.d(LOG_TAG, "installRsync() ** OPENED rsync_abspath="
+ ff_file + "**");
}
BufferedOutputStream fOut = null;
try {
fOut = new BufferedOutputStream(new FileOutputStream(ff_file));
byte[] buffer = new byte[32 * 1024];
int bytesRead = 0;
while ((bytesRead = rsyncraw.read(buffer)) != -1) {
fOut.write(buffer, 0, bytesRead);
}
Log.d(LOG_TAG, "installRsync() **no exists, copy done**");
Runtime.getRuntime().exec("chmod 755 " + ff_file);
} catch (Exception e) {
e.printStackTrace();
Log.d(LOG_TAG, "installRsync() **Exception**");
} finally {
try {
rsyncraw.close();
fOut.close();
} catch (IOException e) {
e.printStackTrace();
Log.d(LOG_TAG, "installRsync() **Exception**");
}
}
}
}
private String rsync_path() {
ContextWrapper cw = new ContextWrapper(getBaseContext());
File directory = cw.getDir("bin", Context.MODE_PRIVATE);
String rsync_abspath = directory + "/";
return rsync_abspath;
}
/*
* private String getUsername() { String temp=""; try{ Process p =
* Runtime.getRuntime().exec("whoami"); p.waitFor();
*
* BufferedReader stdInput = new BufferedReader(new
* InputStreamReader(p.getInputStream())); while ( (temp =
* stdInput.readLine()) != null ) { Log.d(LOG_TAG,
* "getUsername() temp='"+temp+"'"); if ( temp != "" ) { return temp; } }
*
* } catch (IOException e) { e.printStackTrace(); } catch
* (InterruptedException e) { e.printStackTrace(); }
*
* return temp; }
*/
}
