// SmsReceiver.kt - Android Background Gateway
package com.autopay.smsgateway

import android.content.BroadcastReceiver
import android.content.Context
import android.content.Intent
import android.provider.Telephony
import okhttp3.*
import okhttp3.MediaType.Companion.toMediaType
import okhttp3.RequestBody.Companion.toRequestBody
import org.json.JSONObject

class SmsReceiver : BroadcastReceiver() {
    private val client = OkHttpClient()
    private val WEBHOOK_URL = "https://www.autopay.snitpoint.com/webhook.php"
    private val SECRET_TOKEN = "sec_bd_autopay_99x88z77"

    override fun onReceive(context: Context, intent: Intent) {
        if (intent.action == Telephony.Sms.Intents.SMS_RECEIVED_ACTION) {
            val messages = Telephony.Sms.Intents.getMessagesFromIntent(intent)
            for (sms in messages) {
                val sender = sms.displayOriginatingAddress ?: ""
                val body = sms.displayMessageBody ?: ""
                val slot = intent.extras?.getInt("slot", 1) ?: 1

                if (isPaymentSms(sender, body)) {
                    forwardToServer(body, sender, slot)
                }
            }
        }
    }

    private fun isPaymentSms(sender: String, body: String): Boolean {
        val s = sender.lowercase()
        val b = body.lowercase()
        return s.contains("bkash") || s.contains("nagad") || s.contains("rocket") ||
               b.contains("trxid") || b.contains("received tk") || b.contains("cash in")
    }

    private fun forwardToServer(smsBody: String, sender: String, simSlot: Int) {
        val json = JSONObject().apply {
            put("sms", smsBody)
            put("sender", sender)
            put("simSlot", simSlot)
            put("secretToken", SECRET_TOKEN)
        }
        val requestBody = json.toString().toRequestBody("application/json; charset=utf-8".toMediaType())
        val request = Request.Builder().url(WEBHOOK_URL).post(requestBody).build()
        client.newCall(request).enqueue(object : Callback {
            override fun onFailure(call: Call, e: java.io.IOException) {}
            override fun onResponse(call: Call, response: Response) { response.close() }
        })
    }
}