1 package net.ktnx.mobileledger;
3 import android.content.SharedPreferences;
4 import android.database.sqlite.SQLiteDatabase;
5 import android.util.Log;
7 import java.io.BufferedReader;
8 import java.io.IOException;
9 import java.io.InputStream;
10 import java.io.InputStreamReader;
11 import java.net.Authenticator;
12 import java.net.HttpURLConnection;
13 import java.net.MalformedURLException;
14 import java.net.PasswordAuthentication;
16 import java.net.URLDecoder;
17 import java.util.regex.Matcher;
18 import java.util.regex.Pattern;
20 abstract public class RetrieveAccountsTask extends android.os.AsyncTask<SQLiteDatabase, Integer, Void> {
23 SharedPreferences pref;
24 public void setPref(SharedPreferences pref) {
27 public RetrieveAccountsTask() {
31 protected Void doInBackground(SQLiteDatabase... sqLiteDatabases) {
32 final String backend_url = pref.getString("backend_url", "");
33 final boolean use_auth = pref.getBoolean("backend_use_http_auth", false);
34 final SQLiteDatabase db = sqLiteDatabases[0];
36 Log.d("update_accounts", "Connecting to "+backend_url);
37 HttpURLConnection http = (HttpURLConnection) new URL(backend_url + "/journal").openConnection();
39 final String auth_user = pref.getString("backend_auth_user", "");
40 final String auth_password = pref.getString("backend_auth_password", "");
41 Authenticator.setDefault(new Authenticator() {
43 protected PasswordAuthentication getPasswordAuthentication() {
44 Log.d("http-auth", "called");
45 return new PasswordAuthentication(auth_user, auth_password.toCharArray());
48 // final String basic_auth = String.format("Basic %s:%s", auth_user, auth_password);
49 // http.setRequestProperty("Authorization", basic_auth);
50 Log.d("update_accounts", "Will auth as "+auth_user+" with password of "+auth_password.length()+" characters");
52 http.setAllowUserInteraction(false);
53 http.setRequestProperty("Accept-Charset", "UTF-8");
55 InputStream resp = http.getInputStream();
57 Log.d("update_accounts", String.valueOf(http.getResponseCode()));
58 if (http.getResponseCode() != 200) {
59 error = R.string.err_http_error;
62 db.beginTransaction();
63 db.execSQL("delete from accounts;");
67 BufferedReader buf = new BufferedReader(new InputStreamReader(resp, "UTF-8"));
69 Pattern re = Pattern.compile('"' + backend_url + "/register\\?q=inacct%3A([a-zA-Z0-9%]+)\\\"");
71 while ((line = buf.readLine()) != null) {
72 Matcher m = re.matcher(line);
74 String acct_encoded = m.group(1);
75 String acct_name = URLDecoder.decode(acct_encoded, "UTF-8");
76 acct_name = acct_name.replace("\"", "");
77 Log.d("account-parser", acct_name);
79 db.execSQL("insert into accounts(name) values(?)", new Object[]{acct_name} );
80 publishProgress(++count);
84 db.setTransactionSuccessful();
95 } catch (MalformedURLException e) {
96 error = R.string.err_bad_backend_url;
98 } catch (IOException e) {
99 error = R.string.err_net_io_error;
102 catch (Exception e) {
103 error = R.string.err_net_error;
110 abstract protected void onProgressUpdate(Integer... values);
112 abstract protected void onPostExecute(Void result);