package com.sfourdrinier.unifiedblemanager

import org.junit.Assert.assertTrue
import org.junit.Test
import java.io.File

class BlePlxForegroundServiceLifecycleTest {
  @Test
  fun `persists caller session intent before foreground promotion and start acknowledgement`() {
    val source = readAndroidSource(
      "android/src/main/java/com/sfourdrinier/unifiedblemanager/BlePlxForegroundService.java"
    )
    val preferenceWrite = source.indexOf(
      ".putBoolean(SESSION_INTENT_PREFERENCE, configuration.restartWhileSessionIntentExists())"
    )
    val foregroundPromotion = source.indexOf("startForeground(")
    val startedAcknowledgement = source.indexOf("acknowledge(intent, ACK_STARTED")

    assertTrue(preferenceWrite >= 0)
    assertTrue(preferenceWrite < foregroundPromotion)
    assertTrue(preferenceWrite < startedAcknowledgement)
    assertTrue(
      source.substring(preferenceWrite, foregroundPromotion).contains(".commit()")
    )
  }

  @Test
  fun `failed foreground start clears the persisted session intent`() {
    val source = readAndroidSource(
      "android/src/main/java/com/sfourdrinier/unifiedblemanager/BlePlxForegroundService.java"
    )
    val failure = source.substring(source.indexOf("} catch (RuntimeException error)"))

    assertTrue(
      failure.contains(
        ".putBoolean(SESSION_INTENT_PREFERENCE, false)"
      )
    )
  }

  @Test
  fun `stop durably clears the session intent before requesting service stop`() {
    val source = readAndroidSource(
      "android/src/main/java/com/sfourdrinier/unifiedblemanager/background/AndroidConnectedDeviceForegroundServiceDriver.java"
    )
    val stop = source.substring(
      source.indexOf("public void stop()"),
      source.indexOf("private ForegroundServiceNotificationConfiguration configuration()")
    )
    val preferenceWrite = stop.indexOf(
      ".putBoolean(BlePlxForegroundService.SESSION_INTENT_PREFERENCE, false)"
    )
    val serviceStop = stop.indexOf("context.stopService")

    assertTrue(preferenceWrite >= 0)
    assertTrue(preferenceWrite < serviceStop)
    assertTrue(stop.substring(preferenceWrite, serviceStop).contains(".commit()"))
    assertTrue(!stop.substring(preferenceWrite, serviceStop).contains(".apply()"))
  }

  @Test
  fun `timeout cleanup durably clears the session intent before requesting service stop`() {
    val source = readAndroidSource(
      "android/src/main/java/com/sfourdrinier/unifiedblemanager/background/AndroidConnectedDeviceForegroundServiceDriver.java"
    )
    val timeoutStart = source.indexOf("if (!acknowledgement.await")
    val serviceStop = source.indexOf("context.stopService", timeoutStart)
    val timeout = source.substring(timeoutStart, serviceStop)
    val preferenceWrite = timeout.indexOf(
      ".putBoolean(BlePlxForegroundService.SESSION_INTENT_PREFERENCE, false)"
    )
    assertTrue(preferenceWrite >= 0)
    assertTrue(timeout.contains(".commit()"))
    assertTrue(!timeout.contains(".apply()"))
  }

  @Test
  fun `foreground acquisition fails before waiting when invoked on the main thread`() {
    val source = readAndroidSource(
      "android/src/main/java/com/sfourdrinier/unifiedblemanager/background/AndroidConnectedDeviceForegroundServiceDriver.java"
    )
    val mainThreadGuard = source.indexOf("Looper.myLooper() == Looper.getMainLooper()")
    val wait = source.indexOf("acknowledgement.await")

    assertTrue(mainThreadGuard >= 0)
    assertTrue(mainThreadGuard < wait)
    assertTrue(source.contains("foregroundServiceMainThreadUnavailable"))
  }

  @Test
  fun `start failure cleanup checks its synchronous session intent commit`() {
    val source = readAndroidSource(
      "android/src/main/java/com/sfourdrinier/unifiedblemanager/BlePlxForegroundService.java"
    )
    val failure = source.substring(source.indexOf("} catch (RuntimeException error)"))

    assertTrue(failure.contains("if (!getSharedPreferences"))
    assertTrue(failure.contains(".putBoolean(SESSION_INTENT_PREFERENCE, false)"))
    assertTrue(failure.contains(".commit())"))
    assertTrue(!failure.contains(".apply()"))
  }

