Integration tests for http_request_timeout parameter (gcs/s3/alioss)

Author: jochenehret

alioss/integration/general_ali_test.go

@@ -194,6 +194,33 @@ var _ = Describe("General testing for all Ali regions", func() {
 			fileContent, _ := os.ReadFile(outputFilePath) //nolint:errcheck
 			Expect(string(fileContent)).To(Equal("foo"))
 		})
+
+		It("downloads a file when http_request_timeout is set", func() {
+			outputFilePath := "/tmp/" + integration.GenerateRandomString()
+			cfg := defaultConfig
+			cfg.HTTPRequestTimeout = "30s"
+			timeoutConfigPath := integration.MakeConfigFile(&cfg)
+
+			defer func() {
+				cliSession, err := integration.RunCli(cliPath, timeoutConfigPath, storageType, "delete", blobName)
+				Expect(err).ToNot(HaveOccurred())
+				Expect(cliSession.ExitCode()).To(BeZero())
+
+				_ = os.Remove(outputFilePath)   //nolint:errcheck
+				_ = os.Remove(timeoutConfigPath) //nolint:errcheck
+			}()
+
+			cliSession, err := integration.RunCli(cliPath, timeoutConfigPath, storageType, "put", contentFile, blobName)
+			Expect(err).ToNot(HaveOccurred())
+			Expect(cliSession.ExitCode()).To(BeZero())
+
+			cliSession, err = integration.RunCli(cliPath, timeoutConfigPath, storageType, "get", blobName, outputFilePath)
+			Expect(err).ToNot(HaveOccurred())
+			Expect(cliSession.ExitCode()).To(BeZero())
+
+			fileContent, _ := os.ReadFile(outputFilePath) //nolint:errcheck
+			Expect(string(fileContent)).To(Equal("foo"))
+		})
 	})
 
 	Describe("Invoking `delete`", func() {

gcs/integration/gcs_general_test.go

@@ -50,6 +50,15 @@ var _ = Describe("Integration", func() {
 			},
 			configurations)
 
+		DescribeTable("Blobstore lifecycle works with http_request_timeout set",
+			func(cfg *config.GCSCli) {
+				cfgCopy := *cfg
+				cfgCopy.HTTPRequestTimeout = "30s"
+				env.AddConfig(&cfgCopy)
+				AssertLifecycleWorks(gcsCLIPath, env)
+			},
+			configurations)
+
 		DescribeTable("Delete silently ignores that the file doesn't exist",
 			func(config *config.GCSCli) {
 				env.AddConfig(config)

s3/integration/general_aws_test.go

@@ -59,6 +59,14 @@ var _ = Describe("General testing for all AWS regions", Label("aws", "static", "
 			func(cfg *config.S3Cli) { integration.AssertLifecycleWorks(s3CLIPath, cfg) },
 			configurations,
 		)
+		DescribeTable("Blobstore lifecycle works with http_request_timeout set",
+			func(cfg *config.S3Cli) {
+				cfgCopy := *cfg
+				cfgCopy.HTTPRequestTimeout = "30s"
+				integration.AssertLifecycleWorks(s3CLIPath, &cfgCopy)
+			},
+			configurations,
+		)
 
 		DescribeTable("Invoking `ensure-storage-exists` works",
 			func(cfg *config.S3Cli) { integration.AssertOnStorageExists(s3CLIPath, cfg) },