Method handleSlashCommandForStream

pkg/agent/streaming.go:275–302

handleSlashCommandForStream 处理 Slash Command（流式版本）

(ctx context.Context, msg *types.Message, writer *stream.Writer[*session.Event])

// handleSlashCommandForStream 处理 Slash Command（流式版本）
func (a *Agent) handleSlashCommandForStream(ctx context.Context, msg *types.Message, writer *stream.Writer[*session.Event]) (bool, error) {
	// 检查是否为 slash command
	if !a.commandExecutor.IsSlashCommand(msg.Content) {
		return false, nil
	}

	// 执行 slash command
	result, err := a.commandExecutor.Execute(ctx, msg.Content, make(map[string]string))
	if err != nil {
		return true, err
	}

	// 生成响应事件
	event := &session.Event{
		ID:        generateEventID(),
		Timestamp: a.createdAt,
		AgentID:   a.id,
		Author:    "system",
		Content: types.Message{
			Role:    types.RoleAssistant,
			Content: result,
		},
	}

	// 发送事件
	writer.Send(event, nil)
	return true, nil
}

// runModelStepStreaming 流式执行模型步骤
// 返回: (done, error)