package de.android.mobiads.batch;
+import java.io.BufferedReader;
+import java.io.FileNotFoundException;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.io.OutputStream;
+import java.io.UnsupportedEncodingException;
import java.net.MalformedURLException;
+import java.net.URISyntaxException;
import java.net.URL;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
+import org.apache.http.HttpEntity;
+import org.apache.http.HttpResponse;
+import org.apache.http.HttpStatus;
+import org.apache.http.HttpVersion;
+import org.apache.http.client.ClientProtocolException;
+import org.apache.http.client.ResponseHandler;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.params.CoreProtocolPNames;
+import org.json.JSONArray;
+import org.json.JSONException;
+import org.json.JSONObject;
+import org.json.JSONTokener;
+import android.content.ContentValues;
+import android.content.Context;
+import android.database.Cursor;
import android.location.Location;
+import android.net.Uri;
import android.net.http.AndroidHttpClient;
import android.util.Log;
+import android.webkit.CookieManager;
+import android.webkit.CookieSyncManager;
+import de.android.mobiads.R;
+import de.android.mobiads.provider.Indexer;
public class MobiAdsBatch {
private static final String TAG = "MobiAdsBatch";
private static final int tasksMax = 10;
private final ExecutorService exec = Executors.newFixedThreadPool(tasksMax);
- private final String encoded;
private final AndroidHttpClient httpClient;
+ private final Context context;
+ private final String mobiAdsCookie;
- public MobiAdsBatch (String userAgent, String encoded) {
- this.encoded = encoded;
-
+ public MobiAdsBatch (String userAgent, String encoded, Context context) {
+ this.context = context;
this.httpClient = AndroidHttpClient.newInstance(userAgent);
+
+ this.httpClient.getParams().setParameter(CoreProtocolPNames.HTTP_CONTENT_CHARSET, encoded);
+ this.httpClient.getParams().setParameter(CoreProtocolPNames.PROTOCOL_VERSION, HttpVersion.HTTP_1_1);
+
+ CookieSyncManager.createInstance(this.context);
+ this.mobiAdsCookie = CookieManager.getInstance().getCookie(this.context.getResources().getString(R.string.url_web));
}
public void endBatch() {
this.exec.shutdown();
+ this.httpClient.close();
}
private class Batch implements Runnable {
+ private final URL url;
private Batch (URL url) {
-
+ this.url = url;
}
@Override
public void run() {
- // TODO Auto-generated method stub
+ ResponseHandler<StringBuilder> handler = new ResponseHandler<StringBuilder>() {
+ public StringBuilder handleResponse(HttpResponse response) throws ClientProtocolException, IOException {
+ //There could be a null as return value in case of not receiving any data from the server,
+ //although the HTTP connection was OK.
+ return sortResponse(response);
+ }
+ };
+
+ try {
+ final HttpGet httpGet = new HttpGet();
+
+ httpGet.setHeader("Cookie", MobiAdsBatch.this.mobiAdsCookie);
+ try {
+ httpGet.setURI(this.url.toURI());
+ StringBuilder builder = httpClient.execute(httpGet, handler);
+ JSONTokener tokener = new JSONTokener(builder.toString());
+ JSONArray finalResult = new JSONArray(tokener);
+ Uri uriInsert = null;
+
+ //TODO: finalResult.length() -1? Maybe I should remove the last semicolon in the JSON response.
+ for (int i = 0; i < (finalResult.length() -1); i++) {
+ JSONObject objects = finalResult.getJSONObject(i);
+ if ((uriInsert = updatedIndexer(objects)) != null) {
+ try {
+ downloadAds((String)objects.get("domain"), (String)objects.get("link"), (String) objects.get("id"));
+ } catch (Throwable e1) {
+ //In case of any error, remove the index database and the file
+ //or chunk successfully stored before the error.
+ try {
+ MobiAdsBatch.this.context.getContentResolver().delete(uriInsert, null, null);
+ MobiAdsBatch.this.context.deleteFile((String) objects.get("id"));
+ } catch (Throwable e2) {
+ // Log this exception. The original exception (if there is one) is more
+ // important and will be thrown to the caller.
+ Log.w("Error removing content after an exception.", e2);
+ }
+
+ //Besides throw the original exception.
+ if (e1 instanceof Error) {
+ throw (Error) e1;
+ }
+ if (e1 instanceof RuntimeException) {
+ throw (RuntimeException) e1;
+ }
+ if (e1 instanceof Exception) {
+ throw (IOException) e1;
+ }
+ //throwing Throwable. At least the original exception is not lost :/
+ throw e1;
+ }
+ }
+
+ }
+ } catch (URISyntaxException e) {
+ Log.e(TAG, "Error while creating URI from URL.", e);
+ } catch (ClientProtocolException e) {
+ Log.e(TAG, "Error while executing HTTP client connection.", e);
+ } catch (UnsupportedEncodingException e) {
+ Log.e(TAG, "Error InputStreamReader.", e);
+ } catch (IOException e) {
+ Log.e(TAG, "Error while executing HTTP client connection.", e);
+ } catch (JSONException e) {
+ Log.e(TAG, "Error while parsing JSON response.", e);
+ }
+ } catch (Throwable e) {
+ //Not sure if it is "legal" to catch Throwable...
+ Log.e(TAG, "Caught exception, something went wrong", e);
+ }
+ }
+
+ public StringBuilder sortResponse(HttpResponse httpResponse) throws IOException {
+ StringBuilder builder = null;
+
+ if (httpResponse != null) {
+ switch (httpResponse.getStatusLine().getStatusCode()) {
+ case HttpStatus.SC_OK:
+ //OK
+ HttpEntity entity = httpResponse.getEntity();
+ if (entity != null) {
+ //outside try/catch block.
+ //In case of exception it is thrown, otherwise instream will not be null and we get into the try/catch block.
+ InputStreamReader instream = new InputStreamReader(entity.getContent()/*, entity.getContentEncoding().getValue()*/);
+ try {
+ BufferedReader reader = new BufferedReader(instream);
+ builder = new StringBuilder();
+ String currentLine = null;
+ currentLine = reader.readLine();
+ while (currentLine != null) {
+ builder.append(currentLine).append("\n");
+ currentLine = reader.readLine();
+ }
+ } finally {
+ //instream will never be null in case of reaching this code, cause it was initialized outside try/catch block.
+ //In case of exception here, it is thrown to the upper layer.
+ instream.close();
+ }
+ }
+ break;
+ case HttpStatus.SC_UNAUTHORIZED:
+ //ERROR IN USERNAME OR PASSWORD
+ throw new SecurityException("Unauthorized access: error in username or password.");
+ case HttpStatus.SC_BAD_REQUEST:
+ //WHAT THE HECK ARE YOU DOING?
+ throw new IllegalArgumentException("Bad request.");
+ default:
+ throw new IllegalArgumentException("Error while retrieving the HTTP status line.");
+ }
+ }
+ return builder;
+ }
+
+ public void downloadAds(String domain, String link, String path)
+ throws MalformedURLException, URISyntaxException, FileNotFoundException, IOException {
+ final HttpGet httpGet = new HttpGet();
+ final String URLAd = "http://" + domain + "/" + link;
+ HttpResponse httpResponse = null;
+ URL url = null;
+ OutputStream outputStream = null;
+ try {
+ url = new URL(URLAd);
+ httpGet.setURI(url.toURI());
+ //By default max 2 connections at the same time per host.
+ //and infinite time out (we could wait here forever if we do not use a timeout see: 2.1. Connection parameters
+ //http://hc.apache.org/httpcomponents-client-ga/tutorial/html/connmgmt.html) The same for execute with handler.
+ httpResponse = MobiAdsBatch.this.httpClient.execute(httpGet);
+
+ if (httpResponse != null) {
+ switch (httpResponse.getStatusLine().getStatusCode()) {
+ case HttpStatus.SC_OK:
+ outputStream = MobiAdsBatch.this.context.openFileOutput(path, Context.MODE_PRIVATE);
+ try {
+ httpResponse.getEntity().writeTo(outputStream);
+ } finally {
+ //Closing the outputStream
+ outputStream.close();
+ }
+ break;
+ case HttpStatus.SC_UNAUTHORIZED:
+ //ERROR IN USERNAME OR PASSWORD
+ throw new SecurityException("Unauthorized access: error in username or password.");
+ case HttpStatus.SC_BAD_REQUEST:
+ //WHAT THE HECK ARE YOU DOING?
+ throw new IllegalArgumentException("Bad request.");
+ default:
+ throw new IllegalArgumentException("Error while retrieving the HTTP status line.");
+ }
+ }
+ } finally {
+ try {
+ if (httpResponse != null) {
+ HttpEntity entity = httpResponse.getEntity();
+ if (entity != null) {
+ entity.consumeContent();
+ }
+ }
+ } catch (Throwable e) {
+ // Log this exception. The original exception (if there is one) is more
+ // important and will be thrown to the caller. See: {@link AbstractHttpClient}
+ Log.w("Error consuming content after an exception.", e);
+ }
+ }
}
+ public Uri updatedIndexer (JSONObject objects) throws JSONException {
+ Uri updated = null;
+ Uri uri = Uri.parse("content://" + "de.android.mobiads.provider" + "/" + "indexer" + "/idad/" + objects.get("id"));
+
+ synchronized (MobiAdsBatch.this) {
+ Cursor cursor = MobiAdsBatch.this.context.getContentResolver().query(uri, null, null, null, null);
+
+ if (cursor != null) {
+ if (!cursor.moveToFirst()) {
+ //If the advertisement was not stored on the database
+ ContentValues values = new ContentValues();
+ values.put(Indexer.Index.COLUMN_NAME_ID_AD, new Integer((String) objects.get("id")));
+ values.put(Indexer.Index.COLUMN_NAME_PATH, (String) objects.get("id"));
+ updated = MobiAdsBatch.this.context.getContentResolver().insert(Indexer.Index.CONTENT_ID_URI_BASE, values);
+ }
+ cursor.close();
+ }
+ }
+ return updated;
+ }
}
}
projects / JavaForFun / commitdiff