mirror of
https://github.com/KDE/kdeconnect-android
synced 2025-09-05 16:45:08 +00:00
Split Telephony and SMS plugin on Android
Test Plan: Get called: Notification appears as before. Get SMS: Notification shows and it appears in SMS app after reconnect. Write SMS from app: It shows up on the phone Reviewers: #kde_connect, albertvaka Reviewed By: #kde_connect, albertvaka Subscribers: albertvaka, kdeconnect Tags: #kde_connect Differential Revision: https://phabricator.kde.org/D14612
This commit is contained in:
Nicolas Fella
318
src/org/kde/kdeconnect/Plugins/SMSPlugin/SMSPlugin.java
Normal file
318
src/org/kde/kdeconnect/Plugins/SMSPlugin/SMSPlugin.java
Normal file
@@ -0,0 +1,318 @@
|
||||
/*
|
||||
* Copyright 2014 Albert Vaca Cintora <albertvaka@gmail.com>
|
||||
*
|
||||
* This program is free software; you can redistribute it and/or
|
||||
* modify it under the terms of the GNU General Public License as
|
||||
* published by the Free Software Foundation; either version 2 of
|
||||
* the License or (at your option) version 3 or any later version
|
||||
* accepted by the membership of KDE e.V. (or its successor approved
|
||||
* by the membership of KDE e.V.), which shall act as a proxy
|
||||
* defined in Section 14 of version 3 of the license.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
|
||||
package org.kde.kdeconnect.Plugins.SMSPlugin;
|
||||
|
||||
import android.Manifest;
|
||||
import android.content.BroadcastReceiver;
|
||||
import android.content.Context;
|
||||
import android.content.Intent;
|
||||
import android.content.IntentFilter;
|
||||
import android.content.SharedPreferences;
|
||||
import android.content.pm.PackageManager;
|
||||
import android.os.Bundle;
|
||||
import android.preference.PreferenceManager;
|
||||
import android.support.v4.content.ContextCompat;
|
||||
import android.telephony.PhoneNumberUtils;
|
||||
import android.telephony.SmsManager;
|
||||
import android.telephony.SmsMessage;
|
||||
import android.util.Log;
|
||||
|
||||
import org.json.JSONArray;
|
||||
import org.json.JSONException;
|
||||
import org.json.JSONObject;
|
||||
import org.kde.kdeconnect.Helpers.ContactsHelper;
|
||||
import org.kde.kdeconnect.Helpers.SMSHelper;
|
||||
import org.kde.kdeconnect.NetworkPacket;
|
||||
import org.kde.kdeconnect.Plugins.Plugin;
|
||||
import org.kde.kdeconnect.Plugins.TelephonyPlugin.TelephonyPlugin;
|
||||
import org.kde.kdeconnect_tp.BuildConfig;
|
||||
import org.kde.kdeconnect_tp.R;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
import static org.kde.kdeconnect.Plugins.TelephonyPlugin.TelephonyPlugin.PACKET_TYPE_TELEPHONY;
|
||||
|
||||
public class SMSPlugin extends Plugin {
|
||||
|
||||
private final static String PACKET_TYPE_SMS_REQUEST = "kdeconnect.sms.request";
|
||||
|
||||
/**
|
||||
* Packet used to indicate a batch of messages has been pushed from the remote device
|
||||
*
|
||||
* The body should contain the key "messages" mapping to an array of messages
|
||||
*
|
||||
* For example:
|
||||
* { "messages" : [
|
||||
* { "event" : "sms",
|
||||
* "messageBody" : "Hello",
|
||||
* "phoneNumber" : "2021234567",
|
||||
* "messageDate" : "1518846484880",
|
||||
* "messageType" : "2",
|
||||
* "threadID" : "132"
|
||||
* },
|
||||
* { ... },
|
||||
* ...
|
||||
* ]
|
||||
*/
|
||||
private final static String PACKET_TYPE_TELEPHONY_MESSAGE = "kdeconnect.telephony.message";
|
||||
|
||||
/**
|
||||
* Packet sent to request all conversations
|
||||
*
|
||||
* The request packet shall contain no body
|
||||
*/
|
||||
public final static String PACKET_TYPE_TELEPHONY_REQUEST_CONVERSATIONS = "kdeconnect.telephony.request_conversations";
|
||||
|
||||
/**
|
||||
* Packet sent to request all the messages in a particular conversation
|
||||
*
|
||||
* The body should contain the key "threadID" mapping to the threadID (as a string) being requested
|
||||
* For example:
|
||||
* { "threadID": 203 }
|
||||
*/
|
||||
public final static String PACKET_TYPE_TELEPHONY_REQUEST_CONVERSATION = "kdeconnect.telephony.request_conversation";
|
||||
|
||||
private static final String KEY_PREF_BLOCKED_NUMBERS = "telephony_blocked_numbers";
|
||||
|
||||
private final BroadcastReceiver receiver = new BroadcastReceiver() {
|
||||
@Override
|
||||
public void onReceive(Context context, Intent intent) {
|
||||
|
||||
String action = intent.getAction();
|
||||
|
||||
//Log.e("TelephonyPlugin","Telephony event: " + action);
|
||||
|
||||
if ("android.provider.Telephony.SMS_RECEIVED".equals(action)) {
|
||||
|
||||
final Bundle bundle = intent.getExtras();
|
||||
if (bundle == null) return;
|
||||
final Object[] pdus = (Object[]) bundle.get("pdus");
|
||||
ArrayList<SmsMessage> messages = new ArrayList<>();
|
||||
|
||||
for (Object pdu : pdus) {
|
||||
// I hope, but am not sure, that the pdus array is in the order that the parts
|
||||
// of the SMS message should be
|
||||
// If it is not, I believe the pdu contains the information necessary to put it
|
||||
// in order, but in my testing the order seems to be correct, so I won't worry
|
||||
// about it now.
|
||||
messages.add(SmsMessage.createFromPdu((byte[]) pdu));
|
||||
}
|
||||
|
||||
smsBroadcastReceived(messages);
|
||||
|
||||
}
|
||||
}
|
||||
};
|
||||
|
||||
private void smsBroadcastReceived(ArrayList<SmsMessage> messages) {
|
||||
|
||||
if (BuildConfig.DEBUG) {
|
||||
if (!(messages.size() > 0)) {
|
||||
throw new AssertionError("This method requires at least one message");
|
||||
}
|
||||
}
|
||||
|
||||
NetworkPacket np = new NetworkPacket(PACKET_TYPE_TELEPHONY);
|
||||
|
||||
np.set("event", "sms");
|
||||
|
||||
StringBuilder messageBody = new StringBuilder();
|
||||
for (int index = 0; index < messages.size(); index++) {
|
||||
messageBody.append(messages.get(index).getMessageBody());
|
||||
}
|
||||
np.set("messageBody", messageBody.toString());
|
||||
|
||||
String phoneNumber = messages.get(0).getOriginatingAddress();
|
||||
|
||||
if (isNumberBlocked(phoneNumber))
|
||||
return;
|
||||
|
||||
int permissionCheck = ContextCompat.checkSelfPermission(context,
|
||||
Manifest.permission.READ_CONTACTS);
|
||||
|
||||
if (permissionCheck == PackageManager.PERMISSION_GRANTED) {
|
||||
Map<String, String> contactInfo = ContactsHelper.phoneNumberLookup(context, phoneNumber);
|
||||
|
||||
if (contactInfo.containsKey("name")) {
|
||||
np.set("contactName", contactInfo.get("name"));
|
||||
}
|
||||
|
||||
if (contactInfo.containsKey("photoID")) {
|
||||
np.set("phoneThumbnail", ContactsHelper.photoId64Encoded(context, contactInfo.get("photoID")));
|
||||
}
|
||||
}
|
||||
if (phoneNumber != null) {
|
||||
np.set("phoneNumber", phoneNumber);
|
||||
}
|
||||
|
||||
|
||||
device.sendPacket(np);
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean onCreate() {
|
||||
permissionExplanation = R.string.telepathy_permission_explanation;
|
||||
|
||||
IntentFilter filter = new IntentFilter("android.provider.Telephony.SMS_RECEIVED");
|
||||
filter.setPriority(500);
|
||||
context.registerReceiver(receiver, filter);
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
@Override
|
||||
public String getDisplayName() {
|
||||
return context.getResources().getString(R.string.pref_plugin_telepathy);
|
||||
}
|
||||
|
||||
@Override
|
||||
public String getDescription() {
|
||||
return context.getResources().getString(R.string.pref_plugin_telepathy_desc);
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean onPacketReceived(NetworkPacket np) {
|
||||
|
||||
if (np.getType().equals(PACKET_TYPE_TELEPHONY_REQUEST_CONVERSATIONS)) {
|
||||
return this.handleRequestConversations(np);
|
||||
} else if (np.getType().equals(PACKET_TYPE_TELEPHONY_REQUEST_CONVERSATION)) {
|
||||
return this.handleRequestConversation(np);
|
||||
}
|
||||
|
||||
if (np.getBoolean("sendSms")) {
|
||||
String phoneNo = np.getString("phoneNumber");
|
||||
String sms = np.getString("messageBody");
|
||||
|
||||
try {
|
||||
SmsManager smsManager = SmsManager.getDefault();
|
||||
ArrayList<String> parts = smsManager.divideMessage(sms);
|
||||
|
||||
// If this message turns out to fit in a single SMS, sendMultipartTextMessage
|
||||
// properly handles that case
|
||||
smsManager.sendMultipartTextMessage(phoneNo, null, parts, null, null);
|
||||
|
||||
//TODO: Notify other end
|
||||
} catch (Exception e) {
|
||||
//TODO: Notify other end
|
||||
Log.e("SMSPlugin", e.getMessage());
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
/**
|
||||
* Respond to a request for all conversations
|
||||
* <p>
|
||||
* Send one packet of type PACKET_TYPE_TELEPHONY_MESSAGE with the first message in all conversations
|
||||
*/
|
||||
protected boolean handleRequestConversations(NetworkPacket packet) {
|
||||
Map<SMSHelper.ThreadID, SMSHelper.Message> conversations = SMSHelper.getConversations(this.context);
|
||||
|
||||
NetworkPacket reply = new NetworkPacket(PACKET_TYPE_TELEPHONY_MESSAGE);
|
||||
|
||||
JSONArray messages = new JSONArray();
|
||||
|
||||
for (SMSHelper.Message message : conversations.values()) {
|
||||
try {
|
||||
JSONObject json = message.toJSONObject();
|
||||
|
||||
json.put("event", "sms");
|
||||
|
||||
messages.put(json);
|
||||
} catch (JSONException e) {
|
||||
Log.e("Conversations", "Error serializing message");
|
||||
}
|
||||
}
|
||||
|
||||
reply.set("messages", messages);
|
||||
reply.set("event", "batch_messages"); // Not really necessary, since this is implied by PACKET_TYPE_TELEPHONY_MESSAGE, but good for readability
|
||||
|
||||
device.sendPacket(reply);
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
protected boolean handleRequestConversation(NetworkPacket packet) {
|
||||
SMSHelper.ThreadID threadID = new SMSHelper.ThreadID(packet.getInt("threadID"));
|
||||
|
||||
List<SMSHelper.Message> conversation = SMSHelper.getMessagesInThread(this.context, threadID);
|
||||
|
||||
NetworkPacket reply = new NetworkPacket(PACKET_TYPE_TELEPHONY_MESSAGE);
|
||||
|
||||
JSONArray messages = new JSONArray();
|
||||
|
||||
for (SMSHelper.Message message : conversation) {
|
||||
try {
|
||||
JSONObject json = message.toJSONObject();
|
||||
|
||||
json.put("event", "sms");
|
||||
|
||||
messages.put(json);
|
||||
} catch (JSONException e) {
|
||||
Log.e("Conversations", "Error serializing message");
|
||||
}
|
||||
}
|
||||
|
||||
reply.set("messages", messages);
|
||||
reply.set("event", "batch_messages");
|
||||
|
||||
device.sendPacket(reply);
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
private boolean isNumberBlocked(String number) {
|
||||
SharedPreferences sharedPref = PreferenceManager.getDefaultSharedPreferences(context);
|
||||
String[] blockedNumbers = sharedPref.getString(KEY_PREF_BLOCKED_NUMBERS, "").split("\n");
|
||||
|
||||
for (String s : blockedNumbers) {
|
||||
if (PhoneNumberUtils.compare(number, s))
|
||||
return true;
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
|
||||
@Override
|
||||
public String[] getSupportedPacketTypes() {
|
||||
return new String[]{
|
||||
PACKET_TYPE_SMS_REQUEST,
|
||||
TelephonyPlugin.PACKET_TYPE_TELEPHONY_REQUEST,
|
||||
PACKET_TYPE_TELEPHONY_REQUEST_CONVERSATIONS,
|
||||
PACKET_TYPE_TELEPHONY_REQUEST_CONVERSATION
|
||||
};
|
||||
}
|
||||
|
||||
@Override
|
||||
public String[] getOutgoingPacketTypes() {
|
||||
return new String[]{PACKET_TYPE_TELEPHONY_MESSAGE};
|
||||
}
|
||||
|
||||
@Override
|
||||
public String[] getRequiredPermissions() {
|
||||
return new String[]{Manifest.permission.SEND_SMS};
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user