[dumload.git] / src / com / joshuawise / dumload / Uploader.java

package com.joshuawise.dumload;

import java.io.InputStream;
import java.io.OutputStream;

import android.app.Notification;
import android.app.NotificationManager;
import android.app.PendingIntent;
import android.app.Service;
import android.content.Context;
import android.content.Intent;
import android.content.SharedPreferences;
import android.net.Uri;
import android.os.Bundle;
import android.os.Handler;
import android.os.IBinder;
import android.os.Looper;
import android.os.Message;
import android.os.Messenger;
import android.os.SystemClock;
import android.preference.PreferenceManager;
import android.util.Log;
import android.widget.RemoteViews;
import android.widget.Toast;

import com.jcraft.jsch.Channel;
import com.jcraft.jsch.ChannelExec;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.Session;
import com.jcraft.jsch.UIKeyboardInteractive;
import com.jcraft.jsch.UserInfo;

public class Uploader extends Service implements Runnable, UserInfo, UIKeyboardInteractive {
	private Uri uri;
	private String homedir;
	private Thread me;
	private static final int HELPME_ID = 1;
	private RemoteViews remote;
	private int thenotifid;
	private Notification thenotif;
	private String headline;
	private String dest;
	
	private InputStream is;
	
	public Object _theObject;

	private void sayNullNotification(final String scroller, final String headline, final String description)
	{
		int bogon = (int)SystemClock.elapsedRealtime();
		NotificationManager mNotificationManager = (NotificationManager)getSystemService(Context.NOTIFICATION_SERVICE);
		Notification notification = new Notification(R.drawable.icon, scroller, System.currentTimeMillis());

		Intent intent = new Intent(this, NotifSlave.class);
					
		intent.setAction("com.joshuawise.dumload.NotifSlave");
		/* no extras to make the notifslave die */
		intent.setData((Uri.parse("suckit://"+SystemClock.elapsedRealtime())));
				
		PendingIntent contentIntent = PendingIntent.getActivity(this, 0, intent, 0);
		notification.defaults |= Notification.DEFAULT_VIBRATE;
		notification.flags |= Notification.FLAG_AUTO_CANCEL;
		notification.setLatestEventInfo(getApplicationContext(), headline, description, contentIntent);
				
		mNotificationManager.notify(bogon, notification);
	}

	private Object /* pick one type, and fixate on it */ dance(final String type, final String text)	/* for inside the thread */
	{
		final Uploader thisupl = this;
		final Message msg = Message.obtain();
		
		/* t(*A*t) */
		Thread t = new Thread() {
			public void run() {
				Looper.prepare();
				int bogon = (int)SystemClock.elapsedRealtime();
				
				NotificationManager mNotificationManager = (NotificationManager)getSystemService(Context.NOTIFICATION_SERVICE);
				Notification notification = new Notification(R.drawable.icon, "Dumload prompt", System.currentTimeMillis());
				
				Handler h = new Handler() {
					public void handleMessage(Message M) {
						msg.copyFrom(M);
						Looper.myLooper().quit();
					}
				};
				Messenger m = new Messenger(h);
				
				Intent intent = new Intent(thisupl, NotifSlave.class);
					
				intent.setAction("com.joshuawise.dumload.NotifSlave");
				intent.putExtra("com.joshuawise.dumload.returnmessenger", m);
				intent.putExtra("com.joshuawise.dumload.reqtype", type);
				intent.putExtra("com.joshuawise.dumload.prompt", text);
				intent.setData((Uri.parse("suckit://"+SystemClock.elapsedRealtime())));
				
				PendingIntent contentIntent = PendingIntent.getActivity(thisupl, 0, intent, 0);
				notification.defaults |= Notification.DEFAULT_VIBRATE;
				notification.flags |= Notification.FLAG_ONGOING_EVENT | Notification.FLAG_NO_CLEAR;
				notification.setLatestEventInfo(getApplicationContext(), "I've been had!", "Dumload needs your input.", contentIntent);
				
				Log.e("Dumload.Uploader[thread]", "Notifying...");
				
				mNotificationManager.notify(bogon, notification);
				
				Log.e("Dumload.Uploader[thread]", "About to go to 'sleep'...");
				Looper.loop();
				Log.e("Dumload.Uploader[thread]", "And we're alive!");
					
				Log.e("Dumload.Uploader[thread]", "result was: "+(Integer.toString(msg.arg1)));
				
				mNotificationManager.cancel(bogon);
			}
		};
		
		t.start();
		try {
			t.join();
		} catch (Exception e) {
			return null;
		}
		
		if (type.equals("yesno"))
			return new Boolean(msg.arg1 == 1);
		else if (type.equals("message"))
			return null;
		else if (type.equals("password")) {
			if (msg.arg1 == 0)
				return null;
			Bundle b = msg.getData();
			return b.getString("response");
		} else
			return null;
	}
	
