From 6bdf5b791f55e75543c1e7b490522097399603d1 Mon Sep 17 00:00:00 2001 From: Damyan Ivanov Date: Mon, 3 Dec 2018 21:21:19 +0000 Subject: [PATCH] AsyncTask class for saving the new transaction --- .../mobileledger/SaveTransactionTask.java | 150 ++++++++++++++++++ 1 file changed, 150 insertions(+) create mode 100644 app/src/main/java/net/ktnx/mobileledger/SaveTransactionTask.java diff --git a/app/src/main/java/net/ktnx/mobileledger/SaveTransactionTask.java b/app/src/main/java/net/ktnx/mobileledger/SaveTransactionTask.java new file mode 100644 index 00000000..79cf7dc2 --- /dev/null +++ b/app/src/main/java/net/ktnx/mobileledger/SaveTransactionTask.java @@ -0,0 +1,150 @@ +package net.ktnx.mobileledger; + +import android.content.SharedPreferences; +import android.os.AsyncTask; +import android.util.Log; + +import java.io.BufferedReader; +import java.io.IOException; +import java.io.InputStream; +import java.io.InputStreamReader; +import java.io.OutputStream; +import java.net.HttpURLConnection; +import java.util.Iterator; +import java.util.List; +import java.util.Locale; +import java.util.Map; +import java.util.regex.Matcher; +import java.util.regex.Pattern; + +import static java.lang.Thread.sleep; + +class SaveTransactionTask extends AsyncTask { + private final TaskCallback task_callback; + private String token; + private String session; + private String backend_url; + private LedgerTransaction ltr; + + private SharedPreferences pref; + void setPref(SharedPreferences pref) { + this.pref = pref; + } + + SaveTransactionTask(TaskCallback callback) { + task_callback = callback; + } + private boolean send_ok() throws IOException { + HttpURLConnection http = NetworkUtil.prepare_connection(pref, "add"); + http.setRequestMethod("POST"); + http.setRequestProperty("Content-Type", "application/x-www-form-urlencoded"); + http.setRequestProperty("Accept", "*/*"); + if ((session != null) && !session.isEmpty()) { + http.setRequestProperty("Cookie", String.format("_SESSION=%s", session)); + } + http.setDoOutput(true); + http.setDoInput(true); + + UrlEncodedFormData params = new UrlEncodedFormData(); + params.add_pair("_formid", "identify-add"); + if (token != null) params.add_pair("_token", token); + params.add_pair("date", ltr.getDate()); + params.add_pair("description", ltr.getDescription()); + { + Iterator items = ltr.getItemsIterator(); + while (items.hasNext()) { + LedgerTransactionItem item = items.next(); + params.add_pair("account", item.get_account_name()); + if (item.is_amount_set()) + params.add_pair("amount", String.format(Locale.US, "%1.2f", item.get_amount())); + else params.add_pair("amount", ""); + } + } + + String body = params.toString(); + http.addRequestProperty("Content-Length", String.valueOf(body.length())); + + Log.d("network", "request header: " + http.getRequestProperties().toString()); + + try (OutputStream req = http.getOutputStream()) { + Log.d("network", "Request body: " + body); + req.write(body.getBytes("ASCII")); + + try (InputStream resp = http.getInputStream()) { + Log.d("update_accounts", String.valueOf(http.getResponseCode())); + if (http.getResponseCode() == 303) { + // everything is fine + return true; + } else if (http.getResponseCode() == 200) { + // get the new cookie + { + Pattern sess_cookie_re = Pattern.compile("_SESSION=([^;]+);.*"); + + Map> header = http.getHeaderFields(); + List cookie_header = header.get("Set-Cookie"); + if (cookie_header != null) { + String cookie = cookie_header.get(0); + Matcher m = sess_cookie_re.matcher(cookie); + if (m.matches()) { + session = m.group(1); + Log.d("network", "new session is " + session); + } else { + Log.d("network", "set-cookie: " + cookie); + Log.w("network", "Response Set-Cookie headers is not a _SESSION one"); + } + } else { + Log.w("network", "Response has no Set-Cookie header"); + } + } + // the token needs to be updated + BufferedReader reader = new BufferedReader(new InputStreamReader(resp)); + Pattern re = Pattern.compile(""); + String line; + while ((line = reader.readLine()) != null) { + //Log.d("dump", line); + Matcher m = re.matcher(line); + if (m.matches()) { + token = m.group(1); + Log.d("save-transaction", line); + Log.d("save-transaction", "Token=" + token); + return false; // retry + } + } + throw new IOException("Can't find _token string"); + } else { + throw new IOException(String.format("Error response code %d", http.getResponseCode())); + } + } + } + } + + @Override + protected Void doInBackground(LedgerTransaction... ledgerTransactions) { + backend_url = pref.getString("backend_url", ""); + ltr = ledgerTransactions[0]; + try { + int tried = 0; + while (! send_ok() ) { + try { + tried++; + if (tried >= 3) + throw new IOException(String.format("aborting after %d tries", tried)); + sleep(100); + } catch (InterruptedException e) { + e.printStackTrace(); + } + } + } + catch (IOException e) { + e.printStackTrace(); + } + + return null; + } + + @Override + protected void onPostExecute(Void aVoid) { + super.onPostExecute(aVoid); + task_callback.done(); + } +} -- 2.39.2