package com.google.android.apps.iosched.service;
import java.io.IOException;
import java.io.InputStream;
import java.util.zip.GZIPInputStream;
import org.apache.http.Header;
import org.apache.http.HeaderElement;
import org.apache.http.HttpEntity;
import org.apache.http.HttpRequest;
import org.apache.http.HttpRequestInterceptor;
import org.apache.http.HttpResponse;
import org.apache.http.HttpResponseInterceptor;
import org.apache.http.client.HttpClient;
import org.apache.http.entity.HttpEntityWrapper;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.params.BasicHttpParams;
import org.apache.http.params.HttpConnectionParams;
import org.apache.http.params.HttpParams;
import org.apache.http.params.HttpProtocolParams;
import org.apache.http.protocol.HttpContext;
import android.app.IntentService;
import android.app.Service;
import android.content.ContentResolver;
import android.content.Context;
import android.content.Intent;
import android.content.SharedPreferences;
import android.content.pm.PackageInfo;
import android.content.pm.PackageManager;
import android.content.pm.PackageManager.NameNotFoundException;
import android.content.res.Resources;
import android.os.Bundle;
import android.os.ResultReceiver;
import android.text.format.DateUtils;
import android.util.Log;
import com.google.android.apps.iosched.io.LocalBlocksHandler;
import com.google.android.apps.iosched.io.LocalExecutor;
import com.google.android.apps.iosched.io.LocalRoomsHandler;
import com.google.android.apps.iosched.io.LocalSearchSuggestHandler;
import com.google.android.apps.iosched.io.LocalSessionsHandler;
import com.google.android.apps.iosched.io.LocalTracksHandler;
import com.google.android.apps.iosched.io.RemoteExecutor;
import com.google.android.apps.iosched.io.RemoteSessionsHandler;
import com.google.android.apps.iosched.io.RemoteSpeakersHandler;
import com.google.android.apps.iosched.io.RemoteVendorsHandler;
import com.google.android.apps.iosched.io.RemoteWorksheetsHandler;
import com.google.android.apps.iosched.provider.ScheduleProvider;
import com.novoda.droidcon2011.R;
private static final String TAG = "SyncService";
public static final String EXTRA_STATUS_RECEIVER =
"com.google.android.iosched.extra.STATUS_RECEIVER";
public static final int STATUS_RUNNING = 0x1;
public static final int STATUS_ERROR = 0x2;
public static final int STATUS_FINISHED = 0x3;
private static final int SECOND_IN_MILLIS = (int) DateUtils.SECOND_IN_MILLIS;
private static final String WORKSHEETS_URL = "https://spreadsheets.google.com/feeds/worksheets/0AlPB-AKNQC8udEVxaGVTQ19vaG9SOFFGc080WkdHMkE/public/basic";
private static final String HEADER_ACCEPT_ENCODING = "Accept-Encoding";
private static final String ENCODING_GZIP = "gzip";
private static final int VERSION_NONE = 0;
private static final int VERSION_CURRENT = 11;
private LocalExecutor mLocalExecutor;
private RemoteExecutor mRemoteExecutor;
super(TAG);
}
@Override
super.onCreate();
final HttpClient httpClient = getHttpClient(this);
final ContentResolver resolver = getContentResolver();
mLocalExecutor = new LocalExecutor(getResources(), resolver);
mRemoteExecutor = new RemoteExecutor(httpClient, resolver);
}
@Override
Log.d(TAG, "onHandleIntent(intent=" + intent.toString() + ")");
final ResultReceiver receiver = intent.getParcelableExtra(EXTRA_STATUS_RECEIVER);
if (receiver != null) receiver.send(STATUS_RUNNING, Bundle.EMPTY);
final Context context = this;
final SharedPreferences prefs = getSharedPreferences(Prefs.IOSCHED_SYNC,
Context.MODE_PRIVATE);
final int localVersion = prefs.getInt(Prefs.LOCAL_VERSION, VERSION_NONE);
try {
final long startLocal = System.currentTimeMillis();
final boolean localParse = localVersion < VERSION_CURRENT;
Log.d(TAG, "found localVersion=" + localVersion + " and VERSION_CURRENT="
+ VERSION_CURRENT);
if (localParse) {
mLocalExecutor.execute(R.xml.blocks, new LocalBlocksHandler());
mLocalExecutor.execute(R.xml.rooms, new LocalRoomsHandler());
mLocalExecutor.execute(R.xml.tracks, new LocalTracksHandler());
mLocalExecutor.execute(R.xml.search_suggest, new LocalSearchSuggestHandler());
mLocalExecutor.execute(R.xml.sessions, new LocalSessionsHandler());
mLocalExecutor.execute(context, "cache-sessions.xml", new RemoteSessionsHandler());
mLocalExecutor.execute(context, "cache-speakers.xml", new RemoteSpeakersHandler());
mLocalExecutor.execute(context, "cache-vendors.xml", new RemoteVendorsHandler());
prefs.edit().putInt(Prefs.LOCAL_VERSION, VERSION_CURRENT).commit();
}
Log.d(TAG, "local sync took " + (System.currentTimeMillis() - startLocal) + "ms");
final long startRemote = System.currentTimeMillis();
mRemoteExecutor
.executeGet(WORKSHEETS_URL, new RemoteWorksheetsHandler(mRemoteExecutor));
Log.d(TAG, "remote sync took " + (System.currentTimeMillis() - startRemote) + "ms");
} catch (Exception e) {
Log.e(TAG, "Problem while syncing", e);
if (receiver != null) {
final Bundle bundle = new Bundle();
bundle.putString(Intent.EXTRA_TEXT, e.toString());
receiver.send(STATUS_ERROR, bundle);
}
}
Log.d(TAG, "sync finished");
if (receiver != null) receiver.send(STATUS_FINISHED, Bundle.EMPTY);
}
final HttpParams params = new BasicHttpParams();
HttpConnectionParams.setConnectionTimeout(params, 20 * SECOND_IN_MILLIS);
HttpConnectionParams.setSoTimeout(params, 20 * SECOND_IN_MILLIS);
HttpConnectionParams.setSocketBufferSize(params, 8192);
HttpProtocolParams.setUserAgent(params, buildUserAgent(context));
final DefaultHttpClient client = new DefaultHttpClient(params);
client.addRequestInterceptor(new HttpRequestInterceptor() {
public void process(HttpRequest request, HttpContext context) {
if (!request.containsHeader(HEADER_ACCEPT_ENCODING)) {
request.addHeader(HEADER_ACCEPT_ENCODING, ENCODING_GZIP);
}
}
});
client.addResponseInterceptor(new HttpResponseInterceptor() {
public void process(HttpResponse response, HttpContext context) {
final HttpEntity entity = response.getEntity();
final Header encoding = entity.getContentEncoding();
if (encoding != null) {
for (HeaderElement element : encoding.getElements()) {
if (element.getName().equalsIgnoreCase(ENCODING_GZIP)) {
response.setEntity(new InflatingEntity(response.getEntity()));
break;
}
}
}
}
});
return client;
}
try {
final PackageManager manager = context.getPackageManager();
final PackageInfo info = manager.getPackageInfo(context.getPackageName(), 0);
return info.packageName + "/" + info.versionName
+ " (" + info.versionCode + ") (gzip)";
} catch (NameNotFoundException e) {
return null;
}
}
super(wrapped);
}
@Override
public InputStream
getContent()
throws IOException {
return new GZIPInputStream(wrappedEntity.getContent());
}
@Override
return -1;
}
}
private interface Prefs {
String IOSCHED_SYNC = "iosched_sync";
String LOCAL_VERSION = "local_version";
}
}