Remove generated/IDE files

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

diff --git a/src/com/joshuawise/dumload/Uploader.java b/src/com/joshuawise/dumload/Uploader.java
index 56ac043579ba04ca4e74cdb8570e49ef8c485d69..f1dfc7eee702dda3a44fd4de46975da435645f4d 100644 (file)
--- a/src/com/joshuawise/dumload/Uploader.java
+++ b/src/com/joshuawise/dumload/Uploader.java
@@ -24,17 +24,43 @@ import android.os.Messenger;
 import android.os.Looper;
 import android.os.Message;
 import android.os.SystemClock;
 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;
 
 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 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;
        private Object /* pick one type, and fixate on it */ dance(final String type, final String text)        /* for inside the thread */
        {
                final Uploader thisupl = this;


@@ -67,7 +93,7 @@ public class Uploader extends Service implements Runnable, UserInfo, UIKeyboardI
                                
                                PendingIntent contentIntent = PendingIntent.getActivity(thisupl, 0, intent, 0);
                                notification.defaults |= Notification.DEFAULT_VIBRATE;
                                
                                PendingIntent contentIntent = PendingIntent.getActivity(thisupl, 0, intent, 0);
                                notification.defaults |= Notification.DEFAULT_VIBRATE;

-                               notification.flags |= Notification.FLAG_AUTO_CANCEL | Notification.FLAG_ONGOING_EVENT | Notification.FLAG_NO_CLEAR;
+                               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...");
                                notification.setLatestEventInfo(getApplicationContext(), "I've been had!", "Dumload needs your input.", contentIntent);
                                
                                Log.e("Dumload.Uploader[thread]", "Notifying...");


@@ -148,6 +174,8 @@ public class Uploader extends Service implements Runnable, UserInfo, UIKeyboardI
                for (i = 0; i < prompt.length; i++)
                {
                        responses[i] = (String) dance("password", "[" + dest + "]\n" + prompt[i]);
                for (i = 0; i < prompt.length; i++)
                {
                        responses[i] = (String) dance("password", "[" + dest + "]\n" + prompt[i]);

+                       if (responses[i] == null)
+                               return null;

                }
                return responses;
        }
                }
                return responses;
        }


@@ -173,6 +201,66 @@ public class Uploader extends Service implements Runnable, UserInfo, UIKeyboardI
                }
        }
        
                }
        }
        

+       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()
        {
        @Override
        public void run()
        {


@@ -180,50 +268,94 @@ public class Uploader extends Service implements Runnable, UserInfo, UIKeyboardI
                
                Log.e("Dumload.Uploader[thread]", "This brought to you from the new thread.");
                
                
                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");
                
                try {
                        say("Uploading "+(Integer.toString(is.available()))+" bytes");
                

+                       update_notif("Connecting...");
+               

                        JSch jsch = new JSch();
                        jsch.setKnownHosts(homedir + "/known_hosts");
                        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");
                        Session s = jsch.getSession("joshua", "nyus.joshuawise.com", 22);
                        s.setUserInfo(this);
                        s.connect();
                        
                        Channel channel = s.openChannel("exec");

-                       ((ChannelExec)channel).setCommand("scp -t /tmp/lol");
+                       ((ChannelExec)channel).setCommand("scp -t "+dest);

                        channel.connect();
                        
                        OutputStream scp_out = channel.getOutputStream();
                        InputStream scp_in = channel.getInputStream();
                        
                        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);
                        
                        /* Okay, BS out of the way.  Now go send the file. */
                        expect_ack(scp_in);
                        

-                       scp_out.write(("C0644 " + (Integer.toString(is.available())) + " lol\n").getBytes());
+                       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);
                        
                        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)
                        int len;
                        byte[] buf = new byte[4096];
                        while ((len = is.read(buf, 0, buf.length)) > 0)

+                       {

                                scp_out.write(buf, 0, len);
                                scp_out.write(buf, 0, len);

+                               nbytes += len;
+                               update_notif(nbytes, total);
+                       }

                        
                        is.close();
                        
                        
                        is.close();
                        

+                       update_notif("Finishing file transfer...");
+                       

                        scp_out.write("\0".getBytes());
                        scp_out.flush();
                        
                        expect_ack(scp_in);
                        
                        scp_out.write("\0".getBytes());
                        scp_out.flush();
                        
                        expect_ack(scp_in);
                        

-                       dance("message", "done");
-

                        channel.disconnect();
                        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()));
                        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!");
        }
        
                Log.e("Dumload.uploader[thread]", "And now I'm back to life!");
        }
        


@@ -235,6 +367,7 @@ public class Uploader extends Service implements Runnable, UserInfo, UIKeyboardI
        public void onStart(Intent i, int startId)
        {
                uri = i.getData();
        public void onStart(Intent i, int startId)
        {
                uri = i.getData();

+               dest = i.getStringExtra("com.joshuawise.dumload.dest");

                homedir = getApplicationContext().getFilesDir().getAbsolutePath();
                int shits = 0;
                
                homedir = getApplicationContext().getFilesDir().getAbsolutePath();
                int shits = 0;