Method StartAsync

examples/long-running-tools/main.go:246–291

(ctx context.Context, args map[string]any)

}

func (t *MockFileUploadTool) StartAsync(ctx context.Context, args map[string]any) (string, error) {
	// 使用自定义的执行逻辑
	taskID := "task_" + strconv.FormatInt(time.Now().UnixNano(), 10)

	// 创建任务状态
	status := &tools.TaskStatus{
		TaskID:    taskID,
		State:     tools.TaskStatePending,
		Progress:  0.0,
		StartTime: time.Now(),
		Metadata:  make(map[string]any),
	}
	_ = t.executor.UpdateProgress(taskID, 0.0, nil)

	// 异步执行
	go func() {
		fileSize := args["file_size"].(int)
		chunkSize := args["chunk_size"].(int)

		chunks := fileSize / chunkSize
		for i := range chunks {
			select {
			case <-ctx.Done():
				return
			case <-time.After(100 * time.Millisecond):
				progress := float64(i+1) / float64(chunks)
				_ = t.executor.UpdateProgress(taskID, progress, map[string]any{
					"uploaded_chunks": i + 1,
					"total_chunks":    chunks,
				})
			}
		}

		// 完成
		now := time.Now()
		status.State = tools.TaskStateCompleted
		status.Progress = 1.0
		status.EndTime = &now
		status.Result = map[string]any{
			"uploaded_bytes": fileSize,
			"chunks":         chunks,
		}
	}()

	return taskID, nil
}

func (t *MockFileUploadTool) Execute(ctx context.Context, args map[string]any) (any, error) {
	// 简化的同步执行