Modifier/app/src/main/java/com/example/modifier/service/ModifierService.kt

package com.example.modifier.service

import android.accessibilityservice.AccessibilityService
import android.accessibilityservice.AccessibilityServiceInfo
import android.annotation.SuppressLint
import android.content.Context
import android.content.Intent
import android.graphics.PixelFormat
import android.graphics.Rect
import android.net.Uri
import android.os.Build
import android.util.DisplayMetrics
import android.util.Log
import android.view.Gravity
import android.view.LayoutInflater
import android.view.MotionEvent
import android.view.View
import android.view.View.OnTouchListener
import android.view.WindowManager
import android.view.accessibility.AccessibilityEvent
import android.view.accessibility.AccessibilityNodeInfo
import android.widget.CompoundButton
import android.widget.FrameLayout
import androidx.datastore.core.DataStore
import androidx.datastore.preferences.core.Preferences
import androidx.datastore.preferences.preferencesDataStore
import androidx.lifecycle.MediatorLiveData
import androidx.lifecycle.MutableLiveData
import androidx.lifecycle.Observer
import androidx.lifecycle.liveData
import com.example.modifier.BuildConfig
import com.example.modifier.Global
import com.example.modifier.Global.load
import com.example.modifier.Global.resetAll
import com.example.modifier.R
import com.example.modifier.TraverseResult
import com.example.modifier.Utils
import com.example.modifier.databinding.FloatingWindowBinding
import com.example.modifier.enums.RcsConfigureState
import com.example.modifier.extension.waitUntilValueIs
import com.example.modifier.http.KtorClient
import com.example.modifier.http.RcsNumberApi
import com.example.modifier.http.request.RcsNumberRequest
import com.example.modifier.http.response.RcsNumberResponse
import com.example.modifier.model.TelephonyConfig
import com.google.android.material.color.DynamicColors
import io.ktor.client.call.body
import io.ktor.client.plugins.resources.get
import io.ktor.client.plugins.resources.put
import io.ktor.client.request.setBody
import io.ktor.http.ContentType
import io.ktor.http.contentType
import io.socket.client.IO
import io.socket.client.Socket
import io.socket.emitter.Emitter
import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.delay
import kotlinx.coroutines.launch
import kotlinx.coroutines.runBlocking
import kotlinx.coroutines.suspendCancellableCoroutine
import kotlinx.coroutines.withContext
import kotlinx.coroutines.withTimeoutOrNull
import org.apache.commons.collections4.queue.CircularFifoQueue
import org.apache.commons.lang3.RandomStringUtils
import org.apache.commons.lang3.StringUtils
import org.json.JSONArray
import org.json.JSONException
import org.json.JSONObject
import java.util.Optional
import java.util.concurrent.ScheduledExecutorService
import java.util.concurrent.ScheduledThreadPoolExecutor
import java.util.concurrent.TimeUnit
import java.util.concurrent.atomic.AtomicReference
import kotlin.coroutines.resume
import kotlin.math.max
import kotlin.math.min
import kotlin.time.Duration.Companion.hours
import kotlin.time.Duration.Companion.seconds

val Context.dataStore: DataStore<Preferences> by preferencesDataStore(name = "serverConfig")

@SuppressLint("SetTextI18n")
class ModifierService : AccessibilityService(), Emitter.Listener {
    companion object {
        private const val TAG = "ModifierService"

        const val NAME: String = BuildConfig.APPLICATION_ID + ".service.ModifierService"

        @JvmStatic
        var instance: ModifierService? = null
            private set
    }

    private val mExecutor: ScheduledExecutorService = ScheduledThreadPoolExecutor(8)

    private val mSocketOpts = IO.Options()
    private lateinit var mSocket: Socket
    private lateinit var binding: FloatingWindowBinding

