Method Broadcast

pkg/core/room.go:163–196

Broadcast 广播消息给所有成员 (包括发送者)

(ctx context.Context, text string)

// Broadcast 广播消息给所有成员 (包括发送者)
func (r *Room) Broadcast(ctx context.Context, text string) error {
	r.mu.RLock()

	// 复制成员列表
	targets := make(map[string]string, len(r.members))
	maps.Copy(targets, r.members)

	r.mu.RUnlock()

	// 记录到历史
	msg := RoomMessage{
		From: "system",
		Text: text,
		Sent: nowTimestamp(),
	}

	r.mu.Lock()
	r.history = append(r.history, msg)
	r.mu.Unlock()

	// 发送消息
	for _, agentID := range targets {
		ag, exists := r.pool.Get(agentID)
		if !exists {
			continue
		}

		go func(agent *agent.Agent, txt string) {
			_ = agent.Send(ctx, txt)
		}(ag, text)
	}

	return nil
}

// SendTo 发送消息给指定成员
func (r *Room) SendTo(ctx context.Context, from string, to string, text string) error {