36 lines
1.1 KiB
Rust
36 lines
1.1 KiB
Rust
|
use codex_protocol::protocol::SessionSource;
|
||
|
|
use http::HeaderMap;
|
||
|
|
use http::HeaderValue;
|
||
|
|
|
||
|
|
pub(crate) fn build_conversation_headers(conversation_id: Option<String>) -> HeaderMap {
|
||
|
|
let mut headers = HeaderMap::new();
|
||
|
|
if let Some(id) = conversation_id {
|
||
|
|
insert_header(&mut headers, "session_id", &id);
|
||
|
|
}
|
||
|
|
headers
|
||
|
|
}
|
||
|
|
|
||
|
|
pub(crate) fn subagent_header(source: &Option<SessionSource>) -> Option<String> {
|
||
|
|
let SessionSource::SubAgent(sub) = source.as_ref()? else {
|
||
|
|
return None;
|
||
|
|
};
|
||
|
|
match sub {
|
||
|
|
codex_protocol::protocol::SubAgentSource::Other(label) => Some(label.clone()),
|
||
|
|
other => Some(
|
||
|
|
serde_json::to_value(other)
|
||
|
|
.ok()
|
||
|
|
.and_then(|v| v.as_str().map(std::string::ToString::to_string))
|
||
|
|
.unwrap_or_else(|| "other".to_string()),
|
||
|
|
),
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
pub(crate) fn insert_header(headers: &mut HeaderMap, name: &str, value: &str) {
|
||
|
|
if let (Ok(header_name), Ok(header_value)) = (
|
||
|
|
name.parse::<http::HeaderName>(),
|
||
|
|
HeaderValue::from_str(value),
|
||
|
|
) {
|
||
|
|
headers.insert(header_name, header_value);
|
||
|
|
}
|
||
|
|
}
|