Function TestUploadLargeFile

plugin/orchestrator/upload/upload_command_test.go:209–248

(t *testing.T)

}

func TestUploadLargeFile(t *testing.T) {
	size := 10 * 1024 * 1024
	srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		body, _ := io.ReadAll(r.Body)
		if len(body) != size {
			w.WriteHeader(http.StatusInternalServerError)
			_, _ = w.Write([]byte("Invalid size"))
			return
		}
		w.WriteHeader(http.StatusCreated)
	}))
	defer srv.Close()

	path := test.CreateTempFileBinary(t, make([]byte, size))

	definition := `
servers:
- url: https://cloud.uipath.com/{organization}/{tenant}/orchestrator_
  description: The production url
  variables:
    organization:
      description: The organization name (or id)
      default: my-org
    tenant:
      description: The tenant name (or id)
      default: my-tenant
`

	context := test.NewContextBuilder().
		WithDefinition("orchestrator", definition).
		WithCommandPlugin(NewUploadCommand()).
		WithResponse(http.StatusOK, `{"Uri":"`+srv.URL+`"}`).
		Build()

	result := test.RunCli([]string{"orchestrator", "buckets", "upload", "--organization", "myorg", "--tenant", "mytenant", "--folder-id", "1", "--key", "2", "--path", "file.txt", "--file", path}, context)

	if result.Error != nil {
		t.Errorf("Expected no error, but got: %v", result.Error)
	}
}

func TestUploadWithDebugOutput(t *testing.T) {
	srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {