X-Git-Url: http://www.average.org/gitweb/?p=WhereAmI.git;a=blobdiff_plain;f=src%2Forg%2Faverage%2Fwhereami%2FPhoneLog.java;h=ff64fa9b3863aaf9092064a3205bf51c34f9d840;hp=dbb735357eaff4a7086edb4e51f3236a4dbebc11;hb=816e15ad1c9de478be113a53a51b483791503c30;hpb=44b9534a0dc3709450e434089b09a6039275d512 diff --git a/src/org/average/whereami/PhoneLog.java b/src/org/average/whereami/PhoneLog.java index dbb7353..ff64fa9 100644 --- a/src/org/average/whereami/PhoneLog.java +++ b/src/org/average/whereami/PhoneLog.java @@ -1,17 +1,11 @@ package org.average.whereami; -import org.average.whereami.CredentialStore; +import org.average.whereami.PersistentStore; -//import java.lang.Long; +import java.io.IOException; -import com.google.api.client.extensions.android2.AndroidHttp; -import com.google.api.client.auth.oauth2.draft10.AccessTokenResponse; -import com.google.api.client.googleapis.auth.oauth2.draft10.GoogleAccessProtectedResource; +import com.google.api.client.googleapis.json.GoogleJsonResponseException; import com.google.api.client.http.HttpResponseException; -import com.google.api.client.http.HttpTransport; -import com.google.api.client.http.javanet.NetHttpTransport; -import com.google.api.client.json.JsonFactory; -import com.google.api.client.json.jackson.JacksonFactory; import com.google.api.client.util.DateTime; import com.google.api.services.calendar.Calendar; import com.google.api.services.calendar.CalendarRequest; @@ -23,7 +17,7 @@ import com.google.common.collect.Lists; import android.content.Context; import android.content.res.Resources; -import android.content.SharedPreferences; +import android.text.format.Time; import android.util.Log; public final class PhoneLog extends Oracle { @@ -32,49 +26,153 @@ public final class PhoneLog extends Oracle { private Calendar calendar; - public PhoneLog(final Resources res, final CredentialStore store) { - HttpTransport transport = AndroidHttp.newCompatibleTransport(); - JsonFactory jsonFactory = new JacksonFactory(); - AccessTokenResponse token = store.read(); - Log.v(TAG, "tokens - access: \"" + token.accessToken + - "\", refresh: \"" + token.refreshToken + - "\", client_id: \"" + ClientCredentials.CLIENT_ID + - "\", client_secret: \"" + - ClientCredentials.CLIENT_SECRET + - "\""); - GoogleAccessProtectedResource accessProtectedResource = - new GoogleAccessProtectedResource( - token.accessToken, - transport, jsonFactory, - ClientCredentials.CLIENT_ID, - ClientCredentials.CLIENT_SECRET, - token.refreshToken) - { - @Override - public void onAccessToken( - String accessToken) { - Log.v(TAG, "Update access token to \"" + accessToken + "\""); - store.updateAccessToken( - accessToken); - } - } - ; - Calendar.Builder cbldr = Calendar.builder(transport, - jsonFactory); - cbldr.setHttpRequestInitializer(accessProtectedResource); - cbldr.setApplicationName("WhereAmI/1.0"); - calendar = cbldr.build(); + private PersistentStore store; + private String calendar_name; + private String peer_name; + private String calendar_id; + private String nocalendar; + private String noevents; + + public PhoneLog(final Resources res, final PersistentStore store) { + super(res, store); + this.store = store; + nocalendar = res.getString(R.string.nocalendar); + noevents = res.getString(R.string.noevents); + calendar_name = store.get("calendar_name"); + peer_name = store.get("peer_name"); + calendar_id = store.get("calendar_id"); + + calendar = Calendar.builder(httpTransport, jsonFactory) + .setHttpRequestInitializer(accessProtectedResource) + .setApplicationName("WhereAmI/1.0").build(); } @Override public final String getResult() { try { Log.v(TAG, "entering getResult"); - return TAG + " complete"; - } catch (Exception ex) { - Log.v(TAG, "exception in getResult: " + ex); - ex.printStackTrace(); - return ex.getMessage(); - } + if (calendar_id == null || calendar_id == "") { + calendar_id = scanCalendars(calendar_name); + } + if (calendar_id == null || calendar_id == "") { + return nocalendar + " \"" + + calendar_name + "\""; + } else { + store.put("calendar_id", calendar_id); + return scanEvents(calendar_id, peer_name); + } + } catch (GoogleJsonResponseException e) { + Log.e(TAG, "GoogleJsonResponseException: " + e); + if (e.getResponse().getStatusCode() == 401) { + return authErrorMessage; + } else { + return e.getMessage(); + } + } catch (HttpResponseException e) { + Log.e(TAG, "HttpResponseException: " + e); + return e.getMessage(); + } catch (IOException e) { + e.printStackTrace(); + return e.getMessage(); + } + } + + private String scanCalendars(String calendar_name) + throws java.io.IOException { + String res = ""; + Log.v(TAG, "Entering scanCalendars for \"" + + calendar_name + "\""); + + CalendarList cl = calendar.calendarList().list().execute(); + while (true) { + String pt = cl.getNextPageToken(); + Log.v(TAG, "got cl with pt=" + pt); + for (CalendarListEntry le : cl.getItems()) { + Log.v(TAG, "entry " + le.getId() + ":\"" + + le.getSummary() + "\""); + if (le.getSummary().equals(calendar_name)) { + res = le.getId(); + //break; // get all in the log + } + } + if (pt != null && pt != "") { + cl = calendar.calendarList().list() + .setPageToken(pt).execute(); + } else { + break; + } + } + + return res; + } + + private String scanEvents(String calendar_id, String peer_name) + throws java.io.IOException { + Log.v(TAG, "Entering scanEvents for \"" + + peer_name + "\" in \"" + calendar_id + "\""); + Integer count = 0; + Time ago = new Time(); + ago.set(System.currentTimeMillis() - 604800000L); + Long latestStartTime = 0L; + Long latestStopTime = 0L; + Boolean latestWasOutgoing = false; + Boolean wasFound = false; + + Events events = calendar.events().list(calendar_id) + .setTimeMin(ago.format3339(false)) + .setQ(peer_name) + .execute(); + while (true) { + String pt = events.getNextPageToken(); + Log.v(TAG, "got events with pt=" + pt); + for (Event event : events.getItems()) { + count++; + String evSummary = event.getSummary(); + Long evStart = event.getStart() + .getDateTime().getValue(); + Long evStop = event.getEnd() + .getDateTime().getValue(); + Log.v(TAG, "event " + evStart + + " - " + evStop + + " : \"" + evSummary + "\""); + if ((evSummary.startsWith("Called ") || + evSummary.startsWith("Call from ")) && + evStart > latestStartTime) { + latestStartTime = evStart; + latestStopTime = evStop; + latestWasOutgoing = evSummary + .startsWith("Called "); + wasFound = true; + } + } + if (count < 100 && pt != null && pt != "") { + events = calendar.events().list(calendar_id) + .setTimeMin(ago.format3339(false)) + .setQ(peer_name) + .setPageToken(pt).execute(); + } else { + break; + } + } + + if (wasFound) { + return makeMessage(latestStartTime, latestStopTime, + latestWasOutgoing); + } else { + return noevents; + } + } + + private String makeMessage(Long latestStartTime, Long latestStopTime, + Boolean latestWasOutgoing) { + Time stime = new Time(); + stime.set(latestStartTime); + Long durms = latestStopTime - latestStartTime; + Log.v(TAG, "Chosen event: start " + stime + + " for " + durms + " msec"); + Long nowms = System.currentTimeMillis(); + return "" + (latestWasOutgoing?"Out ":"In ") + + (durms/3600000) + " min " + + stime.format("%H:%M"); } }