#![cfg(test)]
use super::*;
struct TestTransform;
#[async_trait]
impl SystemMessageTransform for TestTransform {
fn section_ids(&self) -> Vec<String> {
vec!["instructions".to_string(), "context".to_string()]
}
async fn transform_section(
&self,
section_id: &str,
content: &str,
_ctx: TransformContext,
) -> Option<String> {
match section_id {
"instructions" => Some(format!("[modified] {content}")),
_ => None,
}
}
}
#[tokio::test]
async fn dispatch_applies_matching_transform() {
let transform = TestTransform;
let mut sections = HashMap::new();
sections.insert(
"instructions".to_string(),
TransformSection {
content: "be helpful".to_string(),
},
);
let response = dispatch_transform(&transform, &SessionId::new("sess-1"), sections).await;
assert_eq!(
response.sections["instructions"].content,
"[modified] be helpful"
);
}
#[tokio::test]
async fn dispatch_passes_through_unhandled_section() {
let transform = TestTransform;
let mut sections = HashMap::new();
sections.insert(
"context".to_string(),
TransformSection {
content: "original context".to_string(),
},
);
let response = dispatch_transform(&transform, &SessionId::new("sess-1"), sections).await;
assert_eq!(response.sections["context"].content, "original context");
}
#[tokio::test]
async fn dispatch_unknown_section_passes_through() {
let transform = TestTransform;
let mut sections = HashMap::new();
sections.insert(
"unknown".to_string(),
TransformSection {
content: "mystery".to_string(),
},
);
let response = dispatch_transform(&transform, &SessionId::new("sess-1"), sections).await;
assert_eq!(response.sections["unknown"].content, "mystery");
}
#[tokio::test]
async fn dispatch_mixed_sections() {
let transform = TestTransform;
let mut sections = HashMap::new();
sections.insert(
"instructions".to_string(),
TransformSection {
content: "help me".to_string(),
},
);
sections.insert(
"context".to_string(),
TransformSection {
content: "some context".to_string(),
},
);
sections.insert(
"other".to_string(),
TransformSection {
content: "other stuff".to_string(),
},
);
let response = dispatch_transform(&transform, &SessionId::new("sess-1"), sections).await;
assert_eq!(
response.sections["instructions"].content,
"[modified] help me"
);
assert_eq!(response.sections["context"].content, "some context");
assert_eq!(response.sections["other"].content, "other stuff");
}
#[tokio::test]
async fn section_ids_returns_registered_sections() {
let transform = TestTransform;
let ids = transform.section_ids();
assert_eq!(ids, vec!["instructions", "context"]);
}