    private var canSend: Boolean
        get() {
            return getSharedPreferences(
                BuildConfig.APPLICATION_ID,
                MODE_PRIVATE
            ).getBoolean("canSend", false)
        }
        set(value) {
            getSharedPreferences(BuildConfig.APPLICATION_ID, MODE_PRIVATE).edit()
                .putBoolean("canSend", value).apply()
            reportDeviceStatues()
        }
    private var counter = 0
    private var cleanCount = 0
    private var lastSend = 0L
    private var rcsInterval = 0L
    private var requestNumberInterval = 0
    private val running = MutableLiveData(false)
    private val requesting = MutableLiveData(false)
    private var currentTaskId = 0

    private var busy = MediatorLiveData<Boolean>().apply {
        addSource(running) {
            value = it || requesting.value!!
        }
        addSource(requesting) {
            value = it || running.value!!
        }
        value = requesting.value!! || running.value!!
    }

    private val rcsConfigureState = MutableLiveData(RcsConfigureState.CONFIGURED)

    private var sendCount: Int
        get() {
            return getSharedPreferences(
                BuildConfig.APPLICATION_ID,
                MODE_PRIVATE
            ).getInt("sendCount", 0)
        }
        set(value) {
            getSharedPreferences(BuildConfig.APPLICATION_ID, MODE_PRIVATE).edit()
                .putInt("sendCount", value).apply()
        }

    private var requestNumberCount: Int
        get() {
            return getSharedPreferences(
                BuildConfig.APPLICATION_ID,
                MODE_PRIVATE
            ).getInt("requestNumberCount", 0)
        }
        set(value) {
            getSharedPreferences(BuildConfig.APPLICATION_ID, MODE_PRIVATE).edit()
                .putInt("requestNumberCount", value).apply()
        }

    private val logcat = liveData(Dispatchers.IO) {
        try {
            val logs = CircularFifoQueue<String>(128)
            val p = Runtime.getRuntime().exec("su")
            p.outputStream.bufferedWriter().use { writer ->
                writer.write("logcat -c")
                writer.newLine()
                writer.flush()
                writer.write("logcat BugleRcsEngine:D *:S -v time")
                writer.newLine()
                writer.flush()
            }
            p.inputStream
                .bufferedReader()
                .useLines { lines ->
                    Log.d(TAG, "logcat new lines")
                    lines.forEach { line ->
                        if (line.contains("destState=CheckPreconditionsState")) {
                            rcsConfigureState.postValue(RcsConfigureState.NOT_CONFIGURED)
                        } else if (line.contains("destState=WaitingForOtpState")) {
                            rcsConfigureState.postValue(RcsConfigureState.WAITING_FOR_OTP)
                        } else if (line.contains("destState=VerifyOtpState")) {
                            rcsConfigureState.postValue(RcsConfigureState.VERIFYING_OTP)
                        } else if (line.contains("destState=ConfiguredState")) {
                            rcsConfigureState.postValue(RcsConfigureState.CONFIGURED)
                        } else if (line.contains("destState=WaitingForRcsDefaultOnState")) {
                            rcsConfigureState.postValue(RcsConfigureState.WAITING_FOR_DEFAULT_ON)
                        }
                        Regex("(?<time>\\d{2}-\\d{2} \\d{2}:\\d{2}:\\d{2}.\\d{3}) I/BugleRcsEngine\\(\\W*\\d+\\)(?<log>.*)").matchEntire(
                            line
                        )?.apply {
                            val time = groups["time"]?.value?.dropLast(4)
                            val log = groups["log"]?.value
                                ?.replace(Regex("\\[\\w+-\\w+-\\w+-\\w+-\\w+]"), "")
                                ?.replace(Regex("\\[CONTEXT.*]"), "")
                                ?.trim()

                            if (time != null && log != null) {
                                if (log.contains("destState=")) {
                                    logs.add("$time: $log")
                                    emit(logs.joinToString("\n"))
                                }
                            }
                        }
                    }
                }
        } catch (e: Exception) {
            e.printStackTrace()
        }
    }

