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

package com.joshuawise.dumload;

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

import com.jcraft.jsch.*;
import java.lang.Boolean;

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

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