Allow manual sending of scheduled messages

2018-06-27 12:25:19 -04:00
parent 61c8ca17e8
commit d3ceec01fd
13 changed files with 89 additions and 237 deletions
@@ -0,0 +1,85 @@
+/*
+ * Copyright (C) 2017 Moez Bhatti <moez.bhatti@gmail.com>
+ *
+ * This file is part of QKSMS.
+ *
+ * QKSMS 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 3 of the License, or
+ * (at your option) any later version.
+ *
+ * QKSMS 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 QKSMS.  If not, see <http://www.gnu.org/licenses/>.
+ */
+package com.moez.QKSMS.compat
+
+import android.content.Context
+import android.database.sqlite.SqliteWrapper
+import android.net.Uri
+import android.os.Build
+import android.provider.BaseColumns
+import android.provider.Telephony
+import android.text.TextUtils
+import android.util.Patterns
+import timber.log.Timber
+import java.util.regex.Pattern
+
+object TelephonyCompat {
+
+    private val ID_PROJECTION = arrayOf(BaseColumns._ID)
+
+    private val THREAD_ID_CONTENT_URI = Uri.parse("content://mms-sms/threadID")
+
+    val NAME_ADDR_EMAIL_PATTERN = Pattern.compile("\\s*(\"[^\"]*\"|[^<>\"]+)\\s*<([^<>]+)>\\s*")
+
+    fun getOrCreateThreadId(context: Context, recipient: String): Long {
+        return getOrCreateThreadId(context, listOf(recipient))
+    }
+
+    fun getOrCreateThreadId(context: Context, recipients: Collection<String>): Long {
+        return if (Build.VERSION.SDK_INT >= 23) {
+            Telephony.Threads.getOrCreateThreadId(context, recipients.toSet())
+        } else {
+            val uriBuilder = THREAD_ID_CONTENT_URI.buildUpon()
+
+            recipients
+                    .map { recipient -> if (isEmailAddress(recipient)) extractAddrSpec(recipient) else recipient }
+                    .forEach { recipient -> uriBuilder.appendQueryParameter("recipient", recipient) }
+
+            val uri = uriBuilder.build()
+
+            SqliteWrapper.query(context, context.contentResolver, uri, ID_PROJECTION, null, null, null)?.use { cursor ->
+                if (cursor.moveToFirst()) {
+                    return cursor.getLong(0)
+                } else {
+                    Timber.e("getOrCreateThreadId returned no rows!")
+                }
+            }
+
+            Timber.e("getOrCreateThreadId failed with " + recipients.size + " recipients")
+            throw IllegalArgumentException("Unable to find or allocate a thread ID.")
+        }
+    }
+
+    fun extractAddrSpec(address: String): String {
+        val match = NAME_ADDR_EMAIL_PATTERN.matcher(address)
+        return if (match.matches()) {
+            match.group(2)
+        } else address
+    }
+
+    fun isEmailAddress(address: String): Boolean {
+        if (TextUtils.isEmpty(address)) {
+            return false
+        }
+        val s = extractAddrSpec(address)
+        val match = Patterns.EMAIL_ADDRESS.matcher(s)
+        return match.matches()
+    }
+
+}