Function executeSandboxCodeWithResult

api/service/tools/executor.go:169–216

executeSandboxCodeWithResult executes code and returns full result including output files

(ctx context.Context, language string, code string)

// executeSandboxCodeWithResult executes code and returns full result including output files
func executeSandboxCodeWithResult(ctx context.Context, language string, code string) (*ToolResult, error) {
	reqPayload := buildSandboxRequest(ctx, language, code)
	if err := ensureSandboxSessionSeeded(ctx, reqPayload.SessionID, reqPayload.Cwd); err != nil {
		return nil, err
	}
	if err := preflightSandboxClientCode(ctx, reqPayload.SessionID, reqPayload.Cwd, language, code); err != nil {
		return nil, err
	}

	jsonData, err := json.Marshal(reqPayload)
	if err != nil {
		return nil, fmt.Errorf("failed to marshal sandbox request: %v", err)
	}

	url := fmt.Sprintf("%s/execute", strings.TrimRight(config.SandboxServiceURL, "/"))
	logSandboxRequestDebug(ctx, "execute", url, reqPayload, jsonData)
	var sandboxResp *sandboxclient.ExecuteCodeResponse

	// Execute with retry logic for transient failures
	retryErr := common.Retry(ctx, func() error {
		resp, httpErr := getSandboxClient().ExecuteCode(ctx, convertToSandboxClientExecuteRequest(reqPayload))
		if httpErr != nil {
			logger.Warnf(ctx, "Sandbox service request failed: %v", httpErr)
			return httpErr
		}
		sandboxResp = resp
		return nil
	},
		common.WithMaxRetries(3),
		common.WithInitialDelay(500*time.Millisecond),
		common.WithRetryableFunc(common.IsRetryableError),
	)

	if retryErr != nil {
		logger.Errorf(ctx, "Sandbox service unavailable after retries: %v", retryErr)
		return nil, fmt.Errorf("工具服务暂时不可用，请稍后重试")
	}
	logSandboxResponseDebug(ctx, "execute", convertFromSandboxClientExecuteResponse(sandboxResp))
	outputFiles, snapshot := filterSandboxOutputFilesBySnapshot(loadSandboxOutputSnapshot(ctx), convertSandboxOutputFiles(sandboxResp.OutputFiles))
	rememberSandboxOutputSnapshot(ctx, snapshot)

	return &ToolResult{
		Output:      formatCommandResult(sandboxResp.Stdout, sandboxResp.Stderr, sandboxResp.ExitCode),
		Stderr:      sandboxResp.Stderr,
		ExitCode:    sandboxResp.ExitCode,
		OutputFiles: outputFiles,
	}, nil
}

// executeSandboxCode handles the HTTP communication with the Sandbox Service
// with retry logic for transient failures