Method SendTo

pkg/core/room.go:199–237

SendTo 发送消息给指定成员

(ctx context.Context, from string, to string, text string)

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

	// 检查发送者
	if _, exists := r.members[from]; !exists && from != "system" {
		r.mu.RUnlock()
		return fmt.Errorf("sender is not a member: %s", from)
	}

	// 检查接收者
	agentID, exists := r.members[to]
	if !exists {
		r.mu.RUnlock()
		return fmt.Errorf("recipient not found: %s", to)
	}

	r.mu.RUnlock()

	// 记录到历史
	msg := RoomMessage{
		From: from,
		To:   []string{to},
		Text: text,
		Sent: nowTimestamp(),
	}

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

	// 获取 Agent 并发送
	ag, exists := r.pool.Get(agentID)
	if !exists {
		return fmt.Errorf("agent not found for member %s", to)
	}

	formattedText := fmt.Sprintf("[from:%s] %s", from, text)
	return ag.Send(ctx, formattedText)
}

// GetMembers 获取所有成员
func (r *Room) GetMembers() []RoomMember {