From 002f420df9e284dad8a1452969154ab868700b96 Mon Sep 17 00:00:00 2001
From: Franklin <franklinblanco@tutanota.com>
Date: Wed, 3 May 2023 20:19:27 -0400
Subject: [PATCH] Added s3 creds and urls

---
 Cargo.toml      | 1 -
 src/utils/s3.rs | 8 +++++---
 2 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/Cargo.toml b/Cargo.toml
index cb2f717..47146cd 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -12,7 +12,6 @@ tokio = {version = "1.20.1", features = ["full"]}
 chrono = "0.4.23"
 chrono-tz = "0.8"
 reqwest = { version = "0.11.11", features = ["rustls-tls", "json", "blocking"], default-features = false }
-
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0.88"
 sqlx = { version = "0.6.0", features = [ "runtime-tokio-rustls", "postgres", "chrono", "uuid", "offline" ] }
diff --git a/src/utils/s3.rs b/src/utils/s3.rs
index 3ab41c9..56c1e18 100644
--- a/src/utils/s3.rs
+++ b/src/utils/s3.rs
@@ -1,6 +1,7 @@
 use aws_sdk_s3::{
     error::SdkError, operation::put_object::PutObjectError, primitives::ByteStream, Client,
 };
+use uuid::Uuid;
 
 pub async fn init_aws_client() -> Client {
     dotenvy::dotenv().expect("Failed loading env");
@@ -10,13 +11,14 @@ pub async fn init_aws_client() -> Client {
 
 pub async fn upload_image(
     client: &Client,
+    realtor_id: Uuid,
     file_name: String,
     multipart: Vec<u8>,
 ) -> Result<String, SdkError<PutObjectError>> {
-    let path = format!("jl-images/{file_name}");
+    let path = format!("realtor-images/{realtor_id}/{file_name}");
     match client
         .put_object()
-        .bucket("jorge-ledesma-bucket")
+        .bucket("realtor-lp-bucket")
         .key(path.clone())
         .body(ByteStream::from(multipart))
         .acl(aws_sdk_s3::types::ObjectCannedAcl::PublicRead)
@@ -24,7 +26,7 @@ pub async fn upload_image(
         .await
     {
         Ok(_) => Ok(format!(
-            "https://jorge-ledesma-bucket.s3.us-east-2.amazonaws.com/{path}"
+            "https://realtor-lp-bucket.s3.us-east-2.amazonaws.com/{path}"
         )),
         Err(error) => Err(error),
     }