lib

commit f677293cae4dda6051c1a10e83da86ba5f84e5da
parent 724e122338cb3080616c7096cd6cbb758507c93e
Author: triesap <tyson@radroots.org>
Date:   Tue, 28 Jul 2026 08:13:20 +0000

event_store: cover orphaned raw head authority

- create an orphaned raw head through trusted test-only corruption
- exercise the real transactional raw-head join
- reject a missing referenced event with its stored head identity
- preserve production protocol storage behavior

Diffstat:
M
crates/event_store/src/store/protocol_storage_v1.rs
 | 
43
+++++++++++++++++++++++++++++++++++++++++++

1 file changed, 43 insertions(+), 0 deletions(-)
diff --git a/crates/event_store/src/store/protocol_storage_v1.rs b/crates/event_store/src/store/protocol_storage_v1.rs
@@ -387,4 +387,47 @@ mod tests {
         assert_eq!(u64_from_i64("fixture", 7).expect("u64"), 7);
         assert!(u64_from_i64("fixture", -1).is_err());
     }
+
+    #[tokio::test]
+    async fn raw_head_join_rejects_a_missing_referenced_event() {
+        let store = crate::RadrootsEventStore::open_memory()
+            .await
+            .expect("open store");
+        let pubkey = "a".repeat(64);
+        let event_id = "b".repeat(64);
+        let mut connection = store.pool().acquire().await.expect("trusted connection");
+        sqlx::query("DROP TRIGGER radroots_event_store_event_head_insert_guard")
+            .execute(&mut *connection)
+            .await
+            .expect("trusted head guard removal");
+        sqlx::query("PRAGMA foreign_keys = OFF")
+            .execute(&mut *connection)
+            .await
+            .expect("disable trusted foreign-key enforcement");
+        sqlx::query(
+            "INSERT INTO event_envelope_head(coordinate_type, kind, pubkey, d_tag, event_id, created_at, updated_at_ms) VALUES ('replaceable', 10001, ?, NULL, ?, 7, 8)",
+        )
+        .bind(pubkey.as_str())
+        .bind(event_id.as_str())
+        .execute(&mut *connection)
+        .await
+        .expect("trusted orphan head insertion");
+        sqlx::query("PRAGMA foreign_keys = ON")
+            .execute(&mut *connection)
+            .await
+            .expect("restore foreign-key enforcement");
+        drop(connection);
+
+        let coordinate = RadrootsEventHeadCoordinate::Replaceable {
+            kind: 10_001,
+            pubkey: RadrootsPublicKey::parse(pubkey).expect("pubkey"),
+        };
+        let mut transaction = store.pool().begin().await.expect("transaction");
+        assert!(matches!(
+            raw_head_snapshot_in_transaction(&mut transaction, &coordinate).await,
+            Err(RadrootsEventStoreError::StoredHeadInconsistent {
+                event_id: stored_event_id,
+            }) if stored_event_id == event_id
+        ));
+    }
 }