fix: adjust compression / data stream thresholds to not be inclusive

Author: 1egoman

src/room/rpc/RpcClientManager.ts

@@ -157,10 +157,10 @@ export default class RpcClientManager {
     const payloadBytes = byteLength(payload);
 
     let mode: 'regular' | 'compressed' | 'compressed-data-stream' = 'regular';
-    if (remoteClientProtocol >= CLIENT_PROTOCOL_GZIP_RPC && payloadBytes >= COMPRESS_MIN_BYTES) {
+    if (remoteClientProtocol >= CLIENT_PROTOCOL_GZIP_RPC && payloadBytes > COMPRESS_MIN_BYTES) {
       mode = 'compressed';
     }
-    if (mode === 'compressed' && payloadBytes >= DATA_STREAM_MIN_BYTES) {
+    if (mode === 'compressed' && payloadBytes > DATA_STREAM_MIN_BYTES) {
       mode = 'compressed-data-stream';
     }
 

src/room/rpc/RpcServerManager.ts

@@ -163,7 +163,7 @@ export default class RpcServerManager {
     // for lower TTFB
     if (
       callerClientProtocol >= CLIENT_PROTOCOL_GZIP_RPC &&
-      responseBytes >= DATA_STREAM_MIN_BYTES
+      responseBytes > DATA_STREAM_MIN_BYTES
     ) {
       const writer = await this.outgoingDataStreamManager.streamBytes({
         topic: RPC_DATA_STREAM_TOPIC,
@@ -180,7 +180,7 @@ export default class RpcServerManager {
     // Medium response: compress inline
     if (
       callerClientProtocol >= CLIENT_PROTOCOL_GZIP_RPC &&
-      responseBytes >= COMPRESS_MIN_BYTES
+      responseBytes > COMPRESS_MIN_BYTES
     ) {
       const compressed = await gzipCompress(response!);
       await this.engine.publishRpcResponseCompressed(callerIdentity, requestId, compressed);
@@ -283,7 +283,7 @@ export default class RpcServerManager {
 
     if (
       callerClientProtocol >= CLIENT_PROTOCOL_GZIP_RPC &&
-      responseBytes >= DATA_STREAM_MIN_BYTES
+      responseBytes > DATA_STREAM_MIN_BYTES
     ) {
       // Large response: create the data stream tagged with the request ID,
       // send the RPC response with empty payload, then stream compressed chunks
@@ -301,7 +301,7 @@ export default class RpcServerManager {
 
     if (
       callerClientProtocol >= CLIENT_PROTOCOL_GZIP_RPC &&
-      responseBytes >= COMPRESS_MIN_BYTES
+      responseBytes > COMPRESS_MIN_BYTES
     ) {
       // Medium response: compress inline
       const compressed = await gzipCompress(response);