From 7919aa07a042e71a7de08a5cbd92b99b4be60e25 Mon Sep 17 00:00:00 2001
From: YuviPanda <yuvipanda@gmail.com>
Date: Wed, 30 Jan 2013 05:25:24 +0530
Subject: [PATCH] Refactor to send out Broadcasts events when uploading

---
 commons/AndroidManifest.xml                   |  11 +-
 .../commons/ContributionsActivity.java        |  52 +++++++
 .../org/wikimedia/commons/ShareActivity.java  |  11 +-
 .../org/wikimedia/commons/UploadService.java  | 144 +++++++++++-------
 .../org/wikimedia/commons/media/Media.java    |  21 ++-
 5 files changed, 177 insertions(+), 62 deletions(-)
 create mode 100644 commons/src/main/java/org/wikimedia/commons/ContributionsActivity.java

diff --git a/commons/AndroidManifest.xml b/commons/AndroidManifest.xml
index f9531fc61..2d0e2f628 100644
--- a/commons/AndroidManifest.xml
+++ b/commons/AndroidManifest.xml
@@ -39,7 +39,16 @@
                <!-- Remove Audio Support for now <data android:mimeType="audio/*" /> -->
             </intent-filter>
         </activity>
-
+        <activity
+                android:name=".ContributionsActivity"
+                android:icon="@drawable/ic_launcher"
+                android:label="@string/title_activity_share"
+                 >
+            <intent-filter>
+                <category android:name="android.intent.category.LAUNCHER"/>
+                <action android:name="android.intent.action.MAIN"/>
+             </intent-filter>
+        </activity>
         <service android:name="UploadService" >
         </service>
         <service
diff --git a/commons/src/main/java/org/wikimedia/commons/ContributionsActivity.java b/commons/src/main/java/org/wikimedia/commons/ContributionsActivity.java
new file mode 100644
index 000000000..2ac22ed67
--- /dev/null
+++ b/commons/src/main/java/org/wikimedia/commons/ContributionsActivity.java
@@ -0,0 +1,52 @@
+package org.wikimedia.commons;
+
+import android.content.BroadcastReceiver;
+import android.content.*;
+import android.os.Bundle;
+import android.support.v4.content.LocalBroadcastManager;
+import android.util.Log;
+import com.actionbarsherlock.app.SherlockActivity;
+import org.wikimedia.commons.media.Media;
+
+public class ContributionsActivity extends SherlockActivity  {
+
+    private LocalBroadcastManager localBroadcastManager;
+
+    private String[] broadcastsToReceive = {
+            UploadService.INTENT_UPLOAD_STARTED,
+            UploadService.INTENT_UPLOAD_QUEUED,
+            UploadService.INTENT_UPLOAD_PROGRESS,
+            UploadService.INTENT_UPLOAD_COMPLETE
+    };
+
+    private BroadcastReceiver messageReceiver = new BroadcastReceiver() {
+        @Override
+        public void onReceive(Context context, Intent intent) {
+            Media media = (Media)intent.getParcelableExtra(UploadService.EXTRA_MEDIA);
+            Log.d("Commons", "Completed " + intent.getAction() +" of " + media.getFileName());
+        }
+    };
+
+    @Override
+    protected void onResume() {
+        super.onResume();
+        for(int i=0; i < broadcastsToReceive.length; i++) {
+            localBroadcastManager.registerReceiver(messageReceiver, new IntentFilter(broadcastsToReceive[i]));
+        }
+    }
+
+    @Override
+    protected void onPause() {
+        super.onPause();
+        for(int i=0; i < broadcastsToReceive.length; i++) {
+            localBroadcastManager.unregisterReceiver(messageReceiver);
+        }
+    }
+
+    @Override
+    protected void onCreate(Bundle savedInstanceState) {
+        super.onCreate(savedInstanceState);
+        localBroadcastManager = LocalBroadcastManager.getInstance(this);
+        setContentView(R.layout.activity_contributions);
+    }
+}
diff --git a/commons/src/main/java/org/wikimedia/commons/ShareActivity.java b/commons/src/main/java/org/wikimedia/commons/ShareActivity.java
index 9fcf56a94..c3d1585f0 100644
--- a/commons/src/main/java/org/wikimedia/commons/ShareActivity.java
+++ b/commons/src/main/java/org/wikimedia/commons/ShareActivity.java
@@ -18,6 +18,7 @@ import com.actionbarsherlock.view.MenuItem;
 import com.actionbarsherlock.view.Window;
 import android.widget.*;
 import android.view.*;
