Function TestPutRecursiveIfExistsSkipContinuesPastExistingFiles

cmd/put_test.go:1424–1477

(t *testing.T)

}

func TestPutRecursiveIfExistsSkipContinuesPastExistingFiles(t *testing.T) {
	dir := t.TempDir()
	if err := os.WriteFile(filepath.Join(dir, "existing.txt"), []byte("existing"), 0644); err != nil {
		t.Fatal(err)
	}
	if err := os.WriteFile(filepath.Join(dir, "new.txt"), []byte("new"), 0644); err != nil {
		t.Fatal(err)
	}

	var uploaded []string
	mock := &mockFilesClient{
		getMetadataFn: func(arg *files.GetMetadataArg) (files.IsMetadata, error) {
			if arg.Path == "/backup/existing.txt" {
				return &files.FileMetadata{Metadata: files.Metadata{PathDisplay: arg.Path}}, nil
			}
			return nil, getMetadataNotFoundError()
		},
		uploadFn: func(arg *files.UploadArg, content io.Reader) (*files.FileMetadata, error) {
			uploaded = append(uploaded, arg.Path)
			return &files.FileMetadata{}, nil
		},
		createFolderV2Fn: func(arg *files.CreateFolderArg) (*files.CreateFolderResult, error) {
			return &files.CreateFolderResult{}, nil
		},
	}
	stubFilesClient(t, mock)

	var stderr bytes.Buffer
	cmd := testPutCmd()
	cmd.SetErr(&stderr)

	err := putRecursive(dir, "/backup", putOptions{
		chunkSize: 1 << 24,
		workers:   4,
		ifExists:  putIfExistsSkip,
		output:    commandOutput(cmd),
	})
	if err != nil {
		t.Fatalf("putRecursive error: %v", err)
	}

	if len(uploaded) != 1 || uploaded[0] != "/backup/new.txt" {
		t.Fatalf("uploaded = %v, want [/backup/new.txt]", uploaded)
	}
	if strings.Contains(stderr.String(), "Uploading ") {
		t.Fatalf("stderr = %q, should not print uploading before skip decision", stderr.String())
	}
	if !strings.Contains(stderr.String(), "Processing ") {
		t.Fatalf("stderr = %q, want processing status", stderr.String())
	}
	if !strings.Contains(stderr.String(), "Skipping /backup/existing.txt") {
		t.Fatalf("stderr = %q, want skip status", stderr.String())
	}
}

func TestUploadChunked_RetriesSessionStart(t *testing.T) {
	stubRetrySleep(t)