use genai::adapter::AdapterKind;
use genai::chat::printer::print_chat_stream;
use genai::chat::{ChatMessage, ChatRequest};
use genai::resolver::ModelMapper;
use genai::{Client, ModelIden};
use tracing_subscriber::EnvFilter;
const MODEL: &str = "gpt-4o";
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
tracing_subscriber::fmt()
.with_env_filter(EnvFilter::new("genai=debug"))
.init();
let questions = &[
"Why is the sky blue?",
"Why is it red sometimes?",
];
let model_mapper = ModelMapper::from_mapper_fn(|model_iden: ModelIden| {
if model_iden.model_name.starts_with("gpt-") {
Ok(ModelIden::new(AdapterKind::OpenAI, "gpt-4o-mini"))
} else {
Ok(model_iden)
}
});
let client = Client::builder().with_model_mapper(model_mapper).build();
let mut chat_req = ChatRequest::default().with_system("Answer in one sentence");
for &question in questions {
chat_req = chat_req.append_message(ChatMessage::user(question));
println!("\n--- Question:\n{question}");
let chat_res = client.exec_chat_stream(MODEL, chat_req.clone(), None).await?;
println!(
"\n--- Answer: ({} - {})",
chat_res.model_iden.adapter_kind, chat_res.model_iden.model_name
);
let assistant_answer = print_chat_stream(chat_res, None).await?;
chat_req = chat_req.append_message(ChatMessage::assistant(assistant_answer));
}
Ok(())
}