Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 843d53587c | |||
| c0db3919a6 |
+5
-5
@@ -446,7 +446,7 @@ function smartpack(
|
||||
)::Tuple{msg_envelope_v1, String} where {T1<:Any}
|
||||
|
||||
# Log start of send operation
|
||||
log_trace(correlation_id, "Starting smartpack for subject: $subject")
|
||||
# log_trace(correlation_id, "Starting smartpack for subject: $subject")
|
||||
|
||||
# Process each payload in the list
|
||||
payloads = msg_payload_v1[]
|
||||
@@ -826,7 +826,7 @@ function smartunpack(
|
||||
|
||||
# Parse the JSON envelope
|
||||
env_json_obj = JSON.parse(msg_json_str)
|
||||
log_trace(env_json_obj["correlation_id"], "Processing received message") # Log message processing start
|
||||
# log_trace(env_json_obj["correlation_id"], "Processing received message") # Log message processing start
|
||||
|
||||
# Process all payloads in the envelope
|
||||
payloads_list = Tuple{String, Any, String}[]
|
||||
@@ -840,7 +840,7 @@ function smartunpack(
|
||||
dataname = String(payload["dataname"])
|
||||
|
||||
if transport == "direct" # Direct transport - payload is in the message
|
||||
log_trace(env_json_obj["correlation_id"], "Direct transport - decoding payload '$dataname'") # Log direct transport handling
|
||||
# log_trace(env_json_obj["correlation_id"], "Direct transport - decoding payload '$dataname'") # Log direct transport handling
|
||||
|
||||
# Extract base64 payload from the payload
|
||||
payload_b64 = String(payload["data"])
|
||||
@@ -856,7 +856,7 @@ function smartunpack(
|
||||
elseif transport == "link" # Link transport - payload is at URL
|
||||
# Extract download URL from the payload
|
||||
url = String(payload["data"])
|
||||
log_trace(env_json_obj["correlation_id"], "Link transport - fetching '$dataname' from URL: $url") # Log link transport handling
|
||||
# log_trace(env_json_obj["correlation_id"], "Link transport - fetching '$dataname' from URL: $url") # Log link transport handling
|
||||
|
||||
# Fetch with exponential backoff using the download handler
|
||||
downloaded_data = fileserver_download_handler(url, max_retries, base_delay, max_delay, env_json_obj["correlation_id"])
|
||||
@@ -917,7 +917,7 @@ function _fetch_with_backoff(
|
||||
try
|
||||
response = HTTP.request("GET", url) # Make HTTP GET request to URL
|
||||
if response.status == 200 # Check if request was successful
|
||||
log_trace(correlation_id, "Successfully fetched data from $url on attempt $attempt") # Log success
|
||||
# log_trace(correlation_id, "Successfully fetched data from $url on attempt $attempt") # Log success
|
||||
return response.body # Return response body as bytes
|
||||
else # Request failed
|
||||
error("Failed to fetch: $(response.status)") # Throw error for non-200 status
|
||||
|
||||
Reference in New Issue
Block a user