Ling0925
/
buster
mirror of https://github.com/buster-so/buster.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix Clippy warnings in post_chat_handler and add proper prefixes for unused variables

This commit is contained in:
dal 2025-03-21 11:29:25 -06:00
parent 63933d6627
commit a5529b4746
No known key found for this signature in database
GPG Key ID: 16F4B0E1E9F61122
1 changed files with 15 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
api/libs/handlers/src/chats/post_chat_handler.rs
View File

@ -133,7 +133,7 @@ impl ChunkTracker {
pub async fn post_chat_handler( pub async fn post_chat_handler(
request: ChatCreateNewChat, request: ChatCreateNewChat,
user: AuthenticatedUser, user: AuthenticatedUser,
_tx: Option<mpsc::Sender<Result<(BusterContainer, ThreadEvent)>>>, tx: Option<mpsc::Sender<Result<(BusterContainer, ThreadEvent)>>>,
) -> Result<ChatWithMessages> { ) -> Result<ChatWithMessages> {
// Create a request-local chunk tracker instance instead of using global static // Create a request-local chunk tracker instance instead of using global static
let chunk_tracker = ChunkTracker::new(); let chunk_tracker = ChunkTracker::new();
@ -158,7 +158,7 @@ pub async fn post_chat_handler(
); );
// Send initial chat state to client // Send initial chat state to client
if let Some(tx) = _tx.clone() { if let Some(tx) = tx.clone() {
tx.send(Ok(( tx.send(Ok((
BusterContainer::Chat(chat_with_messages.clone()), BusterContainer::Chat(chat_with_messages.clone()),
ThreadEvent::InitializeChat, ThreadEvent::InitializeChat,
@ -204,7 +204,7 @@ pub async fn post_chat_handler(
let mut chat = AgentThread::new(Some(chat_id), user.id, initial_messages); let mut chat = AgentThread::new(Some(chat_id), user.id, initial_messages);
let title_handle = { let title_handle = {
let tx = _tx.clone(); let tx = tx.clone();
let chat_id = chat_id.clone(); let chat_id = chat_id.clone();
let message_id = message_id.clone(); let message_id = message_id.clone();
let user_id = user.id.clone(); let user_id = user.id.clone();
@ -1520,8 +1520,8 @@ fn transform_assistant_tool_message(
fn assistant_data_catalog_search( fn assistant_data_catalog_search(
id: String, id: String,
content: String, content: String,
progress: MessageProgress, _progress: MessageProgress,
initial: bool, _initial: bool,
) -> Result<Vec<BusterReasoningMessage>> { ) -> Result<Vec<BusterReasoningMessage>> {
let mut parser = StreamingParser::new(); let mut parser = StreamingParser::new();
@ -1589,8 +1589,8 @@ fn assistant_data_catalog_search(
fn assistant_create_metrics( fn assistant_create_metrics(
id: String, id: String,
content: String, content: String,
progress: MessageProgress, _progress: MessageProgress,
initial: bool, _initial: bool,
) -> Result<Vec<BusterReasoningMessage>> { ) -> Result<Vec<BusterReasoningMessage>> {
let mut parser = StreamingParser::new(); let mut parser = StreamingParser::new();
@ -1613,8 +1613,8 @@ fn assistant_create_metrics(
fn assistant_modify_metrics( fn assistant_modify_metrics(
id: String, id: String,
content: String, content: String,
progress: MessageProgress, _progress: MessageProgress,
initial: bool, _initial: bool,
) -> Result<Vec<BusterReasoningMessage>> { ) -> Result<Vec<BusterReasoningMessage>> {
let mut parser = StreamingParser::new(); let mut parser = StreamingParser::new();
@ -1637,8 +1637,8 @@ fn assistant_modify_metrics(
fn assistant_create_dashboards( fn assistant_create_dashboards(
id: String, id: String,
content: String, content: String,
progress: MessageProgress, _progress: MessageProgress,
initial: bool, _initial: bool,
) -> Result<Vec<BusterReasoningMessage>> { ) -> Result<Vec<BusterReasoningMessage>> {
let mut parser = StreamingParser::new(); let mut parser = StreamingParser::new();
@ -1662,8 +1662,8 @@ fn assistant_create_dashboards(
fn assistant_modify_dashboards( fn assistant_modify_dashboards(
id: String, id: String,
content: String, content: String,
progress: MessageProgress, _progress: MessageProgress,
initial: bool, _initial: bool,
) -> Result<Vec<BusterReasoningMessage>> { ) -> Result<Vec<BusterReasoningMessage>> {
let mut parser = StreamingParser::new(); let mut parser = StreamingParser::new();
@ -1686,8 +1686,8 @@ fn assistant_modify_dashboards(
fn assistant_create_plan( fn assistant_create_plan(
id: String, id: String,
content: String, content: String,
progress: MessageProgress, _progress: MessageProgress,
initial: bool, _initial: bool,
) -> Result<Vec<BusterReasoningMessage>> { ) -> Result<Vec<BusterReasoningMessage>> {
let mut parser = StreamingParser::new(); let mut parser = StreamingParser::new();