| /* |
| * Copyright (C) 2007-2008 Esmertec AG. |
| * Copyright (C) 2007-2008 The Android Open Source Project |
| * |
| * Licensed under the Apache License, Version 2.0 (the "License"); |
| * you may not use this file except in compliance with the License. |
| * You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| package com.android.mms.transaction; |
| |
| import static android.provider.Telephony.Sms.Intents.WAP_PUSH_RECEIVED_ACTION; |
| import static com.google.android.mms.pdu.PduHeaders.MESSAGE_TYPE_DELIVERY_IND; |
| import static com.google.android.mms.pdu.PduHeaders.MESSAGE_TYPE_NOTIFICATION_IND; |
| import static com.google.android.mms.pdu.PduHeaders.MESSAGE_TYPE_READ_ORIG_IND; |
| |
| import com.google.android.mms.ContentType; |
| import com.google.android.mms.MmsException; |
| import com.google.android.mms.pdu.DeliveryInd; |
| import com.google.android.mms.pdu.GenericPdu; |
| import com.google.android.mms.pdu.NotificationInd; |
| import com.google.android.mms.pdu.PduHeaders; |
| import com.google.android.mms.pdu.PduParser; |
| import com.google.android.mms.pdu.PduPersister; |
| import com.google.android.mms.pdu.ReadOrigInd; |
| import com.google.android.mms.util.SqliteWrapper; |
| |
| import android.content.BroadcastReceiver; |
| import android.content.ContentResolver; |
| import android.content.ContentValues; |
| import android.content.Context; |
| import android.content.Intent; |
| import android.database.Cursor; |
| import android.database.DatabaseUtils; |
| import android.net.Uri; |
| import android.os.AsyncTask; |
| import android.os.PowerManager; |
| import android.provider.Telephony.Mms; |
| import android.provider.Telephony.Mms.Inbox; |
| import android.util.Config; |
| import android.util.Log; |
| |
| /** |
| * Receives Intent.WAP_PUSH_RECEIVED_ACTION intents and starts the |
| * TransactionService by passing the push-data to it. |
| */ |
| public class PushReceiver extends BroadcastReceiver { |
| private static final String TAG = "PushReceiver"; |
| private static final boolean DEBUG = false; |
| private static final boolean LOCAL_LOGV = DEBUG ? Config.LOGD : Config.LOGV; |
| |
| private abstract class WakefulAsyncTask<Params,Progress,Result> |
| extends AsyncTask<Params,Progress,Result> { |
| private PowerManager.WakeLock mWakeLock; |
| |
| public void useWakeLock(Context c, int wakeLockFlags, String tag) { |
| PowerManager pm = (PowerManager)c.getSystemService(Context.POWER_SERVICE); |
| mWakeLock = pm.newWakeLock(wakeLockFlags, tag); |
| mWakeLock.setReferenceCounted(false); |
| } |
| |
| @Override |
| protected void onPreExecute() { |
| if (mWakeLock != null) { |
| mWakeLock.acquire(); |
| } |
| } |
| |
| @Override |
| protected void onPostExecute(Result result) { |
| if (mWakeLock != null) { |
| mWakeLock.release(); |
| } |
| } |
| } |
| |
| private class ReceivePushTask extends WakefulAsyncTask<Intent,Void,Void> { |
| private Context mContext; |
| public ReceivePushTask(Context context) { |
| mContext = context; |
| useWakeLock(context, PowerManager.PARTIAL_WAKE_LOCK, "ReceivePushTask"); |
| } |
| |
| @Override |
| protected Void doInBackground(Intent... intents) { |
| Intent intent = intents[0]; |
| |
| // Get raw PDU push-data from the message and parse it |
| byte[] pushData = intent.getByteArrayExtra("data"); |
| PduParser parser = new PduParser(pushData); |
| GenericPdu pdu = parser.parse(); |
| |
| if (null == pdu) { |
| Log.e(TAG, "Invalid PUSH data"); |
| return null; |
| } |
| |
| PduPersister p = PduPersister.getPduPersister(mContext); |
| ContentResolver cr = mContext.getContentResolver(); |
| int type = pdu.getMessageType(); |
| long threadId = -1; |
| |
| try { |
| switch (type) { |
| case MESSAGE_TYPE_DELIVERY_IND: |
| case MESSAGE_TYPE_READ_ORIG_IND: { |
| threadId = findThreadId(mContext, pdu, type); |
| if (threadId == -1) { |
| // The associated SendReq isn't found, therefore skip |
| // processing this PDU. |
| break; |
| } |
| |
| Uri uri = p.persist(pdu, Inbox.CONTENT_URI); |
| // Update thread ID for ReadOrigInd & DeliveryInd. |
| ContentValues values = new ContentValues(1); |
| values.put(Mms.THREAD_ID, threadId); |
| SqliteWrapper.update(mContext, cr, uri, values, null, null); |
| break; |
| } |
| case MESSAGE_TYPE_NOTIFICATION_IND: { |
| NotificationInd nInd = (NotificationInd) pdu; |
| if (!isDuplicateNotification(mContext, nInd)) { |
| Uri uri = p.persist(pdu, Inbox.CONTENT_URI); |
| // Start service to finish the notification transaction. |
| Intent svc = new Intent(mContext, TransactionService.class); |
| svc.putExtra(TransactionBundle.URI, uri.toString()); |
| svc.putExtra(TransactionBundle.TRANSACTION_TYPE, |
| Transaction.NOTIFICATION_TRANSACTION); |
| mContext.startService(svc); |
| } else if (LOCAL_LOGV) { |
| Log.v(TAG, "Skip downloading duplicate message: " |
| + new String(nInd.getContentLocation())); |
| } |
| break; |
| } |
| default: |
| Log.e(TAG, "Received unrecognized PDU."); |
| } |
| } catch (MmsException e) { |
| Log.e(TAG, "Failed to save the data from PUSH: type=" + type, e); |
| } catch (RuntimeException e) { |
| Log.e(TAG, "Unexpected RuntimeException.", e); |
| } |
| |
| if (LOCAL_LOGV) { |
| Log.v(TAG, "PUSH Intent processed."); |
| } |
| |
| return null; |
| } |
| } |
| |
| @Override |
| public void onReceive(Context context, Intent intent) { |
| if (intent.getAction().equals(WAP_PUSH_RECEIVED_ACTION) |
| && ContentType.MMS_MESSAGE.equals(intent.getType())) { |
| if (LOCAL_LOGV) { |
| Log.v(TAG, "Received PUSH Intent: " + intent); |
| } |
| |
| new ReceivePushTask(context).execute(intent); |
| } |
| } |
| |
| private static long findThreadId(Context context, GenericPdu pdu, int type) { |
| String messageId; |
| |
| if (type == MESSAGE_TYPE_DELIVERY_IND) { |
| messageId = new String(((DeliveryInd) pdu).getMessageId()); |
| } else { |
| messageId = new String(((ReadOrigInd) pdu).getMessageId()); |
| } |
| |
| StringBuilder sb = new StringBuilder('('); |
| sb.append(Mms.MESSAGE_ID); |
| sb.append('='); |
| sb.append(DatabaseUtils.sqlEscapeString(messageId)); |
| sb.append(" AND "); |
| sb.append(Mms.MESSAGE_TYPE); |
| sb.append('='); |
| sb.append(PduHeaders.MESSAGE_TYPE_SEND_REQ); |
| // TODO ContentResolver.query() appends closing ')' to the selection argument |
| // sb.append(')'); |
| |
| Cursor cursor = SqliteWrapper.query(context, context.getContentResolver(), |
| Mms.CONTENT_URI, new String[] { Mms.THREAD_ID }, |
| sb.toString(), null, null); |
| if (cursor != null) { |
| try { |
| if ((cursor.getCount() == 1) && cursor.moveToFirst()) { |
| return cursor.getLong(0); |
| } |
| } finally { |
| cursor.close(); |
| } |
| } |
| |
| return -1; |
| } |
| |
| private static boolean isDuplicateNotification( |
| Context context, NotificationInd nInd) { |
| byte[] rawLocation = nInd.getContentLocation(); |
| if (rawLocation != null) { |
| String location = new String(rawLocation); |
| String selection = Mms.CONTENT_LOCATION + " = ?"; |
| String[] selectionArgs = new String[] { location }; |
| Cursor cursor = SqliteWrapper.query( |
| context, context.getContentResolver(), |
| Mms.CONTENT_URI, new String[] { Mms._ID }, |
| selection, selectionArgs, null); |
| if (cursor != null) { |
| try { |
| if (cursor.getCount() > 0) { |
| // We already received the same notification before. |
| return true; |
| } |
| } finally { |
| cursor.close(); |
| } |
| } |
| } |
| return false; |
| } |
| } |