XuqmGroup-AndroidSDK/sdk-bugcollect/src/main/java/com/xuqm/sdk/bugcollect/BugCollect.kt

package com.xuqm.sdk.bugcollect

import android.app.ActivityManager
import android.content.Context
import android.content.pm.ApplicationInfo
import android.os.Build
import com.xuqm.sdk.XuqmSDK
import java.util.LinkedList

object BugCollect {

    private var logLevel: LogLevel = LogLevel.WARN
    private var environment: String = "production"
    @Volatile private var queue: LogQueue? = null
    @Volatile private var crashCaptureStarted = false

    private val breadcrumbBuffer: LinkedList<Breadcrumb> = LinkedList()
    private val breadcrumbLock = Any()
    private const val MAX_BREADCRUMBS = 50
    private const val SDK_NAME = "bugcollect.android"
    private const val SDK_VERSION = "1.1.0"

    fun setLogLevel(level: LogLevel) { logLevel = level }
    fun setEnvironment(env: String) { environment = env }

    fun addBreadcrumb(
        category: String,
        message: String,
        level: String = "info",
        data: Map<String, Any?> = emptyMap(),
    ) {
        synchronized(breadcrumbLock) {
            if (breadcrumbBuffer.size >= MAX_BREADCRUMBS) breadcrumbBuffer.removeFirst()
            breadcrumbBuffer.addLast(Breadcrumb(
                timestamp = System.currentTimeMillis(),
                category = category,
                message = message,
                level = level,
                data = data,
            ))
        }
    }

    fun event(name: String, properties: Map<String, Any?> = emptyMap()) {
        if (!isReady()) return
        queue().push(LogEvent(
            name = name, properties = properties,
            appKey = XuqmSDK.appKey, userId = XuqmSDK.getUserId(),
            platform = "android", release = appVersion(), environment = environment,
            sdk = IssueEvent.SdkInfo(SDK_NAME, SDK_VERSION),
        ))
        FunnelTracker.track(name, properties)
    }

    fun captureError(error: Throwable, tags: Map<String, Any?> = emptyMap(), fingerprint: String? = null) {
        if (!isReady()) return
        val crumbs = synchronized(breadcrumbLock) { breadcrumbBuffer.toList() }
        val fp = fingerprint ?: Fingerprint.compute(
            error.javaClass.simpleName,
            error.message ?: error.javaClass.name,
            error.stackTraceToString(),
        )
        queue().push(IssueEvent(
            level = "error",
            platform = "android",
            fingerprint = fp,
            appKey = XuqmSDK.appKey,
            exception = IssueEvent.ExceptionInfo(
                type = error.javaClass.simpleName,
                value = error.message ?: error.javaClass.name,
                stacktrace = error.stackTraceToString(),
            ),
            breadcrumbs = crumbs,
            release = appVersion(),
            environment = environment,
            userId = XuqmSDK.getUserId(),
            user = IssueEvent.UserInfo(id = XuqmSDK.getUserId()),
            device = buildDeviceInfo(),
            tags = tags,
        ))
    }

    fun captureCrash(error: Throwable, tags: Map<String, Any?> = emptyMap()) {
        if (!isReady()) return
        val crumbs = synchronized(breadcrumbLock) { breadcrumbBuffer.toList() }
        queue().push(IssueEvent(
            level = "fatal",
            platform = "android",
            fingerprint = Fingerprint.compute(
                error.javaClass.simpleName,
                error.message ?: error.javaClass.name,
                error.stackTraceToString(),
            ),
            appKey = XuqmSDK.appKey,
            exception = IssueEvent.ExceptionInfo(
                type = error.javaClass.simpleName,
                value = error.message ?: error.javaClass.name,
                stacktrace = error.stackTraceToString(),
            ),
            breadcrumbs = crumbs,
            release = appVersion(),
            environment = environment,
            userId = XuqmSDK.getUserId(),
            user = IssueEvent.UserInfo(id = XuqmSDK.getUserId()),
            device = buildDeviceInfo(),
            tags = tags,
        ))
    }

