@@ -19,8 +19,12 @@ migrate_working_dir/
 *_OLD*
 *_BACKUP*
 
+# Gemini
+GEMINI.md
+
 # Claude Code
 .claude/
+CLAUDE.md
 
 # IntelliJ related
 *.iml
@@ -63,3 +67,5 @@ SPM_ANALYSIS.md
 # (dart pub uses a custom gitignore parser that may differ from git's behaviour)
 !ios/native_workmanager/Package.resolved
 !ios/native_workmanager/Sources/native_workmanager/utils/HttpSecurityHelper.swift
+\ndoc/internal/
+benchmark/
@@ -7,6 +7,17 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ---
 
+## [1.2.0] - 2026-04-17
+
+### Added
+- **Android cold-start `DartWorker` persistence**: `DartWorker` tasks now execute reliably after app kill. The `callbackHandle` is persisted to `SharedPreferences` (Android) and `UserDefaults` (iOS) during `initialize()` and automatically restored when WorkManager restarts the process. Requires host app to implement `Configuration.Provider` — see `doc/ANDROID_SETUP.md`.
+- **Advanced Remote Trigger**: Support for direct commands in push payloads (`native_wm` key). Execute tasks, chains (`enqueue_chain`), graphs, and offline queues without waking Flutter. Both Android and iOS support executing task chains completely in the background.
+- **HMAC Security**: Robust HMAC SHA-256 signature verification for remote triggers (supporting nested objects) to prevent unauthorized task execution.
+- **Real-time Observability**: DevTools extension now supports real-time event streaming via `developer.postEvent`.
+- **Global Middleware API**: Global interceptors for task configuration (Headers, RemoteConfig, Logging).
+- **Code Generation Enhancements**: `native_workmanager_gen` now generates type-safe enqueue wrappers and automatic worker registries from `@WorkerCallback` annotations.
+- **Task Graphs (DAG)**: Support for complex non-linear task dependencies on Android.
+
 ## [1.1.2] - 2026-04-14
 
 ### Added
