mirror of
https://github.com/infinilabs/coco-app.git
synced 2025-12-29 00:24:46 +01:00
fix: add missing message parameter to chat send api (#198)
This commit is contained in:
@@ -1,4 +1,4 @@
|
||||
use crate::common::assistant::InitChatMessage;
|
||||
use crate::common::assistant::ChatRequestMessage;
|
||||
use crate::common::http::GetResponse;
|
||||
use crate::server::http_client::HttpClient;
|
||||
use reqwest::Response;
|
||||
@@ -12,7 +12,7 @@ pub async fn new_chat<R: Runtime>(
|
||||
message: String,
|
||||
) -> Result<GetResponse, String> {
|
||||
let body = if !message.is_empty() {
|
||||
let message = InitChatMessage { message: Some(message) };
|
||||
let message = ChatRequestMessage { message: Some(message) };
|
||||
let body = reqwest::Body::from(serde_json::to_string(&message).unwrap());
|
||||
Some(body)
|
||||
} else {
|
||||
@@ -152,14 +152,16 @@ pub async fn send_message<R: Runtime>(
|
||||
server_id: String,
|
||||
session_id: String,
|
||||
websocket_id: String,
|
||||
message: String,
|
||||
query_params: Option<HashMap<String, String>>, //search,deep_thinking
|
||||
) -> Result<String, String> {
|
||||
let path = format!("/chat/{}/_send", session_id);
|
||||
|
||||
let msg = ChatRequestMessage { message: Some(message) };
|
||||
let mut headers = HashMap::new();
|
||||
headers.insert("WEBSOCKET-SESSION-ID".to_string(), websocket_id);
|
||||
|
||||
let response = HttpClient::advanced_post(&server_id, path.as_str(), Some(headers), query_params, None)
|
||||
let body = reqwest::Body::from(serde_json::to_string(&msg).unwrap());
|
||||
let response = HttpClient::advanced_post(&server_id, path.as_str(), Some(headers), query_params, Some(body))
|
||||
.await
|
||||
.map_err(|e| format!("Error cancel session: {}", e))?;
|
||||
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
use serde::{Deserialize, Serialize};
|
||||
|
||||
#[derive(Debug, Clone, Serialize, Deserialize)]
|
||||
pub struct InitChatMessage {
|
||||
pub struct ChatRequestMessage {
|
||||
pub message: Option<String>,
|
||||
}
|
||||
Reference in New Issue
Block a user