Skip to main content

systemprompt_api/services/gateway/protocol/inbound/openai_responses/
mod.rs

1use bytes::Bytes;
2use http::StatusCode;
3use serde_json::Value;
4
5use super::super::canonical::CanonicalRequest;
6use super::super::canonical_response::{CanonicalEvent, CanonicalResponse};
7use super::{InboundAdapter, InboundParseError};
8
9mod parse;
10mod render;
11
12#[derive(Debug, Clone, Copy, Default)]
13pub struct OpenAiResponsesInbound;
14
15impl InboundAdapter for OpenAiResponsesInbound {
16    fn wire_name(&self) -> &'static str {
17        "openai.responses"
18    }
19
20    fn parse_request(&self, raw: &Bytes) -> Result<CanonicalRequest, InboundParseError> {
21        let value: Value = serde_json::from_slice(raw)
22            .map_err(|e| InboundParseError::InvalidJson(e.to_string()))?;
23        parse::parse(&value)
24    }
25
26    fn render_response(&self, response: &CanonicalResponse) -> Bytes {
27        let value = render::render_response_object(response);
28        Bytes::from(serde_json::to_vec(&value).unwrap_or_else(|_| b"{}".to_vec()))
29    }
30
31    fn render_event(&self, event: &CanonicalEvent, model: &str) -> Option<Bytes> {
32        render::render_event_frame(event, model)
33    }
34
35    fn render_error(&self, _status: StatusCode, message: &str) -> Bytes {
36        let escaped = message.replace('\\', "\\\\").replace('"', "\\\"");
37        let body = format!("{{\"error\":{{\"type\":\"api_error\",\"message\":\"{escaped}\"}}}}");
38        Bytes::from(body)
39    }
40}