fix(catalog): preserve raw apply no-ops

agent-identity: dev3.direct.omp.2cshu64q
agent-persona: generalist
agent-supervisor: unavailable
agent-tool: OMP
agent-tool-version: 18.0.9
agent-runtime: OMP 18.0.9
tooling-profile: dotfiles@b607597

Author: schickling-assistant

src/catalog_transaction.rs

@@ -280,6 +280,34 @@ impl DeclarationProjection {
     }
 }
 
+fn raw_declarations_match(
+    catalog: &Path,
+    current: &DeclarationProjection,
+    desired: &DeclarationProjection,
+) -> bool {
+    if !desired.workspace_dirs.is_subset(&current.workspace_dirs)
+        || !current
+            .files
+            .iter()
+            .all(|(path, file)| desired.files.get(path) == Some(file))
+    {
+        return false;
+    }
+
+    let mut live_profile_modules = BTreeMap::new();
+    for path in &desired.profile_modules {
+        if current.files.contains_key(path) {
+            continue;
+        }
+        if add_profile_module(catalog, Path::new(path), &mut live_profile_modules).is_err() {
+            return false;
+        }
+    }
+    desired.files.iter().all(|(path, file)| {
+        current.files.get(path) == Some(file) || live_profile_modules.get(path) == Some(file)
+    })
+}
+
 #[derive(Debug, Clone, Copy, PartialEq, Eq)]
 enum ProjectionSource {
     Current,
@@ -1628,7 +1656,12 @@ pub fn apply(request: ApplyRequest) -> Result<ApplyResult> {
                 &desired.workspace_dirs,
             )?
         };
-        if current.root_sha256 == desired.root_sha256 && same_pty_root {
+        let same_declarations = if raw_preimage {
+            raw_declarations_match(&catalog, &current, &desired)
+        } else {
+            current.root_sha256 == desired.root_sha256
+        };
+        if same_declarations && same_pty_root {
             return Ok(ApplyResult {
                 schema: if raw_preimage {
                     RAW_APPLY_SCHEMA

tests/catalog_apply.rs

@@ -1994,15 +1994,25 @@ fn raw_preimage_accepts_valid_bytes_and_wrong_cas_preserves_declarations() {
     let temp = tempfile::tempdir().unwrap();
     let valid = temp.path().join("valid");
     write_agent(&valid, "worker", false);
+    fs::create_dir_all(valid.join("resolvers")).unwrap();
+    fs::copy(DEMO_WASM_SRC, valid.join("resolvers/observe.wasm")).unwrap();
+    fs::write(
+        valid.join("catalog.kdl"),
+        profile_catalog_config(&[("dev.example.observe", "resolvers/observe.wasm")]),
+    )
+    .unwrap();
     let valid_prepared = temp.path().join("valid-prepared");
     snapshot(&valid, &valid_prepared);
+    let orphan_workspace = agent_dir(&valid, "worker").join(".workspace");
+    fs::create_dir(&orphan_workspace).unwrap();
     let valid_raw_snapshot = raw_snapshot(&valid, &temp.path().join("valid-raw"));
     assert!(
         valid_raw_snapshot.status.success(),
         "{}",
         String::from_utf8_lossy(&valid_raw_snapshot.stderr)
     );
     let valid_raw_snapshot: Value = serde_json::from_slice(&valid_raw_snapshot.stdout).unwrap();
+    let generation_before = fs::read(valid.join(".st2/catalog-generation")).ok();
     let valid_raw_apply = raw_apply(
         &valid,
         &valid_prepared,
@@ -2013,6 +2023,34 @@ fn raw_preimage_accepts_valid_bytes_and_wrong_cas_preserves_declarations() {
         "{}",
         String::from_utf8_lossy(&valid_raw_apply.stderr)
     );
+    let valid_raw_apply: Value = serde_json::from_slice(&valid_raw_apply.stdout).unwrap();
+    assert_eq!(valid_raw_apply["status"], "unchanged");
+    assert!(!valid.join(".st2/catalog-apply-incomplete").exists());
+    assert_eq!(
+        fs::read(valid.join(".st2/catalog-generation")).ok(),
+        generation_before
+    );
+    assert!(orphan_workspace.is_dir());
+
+    fs::write(valid.join("resolvers/observe.wasm"), b"stale module").unwrap();
+    let stale_module_apply = raw_apply(
+        &valid,
+        &valid_prepared,
+        valid_raw_snapshot["rootSha256"].as_str().unwrap(),
+    );
+    assert!(
+        stale_module_apply.status.success(),
+        "{}",
+        String::from_utf8_lossy(&stale_module_apply.stderr)
+    );
+    let stale_module_apply: Value =
+        serde_json::from_slice(&stale_module_apply.stdout).unwrap();
+    assert_eq!(stale_module_apply["status"], "applied");
+    assert_eq!(
+        fs::read(valid.join("resolvers/observe.wasm")).unwrap(),
+        fs::read(DEMO_WASM_SRC).unwrap()
+    );
+    assert!(orphan_workspace.is_dir());
 
     let invalid = temp.path().join("invalid");
     write_invalid_agent(&invalid, "worker");