jerry/buzz
1
0
Fork 0
mirror of https://github.com/block/buzz.git synced 2026-10-30 22:11:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(workflows): provide durable message provenance

Browse Source 
Update relay action-sink integration fixtures for the immutable workflow message context required by delivery persistence.

Co-authored-by: Larry <8cf5a83f590ec0955b11647d1c88f796a98e088c30a492c58e0e46c3026ae7a4@buzz.block.builderlab.xyz>
Signed-off-by: Logan Johnson <loganj@squareup.com>
This commit is contained in:
Logan Johnson
2026-08-24 19:37:02 -04:00
parent bbd6c2e5b4
commit 1fd4acc694
1 changed files with 17 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
crates/buzz-relay/src/workflow_sink.rs
View File

@@ -760,6 +760,17 @@ mod integration_tests {
use buzz_db::CreateCommunityWithOwnerResult;
use std::sync::Arc;
fn message_context() -> WorkflowMessageContext {
WorkflowMessageContext {
workflow_id: Uuid::new_v4(),
run_id: Uuid::new_v4(),
definition_event_id: nostr::EventId::all_zeros().to_hex(),
step_id: "message".to_string(),
execution_trace: serde_json::json!({}),
trigger_context: None,
}
}
/// Real-PG state mirroring `handlers::event::tests::test_state_with_redis_url`.
async fn test_state() -> Arc<AppState> {
let mut config = crate::config::Config::from_env().expect("default config loads");
@@ -865,6 +876,7 @@ mod integration_tests {
&channel.id.to_string(),
"heads up @Robby — please take a look",
&author_hex,
&message_context(),
None,
)
.await
@@ -941,6 +953,7 @@ mod integration_tests {
&channel.id.to_string(),
"root message",
&author_hex,
&message_context(),
None,
)
.await
@@ -953,6 +966,7 @@ mod integration_tests {
&channel.id.to_string(),
"threaded reply",
&author_hex,
&message_context(),
Some(&root_hex),
)
.await
@@ -1095,6 +1109,7 @@ mod integration_tests {
&channel_hex,
"workflow reply",
&author_hex,
&message_context(),
Some(&parent_hex),
)
.await
@@ -1176,6 +1191,7 @@ mod integration_tests {
&channel_hex,
"workflow reply to root-only parent",
&author_hex,
&message_context(),
Some(&root_only_parent_hex),
)
.await
@@ -1238,6 +1254,7 @@ mod integration_tests {
&channel.id.to_string(),
"orphan reply",
&author_hex,
&message_context(),
Some(&unknown),
)
.await