+import org.wikimedia.commons.media.Media;
 
 
 public class ShareActivity extends AuthenticatedActivity {
@@ -56,11 +57,11 @@ public class ShareActivity extends AuthenticatedActivity {
                 @Override
                 public void onClick(View v) {
                     Intent uploadIntent = new Intent(getApplicationContext(), UploadService.class);
-                    uploadIntent.putExtra(UploadService.EXTRA_MEDIA_URI, mediaUri);
-                    uploadIntent.putExtra(UploadService.EXTRA_TARGET_FILENAME, titleEdit.getText().toString());
-                    uploadIntent.putExtra(UploadService.EXTRA_DESCRIPTION, descEdit.getText().toString());
-                    uploadIntent.putExtra(UploadService.EXTRA_MIMETYPE, mimeType);
-                    uploadIntent.putExtra(UploadService.EXTRA_EDIT_SUMMARY, "Mobile upload from Wikimedia Commons Android app");
+                    uploadIntent.putExtra(Media.EXTRA_MEDIA_URI, mediaUri);
+                    uploadIntent.putExtra(Media.EXTRA_TARGET_FILENAME, titleEdit.getText().toString());
+                    uploadIntent.putExtra(Media.EXTRA_DESCRIPTION, descEdit.getText().toString());
+                    uploadIntent.putExtra(Media.EXTRA_MIMETYPE, mimeType);
+                    uploadIntent.putExtra(Media.EXTRA_EDIT_SUMMARY, "Mobile upload from Wikimedia Commons Android app");
                     startService(uploadIntent);
                     Toast startingToast = Toast.makeText(that, R.string.uploading_started, Toast.LENGTH_LONG);
                     startingToast.show(); 
diff --git a/commons/src/main/java/org/wikimedia/commons/UploadService.java b/commons/src/main/java/org/wikimedia/commons/UploadService.java
index 109e503ed..096727322 100644
--- a/commons/src/main/java/org/wikimedia/commons/UploadService.java
+++ b/commons/src/main/java/org/wikimedia/commons/UploadService.java
@@ -3,6 +3,7 @@ package org.wikimedia.commons;
 import java.io.*;
 import java.util.Date;
 
+import android.support.v4.content.LocalBroadcastManager;
 import org.mediawiki.api.*;
 import org.wikimedia.commons.media.Media;
 
@@ -23,14 +24,16 @@ import android.net.*;
 
 public class UploadService extends IntentService {
 
-    private static final String EXTRA_PREFIX = "org.wikimedia.commons.uploader";
-    public static final String EXTRA_MEDIA_URI = EXTRA_PREFIX + ".media_uri";
-    public static final String EXTRA_TARGET_FILENAME = EXTRA_PREFIX + ".filename";
-    public static final String EXTRA_DESCRIPTION = EXTRA_PREFIX + ".description";
-    public static final String EXTRA_EDIT_SUMMARY = EXTRA_PREFIX + ".summary";
-    public static final String EXTRA_MIMETYPE = EXTRA_PREFIX + ".mimetype";
-   
+    private static final String EXTRA_PREFIX = "org.wikimedia.commons.upload";
+    public static final String INTENT_UPLOAD_COMPLETE = EXTRA_PREFIX + ".completed";
+    public static final String INTENT_UPLOAD_STARTED = EXTRA_PREFIX + ".started";
+    public static final String INTENT_UPLOAD_QUEUED = EXTRA_PREFIX + ".queued";
+    public static final String INTENT_UPLOAD_PROGRESS = EXTRA_PREFIX + ".progress";
+    public static final String EXTRA_MEDIA = ".media";
+    public static final String EXTRA_TRANSFERRED_BYTES = ".progress.transferred";
+
     private NotificationManager notificationManager;
+    private LocalBroadcastManager localBroadcastManager;
     private CommonsApplication app;
 
     private Notification curProgressNotification;
@@ -56,15 +59,17 @@ public class UploadService extends IntentService {
         Notification curNotification;
         String notificationTag;
         boolean notificationTitleChanged;
+        Media media;
        
         String notificationProgressTitle;
         String notificationFinishingTitle;
 
-        public NotificationUpdateProgressListener(Notification curNotification, String notificationTag, String notificationProgressTitle, String notificationFinishingTitle) {
+        public NotificationUpdateProgressListener(Notification curNotification, String notificationTag, String notificationProgressTitle, String notificationFinishingTitle, Media media) {
             this.curNotification = curNotification;
             this.notificationTag = notificationTag;
             this.notificationProgressTitle = notificationProgressTitle;
             this.notificationFinishingTitle = notificationFinishingTitle;
+            this.media = media;
         }
         @Override
         public void onProgress(long transferred, long total) {
@@ -75,6 +80,9 @@ public class UploadService extends IntentService {
                 curView.setTextViewText(R.id.uploadNotificationsCount, String.format(getString(R.string.uploads_pending_notification_indicator), toUpload));
                 Log.d("Commons", String.format("%d uploads left", toUpload));
                 notificationTitleChanged = true;
+                Intent mediaUploadStartedEvent = new Intent(INTENT_UPLOAD_STARTED);
+                mediaUploadStartedEvent.putExtra(EXTRA_MEDIA, media);
+                localBroadcastManager.sendBroadcast(mediaUploadStartedEvent);
             }
             if(transferred == total) {
                 // Completed!
@@ -83,6 +91,10 @@ public class UploadService extends IntentService {
             } else {
                 curNotification.contentView.setProgressBar(R.id.uploadNotificationProgress, 100, (int)(((double)transferred / (double)total) * 100), false);
                 notificationManager.notify(NOTIFICATION_DOWNLOAD_IN_PROGRESS, curNotification);
+                Intent mediaUploadProgressIntent = new Intent(INTENT_UPLOAD_PROGRESS);
+                mediaUploadProgressIntent.putExtra(EXTRA_MEDIA, media);
+                mediaUploadProgressIntent.putExtra(EXTRA_TRANSFERRED_BYTES, transferred);
+                localBroadcastManager.sendBroadcast(mediaUploadProgressIntent);
             }
         }
 
@@ -97,6 +109,7 @@ public class UploadService extends IntentService {
     public void onCreate() {
         super.onCreate();
         notificationManager = (NotificationManager)getSystemService(NOTIFICATION_SERVICE);
+        localBroadcastManager = LocalBroadcastManager.getInstance(this);
         app = (CommonsApplication)this.getApplicationContext();
     }
 
@@ -109,6 +122,37 @@ public class UploadService extends IntentService {
         return cursor.getString(column_index);
     }
 
+    private Media mediaFromIntent(Intent intent) {
+        Bundle extras = intent.getExtras();
+        Uri mediaUri = (Uri)extras.getParcelable(Media.EXTRA_MEDIA_URI);
+        String filename = intent.getStringExtra(Media.EXTRA_TARGET_FILENAME);
+        String description = intent.getStringExtra(Media.EXTRA_DESCRIPTION);
+        String editSummary = intent.getStringExtra(Media.EXTRA_EDIT_SUMMARY);
+        String mimeType = intent.getStringExtra(Media.EXTRA_MIMETYPE);
+        Date dateCreated = null;
+
+        Long length = null;
+        try {
+            length = this.getContentResolver().openAssetFileDescriptor(mediaUri, "r").getLength();
+        } catch (FileNotFoundException e) {
+            throw new RuntimeException(e);
+        }
+
+
+        Log.d("Commons", "MimeType is " + mimeType);
+        if (mimeType.startsWith("image/")) {
+            Cursor cursor = this.getContentResolver().query(mediaUri,
+                    new String[]{MediaStore.Images.ImageColumns.DATE_TAKEN}, null, null, null);
+            if (cursor.getCount() != 0) {
+                cursor.moveToFirst();
+                dateCreated = new Date(cursor.getLong(0));
+            }
+        } /* else if (mimeType.startsWith("audio/")) {
+             Removed Audio implementationf or now
+           }  */
+        Media media = new Media(mediaUri, filename, description, editSummary, app.getCurrentAccount().name, dateCreated, length);
+        return media;
+    }
     @Override
     public int onStartCommand(Intent intent, int flags, int startId) {
         toUpload++;
@@ -117,48 +161,37 @@ public class UploadService extends IntentService {
             Log.d("Commons", String.format("%d uploads left", toUpload));
             notificationManager.notify(NOTIFICATION_DOWNLOAD_IN_PROGRESS, curProgressNotification);
         }
-        return super.onStartCommand(intent, flags, startId);
+
+        Media media = mediaFromIntent(intent);
+
+        Intent mediaUploadQueuedIntent = new Intent(INTENT_UPLOAD_QUEUED);
+        mediaUploadQueuedIntent.putExtra(EXTRA_MEDIA, media);
+        localBroadcastManager.sendBroadcast(mediaUploadQueuedIntent);
+        return super.onStartCommand(mediaUploadQueuedIntent, flags, startId);
     }
 
     @Override
     protected void onHandleIntent(Intent intent) {
        MWApi api = app.getApi();
-       InputStream file = null;
-       long length = 0;
+
        ApiResult result;
        RemoteViews notificationView;
-       
-       Bundle extras = intent.getExtras();
-       Uri mediaUri = (Uri)extras.getParcelable(EXTRA_MEDIA_URI);
-       String filename = intent.getStringExtra(EXTRA_TARGET_FILENAME);
-       String description = intent.getStringExtra(EXTRA_DESCRIPTION);
-       String editSummary = intent.getStringExtra(EXTRA_EDIT_SUMMARY);
-       String mimeType = intent.getStringExtra(EXTRA_MIMETYPE);
-       String notificationTag = mediaUri.toString();
-       Date dateCreated = null;
-               
-       try {
-           Log.d("Commons", "MimeType is " + mimeType);
-           if(mimeType.startsWith("image/")) {
-               file =  this.getContentResolver().openInputStream(mediaUri);
-               length = this.getContentResolver().openAssetFileDescriptor(mediaUri, "r").getLength();
-               Cursor cursor = this.getContentResolver().query(mediaUri,
-                       new String[] { MediaStore.Images.ImageColumns.DATE_TAKEN }, null, null, null);
-               if(cursor.getCount() != 0) {
-                   cursor.moveToFirst();
-                   dateCreated = new Date(cursor.getLong(0));
-               }
-           } /* else if (mimeType.startsWith("audio/")) {
-             Removed Audio implementationf or now
-           }  */
-       } catch (FileNotFoundException e) {
-           throw new RuntimeException(e);
-       } catch (IOException e) {
-           throw new RuntimeException(e);
-       }
-            
+       Media media;
+       InputStream file = null;
+       long length = 0;
+       media = (Media)intent.getParcelableExtra(EXTRA_MEDIA);
+
+       String notificationTag = media.getMediaUri().toString();
+
+
+        try {
+            file =  this.getContentResolver().openInputStream(media.getMediaUri());
+        } catch (FileNotFoundException e) {
+            throw new RuntimeException(e);
+        }
+
        notificationView = new RemoteViews(getPackageName(), R.layout.layout_upload_progress);
-       notificationView.setTextViewText(R.id.uploadNotificationTitle, String.format(getString(R.string.upload_progress_notification_title_start), filename));
+       notificationView.setTextViewText(R.id.uploadNotificationTitle, String.format(getString(R.string.upload_progress_notification_title_start), media.getFileName()));
        notificationView.setProgressBar(R.id.uploadNotificationProgress, 100, 0, false);
        
        Log.d("Commons", "Before execution!");
@@ -168,16 +201,13 @@ public class UploadService extends IntentService {
                .setContent(notificationView)
                .setOngoing(true)
                .setContentIntent(PendingIntent.getActivity(getApplicationContext(), 0, new Intent(), 0))
-               .setTicker(String.format(getString(R.string.upload_progress_notification_title_in_progress), filename))
+               .setTicker(String.format(getString(R.string.upload_progress_notification_title_in_progress), media.getFileName()))
                .getNotification();
      
        this.startForeground(NOTIFICATION_DOWNLOAD_IN_PROGRESS, curProgressNotification);
        
        Log.d("Commons", "Just before");
-       NotificationUpdateProgressListener notificationUpdater = new NotificationUpdateProgressListener(curProgressNotification, notificationTag,
-                                                                    String.format(getString(R.string.upload_progress_notification_title_in_progress), filename), 
-                                                                    String.format(getString(R.string.upload_progress_notification_title_finishing), filename)
-                                                                );
+
        try {
            if(!api.validateLogin()) {
                // Need to revalidate! 
@@ -192,8 +222,12 @@ public class UploadService extends IntentService {
                    return;
                }
            }
-           Media media = new Media(mediaUri, filename, description, editSummary, app.getCurrentAccount().name, dateCreated);
-           result = api.upload(filename, file, length, media.getPageContents(), editSummary, notificationUpdater);
+           NotificationUpdateProgressListener notificationUpdater = new NotificationUpdateProgressListener(curProgressNotification, notificationTag,
+                   String.format(getString(R.string.upload_progress_notification_title_in_progress), media.getFileName()),
+                   String.format(getString(R.string.upload_progress_notification_title_finishing), media.getFileName()),
+                   media
+           );
+           result = api.upload(media.getFileName(), file, length, media.getPageContents(), media.getEditSummary(), notificationUpdater);
        } catch (IOException e) {
            Log.d("Commons", "I have a network fuckup");
            stopForeground(true);
@@ -201,8 +235,8 @@ public class UploadService extends IntentService {
                    .setSmallIcon(R.drawable.ic_launcher)
                    .setAutoCancel(true)
                    .setContentIntent(PendingIntent.getService(getApplicationContext(), 0, intent, 0))
-                   .setTicker(String.format(getString(R.string.upload_failed_notification_title), filename))
-                   .setContentTitle(String.format(getString(R.string.upload_failed_notification_title), filename))
+                   .setTicker(String.format(getString(R.string.upload_failed_notification_title), media.getFileName()))
+                   .setContentTitle(String.format(getString(R.string.upload_failed_notification_title), media.getFileName()))
                    .setContentText(getString(R.string.upload_failed_notification_subtitle))
                    .getNotification();
            notificationManager.notify(NOTIFICATION_UPLOAD_FAILED, failureNotification);
@@ -221,12 +255,16 @@ public class UploadService extends IntentService {
        Notification doneNotification = new NotificationCompat.Builder(this)
                .setAutoCancel(true)
                .setSmallIcon(R.drawable.ic_launcher)
-               .setContentTitle(String.format(getString(R.string.upload_completed_notification_title), filename))
+               .setContentTitle(String.format(getString(R.string.upload_completed_notification_title), media.getFileName()))
                .setContentText(getString(R.string.upload_completed_notification_text))
-               .setTicker(String.format(getString(R.string.upload_completed_notification_title), filename))
+               .setTicker(String.format(getString(R.string.upload_completed_notification_title), media.getFileName()))
                .setContentIntent(PendingIntent.getActivity(this, 0, openUploadedPageIntent, 0))
                .getNotification();
        
        notificationManager.notify(notificationTag, NOTIFICATION_DOWNLOAD_COMPLETE, doneNotification);
+
+       Intent mediaUploadedIntent = new Intent(INTENT_UPLOAD_COMPLETE);
+       mediaUploadedIntent.putExtra(EXTRA_MEDIA, media);
+       localBroadcastManager.sendBroadcast(mediaUploadedIntent);
     }
 }
diff --git a/commons/src/main/java/org/wikimedia/commons/media/Media.java b/commons/src/main/java/org/wikimedia/commons/media/Media.java
index 650c7a6b9..e492e6f8c 100644
--- a/commons/src/main/java/org/wikimedia/commons/media/Media.java
+++ b/commons/src/main/java/org/wikimedia/commons/media/Media.java
@@ -9,6 +9,14 @@ import android.os.Parcel;
 import android.os.Parcelable;
 
 public class Media implements Parcelable {
+
+    private static final String EXTRA_PREFIX = "org.wikimedia.commons.media";
+    public static final String EXTRA_MEDIA_URI = EXTRA_PREFIX + ".uri";
+    public static final String EXTRA_TARGET_FILENAME = EXTRA_PREFIX + ".filename";
+    public static final String EXTRA_DESCRIPTION = EXTRA_PREFIX + ".description";
+    public static final String EXTRA_EDIT_SUMMARY = EXTRA_PREFIX + ".summary";
+    public static final String EXTRA_MIMETYPE = EXTRA_PREFIX + ".mimetype";
+
     private Uri mediaUri;
     private String fileName;
     private String editSummary;
@@ -16,17 +24,22 @@ public class Media implements Parcelable {
     private String description;
     private String userName;
     private Date dateCreated;
+    private long length;
     private Date dateUploaded;
     
-    public Media(Uri mediaUri, String fileName, String description, String editSummary, String userName, Date dateCreated) {
+    public Media(Uri mediaUri, String fileName, String description, String editSummary, String userName, Date dateCreated, long length) {
         this.mediaUri = mediaUri;
         this.fileName = fileName;
         this.description = description;
         this.editSummary = editSummary;
         this.userName = userName;
         this.dateCreated = dateCreated;
+        this.length = length;
+    }
+
+    public long getLength() {
+        return length;
     }
-    
     public Uri getMediaUri() {
         return mediaUri;
     }
@@ -74,6 +87,7 @@ public class Media implements Parcelable {
         parcel.writeString(description);
         parcel.writeString(editSummary);
         parcel.writeString(userName);
+        parcel.writeLong(length);
         parcel.writeSerializable(dateCreated);
     }
 
@@ -83,8 +97,9 @@ public class Media implements Parcelable {
         String description = parcel.readString();
         String editSummary = parcel.readString();
         String userName = parcel.readString();
+        Long length = parcel.readLong();
         Date dateCreated = (Date)parcel.readSerializable();
-        return new Media(mediaUri, fileName, description, editSummary, userName, dateCreated);
+        return new Media(mediaUri, fileName, description, editSummary, userName, dateCreated, length);
     }
 
     public static final Parcelable.Creator<Media> CREATOR = new Parcelable.Creator<Media>() {