• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1 /*
2  * Copyright (C) 2012 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.mms.transaction;
18 
19 import android.app.IntentService;
20 import android.content.ContentUris;
21 import android.content.ContentValues;
22 import android.content.Context;
23 import android.content.Intent;
24 import android.database.Cursor;
25 import android.database.sqlite.SqliteWrapper;
26 import android.net.Uri;
27 import android.provider.Telephony.Sms;
28 import android.provider.Telephony.Sms.Inbox;
29 import android.telephony.SmsMessage;
30 import android.util.Log;
31 
32 import com.android.mms.LogTag;
33 
34 /**
35  * Service that gets started by the MessageStatusReceiver when a message status report is
36  * received.
37  */
38 public class MessageStatusService extends IntentService {
39     private static final String[] ID_PROJECTION = new String[] { Sms._ID };
40     private static final String LOG_TAG = "MessageStatusReceiver";
41     private static final Uri STATUS_URI = Uri.parse("content://sms/status");
42 
MessageStatusService()43     public MessageStatusService() {
44         // Class name will be the thread name.
45         super(MessageStatusService.class.getName());
46 
47         // Intent should be redelivered if the process gets killed before completing the job.
48         setIntentRedelivery(true);
49     }
50 
51     @Override
onHandleIntent(Intent intent)52     protected void onHandleIntent(Intent intent) {
53         // This method is called on a worker thread.
54 
55         Uri messageUri = intent.getData();
56         byte[] pdu = intent.getByteArrayExtra("pdu");
57         String format = intent.getStringExtra("format");
58 
59         SmsMessage message = updateMessageStatus(this, messageUri, pdu, format);
60 
61         // Called on a background thread, so it's OK to block.
62         if (message != null && message.getStatus() < Sms.STATUS_PENDING) {
63             MessagingNotification.blockingUpdateNewMessageIndicator(this,
64                     MessagingNotification.THREAD_NONE, message.isStatusReportMessage());
65         }
66     }
67 
updateMessageStatus(Context context, Uri messageUri, byte[] pdu, String format)68     private SmsMessage updateMessageStatus(Context context, Uri messageUri, byte[] pdu,
69             String format) {
70         SmsMessage message = SmsMessage.createFromPdu(pdu, format);
71         if (message == null) {
72             return null;
73         }
74         // Create a "status/#" URL and use it to update the
75         // message's status in the database.
76         Cursor cursor = SqliteWrapper.query(context, context.getContentResolver(),
77                             messageUri, ID_PROJECTION, null, null, null);
78 
79         try {
80             if (cursor.moveToFirst()) {
81                 int messageId = cursor.getInt(0);
82 
83                 Uri updateUri = ContentUris.withAppendedId(STATUS_URI, messageId);
84                 int status = message.getStatus();
85                 boolean isStatusReport = message.isStatusReportMessage();
86                 ContentValues contentValues = new ContentValues(2);
87 
88                 if (Log.isLoggable(LogTag.TAG, Log.DEBUG)) {
89                     log("updateMessageStatus: msgUrl=" + messageUri + ", status=" + status +
90                             ", isStatusReport=" + isStatusReport);
91                 }
92 
93                 contentValues.put(Sms.STATUS, status);
94                 contentValues.put(Inbox.DATE_SENT, System.currentTimeMillis());
95                 SqliteWrapper.update(context, context.getContentResolver(),
96                                     updateUri, contentValues, null, null);
97             } else {
98                 error("Can't find message for status update: " + messageUri);
99             }
100         } finally {
101             cursor.close();
102         }
103         return message;
104     }
105 
error(String message)106     private void error(String message) {
107         Log.e(LOG_TAG, "[MessageStatusReceiver] " + message);
108     }
109 
log(String message)110     private void log(String message) {
111         Log.d(LOG_TAG, "[MessageStatusReceiver] " + message);
112     }
113 }
114