    fun connect() {
        try {
            load()
            if (this@ModifierService::binding.isInitialized) {
                binding.swSend.text = Global.name
            }
            if (this@ModifierService::mSocket.isInitialized) {
                mSocket.disconnect()
            }
            mSocketOpts.query =
                "model=${Build.MANUFACTURER} ${Build.MODEL}&name=${Global.name}&id=${Utils.getUniqueID()}"
            mSocketOpts.transports = arrayOf("websocket")
            Log.i(TAG, "Connection query: ${mSocketOpts.query}")
            mSocket = IO.socket(Global.serverUrl, mSocketOpts)
            mSocket.on("message", this@ModifierService)
            mSocket.on(Socket.EVENT_CONNECT) {
                Log.i(TAG, "Connected to server")
                CoroutineScope(Dispatchers.IO).launch {
                    delay(500)
                    reportDeviceStatues()
                }
            }
            mSocket.on(Socket.EVENT_DISCONNECT) {
                Log.i(TAG, "Disconnected from server")
            }
            mSocket.on(Socket.EVENT_CONNECT_ERROR) { args ->
                Log.i(TAG, "Connection error: " + args[0])
                if (args[0] is Exception) {
                    val e = args[0] as Exception
                    e.printStackTrace()
                }
            }
            mSocket.connect()
        } catch (e: Exception) {
            e.printStackTrace()
        }
    }

    override fun onCreate() {
        super.onCreate()
        Log.i(TAG, "Starting ModifierService")
        connect()
    }

    override fun onAccessibilityEvent(event: AccessibilityEvent) {
//        traverseNode(getRootInActiveWindow(), new TraverseResult());
    }

    override fun onInterrupt() {
    }

    override fun call(vararg args: Any) {
        if (args.isNotEmpty()) {
            Log.i(TAG, "Received message: " + args[0])
            if (args[0] is JSONObject) {
                val json = args[0] as JSONObject
                val action = json.optString("action")
                if ("send" == action) {
                    val data = json.optJSONObject("data")
                    if (data != null) {
                        val to = data.optString("to")
                        val body = data.optString("body")
                        send(to, body, 2000)
                    }
                } else if ("task" == action) {
                    val data = json.optJSONObject("data")
                    val id = json.optString("id")
                    if (data != null && StringUtils.isNoneBlank(id)) {
                        runTask(id, data)
                    }
                } else if ("changeNumber" == action) {
                }
            }
        }
    }

    private fun runTask(id: String, data: JSONObject) {
        val config = data.optJSONObject("config")
        config!!
        val rcsWait = config.optLong("rcsWait", 2000)
        cleanCount = config.optInt("cleanCount", 20)
        rcsInterval = config.optLong("rcsInterval", 0)
        requestNumberInterval = config.optInt("requestNumberInterval", 0)
        val tasks = data.optJSONArray("tasks")!!
        currentTaskId = data.optInt("taskId", 0)
        mExecutor.submit {
            running.postValue(true)

            val success = JSONArray()
            val fail = JSONArray()
            for (i in 0 until tasks.length()) {
                val task = tasks.optJSONObject(i)
                val to = task.optString("number")
                val body = task.optString("message")
                val taskId = task.optInt("id")
                try {
                    if (send(to, body, rcsWait)) {
                        success.put(taskId)
                    } else {
                        fail.put(taskId)
                    }
                } catch (e: Exception) {
                    e.printStackTrace()
                    fail.put(taskId)
                }
            }
            val res = JSONObject()
            try {
                res.put("id", id)
                res.put("status", 0)
                res.put(
                    "data", JSONObject()
                        .put("success", success)
                        .put("fail", fail)
                )
            } catch (e: JSONException) {
            }
            mSocket.emit("callback", res)
            if (requestNumberInterval in 1..sendCount) {
                runBlocking {
                    requestNumber()
                }
            }
            running.postValue(false)
        }
    }

