Function main

examples/simple/main.go:17–169

()

)

func main() {
	fmt.Println("🚀 Agent SDK - 简单示例")
	fmt.Println("================================")

	// 1. 创建EventBus
	fmt.Println("\n✓ 创建EventBus...")
	bus := events.NewEventBus()

	// 订阅Progress事件
	progressCh := bus.Subscribe([]types.AgentChannel{types.ChannelProgress}, nil)
	go func() {
		for event := range progressCh {
			fmt.Printf("  [Progress] Cursor=%d, Event=%T\n", event.Cursor, event.Event)
		}
	}()

	// 订阅Monitor事件
	monitorCh := bus.Subscribe([]types.AgentChannel{types.ChannelMonitor}, nil)
	go func() {
		for event := range monitorCh {
			fmt.Printf("  [Monitor] Cursor=%d, Event=%T\n", event.Cursor, event.Event)
		}
	}()

	// 发送一些测试事件
	bus.EmitProgress(&types.ProgressTextChunkStartEvent{Step: 1})
	bus.EmitProgress(&types.ProgressTextChunkEvent{Step: 1, Delta: "Hello"})
	bus.EmitProgress(&types.ProgressTextChunkEvent{Step: 1, Delta: " World"})
	bus.EmitMonitor(&types.MonitorStateChangedEvent{State: types.AgentStateWorking})

	time.Sleep(100 * time.Millisecond) // 等待事件处理

	// 2. 创建本地沙箱
	fmt.Println("\n✓ 创建本地沙箱...")
	sb, err := sandbox.NewLocalSandbox(&sandbox.LocalSandboxConfig{
		WorkDir:         "./workspace",
		EnforceBoundary: true,
		WatchFiles:      false,
	})
	if err != nil {
		log.Fatalf("创建沙箱失败: %v", err)
	}
	defer func() { _ = sb.Dispose() }()

	fmt.Printf("  Kind: %s\n", sb.Kind())
	fmt.Printf("  WorkDir: %s\n", sb.WorkDir())

	// 执行命令
	ctx := context.Background()
	result, err := sb.Exec(ctx, "echo 'Hello from sandbox'", nil)
	if err != nil {
		log.Fatalf("执行命令失败: %v", err)
	}
	fmt.Printf("  执行结果: code=%d, stdout=%s\n", result.Code, result.Stdout)

	// 文件系统操作
	fs := sb.FS()
	testPath := "test.txt"