re-enable aws feature gating

Author: MingweiSamuel

hydro_test/Cargo.toml

@@ -12,10 +12,8 @@ docker = ["hydro_lang/docker_deploy"]
 ecs = ["hydro_lang/ecs_deploy"]
 maelstrom = ["hydro_lang/maelstrom"]
 stageleft_macro_entrypoint = ["hydro_lang/stageleft_macro_entrypoint"]
-aws = []
-aws_sqs = ["aws"]
-# aws = ["dep:aws-config", "dep:futures_util"]
-# aws_sqs = ["aws", "dep:aws-sdk-sqs"]
+aws = ["dep:aws-config", "dep:futures-util"]
+aws_sqs = ["aws", "dep:aws-sdk-sqs"]
 
 [[example]]
 name = "aws_sqs"
@@ -45,9 +43,9 @@ hydro_build_utils = { path = "../hydro_build_utils", version = "^0.0.1", optiona
 aws-config = { version = "1", features = [
     "behavior-version-latest",
     "credentials-login",
-]}
-aws-sdk-sqs = { version = "1" }
-futures-util = { version = "0.3.0", default-features = false }
+], optional = true }
+aws-sdk-sqs = { version = "1", optional = true }
+futures-util = { version = "0.3.0", default-features = false, optional = true }
 
 [build-dependencies]
 stageleft_tool.workspace = true

hydro_test/examples/aws_sqs.rs

@@ -14,7 +14,7 @@ use stageleft::q;
 type HostCreator = Box<dyn Fn(&mut Deployment) -> Arc<dyn Host>>;
 
 // aws sqs send-message --queue-url 'https://sqs.us-west-1.amazonaws.com/557701608578/hydro_test_queue_standard' --message-body 'foobar'
-// cargo run -p hydro_test --example aws_sqs --all-features -- --queue-url 'https://sqs.us-west-1.amazonaws.com/557701608578/hydro_test_queue_standard'
+// AWS_PROFILE='test-profile' cargo run -p hydro_test --example aws_sqs --all-features -- --queue-url 'https://sqs.us-west-1.amazonaws.com/557701608578/hydro_test_queue_standard'
 #[derive(Parser, Debug)]
 struct Args {
     #[clap(flatten)]
@@ -113,99 +113,3 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     tokio::signal::ctrl_c().await.unwrap();
     Ok(())
 }
-
-// #[tokio::main]
-// async fn main() {
-//     use aws_sdk_sqs::Client;
-//     use aws_sdk_sqs::types::{DeleteMessageBatchRequestEntry, Message};
-//     use futures::StreamExt;
-//     use futures::stream::Stream;
-//
-//     let queue_url = std::env::var("SQS_QUEUE_URL").expect("set SQS_QUEUE_URL env var");
-
-//     let config = aws_config::load_defaults(aws_config::BehaviorVersion::latest()).await;
-//     let client = Client::new(&config);
-
-//     // Send
-//     client
-//         .send_message()
-//         .queue_url(&queue_url)
-//         .message_body("hello from sqs_sandbox!")
-//         .send()
-//         .await
-//         .expect("failed to send message");
-//     println!("sent message");
-
-//     // Receive
-//     let resp = client
-//         .receive_message()
-//         .queue_url(&queue_url)
-//         .wait_time_seconds(5)
-//         .max_number_of_messages(1)
-//         .send()
-//         .await
-//         .expect("failed to receive message");
-
-//     for msg in resp.messages() {
-//         println!("received: {}", msg.body().unwrap_or("(empty)"));
-
-//         // Delete after processing
-//         client
-//             .delete_message()
-//             .queue_url(&queue_url)
-//             .receipt_handle(msg.receipt_handle().unwrap())
-//             .send()
-//             .await
-//             .expect("failed to delete message");
-//     }
-// }
-
-// pub fn sqs_stream(
-//     client: &Client,
-//     queue_url: impl Into<String>,
-// ) -> impl 'static + Stream<Item = Message> {
-//     let queue_url = queue_url.into();
-//     let recv_msg = client
-//         .receive_message()
-//         .queue_url(&*queue_url)
-//         .wait_time_seconds(10)
-//         .max_number_of_messages(10);
-//     let delete_msg = client.delete_message_batch().queue_url(queue_url);
-//     futures::stream::unfold((), move |()| {
-//         let recv_msg = recv_msg.clone();
-//         let delete_msg = delete_msg.clone();
-//         async move {
-//             let result = recv_msg.send().await;
-//             let output = match result {
-//                 Ok(output) => output,
-//                 Err(e) => {
-//                     eprintln!("error receiving message: {e}");
-//                     return None;
-//                 }
-//             };
-
-//             let messages = output.messages.unwrap_or_default();
-
-//             delete_msg
-//                 .set_entries(Some(
-//                     messages
-//                         .iter()
-//                         .enumerate()
-//                         .map(|(i, msg)| {
-//                             DeleteMessageBatchRequestEntry::builder()
-//                                 .id(i.to_string())
-//                                 .receipt_handle(msg.receipt_handle().unwrap())
-//                                 .build()
-//                                 .unwrap()
-//                         })
-//                         .collect(),
-//                 ))
-//                 .send()
-//                 .await
-//                 .unwrap();
-
-//             Some((messages, ()))
-//         }
-//     })
-//     .flat_map(|vec| futures::stream::iter(vec))
-// }

hydro_test/src/aws/mod.rs

@@ -3,7 +3,7 @@ use hydro_lang::location::tick::NoAtomic;
 use hydro_lang::location::{Location, NoTick};
 use hydro_lang::prelude::*;
 
-// #[cfg(feature = "aws_sqs")]
+#[cfg(feature = "aws_sqs")]
 pub mod sqs;
 
 #[ctor::ctor]

hydro_test/src/lib.rs

@@ -9,7 +9,7 @@ pub mod local;
 pub mod maelstrom;
 pub mod tutorials;
 
-// #[cfg(feature = "aws")]
+#[cfg(feature = "aws")]
 pub mod aws;
 
 #[doc(hidden)]