truncate unexpected response from server if it is too long

Author: glasstiger

src/sender.ts

@@ -174,7 +174,10 @@ class Sender {
   async close() {
     const pos = this.buffer.currentPosition();
     if (pos > 0) {
-      this.log("warn", `Buffer contains data which has not been flushed, and it will be lost [position=${pos}]`);
+      this.log(
+        "warn",
+        `Buffer contains data which has not been flushed, and it will be lost [position=${pos}]`,
+      );
     }
     return this.transport.close();
   }

src/transport/http/stdlib.ts

@@ -92,10 +92,12 @@ class HttpTransport extends HttpTransportBase {
         if (statusCode === HTTP_NO_CONTENT) {
           response.on("end", () => {
             if (body.length > 0) {
-              this.log(
-                "warn",
-                `Unexpected message from server: ${Buffer.concat(body)}`,
-              );
+              const message = Buffer.concat(body).toString();
+              const logMessage =
+                message.length < 256
+                  ? message
+                  : `${message.substring(0, 256)}... (truncated, full length=${message.length})`;
+              this.log("warn", `Unexpected message from server: ${logMessage}`);
             }
             resolve(true);
           });

src/transport/http/undici.ts

@@ -139,10 +139,12 @@ class UndiciTransport extends HttpTransportBase {
     const body = await responseData.body.arrayBuffer();
     if (statusCode === HTTP_NO_CONTENT) {
       if (body.byteLength > 0) {
-        this.log(
-          "warn",
-          `Unexpected message from server: ${Buffer.from(body).toString()}`,
-        );
+        const message = Buffer.from(body).toString();
+        const logMessage =
+          message.length < 256
+            ? message
+            : `${message.substring(0, 256)}... (truncated, full length=${message.length})`;
+        this.log("warn", `Unexpected message from server: ${logMessage}`);
       }
       return true;
     } else {

test/sender.transport.test.ts

@@ -598,10 +598,10 @@ describe("Sender TCP suite", function () {
 
     // add another line to the buffer without calling flush()
     await sender
-        .table("test")
-        .symbol("location", "gb")
-        .floatColumn("temperature", 16.4)
-        .at(1658484775000000000n, "ns");
+      .table("test")
+      .symbol("location", "gb")
+      .floatColumn("temperature", 16.4)
+      .at(1658484775000000000n, "ns");
 
     // assert that only the first line was sent
     await assertSentData(