Actually try writing to gcs to get error on IfNotExists in tests

lytics · Nov 1, 2019 · 36a891b · 36a891b
1 parent 8e0c0c0
commit 36a891b
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/testutils/testutils.go b/testutils/testutils.go
@@ -754,7 +754,14 @@ func TestReadWriteCloser(t TestingT, store cloudstorage.Store) {
 		assert.Equalf(t, nil, err, "at loop-cnt:%v", i)
 		time.Sleep(time.Millisecond * 100)
 
-		_, err = store.NewWriterWithContext(context.Background(), fileName, nil, cloudstorage.Opts{IfNotExists: true})
+		wc, err = store.NewWriterWithContext(context.Background(), fileName, nil, cloudstorage.Opts{IfNotExists: true})
+		if err == nil {
+			// If err == nil then we're gcs so try writing
+			_, err = bytes.NewBufferString(data).WriteTo(wc)
+			assert.NoErrorf(t, err, "at loop-cnt:%v", i)
+			err = wc.Close()
+			time.Sleep(time.Millisecond * 100)
+		}
 		assert.Error(t, err)
 
 		// Read the object from store, delete if it exists