diff --git a/app/src/main/java/com/adamaps/varroa/api/AdaMapsApiClient.kt b/app/src/main/java/com/adamaps/varroa/api/AdaMapsApiClient.kt
index 928e81d..a06c8a1 100644
--- a/app/src/main/java/com/adamaps/varroa/api/AdaMapsApiClient.kt
+++ b/app/src/main/java/com/adamaps/varroa/api/AdaMapsApiClient.kt
@@ -53,9 +53,10 @@ class AdaMapsApiClient(
         apiKey = key
     }
 
-    suspend fun ingest(request: AdaMapsIngestRequest): ApiResult<String> = withContext(Dispatchers.IO) {
+    suspend fun ingest(detections: AdaMapsIngestRequest): ApiResult<String> = withContext(Dispatchers.IO) {
         try {
-            val body = gson.toJson(request).toRequestBody(json)
+            // Server expects flat array of detections, each with device_id
+            val body = gson.toJson(detections).toRequestBody(json)
             val req = Request.Builder()
                 .url("$apiUrl/api/ingest")
                 .addHeader("X-MapNet-Key", apiKey)
diff --git a/app/src/main/java/com/adamaps/varroa/data/Models.kt b/app/src/main/java/com/adamaps/varroa/data/Models.kt
index 171d682..0d17789 100644
--- a/app/src/main/java/com/adamaps/varroa/data/Models.kt
+++ b/app/src/main/java/com/adamaps/varroa/data/Models.kt
@@ -49,6 +49,7 @@ data class BeeDeviceInfo(
 // ── ADAMaps ingest ────────────────────────────────────────────────────────────
 
 data class AdaMapsDetection(
+    @SerializedName("device_id") val deviceId: String,
     @SerializedName("id") val id: Long,
     @SerializedName("class_label") val classLabel: String?,
     @SerializedName("class_label_confidence") val classLabelConfidence: Double?,
@@ -63,12 +64,12 @@ data class AdaMapsDetection(
     @SerializedName("azimuth") val azimuth: Double?
 )
 
-data class AdaMapsIngestRequest(
-    @SerializedName("device_id") val deviceId: String,
-    @SerializedName("detections") val detections: List<AdaMapsDetection>
-)
+// Server expects flat array of detections, each with device_id
+// (NOT nested {device_id, detections: [...]})
+typealias AdaMapsIngestRequest = List<AdaMapsDetection>
 
-fun BeeDetection.toAdaMapsDetection() = AdaMapsDetection(
+fun BeeDetection.toAdaMapsDetection(deviceId: String) = AdaMapsDetection(
+    deviceId = deviceId,
     id = id,
     classLabel = classLabel,
     classLabelConfidence = classLabelConfidence,
diff --git a/app/src/main/java/com/adamaps/varroa/service/ForwardingService.kt b/app/src/main/java/com/adamaps/varroa/service/ForwardingService.kt
index ee67494..a3b2d1e 100644
--- a/app/src/main/java/com/adamaps/varroa/service/ForwardingService.kt
+++ b/app/src/main/java/com/adamaps/varroa/service/ForwardingService.kt
@@ -14,7 +14,7 @@ import com.adamaps.varroa.MainActivity
 import com.adamaps.varroa.R
 import com.adamaps.varroa.api.AdaMapsApiClient
 import com.adamaps.varroa.api.BeeApiClient
-import com.adamaps.varroa.data.AdaMapsIngestRequest
+import com.adamaps.varroa.data.AdaMapsDetection
 import com.adamaps.varroa.data.ApiResult
 import com.adamaps.varroa.data.BeeDetection
 import com.adamaps.varroa.data.SessionStats
@@ -241,15 +241,14 @@ class ForwardingService : LifecycleService() {
     private suspend fun sendToADAMaps(detections: List<BeeDetection>) {
         // Get device ID from device info (best effort)
         val deviceId = try {
-            (beeClient.getDeviceInfo() as? ApiResult.Success)?.data?.deviceId
-                ?: (beeClient.getDeviceInfo() as? ApiResult.Success)?.data?.serial
+            val info = beeClient.getDeviceInfo()
+            (info as? ApiResult.Success)?.data?.deviceId
+                ?: (info as? ApiResult.Success)?.data?.serial
                 ?: "unknown"
         } catch (e: Exception) { "unknown" }
 
-        val request = AdaMapsIngestRequest(
-            deviceId = deviceId,
-            detections = detections.map { it.toAdaMapsDetection() }
-        )
+        // Server expects flat array of detections, each with device_id embedded
+        val request = detections.map { it.toAdaMapsDetection(deviceId) }
 
         _stats.update { it.copy(queued = it.queued + detections.size) }
 
@@ -277,10 +276,8 @@ class ForwardingService : LifecycleService() {
         }
 
         for (item in toRetry) {
-            val request = AdaMapsIngestRequest(
-                deviceId = item.deviceId,
-                detections = item.detections.map { it.toAdaMapsDetection() }
-            )
+            // Server expects flat array of detections, each with device_id embedded
+            val request = item.detections.map { it.toAdaMapsDetection(item.deviceId) }
 
             when (val result = adamapsClient.ingest(request)) {
                 is ApiResult.Success -> {