commit 5c671d4b6206032be6a4c930930a7f72ef9e8edc
parent 3b9b39c730a19ba14fac6e5b319011568e0313c7
Author: triesap <tyson@radroots.org>
Date: Tue, 7 Jul 2026 04:28:53 +0000
events: scope relay policy reducer to Nostr
- Rename the relay policy reducer variant to NostrRelayPolicyProjection.
- Emit the manifest label as nostr_relay_policy_projection.
- Rename the Nostr transport retry test away from retired publish_transport wording.
- Validate with focused events, events_codec, and transport_nostr lanes.
Diffstat:
3 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/crates/events/src/contract.rs b/crates/events/src/contract.rs
@@ -85,7 +85,7 @@ pub enum RadrootsReducer {
MarketProjection,
OrderProjection,
ProfileProjection,
- RelayPolicyProjection,
+ NostrRelayPolicyProjection,
SocialProjection,
TradeValidation,
}
@@ -758,7 +758,7 @@ const ORDER_REDUCERS: &[RadrootsReducer] = &[
RadrootsReducer::ListingInventoryAccounting,
];
const TRADE_VALIDATION_REDUCERS: &[RadrootsReducer] = &[RadrootsReducer::TradeValidation];
-const RELAY_REDUCERS: &[RadrootsReducer] = &[RadrootsReducer::RelayPolicyProjection];
+const RELAY_REDUCERS: &[RadrootsReducer] = &[RadrootsReducer::NostrRelayPolicyProjection];
const KNOWLEDGE_REDUCERS: &[RadrootsReducer] = &[RadrootsReducer::KnowledgeProjection];
const FARM_MEMBERS_LIST_DISCRIMINATOR: &[RadrootsEventDiscriminator] = &[
diff --git a/crates/events_codec/src/manifest.rs b/crates/events_codec/src/manifest.rs
@@ -391,7 +391,7 @@ fn reducer_label(value: RadrootsReducer) -> &'static str {
RadrootsReducer::MarketProjection => "market_projection",
RadrootsReducer::OrderProjection => "order_projection",
RadrootsReducer::ProfileProjection => "profile_projection",
- RadrootsReducer::RelayPolicyProjection => "relay_policy_projection",
+ RadrootsReducer::NostrRelayPolicyProjection => "nostr_relay_policy_projection",
RadrootsReducer::SocialProjection => "social_projection",
RadrootsReducer::TradeValidation => "trade_validation",
}
diff --git a/crates/transport_nostr/tests/transport.rs b/crates/transport_nostr/tests/transport.rs
@@ -1287,7 +1287,7 @@ async fn outbox_publish_persists_partial_success_and_skips_accepted_retry() {
}
#[tokio::test]
-async fn outbox_publish_transport_failure_releases_retryable_claim() {
+async fn outbox_transport_publish_failure_releases_retryable_claim() {
let signed = signed_post("adapter transport failure");
let outbox = RadrootsOutbox::open_memory().await.expect("outbox");
let store = RadrootsEventStore::open_memory().await.expect("store");