📱 Мобильные SDK

import com.instantbase.InstantBase
import com.instantbase.Configuration

class MyApp : Application() {
    
    override fun onCreate() {
        super.onCreate()
        
        // Базовая инициализация
        InstantBase.initialize(
            context = this,
            apiKey = "your_api_key",
            configuration = Configuration(
                environment = Environment.PRODUCTION,
                debug = BuildConfig.DEBUG,
                autoTrackScreen = true,
                autoTrackAppLifecycle = true,
                sessionTimeout = 30,
                maxBatchSize = 20,
                flushInterval = 10
            )
        )
        
        // Установка идентификатора пользователя
        val userId = getCurrentUserId()
        if (userId != null) {
            InstantBase.getInstance().identify(userId)
        }
    }
}

import com.android.billingclient.api.*
import com.instantbase.InstantBase

class BillingManager(private val context: Context) : PurchasesUpdatedListener {
    
    private val ib = InstantBase.getInstance()
    
    override fun onPurchasesUpdated(
        billingResult: BillingResult,
        purchases: MutableList?
    ) {
        if (billingResult.responseCode == BillingClient.BillingResponseCode.OK && purchases != null) {
            for (purchase in purchases) {
                handlePurchase(purchase)
            }
        }
    }
    
    private fun handlePurchase(purchase: Purchase) {
        // Отслеживаем покупку
        ib.track(
            event = "iap_purchase",
            properties = mapOf(
                "product_id" to purchase.products.first(),
                "purchase_token" to purchase.purchaseToken,
                "order_id" to purchase.orderId
            ),
            metadata = mapOf(
                "is_order" to true,
                "event_display_name" to "Покупка в приложении"
            )
        )
        
        // Обновляем атрибуты
        ib.identify(traits = mapOf(
            "last_purchase" to System.currentTimeMillis(),
            "total_purchases" to getPurchaseCount()
        ))
    }
}

import com.google.firebase.messaging.FirebaseMessagingService
import com.google.firebase.messaging.RemoteMessage
import com.instantbase.InstantBase

class MyFirebaseMessagingService : FirebaseMessagingService() {
    
    private val ib by lazy { InstantBase.getInstance() }
    
    override fun onMessageReceived(remoteMessage: RemoteMessage) {
        super.onMessageReceived(remoteMessage)
        
        // Пуш получен
        ib.track(
            event = "push_received",
            properties = mapOf(
                "campaign" to remoteMessage.messageId,
                "title" to (remoteMessage.notification?.title ?: ""),
                "category" to (remoteMessage.notification?.channelId ?: "")
            )
        )
        
        // Показать уведомление...
    }
    
    override fun onNewToken(token: String) {
        super.onNewToken(token)
        
        // Обновляем FCM токен в профиле
        ib.identify(traits = mapOf(
            "fcm_token" to token,
            "push_enabled" to true
        ))
    }
}

// В Activity при клике на уведомление
Intent intent = getIntent();
if (intent.getExtras() != null) {
    InstantBase.getInstance().track(
        "push_opened",
        mapOf("campaign" to intent.getStringExtra("message_id")),
        null
    );
}

import com.instantbase.InstantBase
import java.lang.Thread

class CustomExceptionHandler : Thread.UncaughtExceptionHandler {
    
    private val defaultHandler = Thread.getDefaultUncaughtExceptionHandler()
    private val ib = InstantBase.getInstance()
    
    override fun uncaughtException(t: Thread, e: Throwable) {
        // Отслеживаем краш
        ib.track(
            event = "crash",
            properties = mapOf(
                "exception" to e.javaClass.simpleName,
                "message" to (e.message ?: ""),
                "stacktrace" to e.stackTraceToString()
            ),
            metadata = mapOf(
                "event_display_name" to "Краш",
                "event_color" to "#dc3545"
            )
        )
        
        // Принудительная отправка
        ib.flush()
        
        // Вызываем стандартный обработчик
        defaultHandler?.uncaughtException(t, e)
    }
}

// В Application.onCreate()
Thread.setDefaultUncaughtExceptionHandler(CustomExceptionHandler())

import androidx.compose.runtime.*
import androidx.compose.ui.platform.LocalLifecycleOwner
import androidx.lifecycle.Lifecycle
import androidx.lifecycle.LifecycleEventObserver
import com.instantbase.InstantBase

@Composable
fun TrackScreen(
    screenName: String,
    screenTitle: String,
    properties: Map? = null
) {
    val lifecycleOwner = LocalLifecycleOwner.current
    val ib = InstantBase.getInstance()
    
    DisposableEffect(lifecycleOwner) {
        val observer = LifecycleEventObserver { _, event ->
            if (event == Lifecycle.Event.ON_RESUME) {
                ib.trackScreen(screenName, screenTitle, properties)
            }
        }
        lifecycleOwner.lifecycle.addObserver(observer)
        
        onDispose {
            lifecycleOwner.lifecycle.removeObserver(observer)
        }
    }
}

@Composable
fun ProductScreen(productId: String, productName: String) {
    TrackScreen(
        screenName = "ProductScreen",
        screenTitle = productName,
        properties = mapOf("product_id" to productId)
    )
    
    Column {
        Text(productName)
        Button(onClick = { 
            InstantBase.getInstance().track(
                event = "purchase",
                properties = mapOf(
                    "product_id" to productId,
                    "product_name" to productName
                ),
                metadata = mapOf("is_order" to true)
            )
        }) {
            Text("Купить")
        }
    }
}

// SDK использует Room для локального хранения
// События автоматически сохраняются при отсутствии сети

// Проверка статуса
val isOffline = ib.isOffline
val unsentCount = ib.getUnsentEventsCount()

// Принудительная отправка
ib.flush()

// Ручное управление
ib.setOffline(true)  // перейти в оффлайн
ib.setOffline(false) // выйти из оффлайна

// Слушатель сети
val connectivityManager = getSystemService(Context.CONNECTIVITY_SERVICE) as ConnectivityManager
connectivityManager.registerNetworkCallback(
    NetworkRequest.Builder().build(),
    object : ConnectivityManager.NetworkCallback() {
        override fun onAvailable(network: Network) {
            ib.setOffline(false)
            ib.flush()
        }
        
        override fun onLost(network: Network) {
            ib.setOffline(true)
        }
    }
)