Add GroupId for received messages.

// FREEBIE

src/org/thoughtcrime/securesms/DatabaseUpgradeActivity.java

@@ -206,7 +206,9 @@ public class DatabaseUpgradeActivity extends BaseActivity {
           while ((pushReader != null && pushReader.moveToNext())) {
             ApplicationContext.getInstance(getApplicationContext())
                 .getJobManager()
-                .add(new PushDecryptJob(getApplicationContext(), pushReader.getLong(pushReader.getColumnIndexOrThrow(PushDatabase.ID))));
+                .add(new PushDecryptJob(getApplicationContext(),
+                                        pushReader.getLong(pushReader.getColumnIndexOrThrow(PushDatabase.ID)),
+                                        pushReader.getString(pushReader.getColumnIndexOrThrow(PushDatabase.SOURCE))));
           }
         } finally {
           if (pushReader != null)

src/org/thoughtcrime/securesms/ReceiveKeyActivity.java

@@ -236,7 +236,7 @@ public class ReceiveKeyActivity extends BaseActivity {
 
                 ApplicationContext.getInstance(context)
                                   .getJobManager()
-                                  .add(new PushDecryptJob(context, pushId));
+                                  .add(new PushDecryptJob(context, pushId, message.getSender()));
 
                 smsDatabase.deleteMessage(messageId);
               } catch (IOException e) {

src/org/thoughtcrime/securesms/jobs/PushDecryptJob.java

@@ -53,10 +53,11 @@ public class PushDecryptJob extends MasterSecretJob {
 
   private final long messageId;
 
-  public PushDecryptJob(Context context, long messageId) {
+  public PushDecryptJob(Context context, long messageId, String sender) {
     super(context, JobParameters.newBuilder()
                                 .withPersistence()
                                 .withRequirement(new MasterSecretRequirement(context))
+                                .withGroupId(sender)
                                 .create());
     this.messageId = messageId;
   }

src/org/thoughtcrime/securesms/jobs/PushReceiveJob.java

@@ -83,7 +83,7 @@ public class PushReceiveJob extends ContextJob {
                                             envelope.getRelay()));
     }
 
-    jobManager.add(new PushDecryptJob(context, messageId));
+    jobManager.add(new PushDecryptJob(context, messageId, envelope.getSource()));
   }
 
   private void handleReceipt(TextSecureEnvelope envelope) {