jeena/sms-translate
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

Import SMS

Browse source
This commit is contained in:
Paul Akhamiogu 2021-09-12 18:44:52 +01:00
parent 7f32115afe
commit 9656207135
14 changed files with 310 additions and 28 deletions
Download patch file Download diff file Expand all files Collapse all files

1
app/src/main/kotlin/com/simplemobiletools/smsmessenger/helpers/Constants.kt
View file

@ -22,6 +22,7 @@ const val EXPORT_MIME_TYPE = "application/json"
const val EXPORT_FILE_EXT = ".json"
const val IMPORT_SMS = "import_sms"
const val IMPORT_MMS = "import_mms"
const val MMS_CONTENT = "mms_content"
private const val PATH = "com.simplemobiletools.smsmessenger.action."
const val MARK_AS_READ = PATH + "mark_as_read"

19
app/src/main/kotlin/com/simplemobiletools/smsmessenger/helpers/JsonObjectWriter.kt
View file

@ -8,37 +8,36 @@ import com.google.gson.stream.JsonWriter
class JsonObjectWriter(private val writer: JsonWriter) {
fun dump(obj: JsonObject) {
fun write(obj: JsonObject) {
writer.beginObject()
for (key in obj.keySet()) {
writer.name(key)
val keyObj = obj.get(key)
dump(keyObj)
write(keyObj)
}
writer.endObject()
}
private fun dump(arr: JsonArray) {
private fun write(arr: JsonArray) {
writer.beginArray()
for (i in 0 until arr.size()) {
dump(arr.get(i))
write(arr.get(i))
}
writer.endArray()
}
private fun dump(obj: Any) {
private fun write(obj: Any) {
when (obj) {
is JsonNull -> writer.nullValue()
is JsonPrimitive -> {
when{
obj.isString -> writer.value(obj.asString)
obj.isBoolean -> writer.value(obj.asNumber)
obj.isNumber -> writer.value(obj.asBoolean)
obj.isNumber -> writer.value(obj.asBoolean)
obj.isBoolean -> writer.value(obj.asBoolean)
obj.isNumber -> writer.value(obj.asNumber)
}
}
is JsonArray -> dump(obj)
is JsonObject -> dump(obj)
is JsonArray -> write(obj)
is JsonObject -> write(obj)
}
}
}

4
app/src/main/kotlin/com/simplemobiletools/smsmessenger/helpers/MessagesExporter.kt
View file

@ -53,7 +53,7 @@ class MessagesExporter(private val context: Context) {
writer.beginArray()
//write all sms
messageReader.forEachSms(threadId){
JsonObjectWriter(writer).dump(it)
JsonObjectWriter(writer).write(it)
written++
}
writer.endArray()
@ -64,7 +64,7 @@ class MessagesExporter(private val context: Context) {
writer.beginArray()
//write all mms
messageReader.forEachMms(threadId){
JsonObjectWriter(writer).dump(it)
JsonObjectWriter(writer).write(it)
written++
}

83
app/src/main/kotlin/com/simplemobiletools/smsmessenger/helpers/MessagesImporter.kt Normal file
View file

@ -0,0 +1,83 @@
package com.simplemobiletools.smsmessenger.helpers
import android.content.Context
import android.provider.Telephony
import android.util.Log
import com.google.gson.Gson
import com.google.gson.reflect.TypeToken
import com.simplemobiletools.commons.extensions.queryCursor
import com.simplemobiletools.commons.helpers.ensureBackgroundThread
import com.simplemobiletools.smsmessenger.extensions.*
import com.simplemobiletools.smsmessenger.models.ExportedMessage
import java.io.File
class MessagesImporter(private val context: Context) {
companion object {
private const val TAG = "MessagesImporter"
}
enum class ImportResult {
IMPORT_FAIL, IMPORT_OK, IMPORT_PARTIAL, IMPORT_NOTHING_NEW
}
private val gson = Gson()
private val messageWriter = MessagesWriter(context)
private val config = context.config
fun importMessages(path: String, callback: (result: ImportResult) -> Unit) {
ensureBackgroundThread {
if (path.isEmpty()) {
callback.invoke(ImportResult.IMPORT_FAIL)
return@ensureBackgroundThread
}
//read data from path
// parse json
// write data to sql db
val inputStream = if (path.contains("/")) {
File(path).inputStream()
} else {
context.assets.open(path)
}
inputStream.bufferedReader().use {
try {
val json = it.readText()
Log.d(TAG, "importMessages: json== ${json.length}")
val type = object : TypeToken<Map<String, ExportedMessage>>() {}.type
val data = gson.fromJson<Map<String, ExportedMessage>>(json, type)
Log.d(TAG, "importMessages: ${data.size}")
for (message in data.values) {
// add sms
if (config.importSms) {
message.sms.forEach(messageWriter::writeSmsMessage)
}
// add mms
if (config.importMms) {
message.sms.forEach(messageWriter::writeMmsMessage)
}
// messageWriter.updateAllSmsThreads()
val conversations = context.getConversations()
val conversationIds = context.getConversationIds()
Log.w(TAG, "conversations = $conversations")
Log.w(TAG, "conversationIds = $conversationIds")
context.queryCursor(Telephony.Sms.CONTENT_URI) { cursor ->
val json = cursor.rowsToJson()
Log.w(TAG, "messages = $json")
}
refreshMessages()
}
} catch (e: Exception) {
Log.e(TAG, "importMessages: ", e)
callback.invoke(ImportResult.IMPORT_FAIL)
}
}
}
}
}

1
app/src/main/kotlin/com/simplemobiletools/smsmessenger/helpers/MessagesReader.kt
View file

@ -22,7 +22,6 @@ import java.io.InputStream
class MessagesReader(private val context: Context) {
companion object {
private const val TAG = "MessagesReader"
private const val MMS_CONTENT = "mms_content"
}
fun forEachSms(threadId: Long, block: (JsonObject) -> Unit) {
forEachThreadMessage(Telephony.Sms.CONTENT_URI, threadId, block)

85
app/src/main/kotlin/com/simplemobiletools/smsmessenger/helpers/MessagesWriter.kt Normal file
View file

@ -0,0 +1,85 @@
package com.simplemobiletools.smsmessenger.helpers
import android.content.ContentValues
import android.content.Context
import android.provider.Telephony
import android.util.Log
import com.simplemobiletools.commons.extensions.queryCursor
import com.simplemobiletools.smsmessenger.extensions.getThreadId
import com.simplemobiletools.smsmessenger.extensions.toContentValues
class MessagesWriter(private val context: Context) {
companion object {
private const val TAG = "MessagesWriter"
}
private val contentResolver = context.contentResolver
fun writeSmsMessage(map: Map<String, String>) {
Log.w(TAG, "writeSmsMessage: map=$map")
val contentValues = map.toContentValues()
contentValues.remove(Telephony.Sms._ID)
replaceThreadId(contentValues)
Log.d(TAG, "writeSmsMessage: contentValues=$contentValues")
val type = contentValues.getAsInteger(Telephony.Sms.TYPE)
Log.d(TAG, "writeSmsMessage: type=$type")
if ((type == Telephony.Sms.MESSAGE_TYPE_INBOX || type == Telephony.Sms.MESSAGE_TYPE_SENT) && !smsExist(map)) {
Log.d(TAG, "writeSmsMessage: Inserting SMS...")
val uri = Telephony.Sms.CONTENT_URI
Log.d(TAG, "writeSmsMessage: uri=$uri")
contentResolver.insert(Telephony.Sms.CONTENT_URI, contentValues)
}
}
private fun replaceThreadId(contentValues: ContentValues) {
val address = contentValues.get(Telephony.Sms.ADDRESS)
val threadId = context.getThreadId(address.toString())
contentValues.put(Telephony.Sms.THREAD_ID, threadId)
}
fun writeMmsMessage(map: Map<String, Any>) {
}
private fun smsExist(sms: Map<String, String>): Boolean {
val uri = Telephony.Sms.CONTENT_URI
val projection = arrayOf(Telephony.Sms._ID)
val selection = "${Telephony.Sms.DATE} = ? AND ${Telephony.Sms.ADDRESS} = ? AND ${Telephony.Sms.TYPE} = ?"
val selectionArgs = arrayOf(sms[Telephony.Sms.DATE] as String, sms[Telephony.Sms.ADDRESS] as String, sms[Telephony.Sms.TYPE] as String)
var exists = false
context.queryCursor(uri, projection, selection, selectionArgs) {
exists = it.count > 0
Log.i(TAG, "smsExist After: $exists")
}
Log.i(TAG, "smsExist: $exists")
return exists
}
private fun Map<String, String>.toSmsContentValues(): ContentValues {
val values = ContentValues()
val address = get(Telephony.Sms.ADDRESS) as String
values.put(Telephony.Sms.ADDRESS, address)
values.put(Telephony.Sms.DATE, get(Telephony.Sms.DATE))
values.put(Telephony.Sms.DATE_SENT, get(Telephony.Sms.DATE_SENT))
values.put(Telephony.Sms.BODY, get(Telephony.Sms.BODY) as String)
values.put(Telephony.Sms.TYPE, get(Telephony.Sms.TYPE))
values.put(Telephony.Sms.PROTOCOL, get(Telephony.Sms.PROTOCOL))
values.put(Telephony.Sms.SERVICE_CENTER, get(Telephony.Sms.SERVICE_CENTER))
values.put(Telephony.Sms.STATUS, get(Telephony.Sms.STATUS))
values.put(Telephony.Sms.READ, get(Telephony.Sms.READ))
values.put(Telephony.Sms.CREATOR, get(Telephony.Sms.CREATOR))
values.put(Telephony.Sms.LOCKED, get(Telephony.Sms.LOCKED))
values.put(Telephony.Sms.SUBSCRIPTION_ID, get(Telephony.Sms.SUBSCRIPTION_ID))
values.put(Telephony.Sms.THREAD_ID, context.getThreadId(address))
return values
}
fun updateAllSmsThreads(){
// thread dates + states might be wrong, we need to force a full update
// unfortunately there's no direct way to do that in the SDK, but passing a
// negative conversation id to delete should to the trick
contentResolver.delete(Telephony.Sms.Conversations.CONTENT_URI.buildUpon().appendPath("-1").build(), null, null)
}
}