feat(agent-org): add transactional turn context and member FIFO

src-tauri/crates/agent-core/src/core/coordination/agent_org_runs/store/starting.rs

@@ -396,14 +396,16 @@ impl AgentOrgRunStore {
                         "initial input is not durably materialized for Starting run {run_id}"
                     ));
                 }
-                crate::foundation::session_bridge::upsert_turn_intent_with_connection(
-                    &transaction,
+                let admission = crate::coordination::agent_org_turn_contexts::AgentOrgTurnAdmission::starting_coordinator(
+                    run_id,
                     &root_session_id,
                     &input.turn_intent_id,
-                    Some(&input.message_id),
-                    Some(run_id),
-                    crate::foundation::session_bridge::TurnIntentBridgeSource::AgentOrg,
-                    crate::foundation::session_bridge::TurnIntentBridgeStatus::Queued,
+                    Some(input.message_id.clone()),
+                    expected_generation,
+                );
+                crate::coordination::agent_org_turn_contexts::accept_with_connection(
+                    &transaction,
+                    &admission,
                 )?;
                 transaction
                     .execute(

src-tauri/crates/agent-core/src/core/coordination/agent_org_runs/tests.rs

@@ -361,6 +361,16 @@ fn starting_finish_requires_exact_member_and_input_durability_then_is_idempotent
         )
         .expect("load durable initial Turn Intent");
     assert_eq!(turn_status, "queued");
+    let context: (i64, String, String, Option<i64>) = conn
+        .query_row(
+            "SELECT COUNT(*), turn_kind, source_kind, member_dispatch_sequence
+             FROM agent_org_runtime_turn_contexts
+             WHERE session_id='starting-root' AND turn_intent_id='starting-turn'",
+            [],
+            |row| Ok((row.get(0)?, row.get(1)?, row.get(2)?, row.get(3)?)),
+        )
+        .expect("load initial Coordinator context");
+    assert_eq!(context, (1, "coordinator".into(), "root_turn".into(), None));
 }
 
 #[test]
@@ -386,6 +396,15 @@ fn starting_without_initial_work_finishes_idle() {
         .expect("run exists")
         .idled_at
         .is_some());
+    let conn = database::db::get_connection().expect("db");
+    let context_count: i64 = conn
+        .query_row(
+            "SELECT COUNT(*) FROM agent_org_runtime_turn_contexts WHERE org_run_id=?1",
+            [&run.id],
+            |row| row.get(0),
+        )
+        .expect("count no-work contexts");
+    assert_eq!(context_count, 0);
 }
 
 #[test]