test: added end-to-end test using S3Mock in a container

Author: beeb

src/aws.rs

@@ -30,8 +30,10 @@ pub(crate) async fn upload_file(archive: Archive, params: &Params) -> Result<()>
     env::set_var("AWS_ACCESS_KEY_ID", &params.aws_key_id);
     env::set_var("AWS_SECRET_ACCESS_KEY", &params.aws_key);
     let mut shared_config_builder = aws_config::from_env().region(params.aws_region.region().await);
-    if cfg!(test) {
-        shared_config_builder = shared_config_builder.endpoint_url("http://localhost:9090")
+    // we set this special environment variable when doing e2e testing
+    if env::var("AWSBCK_TESTING_E2E").is_ok() {
+        warn!("Endpoint URL was changed to localhost while in testing environment.");
+        shared_config_builder = shared_config_builder.endpoint_url("http://127.0.0.1:9090")
     }
     let shared_config = shared_config_builder.load().await;
     let client = Client::new(&shared_config);

tests/e2e_test.rs

@@ -1,4 +1,4 @@
-use std::{path::PathBuf, process::Command};
+use std::{collections::HashMap, path::PathBuf, process::Command};
 
 use dockertest::{
     waitfor::{MessageSource, MessageWait},
@@ -8,25 +8,29 @@ use dockertest::{
 #[test]
 fn e2e_test() {
     let mut test = DockerTest::new().with_default_source(Source::DockerHub);
+    let mut container_env = HashMap::new();
+    container_env.insert("initialBuckets".to_string(), "foo".to_string());
     let mut aws = Composition::with_repository("adobe/s3mock")
         .with_container_name("aws")
         .with_wait_for(Box::new(MessageWait {
             message: "Started S3MockApplication".to_string(),
             source: MessageSource::Stdout,
             timeout: 10,
-        }));
-    aws.port_map(9090, 9090);
+        }))
+        .with_env(container_env);
+    aws.port_map(9090, 9090).port_map(9191, 9191);
     test.add_composition(aws);
 
     test.run(|ops| async move {
         let _container = ops.handle("aws");
         let path = PathBuf::from(env!("CARGO_BIN_EXE_awsbck"));
         let output = Command::new(path)
+            .env("AWSBCK_TESTING_E2E", "1")
             .args(["-b", "foo", "--id", "bar", "-k", "baz"])
             .arg("./src")
             .output()
             .expect("Failed to execute command");
-        println!("{}", String::from_utf8_lossy(&output.stderr));
         assert!(output.status.success());
+        assert!(String::from_utf8_lossy(&output.stderr).contains("Backup succeeded"));
     });
 }