	/* UserInfo bits */
	String _password = null;
	public String getPassword()
	{
		return _password;
	}
	public boolean promptPassword(String message)
	{
		_password = (String)dance("password", message); 
		return (_password != null);
	}
	
	String _passphrase = null;
	public String getPassphrase()
	{
		return _passphrase;
	}
	public boolean promptPassphrase(String message)
	{
		_passphrase = (String)dance("password", message); 
		return (_passphrase != null);
	}
	
	public boolean promptYesNo(String str)
	{
		return ((Boolean)dance("yesno", str)).booleanValue();
	}
	
	public void showMessage(String str)
	{
		dance("message", str);
	}
	
	public String[] promptKeyboardInteractive(String dest, String name, String instr, String[] prompt, boolean[] echo)
	{
		int i;
		String [] responses = new String[prompt.length];
		
		Log.e("Dumload.Uploader", "dest: "+dest);
		Log.e("Dumload.Uploader", "name: "+name);
		Log.e("Dumload.Uploader", "instr: "+instr);
		for (i = 0; i < prompt.length; i++)
		{
			responses[i] = (String) dance("password", "[" + dest + "]\n" + prompt[i]);
			if (responses[i] == null)
				return null;
		}
		return responses;
	}
	
	private void expect_ack(InputStream in) throws Exception, java.io.IOException
	{
		int b = in.read();
		
		if (b == -1)
		{
			throw new Exception("unexpected EOF from remote end");
		}
		
		if (b == 1 /* error */ || b == 2 /* fatal error */)
		{
			StringBuffer sb = new StringBuffer();
			int c = 0;
			
			while ((c = in.read()) != '\n')
				sb.append((char)c);
			
			throw new Exception("error from remote end: " + sb.toString());
		}
	}
	
	private void set_up_notif(final String _headline)
	{
		NotificationManager mNotificationManager = (NotificationManager)getSystemService(Context.NOTIFICATION_SERVICE);
		thenotif = new Notification(R.drawable.icon, headline, System.currentTimeMillis());
		thenotifid = (int)SystemClock.elapsedRealtime();

		Intent intent = new Intent(this, NotifSlave.class);
		
		headline = _headline;
					
		intent.setAction("com.joshuawise.dumload.NotifSlave");
		/* no extras to make the notifslave die */
		intent.setData((Uri.parse("suckit://"+SystemClock.elapsedRealtime())));
				
		PendingIntent contentIntent = PendingIntent.getActivity(this, 0, intent, 0);
		thenotif.defaults |= 0;
		thenotif.flags |= Notification.FLAG_ONGOING_EVENT | Notification.FLAG_NO_CLEAR;
		
		remote = new RemoteViews(getPackageName(), R.layout.textnotif);
		remote.setImageViewResource(R.id.image, R.drawable.icon);
		remote.setTextViewText(R.id.headline, headline);
		remote.setTextViewText(R.id.status, "Beginning upload...");
		thenotif.contentView = remote;
		thenotif.contentIntent = contentIntent;
				
		mNotificationManager.notify(thenotifid, thenotif);
	}
	
	private void destroy_notif()
	{
		NotificationManager mNotificationManager = (NotificationManager)getSystemService(Context.NOTIFICATION_SERVICE);
		mNotificationManager.cancel(thenotifid);
	}
	
	private void update_notif(String text)
	{
		NotificationManager mNotificationManager = (NotificationManager)getSystemService(Context.NOTIFICATION_SERVICE);
		
		remote = new RemoteViews(getPackageName(), R.layout.textnotif);
		remote.setImageViewResource(R.id.image, R.drawable.icon);
		remote.setTextViewText(R.id.headline, headline);
		remote.setTextViewText(R.id.status, text);
		thenotif.contentView = remote;
		
		mNotificationManager.notify(thenotifid, thenotif);
	}
	
