Method InternalTestCleanupUnfinished

backend/b2/b2_internal_test.go:491–526

(t *testing.T)

}

func (f *Fs) InternalTestCleanupUnfinished(t *testing.T) {
	ctx := context.Background()

	// B2CleanupHidden tests cleaning up hidden files
	t.Run("CleanupUnfinished", func(t *testing.T) {
		dirName := "unfinished"
		fileCount := 5
		expectedFiles := []string{}
		for i := 1; i < fileCount; i++ {
			fileName := fmt.Sprintf("%s/unfinished-%d", dirName, i)
			expectedFiles = append(expectedFiles, fileName)
			obj := &Object{
				fs:     f,
				remote: fileName,
			}
			objInfo := object.NewStaticObjectInfo(fileName, fstest.Time("2002-02-03T04:05:06.499999999Z"), -1, true, nil, nil)
			_, err := f.newLargeUpload(ctx, obj, nil, objInfo, f.opt.ChunkSize, false, nil)
			require.NoError(t, err)
		}
		checkListing(ctx, t, f, dirName, expectedFiles)

		t.Run("DryRun", func(t *testing.T) {
			// Listing should not change after dry run
			ctx, ci := fs.AddConfig(ctx)
			ci.DryRun = true
			require.NoError(t, f.cleanUp(ctx, false, true, 0))
			checkListing(ctx, t, f, dirName, expectedFiles)
		})

		t.Run("RealThing", func(t *testing.T) {
			// Listing should be empty after real cleanup
			require.NoError(t, f.cleanUp(ctx, false, true, 0))
			checkListing(ctx, t, f, dirName, []string{})
		})
	})
}

func listAllFiles(ctx context.Context, t *testing.T, f *Fs, dirName string) []string {
	bucket, directory := f.split(dirName)