Moved AcceptType Handling From ProjectStore To HttpProjectStore

1 files changed, 3 insertions, 58 deletions

diff --git a/src/zenserver/projectstore/projectstore.cpp b/src/zenserver/projectstore/projectstore.cpp
index 1132e458e..ea3f2aad9 100644
--- a/src/zenserver/projectstore/projectstore.cpp
+++ b/src/zenserver/projectstore/projectstore.cpp
@@ -4770,7 +4770,6 @@ std::pair<HttpResponseCode, std::string>
 ProjectStore::GetChunk(const std::string_view ProjectId,
 					   const std::string_view OplogId,
 					   const std::string_view Cid,
-					   ZenContentType		  AcceptType,
 					   IoBuffer&			  OutChunk,
 					   uint64_t*			  OptionalInOutModificationTag)
 {
@@ -4812,51 +4811,7 @@ ProjectStore::GetChunk(const std::string_view ProjectId,
 		}
 	}
 
-	if (AcceptType == ZenContentType::kUnknownContentType || AcceptType == ZenContentType::kBinary || AcceptType == ZenContentType::kJSON ||
-		AcceptType == ZenContentType::kYAML || AcceptType == ZenContentType::kCbObject)
-	{
-		CompressedBuffer Compressed			= CompressedBuffer::FromCompressedNoValidate(std::move(OutChunk));
-		IoBuffer		 DecompressedBuffer = Compressed.Decompress().AsIoBuffer();
-
-		if (AcceptType == ZenContentType::kJSON || AcceptType == ZenContentType::kYAML || AcceptType == ZenContentType::kCbObject)
-		{
-			CbValidateError CbErr = ValidateCompactBinary(DecompressedBuffer.GetView(), CbValidateMode::Default);
-			if (!!CbErr)
-			{
-				return {HttpResponseCode::NotAcceptable, fmt::format("chunk - '{}' WRONGTYPE", Cid)};
-			}
-
-			if (AcceptType == HttpContentType::kJSON || AcceptType == HttpContentType::kYAML)
-			{
-				CbObject					  ContainerObject = LoadCompactBinaryObject(DecompressedBuffer);
-				ExtendableStringBuilder<1024> Sb;
-				if (AcceptType == HttpContentType::kJSON)
-				{
-					ContainerObject.ToJson(Sb);
-				}
-				else if (AcceptType == HttpContentType::kYAML)
-				{
-					ContainerObject.ToYaml(Sb);
-				}
-				IoBuffer SerializedBuffer(IoBuffer::Clone, Sb.Data(), Sb.Size());
-				OutChunk = SerializedBuffer;
-			}
-			else
-			{
-				OutChunk = DecompressedBuffer;
-			}
-			OutChunk.SetContentType(AcceptType);
-		}
-		else
-		{
-			OutChunk = DecompressedBuffer;
-			OutChunk.SetContentType(ZenContentType::kBinary);
-		}
-	}
-	else
-	{
-		OutChunk.SetContentType(ZenContentType::kCompressedBinary);
-	}
+	OutChunk.SetContentType(ZenContentType::kCompressedBinary);
 	return {HttpResponseCode::OK, {}};
 }
 
@@ -8551,12 +8506,7 @@ TEST_CASE("project.store.partial.read")
 		uint64_t ModificationTag = 0;
 		IoBuffer Chunk;
 		CHECK(ProjectStore
-				  .GetChunk("proj1"sv,
-							"oplog1"sv,
-							Attachments[OpIds[1]][0].second.DecodeRawHash().ToHexString(),
-							HttpContentType::kCompressedBinary,
-							Chunk,
-							&ModificationTag)
+				  .GetChunk("proj1"sv, "oplog1"sv, Attachments[OpIds[1]][0].second.DecodeRawHash().ToHexString(), Chunk, &ModificationTag)
 				  .first == HttpResponseCode::OK);
 		IoHash			 RawHash;
 		uint64_t		 RawSize;
@@ -8565,12 +8515,7 @@ TEST_CASE("project.store.partial.read")
 
 		CHECK(ModificationTag != 0);
 		CHECK(ProjectStore
-				  .GetChunk("proj1"sv,
-							"oplog1"sv,
-							Attachments[OpIds[1]][0].second.DecodeRawHash().ToHexString(),
-							HttpContentType::kCompressedBinary,
-							Chunk,
-							&ModificationTag)
+				  .GetChunk("proj1"sv, "oplog1"sv, Attachments[OpIds[1]][0].second.DecodeRawHash().ToHexString(), Chunk, &ModificationTag)
 				  .first == HttpResponseCode::NotModified);
 	}