mirror of
https://github.com/affaan-m/everything-claude-code.git
synced 2026-04-11 12:03:31 +08:00
style: format ecc2 manager
This commit is contained in:
@@ -480,8 +480,8 @@ pub async fn drain_inbox(
|
|||||||
let mut outcomes = Vec::new();
|
let mut outcomes = Vec::new();
|
||||||
|
|
||||||
for message in messages {
|
for message in messages {
|
||||||
let task = parse_task_handoff_task(&message.content)
|
let task =
|
||||||
.unwrap_or_else(|| message.content.clone());
|
parse_task_handoff_task(&message.content).unwrap_or_else(|| message.content.clone());
|
||||||
|
|
||||||
let outcome = assign_session_in_dir_with_runner_program(
|
let outcome = assign_session_in_dir_with_runner_program(
|
||||||
db,
|
db,
|
||||||
@@ -5040,7 +5040,9 @@ mod tests {
|
|||||||
let auth_messages = db.list_messages_for_session("auth-worker", 10)?;
|
let auth_messages = db.list_messages_for_session("auth-worker", 10)?;
|
||||||
assert!(auth_messages.iter().any(|message| {
|
assert!(auth_messages.iter().any(|message| {
|
||||||
message.msg_type == "task_handoff"
|
message.msg_type == "task_handoff"
|
||||||
&& message.content.contains("Investigate auth callback recovery")
|
&& message
|
||||||
|
.content
|
||||||
|
.contains("Investigate auth callback recovery")
|
||||||
}));
|
}));
|
||||||
|
|
||||||
Ok(())
|
Ok(())
|
||||||
|
|||||||
Reference in New Issue
Block a user