@@ -865,7 +876,7 @@ Built on [kmpworkmanager v2.3.9](https://github.com/pablichjenkov/kmpworkmanager
 
 ---
 
-**Latest Version:** 1.1.2
+**Latest Version:** 1.2.0
 **Status:**  Production Ready - Stable release for all production apps
 **KMP Parity:** 100%  (kmpworkmanager v2.3.9)
 **Platforms:** Android  | iOS 
@@ -15,7 +15,7 @@
   <a href="https://github.com/brewkits/native_workmanager/actions"><img src="https://github.com/brewkits/native_workmanager/workflows/ci/badge.svg" alt="CI"></a>
   <a href="https://opensource.org/licenses/MIT"><img src="https://img.shields.io/badge/License-MIT-blue.svg" alt="MIT"></a>
   <img src="https://img.shields.io/badge/Android-8.0%2B-brightgreen.svg" alt="Android 8.0+">
-  <img src="https://img.shields.io/badge/iOS-14.0%2B-lightgrey.svg" alt="iOS 14.0+">
+  <img src="https://img.shields.io/badge/iOS-13.0%2B-lightgrey.svg" alt="iOS 13.0+">
 </p>
 
 ---
@@ -46,7 +46,7 @@ No boilerplate. No native code to write. No `AndroidManifest.xml` changes. Each
 
 ```yaml
 dependencies:
-  native_workmanager: ^1.1.2
+  native_workmanager: ^1.2.0
 ```
 
 **2. Initialize once in `main()`:**
@@ -93,6 +93,7 @@ The dominant `workmanager` plugin spins up a **full Flutter Engine per backgroun
 | Task chains (A→B→C) | ❌ | ✅ (persist across reboots) |
 | Per-task progress stream | ❌ | ✅ |
 | Survives device reboot | ✅ | ✅ |
+| Remote Trigger (Push) | ❌ | ✅ (FCM/APNs + HMAC Security) |
 | Custom Dart workers | ✅ | ✅ (opt-in via `DartWorker`) |
 
 > **If you only do HTTP syncs and file ops, you probably don't need Dart workers at all.** Use the native workers directly — they're production-hardened and need zero engine overhead.
@@ -206,6 +207,19 @@ await NativeWorkManager.enqueue(
 
 Dart workers boot a headless Flutter isolate (~50 MB, 1–2 s cold start). The isolate is cached for 5 minutes so back-to-back tasks pay the boot cost only once. For HTTP and file tasks, use native workers instead.
 
+> **Android killed-app support** — When Android kills your app and WorkManager later fires a `DartWorker`, the process restarts without Flutter. The plugin automatically restores the `callbackHandle` from `SharedPreferences`, but your `Application` class must implement `Configuration.Provider` so WorkManager uses the plugin's `WorkerFactory`. One-time setup — see **[Android Setup Guide](doc/ANDROID_SETUP.md)**.
+
+### Code generation for DartWorker
+
+The companion [`native_workmanager_gen`](https://pub.dev/packages/native_workmanager_gen) package generates type-safe callback IDs and a worker registry from `@WorkerCallback` annotations, eliminating string-based registration and magic IDs:
+
+```dart
+@WorkerCallback('health-sync')
+Future<bool> syncHealthData(Map<String, dynamic>? input) async { ... }
+
+// Generated: WorkerCallbacks.healthSync, auto-registered in WorkerRegistry
+```
+
 ---
 
 ## Platform Support
@@ -345,14 +359,15 @@ NativeWorkManager.events.listen((event) {
 
 ## Documentation
 
-| Guide | |
+| Guide | Description |
 |---|---|
 | [Getting Started](doc/GETTING_STARTED.md) | Full setup walkthrough |
 | [API Reference](doc/API_REFERENCE.md) | All public types and methods |
-| [Migration from workmanager](doc/MIGRATION_GUIDE.md) | Switch in under 10 minutes |
+| [Android Setup Guide](doc/ANDROID_SETUP.md) | DartWorker killed-app persistence |
 | [iOS Setup Guide](doc/IOS_SETUP_GUIDE.md) | BGTaskScheduler details |
-| [Architecture](doc/ARCHITECTURE_ANALYSIS.md) | How zero-engine execution works |
+| [Migration from workmanager](doc/MIGRATION_GUIDE.md) | Switch in under 10 minutes |
 | [Security](doc/SECURITY.md) | SSRF, path traversal, data redaction |
+| [native_workmanager_gen](https://pub.dev/packages/native_workmanager_gen) | Code generator for type-safe DartWorker callbacks |
 
 ---
 
 
@@ -22,7 +22,7 @@ Our mission is to provide the most robust, efficient, and secure background exec
 - [ ] **Offline Queue Pattern:** Built-in pattern for queuing tasks while offline with automatic file/database-backed retry.
 - [ ] **Middleware / Decorator API:** Intercept task execution for custom logging, analytics, or global headers.
 
-[Read the detailed Phase 2 Architectural Proposals →](doc/PHASE_2_PROPOSALS.md)
+[Phase 2 Architectural Proposals available in internal documentation]
 
 ---
 
 
@@ -1,5 +1,5 @@
 group = "dev.brewkits.native_workmanager"
-version = "1.1.2"
+version = "1.2.0"
 
 apply plugin: "com.android.library"
 apply plugin: "kotlin-android"
 
@@ -26,66 +26,17 @@ internal fun NativeWorkmanagerPlugin.handleEnqueueChain(call: MethodCall, result
             @Suppress("UNCHECKED_CAST")
             val steps = call.argument<List<List<Map<String, Any?>>>>("steps") ?: emptyList()
 
-            if (steps.isEmpty() || steps[0].isEmpty()) {
-                return@launch result.error("CHAIN_ERROR", "Chain must have at least one task", null)
-            }
-
-            val chainId = "${chainName}_${java.util.UUID.randomUUID()}"
-            val workManager = WorkManager.getInstance(context)
-            val allTaskIds = mutableListOf<String>()
-
-            // Build OneTimeWorkRequest for each step tagged with its task ID.
-            val stepWorkRequests: List<List<OneTimeWorkRequest>> = steps.mapIndexed { stepIndex, parallelTasks ->
-                @Suppress("UNCHECKED_CAST")
-                (parallelTasks as List<Map<String, Any?>>).map { taskData ->
-                    val taskId = taskData["id"] as? String ?: java.util.UUID.randomUUID().toString()
-                    allTaskIds.add(taskId)
-                    
-                    val workerClassName = taskData["workerClassName"] as? String ?: ""
-                    @Suppress("UNCHECKED_CAST")
-                    val workerConfig = taskData["workerConfig"] as? Map<String, Any?>
-                    
-                    // Persist each step to ChainStore for resume and Dart visibility.
-                    withContext(Dispatchers.IO) {
-                        chainStore.addChainStep(chainId, stepIndex, taskId, "pending")
-                        
-                        // Also persist to TaskStore so allTasks() surfaces chain nodes
-                        taskStore.upsert(
-                            taskId = taskId,
-                            tag = chainName,
-                            status = "pending",
-                            workerClassName = workerClassName,
-                            workerConfig = if (workerConfig != null) sanitizeConfig(toJson(workerConfig)) else null
-                        )
-                    }
-                    buildChainStepRequest(taskId, taskData)
+            dev.brewkits.native_workmanager.utils.ChainHelper.enqueueChain(
+                context = context,
+                taskStore = taskStore,
+                chainStore = chainStore,
+                chainName = chainName,
+                steps = steps,
+                onObserveTaskId = { taskId ->
+                    taskStatuses[taskId] = "pending"
+                    observeChainStepCompletion(taskId, chainId = null) // We pass null because ChainHelper already handled ChainStore persistence
                 }
-            }
-
-            // Persist chain header BEFORE enqueuing (so resume can find it even if killed immediately).
-            withContext(Dispatchers.IO) {
-                chainStore.upsertChain(
-                    chainId = chainId,
-                    chainName = chainName,
-                    totalSteps = steps.size,
-                    status = "running"
-                )
-            }
-
-            // Enqueue as a WorkManager chain.
-            var continuation = workManager.beginWith(stepWorkRequests[0])
-            for (i in 1 until stepWorkRequests.size) {
-                continuation = continuation.then(stepWorkRequests[i])
-            }
-            continuation.enqueue()
-
-            NativeLogger.d("✅ Chain scheduled: $chainName/$chainId (${steps.size} steps), IDs: $allTaskIds")
-
-            // Observe each chain step by its task-ID tag and emit events on completion.
-            for (taskId in allTaskIds) {
-                taskStatuses[taskId] = "pending"
-                observeChainStepCompletion(taskId, chainId = chainId)
-            }
+            )
 
             result.success("ACCEPTED")
         } catch (e: Exception) {
@@ -121,57 +72,6 @@ internal suspend fun NativeWorkmanagerPlugin.resumePendingChains() {
     }
 }
 
-/**
- * Build a OneTimeWorkRequest for a single chain step.
- * The task ID is added as a WorkManager tag so we can observe by tag later.
- */
-internal fun NativeWorkmanagerPlugin.buildChainStepRequest(taskId: String, taskData: Map<String, Any?>): OneTimeWorkRequest {
-    val workerClassName = taskData["workerClassName"] as? String ?: ""
-    @Suppress("UNCHECKED_CAST")
-    val workerConfig = taskData["workerConfig"] as? Map<String, Any?>
-    // Custom workers (NativeWorker.custom) carry user data under "input" key as a
-    // pre-encoded JSON string. Pass that directly so the custom worker receives its
-    // own fields — matching handleEnqueue and iOS executeWorkerSync behaviour.
-    // Built-in workers receive the full config enriched with __taskId for progress.
-    val inputJson: String? = when {
-        workerConfig == null -> null
-        workerConfig["workerType"] == "custom" -> workerConfig["input"] as? String
-        else -> {
-            val enrichedConfig = workerConfig.toMutableMap()
-            if (taskId.isNotEmpty()) enrichedConfig["__taskId"] = taskId
-            toJson(enrichedConfig)
-        }
-    }
-    @Suppress("UNCHECKED_CAST")
-    val constraintsMap = taskData["constraints"] as? Map<String, Any?>
-    val constraints = parseConstraints(constraintsMap)
-
-    val dataBuilder = Data.Builder().putString("workerClassName", workerClassName)
-    if (inputJson != null) dataBuilder.putString("inputJson", inputJson)
-
-    val networkType = when {
-        constraints.requiresUnmeteredNetwork -> NetworkType.UNMETERED
-        constraints.requiresNetwork -> NetworkType.CONNECTED
-        else -> NetworkType.NOT_REQUIRED
-    }
-    val wmConstraintsBuilder = androidx.work.Constraints.Builder()
-        .setRequiredNetworkType(networkType)
-        .setRequiresCharging(constraints.requiresCharging)
-    val sysConstraints = constraints.systemConstraints ?: emptySet()
-    if (sysConstraints.contains(SystemConstraint.DEVICE_IDLE)) wmConstraintsBuilder.setRequiresDeviceIdle(true)
-    if (sysConstraints.contains(SystemConstraint.REQUIRE_BATTERY_NOT_LOW)) wmConstraintsBuilder.setRequiresBatteryNotLow(true)
-
-    val workerClass = if (constraints.isHeavyTask) KmpHeavyWorker::class.java else KmpWorker::class.java
-    return OneTimeWorkRequest.Builder(workerClass)
-        .setConstraints(wmConstraintsBuilder.build())
-        .setInputData(dataBuilder.build())
-        .addTag(NativeTaskScheduler.TAG_KMP_TASK)
-        .addTag("worker-$workerClassName")
-        .addTag(taskId)         // Critical: allows observeChainStepCompletion to find this work
-        .addTag(workerClassName)
-        .build()
-}
-
 /**
  * Observe a single chain step by its task-ID tag and emit an event when it reaches a terminal state.
  * Uses getWorkInfosByTagFlow since chain steps are NOT unique work.
 
@@ -14,6 +14,7 @@ import dev.brewkits.kmpworkmanager.background.data.NativeTaskScheduler
 import dev.brewkits.kmpworkmanager.background.domain.*
 import dev.brewkits.native_workmanager.notification.DownloadNotificationManager
 import dev.brewkits.native_workmanager.store.TaskStore.Companion.sanitizeConfig
+import dev.brewkits.native_workmanager.utils.MappingUtils.toJson
 import dev.brewkits.native_workmanager.workers.HttpDownloadWorker
 import dev.brewkits.native_workmanager.workers.utils.HostConcurrencyManager
 import dev.brewkits.native_workmanager.workers.utils.KeystorePasswordVault
@@ -598,50 +599,8 @@ internal fun NativeWorkmanagerPlugin.handleGetTaskRecord(call: MethodCall, resul
     }
 }
 
-internal fun NativeWorkmanagerPlugin.parseConstraints(map: Map<String, Any?>?): Constraints {
-    if (map == null) return Constraints()
-
-    val requiresNetwork = map["requiresNetwork"] as? Boolean ?: false
-    val requiresUnmeteredNetwork = map["requiresUnmeteredNetwork"] as? Boolean ?: false
-    val requiresCharging = map["requiresCharging"] as? Boolean ?: false
-    val allowWhileIdle = map["allowWhileIdle"] as? Boolean ?: false
-    val isHeavyTask = map["isHeavyTask"] as? Boolean ?: false
-    val backoffDelayMs = (map["backoffDelayMs"] as? Number)?.toLong() ?: 30_000L
-
-    val backoffPolicy = when ((map["backoffPolicy"] as? String)?.lowercase()) {
-        "linear" -> BackoffPolicy.LINEAR
-        else -> BackoffPolicy.EXPONENTIAL
-    }
-
-    val systemConstraintNames = map["systemConstraints"] as? List<*> ?: emptyList<Any>()
-    val systemConstraints: MutableSet<SystemConstraint> = systemConstraintNames
-        .filterIsInstance<String>()
-        .mapNotNull { name ->
-            when (name) {
-                "allowLowStorage" -> SystemConstraint.ALLOW_LOW_STORAGE
-                "allowLowBattery" -> SystemConstraint.ALLOW_LOW_BATTERY
-                "requireBatteryNotLow" -> SystemConstraint.REQUIRE_BATTERY_NOT_LOW
-                "deviceIdle" -> SystemConstraint.DEVICE_IDLE
-                else -> null
-            }
-        }.toMutableSet()
-
-    // Merge legacy boolean flags into systemConstraints if not already covered
-    if (map["requiresDeviceIdle"] as? Boolean == true) systemConstraints.add(SystemConstraint.DEVICE_IDLE)
-    if (map["requiresBatteryNotLow"] as? Boolean == true) systemConstraints.add(SystemConstraint.REQUIRE_BATTERY_NOT_LOW)
-    // requiresStorageNotLow has no direct SystemConstraint equivalent — intentionally skipped
-
-    return Constraints(
-        requiresNetwork = requiresNetwork,
-        requiresUnmeteredNetwork = requiresUnmeteredNetwork,
-        requiresCharging = requiresCharging,
-        allowWhileIdle = allowWhileIdle,
-        isHeavyTask = isHeavyTask,
-        backoffPolicy = backoffPolicy,
-        backoffDelayMs = backoffDelayMs,
-        systemConstraints = systemConstraints
-    )
-}
+internal fun NativeWorkmanagerPlugin.parseConstraints(map: Map<String, Any?>?): Constraints =
+    dev.brewkits.native_workmanager.utils.MappingUtils.parseConstraints(map)
 
 /**
  * Schedules a OneTime task directly via WorkManager, bypassing kmpworkmanager.
 
@@ -7,6 +7,7 @@ import androidx.work.WorkInfo
 import androidx.work.WorkManager
 import dev.brewkits.native_workmanager.engine.TaskEventBus
 import dev.brewkits.native_workmanager.notification.DownloadNotificationManager
+import dev.brewkits.native_workmanager.utils.MappingUtils.toJson
 import dev.brewkits.native_workmanager.workers.utils.ProgressReporter
 import kotlinx.coroutines.*
 import kotlinx.coroutines.flow.collect