Home | History | Annotate | Download | only in action 
      1 /*
      2  * Copyright (C) 2015 The Android Open Source Project
      3  *
      4  * Licensed under the Apache License, Version 2.0 (the "License");
      5  * you may not use this file except in compliance with the License.
      6  * You may obtain a copy of the License at
      7  *
      8  *      http://www.apache.org/licenses/LICENSE-2.0
      9  *
     10  * Unless required by applicable law or agreed to in writing, software
     11  * distributed under the License is distributed on an "AS IS" BASIS,
     12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     13  * See the License for the specific language governing permissions and
     14  * limitations under the License.
     15  */
     16 
     17 package com.android.messaging.datamodel.action;
     18 
     19 import android.content.Context;
     20 import android.os.Bundle;
     21 import android.os.Parcel;
     22 import android.os.Parcelable;
     23 
     24 import com.android.messaging.Factory;
     25 import com.android.messaging.datamodel.BugleDatabaseOperations;
     26 import com.android.messaging.datamodel.BugleNotifications;
     27 import com.android.messaging.datamodel.DataModel;
     28 import com.android.messaging.datamodel.DataModelException;
     29 import com.android.messaging.datamodel.DatabaseWrapper;
     30 import com.android.messaging.datamodel.MessagingContentProvider;
     31 import com.android.messaging.datamodel.SyncManager;
     32 import com.android.messaging.datamodel.data.MessageData;
     33 import com.android.messaging.datamodel.data.ParticipantData;
     34 import com.android.messaging.mmslib.pdu.PduHeaders;
     35 import com.android.messaging.sms.DatabaseMessages;
     36 import com.android.messaging.sms.MmsUtils;
     37 import com.android.messaging.util.LogUtil;
     38 
     39 import java.util.List;
     40 
     41 /**
     42  * Action used to "receive" an incoming message
     43  */
     44 public class ReceiveMmsMessageAction extends Action implements Parcelable {
     45     private static final String TAG = LogUtil.BUGLE_DATAMODEL_TAG;
     46 
     47     private static final String KEY_SUB_ID = "sub_id";
     48     private static final String KEY_PUSH_DATA = "push_data";
     49     private static final String KEY_TRANSACTION_ID = "transaction_id";
     50     private static final String KEY_CONTENT_LOCATION = "content_location";
     51 
     52     /**
     53      * Create a message received from a particular number in a particular conversation
     54      */
     55     public ReceiveMmsMessageAction(final int subId, final byte[] pushData) {
     56         actionParameters.putInt(KEY_SUB_ID, subId);
     57         actionParameters.putByteArray(KEY_PUSH_DATA, pushData);
     58     }
     59 
     60     @Override
     61     protected Object executeAction() {
     62         final Context context = Factory.get().getApplicationContext();
     63         final int subId = actionParameters.getInt(KEY_SUB_ID, ParticipantData.DEFAULT_SELF_SUB_ID);
     64         final byte[] pushData = actionParameters.getByteArray(KEY_PUSH_DATA);
     65         final DatabaseWrapper db = DataModel.get().getDatabase();
     66 
     67         // Write received message to telephony DB
     68         MessageData message = null;
     69         final ParticipantData self = BugleDatabaseOperations.getOrCreateSelf(db, subId);
     70 
     71         final long received = System.currentTimeMillis();
     72         // Inform sync that message has been added at local received timestamp
     73         final SyncManager syncManager = DataModel.get().getSyncManager();
     74         syncManager.onNewMessageInserted(received);
     75 
     76         // TODO: Should use local time to set received time in MMS message
     77         final DatabaseMessages.MmsMessage mms = MmsUtils.processReceivedPdu(
     78                 context, pushData, self.getSubId(), self.getNormalizedDestination());
     79 
     80         if (mms != null) {
     81             final List<String> recipients = MmsUtils.getRecipientsByThread(mms.mThreadId);
     82             String from = MmsUtils.getMmsSender(recipients, mms.getUri());
     83             if (from == null) {
     84                 LogUtil.w(TAG, "Received an MMS without sender address; using unknown sender.");
     85                 from = ParticipantData.getUnknownSenderDestination();
     86             }
     87             final ParticipantData rawSender = ParticipantData.getFromRawPhoneBySimLocale(
     88                     from, subId);
     89             final boolean blocked = BugleDatabaseOperations.isBlockedDestination(
     90                     db, rawSender.getNormalizedDestination());
     91             final boolean autoDownload = (!blocked && MmsUtils.allowMmsAutoRetrieve(subId));
     92             final String conversationId =
     93                     BugleDatabaseOperations.getOrCreateConversationFromThreadId(db, mms.mThreadId,
     94                             blocked, subId);
     95 
     96             final boolean messageInFocusedConversation =
     97                     DataModel.get().isFocusedConversation(conversationId);
     98             final boolean messageInObservableConversation =
     99                     DataModel.get().isNewMessageObservable(conversationId);
    100 
    101             // TODO: Also write these values to the telephony provider
    102             mms.mRead = messageInFocusedConversation;
    103             mms.mSeen = messageInObservableConversation || blocked;
    104 
    105             // Write received placeholder message to our DB
    106             db.beginTransaction();
    107             try {
    108                 final String participantId =
    109                         BugleDatabaseOperations.getOrCreateParticipantInTransaction(db, rawSender);
    110                 final String selfId =
    111                         BugleDatabaseOperations.getOrCreateParticipantInTransaction(db, self);
    112 
    113                 message = MmsUtils.createMmsMessage(mms, conversationId, participantId, selfId,
    114                         (autoDownload ? MessageData.BUGLE_STATUS_INCOMING_RETRYING_AUTO_DOWNLOAD :
    115                             MessageData.BUGLE_STATUS_INCOMING_YET_TO_MANUAL_DOWNLOAD));
    116                 // Write the message
    117                 BugleDatabaseOperations.insertNewMessageInTransaction(db, message);
    118 
    119                 if (!autoDownload) {
    120                     BugleDatabaseOperations.updateConversationMetadataInTransaction(db,
    121                             conversationId, message.getMessageId(), message.getReceivedTimeStamp(),
    122                             blocked, true /* shouldAutoSwitchSelfId */);
    123                     final ParticipantData sender = ParticipantData .getFromId(
    124                             db, participantId);
    125                     BugleActionToasts.onMessageReceived(conversationId, sender, message);
    126                 }
    127                 // else update the conversation once we have downloaded final message (or failed)
    128                 db.setTransactionSuccessful();
    129             } finally {
    130                 db.endTransaction();
    131             }
    132 
    133             // Update conversation if not immediately initiating a download
    134             if (!autoDownload) {
    135                 MessagingContentProvider.notifyMessagesChanged(message.getConversationId());
    136                 MessagingContentProvider.notifyPartsChanged();
    137 
    138                 // Show a notification to let the user know a new message has arrived
    139                 BugleNotifications.update(false/*silent*/, conversationId,
    140                         BugleNotifications.UPDATE_ALL);
    141 
    142                 // Send the NotifyRespInd with DEFERRED status since no auto download
    143                 actionParameters.putString(KEY_TRANSACTION_ID, mms.mTransactionId);
    144                 actionParameters.putString(KEY_CONTENT_LOCATION, mms.mContentLocation);
    145                 requestBackgroundWork();
    146             }
    147 
    148             LogUtil.i(TAG, "ReceiveMmsMessageAction: Received MMS message " + message.getMessageId()
    149                     + " in conversation " + message.getConversationId()
    150                     + ", uri = " + message.getSmsMessageUri());
    151         } else {
    152             LogUtil.e(TAG, "ReceiveMmsMessageAction: Skipping processing of incoming PDU");
    153         }
    154 
    155         ProcessPendingMessagesAction.scheduleProcessPendingMessagesAction(false, this);
    156 
    157         return message;
    158     }
    159 
    160     @Override
    161     protected Bundle doBackgroundWork() throws DataModelException {
    162         final Context context = Factory.get().getApplicationContext();
    163         final int subId = actionParameters.getInt(KEY_SUB_ID, ParticipantData.DEFAULT_SELF_SUB_ID);
    164         final String transactionId = actionParameters.getString(KEY_TRANSACTION_ID);
    165         final String contentLocation = actionParameters.getString(KEY_CONTENT_LOCATION);
    166         MmsUtils.sendNotifyResponseForMmsDownload(
    167                 context,
    168                 subId,
    169                 MmsUtils.stringToBytes(transactionId, "UTF-8"),
    170                 contentLocation,
    171                 PduHeaders.STATUS_DEFERRED);
    172         // We don't need to return anything.
    173         return null;
    174     }
    175 
    176     private ReceiveMmsMessageAction(final Parcel in) {
    177         super(in);
    178     }
    179 
    180     public static final Parcelable.Creator<ReceiveMmsMessageAction> CREATOR
    181             = new Parcelable.Creator<ReceiveMmsMessageAction>() {
    182         @Override
    183         public ReceiveMmsMessageAction createFromParcel(final Parcel in) {
    184             return new ReceiveMmsMessageAction(in);
    185         }
    186 
    187         @Override
    188         public ReceiveMmsMessageAction[] newArray(final int size) {
    189             return new ReceiveMmsMessageAction[size];
    190         }
    191     };
    192 
    193     @Override
    194     public void writeToParcel(final Parcel parcel, final int flags) {
    195         writeActionToParcel(parcel, flags);
    196     }
    197 }
    198