]>
Commit | Line | Data |
---|---|---|
1 | package com.joshuawise.dumload; | |
2 | ||
3 | import java.io.InputStream; | |
4 | import java.io.OutputStream; | |
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; | |
27 | ||
28 | public class Uploader extends Service implements Runnable, UserInfo, UIKeyboardInteractive { | |
29 | private Uri uri; | |
30 | private String homedir; | |
31 | private Thread me; | |
32 | private static final int HELPME_ID = 1; | |
33 | ||
34 | private InputStream is; | |
35 | ||
36 | public Object _theObject; | |
37 | ||
38 | private Object /* pick one type, and fixate on it */ dance(final String type, final String text) /* for inside the thread */ | |
39 | { | |
40 | final Uploader thisupl = this; | |
41 | final Message msg = Message.obtain(); | |
42 | ||
43 | /* t(*A*t) */ | |
44 | Thread t = new Thread() { | |
45 | public void run() { | |
46 | Looper.prepare(); | |
47 | int bogon = (int)SystemClock.elapsedRealtime(); | |
48 | ||
49 | NotificationManager mNotificationManager = (NotificationManager)getSystemService(Context.NOTIFICATION_SERVICE); | |
50 | Notification notification = new Notification(R.drawable.icon, "Dumload prompt", System.currentTimeMillis()); | |
51 | ||
52 | Handler h = new Handler() { | |
53 | public void handleMessage(Message M) { | |
54 | msg.copyFrom(M); | |
55 | Looper.myLooper().quit(); | |
56 | } | |
57 | }; | |
58 | Messenger m = new Messenger(h); | |
59 | ||
60 | Intent intent = new Intent(thisupl, NotifSlave.class); | |
61 | ||
62 | intent.setAction("com.joshuawise.dumload.NotifSlave"); | |
63 | intent.putExtra("com.joshuawise.dumload.returnmessenger", m); | |
64 | intent.putExtra("com.joshuawise.dumload.reqtype", type); | |
65 | intent.putExtra("com.joshuawise.dumload.prompt", text); | |
66 | intent.setData((Uri.parse("suckit://"+SystemClock.elapsedRealtime()))); | |
67 | ||
68 | PendingIntent contentIntent = PendingIntent.getActivity(thisupl, 0, intent, 0); | |
69 | notification.defaults |= Notification.DEFAULT_VIBRATE; | |
70 | notification.flags |= Notification.FLAG_AUTO_CANCEL | Notification.FLAG_ONGOING_EVENT | Notification.FLAG_NO_CLEAR; | |
71 | notification.setLatestEventInfo(getApplicationContext(), "I've been had!", "Dumload needs your input.", contentIntent); | |
72 | ||
73 | Log.e("Dumload.Uploader[thread]", "Notifying..."); | |
74 | ||
75 | mNotificationManager.notify(bogon, notification); | |
76 | ||
77 | Log.e("Dumload.Uploader[thread]", "About to go to 'sleep'..."); | |
78 | Looper.loop(); | |
79 | Log.e("Dumload.Uploader[thread]", "And we're alive!"); | |
80 | ||
81 | Log.e("Dumload.Uploader[thread]", "result was: "+(Integer.toString(msg.arg1))); | |
82 | ||
83 | mNotificationManager.cancel(bogon); | |
84 | } | |
85 | }; | |
86 | ||
87 | t.start(); | |
88 | try { | |
89 | t.join(); | |
90 | } catch (Exception e) { | |
91 | return null; | |
92 | } | |
93 | ||
94 | if (type.equals("yesno")) | |
95 | return new Boolean(msg.arg1 == 1); | |
96 | else if (type.equals("message")) | |
97 | return null; | |
98 | else if (type.equals("password")) { | |
99 | if (msg.arg1 == 0) | |
100 | return null; | |
101 | Bundle b = msg.getData(); | |
102 | return b.getString("response"); | |
103 | } else | |
104 | return null; | |
105 | } | |
106 | ||
107 | /* UserInfo bits */ | |
108 | String _password = null; | |
109 | public String getPassword() | |
110 | { | |
111 | return _password; | |
112 | } | |
113 | public boolean promptPassword(String message) | |
114 | { | |
115 | _password = (String)dance("password", message); | |
116 | return (_password != null); | |
117 | } | |
118 | ||
119 | String _passphrase = null; | |
120 | public String getPassphrase() | |
121 | { | |
122 | return _passphrase; | |
123 | } | |
124 | public boolean promptPassphrase(String message) | |
125 | { | |
126 | _passphrase = (String)dance("password", message); | |
127 | return (_passphrase != null); | |
128 | } | |
129 | ||
130 | public boolean promptYesNo(String str) | |
131 | { | |
132 | return ((Boolean)dance("yesno", str)).booleanValue(); | |
133 | } | |
134 | ||
135 | public void showMessage(String str) | |
136 | { | |
137 | dance("message", str); | |
138 | } | |
139 | ||
140 | public String[] promptKeyboardInteractive(String dest, String name, String instr, String[] prompt, boolean[] echo) | |
141 | { | |
142 | int i; | |
143 | String [] responses = new String[prompt.length]; | |
144 | ||
145 | Log.e("Dumload.Uploader", "dest: "+dest); | |
146 | Log.e("Dumload.Uploader", "name: "+name); | |
147 | Log.e("Dumload.Uploader", "instr: "+instr); | |
148 | for (i = 0; i < prompt.length; i++) | |
149 | { | |
150 | responses[i] = (String) dance("password", "[" + dest + "]\n" + prompt[i]); | |
151 | } | |
152 | return responses; | |
153 | } | |
154 | ||
155 | private void expect_ack(InputStream in) throws Exception, java.io.IOException | |
156 | { | |
157 | int b = in.read(); | |
158 | ||
159 | if (b == -1) | |
160 | { | |
161 | throw new Exception("unexpected EOF from remote end"); | |
162 | } | |
163 | ||
164 | if (b == 1 /* error */ || b == 2 /* fatal error */) | |
165 | { | |
166 | StringBuffer sb = new StringBuffer(); | |
167 | int c = 0; | |
168 | ||
169 | while ((c = in.read()) != '\n') | |
170 | sb.append((char)c); | |
171 | ||
172 | throw new Exception("error from remote end: " + sb.toString()); | |
173 | } | |
174 | } | |
175 | ||
176 | @Override | |
177 | public void run() | |
178 | { | |
179 | Looper.prepare(); | |
180 | ||
181 | Log.e("Dumload.Uploader[thread]", "This brought to you from the new thread."); | |
182 | ||
183 | try { | |
184 | say("Uploading "+(Integer.toString(is.available()))+" bytes"); | |
185 | ||
186 | JSch jsch = new JSch(); | |
187 | jsch.setKnownHosts(homedir + "/known_hosts"); | |
188 | Session s = jsch.getSession("joshua", "nyus.joshuawise.com", 22); | |
189 | s.setUserInfo(this); | |
190 | s.connect(); | |
191 | ||
192 | Channel channel = s.openChannel("exec"); | |
193 | ((ChannelExec)channel).setCommand("scp -t /tmp/lol"); | |
194 | channel.connect(); | |
195 | ||
196 | OutputStream scp_out = channel.getOutputStream(); | |
197 | InputStream scp_in = channel.getInputStream(); | |
198 | ||
199 | /* Okay, BS out of the way. Now go send the file. */ | |
200 | expect_ack(scp_in); | |
201 | ||
202 | scp_out.write(("C0644 " + (Integer.toString(is.available())) + " lol\n").getBytes()); | |
203 | scp_out.flush(); | |
204 | ||
205 | expect_ack(scp_in); | |
206 | ||
207 | int len; | |
208 | byte[] buf = new byte[4096]; | |
209 | while ((len = is.read(buf, 0, buf.length)) > 0) | |
210 | scp_out.write(buf, 0, len); | |
211 | ||
212 | is.close(); | |
213 | ||
214 | scp_out.write("\0".getBytes()); | |
215 | scp_out.flush(); | |
216 | ||
217 | expect_ack(scp_in); | |
218 | ||
219 | dance("message", "done"); | |
220 | ||
221 | channel.disconnect(); | |
222 | s.disconnect(); | |
223 | } catch (Exception e) { | |
224 | Log.e("Dumload.uploader[thread]", "JSchException: "+(e.toString())); | |
225 | } | |
226 | ||
227 | Log.e("Dumload.uploader[thread]", "And now I'm back to life!"); | |
228 | } | |
229 | ||
230 | private void say(String s) { | |
231 | Toast.makeText(getApplicationContext(), s, Toast.LENGTH_SHORT).show(); | |
232 | } | |
233 | ||
234 | @Override | |
235 | public void onStart(Intent i, int startId) | |
236 | { | |
237 | uri = i.getData(); | |
238 | homedir = getApplicationContext().getFilesDir().getAbsolutePath(); | |
239 | int shits = 0; | |
240 | ||
241 | super.onStart(i, startId); | |
242 | ||
243 | Log.e("Dumload.Uploader", "Started."); | |
244 | Log.e("Dumload.Uploader", "My path is "+homedir); | |
245 | ||
246 | try { | |
247 | is = getContentResolver().openInputStream(uri); | |
248 | } catch (Exception e) { | |
249 | say("Failed to open input file."); | |
250 | return; | |
251 | } | |
252 | ||
253 | ||
254 | me = new Thread(this, "Uploader thread"); | |
255 | me.start(); | |
256 | } | |
257 | ||
258 | @Override | |
259 | public IBinder onBind(Intent i) { | |
260 | Log.e("Dumload.Uploader", "bound"); | |
261 | ||
262 | return null; | |
263 | } | |
264 | } |