    fun warn(message: String, tags: Map<String, Any?> = emptyMap()) {
        if (logLevel.ordinal > LogLevel.WARN.ordinal) return
        if (!isReady()) return
        queue().push(IssueEvent(
            level = "warning",
            platform = "android",
            fingerprint = Fingerprint.compute("Warning", message, ""),
            appKey = XuqmSDK.appKey,
            exception = IssueEvent.ExceptionInfo(type = "Warning", value = message),
            release = appVersion(),
            environment = environment,
            userId = XuqmSDK.getUserId(),
            user = IssueEvent.UserInfo(id = XuqmSDK.getUserId()),
            tags = tags,
        ))
    }

    fun info(message: String, tags: Map<String, Any?> = emptyMap()) {
        if (logLevel.ordinal > LogLevel.INFO.ordinal) return
        event("__log_info", tags + ("message" to message))
    }

    fun startCrashCapture() {
        if (crashCaptureStarted) return
        if (!XuqmSDK.isInitialized()) return
        // bugCollectApiUrl 由远端配置下发，启动时可能尚未到达。
        // 用 platformUrl 推导兜底地址：崩溃文件里会保存此 URL，下次启动时用它上报。
        val logApiUrl = XuqmSDK.bugCollectApiUrl
            ?: (XuqmSDK.platformUrl.trimEnd('/') + "/api/bugcollect/")
        crashCaptureStarted = true
        CrashCapture.start(
            appContext = XuqmSDK.appContext,
            logApiUrl = logApiUrl,
            appKey = XuqmSDK.appKey,
            getUserId = { XuqmSDK.getUserId() },
        )
        queue().uploadPendingCrashes()
    }

    fun defineFunnel(id: String, steps: List<String>) {
        FunnelTracker.define(id, steps)
    }

    private fun isReady() = XuqmSDK.isInitialized() && XuqmSDK.bugCollectEnabled

    private fun queue(): LogQueue {
        return queue ?: synchronized(this) {
            queue ?: LogQueue(
                logApiUrl = XuqmSDK.bugCollectApiUrl ?: "",
                appKey = XuqmSDK.appKey,
                appContext = XuqmSDK.appContext,
            ).also { queue = it }
        }
    }

    private fun appVersion(): String = runCatching {
        val ctx = XuqmSDK.appContext
        ctx.packageManager.getPackageInfo(ctx.packageName, 0).versionName ?: "unknown"
    }.getOrDefault("unknown")

    private fun buildDeviceInfo(): IssueEvent.DeviceInfo {
        val ctx = XuqmSDK.appContext
        val actMgr = ctx.getSystemService(Context.ACTIVITY_SERVICE) as? ActivityManager
        val memInfo = ActivityManager.MemoryInfo().also { actMgr?.getMemoryInfo(it) }
        val freeMemMb = (memInfo.availMem / (1024L * 1024L)).toInt()
        val isDebug = ctx.applicationInfo.flags and ApplicationInfo.FLAG_DEBUGGABLE != 0
        val isEmulator = Build.FINGERPRINT.startsWith("generic")
            || Build.FINGERPRINT.startsWith("unknown")
            || Build.MODEL.contains("Emulator", ignoreCase = true)
            || Build.MODEL.contains("Android SDK", ignoreCase = true)

        return IssueEvent.DeviceInfo(
            model = Build.MODEL,
            manufacturer = Build.MANUFACTURER,
            osName = "Android",
            osVersion = Build.VERSION.RELEASE,
            locale = java.util.Locale.getDefault().toString(),
            timezone = java.util.TimeZone.getDefault().id,
            isEmulator = isEmulator,
            freeMemoryMb = freeMemMb,
            buildType = if (isDebug) "debug" else "release",
        )
    }
}