Reformatted code
This commit is contained in:
daniel oeh
parent
02653918f0
commit
6ebafb2c24
@ -1,22 +1,10 @@
|
||||
package de.danoeh.antennapod.asynctask;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.Iterator;
|
||||
import java.util.List;
|
||||
import java.util.ListIterator;
|
||||
import java.util.concurrent.Executor;
|
||||
|
||||
import org.shredzone.flattr4j.exception.FlattrException;
|
||||
import org.shredzone.flattr4j.model.Flattr;
|
||||
|
||||
import android.annotation.SuppressLint;
|
||||
import android.app.Notification;
|
||||
import android.app.NotificationManager;
|
||||
import android.app.PendingIntent;
|
||||
import android.app.ProgressDialog;
|
||||
import android.content.Context;
|
||||
import android.content.Intent;
|
||||
import android.graphics.BitmapFactory;
|
||||
import android.net.ConnectivityManager;
|
||||
import android.net.NetworkInfo;
|
||||
import android.os.AsyncTask;
|
||||
@ -25,45 +13,47 @@ import android.util.Log;
|
||||
import android.widget.Toast;
|
||||
import de.danoeh.antennapod.AppConfig;
|
||||
import de.danoeh.antennapod.R;
|
||||
import de.danoeh.antennapod.activity.FeedItemlistActivity;
|
||||
import de.danoeh.antennapod.feed.Feed;
|
||||
import de.danoeh.antennapod.feed.FeedItem;
|
||||
import de.danoeh.antennapod.util.flattr.FlattrThing;
|
||||
import de.danoeh.antennapod.util.flattr.FlattrUtils;
|
||||
import de.danoeh.antennapod.util.flattr.FlattrStatus;
|
||||
import de.danoeh.antennapod.storage.DBReader;
|
||||
import de.danoeh.antennapod.storage.DBWriter;
|
||||
import de.danoeh.antennapod.util.flattr.FlattrThing;
|
||||
import de.danoeh.antennapod.util.flattr.FlattrUtils;
|
||||
|
||||
/** Performs a click action in a background thread. */
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import java.util.concurrent.Executor;
|
||||
|
||||
/**
|
||||
* Performs a click action in a background thread.
|
||||
*/
|
||||
|
||||
public class FlattrClickWorker extends AsyncTask<Void, String, Void> {
|
||||
protected static final String TAG = "FlattrClickWorker";
|
||||
protected Context context;
|
||||
|
||||
private final int NOTIFICATION_ID = 4;
|
||||
|
||||
protected String errorMsg;
|
||||
protected int exitCode;
|
||||
protected ArrayList<String> flattrd;
|
||||
protected ArrayList<String> flattr_failed;
|
||||
protected static final String TAG = "FlattrClickWorker";
|
||||
protected Context context;
|
||||
|
||||
private final int NOTIFICATION_ID = 4;
|
||||
|
||||
protected String errorMsg;
|
||||
protected int exitCode;
|
||||
protected ArrayList<String> flattrd;
|
||||
protected ArrayList<String> flattr_failed;
|
||||
|
||||
|
||||
protected NotificationCompat.Builder notificationCompatBuilder;
|
||||
protected NotificationCompat.Builder notificationCompatBuilder;
|
||||
private Notification.BigTextStyle notificationBuilder;
|
||||
protected NotificationManager notificationManager;
|
||||
|
||||
protected ProgressDialog progDialog;
|
||||
|
||||
protected final static int EXIT_DEFAULT = 0;
|
||||
protected final static int NO_TOKEN = 1;
|
||||
protected final static int ENQUEUED = 2;
|
||||
protected final static int NO_THINGS = 3;
|
||||
protected ProgressDialog progDialog;
|
||||
|
||||
protected final static int EXIT_DEFAULT = 0;
|
||||
protected final static int NO_TOKEN = 1;
|
||||
protected final static int ENQUEUED = 2;
|
||||
protected final static int NO_THINGS = 3;
|
||||
|
||||
public final static int ENQUEUE_ONLY = 1;
|
||||
public final static int FLATTR_TOAST = 2;
|
||||
public static final int FLATTR_NOTIFICATION = 3;
|
||||
|
||||
private int run_mode = FLATTR_NOTIFICATION;
|
||||
private int run_mode = FLATTR_NOTIFICATION;
|
||||
|
||||
private FlattrThing extra_flattr_thing; // additional urls to flattr that do *not* originate from the queue
|
||||
|
||||
@ -71,21 +61,21 @@ public class FlattrClickWorker extends AsyncTask<Void, String, Void> {
|
||||
* @param context
|
||||
* @param run_mode can be one of ENQUEUE_ONLY, FLATTR_TOAST and FLATTR_NOTIFICATION
|
||||
*/
|
||||
public FlattrClickWorker(Context context, int run_mode) {
|
||||
this(context);
|
||||
this.run_mode = run_mode;
|
||||
}
|
||||
|
||||
public FlattrClickWorker(Context context) {
|
||||
super();
|
||||
this.context = context;
|
||||
exitCode = EXIT_DEFAULT;
|
||||
public FlattrClickWorker(Context context, int run_mode) {
|
||||
this(context);
|
||||
this.run_mode = run_mode;
|
||||
}
|
||||
|
||||
flattrd = new ArrayList<String>();
|
||||
flattr_failed = new ArrayList<String>();
|
||||
|
||||
errorMsg = "";
|
||||
}
|
||||
public FlattrClickWorker(Context context) {
|
||||
super();
|
||||
this.context = context;
|
||||
exitCode = EXIT_DEFAULT;
|
||||
|
||||
flattrd = new ArrayList<String>();
|
||||
flattr_failed = new ArrayList<String>();
|
||||
|
||||
errorMsg = "";
|
||||
}
|
||||
|
||||
/* only used in PreferencesActivity for flattring antennapod itself,
|
||||
* can't really enqueue this thing
|
||||
@ -98,56 +88,55 @@ public class FlattrClickWorker extends AsyncTask<Void, String, Void> {
|
||||
}
|
||||
|
||||
protected void onNoAccessToken() {
|
||||
Log.w(TAG, "No access token was available");
|
||||
FlattrUtils.showNoTokenDialog(context, "");
|
||||
}
|
||||
Log.w(TAG, "No access token was available");
|
||||
FlattrUtils.showNoTokenDialog(context, "");
|
||||
}
|
||||
|
||||
protected void onFlattrError() {
|
||||
FlattrUtils.showErrorDialog(context, errorMsg);
|
||||
}
|
||||
|
||||
protected void onFlattred() {
|
||||
String notificationTitle = context.getString(R.string.flattrd_label);
|
||||
String notificationText = "", notificationSubText = "", notificationBigText = "";
|
||||
|
||||
// text for successfully flattred items
|
||||
if (flattrd.size() == 1)
|
||||
notificationText = String.format(context.getString(R.string.flattr_click_success));
|
||||
else if (flattrd.size() > 1) // flattred pending items from queue
|
||||
notificationText = String.format(context.getString(R.string.flattr_click_success_count, flattrd.size()));
|
||||
|
||||
if (flattrd.size() > 0) {
|
||||
String acc = "";
|
||||
for (String s: flattrd)
|
||||
acc += s + '\n';
|
||||
acc = acc.substring(0, acc.length()-2);
|
||||
|
||||
notificationBigText = String.format(context.getString(R.string.flattr_click_success_queue), acc);
|
||||
}
|
||||
|
||||
// add text for failures
|
||||
if (flattr_failed.size() > 0) {
|
||||
notificationTitle = context.getString(R.string.flattrd_failed_label);
|
||||
notificationText = String.format(context.getString(R.string.flattr_click_failure_count), flattr_failed.size())
|
||||
+ " " + notificationText;
|
||||
protected void onFlattrError() {
|
||||
FlattrUtils.showErrorDialog(context, errorMsg);
|
||||
}
|
||||
|
||||
protected void onFlattred() {
|
||||
String notificationTitle = context.getString(R.string.flattrd_label);
|
||||
String notificationText = "", notificationSubText = "", notificationBigText = "";
|
||||
|
||||
// text for successfully flattred items
|
||||
if (flattrd.size() == 1)
|
||||
notificationText = String.format(context.getString(R.string.flattr_click_success));
|
||||
else if (flattrd.size() > 1) // flattred pending items from queue
|
||||
notificationText = String.format(context.getString(R.string.flattr_click_success_count, flattrd.size()));
|
||||
|
||||
if (flattrd.size() > 0) {
|
||||
String acc = "";
|
||||
for (String s : flattrd)
|
||||
acc += s + '\n';
|
||||
acc = acc.substring(0, acc.length() - 2);
|
||||
|
||||
notificationBigText = String.format(context.getString(R.string.flattr_click_success_queue), acc);
|
||||
}
|
||||
|
||||
// add text for failures
|
||||
if (flattr_failed.size() > 0) {
|
||||
notificationTitle = context.getString(R.string.flattrd_failed_label);
|
||||
notificationText = String.format(context.getString(R.string.flattr_click_failure_count), flattr_failed.size())
|
||||
+ " " + notificationText;
|
||||
|
||||
notificationSubText = flattr_failed.get(0);
|
||||
|
||||
String acc = "";
|
||||
for (String s: flattr_failed)
|
||||
acc += s + '\n';
|
||||
acc = acc.substring(0, acc.length()-2);
|
||||
|
||||
notificationBigText = String.format(context.getString(R.string.flattr_click_failure), acc)
|
||||
+ "\n" + notificationBigText;
|
||||
}
|
||||
String acc = "";
|
||||
for (String s : flattr_failed)
|
||||
acc += s + '\n';
|
||||
acc = acc.substring(0, acc.length() - 2);
|
||||
|
||||
notificationBigText = String.format(context.getString(R.string.flattr_click_failure), acc)
|
||||
+ "\n" + notificationBigText;
|
||||
}
|
||||
|
||||
Log.d(TAG, "Going to post notification: " + notificationBigText);
|
||||
|
||||
notificationManager.cancel(NOTIFICATION_ID);
|
||||
|
||||
if (run_mode == FLATTR_NOTIFICATION || flattr_failed.size() > 0)
|
||||
{
|
||||
if (run_mode == FLATTR_NOTIFICATION || flattr_failed.size() > 0) {
|
||||
if (android.os.Build.VERSION.SDK_INT >= 16) {
|
||||
notificationBuilder = new Notification.BigTextStyle(
|
||||
new Notification.Builder(context)
|
||||
@ -158,9 +147,7 @@ public class FlattrClickWorker extends AsyncTask<Void, String, Void> {
|
||||
.setSmallIcon(R.drawable.stat_notify_sync))
|
||||
.bigText(notificationText + "\n" + notificationBigText);
|
||||
notificationManager.notify(NOTIFICATION_ID, notificationBuilder.build());
|
||||
}
|
||||
else
|
||||
{
|
||||
} else {
|
||||
notificationCompatBuilder = new NotificationCompat.Builder(context) // need new notificationBuilder and cancel/renotify to get rid of progress bar
|
||||
.setContentTitle(notificationTitle)
|
||||
.setContentText(notificationText)
|
||||
@ -170,155 +157,147 @@ public class FlattrClickWorker extends AsyncTask<Void, String, Void> {
|
||||
.setOngoing(false);
|
||||
notificationManager.notify(NOTIFICATION_ID, notificationCompatBuilder.build());
|
||||
}
|
||||
}
|
||||
else if (run_mode == FLATTR_TOAST)
|
||||
{
|
||||
} else if (run_mode == FLATTR_TOAST) {
|
||||
Toast.makeText(context.getApplicationContext(),
|
||||
notificationText,
|
||||
Toast.LENGTH_LONG)
|
||||
.show();
|
||||
}
|
||||
}
|
||||
|
||||
protected void onEnqueue() {
|
||||
Toast.makeText(context.getApplicationContext(),
|
||||
R.string.flattr_click_enqueued,
|
||||
Toast.LENGTH_LONG)
|
||||
.show();
|
||||
}
|
||||
}
|
||||
|
||||
protected void onSetupNotification() {
|
||||
protected void onEnqueue() {
|
||||
Toast.makeText(context.getApplicationContext(),
|
||||
R.string.flattr_click_enqueued,
|
||||
Toast.LENGTH_LONG)
|
||||
.show();
|
||||
}
|
||||
|
||||
protected void onSetupNotification() {
|
||||
if (android.os.Build.VERSION.SDK_INT >= 16) {
|
||||
notificationBuilder = new Notification.BigTextStyle(
|
||||
new Notification.Builder(context)
|
||||
.setContentTitle(context.getString(R.string.flattring_label))
|
||||
.setAutoCancel(true)
|
||||
.setSmallIcon(R.drawable.stat_notify_sync)
|
||||
.setProgress(0, 0, true)
|
||||
.setOngoing(true));
|
||||
} else {
|
||||
notificationCompatBuilder = new NotificationCompat.Builder(context)
|
||||
.setContentTitle(context.getString(R.string.flattring_label))
|
||||
.setAutoCancel(true)
|
||||
.setSmallIcon(R.drawable.stat_notify_sync)
|
||||
.setProgress(0, 0, true)
|
||||
.setOngoing(true));
|
||||
}
|
||||
else {
|
||||
notificationCompatBuilder = new NotificationCompat.Builder(context)
|
||||
.setContentTitle(context.getString(R.string.flattring_label))
|
||||
.setAutoCancel(true)
|
||||
.setSmallIcon(R.drawable.stat_notify_sync)
|
||||
.setProgress(0, 0, true)
|
||||
.setOngoing(true);
|
||||
.setOngoing(true);
|
||||
}
|
||||
|
||||
notificationManager = (NotificationManager) context.getSystemService(Context.NOTIFICATION_SERVICE);
|
||||
}
|
||||
notificationManager = (NotificationManager) context.getSystemService(Context.NOTIFICATION_SERVICE);
|
||||
}
|
||||
|
||||
@Override
|
||||
protected void onPostExecute(Void result) {
|
||||
if (AppConfig.DEBUG) Log.d(TAG, "Exit code was " + exitCode);
|
||||
@Override
|
||||
protected void onPostExecute(Void result) {
|
||||
if (AppConfig.DEBUG) Log.d(TAG, "Exit code was " + exitCode);
|
||||
|
||||
switch (exitCode) {
|
||||
case NO_TOKEN:
|
||||
notificationManager.cancel(NOTIFICATION_ID);
|
||||
onNoAccessToken();
|
||||
break;
|
||||
case ENQUEUED:
|
||||
onEnqueue();
|
||||
break;
|
||||
case EXIT_DEFAULT:
|
||||
onFlattred();
|
||||
break;
|
||||
case NO_THINGS: // FlattrClickWorker called automatically somewhere to empty flattr queue
|
||||
notificationManager.cancel(NOTIFICATION_ID);
|
||||
break;
|
||||
}
|
||||
}
|
||||
switch (exitCode) {
|
||||
case NO_TOKEN:
|
||||
notificationManager.cancel(NOTIFICATION_ID);
|
||||
onNoAccessToken();
|
||||
break;
|
||||
case ENQUEUED:
|
||||
onEnqueue();
|
||||
break;
|
||||
case EXIT_DEFAULT:
|
||||
onFlattred();
|
||||
break;
|
||||
case NO_THINGS: // FlattrClickWorker called automatically somewhere to empty flattr queue
|
||||
notificationManager.cancel(NOTIFICATION_ID);
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
protected void onPreExecute() {
|
||||
onSetupNotification();
|
||||
}
|
||||
@Override
|
||||
protected void onPreExecute() {
|
||||
onSetupNotification();
|
||||
}
|
||||
|
||||
private static boolean haveInternetAccess(Context context) {
|
||||
ConnectivityManager cm =
|
||||
(ConnectivityManager) context.getSystemService(Context.CONNECTIVITY_SERVICE);
|
||||
|
||||
NetworkInfo networkInfo = cm.getActiveNetworkInfo();
|
||||
return (networkInfo != null && networkInfo.isConnectedOrConnecting());
|
||||
}
|
||||
|
||||
@Override
|
||||
protected Void doInBackground(Void... params) {
|
||||
if (AppConfig.DEBUG) Log.d(TAG, "Starting background work");
|
||||
private static boolean haveInternetAccess(Context context) {
|
||||
ConnectivityManager cm =
|
||||
(ConnectivityManager) context.getSystemService(Context.CONNECTIVITY_SERVICE);
|
||||
|
||||
exitCode = EXIT_DEFAULT;
|
||||
NetworkInfo networkInfo = cm.getActiveNetworkInfo();
|
||||
return (networkInfo != null && networkInfo.isConnectedOrConnecting());
|
||||
}
|
||||
|
||||
if (!FlattrUtils.hasToken()) {
|
||||
exitCode = NO_TOKEN;
|
||||
}
|
||||
else if (DBReader.getFlattrQueueEmpty(context) && extra_flattr_thing == null) {
|
||||
exitCode = NO_THINGS;
|
||||
}
|
||||
else if (!haveInternetAccess(context) || run_mode == ENQUEUE_ONLY) {
|
||||
exitCode = ENQUEUED;
|
||||
}
|
||||
else {
|
||||
List<FlattrThing> flattrList = DBReader.getFlattrQueue(context);
|
||||
Log.d(TAG, "flattrQueue processing list with " + flattrList.size() + " items.");
|
||||
@Override
|
||||
protected Void doInBackground(Void... params) {
|
||||
if (AppConfig.DEBUG) Log.d(TAG, "Starting background work");
|
||||
|
||||
exitCode = EXIT_DEFAULT;
|
||||
|
||||
if (!FlattrUtils.hasToken()) {
|
||||
exitCode = NO_TOKEN;
|
||||
} else if (DBReader.getFlattrQueueEmpty(context) && extra_flattr_thing == null) {
|
||||
exitCode = NO_THINGS;
|
||||
} else if (!haveInternetAccess(context) || run_mode == ENQUEUE_ONLY) {
|
||||
exitCode = ENQUEUED;
|
||||
} else {
|
||||
List<FlattrThing> flattrList = DBReader.getFlattrQueue(context);
|
||||
Log.d(TAG, "flattrQueue processing list with " + flattrList.size() + " items.");
|
||||
|
||||
if (extra_flattr_thing != null)
|
||||
flattrList.add(extra_flattr_thing);
|
||||
|
||||
flattrd.ensureCapacity(flattrList.size());
|
||||
|
||||
for (FlattrThing thing: flattrList) {
|
||||
try {
|
||||
Log.d(TAG, "flattrQueue processing " + thing.getTitle() + " " + thing.getPaymentLink());
|
||||
publishProgress(String.format(context.getString(R.string.flattring_thing), thing.getTitle()));
|
||||
flattrd.ensureCapacity(flattrList.size());
|
||||
|
||||
thing.getFlattrStatus().setUnflattred(); // pop from queue to prevent unflattrable things from getting stuck in flattr queue infinitely
|
||||
for (FlattrThing thing : flattrList) {
|
||||
try {
|
||||
Log.d(TAG, "flattrQueue processing " + thing.getTitle() + " " + thing.getPaymentLink());
|
||||
publishProgress(String.format(context.getString(R.string.flattring_thing), thing.getTitle()));
|
||||
|
||||
FlattrUtils.clickUrl(context, thing.getPaymentLink());
|
||||
flattrd.add(thing.getTitle());
|
||||
thing.getFlattrStatus().setUnflattred(); // pop from queue to prevent unflattrable things from getting stuck in flattr queue infinitely
|
||||
|
||||
thing.getFlattrStatus().setFlattred();
|
||||
}
|
||||
catch (Exception e) {
|
||||
Log.d(TAG, "flattrQueue processing exception at item " + thing.getTitle() + " " + e.getMessage());
|
||||
flattr_failed.ensureCapacity(flattrList.size());
|
||||
flattr_failed.add(thing.getTitle() + ": " + e.getMessage());
|
||||
}
|
||||
FlattrUtils.clickUrl(context, thing.getPaymentLink());
|
||||
flattrd.add(thing.getTitle());
|
||||
|
||||
thing.getFlattrStatus().setFlattred();
|
||||
} catch (Exception e) {
|
||||
Log.d(TAG, "flattrQueue processing exception at item " + thing.getTitle() + " " + e.getMessage());
|
||||
flattr_failed.ensureCapacity(flattrList.size());
|
||||
flattr_failed.add(thing.getTitle() + ": " + e.getMessage());
|
||||
}
|
||||
Log.d(TAG, "flattrQueue processing - going to write thing back to db with flattr_status " + Long.toString(thing.getFlattrStatus().toLong()));
|
||||
DBWriter.setFlattredStatus(context, thing, false);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
protected void onProgressUpdate(String... names) {
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
protected void onProgressUpdate(String... names) {
|
||||
if (android.os.Build.VERSION.SDK_INT >= 16) {
|
||||
notificationBuilder.setBigContentTitle(names[0]);
|
||||
notificationManager.notify(NOTIFICATION_ID, notificationBuilder.build());
|
||||
}
|
||||
else {
|
||||
} else {
|
||||
notificationCompatBuilder.setContentText(names[0]);
|
||||
notificationManager.notify(NOTIFICATION_ID, notificationCompatBuilder.build());
|
||||
}
|
||||
}
|
||||
|
||||
@SuppressLint("NewApi")
|
||||
public void executeAsync() {
|
||||
FlattrUtils.hasToken();
|
||||
if (android.os.Build.VERSION.SDK_INT > android.os.Build.VERSION_CODES.GINGERBREAD_MR1) {
|
||||
executeOnExecutor(THREAD_POOL_EXECUTOR);
|
||||
} else {
|
||||
execute();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@SuppressLint("NewApi")
|
||||
public void executeAsync() {
|
||||
FlattrUtils.hasToken();
|
||||
if (android.os.Build.VERSION.SDK_INT > android.os.Build.VERSION_CODES.GINGERBREAD_MR1) {
|
||||
executeOnExecutor(THREAD_POOL_EXECUTOR);
|
||||
} else {
|
||||
execute();
|
||||
}
|
||||
}
|
||||
|
||||
public void executeSync() {
|
||||
class DirectExecutor implements Executor {
|
||||
public void execute(Runnable r) {
|
||||
r.run();
|
||||
r.run();
|
||||
}
|
||||
}
|
||||
FlattrUtils.hasToken();
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user