Remove all event stream length validations

Author: lauzadis

runtime/protocol/aws-event-stream/common/src/aws/smithy/kotlin/runtime/awsprotocol/eventstream/Message.kt

@@ -12,15 +12,9 @@ import aws.smithy.kotlin.runtime.text.encoding.encodeToHex
 
 internal const val MESSAGE_CRC_BYTE_LEN = 4
 
-// max message size is 16 MB
-internal const val MAX_MESSAGE_SIZE = 16 * 1024 * 1024
-
-// max header size is 128 KB
-internal const val MAX_HEADER_SIZE = 128 * 1024
-
 /*
     Message Wire Format
-    See also: https://docs.aws.amazon.com/transcribe/latest/dg/event-stream-med.html
+    See also: https://docs.aws.amazon.com/transcribe/latest/dg/streaming-setting-up.html
 
     +--------------------------------------------------------------------+   --
     |                            Total Len (32)                          |     |
@@ -49,7 +43,6 @@ public data class Message(val headers: List<Header>, val payload: ByteArray) {
          */
         public fun decode(source: SdkBufferedSource): Message {
             val totalLen = source.peek().use { it.readInt().toUInt() }
-            check(totalLen <= MAX_MESSAGE_SIZE.toUInt()) { "Invalid Message size: $totalLen" }
 
             // Limiting the amount of data read by SdkBufferedSource is tricky and cause incorrect CRC
             // if not careful (e.g. creating a buffered source of a HashingSource will usually lead to incorrect results
@@ -117,8 +110,6 @@ public data class Message(val headers: List<Header>, val payload: ByteArray) {
         val payloadLen = payload.size
 
         val messageLen = PRELUDE_BYTE_LEN_WITH_CRC + headersLen + payloadLen + MESSAGE_CRC_BYTE_LEN
-        check(headersLen < MAX_HEADER_SIZE) { "Invalid Headers length: $headersLen" }
-        check(messageLen < MAX_MESSAGE_SIZE) { "Invalid Message length: $messageLen" }
 
         val prelude = Prelude(messageLen.toInt(), headersLen.toInt())
 

runtime/protocol/aws-event-stream/common/src/aws/smithy/kotlin/runtime/awsprotocol/eventstream/Prelude.kt

@@ -56,8 +56,6 @@ public data class Prelude(val totalLen: Int, val headersLength: Int) {
             val totalLen = buffer.readInt()
             val headerLen = buffer.readInt()
 
-            check(totalLen <= MAX_MESSAGE_SIZE) { "Invalid Message size: $totalLen" }
-            check(headerLen <= MAX_HEADER_SIZE) { "Invalid Header size: $headerLen" }
             check(expectedCrc.contentEquals(computedCrc)) {
                 "Prelude checksum mismatch; expected=0x${expectedCrc.encodeToHex()}; calculated=0x${computedCrc.encodeToHex()}"
             }