add extened info in log on all jupiter operation (#350)

1 files changed, 273 insertions, 7 deletions

diff --git a/src/zenserver/upstream/jupiter.cpp b/src/zenserver/upstream/jupiter.cpp
index 0f810ea2b..3ff8525d1 100644
--- a/src/zenserver/upstream/jupiter.cpp
+++ b/src/zenserver/upstream/jupiter.cpp
@@ -133,6 +133,29 @@ CloudCacheSession::GetRef(std::string_view Namespace, std::string_view BucketId,
 	{
 		Result.Response = IoBufferBuilder::MakeCloneFromMemory(Response.text.data(), Response.text.size());
 	}
+	else
+	{
+		ZEN_WARN(
+			"CloudCacheSession::GetRef failed GET. "
+			"Elapsed: {} s, "
+			"Uri: '{}', "
+			"Header-Authorization: '{} <redacted>', "
+			"Header-Accept: '{}', "
+			"Response.status_code: {}, "
+			"Response.reason: '{}', "
+			"Response.error.code: {}, "
+			"Response.error.message: '{}', "
+			"Resonse.raw_header: '{}'",
+			Response.elapsed,
+			Uri,
+			AccessToken.Value.substr(0, 6),
+			ContentType,
+			Response.status_code,
+			Response.reason,
+			gsl::narrow<int>(Response.error.code),
+			Response.error.message,
+			Response.raw_header);
+	}
 	return Result;
 }
 
@@ -157,6 +180,29 @@ CloudCacheSession::GetBlob(std::string_view Namespace, const IoHash& Key)
 	{
 		Result.Response = IoBufferBuilder::MakeCloneFromMemory(Response.text.data(), Response.text.size());
 	}
+	else
+	{
+		ZEN_WARN(
+			"CloudCacheSession::GetBlob failed GET. "
+			"Elapsed: {} s, "
+			"Uri: '{}', "
+			"Header-Authorization: '{} <redacted>', "
+			"Header-Accept: '{}', "
+			"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",
+			Response.status_code,
+			Response.reason,
+			gsl::narrow<int>(Response.error.code),
+			Response.error.message,
+			Response.raw_header);
+	}
 	return Result;
 }
 
@@ -183,6 +229,29 @@ CloudCacheSession::GetCompressedBlob(std::string_view Namespace, const IoHash& K
 	{
 		Result.Response = IoBufferBuilder::MakeCloneFromMemory(Response.text.data(), Response.text.size());
 	}
+	else
+	{
+		ZEN_WARN(
+			"CloudCacheSession::GetCompressedBlob failed GET. "
+			"Elapsed: {} s, "
+			"Uri: '{}', "
+			"Header-Authorization: '{} <redacted>', "
+			"Header-Accept: '{}', "
+			"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",
+			Response.status_code,
+			Response.reason,
+			gsl::narrow<int>(Response.error.code),
+			Response.error.message,
+			Response.raw_header);
+	}
 	return Result;
 }
 
@@ -209,6 +278,29 @@ CloudCacheSession::GetInlineBlob(std::string_view Namespace, std::string_view Bu
 	{
 		Result.Response = IoBufferBuilder::MakeCloneFromMemory(Response.text.data(), Response.text.size());
 	}
+	else
+	{
+		ZEN_WARN(
+			"CloudCacheSession::GetInlineBlob failed GET. "
+			"Elapsed: {} s, "
+			"Uri: '{}', "
+			"Header-Authorization: '{} <redacted>', "
+			"Header-Accept: '{}', "
+			"Response.status_code: {}, "
+			"Response.reason: '{}', "
+			"Response.error.code: {}, "
+			"Response.error.message: '{}', "
+			"Resonse.raw_header: '{}'",
+			Response.elapsed,
+			Uri,
+			AccessToken.Value.substr(0, 6),
+			"application/x-jupiter-inline",
+			Response.status_code,
+			Response.reason,
+			gsl::narrow<int>(Response.error.code),
+			Response.error.message,
+			Response.raw_header);
+	}
 
 	if (auto It = Response.header.find("X-Jupiter-InlinePayloadHash"); It != Response.header.end())
 	{
@@ -245,6 +337,29 @@ CloudCacheSession::GetObject(std::string_view Namespace, const IoHash& Key)
 	{
 		Result.Response = IoBufferBuilder::MakeCloneFromMemory(Response.text.data(), Response.text.size());
 	}
+	else
+	{
+		ZEN_WARN(
+			"CloudCacheSession::GetObject failed GET. "
+			"Elapsed: {} s, "
+			"Uri: '{}', "
+			"Header-Authorization: '{} <redacted>', "
+			"Header-Accept: '{}', "
+			"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-cb",
+			Response.status_code,
+			Response.reason,
+			gsl::narrow<int>(Response.error.code),
+			Response.error.message,
+			Response.raw_header);
+	}
 
 	return Result;
 }
@@ -312,8 +427,6 @@ CloudCacheSession::PutRef(std::string_view Namespace, std::string_view BucketId,
 			gsl::narrow<int>(Response.error.code),
 			Response.error.message,
 			Response.raw_header);
-		Result.ErrorCode = Response.status_code;
-		Result.Reason	 = Response.reason;
 	}
 
 	return Result;
@@ -381,9 +494,6 @@ CloudCacheSession::FinalizeRef(std::string_view Namespace, std::string_view Buck
 			gsl::narrow<int>(Response.error.code),
 			Response.error.message,
 			Response.raw_header);
