tkmind/tkmind_go
1
0
Fork 0
Code Issues Pull Requests Actions 7 Packages Projects Releases Wiki Activity

fix: message concatenation in server session management (#3412)

Browse Source
This commit is contained in:
Jack Amadeo
2025-07-14 20:31:16 -04:00
committed by GitHub
parent 0572fd2dc4
commit a71a2d0e73
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/goose-server/src/routes/reply.rs
+3 -3
View File
@@ -11,7 +11,7 @@ use bytes::Bytes;
use futures::{stream::StreamExt, Stream}; use futures::{stream::StreamExt, Stream};
use goose::{ use goose::{
agents::{AgentEvent, SessionConfig}, agents::{AgentEvent, SessionConfig},
message::{Message, MessageContent}, message::{push_message, Message, MessageContent},
permission::permission_confirmation::PrincipalType, permission::permission_confirmation::PrincipalType,
}; };
use goose::{ use goose::{
@@ -232,7 +232,7 @@ async fn handler(
response = timeout(Duration::from_millis(500), stream.next()) => { response = timeout(Duration::from_millis(500), stream.next()) => {
match response { match response {
Ok(Some(Ok(AgentEvent::Message(message)))) => { Ok(Some(Ok(AgentEvent::Message(message)))) => {
all_messages.push(message.clone()); push_message(&mut all_messages, message.clone());
if let Err(e) = stream_event(MessageEvent::Message { message }, &tx).await { if let Err(e) = stream_event(MessageEvent::Message { message }, &tx).await {
tracing::error!("Error sending message through channel: {}", e); tracing::error!("Error sending message through channel: {}", e);
let _ = stream_event( let _ = stream_event(
@@ -406,7 +406,7 @@ async fn ask_handler(
} }
if !response_message.content.is_empty() { if !response_message.content.is_empty() {
all_messages.push(response_message); push_message(&mut all_messages, response_message);
} }
let session_path = match session::get_path(session::Identifier::Name(session_id.clone())) { let session_path = match session::get_path(session::Identifier::Name(session_id.clone())) {