1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
|
/*
* Copyright (C) 2015 The CyanogenMod 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.messaging.util;
import android.content.ContentResolver;
import android.database.ContentObserver;
import android.database.Cursor;
import android.net.Uri;
import android.os.Handler;
import android.util.Log;
import com.android.messaging.BugleApplication;
import com.android.messaging.datamodel.BugleDatabaseOperations;
import com.android.messaging.datamodel.DataModel;
import com.android.messaging.datamodel.DatabaseWrapper;
import com.android.messaging.datamodel.MessagingContentProvider;
import com.android.messaging.datamodel.action.UpdateConversationArchiveStatusAction;
import com.android.messaging.datamodel.data.ParticipantData;
import com.android.messaging.util.LogUtil;
// ContentObserver class to monitor changes to the Framework Blacklist DB
public class BlacklistObserver extends ContentObserver {
private static final String TAG = BlacklistObserver.class.getSimpleName();
private ContentResolver mResolver;
public BlacklistObserver(Handler handler, ContentResolver resolver) {
super(handler);
mResolver = resolver;
}
@Override
public void onChange(boolean selfChange, final Uri uri) {
// depending on the Thread in which the handler was created, this function
// may or may not run on the UI thread, to be sure that it doesn't, launch
// it via AsyncTask
new SafeAsyncTask<Void, Void, Void>() {
@Override
protected Void doInBackgroundTimed(Void... params) {
if (LogUtil.isLoggable(TAG, LogUtil.VERBOSE)) {
Log.i(TAG, "BlacklistObserver: onChange: Uri:" + uri.toString());
}
// we need to find the phone number being blacklisted and add/update it
// in the bugle database
Cursor cursor = null;
try {
cursor = mResolver.query(uri, null, null, null, null);
int normalizedNumberIndex = cursor.getColumnIndex("normalized_number");
int blockedIndex = cursor.getColumnIndex("message");
int nonNormalizedNumberIndex = cursor.getColumnIndex("number");
int regexIndex = cursor.getColumnIndex("is_regex");
// if the column indices are not valid, don't perform the queries
if (normalizedNumberIndex < 0 || blockedIndex < 0) {
if (cursor != null) {
cursor.close();
}
return null;
}
DatabaseWrapper db = DataModel.get().getDatabase();
while(cursor.moveToNext()) {
String number = cursor.getString(normalizedNumberIndex);
String blocked = cursor.getString(blockedIndex);
boolean isBlocked = blocked.compareTo("1") == 0;
String formattedNumber = cursor.getInt(regexIndex) != 0
? cursor.getString(nonNormalizedNumberIndex) : null;
// don't update the framework db - the 'false' argument
int updateCount = BugleDatabaseOperations.updateDestination(db, number,
isBlocked, false);
if (updateCount == 0) {
// there was no phone number in the local participants database that was
// blacklisted in the framework blacklist database,
// create a new participant
// and insert him into the local participants database
ParticipantData participant =
ParticipantData.getFromRawPhoneBySystemLocale(number, formattedNumber);
BugleDatabaseOperations.getOrCreateParticipantInTransaction(db,
participant);
BugleDatabaseOperations.updateDestination(db, number,
isBlocked, false);
}
String conversationId = BugleDatabaseOperations
.getConversationFromOtherParticipantDestination(db, number);
if (conversationId != null) {
if (isBlocked) {
UpdateConversationArchiveStatusAction
.archiveConversation(conversationId);
} else {
UpdateConversationArchiveStatusAction
.unarchiveConversation(conversationId);
}
MessagingContentProvider.notifyParticipantsChanged(conversationId);
}
}
} catch (Exception e) {
Log.e(TAG, "BlacklistObserver: onChange: " + e.getMessage());
} finally {
if (cursor != null) {
cursor.close();
}
}
return null;
}
}.executeOnThreadPool();
}
}
|