  @Test
  fun `ack receiver uses typed parcelable retrieval on API 33 and a guarded legacy path`() {
    val source = readAndroidSource(
      "android/src/main/java/com/sfourdrinier/unifiedblemanager/BlePlxForegroundService.java"
    )
    val acknowledgement = source.substring(source.indexOf("private void acknowledge"))

    assertTrue(acknowledgement.contains("Build.VERSION.SDK_INT >= Build.VERSION_CODES.TIRAMISU"))
    assertTrue(
      acknowledgement.contains(
        "intent.getParcelableExtra(EXTRA_ACK, ResultReceiver.class)"
      )
    )
    assertTrue(acknowledgement.contains("intent.getParcelableExtra(EXTRA_ACK);"))
  }

  @Test
  fun `caller restart policy remains the service restart policy`() {
    val source = readAndroidSource(
      "android/src/main/java/com/sfourdrinier/unifiedblemanager/BlePlxForegroundService.java"
    )

    assertTrue(
      source.contains(
        "return configuration.restartWhileSessionIntentExists() ? START_STICKY : START_NOT_STICKY;"
      )
    )
  }

  @Test
  fun `foreground readiness wakes recovery only after promotion and only in the host app`() {
    val source = readAndroidSource(
      "android/src/main/java/com/sfourdrinier/unifiedblemanager/BlePlxForegroundService.java"
    )
    val foregroundPromotion = source.indexOf("startForeground(")
    val readinessSignal = source.indexOf("sendBroadcast(new Intent(ACTION_FOREGROUND_READY)")
    val startedAcknowledgement = source.indexOf("acknowledge(intent, ACK_STARTED")

    assertTrue(foregroundPromotion >= 0)
    assertTrue(foregroundPromotion < startedAcknowledgement)
    assertTrue(startedAcknowledgement < readinessSignal)
    assertTrue(
      source.substring(startedAcknowledgement, readinessSignal)
        .contains("intent == null || !intent.hasExtra(EXTRA_ACK)")
    )
    assertTrue(
      source.substring(readinessSignal)
        .contains(".setPackage(getPackageName())")
    )
  }

  @Test
  fun `notification updates reuse the UBM id and shared builder without changing service semantics`() {
    val source = readAndroidSource(
      "android/src/main/java/com/sfourdrinier/unifiedblemanager/BlePlxForegroundService.java"
    )
    assertTrue(source.contains("manager.notify(ForegroundServiceNotificationConfiguration.NOTIFICATION_ID"))
    assertTrue(source.contains("service.buildNotification(service.activeConfiguration)"))
    assertTrue(source.contains(".setContentIntent(contentIntent)"))
    assertTrue(source.contains(".setOngoing(true)"))
    assertTrue(source.contains("FOREGROUND_SERVICE_TYPE_CONNECTED_DEVICE"))
  }

  @Test
  fun `lifecycle recovery starts only the configured service when native session intent exists`() {
    val source = readAndroidSource(
      "android/src/main/java/com/sfourdrinier/unifiedblemanager/background/BlePlxForegroundServiceRecoveryReceiver.java"
    )
    assertTrue(source.contains("SESSION_INTENT_PREFERENCE"))
    assertTrue(source.contains("startForegroundService(start)"))
    assertTrue(source.contains("ACTION_BOOT_COMPLETED"))
    assertTrue(source.contains("ACTION_MY_PACKAGE_REPLACED"))
    assertTrue(!source.contains("BluetoothAdapter"))
    assertTrue(!source.contains("scan("))
    assertTrue(!source.contains("reconnect("))
  }

  @Test
  fun `bond receiver uses the API safe typed parcelable helper on min sdk 24`() {
    val source = readAndroidSource(
      "android/src/main/java/com/sfourdrinier/unifiedblemanager/radio/OwnedAndroidGattRadio.kt"
    )
    val receiver = source.substring(
      source.indexOf("internal fun registerBondStateReceiver()"),
      source.indexOf("internal fun unregisterBondStateReceiver()")
    )

    assertTrue(source.contains("import androidx.core.content.IntentCompat"))
    assertTrue(
      receiver.contains("IntentCompat.getParcelableExtra(")
    )
    assertTrue(receiver.contains("BluetoothDevice.EXTRA_DEVICE"))
    assertTrue(receiver.contains("BluetoothDevice::class.java"))
    assertTrue(!receiver.contains("getParcelableExtra<BluetoothDevice>"))
    assertTrue(!receiver.contains("intent.getParcelableExtra(BluetoothDevice.EXTRA_DEVICE)"))
  }

  private fun readAndroidSource(relativePath: String): String {
    val candidates = listOf(
      File(relativePath),
      File("../$relativePath"),
      File("../../$relativePath"),
      File("../../../$relativePath")
    )
    return candidates.firstOrNull { it.isFile }?.readText()
      ?: throw AssertionError("Unable to locate Android source guard target: $relativePath")
  }
}