	private void update_notif(int n, int total)
	{
		NotificationManager mNotificationManager = (NotificationManager)getSystemService(Context.NOTIFICATION_SERVICE);
		
		remote = new RemoteViews(getPackageName(), R.layout.progressnotif);
		remote.setImageViewResource(R.id.image, R.drawable.icon);
		remote.setTextViewText(R.id.headline, headline);
		remote.setProgressBar(R.id.status, total, n, false);
		thenotif.contentView = remote;
		
		mNotificationManager.notify(thenotifid, thenotif);
	}
	
	public void run()
	{
		Looper.prepare();
		
		Log.e("Dumload.Uploader[thread]", "This brought to you from the new thread.");
		
		set_up_notif("Dumload upload: " + dest);
		
		try {
			say("Uploading "+(Integer.toString(is.available()))+" bytes");
		
			update_notif("Connecting...");
		
			JSch jsch = new JSch();
			jsch.setKnownHosts(homedir + "/known_hosts");
			try {
				jsch.addIdentity(homedir + "/id_dsa");
			} catch (java.lang.Exception e) {
			}
			SharedPreferences prefs = PreferenceManager.getDefaultSharedPreferences(this);
			String server = prefs.getString("server", "").trim();
			String userName = prefs.getString("userName", "").trim();
			Integer port = prefs.getInt("serverPort", 22);
			Log.d("dbg", userName + "@" + server + ":" + port);
			Session s = jsch.getSession(userName, server, port);
			s.setUserInfo(this);
			s.connect();
			
			Channel channel = s.openChannel("exec");
			((ChannelExec)channel).setCommand("scp -t "+dest);
			channel.connect();
			
			OutputStream scp_out = channel.getOutputStream();
			InputStream scp_in = channel.getInputStream();
			
			update_notif("Starting send...");
			
			/* Okay, BS out of the way.  Now go send the file. */
			expect_ack(scp_in);
			
			String stfu;
			if (dest.lastIndexOf("/") > 0)
				stfu = dest.substring(dest.lastIndexOf("/") + 1);
			else
				stfu = dest;
			
			scp_out.write(("C0644 " + (Integer.toString(is.available())) + " "+stfu+"\n").getBytes());
			scp_out.flush();
			
			expect_ack(scp_in);
			
			int total, nbytes;
			total = is.available();
			nbytes = 0;
			int len;
			byte[] buf = new byte[4096];
			while ((len = is.read(buf, 0, buf.length)) > 0)
			{
				scp_out.write(buf, 0, len);
				nbytes += len;
				update_notif(nbytes, total);
			}
			
			is.close();
			
			update_notif("Finishing file transfer...");
			
			scp_out.write("\0".getBytes());
			scp_out.flush();
			
			expect_ack(scp_in);
			
			channel.disconnect();
			
			update_notif("Preparing to resize image...");
			
			channel = s.openChannel("exec");
			((ChannelExec)channel).setCommand("pscale "+dest);
			channel.connect();
			
			scp_in = channel.getInputStream();
			
			update_notif("Resizing image...");
			while ((len = scp_in.read(buf, 0, buf.length)) > 0)
				;
			
			channel.disconnect();
			update_notif("Upload complete.");
			
			sayNullNotification("Dumload upload complete: " + dest, "Upload complete", "Uploaded: " + dest);

			s.disconnect();
		} catch (Exception e) {
			Log.e("Dumload.uploader[thread]", "JSchException: "+(e.toString()));
			sayNullNotification("Dumload upload failed", "Upload failed", e.toString());
		}
		
		destroy_notif();
		
		Log.e("Dumload.uploader[thread]", "And now I'm back to life!");
	}
	
	private void say(String s) {
		Toast.makeText(getApplicationContext(), s, Toast.LENGTH_SHORT).show();
	}
	
	@Override
	public void onStart(Intent i, int startId)
	{
		uri = i.getData();
		dest = i.getStringExtra("com.joshuawise.dumload.dest");
		homedir = getApplicationContext().getFilesDir().getAbsolutePath();
		int shits = 0;
		int giggles = 1;
		
		super.onStart(i, startId);
		
		Log.e("Dumload.Uploader", "Started.");
		Log.e("Dumload.Uploader", "My path is "+homedir);
		
		try {
			is = getContentResolver().openInputStream(uri);
		} catch (Exception e) {
			say("Failed to open input file.");
			return;
		}
		
		
		me = new Thread(this, "Uploader thread");
		me.start();
	}
	
