ccswarm 0.5.0

AI-powered multi-agent orchestration system with proactive intelligence, security monitoring, and session management
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

//! Integration tests for Master Claude orchestration
//!
//! These tests verify the coordination and delegation functionality.

use ccswarm::coordination::{AgentMessage, CoordinationBus};
use serde_json::json;
use std::sync::Arc;

#[tokio::test]
async fn test_coordination_messages() {
    let bus = Arc::new(CoordinationBus::new().await.unwrap());

    let task_msg = AgentMessage::TaskAssignment {
        task_id: "test-task-001".to_string(),
        agent_id: "frontend-agent".to_string(),
        task_data: json!({
            "description": "Create login component",
            "priority": "high"
        }),
    };

    bus.send_message(task_msg.clone()).await.unwrap();
    let received_msg = bus.receive_message().await.unwrap();

    match received_msg {
        AgentMessage::TaskAssignment { task_id, .. } => {
            assert_eq!(task_id, "test-task-001");
        }
        _ => panic!("Unexpected message type received"),
    }
}