-
-		Result.ErrorCode = Response.status_code;
-		Result.Reason	 = Response.reason;
 	}
 
 	return Result;
@@ -575,6 +685,31 @@ CloudCacheSession::PutObject(std::string_view Namespace, const IoHash& Key, IoBu
 	ZEN_DEBUG("PUT {}", Response);
 
 	CloudCacheResult Result = detail::ConvertResponse(Response);
+	if (!Result.Success)
+	{
+		ZEN_WARN(
+			"CloudCacheSession::PutObject 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-cb",
+			NiceBytes(Object.GetSize()),
+			Response.status_code,
+			Response.reason,
+			gsl::narrow<int>(Response.error.code),
+			Response.error.message,
+			Response.raw_header);
+	}
 	return Result;
 }
 
@@ -597,6 +732,27 @@ CloudCacheSession::RefExists(std::string_view Namespace, std::string_view Bucket
 	ZEN_DEBUG("HEAD {}", Response);
 
 	CloudCacheResult Result = detail::ConvertResponse(Response);
+	if (!Result.Success)
+	{
+		ZEN_WARN(
+			"CloudCacheSession::RefExists failed PUT. "
+			"Elapsed: {} s, "
+			"Uri: '{}', "
+			"Header-Authorization: '{} <redacted>', "
+			"Response.status_code: {}, "
+			"Response.reason: '{}', "
+			"Response.error.code: {}, "
+			"Response.error.message: '{}', "
+			"Resonse.raw_header: '{}'",
+			Response.elapsed,
+			Uri,
+			AccessToken.Value.substr(0, 6),
+			Response.status_code,
+			Response.reason,
+			gsl::narrow<int>(Response.error.code),
+			Response.error.message,
+			Response.raw_header);
+	}
 	return Result;
 }
 
@@ -631,8 +787,26 @@ CloudCacheSession::GetObjectReferences(std::string_view Namespace, const IoHash&
 	}
 	else
 	{
-		Result.ErrorCode = gsl::narrow<int32_t>(Response.status_code);
-		Result.Reason	 = Response.reason;
+		ZEN_WARN(
+			"CloudCacheSession::GetObjectReferences failed PUT. "
+			"Elapsed: {} s, "
+			"Uri: '{}', "
+			"Header-Authorization: '{} <redacted>', "
+			"Header-Accept: '{}', "
+			"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-cb",
+			Response.status_code,
+			Response.reason,
+			gsl::narrow<int>(Response.error.code),
+			Response.error.message,
+			Response.raw_header);
 	}
 
 	return Result;
@@ -693,6 +867,29 @@ CloudCacheSession::PostComputeTasks(IoBuffer TasksData)
 	ZEN_DEBUG("POST {}", Response);
 
 	CloudCacheResult Result = detail::ConvertResponse(Response);
+	if (!Result.Success)
+	{
+		ZEN_WARN(
+			"CloudCacheSession::PostComputeTasks failed GET. "
+			"Elapsed: {} s, "
+			"Uri: '{}', "
+			"Header-Authorization: '{} <redacted>', "
+			"Header-Accept: '{}', "
+			"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-cb",
+			Response.status_code,
+			Response.reason,
+			gsl::narrow<int>(Response.error.code),
+			Response.error.message,
+			Response.raw_header);
+	}
 	return Result;
 }
 
@@ -721,6 +918,29 @@ CloudCacheSession::GetComputeUpdates(std::string_view ChannelId, const uint32_t
 	{
 		Result.Response = IoBufferBuilder::MakeCloneFromMemory(Response.text.data(), Response.text.size());
 	}
+	else
+	{
+		ZEN_WARN(
+			"CloudCacheSession::GetComputeUpdates failed GET. "
+			"Elapsed: {} s, "
+			"Uri: '{}', "
+			"Header-Authorization: '{} <redacted>', "
+			"Header-Accept: '{}', "
+			"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-cb",
+			Response.status_code,
+			Response.reason,
+			gsl::narrow<int>(Response.error.code),
+			Response.error.message,
+			Response.raw_header);
+	}
 
 	return Result;
 }
@@ -768,6 +988,29 @@ CloudCacheSession::CacheTypeExists(std::string_view Namespace, std::string_view
 	ZEN_DEBUG("HEAD {}", Response);
 
 	CloudCacheResult Result = detail::ConvertResponse(Response);
+	if (!Result.Success)
+	{
+		ZEN_WARN(
+			"CloudCacheSession::CacheTypeExists failed GET. "
+			"Elapsed: {} s, "
+			"Uri: '{}', "
+			"Header-Authorization: '{} <redacted>', "
+			"Header-Accept: '{}', "
+			"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-cb",
+			Response.status_code,
+			Response.reason,
+			gsl::narrow<int>(Response.error.code),
+			Response.error.message,
+			Response.raw_header);
+	}
 	return Result;
 }
 
@@ -808,6 +1051,29 @@ CloudCacheSession::CacheTypeExists(std::string_view Namespace, std::string_view
 			Result.Needs.insert(Item.AsHash());
 		}
 	}
+	else
+	{
+		ZEN_WARN(
+			"CloudCacheSession::CacheTypeExists failed GET. "
+			"Elapsed: {} s, "
+			"Uri: '{}', "
+			"Header-Authorization: '{} <redacted>', "
+			"Header-Accept: '{}', "
+			"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-cb",
+			Response.status_code,
+			Response.reason,
+			gsl::narrow<int>(Response.error.code),
+			Response.error.message,
+			Response.raw_header);
+	}
 
 	return Result;
 }