	@Override
	public IBinder onBind(Intent i) {
		Log.e("Dumload.Uploader", "bound");
		
		return null;
	}
}
Commit	Line	Data
0763e16d JW	1	package com.joshuawise.dumload;
	2
	3	import java.io.InputStream;
035767ac	4	import java.io.OutputStream;
0763e16d	5
42aa7dfd	6	import android.app.Notification;
42aa7dfd	7	import android.app.NotificationManager;
0763e16d	8	import android.app.PendingIntent;
42aa7dfd	9	import android.app.Service;
0763e16d	10	import android.content.Context;
42aa7dfd	11	import android.content.Intent;
42aa7dfd	12	import android.content.SharedPreferences;
0763e16d JW	13	import android.net.Uri;
0763e16d JW	14	import android.os.Bundle;
0763e16d	15	import android.os.Handler;
42aa7dfd	16	import android.os.IBinder;
0763e16d JW	17	import android.os.Looper;
0763e16d JW	18	import android.os.Message;
42aa7dfd	19	import android.os.Messenger;
0763e16d	20	import android.os.SystemClock;
42aa7dfd	21	import android.preference.PreferenceManager;
42aa7dfd	22	import android.util.Log;
ae61bba6	23	import android.widget.RemoteViews;
42aa7dfd	24	import android.widget.Toast;
	25
	26	import com.jcraft.jsch.Channel;
	27	import com.jcraft.jsch.ChannelExec;
	28	import com.jcraft.jsch.JSch;
	29	import com.jcraft.jsch.Session;
	30	import com.jcraft.jsch.UIKeyboardInteractive;
	31	import com.jcraft.jsch.UserInfo;
