add more logging on jupiter fail (#345)

* add more details in log if jupiter operations fail
* changelog

1 files changed, 124 insertions, 0 deletions

diff --git a/src/zenserver/upstream/jupiter.cpp b/src/zenserver/upstream/jupiter.cpp
index 4cabcebf0..32537508c 100644
--- a/src/zenserver/upstream/jupiter.cpp
+++ b/src/zenserver/upstream/jupiter.cpp
@@ -284,6 +284,30 @@ CloudCacheSession::PutRef(std::string_view Namespace, std::string_view BucketId,
 	}
 	else
 	{
+		ZEN_WARN(
+			"CloudCacheSession::PutRef failed PUT. "
+			"Elapsed: {} s, "
+			"Uri: '{}', "
+			"Header-Authorization: '{} <redacted>', "
+			"Header-X-Jupiter-IoHash: '{}', "
+			"Header-ContentType: '{}', "
+			"ContentSize: {}, "
+			"Response.status_code: {}, "
+			"Response.reason: '{}', "
+			"Response.error.code: {}, "
+			"Response.error.message: '{}', "
+			"Resonse.raw_header: '{}'",
+			Response.elapsed,
+			Uri,
+			AccessToken.Value.substr(0, 6),
+			Hash.ToHexString(),
+			ContentType,
+			NiceBytes(Ref.Size()),
+			Response.status_code,
+			Response.reason,
+			gsl::narrow<int>(Response.error.code),
+			Response.error.message,
+			Response.raw_header);
 		Result.ErrorCode = Response.status_code;
 		Result.Reason	 = Response.reason;
 	}
@@ -329,6 +353,31 @@ CloudCacheSession::FinalizeRef(std::string_view Namespace, std::string_view Buck
 	}
 	else
 	{
+		ZEN_WARN(
+			"CloudCacheSession::FinalizeRef failed PUT. "
+			"Elapsed: {} s, "
+			"Uri: '{}', "
+			"Header-Authorization: '{} <redacted>', "
+			"Header-X-Jupiter-IoHash: '{}', "
+			"Header-ContentType: '{}', "
+			"ContentSize: {}, "
+			"Response.status_code: {}, "
+			"Response.reason: '{}', "
+			"Response.error.code: {}, "
+			"Response.error.message: '{}', "
+			"Resonse.raw_header: '{}'",
+			Response.elapsed,
+			Uri,
+			AccessToken.Value.substr(0, 6),
+			RefHash.ToHexString(),
+			"application/x-ue-cb",
+			NiceBytes(0),
+			Response.status_code,
+			Response.reason,
+			gsl::narrow<int>(Response.error.code),
+			Response.error.message,
+			Response.raw_header);
+
 		Result.ErrorCode = Response.status_code;
 		Result.Reason	 = Response.reason;
 	}
@@ -355,6 +404,31 @@ CloudCacheSession::PutBlob(std::string_view Namespace, const IoHash& Key, IoBuff
 	ZEN_DEBUG("PUT {}", Response);
 
 	CloudCacheResult Result = detail::ConvertResponse(Response);
+	if (!Result.Success)
+	{
+		ZEN_WARN(
+			"CloudCacheSession::PutBlob failed PUT. "
+			"Elapsed: {} s, "
+			"Uri: '{}', "
+			"Header-Authorization: '{} <redacted>', "
+			"Header-ContentType: '{}', "
+			"ContentSize: {}, "
+			"Response.status_code: {}, "
+			"Response.reason: '{}', "
+			"Response.error.code: {}, "
+			"Response.error.message: '{}', "
+			"Resonse.raw_header: '{}'",
+			Response.elapsed,
+			Uri,
+			AccessToken.Value.substr(0, 6),
+			"application/octet-stream",
+			NiceBytes(Blob.Size()),
+			Response.status_code,
+			Response.reason,
+			gsl::narrow<int>(Response.error.code),
+			Response.error.message,
+			Response.raw_header);
+	}
 	return Result;
 }
 
@@ -377,6 +451,31 @@ CloudCacheSession::PutCompressedBlob(std::string_view Namespace, const IoHash& K
 	ZEN_DEBUG("PUT {}", Response);
 
 	CloudCacheResult Result = detail::ConvertResponse(Response);
+	if (!Result.Success)
+	{
+		ZEN_WARN(
+			"CloudCacheSession::PutCompressedBlob failed PUT. "
+			"Elapsed: {} s, "
+			"Uri: '{}', "
+			"Header-Authorization: '{} <redacted>', "
+			"Header-ContentType: '{}', "
+			"ContentSize: {}, "
+			"Response.status_code: {}, "
+			"Response.reason: '{}', "
+			"Response.error.code: {}, "
+			"Response.error.message: '{}', "
+			"Resonse.raw_header: '{}'",
+			Response.elapsed,
+			Uri,
+			AccessToken.Value.substr(0, 6),
+			"application/x-ue-comp",
+			NiceBytes(Blob.Size()),
+			Response.status_code,
+			Response.reason,
+			gsl::narrow<int>(Response.error.code),
+			Response.error.message,
+			Response.raw_header);
+	}
 	return Result;
 }
 
@@ -408,6 +507,31 @@ CloudCacheSession::PutCompressedBlob(std::string_view Namespace, const IoHash& K
 	ZEN_DEBUG("PUT {}", Response);
 
 	CloudCacheResult Result = detail::ConvertResponse(Response);
+	if (!Result.Success)
+	{
+		ZEN_WARN(
+			"CloudCacheSession::PutCompressedBlob failed PUT. "
+			"Elapsed: {} s, "
+			"Uri: '{}', "
+			"Header-Authorization: '{} <redacted>', "
+			"Header-ContentType: '{}', "
+			"ContentSize: {}, "
+			"Response.status_code: {}, "
+			"Response.reason: '{}', "
+			"Response.error.code: {}, "
+			"Response.error.message: '{}', "
+			"Resonse.raw_header: '{}'",
+			Response.elapsed,
+			Uri,
+			AccessToken.Value.substr(0, 6),
+			"application/x-ue-comp",
+			NiceBytes(Payload.GetSize()),
+			Response.status_code,
+			Response.reason,
+			gsl::narrow<int>(Response.error.code),
+			Response.error.message,
+			Response.raw_header);
+	}
 	return Result;
 }