fix(integration): align Zonal and Pirlo bucket handling across test suites

Author: vipnydav

tools/integration_tests/list_large_dir/list_dir_with_twelve_thousand_files_test.go

@@ -275,7 +275,7 @@ func (t *listLargeDir) TestListDirectoryWithTwelveThousandFilesAndHundredExplici
 }
 
 func (t *listLargeDir) TestListDirectoryWithTwelveThousandFilesAndHundredExplicitDirAndHundredImplicitDir() {
-	if setup.IsZonalBucketRun() {
+	if setup.IsZonalBucketRun() || setup.IsPirloBucketRun() {
 		t.T().Skipf("Redundant test for ZB as implicit-dir is a non-HNS concept, hence not applicable here. ")
 	}
 	dirPath := prepareTestDirectory(t.T(), true, true)

tools/integration_tests/requester_pays_bucket/setup_test.go

@@ -74,7 +74,7 @@ var (
 func TestMain(m *testing.M) {
 	setup.ParseSetUpFlags()
 
-	if setup.IsZonalBucketRun() {
+	if setup.IsZonalBucketRun() || setup.IsPirloBucketRun() {
 		log.Fatal("Test not supported for zonal bucket as they don't support requester-pays feature")
 	}
 

tools/integration_tests/unfinalized_object/setup_test.go

@@ -60,7 +60,7 @@ func TestMain(m *testing.M) {
 	testEnv.cfg = &cfg.UnfinalizedObject[0]
 	testEnv.bucketType = setup.TestEnvironment(testEnv.ctx, testEnv.cfg)
 
-	if !setup.IsZonalBucketRun() {
+	if !setup.IsZonalBucketRun() && !setup.IsPirloBucketRun() {
 		log.Printf("This test is only for Zonal buckets.")
 		os.Exit(0)
 	}

tools/integration_tests/util/client/storage_client.go

@@ -237,7 +237,7 @@ func WithAppendableAPI(use bool) WriterOption {
 func NewWriterWithOptions(ctx context.Context, o *storage.ObjectHandle, opts ...WriterOption) *storage.Writer {
 	// 1. Set the dynamic defaults first
 	cfg := writerConfig{
-		finalizeOnClose: !setup.IsZonalBucketRun(),
+		finalizeOnClose: !(setup.IsZonalBucketRun() || setup.IsPirloBucketRun()),
 	}
 
 	// 2. Apply any explicit overrides passed by the caller
@@ -248,7 +248,7 @@ func NewWriterWithOptions(ctx context.Context, o *storage.ObjectHandle, opts ...
 	// 3. Construct the writer using the final resolved config
 	wc := o.NewWriter(ctx)
 	wc.FinalizeOnClose = cfg.finalizeOnClose
-	wc.Append = cfg.useAppendableAPI || setup.IsZonalBucketRun()
+	wc.Append = cfg.useAppendableAPI || setup.IsZonalBucketRun() || setup.IsPirloBucketRun()
 
 	if cfg.storageClass != "" {
 		wc.StorageClass = cfg.storageClass

tools/integration_tests/write_large_files/concurrent_write_to_same_file_test.go

@@ -69,7 +69,7 @@ func writeToFileSequentially(t *testing.T, filePaths []string, startOffset int,
 
 		startOffset = startOffset + chunkSize
 	}
-	if setup.IsZonalBucketRun() {
+	if setup.IsZonalBucketRun() || setup.IsPirloBucketRun() {
 		operations.SyncFiles(filesToWrite, t)
 	}
 }