From 0fad62aed9253bd6864c2abda03cbb97fc41d34a Mon Sep 17 00:00:00 2001
From: "Rodrigo Rodriguez (Pragmatismo)" <me@rodrigorodriguez.com>
Date: Fri, 10 Apr 2026 13:39:07 -0300
Subject: [PATCH] Fix S3 endpoint: add http:// prefix if missing

---
 src/core/shared/utils.rs | 15 +++++++++++----
 1 file changed, 11 insertions(+), 4 deletions(-)

diff --git a/src/core/shared/utils.rs b/src/core/shared/utils.rs
index b7a91b40..15bfa675 100644
--- a/src/core/shared/utils.rs
+++ b/src/core/shared/utils.rs
@@ -141,10 +141,17 @@ pub async fn create_s3_operator(
     config: &DriveConfig,
 ) -> Result<S3Client, Box<dyn std::error::Error>> {
     log::info!("Creating S3 operator with server: {}, access_key: {}", config.server, config.access_key);
-    let endpoint = if config.server.ends_with('/') {
-        config.server.clone()
-    } else {
-        format!("{}/", config.server)
+    let endpoint = {
+        let server = if config.server.starts_with("http://") || config.server.starts_with("https://") {
+            config.server.clone()
+        } else {
+            format!("http://{}", config.server)
+        };
+        if server.ends_with('/') {
+            server
+        } else {
+            format!("{}/", server)
+        }
     };
 
     let (access_key, secret_key) = if config.access_key.is_empty() || config.secret_key.is_empty() {