0763e16d JW	32
	33	public class Uploader extends Service implements Runnable, UserInfo, UIKeyboardInteractive {
	34	private Uri uri;
	35	private String homedir;
	36	private Thread me;
	37	private static final int HELPME_ID = 1;
ae61bba6 JW	38	private RemoteViews remote;
	39	private int thenotifid;
	40	private Notification thenotif;
	41	private String headline;
bb6544e9	42	private String dest;
0763e16d	43
035767ac JW	44	private InputStream is;
035767ac JW	45
0763e16d JW	46	public Object _theObject;
0763e16d JW	47
ae61bba6 JW	48	private void sayNullNotification(final String scroller, final String headline, final String description)
	49	{
	50	int bogon = (int)SystemClock.elapsedRealtime();
	51	NotificationManager mNotificationManager = (NotificationManager)getSystemService(Context.NOTIFICATION_SERVICE);
	52	Notification notification = new Notification(R.drawable.icon, scroller, System.currentTimeMillis());
	53
	54	Intent intent = new Intent(this, NotifSlave.class);
	55
	56	intent.setAction("com.joshuawise.dumload.NotifSlave");
	57	/* no extras to make the notifslave die */
	58	intent.setData((Uri.parse("suckit://"+SystemClock.elapsedRealtime())));
	59
	60	PendingIntent contentIntent = PendingIntent.getActivity(this, 0, intent, 0);
	61	notification.defaults \|= Notification.DEFAULT_VIBRATE;
	62	notification.flags \|= Notification.FLAG_AUTO_CANCEL;
	63	notification.setLatestEventInfo(getApplicationContext(), headline, description, contentIntent);
	64
	65	mNotificationManager.notify(bogon, notification);
	66	}
	67
0763e16d JW	68	private Object /* pick one type, and fixate on it / dance(final String type, final String text) / for inside the thread */
	69	{
	70	final Uploader thisupl = this;
	71	final Message msg = Message.obtain();
	72
	73	/* t(At) */
	74	Thread t = new Thread() {
	75	public void run() {
	76	Looper.prepare();
	77	int bogon = (int)SystemClock.elapsedRealtime();
	78
	79	NotificationManager mNotificationManager = (NotificationManager)getSystemService(Context.NOTIFICATION_SERVICE);
	80	Notification notification = new Notification(R.drawable.icon, "Dumload prompt", System.currentTimeMillis());
	81
	82	Handler h = new Handler() {
	83	public void handleMessage(Message M) {
	84	msg.copyFrom(M);
	85	Looper.myLooper().quit();
	86	}
	87	};
	88	Messenger m = new Messenger(h);
	89
	90	Intent intent = new Intent(thisupl, NotifSlave.class);
	91
	92	intent.setAction("com.joshuawise.dumload.NotifSlave");
	93	intent.putExtra("com.joshuawise.dumload.returnmessenger", m);
	94	intent.putExtra("com.joshuawise.dumload.reqtype", type);
	95	intent.putExtra("com.joshuawise.dumload.prompt", text);
	96	intent.setData((Uri.parse("suckit://"+SystemClock.elapsedRealtime())));
	97
	98	PendingIntent contentIntent = PendingIntent.getActivity(thisupl, 0, intent, 0);
	99	notification.defaults \|= Notification.DEFAULT_VIBRATE;
ae61bba6	100	notification.flags \|= Notification.FLAG_ONGOING_EVENT \| Notification.FLAG_NO_CLEAR;
0763e16d JW	101	notification.setLatestEventInfo(getApplicationContext(), "I've been had!", "Dumload needs your input.", contentIntent);
	102
	103	Log.e("Dumload.Uploader[thread]", "Notifying...");
	104
	105	mNotificationManager.notify(bogon, notification);
	106
	107	Log.e("Dumload.Uploader[thread]", "About to go to 'sleep'...");
	108	Looper.loop();
	109	Log.e("Dumload.Uploader[thread]", "And we're alive!");
	110
	111	Log.e("Dumload.Uploader[thread]", "result was: "+(Integer.toString(msg.arg1)));
	112
	113	mNotificationManager.cancel(bogon);
	114	}
	115	};
	116
	117	t.start();
	118	try {
	119	t.join();
	120	} catch (Exception e) {
	121	return null;
	122	}
	123
	124	if (type.equals("yesno"))
	125	return new Boolean(msg.arg1 == 1);
	126	else if (type.equals("message"))
	127	return null;
	128	else if (type.equals("password")) {
	129	if (msg.arg1 == 0)
	130	return null;
	131	Bundle b = msg.getData();
	132	return b.getString("response");
	133	} else
	134	return null;
	135	}
	136
	137	/* UserInfo bits */
	138	String _password = null;
	139	public String getPassword()
	140	{
	141	return _password;
	142	}
	143	public boolean promptPassword(String message)
	144	{
	145	_password = (String)dance("password", message);
	146	return (_password != null);
	147	}
	148
	149	String _passphrase = null;
	150	public String getPassphrase()
	151	{
	152	return _passphrase;
	153	}
	154	public boolean promptPassphrase(String message)
	155	{
	156	_passphrase = (String)dance("password", message);
	157	return (_passphrase != null);
	158	}
	159
	160	public boolean promptYesNo(String str)
	161	{
	162	return ((Boolean)dance("yesno", str)).booleanValue();
	163	}
	164
165	public void showMessage(String str)
166	{
167	dance("message", str);
168	}
169
170	public String[] promptKeyboardInteractive(String dest, String name, String instr, String[] prompt, boolean[] echo)
171	{
172	int i;
173	String [] responses = new String[prompt.length];
174
175	Log.e("Dumload.Uploader", "dest: "+dest);
176	Log.e("Dumload.Uploader", "name: "+name);
177	Log.e("Dumload.Uploader", "instr: "+instr);
178	for (i = 0; i < prompt.length; i++)
179	{
180	responses[i] = (String) dance("password", "[" + dest + "]\n" + prompt[i]);
ae61bba6 JW	181	if (responses[i] == null)
ae61bba6 JW	182	return null;
0763e16d JW	183	}
	184	return responses;
	185	}
	186
035767ac JW	187	private void expect_ack(InputStream in) throws Exception, java.io.IOException
	188	{
	189	int b = in.read();
	190
	191	if (b == -1)
	192	{
	193	throw new Exception("unexpected EOF from remote end");
	194	}
	195
	196	if (b == 1 /* error / \|\| b == 2 / fatal error */)
	197	{
	198	StringBuffer sb = new StringBuffer();
	199	int c = 0;
	200
	201	while ((c = in.read()) != '\n')
	202	sb.append((char)c);
	203
	204	throw new Exception("error from remote end: " + sb.toString());
	205	}
	206	}
	207
ae61bba6 JW	208	private void set_up_notif(final String _headline)
	209	{
	210	NotificationManager mNotificationManager = (NotificationManager)getSystemService(Context.NOTIFICATION_SERVICE);
	211	thenotif = new Notification(R.drawable.icon, headline, System.currentTimeMillis());
	212	thenotifid = (int)SystemClock.elapsedRealtime();
	213
	214	Intent intent = new Intent(this, NotifSlave.class);
	215
	216	headline = _headline;
	217
	218	intent.setAction("com.joshuawise.dumload.NotifSlave");
	219	/* no extras to make the notifslave die */
	220	intent.setData((Uri.parse("suckit://"+SystemClock.elapsedRealtime())));
	221
	222	PendingIntent contentIntent = PendingIntent.getActivity(this, 0, intent, 0);
	223	thenotif.defaults \|= 0;
	224	thenotif.flags \|= Notification.FLAG_ONGOING_EVENT \| Notification.FLAG_NO_CLEAR;
	225
	226	remote = new RemoteViews(getPackageName(), R.layout.textnotif);
	227	remote.setImageViewResource(R.id.image, R.drawable.icon);
	228	remote.setTextViewText(R.id.headline, headline);
	229	remote.setTextViewText(R.id.status, "Beginning upload...");
	230	thenotif.contentView = remote;
	231	thenotif.contentIntent = contentIntent;
	232
	233	mNotificationManager.notify(thenotifid, thenotif);
	234	}
	235
	236	private void destroy_notif()
	237	{
	238	NotificationManager mNotificationManager = (NotificationManager)getSystemService(Context.NOTIFICATION_SERVICE);
	239	mNotificationManager.cancel(thenotifid);
	240	}
	241
	242	private void update_notif(String text)
	243	{
	244	NotificationManager mNotificationManager = (NotificationManager)getSystemService(Context.NOTIFICATION_SERVICE);
	245
	246	remote = new RemoteViews(getPackageName(), R.layout.textnotif);
	247	remote.setImageViewResource(R.id.image, R.drawable.icon);
	248	remote.setTextViewText(R.id.headline, headline);
	249	remote.setTextViewText(R.id.status, text);
	250	thenotif.contentView = remote;
	251
	252	mNotificationManager.notify(thenotifid, thenotif);
	253	}
	254
	255	private void update_notif(int n, int total)
	256	{
	257	NotificationManager mNotificationManager = (NotificationManager)getSystemService(Context.NOTIFICATION_SERVICE);
	258
	259	remote = new RemoteViews(getPackageName(), R.layout.progressnotif);
	260	remote.setImageViewResource(R.id.image, R.drawable.icon);
	261	remote.setTextViewText(R.id.headline, headline);
	262	remote.setProgressBar(R.id.status, total, n, false);
	263	thenotif.contentView = remote;
	264
	265	mNotificationManager.notify(thenotifid, thenotif);
	266	}
	267
0763e16d JW	268	public void run()
	269	{
	270	Looper.prepare();
	271
	272	Log.e("Dumload.Uploader[thread]", "This brought to you from the new thread.");
	273
bb6544e9	274	set_up_notif("Dumload upload: " + dest);
ae61bba6	275
0763e16d	276	try {
035767ac JW	277	say("Uploading "+(Integer.toString(is.available()))+" bytes");
035767ac JW	278
ae61bba6 JW	279	update_notif("Connecting...");
ae61bba6 JW	280
0763e16d JW	281	JSch jsch = new JSch();
0763e16d JW	282	jsch.setKnownHosts(homedir + "/known_hosts");
bb6544e9 JW	283	try {
	284	jsch.addIdentity(homedir + "/id_dsa");
	285	} catch (java.lang.Exception e) {
	286	}
42aa7dfd	287	SharedPreferences prefs = PreferenceManager.getDefaultSharedPreferences(this);
	288	String server = prefs.getString("server", "").trim();
	289	String userName = prefs.getString("userName", "").trim();
	290	Integer port = prefs.getInt("serverPort", 22);
	291	Log.d("dbg", userName + "@" + server + ":" + port);
	292	Session s = jsch.getSession(userName, server, port);
0763e16d JW	293	s.setUserInfo(this);
	294	s.connect();
	295
	296	Channel channel = s.openChannel("exec");
bb6544e9	297	((ChannelExec)channel).setCommand("scp -t "+dest);
0763e16d JW	298	channel.connect();
0763e16d JW	299
035767ac JW	300	OutputStream scp_out = channel.getOutputStream();
	301	InputStream scp_in = channel.getInputStream();
	302
ae61bba6 JW	303	update_notif("Starting send...");
ae61bba6 JW	304
035767ac JW	305	/* Okay, BS out of the way. Now go send the file. */
	306	expect_ack(scp_in);
	307
bb6544e9 JW	308	String stfu;
	309	if (dest.lastIndexOf("/") > 0)
	310	stfu = dest.substring(dest.lastIndexOf("/") + 1);
	311	else
	312	stfu = dest;
	313
	314	scp_out.write(("C0644 " + (Integer.toString(is.available())) + " "+stfu+"\n").getBytes());
035767ac JW	315	scp_out.flush();
	316
	317	expect_ack(scp_in);
	318
ae61bba6 JW	319	int total, nbytes;
	320	total = is.available();
	321	nbytes = 0;
035767ac JW	322	int len;
	323	byte[] buf = new byte[4096];
	324	while ((len = is.read(buf, 0, buf.length)) > 0)
ae61bba6	325	{
035767ac	326	scp_out.write(buf, 0, len);
ae61bba6 JW	327	nbytes += len;
	328	update_notif(nbytes, total);
	329	}
035767ac JW	330
	331	is.close();
	332
e1916520	333	update_notif("Finishing file transfer...");
ae61bba6	334
035767ac JW	335	scp_out.write("\0".getBytes());
	336	scp_out.flush();
	337
	338	expect_ack(scp_in);
	339
e1916520 JW	340	channel.disconnect();
	341
	342	update_notif("Preparing to resize image...");
	343
	344	channel = s.openChannel("exec");
bb6544e9	345	((ChannelExec)channel).setCommand("pscale "+dest);
e1916520 JW	346	channel.connect();
	347
	348	scp_in = channel.getInputStream();
	349
	350	update_notif("Resizing image...");
	351	while ((len = scp_in.read(buf, 0, buf.length)) > 0)
	352	;
	353
	354	channel.disconnect();
	355	update_notif("Upload complete.");
	356
bb6544e9	357	sayNullNotification("Dumload upload complete: " + dest, "Upload complete", "Uploaded: " + dest);
0763e16d	358
0763e16d	359	s.disconnect();
035767ac	360	} catch (Exception e) {
0763e16d	361	Log.e("Dumload.uploader[thread]", "JSchException: "+(e.toString()));
ae61bba6	362	sayNullNotification("Dumload upload failed", "Upload failed", e.toString());
0763e16d JW	363	}
0763e16d JW	364
ae61bba6 JW	365	destroy_notif();
ae61bba6 JW	366
0763e16d JW	367	Log.e("Dumload.uploader[thread]", "And now I'm back to life!");
	368	}
	369
	370	private void say(String s) {
	371	Toast.makeText(getApplicationContext(), s, Toast.LENGTH_SHORT).show();
	372	}
	373
	374	@Override
	375	public void onStart(Intent i, int startId)
	376	{
	377	uri = i.getData();
bb6544e9	378	dest = i.getStringExtra("com.joshuawise.dumload.dest");
0763e16d JW	379	homedir = getApplicationContext().getFilesDir().getAbsolutePath();
0763e16d JW	380	int shits = 0;
42aa7dfd	381	int giggles = 1;
0763e16d JW	382
	383	super.onStart(i, startId);
	384
	385	Log.e("Dumload.Uploader", "Started.");
	386	Log.e("Dumload.Uploader", "My path is "+homedir);
	387
	388	try {
035767ac	389	is = getContentResolver().openInputStream(uri);
0763e16d	390	} catch (Exception e) {
035767ac JW	391	say("Failed to open input file.");
035767ac JW	392	return;
0763e16d JW	393	}
0763e16d JW	394
0763e16d JW	395
	396	me = new Thread(this, "Uploader thread");
	397	me.start();
	398	}
	399
	400	@Override
	401	public IBinder onBind(Intent i) {
	402	Log.e("Dumload.Uploader", "bound");
	403
	404	return null;
	405	}
	406	}