    private fun send(to: String, body: String, rcsWait: Long): Boolean {
        Log.i(TAG, "Sending SMS to $to: $body")
        val intent = Intent(Intent.ACTION_SENDTO)
        intent.setData(Uri.parse("sms:$to"))
        intent.putExtra("sms_body", body)
        intent.putExtra("exit_on_sent", true)
        intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK)
        startActivity(intent)
        try {
            Log.i(TAG, "Command executed successfully, waiting for app to open...")
            val f = mExecutor.schedule<Boolean>(
                {
                    var success = false
                    val ts = System.currentTimeMillis()
                    while (System.currentTimeMillis() - ts < rcsWait) {
                        val root = rootInActiveWindow
                        val packageName = root.packageName.toString()
                        val traverseResult = TraverseResult()
                        traverseNode(root, traverseResult)
                        if (traverseResult.isRcsCapable) {
                            if (traverseResult.sendBtn == null) {
                                Log.i(TAG, "Send button not found")
                            } else {
                                Log.i(TAG, "Clicking send button")

                                val dt = System.currentTimeMillis() - lastSend
                                if (rcsInterval > 0 && dt < rcsInterval) {
                                    Log.i(TAG, "Waiting for RCS interval")
                                    Thread.sleep(rcsInterval - dt)
                                }
                                traverseResult.sendBtn.performAction(AccessibilityNodeInfo.ACTION_CLICK)
                                lastSend = System.currentTimeMillis()
                                success = true
                                sendCount++
                                break
                            }
                        } else {
                            Log.i(TAG, "RCS not detected")
                        }
                        try {
                            Thread.sleep(500)
                        } catch (e: InterruptedException) {
                            e.printStackTrace()
                        }
                    }
                    counter++
                    Log.i(
                        TAG,
                        "sendCount: $sendCount, Counter: $counter, cleanCount: $cleanCount, requestNumberInterval: $requestNumberInterval"
                    )
                    if (cleanCount in 1..counter) {
                        counter = 0
                        Thread.sleep(2000)
                        Global.clearConv();
                        Thread.sleep(2000)
                    }
                    success
                }, 1000, TimeUnit.MILLISECONDS
            )
            synchronized(f) {
                Log.i(TAG, "Waiting for task to complete...")
                return f.get()
            }
        } catch (e: Exception) {
            e.printStackTrace()
        }
        return false
    }

    private fun traverseNode(node: AccessibilityNodeInfo?, result: TraverseResult) {
        if (node == null) {
            return
        }

        val className = node.className.toString()
        val name = node.viewIdResourceName
        val text = Optional.ofNullable(node.text).map { obj: CharSequence -> obj.toString() }
            .orElse(null)
        val id = node.viewIdResourceName

        Log.d(TAG, "Node: class=$className, text=$text, name=$name, id=$id")

        if ("Compose:Draft:Send" == name) {
            result.sendBtn = node
        }

        if ("com.google.android.apps.messaging:id/send_message_button_icon" == id) {
            result.sendBtn = node
        }

        if (text != null && (text.contains("RCS 聊天") || text.contains("RCS chat"))) {
            result.isRcsCapable = true
        }

        if (text != null && (text.contains("Turn on RCS chats") || text.contains("开启 RCS 聊天功能"))) {
            fun findSwitch(node: AccessibilityNodeInfo): Boolean {
                if ("com.google.android.apps.messaging:id/switchWidget" == node.viewIdResourceName) {
                    result.rcsSwitch = node
                    return true
                }
                for (i in 0 until node.childCount) {
                    val child = node.getChild(i)
                    if (findSwitch(child)) {
                        return true
                    }
                }
                return false
            }
            findSwitch(node.parent.parent)
        }

        if (node.childCount != 0) {
            for (i in 0 until node.childCount) {
                traverseNode(node.getChild(i), result)
            }
        }
    }

    @SuppressLint("ClickableViewAccessibility")
    override fun onServiceConnected() {
        super.onServiceConnected()

        instance = this

        val info = AccessibilityServiceInfo()
        info.flags =
            AccessibilityServiceInfo.DEFAULT or AccessibilityServiceInfo.FLAG_REPORT_VIEW_IDS
        info.eventTypes = AccessibilityEvent.TYPE_WINDOW_STATE_CHANGED
        info.feedbackType = AccessibilityServiceInfo.FEEDBACK_SPOKEN
        info.notificationTimeout = 100
        this.serviceInfo = info

        val displayMetrics = DisplayMetrics()
        val windowManager = getSystemService(WINDOW_SERVICE) as WindowManager
        windowManager.defaultDisplay.getMetrics(displayMetrics)
        val height = displayMetrics.heightPixels
        val width = displayMetrics.widthPixels

        val mLayout = FrameLayout(this)
        val layoutParams = WindowManager.LayoutParams()
        layoutParams.type = WindowManager.LayoutParams.TYPE_ACCESSIBILITY_OVERLAY
        layoutParams.format = PixelFormat.TRANSLUCENT
        layoutParams.flags = layoutParams.flags or WindowManager.LayoutParams.FLAG_NOT_FOCUSABLE
        layoutParams.flags = layoutParams.flags or WindowManager.LayoutParams.FLAG_KEEP_SCREEN_ON
        layoutParams.width = WindowManager.LayoutParams.WRAP_CONTENT
        layoutParams.height = WindowManager.LayoutParams.WRAP_CONTENT
        layoutParams.x = 0
        layoutParams.y = 800
        layoutParams.gravity = Gravity.START or Gravity.TOP

        val newContext = DynamicColors.wrapContextIfAvailable(applicationContext, R.style.AppTheme)
        val inflater = LayoutInflater.from(newContext)
        binding = FloatingWindowBinding.inflate(inflater, mLayout, true)
        binding.swSend.text = Global.name
        windowManager.addView(mLayout, layoutParams)

        val maxX = width - binding.root.measuredWidth
        val maxY = height - binding.root.measuredHeight
        val downX = AtomicReference(0f)
        val downY = AtomicReference(0f)
        val downParamX = AtomicReference(0)
        val downParamY = AtomicReference(0)

        var touchListener = OnTouchListener { v, event ->
            when (event.action) {
                MotionEvent.ACTION_DOWN -> {
                    downX.set(event.rawX)
                    downY.set(event.rawY)
                    downParamX.set(layoutParams.x)
                    downParamY.set(layoutParams.y)
                }

                MotionEvent.ACTION_MOVE -> {
                    layoutParams.x = min(
                        max((downParamX.get() + (event.rawX - downX.get())).toDouble(), 0.0),
                        maxX.toDouble()
                    )
                        .toInt()
                    layoutParams.y = min(
                        max((downParamY.get() + (event.rawY - downY.get())).toDouble(), 0.0),
                        maxY.toDouble()
                    )
                        .toInt()
                    windowManager.updateViewLayout(mLayout, layoutParams)
                }

                MotionEvent.ACTION_UP -> {
                    return@OnTouchListener event.eventTime - event.downTime >= 200
                }
            }
            false
        }

        binding.swSend.setOnTouchListener(touchListener)

        binding.swConnect.isChecked = true
        binding.swConnect.setOnCheckedChangeListener { buttonView: CompoundButton?, isChecked: Boolean ->
            if (isChecked) {
                connect()
            } else {
                if (this::mSocket.isInitialized) {
                    mSocket.disconnect()
                }
            }
        }

        binding.swSend.isChecked = canSend
        binding.swSend.setOnCheckedChangeListener { buttonView: CompoundButton?, isChecked: Boolean ->
            canSend = isChecked
        }

        logcat.observeForever {
            binding.tvLog.text = it
            binding.scroll.fullScroll(View.FOCUS_DOWN)
        }
        requesting.observeForever {
            binding.btnReq.isEnabled = !it
        }
        binding.btnReq.setOnClickListener {
            requestNumberCount = 6
            CoroutineScope(Dispatchers.IO).launch {
                requestNumber()
            }
        }
        binding.btnInspect.setOnClickListener {
            CoroutineScope(Dispatchers.IO).launch {
                traverseNode(rootInActiveWindow, TraverseResult())
            }
        }

        busy.observeForever {
            reportDeviceStatues()
        }
    }

    private fun reportDeviceStatues() {
        if (this::mSocket.isInitialized) {
            val data = JSONObject()
            try {
                data.put("action", "updateDevice")
                val dataObj = JSONObject()
                dataObj.put("canSend", canSend)
                dataObj.put("busy", busy.value)
                data.put("data", dataObj)
                mSocket.emit("message", data)
            } catch (e: JSONException) {
                e.printStackTrace()
            }
        }
    }

    private suspend fun requestNumber() {
        requesting.postValue(true)
        val result = withTimeoutOrNull(1.hours) {
            while (true) {
                withContext(Dispatchers.Main) {
                    binding.tvLog.text = "Waiting for logs..."
                }
                requestNumberCount++
                if (requestNumberCount > 5) {
                    requestNumberCount = 0

                    while (true) {
                        withContext(Dispatchers.Main) {
                            binding.tvLog.text = "Waiting for logs..."
                        }
                        rcsConfigureState.postValue(RcsConfigureState.NOT_CONFIGURED)
                        resetAll()
                        val switchAppear = withTimeoutOrNull(60.seconds) {
                            while (true) {
                                if (rcsConfigureState.value == RcsConfigureState.WAITING_FOR_DEFAULT_ON) {
                                    break
                                }
                                delay(1.seconds)
                            }
                            true
                        } ?: false
                        if (!switchAppear) {
                            Log.e(TAG, "RCS not entered default on state, retrying...")
                            continue
                        }
                        Utils.runAsRoot(
                            "am start com.google.android.apps.messaging/com.google.android.apps.messaging.ui.appsettings.RcsSettingsActivity",
                            "sleep 1"
                        )
                        val res = TraverseResult()
                        traverseNode(rootInActiveWindow, res)
                        if (res.rcsSwitch == null) {
                            Log.e(TAG, "RCS switch not found, retrying...")
                            continue
                        }
                        val rect = Rect()
                        res.rcsSwitch.getBoundsInScreen(rect)
                        Utils.runAsRoot(
                            "input tap ${rect.centerX()} ${rect.centerY()}",
                            "sleep 1",
                            "input keyevent KEYCODE_BACK",
                            "am start com.google.android.apps.messaging/com.google.android.apps.messaging.ui.appsettings.RcsSettingsActivity",
                        )
                        Log.i(TAG, "RCS switch turned on, waiting 60 seconds...")
                        delay(60000)
                        break
                    }

                }
                lateinit var rcsRes: RcsNumberResponse
                rcsConfigureState.postValue(RcsConfigureState.NOT_CONFIGURED)
                try {
                    val response = KtorClient.put(
                        RcsNumberApi()
                    ) {
                        contentType(ContentType.Application.Json)
                        setBody(
                            RcsNumberRequest(
                                deviceId = Utils.getUniqueID(),
                                taskId = currentTaskId
                            )
                        )
                    }
                    rcsRes = response.body<RcsNumberResponse>()
                    Log.i(TAG, "requestNumber response: $rcsRes")
                } catch (exception: Exception) {
                    exception.printStackTrace()
                    delay(2000)
                    continue
                }

                Global.save(
                    TelephonyConfig(
                        rcsRes.number,
                        rcsRes.mcc,
                        rcsRes.mnc,
                        RandomStringUtils.randomNumeric(20),
                        rcsRes.mcc + rcsRes.mnc + RandomStringUtils.randomNumeric(
                            15 - rcsRes.mcc.length - rcsRes.mnc.length
                        ),
                        Utils.generateIMEI(),
                        rcsRes.country
                    )
                )
                delay(1000)
                Utils.runAsRoot("am start -a android.intent.action.MAIN -c android.intent.category.LAUNCHER com.google.android.apps.messaging")
                delay(1000)
                Utils.runAsRoot(
                    "am start com.google.android.apps.messaging/com.google.android.apps.messaging.ui.appsettings.SettingsActivity",
                    "am start com.google.android.apps.messaging/com.google.android.apps.messaging.ui.appsettings.RcsSettingsActivity"
                )
                delay(1000)

                val waitingForOtp = withTimeoutOrNull(30000) {
                    repeat(1000) {
                        if (rcsConfigureState.value == RcsConfigureState.WAITING_FOR_OTP) {
                            return@repeat
                        }
                        delay(1000)
                    }
                    true
                } ?: false

                if (!waitingForOtp) {
                    Log.e(TAG, "RCS not entered waiting for OTP state, retrying...")
                    continue
                }

                withTimeoutOrNull(20000) {
                    while (true) {
                        try {
                            rcsRes = KtorClient.get(RcsNumberApi.Id(id = rcsRes.id))
                                .body<RcsNumberResponse>()
                            Log.i(TAG, "wait for otp response: $rcsRes")
                            if (rcsRes.status == RcsNumberResponse.STATUS_SUCCESS) {
                                break
                            }
                        } catch (exception: Exception) {
                            Log.e(TAG, "wait for otp Error: ${exception.stackTrace}")
                        }
                        delay(2000)
                    }
                }

                if (rcsRes.status != RcsNumberResponse.STATUS_SUCCESS) {
                    Log.e(TAG, "OTP not received, retrying...")
                    continue
                }

                val match =
                    Regex("Your Messenger verification code is G-(\\d{6})")
                        .matchEntire(rcsRes.message!!)
                if (match != null) {
                    val otp = match.groupValues[1]
                    Log.i(TAG, "OTP: $otp")
                    val intent = Intent()
                    intent.setAction("com.example.modifier.sms")
                    intent.putExtra("sender", "3538")
                    intent.putExtra(
                        "message",
                        "Your Messenger verification code is G-$otp"
                    )

                    suspend fun waitForConfigured(): Boolean {
                        sendBroadcast(intent)
                        val configured = withTimeoutOrNull(30.seconds) {
                            while (true) {
                                if (rcsConfigureState.value == RcsConfigureState.CONFIGURED) {
                                    break
                                }
                                delay(1000)
                            }
                            true
                        } ?: false
                        if (configured) {
                            return true
                        } else {
                            Log.e(TAG, "verifyOtp fail, retrying...")
                            return false
                        }
                    }

//                    suspendCancellableCoroutine<Unit> { continuation ->
//                        val observer = Observer<RcsConfigureState> { value ->
//                            if (value == expectedValue) {
//                                continuation.resume(Unit)
//                            }
//                        }
//
//                        observeForever(observer)
//
//                        continuation.invokeOnCancellation {
//                            removeObserver(observer)
//                        }
//                    }

                    val configured = run a@{
                        repeat(2) {
                            sendBroadcast(intent)
                            val configured = withTimeoutOrNull(30.seconds) {
                                while (true) {
                                    if (rcsConfigureState.value == RcsConfigureState.CONFIGURED) {
                                        break
                                    }
                                    delay(1000)
                                }
                                true
                            } ?: false
                            if (configured) {
                                return@a true
                            } else {
                                Log.e(TAG, "verifyOtp fail, retrying...")
                            }
                        }
                        false
                    }
                    if (!configured) {
                        Log.e(TAG, "RCS not configured, retrying...")
                        continue
                    } else {
                        break
                    }
                }
            }
            true
        } ?: false
        requesting.postValue(false)
        if (result) {
            sendCount = 0
            counter = 0
            Log.i(TAG, "requestNumber success")
        } else {
            Log.e(TAG, "requestNumber failed")
        }
    }
}